| 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.