Uses of Interface
io.druid.segment.realtime.plumber.RejectionPolicyFactory

Packages that use RejectionPolicyFactory

Package	Description
io.druid.indexing.common.task
io.druid.segment.indexing
io.druid.segment.realtime.plumber

Uses of RejectionPolicyFactory in io.druid.indexing.common.task

Constructors in io.druid.indexing.common.task with parameters of type RejectionPolicyFactory

Constructor and Description
RealtimeIndexTask(String id, TaskResource taskResource, FireDepartment fireDepartment, Schema spec, io.druid.data.input.FirehoseFactory firehoseFactory, FireDepartmentConfig fireDepartmentConfig, org.joda.time.Period windowPeriod, int maxPendingPersists, com.metamx.common.Granularity segmentGranularity, RejectionPolicyFactory rejectionPolicy, RejectionPolicyFactory rejectionPolicyFactory)

Uses of RejectionPolicyFactory in io.druid.segment.indexing

Methods in io.druid.segment.indexing that return RejectionPolicyFactory

Modifier and Type	Method and Description
RejectionPolicyFactory	RealtimeTuningConfig.getRejectionPolicyFactory()

Constructors in io.druid.segment.indexing with parameters of type RejectionPolicyFactory

Constructor and Description
RealtimeTuningConfig(Integer maxRowsInMemory, org.joda.time.Period intermediatePersistPeriod, org.joda.time.Period windowPeriod, File basePersistDirectory, VersioningPolicy versioningPolicy, RejectionPolicyFactory rejectionPolicyFactory, Integer maxPendingPersists, io.druid.timeline.partition.ShardSpec shardSpec)

Uses of RejectionPolicyFactory in io.druid.segment.realtime.plumber

Classes in io.druid.segment.realtime.plumber that implement RejectionPolicyFactory

Modifier and Type	Class and Description
class	MessageTimeRejectionPolicyFactory
class	NoopRejectionPolicyFactory
class	ServerTimeRejectionPolicyFactory
class	TestRejectionPolicyFactory

Methods in io.druid.segment.realtime.plumber that return RejectionPolicyFactory

Modifier and Type	Method and Description
RejectionPolicyFactory	RealtimePlumberSchool.getRejectionPolicyFactory() Deprecated.

Constructors in io.druid.segment.realtime.plumber with parameters of type RejectionPolicyFactory

Constructor and Description
FlushingPlumberSchool(org.joda.time.Duration flushDuration, com.metamx.emitter.service.ServiceEmitter emitter, QueryRunnerFactoryConglomerate conglomerate, DataSegmentAnnouncer segmentAnnouncer, ExecutorService queryExecutorService, org.joda.time.Period windowPeriod, File basePersistDirectory, com.metamx.common.Granularity segmentGranularity, VersioningPolicy versioningPolicy, RejectionPolicyFactory rejectionPolicy, RejectionPolicyFactory rejectionPolicyFactory, int maxPendingPersists)
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)