| Package | Description |
|---|---|
| io.druid.segment.realtime.appenderator |
| Modifier and Type | Method and Description |
|---|---|
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
AppenderatorDriver.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> |
AppenderatorDriver.publishAndRegisterHandoff(TransactionalSegmentPublisher publisher,
Committer committer,
Collection<String> sequenceNames) |
Copyright © 2011–2017. All rights reserved.