| Package | Description |
|---|---|
| io.druid.segment.realtime.appenderator |
| Modifier and Type | Method and Description |
|---|---|
SegmentsAndMetadata |
FiniteAppenderatorDriver.finish(TransactionalSegmentPublisher publisher,
Committer committer)
Publish all data indexed through this driver so far, and waits for it to be handed off.
|
static SegmentsAndMetadata |
SegmentsAndMetadata.nil() |
| Modifier and Type | Method and Description |
|---|---|
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
AppenderatorImpl.push(List<SegmentIdentifier> identifiers,
Committer committer) |
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
Appenderator.push(List<SegmentIdentifier> identifiers,
Committer committer)
Merge and push particular segments to deep storage.
|
Copyright © 2011–2017. All rights reserved.