00001
00002
00003 JniProxyVisitTable<FemVisitor> FemVisitor::visitTbl;
00004
00005 jmethodID ProxyAggInvocation::meth_getAggStreamDef = 0;
00006 jmethodID ProxyAggInvocation::meth_getFunction = 0;
00007 jmethodID ProxyAggInvocation::meth_getInputAttributeIndex = 0;
00008 jmethodID ProxyAggStreamDef::meth_getAggInvocation = 0;
00009 jmethodID ProxyAggStreamDef::meth_getGroupingPrefixSize = 0;
00010 jmethodID ProxyBarrierStreamDef::meth_getDynamicParameter = 0;
00011 jmethodID ProxyBarrierStreamDef::meth_getReturnMode = 0;
00012 jmethodID ProxyBeginTxnCmd::meth_getResultHandle = 0;
00013 jmethodID ProxyBernoulliSamplingStreamDef::meth_getRepeatableSeed = 0;
00014 jmethodID ProxyBernoulliSamplingStreamDef::meth_isRepeatable = 0;
00015 jmethodID ProxyBernoulliSamplingStreamDef::meth_getSamplingRate = 0;
00016 jmethodID ProxyBufferingTupleStreamDef::meth_isInMemory = 0;
00017 jmethodID ProxyBufferingTupleStreamDef::meth_isMultipass = 0;
00018 jmethodID ProxyCalcTupleStreamDef::meth_isFilter = 0;
00019 jmethodID ProxyCalcTupleStreamDef::meth_getProgram = 0;
00020 jmethodID ProxyCartesianProductStreamDef::meth_isLeftOuter = 0;
00021 jmethodID ProxyCmdAlterSystemDeallocate::meth_getOldestLabelCsn = 0;
00022 jmethodID ProxyCmdBeginTxn::meth_isReadOnly = 0;
00023 jmethodID ProxyCmdBeginTxnWithCsn::meth_getCsnHandle = 0;
00024 jmethodID ProxyCmdCheckpoint::meth_isAsync = 0;
00025 jmethodID ProxyCmdCheckpoint::meth_isFuzzy = 0;
00026 jmethodID ProxyCmdCompleteBackup::meth_getLowerBoundCsn = 0;
00027 jmethodID ProxyCmdCompleteBackup::meth_getUpperBoundCsn = 0;
00028 jmethodID ProxyCmdCreateExecutionStreamGraph::meth_getResultHandle = 0;
00029 jmethodID ProxyCmdCreateStreamHandle::meth_isInput = 0;
00030 jmethodID ProxyCmdCreateStreamHandle::meth_getResultHandle = 0;
00031 jmethodID ProxyCmdCreateStreamHandle::meth_getStreamName = 0;
00032 jmethodID ProxyCmdInitiateBackup::meth_getBackupPathname = 0;
00033 jmethodID ProxyCmdInitiateBackup::meth_isCheckSpaceRequirements = 0;
00034 jmethodID ProxyCmdInitiateBackup::meth_getCompressionProgram = 0;
00035 jmethodID ProxyCmdInitiateBackup::meth_getLowerBoundCsn = 0;
00036 jmethodID ProxyCmdInitiateBackup::meth_getResultDataDeviceSize = 0;
00037 jmethodID ProxyCmdInitiateBackup::meth_setResultDataDeviceSize = 0;
00038 jmethodID ProxyCmdInitiateBackup::meth_getSpacePadding = 0;
00039 jmethodID ProxyCmdOpenDatabase::meth_isCreateDatabase = 0;
00040 jmethodID ProxyCmdOpenDatabase::meth_getParams = 0;
00041 jmethodID ProxyCmdOpenDatabase::meth_getResultHandle = 0;
00042 jmethodID ProxyCmdOpenDatabase::meth_isResultRecoveryRequired = 0;
00043 jmethodID ProxyCmdOpenDatabase::meth_setResultRecoveryRequired = 0;
00044 jmethodID ProxyCmdPrepareExecutionStreamGraph::meth_getDegreeOfParallelism = 0;
00045 jmethodID ProxyCmdPrepareExecutionStreamGraph::meth_getStreamDefs = 0;
00046 jmethodID ProxyCmdRestoreFromBackup::meth_getBackupPathname = 0;
00047 jmethodID ProxyCmdRestoreFromBackup::meth_getCompressionProgram = 0;
00048 jmethodID ProxyCmdRestoreFromBackup::meth_getFileSize = 0;
00049 jmethodID ProxyCmdRestoreFromBackup::meth_getLowerBoundCsn = 0;
00050 jmethodID ProxyCmdRestoreFromBackup::meth_getUpperBoundCsn = 0;
00051 jmethodID ProxyCmdSavepoint::meth_getResultHandle = 0;
00052 jmethodID ProxyCmdSetParam::meth_getParam = 0;
00053 jmethodID ProxyCmdVerifyIndex::meth_isEstimate = 0;
00054 jmethodID ProxyCmdVerifyIndex::meth_isIncludeTuples = 0;
00055 jmethodID ProxyCmdVerifyIndex::meth_getResultPageCount = 0;
00056 jmethodID ProxyCmdVerifyIndex::meth_setResultPageCount = 0;
00057 jmethodID ProxyCmdVerifyIndex::meth_getResultUniqueKeyCount = 0;
00058 jmethodID ProxyCmdVerifyIndex::meth_setResultUniqueKeyCount = 0;
00059 jmethodID ProxyCmdVersionIndexRoot::meth_getNewRootPageId = 0;
00060 jmethodID ProxyCmdVersionIndexRoot::meth_getOldRootPageId = 0;
00061 jmethodID ProxyColumnName::meth_getFlatFile = 0;
00062 jmethodID ProxyColumnName::meth_getName = 0;
00063 jmethodID ProxyCorrelation::meth_getId = 0;
00064 jmethodID ProxyCorrelation::meth_getIndexSearch = 0;
00065 jmethodID ProxyCorrelation::meth_getNestedLoopJoin = 0;
00066 jmethodID ProxyCorrelation::meth_getOffset = 0;
00067 jmethodID ProxyCorrelationJoinStreamDef::meth_getCorrelations = 0;
00068 jmethodID ProxyCsnHandleReturningCmd::meth_getResultHandle = 0;
00069 jmethodID ProxyDatabaseCmd::meth_getDbHandle = 0;
00070 jmethodID ProxyDatabaseParam::meth_getName = 0;
00071 jmethodID ProxyDatabaseParam::meth_getValue = 0;
00072 jmethodID ProxyDynamicParamUse::meth_getDynamicParamId = 0;
00073 jmethodID ProxyDynamicParamUse::meth_getExecutionStreamDef = 0;
00074 jmethodID ProxyDynamicParamUse::meth_isRead = 0;
00075 jmethodID ProxyDynamicParameter::meth_getBarrier = 0;
00076 jmethodID ProxyDynamicParameter::meth_getParameterId = 0;
00077 jmethodID ProxyEndTxnCmd::meth_getSvptHandle = 0;
00078 jmethodID ProxyExecStreamDataFlow::meth_getConsumer = 0;
00079 jmethodID ProxyExecStreamDataFlow::meth_isImplicit = 0;
00080 jmethodID ProxyExecStreamDataFlow::meth_getProducer = 0;
00081 jmethodID ProxyExecutionStreamDef::meth_getDynamicParamUse = 0;
00082 jmethodID ProxyExecutionStreamDef::meth_getInputFlow = 0;
00083 jmethodID ProxyExecutionStreamDef::meth_getName = 0;
00084 jmethodID ProxyExecutionStreamDef::meth_getOutputDesc = 0;
00085 jmethodID ProxyExecutionStreamDef::meth_getOutputFlow = 0;
00086 jmethodID ProxyFlatFileTupleStreamDef::meth_getCalcProgram = 0;
00087 jmethodID ProxyFlatFileTupleStreamDef::meth_getCodePage = 0;
00088 jmethodID ProxyFlatFileTupleStreamDef::meth_getColumn = 0;
00089 jmethodID ProxyFlatFileTupleStreamDef::meth_getDataFilePath = 0;
00090 jmethodID ProxyFlatFileTupleStreamDef::meth_getErrorFilePath = 0;
00091 jmethodID ProxyFlatFileTupleStreamDef::meth_getEscapeCharacter = 0;
00092 jmethodID ProxyFlatFileTupleStreamDef::meth_getFieldDelimiter = 0;
00093 jmethodID ProxyFlatFileTupleStreamDef::meth_isHasHeader = 0;
00094 jmethodID ProxyFlatFileTupleStreamDef::meth_isLenient = 0;
00095 jmethodID ProxyFlatFileTupleStreamDef::meth_isMapped = 0;
00096 jmethodID ProxyFlatFileTupleStreamDef::meth_getNumRowsScan = 0;
00097 jmethodID ProxyFlatFileTupleStreamDef::meth_getQuoteCharacter = 0;
00098 jmethodID ProxyFlatFileTupleStreamDef::meth_getRowDelimiter = 0;
00099 jmethodID ProxyFlatFileTupleStreamDef::meth_getSubstituteCharacter = 0;
00100 jmethodID ProxyFlatFileTupleStreamDef::meth_isTranslationRecovery = 0;
00101 jmethodID ProxyFlatFileTupleStreamDef::meth_isTrim = 0;
00102 jmethodID ProxyGenericStreamDef::meth_getContent = 0;
00103 jmethodID ProxyGenericStreamDef::meth_getType = 0;
00104 jmethodID ProxyHandle::meth_getLongHandle = 0;
00105 jmethodID ProxyIndexAccessCmd::meth_getRootPageId = 0;
00106 jmethodID ProxyIndexAccessorDef::meth_getIndexId = 0;
00107 jmethodID ProxyIndexAccessorDef::meth_isReadOnlyCommittedData = 0;
00108 jmethodID ProxyIndexAccessorDef::meth_getRootPageIdParamId = 0;
00109 jmethodID ProxyIndexAccessorDef::meth_getRootPageId = 0;
00110 jmethodID ProxyIndexAccessorDef::meth_getSegmentId = 0;
00111 jmethodID ProxyIndexAccessorDef::meth_getTupleDesc = 0;
00112 jmethodID ProxyIndexCmd::meth_getIndexId = 0;
00113 jmethodID ProxyIndexCmd::meth_getKeyProj = 0;
00114 jmethodID ProxyIndexCmd::meth_getLeafPageIdProj = 0;
00115 jmethodID ProxyIndexCmd::meth_getSegmentId = 0;
00116 jmethodID ProxyIndexCmd::meth_getTupleDesc = 0;
00117 jmethodID ProxyIndexLoaderDef::meth_getDistinctness = 0;
00118 jmethodID ProxyIndexLoaderDef::meth_isMonotonic = 0;
00119 jmethodID ProxyIndexScanDef::meth_getOutputProj = 0;
00120 jmethodID ProxyIndexSearchDef::meth_getInputDirectiveProj = 0;
00121 jmethodID ProxyIndexSearchDef::meth_getInputJoinProj = 0;
00122 jmethodID ProxyIndexSearchDef::meth_getInputKeyProj = 0;
00123 jmethodID ProxyIndexSearchDef::meth_isOuterJoin = 0;
00124 jmethodID ProxyIndexSearchDef::meth_isPrefetch = 0;
00125 jmethodID ProxyIndexSearchDef::meth_getSearchKeyParameter = 0;
00126 jmethodID ProxyIndexSearchDef::meth_isUniqueKey = 0;
00127 jmethodID ProxyIndexWriterDef::meth_getDistinctness = 0;
00128 jmethodID ProxyIndexWriterDef::meth_getInputProj = 0;
00129 jmethodID ProxyIndexWriterDef::meth_getTableWriter = 0;
00130 jmethodID ProxyIndexWriterDef::meth_isUpdateInPlace = 0;
00131 jmethodID ProxyJavaSinkStreamDef::meth_getStreamId = 0;
00132 jmethodID ProxyJavaTransformStreamDef::meth_getJavaClassName = 0;
00133 jmethodID ProxyJavaTransformStreamDef::meth_getReserved = 0;
00134 jmethodID ProxyJavaTransformStreamDef::meth_getStreamId = 0;
00135 jmethodID ProxyKeyAccessorDef::meth_getKeyProj = 0;
00136 jmethodID ProxyLbmBitOpStreamDef::meth_getRowLimitParamId = 0;
00137 jmethodID ProxyLbmBitOpStreamDef::meth_getStartRidParamId = 0;
00138 jmethodID ProxyLbmChopperStreamDef::meth_getRidLimitParamId = 0;
00139 jmethodID ProxyLbmGeneratorStreamDef::meth_isCreateIndex = 0;
00140 jmethodID ProxyLbmGeneratorStreamDef::meth_getInsertRowCountParamId = 0;
00141 jmethodID ProxyLbmSearchStreamDef::meth_getRowLimitParamId = 0;
00142 jmethodID ProxyLbmSearchStreamDef::meth_getStartRidParamId = 0;
00143 jmethodID ProxyLbmSplicerStreamDef::meth_isCreateNewIndex = 0;
00144 jmethodID ProxyLbmSplicerStreamDef::meth_getIndexAccessor = 0;
00145 jmethodID ProxyLbmSplicerStreamDef::meth_getInsertRowCountParamId = 0;
00146 jmethodID ProxyLbmSplicerStreamDef::meth_getWriteRowCountParamId = 0;
00147 jmethodID ProxyLbmUnionStreamDef::meth_getConsumerSridParamId = 0;
00148 jmethodID ProxyLbmUnionStreamDef::meth_getRidLimitParamId = 0;
00149 jmethodID ProxyLbmUnionStreamDef::meth_getSegmentLimitParamId = 0;
00150 jmethodID ProxyLcsClusterAppendStreamDef::meth_getClusterColProj = 0;
00151 jmethodID ProxyLcsClusterScanDef::meth_getClusterTupleDesc = 0;
00152 jmethodID ProxyLcsClusterScanDef::meth_getRowScan = 0;
00153 jmethodID ProxyLcsRowScanStreamDef::meth_getClusterScan = 0;
00154 jmethodID ProxyLcsRowScanStreamDef::meth_isFullScan = 0;
00155 jmethodID ProxyLcsRowScanStreamDef::meth_isHasExtraFilter = 0;
00156 jmethodID ProxyLcsRowScanStreamDef::meth_getOutputProj = 0;
00157 jmethodID ProxyLcsRowScanStreamDef::meth_getResidualFilterColumns = 0;
00158 jmethodID ProxyLcsRowScanStreamDef::meth_getSamplingClumps = 0;
00159 jmethodID ProxyLcsRowScanStreamDef::meth_getSamplingMode = 0;
00160 jmethodID ProxyLcsRowScanStreamDef::meth_getSamplingRate = 0;
00161 jmethodID ProxyLcsRowScanStreamDef::meth_getSamplingRepeatableSeed = 0;
00162 jmethodID ProxyLcsRowScanStreamDef::meth_isSamplingRepeatable = 0;
00163 jmethodID ProxyLcsRowScanStreamDef::meth_getSamplingRowCount = 0;
00164 jmethodID ProxyLhxAggStreamDef::meth_getCndGroupByKeys = 0;
00165 jmethodID ProxyLhxAggStreamDef::meth_getNumRows = 0;
00166 jmethodID ProxyLhxJoinStreamDef::meth_getCndBuildKeys = 0;
00167 jmethodID ProxyLhxJoinStreamDef::meth_getFilterNullProj = 0;
00168 jmethodID ProxyLhxJoinStreamDef::meth_isLeftInner = 0;
00169 jmethodID ProxyLhxJoinStreamDef::meth_getLeftKeyProj = 0;
00170 jmethodID ProxyLhxJoinStreamDef::meth_isLeftOuter = 0;
00171 jmethodID ProxyLhxJoinStreamDef::meth_getNumBuildRows = 0;
00172 jmethodID ProxyLhxJoinStreamDef::meth_isRightInner = 0;
00173 jmethodID ProxyLhxJoinStreamDef::meth_getRightKeyProj = 0;
00174 jmethodID ProxyLhxJoinStreamDef::meth_isRightOuter = 0;
00175 jmethodID ProxyLhxJoinStreamDef::meth_isSetopAll = 0;
00176 jmethodID ProxyLhxJoinStreamDef::meth_isSetopDistinct = 0;
00177 jmethodID ProxyMergeStreamDef::meth_isPrePullInputs = 0;
00178 jmethodID ProxyMergeStreamDef::meth_isSequential = 0;
00179 jmethodID ProxyMockTupleStreamDef::meth_getRowCount = 0;
00180 jmethodID ProxyMultiUseBufferingStreamDef::meth_getReaderRefCountParamId = 0;
00181 jmethodID ProxyNestedLoopJoinStreamDef::meth_getLeftJoinKey = 0;
00182 jmethodID ProxyReshapeParameter::meth_getCompareOffset = 0;
00183 jmethodID ProxyReshapeParameter::meth_getDynamicParamId = 0;
00184 jmethodID ProxyReshapeParameter::meth_isOutputParam = 0;
00185 jmethodID ProxyReshapeParameter::meth_getReshape = 0;
00186 jmethodID ProxyReshapeStreamDef::meth_getCompareOp = 0;
00187 jmethodID ProxyReshapeStreamDef::meth_getInputCompareProjection = 0;
00188 jmethodID ProxyReshapeStreamDef::meth_getOutputProjection = 0;
00189 jmethodID ProxyReshapeStreamDef::meth_getReshapeParameter = 0;
00190 jmethodID ProxyReshapeStreamDef::meth_getTupleCompareBytesBase64 = 0;
00191 jmethodID ProxySortingStreamDef::meth_getDescendingProj = 0;
00192 jmethodID ProxySortingStreamDef::meth_getDistinctness = 0;
00193 jmethodID ProxySortingStreamDef::meth_isEarlyClose = 0;
00194 jmethodID ProxySortingStreamDef::meth_getEstimatedNumRows = 0;
00195 jmethodID ProxySplicerIndexAccessorDef::meth_getSplicer = 0;
00196 jmethodID ProxyTableUpdaterDef::meth_getUpdateProj = 0;
00197 jmethodID ProxyTableWriterDef::meth_getIndexWriter = 0;
00198 jmethodID ProxyTupleAccessor::meth_getAttrAccessor = 0;
00199 jmethodID ProxyTupleAccessor::meth_getBitFieldOffset = 0;
00200 jmethodID ProxyTupleAccessor::meth_getMinByteLength = 0;
00201 jmethodID ProxyTupleAttrAccessor::meth_getBitValueIndex = 0;
00202 jmethodID ProxyTupleAttrAccessor::meth_getEndIndirectOffset = 0;
00203 jmethodID ProxyTupleAttrAccessor::meth_getFixedOffset = 0;
00204 jmethodID ProxyTupleAttrAccessor::meth_getNullBitIndex = 0;
00205 jmethodID ProxyTupleAttrDescriptor::meth_getByteLength = 0;
00206 jmethodID ProxyTupleAttrDescriptor::meth_isNullable = 0;
00207 jmethodID ProxyTupleAttrDescriptor::meth_getTypeOrdinal = 0;
00208 jmethodID ProxyTupleAttrProjection::meth_getAttributeIndex = 0;
00209 jmethodID ProxyTupleDescriptor::meth_getAttrDescriptor = 0;
00210 jmethodID ProxyTupleProjection::meth_getAttrProjection = 0;
00211 jmethodID ProxyTupleStreamGraphCmd::meth_getStreamGraphHandle = 0;
00212 jmethodID ProxyTxnCmd::meth_getTxnHandle = 0;
00213 jmethodID ProxyValuesStreamDef::meth_getTupleBytesBase64 = 0;
00214 jmethodID ProxyWindowDef::meth_getOffset = 0;
00215 jmethodID ProxyWindowDef::meth_getOrderKeyList = 0;
00216 jmethodID ProxyWindowDef::meth_getPartition = 0;
00217 jmethodID ProxyWindowDef::meth_isPhysical = 0;
00218 jmethodID ProxyWindowDef::meth_getRange = 0;
00219 jmethodID ProxyWindowDef::meth_getWindowStream = 0;
00220 jmethodID ProxyWindowPartitionDef::meth_getAddProgram = 0;
00221 jmethodID ProxyWindowPartitionDef::meth_getBucketDesc = 0;
00222 jmethodID ProxyWindowPartitionDef::meth_getDropProgram = 0;
00223 jmethodID ProxyWindowPartitionDef::meth_getInitializeProgram = 0;
00224 jmethodID ProxyWindowPartitionDef::meth_getPartitionKeyList = 0;
00225 jmethodID ProxyWindowPartitionDef::meth_getWindow = 0;
00226 jmethodID ProxyWindowStreamDef::meth_isFilter = 0;
00227 jmethodID ProxyWindowStreamDef::meth_getInputOrderKeyList = 0;
00228 jmethodID ProxyWindowStreamDef::meth_getOutputProgram = 0;
00229 jmethodID ProxyWindowStreamDef::meth_getWindow = 0;
00230 void staticInitFem(JniEnvRef pEnv,JniProxyVisitTableBase &visitTbl)
00231 {
00232 jclass jClass;
00233 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemAggInvocation");
00234 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyAggInvocation>));
00235 ProxyAggInvocation::meth_getAggStreamDef = pEnv->GetMethodID(jClass,"getAggStreamDef","()Lnet/sf/farrago/fem/fennel/FemAggStreamDef;");
00236 ProxyAggInvocation::meth_getFunction = pEnv->GetMethodID(jClass,"getFunction","()Lnet/sf/farrago/fem/fennel/AggFunction;");
00237 ProxyAggInvocation::meth_getInputAttributeIndex = pEnv->GetMethodID(jClass,"getInputAttributeIndex","()I");
00238
00239 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemAggStreamDef");
00240 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyAggStreamDef>));
00241 ProxyAggStreamDef::meth_getAggInvocation = pEnv->GetMethodID(jClass,"getAggInvocation","()Ljava/util/Collection;");
00242 ProxyAggStreamDef::meth_getGroupingPrefixSize = pEnv->GetMethodID(jClass,"getGroupingPrefixSize","()I");
00243
00244 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemBarrierStreamDef");
00245 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyBarrierStreamDef>));
00246 ProxyBarrierStreamDef::meth_getDynamicParameter = pEnv->GetMethodID(jClass,"getDynamicParameter","()Ljava/util/List;");
00247 ProxyBarrierStreamDef::meth_getReturnMode = pEnv->GetMethodID(jClass,"getReturnMode","()Lnet/sf/farrago/fem/fennel/BarrierReturnMode;");
00248
00249 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemBeginTxnCmd");
00250 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyBeginTxnCmd>));
00251 ProxyBeginTxnCmd::meth_getResultHandle = pEnv->GetMethodID(jClass,"getResultHandle","()Lnet/sf/farrago/fem/fennel/FemTxnHandle;");
00252
00253 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemBernoulliSamplingStreamDef");
00254 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyBernoulliSamplingStreamDef>));
00255 ProxyBernoulliSamplingStreamDef::meth_getRepeatableSeed = pEnv->GetMethodID(jClass,"getRepeatableSeed","()I");
00256 ProxyBernoulliSamplingStreamDef::meth_isRepeatable = pEnv->GetMethodID(jClass,"isRepeatable","()Z");
00257 ProxyBernoulliSamplingStreamDef::meth_getSamplingRate = pEnv->GetMethodID(jClass,"getSamplingRate","()F");
00258
00259 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemBufferReaderStreamDef");
00260 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyBufferReaderStreamDef>));
00261
00262 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemBufferWriterStreamDef");
00263 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyBufferWriterStreamDef>));
00264
00265 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemBufferingTupleStreamDef");
00266 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyBufferingTupleStreamDef>));
00267 ProxyBufferingTupleStreamDef::meth_isInMemory = pEnv->GetMethodID(jClass,"isInMemory","()Z");
00268 ProxyBufferingTupleStreamDef::meth_isMultipass = pEnv->GetMethodID(jClass,"isMultipass","()Z");
00269
00270 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCalcTupleStreamDef");
00271 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCalcTupleStreamDef>));
00272 ProxyCalcTupleStreamDef::meth_isFilter = pEnv->GetMethodID(jClass,"isFilter","()Z");
00273 ProxyCalcTupleStreamDef::meth_getProgram = pEnv->GetMethodID(jClass,"getProgram","()Ljava/lang/String;");
00274
00275 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCartesianProductStreamDef");
00276 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCartesianProductStreamDef>));
00277 ProxyCartesianProductStreamDef::meth_isLeftOuter = pEnv->GetMethodID(jClass,"isLeftOuter","()Z");
00278
00279 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmd");
00280 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmd>));
00281
00282 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdAbandonBackup");
00283 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdAbandonBackup>));
00284
00285 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdAlterSystemDeallocate");
00286 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdAlterSystemDeallocate>));
00287 ProxyCmdAlterSystemDeallocate::meth_getOldestLabelCsn = pEnv->GetMethodID(jClass,"getOldestLabelCsn","()J");
00288
00289 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdBeginTxn");
00290 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdBeginTxn>));
00291 ProxyCmdBeginTxn::meth_isReadOnly = pEnv->GetMethodID(jClass,"isReadOnly","()Z");
00292
00293 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdBeginTxnWithCsn");
00294 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdBeginTxnWithCsn>));
00295 ProxyCmdBeginTxnWithCsn::meth_getCsnHandle = pEnv->GetMethodID(jClass,"getCsnHandle","()Lnet/sf/farrago/fem/fennel/FemCsnHandle;");
00296
00297 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdCheckpoint");
00298 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdCheckpoint>));
00299 ProxyCmdCheckpoint::meth_isAsync = pEnv->GetMethodID(jClass,"isAsync","()Z");
00300 ProxyCmdCheckpoint::meth_isFuzzy = pEnv->GetMethodID(jClass,"isFuzzy","()Z");
00301
00302 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdCloseDatabase");
00303 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdCloseDatabase>));
00304
00305 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdCommit");
00306 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdCommit>));
00307
00308 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdCompleteBackup");
00309 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdCompleteBackup>));
00310 ProxyCmdCompleteBackup::meth_getLowerBoundCsn = pEnv->GetMethodID(jClass,"getLowerBoundCsn","()J");
00311 ProxyCmdCompleteBackup::meth_getUpperBoundCsn = pEnv->GetMethodID(jClass,"getUpperBoundCsn","()J");
00312
00313 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdCreateExecutionStreamGraph");
00314 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdCreateExecutionStreamGraph>));
00315 ProxyCmdCreateExecutionStreamGraph::meth_getResultHandle = pEnv->GetMethodID(jClass,"getResultHandle","()Lnet/sf/farrago/fem/fennel/FemStreamGraphHandle;");
00316
00317 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdCreateIndex");
00318 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdCreateIndex>));
00319
00320 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdCreateStreamHandle");
00321 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdCreateStreamHandle>));
00322 ProxyCmdCreateStreamHandle::meth_isInput = pEnv->GetMethodID(jClass,"isInput","()Z");
00323 ProxyCmdCreateStreamHandle::meth_getResultHandle = pEnv->GetMethodID(jClass,"getResultHandle","()Lnet/sf/farrago/fem/fennel/FemStreamHandle;");
00324 ProxyCmdCreateStreamHandle::meth_getStreamName = pEnv->GetMethodID(jClass,"getStreamName","()Ljava/lang/String;");
00325
00326 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdDropIndex");
00327 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdDropIndex>));
00328
00329 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdGetLastCommittedTxnId");
00330 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdGetLastCommittedTxnId>));
00331
00332 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdGetTxnCsn");
00333 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdGetTxnCsn>));
00334
00335 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdInitiateBackup");
00336 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdInitiateBackup>));
00337 ProxyCmdInitiateBackup::meth_getBackupPathname = pEnv->GetMethodID(jClass,"getBackupPathname","()Ljava/lang/String;");
00338 ProxyCmdInitiateBackup::meth_isCheckSpaceRequirements = pEnv->GetMethodID(jClass,"isCheckSpaceRequirements","()Z");
00339 ProxyCmdInitiateBackup::meth_getCompressionProgram = pEnv->GetMethodID(jClass,"getCompressionProgram","()Ljava/lang/String;");
00340 ProxyCmdInitiateBackup::meth_getLowerBoundCsn = pEnv->GetMethodID(jClass,"getLowerBoundCsn","()J");
00341 ProxyCmdInitiateBackup::meth_getResultDataDeviceSize = pEnv->GetMethodID(jClass,"getResultDataDeviceSize","()Ljava/lang/Long;");
00342 ProxyCmdInitiateBackup::meth_setResultDataDeviceSize = pEnv->GetMethodID(jClass,"setResultDataDeviceSize","(Ljava/lang/Long;)V");
00343 ProxyCmdInitiateBackup::meth_getSpacePadding = pEnv->GetMethodID(jClass,"getSpacePadding","()J");
00344
00345 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdOpenDatabase");
00346 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdOpenDatabase>));
00347 ProxyCmdOpenDatabase::meth_isCreateDatabase = pEnv->GetMethodID(jClass,"isCreateDatabase","()Z");
00348 ProxyCmdOpenDatabase::meth_getParams = pEnv->GetMethodID(jClass,"getParams","()Ljava/util/Collection;");
00349 ProxyCmdOpenDatabase::meth_getResultHandle = pEnv->GetMethodID(jClass,"getResultHandle","()Lnet/sf/farrago/fem/fennel/FemDbHandle;");
00350 ProxyCmdOpenDatabase::meth_isResultRecoveryRequired = pEnv->GetMethodID(jClass,"isResultRecoveryRequired","()Ljava/lang/Boolean;");
00351 ProxyCmdOpenDatabase::meth_setResultRecoveryRequired = pEnv->GetMethodID(jClass,"setResultRecoveryRequired","(Ljava/lang/Boolean;)V");
00352
00353 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdPrepareExecutionStreamGraph");
00354 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdPrepareExecutionStreamGraph>));
00355 ProxyCmdPrepareExecutionStreamGraph::meth_getDegreeOfParallelism = pEnv->GetMethodID(jClass,"getDegreeOfParallelism","()I");
00356 ProxyCmdPrepareExecutionStreamGraph::meth_getStreamDefs = pEnv->GetMethodID(jClass,"getStreamDefs","()Ljava/util/Collection;");
00357
00358 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdRestoreFromBackup");
00359 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdRestoreFromBackup>));
00360 ProxyCmdRestoreFromBackup::meth_getBackupPathname = pEnv->GetMethodID(jClass,"getBackupPathname","()Ljava/lang/String;");
00361 ProxyCmdRestoreFromBackup::meth_getCompressionProgram = pEnv->GetMethodID(jClass,"getCompressionProgram","()Ljava/lang/String;");
00362 ProxyCmdRestoreFromBackup::meth_getFileSize = pEnv->GetMethodID(jClass,"getFileSize","()J");
00363 ProxyCmdRestoreFromBackup::meth_getLowerBoundCsn = pEnv->GetMethodID(jClass,"getLowerBoundCsn","()J");
00364 ProxyCmdRestoreFromBackup::meth_getUpperBoundCsn = pEnv->GetMethodID(jClass,"getUpperBoundCsn","()J");
00365
00366 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdRollback");
00367 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdRollback>));
00368
00369 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdSavepoint");
00370 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdSavepoint>));
00371 ProxyCmdSavepoint::meth_getResultHandle = pEnv->GetMethodID(jClass,"getResultHandle","()Lnet/sf/farrago/fem/fennel/FemSvptHandle;");
00372
00373 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdSetParam");
00374 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdSetParam>));
00375 ProxyCmdSetParam::meth_getParam = pEnv->GetMethodID(jClass,"getParam","()Lnet/sf/farrago/fem/fennel/FemDatabaseParam;");
00376
00377 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdTruncateIndex");
00378 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdTruncateIndex>));
00379
00380 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdVerifyIndex");
00381 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdVerifyIndex>));
00382 ProxyCmdVerifyIndex::meth_isEstimate = pEnv->GetMethodID(jClass,"isEstimate","()Z");
00383 ProxyCmdVerifyIndex::meth_isIncludeTuples = pEnv->GetMethodID(jClass,"isIncludeTuples","()Z");
00384 ProxyCmdVerifyIndex::meth_getResultPageCount = pEnv->GetMethodID(jClass,"getResultPageCount","()Ljava/lang/Long;");
00385 ProxyCmdVerifyIndex::meth_setResultPageCount = pEnv->GetMethodID(jClass,"setResultPageCount","(Ljava/lang/Long;)V");
00386 ProxyCmdVerifyIndex::meth_getResultUniqueKeyCount = pEnv->GetMethodID(jClass,"getResultUniqueKeyCount","()Ljava/lang/Long;");
00387 ProxyCmdVerifyIndex::meth_setResultUniqueKeyCount = pEnv->GetMethodID(jClass,"setResultUniqueKeyCount","(Ljava/lang/Long;)V");
00388
00389 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdVersionIndexRoot");
00390 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCmdVersionIndexRoot>));
00391 ProxyCmdVersionIndexRoot::meth_getNewRootPageId = pEnv->GetMethodID(jClass,"getNewRootPageId","()J");
00392 ProxyCmdVersionIndexRoot::meth_getOldRootPageId = pEnv->GetMethodID(jClass,"getOldRootPageId","()J");
00393
00394 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCollectTupleStreamDef");
00395 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCollectTupleStreamDef>));
00396
00397 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemColumnName");
00398 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyColumnName>));
00399 ProxyColumnName::meth_getFlatFile = pEnv->GetMethodID(jClass,"getFlatFile","()Lnet/sf/farrago/fem/fennel/FemFlatFileTupleStreamDef;");
00400 ProxyColumnName::meth_getName = pEnv->GetMethodID(jClass,"getName","()Ljava/lang/String;");
00401
00402 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCorrelation");
00403 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCorrelation>));
00404 ProxyCorrelation::meth_getId = pEnv->GetMethodID(jClass,"getId","()I");
00405 ProxyCorrelation::meth_getIndexSearch = pEnv->GetMethodID(jClass,"getIndexSearch","()Lnet/sf/farrago/fem/fennel/FemIndexSearchDef;");
00406 ProxyCorrelation::meth_getNestedLoopJoin = pEnv->GetMethodID(jClass,"getNestedLoopJoin","()Lnet/sf/farrago/fem/fennel/FemNestedLoopJoinStreamDef;");
00407 ProxyCorrelation::meth_getOffset = pEnv->GetMethodID(jClass,"getOffset","()I");
00408
00409 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCorrelationJoinStreamDef");
00410 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCorrelationJoinStreamDef>));
00411 ProxyCorrelationJoinStreamDef::meth_getCorrelations = pEnv->GetMethodID(jClass,"getCorrelations","()Ljava/util/Collection;");
00412
00413 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCsnHandle");
00414 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCsnHandle>));
00415
00416 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCsnHandleReturningCmd");
00417 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyCsnHandleReturningCmd>));
00418 ProxyCsnHandleReturningCmd::meth_getResultHandle = pEnv->GetMethodID(jClass,"getResultHandle","()Lnet/sf/farrago/fem/fennel/FemCsnHandle;");
00419
00420 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemDatabaseCmd");
00421 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyDatabaseCmd>));
00422 ProxyDatabaseCmd::meth_getDbHandle = pEnv->GetMethodID(jClass,"getDbHandle","()Lnet/sf/farrago/fem/fennel/FemDbHandle;");
00423
00424 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemDatabaseParam");
00425 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyDatabaseParam>));
00426 ProxyDatabaseParam::meth_getName = pEnv->GetMethodID(jClass,"getName","()Ljava/lang/String;");
00427 ProxyDatabaseParam::meth_getValue = pEnv->GetMethodID(jClass,"getValue","()Ljava/lang/String;");
00428
00429 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemDbHandle");
00430 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyDbHandle>));
00431
00432 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemDynamicParamUse");
00433 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyDynamicParamUse>));
00434 ProxyDynamicParamUse::meth_getDynamicParamId = pEnv->GetMethodID(jClass,"getDynamicParamId","()I");
00435 ProxyDynamicParamUse::meth_getExecutionStreamDef = pEnv->GetMethodID(jClass,"getExecutionStreamDef","()Lnet/sf/farrago/fem/fennel/FemExecutionStreamDef;");
00436 ProxyDynamicParamUse::meth_isRead = pEnv->GetMethodID(jClass,"isRead","()Z");
00437
00438 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemDynamicParameter");
00439 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyDynamicParameter>));
00440 ProxyDynamicParameter::meth_getBarrier = pEnv->GetMethodID(jClass,"getBarrier","()Lnet/sf/farrago/fem/fennel/FemBarrierStreamDef;");
00441 ProxyDynamicParameter::meth_getParameterId = pEnv->GetMethodID(jClass,"getParameterId","()I");
00442
00443 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemEndTxnCmd");
00444 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyEndTxnCmd>));
00445 ProxyEndTxnCmd::meth_getSvptHandle = pEnv->GetMethodID(jClass,"getSvptHandle","()Lnet/sf/farrago/fem/fennel/FemSvptHandle;");
00446
00447 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemExecStreamDataFlow");
00448 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyExecStreamDataFlow>));
00449 ProxyExecStreamDataFlow::meth_getConsumer = pEnv->GetMethodID(jClass,"getConsumer","()Lnet/sf/farrago/fem/fennel/FemExecutionStreamDef;");
00450 ProxyExecStreamDataFlow::meth_isImplicit = pEnv->GetMethodID(jClass,"isImplicit","()Z");
00451 ProxyExecStreamDataFlow::meth_getProducer = pEnv->GetMethodID(jClass,"getProducer","()Lnet/sf/farrago/fem/fennel/FemExecutionStreamDef;");
00452
00453 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemExecutionStreamDef");
00454 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyExecutionStreamDef>));
00455 ProxyExecutionStreamDef::meth_getDynamicParamUse = pEnv->GetMethodID(jClass,"getDynamicParamUse","()Ljava/util/Collection;");
00456 ProxyExecutionStreamDef::meth_getInputFlow = pEnv->GetMethodID(jClass,"getInputFlow","()Ljava/util/List;");
00457 ProxyExecutionStreamDef::meth_getName = pEnv->GetMethodID(jClass,"getName","()Ljava/lang/String;");
00458 ProxyExecutionStreamDef::meth_getOutputDesc = pEnv->GetMethodID(jClass,"getOutputDesc","()Lnet/sf/farrago/fem/fennel/FemTupleDescriptor;");
00459 ProxyExecutionStreamDef::meth_getOutputFlow = pEnv->GetMethodID(jClass,"getOutputFlow","()Ljava/util/List;");
00460
00461 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemFlatFileTupleStreamDef");
00462 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyFlatFileTupleStreamDef>));
00463 ProxyFlatFileTupleStreamDef::meth_getCalcProgram = pEnv->GetMethodID(jClass,"getCalcProgram","()Ljava/lang/String;");
00464 ProxyFlatFileTupleStreamDef::meth_getCodePage = pEnv->GetMethodID(jClass,"getCodePage","()I");
00465 ProxyFlatFileTupleStreamDef::meth_getColumn = pEnv->GetMethodID(jClass,"getColumn","()Ljava/util/List;");
00466 ProxyFlatFileTupleStreamDef::meth_getDataFilePath = pEnv->GetMethodID(jClass,"getDataFilePath","()Ljava/lang/String;");
00467 ProxyFlatFileTupleStreamDef::meth_getErrorFilePath = pEnv->GetMethodID(jClass,"getErrorFilePath","()Ljava/lang/String;");
00468 ProxyFlatFileTupleStreamDef::meth_getEscapeCharacter = pEnv->GetMethodID(jClass,"getEscapeCharacter","()Ljava/lang/String;");
00469 ProxyFlatFileTupleStreamDef::meth_getFieldDelimiter = pEnv->GetMethodID(jClass,"getFieldDelimiter","()Ljava/lang/String;");
00470 ProxyFlatFileTupleStreamDef::meth_isHasHeader = pEnv->GetMethodID(jClass,"isHasHeader","()Z");
00471 ProxyFlatFileTupleStreamDef::meth_isLenient = pEnv->GetMethodID(jClass,"isLenient","()Z");
00472 ProxyFlatFileTupleStreamDef::meth_isMapped = pEnv->GetMethodID(jClass,"isMapped","()Z");
00473 ProxyFlatFileTupleStreamDef::meth_getNumRowsScan = pEnv->GetMethodID(jClass,"getNumRowsScan","()I");
00474 ProxyFlatFileTupleStreamDef::meth_getQuoteCharacter = pEnv->GetMethodID(jClass,"getQuoteCharacter","()Ljava/lang/String;");
00475 ProxyFlatFileTupleStreamDef::meth_getRowDelimiter = pEnv->GetMethodID(jClass,"getRowDelimiter","()Ljava/lang/String;");
00476 ProxyFlatFileTupleStreamDef::meth_getSubstituteCharacter = pEnv->GetMethodID(jClass,"getSubstituteCharacter","()Ljava/lang/String;");
00477 ProxyFlatFileTupleStreamDef::meth_isTranslationRecovery = pEnv->GetMethodID(jClass,"isTranslationRecovery","()Z");
00478 ProxyFlatFileTupleStreamDef::meth_isTrim = pEnv->GetMethodID(jClass,"isTrim","()Z");
00479
00480 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemGenericStreamDef");
00481 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyGenericStreamDef>));
00482 ProxyGenericStreamDef::meth_getContent = pEnv->GetMethodID(jClass,"getContent","()Ljava/lang/String;");
00483 ProxyGenericStreamDef::meth_getType = pEnv->GetMethodID(jClass,"getType","()Ljava/lang/String;");
00484
00485 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemHandle");
00486 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyHandle>));
00487 ProxyHandle::meth_getLongHandle = pEnv->GetMethodID(jClass,"getLongHandle","()J");
00488
00489 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemIndexAccessCmd");
00490 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyIndexAccessCmd>));
00491 ProxyIndexAccessCmd::meth_getRootPageId = pEnv->GetMethodID(jClass,"getRootPageId","()J");
00492
00493 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemIndexAccessorDef");
00494 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyIndexAccessorDef>));
00495 ProxyIndexAccessorDef::meth_getIndexId = pEnv->GetMethodID(jClass,"getIndexId","()J");
00496 ProxyIndexAccessorDef::meth_isReadOnlyCommittedData = pEnv->GetMethodID(jClass,"isReadOnlyCommittedData","()Z");
00497 ProxyIndexAccessorDef::meth_getRootPageIdParamId = pEnv->GetMethodID(jClass,"getRootPageIdParamId","()I");
00498 ProxyIndexAccessorDef::meth_getRootPageId = pEnv->GetMethodID(jClass,"getRootPageId","()J");
00499 ProxyIndexAccessorDef::meth_getSegmentId = pEnv->GetMethodID(jClass,"getSegmentId","()J");
00500 ProxyIndexAccessorDef::meth_getTupleDesc = pEnv->GetMethodID(jClass,"getTupleDesc","()Lnet/sf/farrago/fem/fennel/FemTupleDescriptor;");
00501
00502 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemIndexCmd");
00503 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyIndexCmd>));
00504 ProxyIndexCmd::meth_getIndexId = pEnv->GetMethodID(jClass,"getIndexId","()J");
00505 ProxyIndexCmd::meth_getKeyProj = pEnv->GetMethodID(jClass,"getKeyProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00506 ProxyIndexCmd::meth_getLeafPageIdProj = pEnv->GetMethodID(jClass,"getLeafPageIdProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00507 ProxyIndexCmd::meth_getSegmentId = pEnv->GetMethodID(jClass,"getSegmentId","()J");
00508 ProxyIndexCmd::meth_getTupleDesc = pEnv->GetMethodID(jClass,"getTupleDesc","()Lnet/sf/farrago/fem/fennel/FemTupleDescriptor;");
00509
00510 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemIndexLoaderDef");
00511 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyIndexLoaderDef>));
00512 ProxyIndexLoaderDef::meth_getDistinctness = pEnv->GetMethodID(jClass,"getDistinctness","()Lnet/sf/farrago/fem/fennel/Distinctness;");
00513 ProxyIndexLoaderDef::meth_isMonotonic = pEnv->GetMethodID(jClass,"isMonotonic","()Z");
00514
00515 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemIndexScanDef");
00516 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyIndexScanDef>));
00517 ProxyIndexScanDef::meth_getOutputProj = pEnv->GetMethodID(jClass,"getOutputProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00518
00519 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemIndexSearchDef");
00520 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyIndexSearchDef>));
00521 ProxyIndexSearchDef::meth_getInputDirectiveProj = pEnv->GetMethodID(jClass,"getInputDirectiveProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00522 ProxyIndexSearchDef::meth_getInputJoinProj = pEnv->GetMethodID(jClass,"getInputJoinProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00523 ProxyIndexSearchDef::meth_getInputKeyProj = pEnv->GetMethodID(jClass,"getInputKeyProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00524 ProxyIndexSearchDef::meth_isOuterJoin = pEnv->GetMethodID(jClass,"isOuterJoin","()Z");
00525 ProxyIndexSearchDef::meth_isPrefetch = pEnv->GetMethodID(jClass,"isPrefetch","()Z");
00526 ProxyIndexSearchDef::meth_getSearchKeyParameter = pEnv->GetMethodID(jClass,"getSearchKeyParameter","()Ljava/util/List;");
00527 ProxyIndexSearchDef::meth_isUniqueKey = pEnv->GetMethodID(jClass,"isUniqueKey","()Z");
00528
00529 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemIndexStreamDef");
00530 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyIndexStreamDef>));
00531
00532 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemIndexWriterDef");
00533 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyIndexWriterDef>));
00534 ProxyIndexWriterDef::meth_getDistinctness = pEnv->GetMethodID(jClass,"getDistinctness","()Lnet/sf/farrago/fem/fennel/Distinctness;");
00535 ProxyIndexWriterDef::meth_getInputProj = pEnv->GetMethodID(jClass,"getInputProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00536 ProxyIndexWriterDef::meth_getTableWriter = pEnv->GetMethodID(jClass,"getTableWriter","()Lnet/sf/farrago/fem/fennel/FemTableWriterDef;");
00537 ProxyIndexWriterDef::meth_isUpdateInPlace = pEnv->GetMethodID(jClass,"isUpdateInPlace","()Z");
00538
00539 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemJavaSinkStreamDef");
00540 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyJavaSinkStreamDef>));
00541 ProxyJavaSinkStreamDef::meth_getStreamId = pEnv->GetMethodID(jClass,"getStreamId","()I");
00542
00543 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemJavaTransformStreamDef");
00544 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyJavaTransformStreamDef>));
00545 ProxyJavaTransformStreamDef::meth_getJavaClassName = pEnv->GetMethodID(jClass,"getJavaClassName","()Ljava/lang/String;");
00546 ProxyJavaTransformStreamDef::meth_getReserved = pEnv->GetMethodID(jClass,"getReserved","()Ljava/lang/String;");
00547 ProxyJavaTransformStreamDef::meth_getStreamId = pEnv->GetMethodID(jClass,"getStreamId","()I");
00548
00549 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemKeyAccessorDef");
00550 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyKeyAccessorDef>));
00551 ProxyKeyAccessorDef::meth_getKeyProj = pEnv->GetMethodID(jClass,"getKeyProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00552
00553 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmBitOpStreamDef");
00554 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLbmBitOpStreamDef>));
00555 ProxyLbmBitOpStreamDef::meth_getRowLimitParamId = pEnv->GetMethodID(jClass,"getRowLimitParamId","()I");
00556 ProxyLbmBitOpStreamDef::meth_getStartRidParamId = pEnv->GetMethodID(jClass,"getStartRidParamId","()I");
00557
00558 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmChopperStreamDef");
00559 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLbmChopperStreamDef>));
00560 ProxyLbmChopperStreamDef::meth_getRidLimitParamId = pEnv->GetMethodID(jClass,"getRidLimitParamId","()I");
00561
00562 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmGeneratorStreamDef");
00563 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLbmGeneratorStreamDef>));
00564 ProxyLbmGeneratorStreamDef::meth_isCreateIndex = pEnv->GetMethodID(jClass,"isCreateIndex","()Z");
00565 ProxyLbmGeneratorStreamDef::meth_getInsertRowCountParamId = pEnv->GetMethodID(jClass,"getInsertRowCountParamId","()I");
00566
00567 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmIntersectStreamDef");
00568 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLbmIntersectStreamDef>));
00569
00570 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmMinusStreamDef");
00571 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLbmMinusStreamDef>));
00572
00573 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmNormalizerStreamDef");
00574 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLbmNormalizerStreamDef>));
00575
00576 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmSearchStreamDef");
00577 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLbmSearchStreamDef>));
00578 ProxyLbmSearchStreamDef::meth_getRowLimitParamId = pEnv->GetMethodID(jClass,"getRowLimitParamId","()I");
00579 ProxyLbmSearchStreamDef::meth_getStartRidParamId = pEnv->GetMethodID(jClass,"getStartRidParamId","()I");
00580
00581 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmSortedAggStreamDef");
00582 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLbmSortedAggStreamDef>));
00583
00584 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmSplicerStreamDef");
00585 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLbmSplicerStreamDef>));
00586 ProxyLbmSplicerStreamDef::meth_isCreateNewIndex = pEnv->GetMethodID(jClass,"isCreateNewIndex","()Z");
00587 ProxyLbmSplicerStreamDef::meth_getIndexAccessor = pEnv->GetMethodID(jClass,"getIndexAccessor","()Ljava/util/List;");
00588 ProxyLbmSplicerStreamDef::meth_getInsertRowCountParamId = pEnv->GetMethodID(jClass,"getInsertRowCountParamId","()I");
00589 ProxyLbmSplicerStreamDef::meth_getWriteRowCountParamId = pEnv->GetMethodID(jClass,"getWriteRowCountParamId","()I");
00590
00591 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmUnionStreamDef");
00592 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLbmUnionStreamDef>));
00593 ProxyLbmUnionStreamDef::meth_getConsumerSridParamId = pEnv->GetMethodID(jClass,"getConsumerSridParamId","()I");
00594 ProxyLbmUnionStreamDef::meth_getRidLimitParamId = pEnv->GetMethodID(jClass,"getRidLimitParamId","()I");
00595 ProxyLbmUnionStreamDef::meth_getSegmentLimitParamId = pEnv->GetMethodID(jClass,"getSegmentLimitParamId","()I");
00596
00597 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLcsClusterAppendStreamDef");
00598 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLcsClusterAppendStreamDef>));
00599 ProxyLcsClusterAppendStreamDef::meth_getClusterColProj = pEnv->GetMethodID(jClass,"getClusterColProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00600
00601 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLcsClusterReplaceStreamDef");
00602 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLcsClusterReplaceStreamDef>));
00603
00604 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLcsClusterScanDef");
00605 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLcsClusterScanDef>));
00606 ProxyLcsClusterScanDef::meth_getClusterTupleDesc = pEnv->GetMethodID(jClass,"getClusterTupleDesc","()Lnet/sf/farrago/fem/fennel/FemTupleDescriptor;");
00607 ProxyLcsClusterScanDef::meth_getRowScan = pEnv->GetMethodID(jClass,"getRowScan","()Lnet/sf/farrago/fem/fennel/FemLcsRowScanStreamDef;");
00608
00609 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLcsRowScanStreamDef");
00610 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLcsRowScanStreamDef>));
00611 ProxyLcsRowScanStreamDef::meth_getClusterScan = pEnv->GetMethodID(jClass,"getClusterScan","()Ljava/util/List;");
00612 ProxyLcsRowScanStreamDef::meth_isFullScan = pEnv->GetMethodID(jClass,"isFullScan","()Z");
00613 ProxyLcsRowScanStreamDef::meth_isHasExtraFilter = pEnv->GetMethodID(jClass,"isHasExtraFilter","()Z");
00614 ProxyLcsRowScanStreamDef::meth_getOutputProj = pEnv->GetMethodID(jClass,"getOutputProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00615 ProxyLcsRowScanStreamDef::meth_getResidualFilterColumns = pEnv->GetMethodID(jClass,"getResidualFilterColumns","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00616 ProxyLcsRowScanStreamDef::meth_getSamplingClumps = pEnv->GetMethodID(jClass,"getSamplingClumps","()I");
00617 ProxyLcsRowScanStreamDef::meth_getSamplingMode = pEnv->GetMethodID(jClass,"getSamplingMode","()Lnet/sf/farrago/fem/fennel/TableSamplingMode;");
00618 ProxyLcsRowScanStreamDef::meth_getSamplingRate = pEnv->GetMethodID(jClass,"getSamplingRate","()F");
00619 ProxyLcsRowScanStreamDef::meth_getSamplingRepeatableSeed = pEnv->GetMethodID(jClass,"getSamplingRepeatableSeed","()I");
00620 ProxyLcsRowScanStreamDef::meth_isSamplingRepeatable = pEnv->GetMethodID(jClass,"isSamplingRepeatable","()Z");
00621 ProxyLcsRowScanStreamDef::meth_getSamplingRowCount = pEnv->GetMethodID(jClass,"getSamplingRowCount","()J");
00622
00623 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLhxAggStreamDef");
00624 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLhxAggStreamDef>));
00625 ProxyLhxAggStreamDef::meth_getCndGroupByKeys = pEnv->GetMethodID(jClass,"getCndGroupByKeys","()J");
00626 ProxyLhxAggStreamDef::meth_getNumRows = pEnv->GetMethodID(jClass,"getNumRows","()J");
00627
00628 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLhxJoinStreamDef");
00629 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyLhxJoinStreamDef>));
00630 ProxyLhxJoinStreamDef::meth_getCndBuildKeys = pEnv->GetMethodID(jClass,"getCndBuildKeys","()J");
00631 ProxyLhxJoinStreamDef::meth_getFilterNullProj = pEnv->GetMethodID(jClass,"getFilterNullProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00632 ProxyLhxJoinStreamDef::meth_isLeftInner = pEnv->GetMethodID(jClass,"isLeftInner","()Z");
00633 ProxyLhxJoinStreamDef::meth_getLeftKeyProj = pEnv->GetMethodID(jClass,"getLeftKeyProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00634 ProxyLhxJoinStreamDef::meth_isLeftOuter = pEnv->GetMethodID(jClass,"isLeftOuter","()Z");
00635 ProxyLhxJoinStreamDef::meth_getNumBuildRows = pEnv->GetMethodID(jClass,"getNumBuildRows","()J");
00636 ProxyLhxJoinStreamDef::meth_isRightInner = pEnv->GetMethodID(jClass,"isRightInner","()Z");
00637 ProxyLhxJoinStreamDef::meth_getRightKeyProj = pEnv->GetMethodID(jClass,"getRightKeyProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00638 ProxyLhxJoinStreamDef::meth_isRightOuter = pEnv->GetMethodID(jClass,"isRightOuter","()Z");
00639 ProxyLhxJoinStreamDef::meth_isSetopAll = pEnv->GetMethodID(jClass,"isSetopAll","()Z");
00640 ProxyLhxJoinStreamDef::meth_isSetopDistinct = pEnv->GetMethodID(jClass,"isSetopDistinct","()Z");
00641
00642 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemMergeStreamDef");
00643 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyMergeStreamDef>));
00644 ProxyMergeStreamDef::meth_isPrePullInputs = pEnv->GetMethodID(jClass,"isPrePullInputs","()Z");
00645 ProxyMergeStreamDef::meth_isSequential = pEnv->GetMethodID(jClass,"isSequential","()Z");
00646
00647 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemMockTupleStreamDef");
00648 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyMockTupleStreamDef>));
00649 ProxyMockTupleStreamDef::meth_getRowCount = pEnv->GetMethodID(jClass,"getRowCount","()J");
00650
00651 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemMultiUseBufferingStreamDef");
00652 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyMultiUseBufferingStreamDef>));
00653 ProxyMultiUseBufferingStreamDef::meth_getReaderRefCountParamId = pEnv->GetMethodID(jClass,"getReaderRefCountParamId","()I");
00654
00655 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemNestedLoopJoinStreamDef");
00656 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyNestedLoopJoinStreamDef>));
00657 ProxyNestedLoopJoinStreamDef::meth_getLeftJoinKey = pEnv->GetMethodID(jClass,"getLeftJoinKey","()Ljava/util/List;");
00658
00659 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemReshapeParameter");
00660 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyReshapeParameter>));
00661 ProxyReshapeParameter::meth_getCompareOffset = pEnv->GetMethodID(jClass,"getCompareOffset","()I");
00662 ProxyReshapeParameter::meth_getDynamicParamId = pEnv->GetMethodID(jClass,"getDynamicParamId","()I");
00663 ProxyReshapeParameter::meth_isOutputParam = pEnv->GetMethodID(jClass,"isOutputParam","()Z");
00664 ProxyReshapeParameter::meth_getReshape = pEnv->GetMethodID(jClass,"getReshape","()Lnet/sf/farrago/fem/fennel/FemReshapeStreamDef;");
00665
00666 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemReshapeStreamDef");
00667 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyReshapeStreamDef>));
00668 ProxyReshapeStreamDef::meth_getCompareOp = pEnv->GetMethodID(jClass,"getCompareOp","()Lnet/sf/farrago/fem/fennel/CompOperator;");
00669 ProxyReshapeStreamDef::meth_getInputCompareProjection = pEnv->GetMethodID(jClass,"getInputCompareProjection","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00670 ProxyReshapeStreamDef::meth_getOutputProjection = pEnv->GetMethodID(jClass,"getOutputProjection","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00671 ProxyReshapeStreamDef::meth_getReshapeParameter = pEnv->GetMethodID(jClass,"getReshapeParameter","()Ljava/util/List;");
00672 ProxyReshapeStreamDef::meth_getTupleCompareBytesBase64 = pEnv->GetMethodID(jClass,"getTupleCompareBytesBase64","()Ljava/lang/String;");
00673
00674 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemSortedAggStreamDef");
00675 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxySortedAggStreamDef>));
00676
00677 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemSortingStreamDef");
00678 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxySortingStreamDef>));
00679 ProxySortingStreamDef::meth_getDescendingProj = pEnv->GetMethodID(jClass,"getDescendingProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00680 ProxySortingStreamDef::meth_getDistinctness = pEnv->GetMethodID(jClass,"getDistinctness","()Lnet/sf/farrago/fem/fennel/Distinctness;");
00681 ProxySortingStreamDef::meth_isEarlyClose = pEnv->GetMethodID(jClass,"isEarlyClose","()Z");
00682 ProxySortingStreamDef::meth_getEstimatedNumRows = pEnv->GetMethodID(jClass,"getEstimatedNumRows","()J");
00683
00684 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemSplicerIndexAccessorDef");
00685 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxySplicerIndexAccessorDef>));
00686 ProxySplicerIndexAccessorDef::meth_getSplicer = pEnv->GetMethodID(jClass,"getSplicer","()Lnet/sf/farrago/fem/fennel/FemLbmSplicerStreamDef;");
00687
00688 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemSplitterStreamDef");
00689 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxySplitterStreamDef>));
00690
00691 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemStreamGraphHandle");
00692 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyStreamGraphHandle>));
00693
00694 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemStreamHandle");
00695 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyStreamHandle>));
00696
00697 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemSvptHandle");
00698 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxySvptHandle>));
00699
00700 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTableDeleterDef");
00701 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTableDeleterDef>));
00702
00703 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTableInserterDef");
00704 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTableInserterDef>));
00705
00706 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTableUpdaterDef");
00707 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTableUpdaterDef>));
00708 ProxyTableUpdaterDef::meth_getUpdateProj = pEnv->GetMethodID(jClass,"getUpdateProj","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00709
00710 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTableWriterDef");
00711 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTableWriterDef>));
00712 ProxyTableWriterDef::meth_getIndexWriter = pEnv->GetMethodID(jClass,"getIndexWriter","()Ljava/util/List;");
00713
00714 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTupleAccessor");
00715 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTupleAccessor>));
00716 ProxyTupleAccessor::meth_getAttrAccessor = pEnv->GetMethodID(jClass,"getAttrAccessor","()Ljava/util/List;");
00717 ProxyTupleAccessor::meth_getBitFieldOffset = pEnv->GetMethodID(jClass,"getBitFieldOffset","()I");
00718 ProxyTupleAccessor::meth_getMinByteLength = pEnv->GetMethodID(jClass,"getMinByteLength","()I");
00719
00720 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTupleAttrAccessor");
00721 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTupleAttrAccessor>));
00722 ProxyTupleAttrAccessor::meth_getBitValueIndex = pEnv->GetMethodID(jClass,"getBitValueIndex","()I");
00723 ProxyTupleAttrAccessor::meth_getEndIndirectOffset = pEnv->GetMethodID(jClass,"getEndIndirectOffset","()I");
00724 ProxyTupleAttrAccessor::meth_getFixedOffset = pEnv->GetMethodID(jClass,"getFixedOffset","()I");
00725 ProxyTupleAttrAccessor::meth_getNullBitIndex = pEnv->GetMethodID(jClass,"getNullBitIndex","()I");
00726
00727 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTupleAttrDescriptor");
00728 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTupleAttrDescriptor>));
00729 ProxyTupleAttrDescriptor::meth_getByteLength = pEnv->GetMethodID(jClass,"getByteLength","()I");
00730 ProxyTupleAttrDescriptor::meth_isNullable = pEnv->GetMethodID(jClass,"isNullable","()Z");
00731 ProxyTupleAttrDescriptor::meth_getTypeOrdinal = pEnv->GetMethodID(jClass,"getTypeOrdinal","()I");
00732
00733 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTupleAttrProjection");
00734 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTupleAttrProjection>));
00735 ProxyTupleAttrProjection::meth_getAttributeIndex = pEnv->GetMethodID(jClass,"getAttributeIndex","()I");
00736
00737 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTupleDescriptor");
00738 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTupleDescriptor>));
00739 ProxyTupleDescriptor::meth_getAttrDescriptor = pEnv->GetMethodID(jClass,"getAttrDescriptor","()Ljava/util/List;");
00740
00741 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTupleProjection");
00742 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTupleProjection>));
00743 ProxyTupleProjection::meth_getAttrProjection = pEnv->GetMethodID(jClass,"getAttrProjection","()Ljava/util/List;");
00744
00745 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTupleStreamDef");
00746 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTupleStreamDef>));
00747
00748 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTupleStreamGraphCmd");
00749 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTupleStreamGraphCmd>));
00750 ProxyTupleStreamGraphCmd::meth_getStreamGraphHandle = pEnv->GetMethodID(jClass,"getStreamGraphHandle","()Lnet/sf/farrago/fem/fennel/FemStreamGraphHandle;");
00751
00752 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTxnCmd");
00753 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTxnCmd>));
00754 ProxyTxnCmd::meth_getTxnHandle = pEnv->GetMethodID(jClass,"getTxnHandle","()Lnet/sf/farrago/fem/fennel/FemTxnHandle;");
00755
00756 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTxnHandle");
00757 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyTxnHandle>));
00758
00759 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemUncollectTupleStreamDef");
00760 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyUncollectTupleStreamDef>));
00761
00762 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemValuesStreamDef");
00763 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyValuesStreamDef>));
00764 ProxyValuesStreamDef::meth_getTupleBytesBase64 = pEnv->GetMethodID(jClass,"getTupleBytesBase64","()Ljava/lang/String;");
00765
00766 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemWindowDef");
00767 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyWindowDef>));
00768 ProxyWindowDef::meth_getOffset = pEnv->GetMethodID(jClass,"getOffset","()I");
00769 ProxyWindowDef::meth_getOrderKeyList = pEnv->GetMethodID(jClass,"getOrderKeyList","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00770 ProxyWindowDef::meth_getPartition = pEnv->GetMethodID(jClass,"getPartition","()Ljava/util/List;");
00771 ProxyWindowDef::meth_isPhysical = pEnv->GetMethodID(jClass,"isPhysical","()Z");
00772 ProxyWindowDef::meth_getRange = pEnv->GetMethodID(jClass,"getRange","()Ljava/lang/String;");
00773 ProxyWindowDef::meth_getWindowStream = pEnv->GetMethodID(jClass,"getWindowStream","()Lnet/sf/farrago/fem/fennel/FemWindowStreamDef;");
00774
00775 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemWindowPartitionDef");
00776 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyWindowPartitionDef>));
00777 ProxyWindowPartitionDef::meth_getAddProgram = pEnv->GetMethodID(jClass,"getAddProgram","()Ljava/lang/String;");
00778 ProxyWindowPartitionDef::meth_getBucketDesc = pEnv->GetMethodID(jClass,"getBucketDesc","()Lnet/sf/farrago/fem/fennel/FemTupleDescriptor;");
00779 ProxyWindowPartitionDef::meth_getDropProgram = pEnv->GetMethodID(jClass,"getDropProgram","()Ljava/lang/String;");
00780 ProxyWindowPartitionDef::meth_getInitializeProgram = pEnv->GetMethodID(jClass,"getInitializeProgram","()Ljava/lang/String;");
00781 ProxyWindowPartitionDef::meth_getPartitionKeyList = pEnv->GetMethodID(jClass,"getPartitionKeyList","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00782 ProxyWindowPartitionDef::meth_getWindow = pEnv->GetMethodID(jClass,"getWindow","()Lnet/sf/farrago/fem/fennel/FemWindowDef;");
00783
00784 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemWindowStreamDef");
00785 visitTbl.addMethod(jClass,JniProxyVisitTable<FemVisitor>::SharedVisitorMethod(new JniProxyVisitTable<FemVisitor>::VisitorMethodImpl<ProxyWindowStreamDef>));
00786 ProxyWindowStreamDef::meth_isFilter = pEnv->GetMethodID(jClass,"isFilter","()Z");
00787 ProxyWindowStreamDef::meth_getInputOrderKeyList = pEnv->GetMethodID(jClass,"getInputOrderKeyList","()Lnet/sf/farrago/fem/fennel/FemTupleProjection;");
00788 ProxyWindowStreamDef::meth_getOutputProgram = pEnv->GetMethodID(jClass,"getOutputProgram","()Ljava/lang/String;");
00789 ProxyWindowStreamDef::meth_getWindow = pEnv->GetMethodID(jClass,"getWindow","()Ljava/util/List;");
00790
00791 }
00792
00793 SharedProxyAggStreamDef ProxyAggInvocation::getAggStreamDef()
00794 {
00795 SharedProxyAggStreamDef p;
00796 p->pEnv = pEnv;
00797 p->jObject = pEnv->CallObjectMethod(jObject,meth_getAggStreamDef);
00798 if (!p->jObject) p.reset();
00799 return p;
00800 }
00801
00802 AggFunction ProxyAggInvocation::getFunction()
00803 {
00804 std::string symbol = constructString(JniUtil::toString(pEnv,pEnv->CallObjectMethod(jObject,meth_getFunction)));
00805 return static_cast<AggFunction>(JniUtil::lookUpEnum(AggFunction_names,symbol));
00806 }
00807
00808 int32_t ProxyAggInvocation::getInputAttributeIndex()
00809 {
00810 return pEnv->CallIntMethod(jObject,meth_getInputAttributeIndex);
00811 }
00812
00813 SharedProxyAggInvocation ProxyAggStreamDef::getAggInvocation()
00814 {
00815 SharedProxyAggInvocation p;
00816 p->pEnv = pEnv;
00817 p->jObject = pEnv->CallObjectMethod(jObject,meth_getAggInvocation);
00818 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
00819 ++p;
00820 return p;
00821 }
00822
00823 int32_t ProxyAggStreamDef::getGroupingPrefixSize()
00824 {
00825 return pEnv->CallIntMethod(jObject,meth_getGroupingPrefixSize);
00826 }
00827
00828 SharedProxyDynamicParameter ProxyBarrierStreamDef::getDynamicParameter()
00829 {
00830 SharedProxyDynamicParameter p;
00831 p->pEnv = pEnv;
00832 p->jObject = pEnv->CallObjectMethod(jObject,meth_getDynamicParameter);
00833 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
00834 ++p;
00835 return p;
00836 }
00837
00838 BarrierReturnMode ProxyBarrierStreamDef::getReturnMode()
00839 {
00840 std::string symbol = constructString(JniUtil::toString(pEnv,pEnv->CallObjectMethod(jObject,meth_getReturnMode)));
00841 return static_cast<BarrierReturnMode>(JniUtil::lookUpEnum(BarrierReturnMode_names,symbol));
00842 }
00843
00844 SharedProxyTxnHandle ProxyBeginTxnCmd::getResultHandle()
00845 {
00846 SharedProxyTxnHandle p;
00847 p->pEnv = pEnv;
00848 p->jObject = pEnv->CallObjectMethod(jObject,meth_getResultHandle);
00849 if (!p->jObject) p.reset();
00850 return p;
00851 }
00852
00853 int32_t ProxyBernoulliSamplingStreamDef::getRepeatableSeed()
00854 {
00855 return pEnv->CallIntMethod(jObject,meth_getRepeatableSeed);
00856 }
00857
00858 bool ProxyBernoulliSamplingStreamDef::isRepeatable()
00859 {
00860 return pEnv->CallBooleanMethod(jObject,meth_isRepeatable);
00861 }
00862
00863 float ProxyBernoulliSamplingStreamDef::getSamplingRate()
00864 {
00865 return pEnv->CallFloatMethod(jObject,meth_getSamplingRate);
00866 }
00867
00868 bool ProxyBufferingTupleStreamDef::isInMemory()
00869 {
00870 return pEnv->CallBooleanMethod(jObject,meth_isInMemory);
00871 }
00872
00873 bool ProxyBufferingTupleStreamDef::isMultipass()
00874 {
00875 return pEnv->CallBooleanMethod(jObject,meth_isMultipass);
00876 }
00877
00878 bool ProxyCalcTupleStreamDef::isFilter()
00879 {
00880 return pEnv->CallBooleanMethod(jObject,meth_isFilter);
00881 }
00882
00883 std::string ProxyCalcTupleStreamDef::getProgram()
00884 {
00885 return constructString(pEnv->CallObjectMethod(jObject,meth_getProgram));
00886 }
00887
00888 bool ProxyCartesianProductStreamDef::isLeftOuter()
00889 {
00890 return pEnv->CallBooleanMethod(jObject,meth_isLeftOuter);
00891 }
00892
00893 int64_t ProxyCmdAlterSystemDeallocate::getOldestLabelCsn()
00894 {
00895 return pEnv->CallLongMethod(jObject,meth_getOldestLabelCsn);
00896 }
00897
00898 bool ProxyCmdBeginTxn::isReadOnly()
00899 {
00900 return pEnv->CallBooleanMethod(jObject,meth_isReadOnly);
00901 }
00902
00903 SharedProxyCsnHandle ProxyCmdBeginTxnWithCsn::getCsnHandle()
00904 {
00905 SharedProxyCsnHandle p;
00906 p->pEnv = pEnv;
00907 p->jObject = pEnv->CallObjectMethod(jObject,meth_getCsnHandle);
00908 if (!p->jObject) p.reset();
00909 return p;
00910 }
00911
00912 bool ProxyCmdCheckpoint::isAsync()
00913 {
00914 return pEnv->CallBooleanMethod(jObject,meth_isAsync);
00915 }
00916
00917 bool ProxyCmdCheckpoint::isFuzzy()
00918 {
00919 return pEnv->CallBooleanMethod(jObject,meth_isFuzzy);
00920 }
00921
00922 int64_t ProxyCmdCompleteBackup::getLowerBoundCsn()
00923 {
00924 return pEnv->CallLongMethod(jObject,meth_getLowerBoundCsn);
00925 }
00926
00927 int64_t ProxyCmdCompleteBackup::getUpperBoundCsn()
00928 {
00929 return pEnv->CallLongMethod(jObject,meth_getUpperBoundCsn);
00930 }
00931
00932 SharedProxyStreamGraphHandle ProxyCmdCreateExecutionStreamGraph::getResultHandle()
00933 {
00934 SharedProxyStreamGraphHandle p;
00935 p->pEnv = pEnv;
00936 p->jObject = pEnv->CallObjectMethod(jObject,meth_getResultHandle);
00937 if (!p->jObject) p.reset();
00938 return p;
00939 }
00940
00941 bool ProxyCmdCreateStreamHandle::isInput()
00942 {
00943 return pEnv->CallBooleanMethod(jObject,meth_isInput);
00944 }
00945
00946 SharedProxyStreamHandle ProxyCmdCreateStreamHandle::getResultHandle()
00947 {
00948 SharedProxyStreamHandle p;
00949 p->pEnv = pEnv;
00950 p->jObject = pEnv->CallObjectMethod(jObject,meth_getResultHandle);
00951 if (!p->jObject) p.reset();
00952 return p;
00953 }
00954
00955 std::string ProxyCmdCreateStreamHandle::getStreamName()
00956 {
00957 return constructString(pEnv->CallObjectMethod(jObject,meth_getStreamName));
00958 }
00959
00960 std::string ProxyCmdInitiateBackup::getBackupPathname()
00961 {
00962 return constructString(pEnv->CallObjectMethod(jObject,meth_getBackupPathname));
00963 }
00964
00965 bool ProxyCmdInitiateBackup::isCheckSpaceRequirements()
00966 {
00967 return pEnv->CallBooleanMethod(jObject,meth_isCheckSpaceRequirements);
00968 }
00969
00970 std::string ProxyCmdInitiateBackup::getCompressionProgram()
00971 {
00972 return constructString(pEnv->CallObjectMethod(jObject,meth_getCompressionProgram));
00973 }
00974
00975 int64_t ProxyCmdInitiateBackup::getLowerBoundCsn()
00976 {
00977 return pEnv->CallLongMethod(jObject,meth_getLowerBoundCsn);
00978 }
00979
00980 int64_t ProxyCmdInitiateBackup::getResultDataDeviceSize()
00981 {
00982 return int64Value(pEnv->CallObjectMethod(jObject,meth_getResultDataDeviceSize));
00983 }
00984
00985 void ProxyCmdInitiateBackup::setResultDataDeviceSize(const int64_t &valueRef)
00986 {
00987 pEnv->CallVoidMethod(jObject,meth_setResultDataDeviceSize,constructJavaLong(valueRef));
00988 }
00989 void ProxyCmdInitiateBackup::clearResultDataDeviceSize()
00990 {
00991 pEnv->CallVoidMethod(jObject,meth_setResultDataDeviceSize,NULL);
00992 }
00993
00994 int64_t ProxyCmdInitiateBackup::getSpacePadding()
00995 {
00996 return pEnv->CallLongMethod(jObject,meth_getSpacePadding);
00997 }
00998
00999 bool ProxyCmdOpenDatabase::isCreateDatabase()
01000 {
01001 return pEnv->CallBooleanMethod(jObject,meth_isCreateDatabase);
01002 }
01003
01004 SharedProxyDatabaseParam ProxyCmdOpenDatabase::getParams()
01005 {
01006 SharedProxyDatabaseParam p;
01007 p->pEnv = pEnv;
01008 p->jObject = pEnv->CallObjectMethod(jObject,meth_getParams);
01009 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01010 ++p;
01011 return p;
01012 }
01013
01014 SharedProxyDbHandle ProxyCmdOpenDatabase::getResultHandle()
01015 {
01016 SharedProxyDbHandle p;
01017 p->pEnv = pEnv;
01018 p->jObject = pEnv->CallObjectMethod(jObject,meth_getResultHandle);
01019 if (!p->jObject) p.reset();
01020 return p;
01021 }
01022
01023 bool ProxyCmdOpenDatabase::isResultRecoveryRequired()
01024 {
01025 return boolValue(pEnv->CallObjectMethod(jObject,meth_isResultRecoveryRequired));
01026 }
01027
01028 void ProxyCmdOpenDatabase::setResultRecoveryRequired(const bool &valueRef)
01029 {
01030 pEnv->CallVoidMethod(jObject,meth_setResultRecoveryRequired,constructJavaBoolean(valueRef));
01031 }
01032 void ProxyCmdOpenDatabase::clearResultRecoveryRequired()
01033 {
01034 pEnv->CallVoidMethod(jObject,meth_setResultRecoveryRequired,NULL);
01035 }
01036
01037 int32_t ProxyCmdPrepareExecutionStreamGraph::getDegreeOfParallelism()
01038 {
01039 return pEnv->CallIntMethod(jObject,meth_getDegreeOfParallelism);
01040 }
01041
01042 SharedProxyExecutionStreamDef ProxyCmdPrepareExecutionStreamGraph::getStreamDefs()
01043 {
01044 SharedProxyExecutionStreamDef p;
01045 p->pEnv = pEnv;
01046 p->jObject = pEnv->CallObjectMethod(jObject,meth_getStreamDefs);
01047 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01048 ++p;
01049 return p;
01050 }
01051
01052 std::string ProxyCmdRestoreFromBackup::getBackupPathname()
01053 {
01054 return constructString(pEnv->CallObjectMethod(jObject,meth_getBackupPathname));
01055 }
01056
01057 std::string ProxyCmdRestoreFromBackup::getCompressionProgram()
01058 {
01059 return constructString(pEnv->CallObjectMethod(jObject,meth_getCompressionProgram));
01060 }
01061
01062 int64_t ProxyCmdRestoreFromBackup::getFileSize()
01063 {
01064 return pEnv->CallLongMethod(jObject,meth_getFileSize);
01065 }
01066
01067 int64_t ProxyCmdRestoreFromBackup::getLowerBoundCsn()
01068 {
01069 return pEnv->CallLongMethod(jObject,meth_getLowerBoundCsn);
01070 }
01071
01072 int64_t ProxyCmdRestoreFromBackup::getUpperBoundCsn()
01073 {
01074 return pEnv->CallLongMethod(jObject,meth_getUpperBoundCsn);
01075 }
01076
01077 SharedProxySvptHandle ProxyCmdSavepoint::getResultHandle()
01078 {
01079 SharedProxySvptHandle p;
01080 p->pEnv = pEnv;
01081 p->jObject = pEnv->CallObjectMethod(jObject,meth_getResultHandle);
01082 if (!p->jObject) p.reset();
01083 return p;
01084 }
01085
01086 SharedProxyDatabaseParam ProxyCmdSetParam::getParam()
01087 {
01088 SharedProxyDatabaseParam p;
01089 p->pEnv = pEnv;
01090 p->jObject = pEnv->CallObjectMethod(jObject,meth_getParam);
01091 if (!p->jObject) p.reset();
01092 return p;
01093 }
01094
01095 bool ProxyCmdVerifyIndex::isEstimate()
01096 {
01097 return pEnv->CallBooleanMethod(jObject,meth_isEstimate);
01098 }
01099
01100 bool ProxyCmdVerifyIndex::isIncludeTuples()
01101 {
01102 return pEnv->CallBooleanMethod(jObject,meth_isIncludeTuples);
01103 }
01104
01105 int64_t ProxyCmdVerifyIndex::getResultPageCount()
01106 {
01107 return int64Value(pEnv->CallObjectMethod(jObject,meth_getResultPageCount));
01108 }
01109
01110 void ProxyCmdVerifyIndex::setResultPageCount(const int64_t &valueRef)
01111 {
01112 pEnv->CallVoidMethod(jObject,meth_setResultPageCount,constructJavaLong(valueRef));
01113 }
01114 void ProxyCmdVerifyIndex::clearResultPageCount()
01115 {
01116 pEnv->CallVoidMethod(jObject,meth_setResultPageCount,NULL);
01117 }
01118
01119 int64_t ProxyCmdVerifyIndex::getResultUniqueKeyCount()
01120 {
01121 return int64Value(pEnv->CallObjectMethod(jObject,meth_getResultUniqueKeyCount));
01122 }
01123
01124 void ProxyCmdVerifyIndex::setResultUniqueKeyCount(const int64_t &valueRef)
01125 {
01126 pEnv->CallVoidMethod(jObject,meth_setResultUniqueKeyCount,constructJavaLong(valueRef));
01127 }
01128 void ProxyCmdVerifyIndex::clearResultUniqueKeyCount()
01129 {
01130 pEnv->CallVoidMethod(jObject,meth_setResultUniqueKeyCount,NULL);
01131 }
01132
01133 int64_t ProxyCmdVersionIndexRoot::getNewRootPageId()
01134 {
01135 return pEnv->CallLongMethod(jObject,meth_getNewRootPageId);
01136 }
01137
01138 int64_t ProxyCmdVersionIndexRoot::getOldRootPageId()
01139 {
01140 return pEnv->CallLongMethod(jObject,meth_getOldRootPageId);
01141 }
01142
01143 SharedProxyFlatFileTupleStreamDef ProxyColumnName::getFlatFile()
01144 {
01145 SharedProxyFlatFileTupleStreamDef p;
01146 p->pEnv = pEnv;
01147 p->jObject = pEnv->CallObjectMethod(jObject,meth_getFlatFile);
01148 if (!p->jObject) p.reset();
01149 return p;
01150 }
01151
01152 std::string ProxyColumnName::getName()
01153 {
01154 return constructString(pEnv->CallObjectMethod(jObject,meth_getName));
01155 }
01156
01157 int32_t ProxyCorrelation::getId()
01158 {
01159 return pEnv->CallIntMethod(jObject,meth_getId);
01160 }
01161
01162 SharedProxyIndexSearchDef ProxyCorrelation::getIndexSearch()
01163 {
01164 SharedProxyIndexSearchDef p;
01165 p->pEnv = pEnv;
01166 p->jObject = pEnv->CallObjectMethod(jObject,meth_getIndexSearch);
01167 if (!p->jObject) p.reset();
01168 return p;
01169 }
01170
01171 SharedProxyNestedLoopJoinStreamDef ProxyCorrelation::getNestedLoopJoin()
01172 {
01173 SharedProxyNestedLoopJoinStreamDef p;
01174 p->pEnv = pEnv;
01175 p->jObject = pEnv->CallObjectMethod(jObject,meth_getNestedLoopJoin);
01176 if (!p->jObject) p.reset();
01177 return p;
01178 }
01179
01180 int32_t ProxyCorrelation::getOffset()
01181 {
01182 return pEnv->CallIntMethod(jObject,meth_getOffset);
01183 }
01184
01185 SharedProxyCorrelation ProxyCorrelationJoinStreamDef::getCorrelations()
01186 {
01187 SharedProxyCorrelation p;
01188 p->pEnv = pEnv;
01189 p->jObject = pEnv->CallObjectMethod(jObject,meth_getCorrelations);
01190 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01191 ++p;
01192 return p;
01193 }
01194
01195 SharedProxyCsnHandle ProxyCsnHandleReturningCmd::getResultHandle()
01196 {
01197 SharedProxyCsnHandle p;
01198 p->pEnv = pEnv;
01199 p->jObject = pEnv->CallObjectMethod(jObject,meth_getResultHandle);
01200 if (!p->jObject) p.reset();
01201 return p;
01202 }
01203
01204 SharedProxyDbHandle ProxyDatabaseCmd::getDbHandle()
01205 {
01206 SharedProxyDbHandle p;
01207 p->pEnv = pEnv;
01208 p->jObject = pEnv->CallObjectMethod(jObject,meth_getDbHandle);
01209 if (!p->jObject) p.reset();
01210 return p;
01211 }
01212
01213 std::string ProxyDatabaseParam::getName()
01214 {
01215 return constructString(pEnv->CallObjectMethod(jObject,meth_getName));
01216 }
01217
01218 std::string ProxyDatabaseParam::getValue()
01219 {
01220 return constructString(pEnv->CallObjectMethod(jObject,meth_getValue));
01221 }
01222
01223 int32_t ProxyDynamicParamUse::getDynamicParamId()
01224 {
01225 return pEnv->CallIntMethod(jObject,meth_getDynamicParamId);
01226 }
01227
01228 SharedProxyExecutionStreamDef ProxyDynamicParamUse::getExecutionStreamDef()
01229 {
01230 SharedProxyExecutionStreamDef p;
01231 p->pEnv = pEnv;
01232 p->jObject = pEnv->CallObjectMethod(jObject,meth_getExecutionStreamDef);
01233 if (!p->jObject) p.reset();
01234 return p;
01235 }
01236
01237 bool ProxyDynamicParamUse::isRead()
01238 {
01239 return pEnv->CallBooleanMethod(jObject,meth_isRead);
01240 }
01241
01242 SharedProxyBarrierStreamDef ProxyDynamicParameter::getBarrier()
01243 {
01244 SharedProxyBarrierStreamDef p;
01245 p->pEnv = pEnv;
01246 p->jObject = pEnv->CallObjectMethod(jObject,meth_getBarrier);
01247 if (!p->jObject) p.reset();
01248 return p;
01249 }
01250
01251 int32_t ProxyDynamicParameter::getParameterId()
01252 {
01253 return pEnv->CallIntMethod(jObject,meth_getParameterId);
01254 }
01255
01256 SharedProxySvptHandle ProxyEndTxnCmd::getSvptHandle()
01257 {
01258 SharedProxySvptHandle p;
01259 p->pEnv = pEnv;
01260 p->jObject = pEnv->CallObjectMethod(jObject,meth_getSvptHandle);
01261 if (!p->jObject) p.reset();
01262 return p;
01263 }
01264
01265 SharedProxyExecutionStreamDef ProxyExecStreamDataFlow::getConsumer()
01266 {
01267 SharedProxyExecutionStreamDef p;
01268 p->pEnv = pEnv;
01269 p->jObject = pEnv->CallObjectMethod(jObject,meth_getConsumer);
01270 if (!p->jObject) p.reset();
01271 return p;
01272 }
01273
01274 bool ProxyExecStreamDataFlow::isImplicit()
01275 {
01276 return pEnv->CallBooleanMethod(jObject,meth_isImplicit);
01277 }
01278
01279 SharedProxyExecutionStreamDef ProxyExecStreamDataFlow::getProducer()
01280 {
01281 SharedProxyExecutionStreamDef p;
01282 p->pEnv = pEnv;
01283 p->jObject = pEnv->CallObjectMethod(jObject,meth_getProducer);
01284 if (!p->jObject) p.reset();
01285 return p;
01286 }
01287
01288 SharedProxyDynamicParamUse ProxyExecutionStreamDef::getDynamicParamUse()
01289 {
01290 SharedProxyDynamicParamUse p;
01291 p->pEnv = pEnv;
01292 p->jObject = pEnv->CallObjectMethod(jObject,meth_getDynamicParamUse);
01293 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01294 ++p;
01295 return p;
01296 }
01297
01298 SharedProxyExecStreamDataFlow ProxyExecutionStreamDef::getInputFlow()
01299 {
01300 SharedProxyExecStreamDataFlow p;
01301 p->pEnv = pEnv;
01302 p->jObject = pEnv->CallObjectMethod(jObject,meth_getInputFlow);
01303 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01304 ++p;
01305 return p;
01306 }
01307
01308 std::string ProxyExecutionStreamDef::getName()
01309 {
01310 return constructString(pEnv->CallObjectMethod(jObject,meth_getName));
01311 }
01312
01313 SharedProxyTupleDescriptor ProxyExecutionStreamDef::getOutputDesc()
01314 {
01315 SharedProxyTupleDescriptor p;
01316 p->pEnv = pEnv;
01317 p->jObject = pEnv->CallObjectMethod(jObject,meth_getOutputDesc);
01318 if (!p->jObject) p.reset();
01319 return p;
01320 }
01321
01322 SharedProxyExecStreamDataFlow ProxyExecutionStreamDef::getOutputFlow()
01323 {
01324 SharedProxyExecStreamDataFlow p;
01325 p->pEnv = pEnv;
01326 p->jObject = pEnv->CallObjectMethod(jObject,meth_getOutputFlow);
01327 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01328 ++p;
01329 return p;
01330 }
01331
01332 std::string ProxyFlatFileTupleStreamDef::getCalcProgram()
01333 {
01334 return constructString(pEnv->CallObjectMethod(jObject,meth_getCalcProgram));
01335 }
01336
01337 int32_t ProxyFlatFileTupleStreamDef::getCodePage()
01338 {
01339 return pEnv->CallIntMethod(jObject,meth_getCodePage);
01340 }
01341
01342 SharedProxyColumnName ProxyFlatFileTupleStreamDef::getColumn()
01343 {
01344 SharedProxyColumnName p;
01345 p->pEnv = pEnv;
01346 p->jObject = pEnv->CallObjectMethod(jObject,meth_getColumn);
01347 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01348 ++p;
01349 return p;
01350 }
01351
01352 std::string ProxyFlatFileTupleStreamDef::getDataFilePath()
01353 {
01354 return constructString(pEnv->CallObjectMethod(jObject,meth_getDataFilePath));
01355 }
01356
01357 std::string ProxyFlatFileTupleStreamDef::getErrorFilePath()
01358 {
01359 return constructString(pEnv->CallObjectMethod(jObject,meth_getErrorFilePath));
01360 }
01361
01362 std::string ProxyFlatFileTupleStreamDef::getEscapeCharacter()
01363 {
01364 return constructString(pEnv->CallObjectMethod(jObject,meth_getEscapeCharacter));
01365 }
01366
01367 std::string ProxyFlatFileTupleStreamDef::getFieldDelimiter()
01368 {
01369 return constructString(pEnv->CallObjectMethod(jObject,meth_getFieldDelimiter));
01370 }
01371
01372 bool ProxyFlatFileTupleStreamDef::isHasHeader()
01373 {
01374 return pEnv->CallBooleanMethod(jObject,meth_isHasHeader);
01375 }
01376
01377 bool ProxyFlatFileTupleStreamDef::isLenient()
01378 {
01379 return pEnv->CallBooleanMethod(jObject,meth_isLenient);
01380 }
01381
01382 bool ProxyFlatFileTupleStreamDef::isMapped()
01383 {
01384 return pEnv->CallBooleanMethod(jObject,meth_isMapped);
01385 }
01386
01387 int32_t ProxyFlatFileTupleStreamDef::getNumRowsScan()
01388 {
01389 return pEnv->CallIntMethod(jObject,meth_getNumRowsScan);
01390 }
01391
01392 std::string ProxyFlatFileTupleStreamDef::getQuoteCharacter()
01393 {
01394 return constructString(pEnv->CallObjectMethod(jObject,meth_getQuoteCharacter));
01395 }
01396
01397 std::string ProxyFlatFileTupleStreamDef::getRowDelimiter()
01398 {
01399 return constructString(pEnv->CallObjectMethod(jObject,meth_getRowDelimiter));
01400 }
01401
01402 std::string ProxyFlatFileTupleStreamDef::getSubstituteCharacter()
01403 {
01404 return constructString(pEnv->CallObjectMethod(jObject,meth_getSubstituteCharacter));
01405 }
01406
01407 bool ProxyFlatFileTupleStreamDef::isTranslationRecovery()
01408 {
01409 return pEnv->CallBooleanMethod(jObject,meth_isTranslationRecovery);
01410 }
01411
01412 bool ProxyFlatFileTupleStreamDef::isTrim()
01413 {
01414 return pEnv->CallBooleanMethod(jObject,meth_isTrim);
01415 }
01416
01417 std::string ProxyGenericStreamDef::getContent()
01418 {
01419 return constructString(pEnv->CallObjectMethod(jObject,meth_getContent));
01420 }
01421
01422 std::string ProxyGenericStreamDef::getType()
01423 {
01424 return constructString(pEnv->CallObjectMethod(jObject,meth_getType));
01425 }
01426
01427 int64_t ProxyHandle::getLongHandle()
01428 {
01429 return pEnv->CallLongMethod(jObject,meth_getLongHandle);
01430 }
01431
01432 int64_t ProxyIndexAccessCmd::getRootPageId()
01433 {
01434 return pEnv->CallLongMethod(jObject,meth_getRootPageId);
01435 }
01436
01437 int64_t ProxyIndexAccessorDef::getIndexId()
01438 {
01439 return pEnv->CallLongMethod(jObject,meth_getIndexId);
01440 }
01441
01442 bool ProxyIndexAccessorDef::isReadOnlyCommittedData()
01443 {
01444 return pEnv->CallBooleanMethod(jObject,meth_isReadOnlyCommittedData);
01445 }
01446
01447 int32_t ProxyIndexAccessorDef::getRootPageIdParamId()
01448 {
01449 return pEnv->CallIntMethod(jObject,meth_getRootPageIdParamId);
01450 }
01451
01452 int64_t ProxyIndexAccessorDef::getRootPageId()
01453 {
01454 return pEnv->CallLongMethod(jObject,meth_getRootPageId);
01455 }
01456
01457 int64_t ProxyIndexAccessorDef::getSegmentId()
01458 {
01459 return pEnv->CallLongMethod(jObject,meth_getSegmentId);
01460 }
01461
01462 SharedProxyTupleDescriptor ProxyIndexAccessorDef::getTupleDesc()
01463 {
01464 SharedProxyTupleDescriptor p;
01465 p->pEnv = pEnv;
01466 p->jObject = pEnv->CallObjectMethod(jObject,meth_getTupleDesc);
01467 if (!p->jObject) p.reset();
01468 return p;
01469 }
01470
01471 int64_t ProxyIndexCmd::getIndexId()
01472 {
01473 return pEnv->CallLongMethod(jObject,meth_getIndexId);
01474 }
01475
01476 SharedProxyTupleProjection ProxyIndexCmd::getKeyProj()
01477 {
01478 SharedProxyTupleProjection p;
01479 p->pEnv = pEnv;
01480 p->jObject = pEnv->CallObjectMethod(jObject,meth_getKeyProj);
01481 if (!p->jObject) p.reset();
01482 return p;
01483 }
01484
01485 SharedProxyTupleProjection ProxyIndexCmd::getLeafPageIdProj()
01486 {
01487 SharedProxyTupleProjection p;
01488 p->pEnv = pEnv;
01489 p->jObject = pEnv->CallObjectMethod(jObject,meth_getLeafPageIdProj);
01490 if (!p->jObject) p.reset();
01491 return p;
01492 }
01493
01494 int64_t ProxyIndexCmd::getSegmentId()
01495 {
01496 return pEnv->CallLongMethod(jObject,meth_getSegmentId);
01497 }
01498
01499 SharedProxyTupleDescriptor ProxyIndexCmd::getTupleDesc()
01500 {
01501 SharedProxyTupleDescriptor p;
01502 p->pEnv = pEnv;
01503 p->jObject = pEnv->CallObjectMethod(jObject,meth_getTupleDesc);
01504 if (!p->jObject) p.reset();
01505 return p;
01506 }
01507
01508 Distinctness ProxyIndexLoaderDef::getDistinctness()
01509 {
01510 std::string symbol = constructString(JniUtil::toString(pEnv,pEnv->CallObjectMethod(jObject,meth_getDistinctness)));
01511 return static_cast<Distinctness>(JniUtil::lookUpEnum(Distinctness_names,symbol));
01512 }
01513
01514 bool ProxyIndexLoaderDef::isMonotonic()
01515 {
01516 return pEnv->CallBooleanMethod(jObject,meth_isMonotonic);
01517 }
01518
01519 SharedProxyTupleProjection ProxyIndexScanDef::getOutputProj()
01520 {
01521 SharedProxyTupleProjection p;
01522 p->pEnv = pEnv;
01523 p->jObject = pEnv->CallObjectMethod(jObject,meth_getOutputProj);
01524 if (!p->jObject) p.reset();
01525 return p;
01526 }
01527
01528 SharedProxyTupleProjection ProxyIndexSearchDef::getInputDirectiveProj()
01529 {
01530 SharedProxyTupleProjection p;
01531 p->pEnv = pEnv;
01532 p->jObject = pEnv->CallObjectMethod(jObject,meth_getInputDirectiveProj);
01533 if (!p->jObject) p.reset();
01534 return p;
01535 }
01536
01537 SharedProxyTupleProjection ProxyIndexSearchDef::getInputJoinProj()
01538 {
01539 SharedProxyTupleProjection p;
01540 p->pEnv = pEnv;
01541 p->jObject = pEnv->CallObjectMethod(jObject,meth_getInputJoinProj);
01542 if (!p->jObject) p.reset();
01543 return p;
01544 }
01545
01546 SharedProxyTupleProjection ProxyIndexSearchDef::getInputKeyProj()
01547 {
01548 SharedProxyTupleProjection p;
01549 p->pEnv = pEnv;
01550 p->jObject = pEnv->CallObjectMethod(jObject,meth_getInputKeyProj);
01551 if (!p->jObject) p.reset();
01552 return p;
01553 }
01554
01555 bool ProxyIndexSearchDef::isOuterJoin()
01556 {
01557 return pEnv->CallBooleanMethod(jObject,meth_isOuterJoin);
01558 }
01559
01560 bool ProxyIndexSearchDef::isPrefetch()
01561 {
01562 return pEnv->CallBooleanMethod(jObject,meth_isPrefetch);
01563 }
01564
01565 SharedProxyCorrelation ProxyIndexSearchDef::getSearchKeyParameter()
01566 {
01567 SharedProxyCorrelation p;
01568 p->pEnv = pEnv;
01569 p->jObject = pEnv->CallObjectMethod(jObject,meth_getSearchKeyParameter);
01570 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01571 ++p;
01572 return p;
01573 }
01574
01575 bool ProxyIndexSearchDef::isUniqueKey()
01576 {
01577 return pEnv->CallBooleanMethod(jObject,meth_isUniqueKey);
01578 }
01579
01580 Distinctness ProxyIndexWriterDef::getDistinctness()
01581 {
01582 std::string symbol = constructString(JniUtil::toString(pEnv,pEnv->CallObjectMethod(jObject,meth_getDistinctness)));
01583 return static_cast<Distinctness>(JniUtil::lookUpEnum(Distinctness_names,symbol));
01584 }
01585
01586 SharedProxyTupleProjection ProxyIndexWriterDef::getInputProj()
01587 {
01588 SharedProxyTupleProjection p;
01589 p->pEnv = pEnv;
01590 p->jObject = pEnv->CallObjectMethod(jObject,meth_getInputProj);
01591 if (!p->jObject) p.reset();
01592 return p;
01593 }
01594
01595 SharedProxyTableWriterDef ProxyIndexWriterDef::getTableWriter()
01596 {
01597 SharedProxyTableWriterDef p;
01598 p->pEnv = pEnv;
01599 p->jObject = pEnv->CallObjectMethod(jObject,meth_getTableWriter);
01600 if (!p->jObject) p.reset();
01601 return p;
01602 }
01603
01604 bool ProxyIndexWriterDef::isUpdateInPlace()
01605 {
01606 return pEnv->CallBooleanMethod(jObject,meth_isUpdateInPlace);
01607 }
01608
01609 int32_t ProxyJavaSinkStreamDef::getStreamId()
01610 {
01611 return pEnv->CallIntMethod(jObject,meth_getStreamId);
01612 }
01613
01614 std::string ProxyJavaTransformStreamDef::getJavaClassName()
01615 {
01616 return constructString(pEnv->CallObjectMethod(jObject,meth_getJavaClassName));
01617 }
01618
01619 std::string ProxyJavaTransformStreamDef::getReserved()
01620 {
01621 return constructString(pEnv->CallObjectMethod(jObject,meth_getReserved));
01622 }
01623
01624 int32_t ProxyJavaTransformStreamDef::getStreamId()
01625 {
01626 return pEnv->CallIntMethod(jObject,meth_getStreamId);
01627 }
01628
01629 SharedProxyTupleProjection ProxyKeyAccessorDef::getKeyProj()
01630 {
01631 SharedProxyTupleProjection p;
01632 p->pEnv = pEnv;
01633 p->jObject = pEnv->CallObjectMethod(jObject,meth_getKeyProj);
01634 if (!p->jObject) p.reset();
01635 return p;
01636 }
01637
01638 int32_t ProxyLbmBitOpStreamDef::getRowLimitParamId()
01639 {
01640 return pEnv->CallIntMethod(jObject,meth_getRowLimitParamId);
01641 }
01642
01643 int32_t ProxyLbmBitOpStreamDef::getStartRidParamId()
01644 {
01645 return pEnv->CallIntMethod(jObject,meth_getStartRidParamId);
01646 }
01647
01648 int32_t ProxyLbmChopperStreamDef::getRidLimitParamId()
01649 {
01650 return pEnv->CallIntMethod(jObject,meth_getRidLimitParamId);
01651 }
01652
01653 bool ProxyLbmGeneratorStreamDef::isCreateIndex()
01654 {
01655 return pEnv->CallBooleanMethod(jObject,meth_isCreateIndex);
01656 }
01657
01658 int32_t ProxyLbmGeneratorStreamDef::getInsertRowCountParamId()
01659 {
01660 return pEnv->CallIntMethod(jObject,meth_getInsertRowCountParamId);
01661 }
01662
01663 int32_t ProxyLbmSearchStreamDef::getRowLimitParamId()
01664 {
01665 return pEnv->CallIntMethod(jObject,meth_getRowLimitParamId);
01666 }
01667
01668 int32_t ProxyLbmSearchStreamDef::getStartRidParamId()
01669 {
01670 return pEnv->CallIntMethod(jObject,meth_getStartRidParamId);
01671 }
01672
01673 bool ProxyLbmSplicerStreamDef::isCreateNewIndex()
01674 {
01675 return pEnv->CallBooleanMethod(jObject,meth_isCreateNewIndex);
01676 }
01677
01678 SharedProxySplicerIndexAccessorDef ProxyLbmSplicerStreamDef::getIndexAccessor()
01679 {
01680 SharedProxySplicerIndexAccessorDef p;
01681 p->pEnv = pEnv;
01682 p->jObject = pEnv->CallObjectMethod(jObject,meth_getIndexAccessor);
01683 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01684 ++p;
01685 return p;
01686 }
01687
01688 int32_t ProxyLbmSplicerStreamDef::getInsertRowCountParamId()
01689 {
01690 return pEnv->CallIntMethod(jObject,meth_getInsertRowCountParamId);
01691 }
01692
01693 int32_t ProxyLbmSplicerStreamDef::getWriteRowCountParamId()
01694 {
01695 return pEnv->CallIntMethod(jObject,meth_getWriteRowCountParamId);
01696 }
01697
01698 int32_t ProxyLbmUnionStreamDef::getConsumerSridParamId()
01699 {
01700 return pEnv->CallIntMethod(jObject,meth_getConsumerSridParamId);
01701 }
01702
01703 int32_t ProxyLbmUnionStreamDef::getRidLimitParamId()
01704 {
01705 return pEnv->CallIntMethod(jObject,meth_getRidLimitParamId);
01706 }
01707
01708 int32_t ProxyLbmUnionStreamDef::getSegmentLimitParamId()
01709 {
01710 return pEnv->CallIntMethod(jObject,meth_getSegmentLimitParamId);
01711 }
01712
01713 SharedProxyTupleProjection ProxyLcsClusterAppendStreamDef::getClusterColProj()
01714 {
01715 SharedProxyTupleProjection p;
01716 p->pEnv = pEnv;
01717 p->jObject = pEnv->CallObjectMethod(jObject,meth_getClusterColProj);
01718 if (!p->jObject) p.reset();
01719 return p;
01720 }
01721
01722 SharedProxyTupleDescriptor ProxyLcsClusterScanDef::getClusterTupleDesc()
01723 {
01724 SharedProxyTupleDescriptor p;
01725 p->pEnv = pEnv;
01726 p->jObject = pEnv->CallObjectMethod(jObject,meth_getClusterTupleDesc);
01727 if (!p->jObject) p.reset();
01728 return p;
01729 }
01730
01731 SharedProxyLcsRowScanStreamDef ProxyLcsClusterScanDef::getRowScan()
01732 {
01733 SharedProxyLcsRowScanStreamDef p;
01734 p->pEnv = pEnv;
01735 p->jObject = pEnv->CallObjectMethod(jObject,meth_getRowScan);
01736 if (!p->jObject) p.reset();
01737 return p;
01738 }
01739
01740 SharedProxyLcsClusterScanDef ProxyLcsRowScanStreamDef::getClusterScan()
01741 {
01742 SharedProxyLcsClusterScanDef p;
01743 p->pEnv = pEnv;
01744 p->jObject = pEnv->CallObjectMethod(jObject,meth_getClusterScan);
01745 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01746 ++p;
01747 return p;
01748 }
01749
01750 bool ProxyLcsRowScanStreamDef::isFullScan()
01751 {
01752 return pEnv->CallBooleanMethod(jObject,meth_isFullScan);
01753 }
01754
01755 bool ProxyLcsRowScanStreamDef::isHasExtraFilter()
01756 {
01757 return pEnv->CallBooleanMethod(jObject,meth_isHasExtraFilter);
01758 }
01759
01760 SharedProxyTupleProjection ProxyLcsRowScanStreamDef::getOutputProj()
01761 {
01762 SharedProxyTupleProjection p;
01763 p->pEnv = pEnv;
01764 p->jObject = pEnv->CallObjectMethod(jObject,meth_getOutputProj);
01765 if (!p->jObject) p.reset();
01766 return p;
01767 }
01768
01769 SharedProxyTupleProjection ProxyLcsRowScanStreamDef::getResidualFilterColumns()
01770 {
01771 SharedProxyTupleProjection p;
01772 p->pEnv = pEnv;
01773 p->jObject = pEnv->CallObjectMethod(jObject,meth_getResidualFilterColumns);
01774 if (!p->jObject) p.reset();
01775 return p;
01776 }
01777
01778 int32_t ProxyLcsRowScanStreamDef::getSamplingClumps()
01779 {
01780 return pEnv->CallIntMethod(jObject,meth_getSamplingClumps);
01781 }
01782
01783 TableSamplingMode ProxyLcsRowScanStreamDef::getSamplingMode()
01784 {
01785 std::string symbol = constructString(JniUtil::toString(pEnv,pEnv->CallObjectMethod(jObject,meth_getSamplingMode)));
01786 return static_cast<TableSamplingMode>(JniUtil::lookUpEnum(TableSamplingMode_names,symbol));
01787 }
01788
01789 float ProxyLcsRowScanStreamDef::getSamplingRate()
01790 {
01791 return pEnv->CallFloatMethod(jObject,meth_getSamplingRate);
01792 }
01793
01794 int32_t ProxyLcsRowScanStreamDef::getSamplingRepeatableSeed()
01795 {
01796 return pEnv->CallIntMethod(jObject,meth_getSamplingRepeatableSeed);
01797 }
01798
01799 bool ProxyLcsRowScanStreamDef::isSamplingRepeatable()
01800 {
01801 return pEnv->CallBooleanMethod(jObject,meth_isSamplingRepeatable);
01802 }
01803
01804 int64_t ProxyLcsRowScanStreamDef::getSamplingRowCount()
01805 {
01806 return pEnv->CallLongMethod(jObject,meth_getSamplingRowCount);
01807 }
01808
01809 int64_t ProxyLhxAggStreamDef::getCndGroupByKeys()
01810 {
01811 return pEnv->CallLongMethod(jObject,meth_getCndGroupByKeys);
01812 }
01813
01814 int64_t ProxyLhxAggStreamDef::getNumRows()
01815 {
01816 return pEnv->CallLongMethod(jObject,meth_getNumRows);
01817 }
01818
01819 int64_t ProxyLhxJoinStreamDef::getCndBuildKeys()
01820 {
01821 return pEnv->CallLongMethod(jObject,meth_getCndBuildKeys);
01822 }
01823
01824 SharedProxyTupleProjection ProxyLhxJoinStreamDef::getFilterNullProj()
01825 {
01826 SharedProxyTupleProjection p;
01827 p->pEnv = pEnv;
01828 p->jObject = pEnv->CallObjectMethod(jObject,meth_getFilterNullProj);
01829 if (!p->jObject) p.reset();
01830 return p;
01831 }
01832
01833 bool ProxyLhxJoinStreamDef::isLeftInner()
01834 {
01835 return pEnv->CallBooleanMethod(jObject,meth_isLeftInner);
01836 }
01837
01838 SharedProxyTupleProjection ProxyLhxJoinStreamDef::getLeftKeyProj()
01839 {
01840 SharedProxyTupleProjection p;
01841 p->pEnv = pEnv;
01842 p->jObject = pEnv->CallObjectMethod(jObject,meth_getLeftKeyProj);
01843 if (!p->jObject) p.reset();
01844 return p;
01845 }
01846
01847 bool ProxyLhxJoinStreamDef::isLeftOuter()
01848 {
01849 return pEnv->CallBooleanMethod(jObject,meth_isLeftOuter);
01850 }
01851
01852 int64_t ProxyLhxJoinStreamDef::getNumBuildRows()
01853 {
01854 return pEnv->CallLongMethod(jObject,meth_getNumBuildRows);
01855 }
01856
01857 bool ProxyLhxJoinStreamDef::isRightInner()
01858 {
01859 return pEnv->CallBooleanMethod(jObject,meth_isRightInner);
01860 }
01861
01862 SharedProxyTupleProjection ProxyLhxJoinStreamDef::getRightKeyProj()
01863 {
01864 SharedProxyTupleProjection p;
01865 p->pEnv = pEnv;
01866 p->jObject = pEnv->CallObjectMethod(jObject,meth_getRightKeyProj);
01867 if (!p->jObject) p.reset();
01868 return p;
01869 }
01870
01871 bool ProxyLhxJoinStreamDef::isRightOuter()
01872 {
01873 return pEnv->CallBooleanMethod(jObject,meth_isRightOuter);
01874 }
01875
01876 bool ProxyLhxJoinStreamDef::isSetopAll()
01877 {
01878 return pEnv->CallBooleanMethod(jObject,meth_isSetopAll);
01879 }
01880
01881 bool ProxyLhxJoinStreamDef::isSetopDistinct()
01882 {
01883 return pEnv->CallBooleanMethod(jObject,meth_isSetopDistinct);
01884 }
01885
01886 bool ProxyMergeStreamDef::isPrePullInputs()
01887 {
01888 return pEnv->CallBooleanMethod(jObject,meth_isPrePullInputs);
01889 }
01890
01891 bool ProxyMergeStreamDef::isSequential()
01892 {
01893 return pEnv->CallBooleanMethod(jObject,meth_isSequential);
01894 }
01895
01896 int64_t ProxyMockTupleStreamDef::getRowCount()
01897 {
01898 return pEnv->CallLongMethod(jObject,meth_getRowCount);
01899 }
01900
01901 int32_t ProxyMultiUseBufferingStreamDef::getReaderRefCountParamId()
01902 {
01903 return pEnv->CallIntMethod(jObject,meth_getReaderRefCountParamId);
01904 }
01905
01906 SharedProxyCorrelation ProxyNestedLoopJoinStreamDef::getLeftJoinKey()
01907 {
01908 SharedProxyCorrelation p;
01909 p->pEnv = pEnv;
01910 p->jObject = pEnv->CallObjectMethod(jObject,meth_getLeftJoinKey);
01911 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01912 ++p;
01913 return p;
01914 }
01915
01916 int32_t ProxyReshapeParameter::getCompareOffset()
01917 {
01918 return pEnv->CallIntMethod(jObject,meth_getCompareOffset);
01919 }
01920
01921 int32_t ProxyReshapeParameter::getDynamicParamId()
01922 {
01923 return pEnv->CallIntMethod(jObject,meth_getDynamicParamId);
01924 }
01925
01926 bool ProxyReshapeParameter::isOutputParam()
01927 {
01928 return pEnv->CallBooleanMethod(jObject,meth_isOutputParam);
01929 }
01930
01931 SharedProxyReshapeStreamDef ProxyReshapeParameter::getReshape()
01932 {
01933 SharedProxyReshapeStreamDef p;
01934 p->pEnv = pEnv;
01935 p->jObject = pEnv->CallObjectMethod(jObject,meth_getReshape);
01936 if (!p->jObject) p.reset();
01937 return p;
01938 }
01939
01940 CompOperator ProxyReshapeStreamDef::getCompareOp()
01941 {
01942 std::string symbol = constructString(JniUtil::toString(pEnv,pEnv->CallObjectMethod(jObject,meth_getCompareOp)));
01943 return static_cast<CompOperator>(JniUtil::lookUpEnum(CompOperator_names,symbol));
01944 }
01945
01946 SharedProxyTupleProjection ProxyReshapeStreamDef::getInputCompareProjection()
01947 {
01948 SharedProxyTupleProjection p;
01949 p->pEnv = pEnv;
01950 p->jObject = pEnv->CallObjectMethod(jObject,meth_getInputCompareProjection);
01951 if (!p->jObject) p.reset();
01952 return p;
01953 }
01954
01955 SharedProxyTupleProjection ProxyReshapeStreamDef::getOutputProjection()
01956 {
01957 SharedProxyTupleProjection p;
01958 p->pEnv = pEnv;
01959 p->jObject = pEnv->CallObjectMethod(jObject,meth_getOutputProjection);
01960 if (!p->jObject) p.reset();
01961 return p;
01962 }
01963
01964 SharedProxyReshapeParameter ProxyReshapeStreamDef::getReshapeParameter()
01965 {
01966 SharedProxyReshapeParameter p;
01967 p->pEnv = pEnv;
01968 p->jObject = pEnv->CallObjectMethod(jObject,meth_getReshapeParameter);
01969 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
01970 ++p;
01971 return p;
01972 }
01973
01974 std::string ProxyReshapeStreamDef::getTupleCompareBytesBase64()
01975 {
01976 return constructString(pEnv->CallObjectMethod(jObject,meth_getTupleCompareBytesBase64));
01977 }
01978
01979 SharedProxyTupleProjection ProxySortingStreamDef::getDescendingProj()
01980 {
01981 SharedProxyTupleProjection p;
01982 p->pEnv = pEnv;
01983 p->jObject = pEnv->CallObjectMethod(jObject,meth_getDescendingProj);
01984 if (!p->jObject) p.reset();
01985 return p;
01986 }
01987
01988 Distinctness ProxySortingStreamDef::getDistinctness()
01989 {
01990 std::string symbol = constructString(JniUtil::toString(pEnv,pEnv->CallObjectMethod(jObject,meth_getDistinctness)));
01991 return static_cast<Distinctness>(JniUtil::lookUpEnum(Distinctness_names,symbol));
01992 }
01993
01994 bool ProxySortingStreamDef::isEarlyClose()
01995 {
01996 return pEnv->CallBooleanMethod(jObject,meth_isEarlyClose);
01997 }
01998
01999 int64_t ProxySortingStreamDef::getEstimatedNumRows()
02000 {
02001 return pEnv->CallLongMethod(jObject,meth_getEstimatedNumRows);
02002 }
02003
02004 SharedProxyLbmSplicerStreamDef ProxySplicerIndexAccessorDef::getSplicer()
02005 {
02006 SharedProxyLbmSplicerStreamDef p;
02007 p->pEnv = pEnv;
02008 p->jObject = pEnv->CallObjectMethod(jObject,meth_getSplicer);
02009 if (!p->jObject) p.reset();
02010 return p;
02011 }
02012
02013 SharedProxyTupleProjection ProxyTableUpdaterDef::getUpdateProj()
02014 {
02015 SharedProxyTupleProjection p;
02016 p->pEnv = pEnv;
02017 p->jObject = pEnv->CallObjectMethod(jObject,meth_getUpdateProj);
02018 if (!p->jObject) p.reset();
02019 return p;
02020 }
02021
02022 SharedProxyIndexWriterDef ProxyTableWriterDef::getIndexWriter()
02023 {
02024 SharedProxyIndexWriterDef p;
02025 p->pEnv = pEnv;
02026 p->jObject = pEnv->CallObjectMethod(jObject,meth_getIndexWriter);
02027 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
02028 ++p;
02029 return p;
02030 }
02031
02032 SharedProxyTupleAttrAccessor ProxyTupleAccessor::getAttrAccessor()
02033 {
02034 SharedProxyTupleAttrAccessor p;
02035 p->pEnv = pEnv;
02036 p->jObject = pEnv->CallObjectMethod(jObject,meth_getAttrAccessor);
02037 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
02038 ++p;
02039 return p;
02040 }
02041
02042 int32_t ProxyTupleAccessor::getBitFieldOffset()
02043 {
02044 return pEnv->CallIntMethod(jObject,meth_getBitFieldOffset);
02045 }
02046
02047 int32_t ProxyTupleAccessor::getMinByteLength()
02048 {
02049 return pEnv->CallIntMethod(jObject,meth_getMinByteLength);
02050 }
02051
02052 int32_t ProxyTupleAttrAccessor::getBitValueIndex()
02053 {
02054 return pEnv->CallIntMethod(jObject,meth_getBitValueIndex);
02055 }
02056
02057 int32_t ProxyTupleAttrAccessor::getEndIndirectOffset()
02058 {
02059 return pEnv->CallIntMethod(jObject,meth_getEndIndirectOffset);
02060 }
02061
02062 int32_t ProxyTupleAttrAccessor::getFixedOffset()
02063 {
02064 return pEnv->CallIntMethod(jObject,meth_getFixedOffset);
02065 }
02066
02067 int32_t ProxyTupleAttrAccessor::getNullBitIndex()
02068 {
02069 return pEnv->CallIntMethod(jObject,meth_getNullBitIndex);
02070 }
02071
02072 int32_t ProxyTupleAttrDescriptor::getByteLength()
02073 {
02074 return pEnv->CallIntMethod(jObject,meth_getByteLength);
02075 }
02076
02077 bool ProxyTupleAttrDescriptor::isNullable()
02078 {
02079 return pEnv->CallBooleanMethod(jObject,meth_isNullable);
02080 }
02081
02082 int32_t ProxyTupleAttrDescriptor::getTypeOrdinal()
02083 {
02084 return pEnv->CallIntMethod(jObject,meth_getTypeOrdinal);
02085 }
02086
02087 int32_t ProxyTupleAttrProjection::getAttributeIndex()
02088 {
02089 return pEnv->CallIntMethod(jObject,meth_getAttributeIndex);
02090 }
02091
02092 SharedProxyTupleAttrDescriptor ProxyTupleDescriptor::getAttrDescriptor()
02093 {
02094 SharedProxyTupleAttrDescriptor p;
02095 p->pEnv = pEnv;
02096 p->jObject = pEnv->CallObjectMethod(jObject,meth_getAttrDescriptor);
02097 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
02098 ++p;
02099 return p;
02100 }
02101
02102 SharedProxyTupleAttrProjection ProxyTupleProjection::getAttrProjection()
02103 {
02104 SharedProxyTupleAttrProjection p;
02105 p->pEnv = pEnv;
02106 p->jObject = pEnv->CallObjectMethod(jObject,meth_getAttrProjection);
02107 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
02108 ++p;
02109 return p;
02110 }
02111
02112 SharedProxyStreamGraphHandle ProxyTupleStreamGraphCmd::getStreamGraphHandle()
02113 {
02114 SharedProxyStreamGraphHandle p;
02115 p->pEnv = pEnv;
02116 p->jObject = pEnv->CallObjectMethod(jObject,meth_getStreamGraphHandle);
02117 if (!p->jObject) p.reset();
02118 return p;
02119 }
02120
02121 SharedProxyTxnHandle ProxyTxnCmd::getTxnHandle()
02122 {
02123 SharedProxyTxnHandle p;
02124 p->pEnv = pEnv;
02125 p->jObject = pEnv->CallObjectMethod(jObject,meth_getTxnHandle);
02126 if (!p->jObject) p.reset();
02127 return p;
02128 }
02129
02130 std::string ProxyValuesStreamDef::getTupleBytesBase64()
02131 {
02132 return constructString(pEnv->CallObjectMethod(jObject,meth_getTupleBytesBase64));
02133 }
02134
02135 int32_t ProxyWindowDef::getOffset()
02136 {
02137 return pEnv->CallIntMethod(jObject,meth_getOffset);
02138 }
02139
02140 SharedProxyTupleProjection ProxyWindowDef::getOrderKeyList()
02141 {
02142 SharedProxyTupleProjection p;
02143 p->pEnv = pEnv;
02144 p->jObject = pEnv->CallObjectMethod(jObject,meth_getOrderKeyList);
02145 if (!p->jObject) p.reset();
02146 return p;
02147 }
02148
02149 SharedProxyWindowPartitionDef ProxyWindowDef::getPartition()
02150 {
02151 SharedProxyWindowPartitionDef p;
02152 p->pEnv = pEnv;
02153 p->jObject = pEnv->CallObjectMethod(jObject,meth_getPartition);
02154 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
02155 ++p;
02156 return p;
02157 }
02158
02159 bool ProxyWindowDef::isPhysical()
02160 {
02161 return pEnv->CallBooleanMethod(jObject,meth_isPhysical);
02162 }
02163
02164 std::string ProxyWindowDef::getRange()
02165 {
02166 return constructString(pEnv->CallObjectMethod(jObject,meth_getRange));
02167 }
02168
02169 SharedProxyWindowStreamDef ProxyWindowDef::getWindowStream()
02170 {
02171 SharedProxyWindowStreamDef p;
02172 p->pEnv = pEnv;
02173 p->jObject = pEnv->CallObjectMethod(jObject,meth_getWindowStream);
02174 if (!p->jObject) p.reset();
02175 return p;
02176 }
02177
02178 std::string ProxyWindowPartitionDef::getAddProgram()
02179 {
02180 return constructString(pEnv->CallObjectMethod(jObject,meth_getAddProgram));
02181 }
02182
02183 SharedProxyTupleDescriptor ProxyWindowPartitionDef::getBucketDesc()
02184 {
02185 SharedProxyTupleDescriptor p;
02186 p->pEnv = pEnv;
02187 p->jObject = pEnv->CallObjectMethod(jObject,meth_getBucketDesc);
02188 if (!p->jObject) p.reset();
02189 return p;
02190 }
02191
02192 std::string ProxyWindowPartitionDef::getDropProgram()
02193 {
02194 return constructString(pEnv->CallObjectMethod(jObject,meth_getDropProgram));
02195 }
02196
02197 std::string ProxyWindowPartitionDef::getInitializeProgram()
02198 {
02199 return constructString(pEnv->CallObjectMethod(jObject,meth_getInitializeProgram));
02200 }
02201
02202 SharedProxyTupleProjection ProxyWindowPartitionDef::getPartitionKeyList()
02203 {
02204 SharedProxyTupleProjection p;
02205 p->pEnv = pEnv;
02206 p->jObject = pEnv->CallObjectMethod(jObject,meth_getPartitionKeyList);
02207 if (!p->jObject) p.reset();
02208 return p;
02209 }
02210
02211 SharedProxyWindowDef ProxyWindowPartitionDef::getWindow()
02212 {
02213 SharedProxyWindowDef p;
02214 p->pEnv = pEnv;
02215 p->jObject = pEnv->CallObjectMethod(jObject,meth_getWindow);
02216 if (!p->jObject) p.reset();
02217 return p;
02218 }
02219
02220 bool ProxyWindowStreamDef::isFilter()
02221 {
02222 return pEnv->CallBooleanMethod(jObject,meth_isFilter);
02223 }
02224
02225 SharedProxyTupleProjection ProxyWindowStreamDef::getInputOrderKeyList()
02226 {
02227 SharedProxyTupleProjection p;
02228 p->pEnv = pEnv;
02229 p->jObject = pEnv->CallObjectMethod(jObject,meth_getInputOrderKeyList);
02230 if (!p->jObject) p.reset();
02231 return p;
02232 }
02233
02234 std::string ProxyWindowStreamDef::getOutputProgram()
02235 {
02236 return constructString(pEnv->CallObjectMethod(jObject,meth_getOutputProgram));
02237 }
02238
02239 SharedProxyWindowDef ProxyWindowStreamDef::getWindow()
02240 {
02241 SharedProxyWindowDef p;
02242 p->pEnv = pEnv;
02243 p->jObject = pEnv->CallObjectMethod(jObject,meth_getWindow);
02244 p.jIter = JniUtil::getIter(p->pEnv,p->jObject);
02245 ++p;
02246 return p;
02247 }
02248