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 <HashPartitionTransformationSink.h>
Public Member Functions | |
HashPartitionTransformationSink (int numPartitions, int numNodes, TupleSpec &inputSchema, TupleSpec &attToOperateOn) | |
Handle< Object > | createNewOutputContainer () override |
void | writeOut (TupleSetPtr input, Handle< Object > &writeToMe) override |
~HashPartitionTransformationSink () | |
Public Member Functions inherited from pdb::ComputeSink | |
virtual | ~ComputeSink () |
Private Attributes | |
int | whichAttToHash |
int | numPartitions |
int | numNodes |
Definition at line 34 of file HashPartitionTransformationSink.h.
|
inline |
constructor.
numPartitions | number of partitions in the cluster |
inputSchema | the schema of input tuple set |
attToOperateOn | the column that we want to partition and keep |
Definition at line 45 of file HashPartitionTransformationSink.h.
|
inline |
Definition at line 125 of file HashPartitionTransformationSink.h.
|
inlineoverridevirtual |
create container for output
Implements pdb::ComputeSink.
Definition at line 62 of file HashPartitionTransformationSink.h.
|
inlineoverridevirtual |
partition the input tuple set, and store the partitioned result to the output container
input | the input tuple set |
writeToMe | the output container |
Implements pdb::ComputeSink.
Definition at line 89 of file HashPartitionTransformationSink.h.
|
private |
Definition at line 136 of file HashPartitionTransformationSink.h.
|
private |
Definition at line 133 of file HashPartitionTransformationSink.h.
|
private |
Definition at line 130 of file HashPartitionTransformationSink.h.