| Package | Description |
|---|---|
| io.druid.segment.realtime.appenderator |
| Modifier and Type | Method and Description |
|---|---|
static SegmentsAndMetadata |
SegmentsAndMetadata.nil() |
| 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) |
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
AppenderatorImpl.push(Collection<SegmentIdentifier> identifiers,
Committer committer) |
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
Appenderator.push(Collection<SegmentIdentifier> identifiers,
Committer committer)
Merge and push particular segments to deep storage.
|
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
AppenderatorDriver.registerHandoff(SegmentsAndMetadata segmentsAndMetadata)
Register the segments in the given
SegmentsAndMetadata to be handed off and execute a background task which
waits until the hand off completes. |
| Modifier and Type | Method and Description |
|---|---|
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
AppenderatorDriver.registerHandoff(SegmentsAndMetadata segmentsAndMetadata)
Register the segments in the given
SegmentsAndMetadata to be handed off and execute a background task which
waits until the hand off completes. |
Copyright © 2011–2017. All rights reserved.