|
| ENABLE_DEEP_COPY | ScanDoubleVectorSet () |
| |
| | ScanDoubleVectorSet (std::string dbName, std::string setName) |
| |
| | ScanUserSet ()=default |
| |
| | ScanUserSet (std::string dbName, std::string setName) |
| |
| | ScanUserSetBase ()=default |
| |
| | ScanUserSetBase (std::string dbName, std::string setName) |
| |
| | ~ScanUserSetBase () |
| |
| void | setUpAndCopyFrom (void *target, void *source) const override |
| |
| void | deleteObject (void *deleteMe) override |
| |
| size_t | getSize (void *forMe) override |
| |
| ComputeSourcePtr | getComputeSource (TupleSpec &schema, ComputePlan &plan) override |
| |
| void | setIterator (PageCircularBufferIteratorPtr iterator) |
| |
| void | setProxy (DataProxyPtr proxy) |
| |
| void | setBatchSize (int batchSize) override |
| |
| int | getBatchSize () |
| |
| void | setOutput (std::string dbName, std::string setName) override |
| |
| void | setDatabaseName (std::string dbName) |
| |
| void | setSetName (std::string setName) |
| |
| std::string | getDatabaseName () override |
| |
| std::string | getSetName () override |
| |
| std::string | getComputationType () override |
| |
| ComputationTypeID | getComputationTypeID () override |
| |
| std::string | toTCAPString (std::vector< InputTupleSetSpecifier > &inputTupleSets, int computationLabel, std::string &outputTupleSetName, std::vector< std::string > &outputColumnNames, std::string &addedOutputColumnName) override |
| |
| std::string | toTCAPString (std::string inputTupleSetName, std::vector< std::string > &inputColumnNames, std::vector< std::string > &inputColumnsToApply, int computationLabel, std::string &outputTupleSetName, std::vector< std::string > &outputColumnNames, std::string &addedOutputColumnName) |
| |
| int | getNumInputs () override |
| |
| std::string | getIthInputType (int i) override |
| |
| std::string | getOutputType () override |
| |
| bool | needsMaterializeOutput () override |
| |
| virtual void | extractLambdas (std::map< std::string, GenericLambdaObjectPtr > &returnVal) |
| |
| virtual ComputeSinkPtr | getComputeSink (TupleSpec &consumeMe, TupleSpec &projection, ComputePlan &plan) |
| |
| virtual ComputeSinkPtr | getComputeSink (TupleSpec &consumeMe, TupleSpec &whichAttsToOpOn, TupleSpec &projection, ComputePlan &plan) |
| |
| virtual SinkMergerPtr | getSinkMerger (TupleSpec &consumeMe, TupleSpec &projection, ComputePlan &plan) |
| |
| virtual SinkMergerPtr | getSinkMerger (TupleSpec &consumeMe, TupleSpec &whichAttsToOpOn, TupleSpec &projection, ComputePlan &plan) |
| |
| virtual SinkShufflerPtr | getSinkShuffler (TupleSpec &consumeMe, TupleSpec &projection, ComputePlan &plan) |
| | JiaNote: add below interface for shuffling multiple join map sinks for hash partitioned join. More...
|
| |
| virtual SinkShufflerPtr | getSinkShuffler (TupleSpec &consumeMe, TupleSpec &whichAttsToOpOn, TupleSpec &projection, ComputePlan &plan) |
| |
| bool | hasInput () |
| |
| Handle< Computation > & | getIthInput (int i) const |
| |
| int | getNumConsumers () |
| |
| void | setNumConsumers (int numConsumers) |
| |
| bool | setInput (Handle< Computation > toMe) |
| |
| bool | setInput (int whichSlot, Handle< Computation > toMe) |
| |
| bool | isTraversed () |
| |
| void | setTraversed (bool traversed) |
| |
| std::string | getOutputTupleSetName () |
| |
| void | setOutputTupleSetName (std::string outputTupleSetName) |
| |
| std::string | getOutputColumnToApply () |
| |
| void | setOutputColumnToApply (std::string outputColumnToApply) |
| |
| virtual bool | isUsingCombiner () |
| |
| virtual void | setUsingCombiner (bool useCombinerOrNot) |
| |
| void | setAllocatorPolicy (AllocatorPolicy myPolicy) |
| |
| void | setObjectPolicy (ObjectPolicy myPolicy) |
| |
| AllocatorPolicy | getAllocatorPolicy () |
| |
| ObjectPolicy | getObjectPolicy () |
| |
| virtual void | setCollectAsMap (bool collectAsMapOrNot) |
| |
| virtual bool | isCollectAsMap () |
| |
| virtual int | getNumNodesToCollect () |
| |
| virtual void | setNumNodesToCollect (int numNodesToCollect) |
| |
| void | setVTablePtr (void *setToMe) |
| |
| void * | getVTablePtr () |
| |
Definition at line 28 of file ScanDoubleVectorSet.h.