Package | Description |
---|---|
io.druid.segment.indexing | |
io.druid.segment.realtime.plumber |
Modifier and Type | Method and Description |
---|---|
VersioningPolicy |
RealtimeTuningConfig.getVersioningPolicy() |
Modifier and Type | Method and Description |
---|---|
RealtimeTuningConfig |
RealtimeTuningConfig.withVersioningPolicy(VersioningPolicy policy) |
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) |
Modifier and Type | Class and Description |
---|---|
class |
CustomVersioningPolicy |
class |
IntervalStartVersioningPolicy |
Modifier and Type | Method and Description |
---|---|
VersioningPolicy |
RealtimePlumberSchool.getVersioningPolicy()
Deprecated.
|
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) |
Copyright © 2015. All rights reserved.