FemGeneratedMethods.h Source File (original) (raw)

00001 00002 00003 JniProxyVisitTable 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00261 00262 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemBufferWriterStreamDef"); 00263 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00264 00265 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemBufferingTupleStreamDef"); 00266 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00281 00282 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdAbandonBackup"); 00283 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00284 00285 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdAlterSystemDeallocate"); 00286 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00304 00305 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdCommit"); 00306 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00307 00308 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdCompleteBackup"); 00309 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00319 00320 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdCreateStreamHandle"); 00321 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00328 00329 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdGetLastCommittedTxnId"); 00330 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00331 00332 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdGetTxnCsn"); 00333 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00334 00335 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdInitiateBackup"); 00336 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00368 00369 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdSavepoint"); 00370 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00379 00380 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCmdVerifyIndex"); 00381 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00396 00397 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemColumnName"); 00398 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00415 00416 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemCsnHandleReturningCmd"); 00417 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00431 00432 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemDynamicParamUse"); 00433 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00531 00532 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemIndexWriterDef"); 00533 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00569 00570 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmMinusStreamDef"); 00571 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00572 00573 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmNormalizerStreamDef"); 00574 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00575 00576 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmSearchStreamDef"); 00577 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00583 00584 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLbmSplicerStreamDef"); 00585 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00603 00604 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemLcsClusterScanDef"); 00605 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00676 00677 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemSortingStreamDef"); 00678 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00690 00691 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemStreamGraphHandle"); 00692 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00693 00694 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemStreamHandle"); 00695 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00696 00697 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemSvptHandle"); 00698 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00699 00700 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTableDeleterDef"); 00701 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00702 00703 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTableInserterDef"); 00704 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00705 00706 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTableUpdaterDef"); 00707 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00747 00748 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemTupleStreamGraphCmd"); 00749 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00758 00759 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemUncollectTupleStreamDef"); 00760 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 00761 00762 jClass = pEnv->FindClass("net/sf/farrago/fem/fennel/FemValuesStreamDef"); 00763 visitTbl.addMethod(jClass,JniProxyVisitTable::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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::SharedVisitorMethod(new JniProxyVisitTable::VisitorMethodImpl)); 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(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(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(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(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(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(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(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