io.druid.segment.realtime.plumber

Class FlushingPlumber

java.lang.Object

io.druid.segment.realtime.plumber.RealtimePlumber

io.druid.segment.realtime.plumber.FlushingPlumber

All Implemented Interfaces:

Plumber

public class FlushingPlumber
extends RealtimePlumber

Constructor Summary

Constructors

Constructor and Description
FlushingPlumber(org.joda.time.Duration flushDuration, DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics, com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ExecutorService queryExecutorService)

Method Summary

Methods

Modifier and Type	Method and Description
void	finishJob() Perform any final processing and clean up after ourselves.
protected void	flushAfterDuration(long truncatedTime, Sink sink)
void	startJob() Perform any initial setup.

Methods inherited from class io.druid.segment.realtime.plumber.RealtimePlumber

abandonSegment, add, bootstrapSinksFromDisk, computeBaseDir, computePersistDir, getConfig, getQueryRunner, getRejectionPolicy, getSchema, getSink, getSinks, initializeExecutors, persist, persistHydrant, shutdownExecutors, startPersistThread

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlushingPlumber

public FlushingPlumber(org.joda.time.Duration flushDuration,
               DataSchema schema,
               RealtimeTuningConfig config,
               FireDepartmentMetrics metrics,
               com.metamx.emitter.service.ServiceEmitter emitter,
               QueryRunnerFactoryConglomerate conglomerate,
               DataSegmentAnnouncer segmentAnnouncer,
               ExecutorService queryExecutorService)

Method Detail

startJob

public void startJob()

Description copied from interface: Plumber

Perform any initial setup. Should be called before using any other methods, and should be paired with a corresponding call to Plumber.finishJob().

Specified by:

startJob in interface Plumber

Overrides:

startJob in class RealtimePlumber

flushAfterDuration

protected void flushAfterDuration(long truncatedTime,
                      Sink sink)

finishJob

public void finishJob()

Description copied from interface: Plumber

Perform any final processing and clean up after ourselves. Should be called after all data has been fed into sinks and persisted.

Specified by:

finishJob in interface Plumber

Overrides:

finishJob in class RealtimePlumber