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 <HashSink.h>
Public Member Functions | |
HashSink (TupleSpec &inputSchema, TupleSpec &attsToOperateOn) | |
Handle< Object > | createNewOutputContainer () override |
void | writeOut (TupleSetPtr input, Handle< Object > &writeToMe) override |
~HashSink () | |
Public Member Functions inherited from pdb::ComputeSink | |
virtual | ~ComputeSink () |
Private Attributes | |
int | whichAttToHash |
int | whichAttToAggregate |
Definition at line 31 of file HashSink.h.
|
inline |
|
inline |
Definition at line 137 of file HashSink.h.
|
inlineoverridevirtual |
Implements pdb::ComputeSink.
Definition at line 51 of file HashSink.h.
|
inlineoverridevirtual |
Implements pdb::ComputeSink.
Definition at line 58 of file HashSink.h.
|
private |
Definition at line 36 of file HashSink.h.
|
private |
Definition at line 35 of file HashSink.h.