Uses of Interface
io.druid.segment.realtime.appenderator.TransactionalSegmentPublisher

Packages that use TransactionalSegmentPublisher

Package	Description
io.druid.segment.realtime.appenderator

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

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

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)