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.