io.druid.indexing.common.actions

Class SegmentTransactionalInsertAction

java.lang.Object

io.druid.indexing.common.actions.SegmentTransactionalInsertAction

All Implemented Interfaces:

TaskAction<SegmentPublishResult>

public class SegmentTransactionalInsertAction
extends Object
implements TaskAction<SegmentPublishResult>

Insert segments into metadata storage. The segment versions must all be less than or equal to a lock held by your task for the segment intervals.

Word of warning: Very large "segments" sets can cause oversized audit log entries, which is bad because it means that the task cannot actually complete. Callers should avoid this by avoiding inserting too many segments in the same action.

Constructor Summary

Constructors

Constructor and Description
SegmentTransactionalInsertAction(Set<DataSegment> segments)
SegmentTransactionalInsertAction(Set<DataSegment> segments, DataSourceMetadata startMetadata, DataSourceMetadata endMetadata)

Method Summary

Modifier and Type	Method and Description
DataSourceMetadata	getEndMetadata()
com.fasterxml.jackson.core.type.TypeReference<SegmentPublishResult>	getReturnTypeReference()
Set<DataSegment>	getSegments()
DataSourceMetadata	getStartMetadata()
boolean	isAudited()
SegmentPublishResult	perform(Task task, TaskActionToolbox toolbox) Behaves similarly to IndexerMetadataStorageCoordinator.announceHistoricalSegments(Set, DataSourceMetadata, DataSourceMetadata).
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SegmentTransactionalInsertAction

public SegmentTransactionalInsertAction(Set<DataSegment> segments)

SegmentTransactionalInsertAction

public SegmentTransactionalInsertAction(Set<DataSegment> segments,
                                        DataSourceMetadata startMetadata,
                                        DataSourceMetadata endMetadata)

Method Detail

getSegments

public Set<DataSegment> getSegments()

getStartMetadata

public DataSourceMetadata getStartMetadata()

getEndMetadata

public DataSourceMetadata getEndMetadata()

getReturnTypeReference

public com.fasterxml.jackson.core.type.TypeReference<SegmentPublishResult> getReturnTypeReference()

Specified by:

getReturnTypeReference in interface TaskAction<SegmentPublishResult>

perform

public SegmentPublishResult perform(Task task,
                                    TaskActionToolbox toolbox)
                             throws IOException

Behaves similarly to IndexerMetadataStorageCoordinator.announceHistoricalSegments(Set, DataSourceMetadata, DataSourceMetadata).

Specified by:

perform in interface TaskAction<SegmentPublishResult>

Throws:

IOException

isAudited

public boolean isAudited()

Specified by:

isAudited in interface TaskAction<SegmentPublishResult>

toString

public String toString()

Overrides:

toString in class Object