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 | |
~JoinSink () | |
JoinSink (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 | keyAtt |
std::vector< int > | useTheseAtts |
std::vector< int > | whereEveryoneGoes |
void ** | columns = nullptr |
Definition at line 1027 of file JoinTuple.h.
|
inline |
Definition at line 1045 of file JoinTuple.h.
|
inline |
|
inlineoverridevirtual |
Implements pdb::ComputeSink.
Definition at line 1067 of file JoinTuple.h.
|
inlineoverridevirtual |
Implements pdb::ComputeSink.
Definition at line 1074 of file JoinTuple.h.
|
private |
Definition at line 1042 of file JoinTuple.h.
|
private |
Definition at line 1031 of file JoinTuple.h.
|
private |
Definition at line 1035 of file JoinTuple.h.
|
private |
Definition at line 1039 of file JoinTuple.h.