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.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
Public Member Functions | List of all members
pdb::ComputeSink Class Referenceabstract

#include <ComputeSink.h>

+ Inheritance diagram for pdb::ComputeSink:
+ Collaboration diagram for pdb::ComputeSink:

Public Member Functions

virtual Handle< Object > createNewOutputContainer ()=0
 
virtual void writeOut (TupleSetPtr writeMe, Handle< Object > &writeToMe)=0
 
virtual ~ComputeSink ()
 

Detailed Description

Definition at line 33 of file ComputeSink.h.

Constructor & Destructor Documentation

virtual pdb::ComputeSink::~ComputeSink ( )
inlinevirtual

Definition at line 42 of file ComputeSink.h.

Member Function Documentation

virtual Handle<Object> pdb::ComputeSink::createNewOutputContainer ( )
pure virtual

Implemented in pdb::JoinSink< RHSType >, pdb::PartitionedJoinSink< RHSType >, pdb::CombinedShuffleSink< KeyType, ValueType >, pdb::HashPartitionSink< KeyType, ValueType >, pdb::HashPartitionTransformationSink< ValueType >, pdb::ShuffleSink< KeyType, ValueType >, pdb::HashSink< KeyType, ValueType >, and pdb::VectorSink< DataType >.

virtual void pdb::ComputeSink::writeOut ( TupleSetPtr  writeMe,
Handle< Object > &  writeToMe 
)
pure virtual

Implemented in pdb::JoinSink< RHSType >, pdb::PartitionedJoinSink< RHSType >, pdb::CombinedShuffleSink< KeyType, ValueType >, pdb::HashPartitionTransformationSink< ValueType >, pdb::HashPartitionSink< KeyType, ValueType >, pdb::ShuffleSink< KeyType, ValueType >, pdb::HashSink< KeyType, ValueType >, and pdb::VectorSink< DataType >.

The documentation for this class was generated from the following file: