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::PartitionedJoinSink< RHSType > Class Template Reference

#include <JoinTuple.h>

+ Inheritance diagram for pdb::PartitionedJoinSink< RHSType >:
+ Collaboration diagram for pdb::PartitionedJoinSink< RHSType >:

Public Member Functions

 ~PartitionedJoinSink ()
 
 PartitionedJoinSink (int numPartitionsPerNode, int numNodes, TupleSpec &inputSchema, TupleSpec &attsToOperateOn, TupleSpec &additionalAtts, std::vector< int > &whereEveryoneGoes)
 
Handle< Object > createNewOutputContainer () override
 
void writeOut (TupleSetPtr input, Handle< Object > &writeToMe) override
 
- Public Member Functions inherited from pdb::ComputeSink
virtual ~ComputeSink ()
 

Private Attributes

int numPartitionsPerNode
 
int numNodes
 
int keyAtt
 
std::vector< int > useTheseAtts
 
std::vector< int > whereEveryoneGoes
 
void ** columns = nullptr
 

Detailed Description

template<typename RHSType>
class pdb::PartitionedJoinSink< RHSType >

Definition at line 869 of file JoinTuple.h.

Constructor & Destructor Documentation

template<typename RHSType >
pdb::PartitionedJoinSink< RHSType >::~PartitionedJoinSink ( )
inline

Definition at line 893 of file JoinTuple.h.

template<typename RHSType >
pdb::PartitionedJoinSink< RHSType >::PartitionedJoinSink ( int  numPartitionsPerNode,
int  numNodes,
TupleSpec &  inputSchema,
TupleSpec &  attsToOperateOn,
TupleSpec &  additionalAtts,
std::vector< int > &  whereEveryoneGoes 
)
inline

Definition at line 898 of file JoinTuple.h.

+ Here is the call graph for this function:

Member Function Documentation

template<typename RHSType >
Handle<Object> pdb::PartitionedJoinSink< RHSType >::createNewOutputContainer ( )
inlineoverridevirtual

Implements pdb::ComputeSink.

Definition at line 921 of file JoinTuple.h.

template<typename RHSType >
void pdb::PartitionedJoinSink< RHSType >::writeOut ( TupleSetPtr  input,
Handle< Object > &  writeToMe 
)
inlineoverridevirtual

Implements pdb::ComputeSink.

Definition at line 938 of file JoinTuple.h.

+ Here is the call graph for this function:

Member Data Documentation

template<typename RHSType >
void** pdb::PartitionedJoinSink< RHSType >::columns = nullptr
private

Definition at line 890 of file JoinTuple.h.

template<typename RHSType >
int pdb::PartitionedJoinSink< RHSType >::keyAtt
private

Definition at line 879 of file JoinTuple.h.

template<typename RHSType >
int pdb::PartitionedJoinSink< RHSType >::numNodes
private

Definition at line 876 of file JoinTuple.h.

template<typename RHSType >
int pdb::PartitionedJoinSink< RHSType >::numPartitionsPerNode
private

Definition at line 873 of file JoinTuple.h.

template<typename RHSType >
std::vector<int> pdb::PartitionedJoinSink< RHSType >::useTheseAtts
private

Definition at line 883 of file JoinTuple.h.

template<typename RHSType >
std::vector<int> pdb::PartitionedJoinSink< RHSType >::whereEveryoneGoes
private

Definition at line 887 of file JoinTuple.h.

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