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
pdb::VectorSink< DataType > Class Template Reference

#include <VectorSink.h>

+ Inheritance diagram for pdb::VectorSink< DataType >:
+ Collaboration diagram for pdb::VectorSink< DataType >:

Public Member Functions

 VectorSink (TupleSpec &inputSchema, TupleSpec &attsToOperateOn)
 
Handle< ObjectcreateNewOutputContainer () override
 
void writeOut (TupleSetPtr input, Handle< Object > &writeToMe) override
 
 ~VectorSink ()
 
- Public Member Functions inherited from pdb::ComputeSink
virtual ~ComputeSink ()
 

Private Attributes

int whichAttToStore
 
int whichAttToAggregate
 

Detailed Description

template<typename DataType>
class pdb::VectorSink< DataType >

Definition at line 31 of file VectorSink.h.

Constructor & Destructor Documentation

template<typename DataType >
pdb::VectorSink< DataType >::VectorSink ( TupleSpec inputSchema,
TupleSpec attsToOperateOn 
)
inline

Definition at line 39 of file VectorSink.h.

+ Here is the call graph for this function:

template<typename DataType >
pdb::VectorSink< DataType >::~VectorSink ( )
inline

Definition at line 81 of file VectorSink.h.

Member Function Documentation

template<typename DataType >
Handle<Object> pdb::VectorSink< DataType >::createNewOutputContainer ( )
inlineoverridevirtual

Implements pdb::ComputeSink.

Definition at line 50 of file VectorSink.h.

template<typename DataType >
void pdb::VectorSink< DataType >::writeOut ( TupleSetPtr  input,
Handle< Object > &  writeToMe 
)
inlineoverridevirtual

Implements pdb::ComputeSink.

Definition at line 57 of file VectorSink.h.

Member Data Documentation

template<typename DataType >
int pdb::VectorSink< DataType >::whichAttToAggregate
private

Definition at line 36 of file VectorSink.h.

template<typename DataType >
int pdb::VectorSink< DataType >::whichAttToStore
private

Definition at line 35 of file VectorSink.h.


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