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 <JoinTuple.h>
Public Member Functions | |
~JoinSinkShuffler () | |
JoinSinkShuffler () | |
void | setNodeId (int nodeId) override |
int | getNodeId () override |
Handle< Object > | createNewOutputContainer () override |
bool | writeOut (Handle< Object > shuffleMe, Handle< Object > &shuffleToMe) override |
Public Member Functions inherited from pdb::SinkShuffler | |
virtual | ~SinkShuffler () |
Private Attributes | |
int | nodeId |
Definition at line 767 of file JoinTuple.h.
|
inline |
Definition at line 773 of file JoinTuple.h.
|
inline |
Definition at line 775 of file JoinTuple.h.
|
inlineoverridevirtual |
Implements pdb::SinkShuffler.
Definition at line 785 of file JoinTuple.h.
|
inlineoverridevirtual |
Implements pdb::SinkShuffler.
Definition at line 781 of file JoinTuple.h.
|
inlineoverridevirtual |
Implements pdb::SinkShuffler.
Definition at line 777 of file JoinTuple.h.
|
inlineoverridevirtual |
Implements pdb::SinkShuffler.
Definition at line 793 of file JoinTuple.h.
|
private |
Definition at line 770 of file JoinTuple.h.