Akumuli
 All Classes Namespaces Functions Variables Typedefs Enumerations Enumerator Friends
Public Member Functions | List of all members
Akumuli::IngestionPipeline Class Reference
Inheritance diagram for Akumuli::IngestionPipeline:

Public Member Functions

 IngestionPipeline (std::shared_ptr< DbConnection > con, BackoffPolicy bp=AKU_THROTTLE)
 
void start ()
 
std::shared_ptr< PipelineSpoutmake_spout ()
 
void stop ()
 

Constructor & Destructor Documentation

Akumuli::IngestionPipeline::IngestionPipeline ( std::shared_ptr< DbConnection con,
BackoffPolicy  bp = AKU_THROTTLE 
)

Create new pipeline topology.

Member Function Documentation

std::shared_ptr< PipelineSpout > Akumuli::IngestionPipeline::make_spout ( )

Add new pipeline spout.

void Akumuli::IngestionPipeline::start ( )

Run pipeline topology.


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