Package org.voltdb.catalog

Examples of org.voltdb.catalog.ProcParameter.fullName()

119
120
121
122
123
124
125
126
127
128
129
            } catch (ParseException ex) {
                LOG.error("Invalid parameter #" + i + ": " + params[i], ex);
                return (null);
            }
            if (LOG.isDebugEnabled())
                LOG.debug(String.format("%s: %s [%s / %s]", catalog_param.fullName(),
                                                            (catalog_param.getIsarray() ? Arrays.toString((Object[])parameters[i]) : parameters[i]),
                                                            vt, parameters[i].getClass()));
        } // FOR
       
        LOG.info(String.format("Invoking %s [params=%s]",
View Full Code Here
363
364
365
366
367
368
369
370
371
372
373
                } else {
                    catalog_param = catalog_proc.getParameters().get(param_idx);
                }
                this.cache_procPartitionParameters.put(catalog_proc, catalog_param);
                if (debug.val)
                    LOG.debug(catalog_proc + " ProcParameter Cache: " + (catalog_param != null ? catalog_param.fullName() : catalog_param));
            }
        } // FOR

        for (Table catalog_tbl : this.catalogContext.database.getTables()) {
            if (catalog_tbl.getSystable())
View Full Code Here
927
928
929
930
931
932
933
934
935
936
937
                LOG.debug(Arrays.toString(hashes) + " => " + partition);
        }
        // Single ProcParameter
        else {
            if (debug.val)
                LOG.debug("Calculating base partition using " + catalog_param.fullName() + ": " + params[catalog_param.getIndex()]);
            assert(catalog_param.getIndex() >= 0) : "Invalid parameter offset " + catalog_param.fullName();
            partition = this.calculatePartition(catalog_proc, params[catalog_param.getIndex()], is_array);
        }
        return (partition);
    }
View Full Code Here
928
929
930
931
932
933
934
935
936
937
938
        }
        // Single ProcParameter
        else {
            if (debug.val)
                LOG.debug("Calculating base partition using " + catalog_param.fullName() + ": " + params[catalog_param.getIndex()]);
            assert(catalog_param.getIndex() >= 0) : "Invalid parameter offset " + catalog_param.fullName();
            partition = this.calculatePartition(catalog_proc, params[catalog_param.getIndex()], is_array);
        }
        return (partition);
    }
View Full Code Here
157
158
159
160
161
162
163
164
165
166
167
                        }
                    } // FOR
                    if (field.equals("procparameter")) {
                        ProcParameter proc_param = ((StmtParameter)catalog_obj).getProcparameter();
                        if (proc_param != null) {
                            m[0].put(field, proc_param.fullName());
                        }
                    }
                }
            } // FOR
        } else {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.