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::CombinedShuffleSink< KeyType, ValueType > Class Template Reference

#include <CombinedShuffleSink.h>

+ Inheritance diagram for pdb::CombinedShuffleSink< KeyType, ValueType >:
+ Collaboration diagram for pdb::CombinedShuffleSink< KeyType, ValueType >:

Public Member Functions

 CombinedShuffleSink (int numPartitionsPerNode, int numNodes, TupleSpec &inputSchema, TupleSpec &attsToOperateOn)
 
AggregationMap< KeyType,
ValueType > & 		getMap (HashPartitionID myHashID, Handle< Vector< Handle< Vector< Handle< AggregationMap< KeyType, ValueType >>>>>> outputData)
 
Handle< Object > createNewOutputContainer () override
 
void writeOut (TupleSetPtr input, Handle< Object > &writeToMe) override
 
 ~CombinedShuffleSink ()
 
- Public Member Functions inherited from pdb::ComputeSink
virtual ~ComputeSink ()
 

Private Attributes

int whichAttToHash
 
int whichAttToAggregate
 
int numNodes
 
int numPartitionsPerNode
 

Detailed Description

template<class KeyType, class ValueType>
class pdb::CombinedShuffleSink< KeyType, ValueType >

Definition at line 35 of file CombinedShuffleSink.h.

Constructor & Destructor Documentation

template<class KeyType , class ValueType >
pdb::CombinedShuffleSink< KeyType, ValueType >::CombinedShuffleSink ( int  numPartitionsPerNode,
int  numNodes,
TupleSpec &  inputSchema,
TupleSpec &  attsToOperateOn 
)
inline

Definition at line 45 of file CombinedShuffleSink.h.

+ Here is the call graph for this function:

template<class KeyType , class ValueType >
pdb::CombinedShuffleSink< KeyType, ValueType >::~CombinedShuffleSink ( )
inline

Definition at line 178 of file CombinedShuffleSink.h.

Member Function Documentation

template<class KeyType , class ValueType >
Handle<Object> pdb::CombinedShuffleSink< KeyType, ValueType >::createNewOutputContainer ( )
inlineoverridevirtual

Implements pdb::ComputeSink.

Definition at line 73 of file CombinedShuffleSink.h.

template<class KeyType , class ValueType >
AggregationMap<KeyType, ValueType>& pdb::CombinedShuffleSink< KeyType, ValueType >::getMap ( HashPartitionID  myHashID,
Handle< Vector< Handle< Vector< Handle< AggregationMap< KeyType, ValueType >>>>>>  outputData 
)
inline

Definition at line 64 of file CombinedShuffleSink.h.

+ Here is the caller graph for this function:

template<class KeyType , class ValueType >
void pdb::CombinedShuffleSink< KeyType, ValueType >::writeOut ( TupleSetPtr  input,
Handle< Object > &  writeToMe 
)
inlineoverridevirtual

Implements pdb::ComputeSink.

Definition at line 95 of file CombinedShuffleSink.h.

+ Here is the call graph for this function:

Member Data Documentation

template<class KeyType , class ValueType >
int pdb::CombinedShuffleSink< KeyType, ValueType >::numNodes
private

Definition at line 41 of file CombinedShuffleSink.h.

template<class KeyType , class ValueType >
int pdb::CombinedShuffleSink< KeyType, ValueType >::numPartitionsPerNode
private

Definition at line 42 of file CombinedShuffleSink.h.

template<class KeyType , class ValueType >
int pdb::CombinedShuffleSink< KeyType, ValueType >::whichAttToAggregate
private

Definition at line 40 of file CombinedShuffleSink.h.

template<class KeyType , class ValueType >
int pdb::CombinedShuffleSink< KeyType, ValueType >::whichAttToHash
private

Definition at line 39 of file CombinedShuffleSink.h.

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