Package | Description |
---|---|
io.druid.segment.realtime.appenderator |
Modifier and Type | Method and Description |
---|---|
static SegmentsAndMetadata |
SegmentsAndMetadata.nil() |
SegmentsAndMetadata |
BatchAppenderatorDriver.pushAllAndClear(long pushAndClearTimeoutMs)
Push and drop all segments in the
SegmentWithState.SegmentState.APPENDING state. |
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) |
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> |
StreamAppenderatorDriver.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> |
StreamAppenderatorDriver.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–2018. All rights reserved.