Package | Description |
---|---|
io.druid.segment.realtime.appenderator |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
StreamAppenderatorDriver.publish(TransactionalSegmentPublisher publisher,
Committer committer,
Collection<String> sequenceNames)
Execute a task in background to publish all segments corresponding to the given sequence names.
|
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
BatchAppenderatorDriver.publishAll(TransactionalSegmentPublisher publisher)
Publish all segments.
|
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
StreamAppenderatorDriver.publishAndRegisterHandoff(TransactionalSegmentPublisher publisher,
Committer committer,
Collection<String> sequenceNames) |
Copyright © 2011–2018. All rights reserved.