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.
|
#include <SelectionCompBase.h>
Public Member Functions | |
virtual Lambda< bool > | getSelection (Handle< InputClass > checkMe)=0 |
virtual Lambda< Handle < OutputClass > > | getProjection (Handle< InputClass > checkMe)=0 |
void | extractLambdas (std::map< std::string, GenericLambdaObjectPtr > &returnVal) override |
std::string | getComputationType () override |
ComputationTypeID | getComputationTypeID () override |
std::string | getIthInputType (int i) override |
int | getNumInputs () override |
std::string | getOutputType () 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, std::vector< std::string > &childrenLambdaNames, int computationLabel, std::string &outputTupleSetName, std::vector< std::string > &outputColumnNames, std::string &addedOutputColumnName, std::string &myLambdaName) |
void | setOutput (std::string dbName, std::string setName) override |
void | setBatchSize (int batchSize) override |
std::string | getDatabaseName () override |
std::string | getSetName () override |
ComputeSourcePtr | getComputeSource (TupleSpec &outputScheme, ComputePlan &plan) override |
ComputeSinkPtr | getComputeSink (TupleSpec &consumeMe, TupleSpec &projection, ComputePlan &plan) override |
bool | needsMaterializeOutput () override |
Handle< ScanUserSet < OutputClass > > & | getOutputSetScanner () |
Public Member Functions inherited from pdb::Computation | |
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 () |
virtual void | setUpAndCopyFrom (void *target, void *source) const |
virtual void | deleteObject (void *deleteMe) |
virtual size_t | getSize (void *ofMe) |
Private Attributes | |
bool | materializeSelectionOut = false |
Handle< ScanUserSet < OutputClass > > | outputSetScanner = nullptr |
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) |
Definition at line 29 of file SelectionCompBase.h.
|
inlineoverridevirtual |
calls getProjection and getSelection to extract the lambdas
returnVal |
Reimplemented from pdb::Computation.
Definition at line 52 of file SelectionCompBase.h.
|
inlineoverridevirtual |
this is a selection computation
Implements pdb::Computation.
Definition at line 65 of file SelectionCompBase.h.
|
inlineoverridevirtual |
to return the type if of this computation
Implements pdb::Computation.
Definition at line 73 of file SelectionCompBase.h.
|
inlineoverridevirtual |
Sink to write selection output
consumeMe | |
projection | |
plan |
Reimplemented from pdb::Computation.
Definition at line 303 of file SelectionCompBase.h.
|
inlineoverridevirtual |
source for consumer to read selection output, which has been written to a user set
outputScheme | |
plan |
Reimplemented from pdb::Computation.
Definition at line 285 of file SelectionCompBase.h.
|
inlineoverridevirtual |
to return the database name
Reimplemented from pdb::Computation.
Definition at line 267 of file SelectionCompBase.h.
|
inlineoverridevirtual |
gets the name of the i^th input type...
i |
Implements pdb::Computation.
Definition at line 82 of file SelectionCompBase.h.
|
inlineoverridevirtual |
get the number of inputs to this query type
Implements pdb::Computation.
Definition at line 94 of file SelectionCompBase.h.
|
inline |
Definition at line 317 of file SelectionCompBase.h.
|
inlineoverridevirtual |
gets the output type of this query as a string
Implements pdb::Computation.
Definition at line 102 of file SelectionCompBase.h.
|
pure virtual |
the computation returned by this method is called to perfom a transformation on the input item before it is inserted into the output set
checkMe |
Implemented in pdb::SelectionComp< OutputClass, InputClass >.
|
pure virtual |
The computation returned by this method is called to see if a data item should be returned in the output set
checkMe |
Implemented in pdb::SelectionComp< OutputClass, InputClass >.
|
inlineoverridevirtual |
to return the set name
Reimplemented from pdb::Computation.
Definition at line 275 of file SelectionCompBase.h.
|
inlineoverridevirtual |
Reimplemented from pdb::Computation.
Definition at line 313 of file SelectionCompBase.h.
|
inlineoverridevirtual |
Reimplemented from pdb::Computation.
Definition at line 257 of file SelectionCompBase.h.
|
inlineoverridevirtual |
set user set for output when necessary (e.g. results need to be materialized) by default it do nothing, subclasses shall override this function to handle the case when results need to be materialized.
Reimplemented from pdb::Computation.
Definition at line 250 of file SelectionCompBase.h.
|
inlineoverridevirtual |
below function implements the interface for parsing computation into a TCAP string
inputTupleSets | |
computationLabel | |
outputTupleSetName | |
outputColumnNames | |
addedOutputColumnName |
Implements pdb::Computation.
Definition at line 115 of file SelectionCompBase.h.
|
inline |
to return Selection tcap string
inputTupleSetName | |
inputColumnNames | |
inputColumnsToApply | |
childrenLambdaNames | |
computationLabel | |
outputTupleSetName | |
outputColumnNames | |
addedOutputColumnName | |
myLambdaName |
Definition at line 151 of file SelectionCompBase.h.
|
private |
Definition at line 322 of file SelectionCompBase.h.
|
private |
Definition at line 323 of file SelectionCompBase.h.