Uses of Class
io.druid.segment.realtime.appenderator.SegmentsAndMetadata

Packages that use SegmentsAndMetadata

Package	Description
io.druid.segment.realtime.appenderator

Uses of SegmentsAndMetadata in io.druid.segment.realtime.appenderator

Methods in io.druid.segment.realtime.appenderator that return SegmentsAndMetadata

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.

Methods in io.druid.segment.realtime.appenderator that return types with arguments of type SegmentsAndMetadata

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.

Methods in io.druid.segment.realtime.appenderator with parameters of type SegmentsAndMetadata

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.