A platform for high-performance distributed tool and library development written in C++. It can be deployed in two different cluster modes: standalone or distributed. API for v0.5.0, released on June 13, 2018.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
ScanDoubleVectorSet Class Reference

#include <ScanDoubleVectorSet.h>

+ Inheritance diagram for ScanDoubleVectorSet:
+ Collaboration diagram for ScanDoubleVectorSet:

Public Member Functions

ENABLE_DEEP_COPY ScanDoubleVectorSet ()
 
 ScanDoubleVectorSet (std::string dbName, std::string setName)
 
- Public Member Functions inherited from pdb::ScanUserSet< DoubleVector >
 ScanUserSet ()=default
 
 ScanUserSet (std::string dbName, std::string setName)
 
- Public Member Functions inherited from pdb::ScanUserSetBase< DoubleVector >
 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
 
- Public Member Functions inherited from pdb::Computation
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)
 
- Public Member Functions inherited from pdb::Object
void setVTablePtr (void *setToMe)
 
void * getVTablePtr ()
 

Additional Inherited Members

- Static Public Member Functions inherited from pdb::Object
static void * operator new (size_t sz, const std::nothrow_t &tag)
 
static void * operator new (size_t sz)
 
static void operator delete (void *me)
 
static void * operator new (std::size_t count, void *ptr)
 
- Protected Attributes inherited from pdb::ScanUserSetBase< DoubleVector >
PageCircularBufferIteratorPtr iterator
 
DataProxyPtr proxy
 
String dbName
 
String setName
 
int batchSize
 
String outputType
 

Detailed Description

Definition at line 28 of file ScanDoubleVectorSet.h.

Constructor & Destructor Documentation

ENABLE_DEEP_COPY ScanDoubleVectorSet::ScanDoubleVectorSet ( )
inline

Definition at line 33 of file ScanDoubleVectorSet.h.

ScanDoubleVectorSet::ScanDoubleVectorSet ( std::string  dbName,
std::string  setName 
)
inline

Definition at line 35 of file ScanDoubleVectorSet.h.


The documentation for this class was generated from the following file: