org.apache.druid.segment.realtime.appenderator

Interface TransactionalSegmentPublisher

public interface TransactionalSegmentPublisher

Method Summary

Modifier and Type	Method and Description
SegmentPublishResult	publishSegments(Set<org.apache.druid.timeline.DataSegment> segments, Object commitMetadata) Publish segments, along with some commit metadata, in a single transaction.

Method Detail

publishSegments

SegmentPublishResult publishSegments(Set<org.apache.druid.timeline.DataSegment> segments,
                                     @Nullable
                                     Object commitMetadata)
                              throws IOException

Publish segments, along with some commit metadata, in a single transaction.

Returns:

publish result that indicates if segments were published or not. If it is unclear if the segments were published or not, this method must throw an exception. The behavior is similar to IndexerSQLMetadataStorageCoordinator's announceHistoricalSegments.

Throws:

IOException - if there was an I/O error when publishing

RuntimeException - if we cannot tell if the segments were published or not, for some other reason