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
Public Member Functions | List of all members
pdb::JoinTupleSingleton Class Referenceabstract

#include <JoinTuple.h>

+ Inheritance diagram for pdb::JoinTupleSingleton:
+ Collaboration diagram for pdb::JoinTupleSingleton:

Public Member Functions

virtual ComputeExecutorPtr getProber (void *hashTable, std::vector< int > &positions, TupleSpec &inputSchema, TupleSpec &attsToOperateOn, TupleSpec &attsToIncludeInOutput, bool needToSwapLHSAndRhs)=0
 
virtual ComputeSinkPtr getSink (TupleSpec &consumeMe, TupleSpec &attsToOpOn, TupleSpec &projection, std::vector< int > &whereEveryoneGoes)=0
 
virtual ComputeSinkPtr getPartitionedSink (int numPartitionsPerNode, int numNodes, TupleSpec &consumeMe, TupleSpec &attsToOpOn, TupleSpec &projection, std::vector< int > &whereEveryoneGoes)=0
 
virtual ComputeSourcePtr getPartitionedSource (size_t myPartitionId, std::function< PDBPagePtr()> getAnotherVector, std::function< void(PDBPagePtr)> doneWithVector, size_t chunkSize, std::vector< int > &whereEveryoneGoes)=0
 
virtual SinkMergerPtr getMerger ()=0
 
virtual SinkShufflerPtr getShuffler ()=0
 

Detailed Description

Definition at line 1152 of file JoinTuple.h.

Member Function Documentation

virtual SinkMergerPtr pdb::JoinTupleSingleton::getMerger ( )
pure virtual

Implemented in pdb::JoinSingleton< HoldMe >.

virtual ComputeSinkPtr pdb::JoinTupleSingleton::getPartitionedSink ( int  numPartitionsPerNode,
int  numNodes,
TupleSpec &  consumeMe,
TupleSpec &  attsToOpOn,
TupleSpec &  projection,
std::vector< int > &  whereEveryoneGoes 
)
pure virtual

Implemented in pdb::JoinSingleton< HoldMe >.

virtual ComputeSourcePtr pdb::JoinTupleSingleton::getPartitionedSource ( size_t  myPartitionId,
std::function< PDBPagePtr()>  getAnotherVector,
std::function< void(PDBPagePtr)>  doneWithVector,
size_t  chunkSize,
std::vector< int > &  whereEveryoneGoes 
)
pure virtual

Implemented in pdb::JoinSingleton< HoldMe >.

virtual ComputeExecutorPtr pdb::JoinTupleSingleton::getProber ( void *  hashTable,
std::vector< int > &  positions,
TupleSpec &  inputSchema,
TupleSpec &  attsToOperateOn,
TupleSpec &  attsToIncludeInOutput,
bool  needToSwapLHSAndRhs 
)
pure virtual

Implemented in pdb::JoinSingleton< HoldMe >.

virtual SinkShufflerPtr pdb::JoinTupleSingleton::getShuffler ( )
pure virtual

Implemented in pdb::JoinSingleton< HoldMe >.

virtual ComputeSinkPtr pdb::JoinTupleSingleton::getSink ( TupleSpec &  consumeMe,
TupleSpec &  attsToOpOn,
TupleSpec &  projection,
std::vector< int > &  whereEveryoneGoes 
)
pure virtual

Implemented in pdb::JoinSingleton< HoldMe >.

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