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 | Private Attributes | List of all members
pdb::JoinSingleton< HoldMe > Class Template Reference

#include <JoinTuple.h>

+ Inheritance diagram for pdb::JoinSingleton< HoldMe >:
+ Collaboration diagram for pdb::JoinSingleton< HoldMe >:

Public Member Functions

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

Private Attributes

HoldMe myData
 

Detailed Description

template<typename HoldMe>
class pdb::JoinSingleton< HoldMe >

Definition at line 1188 of file JoinTuple.h.

Member Function Documentation

template<typename HoldMe >
SinkMergerPtr pdb::JoinSingleton< HoldMe >::getMerger ( )
inlineoverridevirtual

Implements pdb::JoinTupleSingleton.

Definition at line 1241 of file JoinTuple.h.

template<typename HoldMe >
ComputeSinkPtr pdb::JoinSingleton< HoldMe >::getPartitionedSink ( int  numPartitionsPerNode,
int  numNodes,
TupleSpec &  consumeMe,
TupleSpec &  attsToOpOn,
TupleSpec &  projection,
std::vector< int > &  whereEveryoneGoes 
)
inlineoverridevirtual

Implements pdb::JoinTupleSingleton.

Definition at line 1219 of file JoinTuple.h.

template<typename HoldMe >
ComputeSourcePtr pdb::JoinSingleton< HoldMe >::getPartitionedSource ( size_t  myPartitionId,
std::function< PDBPagePtr()>  getAnotherVector,
std::function< void(PDBPagePtr)>  doneWithVector,
size_t  chunkSize,
std::vector< int > &  whereEveryoneGoes 
)
inlineoverridevirtual

Implements pdb::JoinTupleSingleton.

Definition at line 1230 of file JoinTuple.h.

template<typename HoldMe >
ComputeExecutorPtr pdb::JoinSingleton< HoldMe >::getProber ( void *  hashTable,
std::vector< int > &  positions,
TupleSpec &  inputSchema,
TupleSpec &  attsToOperateOn,
TupleSpec &  attsToIncludeInOutput,
bool  needToSwapLHSAndRhs 
)
inlineoverridevirtual

Implements pdb::JoinTupleSingleton.

Definition at line 1195 of file JoinTuple.h.

template<typename HoldMe >
SinkShufflerPtr pdb::JoinSingleton< HoldMe >::getShuffler ( )
inlineoverridevirtual

Implements pdb::JoinTupleSingleton.

Definition at line 1246 of file JoinTuple.h.

template<typename HoldMe >
ComputeSinkPtr pdb::JoinSingleton< HoldMe >::getSink ( TupleSpec &  consumeMe,
TupleSpec &  attsToOpOn,
TupleSpec &  projection,
std::vector< int > &  whereEveryoneGoes 
)
inlineoverridevirtual

Implements pdb::JoinTupleSingleton.

Definition at line 1210 of file JoinTuple.h.

Member Data Documentation

template<typename HoldMe >
HoldMe pdb::JoinSingleton< HoldMe >::myData
private

Definition at line 1191 of file JoinTuple.h.

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