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 <ShuffleSink.h>
Public Member Functions | |
ShuffleSink (int numPartitions, TupleSpec &inputSchema, TupleSpec &attsToOperateOn) | |
Handle< Object > | createNewOutputContainer () override |
void | writeOut (TupleSetPtr input, Handle< Object > &writeToMe) override |
~ShuffleSink () | |
Public Member Functions inherited from pdb::ComputeSink | |
virtual | ~ComputeSink () |
Private Attributes | |
int | whichAttToHash |
int | whichAttToAggregate |
int | numPartitions |
Definition at line 34 of file ShuffleSink.h.
|
inline |
|
inline |
Definition at line 160 of file ShuffleSink.h.
|
inlineoverridevirtual |
Implements pdb::ComputeSink.
Definition at line 56 of file ShuffleSink.h.
|
inlineoverridevirtual |
Implements pdb::ComputeSink.
Definition at line 69 of file ShuffleSink.h.
|
private |
Definition at line 40 of file ShuffleSink.h.
|
private |
Definition at line 39 of file ShuffleSink.h.
|
private |
Definition at line 38 of file ShuffleSink.h.