io.druid.segment.realtime.plumber

Class RealtimePlumberSchool

java.lang.Object

io.druid.segment.realtime.plumber.RealtimePlumberSchool

All Implemented Interfaces:

PlumberSchool

Direct Known Subclasses:

FlushingPlumberSchool

public class RealtimePlumberSchool
extends Object
implements PlumberSchool

Constructor Summary

Constructors

Constructor and Description

RealtimePlumberSchool(com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, io.druid.segment.loading.DataSegmentPusher dataSegmentPusher, DataSegmentAnnouncer segmentAnnouncer, SegmentPublisher segmentPublisher, FilteredServerView serverView, ExecutorService executorService, org.joda.time.Period windowPeriod, File basePersistDirectory, com.metamx.common.Granularity segmentGranularity, VersioningPolicy versioningPolicy, RejectionPolicyFactory rejectionPolicy, RejectionPolicyFactory rejectionPolicyFactory, int maxPendingPersists)

Method Summary

Methods

Modifier and Type	Method and Description
Plumber	findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics) Creates a Plumber
File	getBasePersistDirectory() Deprecated.
int	getMaxPendingPersists() Deprecated.
RejectionPolicyFactory	getRejectionPolicyFactory() Deprecated.
com.metamx.common.Granularity	getSegmentGranularity()
VersioningPolicy	getVersioningPolicy() Deprecated.
org.joda.time.Period	getWindowPeriod() Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

RealtimePlumberSchool

public RealtimePlumberSchool(com.metamx.emitter.service.ServiceEmitter emitter,
                     QueryRunnerFactoryConglomerate conglomerate,
                     io.druid.segment.loading.DataSegmentPusher dataSegmentPusher,
                     DataSegmentAnnouncer segmentAnnouncer,
                     SegmentPublisher segmentPublisher,
                     FilteredServerView serverView,
                     ExecutorService executorService,
                     org.joda.time.Period windowPeriod,
                     File basePersistDirectory,
                     com.metamx.common.Granularity segmentGranularity,
                     VersioningPolicy versioningPolicy,
                     RejectionPolicyFactory rejectionPolicy,
                     RejectionPolicyFactory rejectionPolicyFactory,
                     int maxPendingPersists)

Method Detail

getWindowPeriod

@Deprecated
public org.joda.time.Period getWindowPeriod()

Deprecated.

getBasePersistDirectory

@Deprecated
public File getBasePersistDirectory()

Deprecated.

getSegmentGranularity

public com.metamx.common.Granularity getSegmentGranularity()

Specified by:

getSegmentGranularity in interface PlumberSchool

getVersioningPolicy

@Deprecated
public VersioningPolicy getVersioningPolicy()

Deprecated.

getRejectionPolicyFactory

@Deprecated
public RejectionPolicyFactory getRejectionPolicyFactory()

Deprecated.

getMaxPendingPersists

@Deprecated
public int getMaxPendingPersists()

Deprecated.

findPlumber

public Plumber findPlumber(DataSchema schema,
                  RealtimeTuningConfig config,
                  FireDepartmentMetrics metrics)

Description copied from interface: PlumberSchool

Creates a Plumber

Specified by:

findPlumber in interface PlumberSchool

Returns:

returns a plumber