io.druid.indexing.common.actions

Class SegmentInsertAction

java.lang.Object

io.druid.indexing.common.actions.SegmentInsertAction

All Implemented Interfaces:

TaskAction<Set<DataSegment>>

public class SegmentInsertAction
extends Object
implements TaskAction<Set<DataSegment>>

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
SegmentInsertAction(Set<DataSegment> segments)

Method Summary

Modifier and Type	Method and Description
com.fasterxml.jackson.core.type.TypeReference<Set<DataSegment>>	getReturnTypeReference()
Set<DataSegment>	getSegments()
boolean	isAudited()
Set<DataSegment>	perform(Task task, TaskActionToolbox toolbox) Behaves similarly to IndexerMetadataStorageCoordinator.announceHistoricalSegments(java.util.Set<io.druid.timeline.DataSegment>), with startMetadata and endMetadata both null.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentInsertAction

public SegmentInsertAction(Set<DataSegment> segments)

Method Detail

getSegments

public Set<DataSegment> getSegments()

getReturnTypeReference

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

Specified by:

getReturnTypeReference in interface TaskAction<Set<DataSegment>>

perform

public Set<DataSegment> perform(Task task,
                                TaskActionToolbox toolbox)
                         throws IOException

Behaves similarly to IndexerMetadataStorageCoordinator.announceHistoricalSegments(java.util.Set<io.druid.timeline.DataSegment>), with startMetadata and endMetadata both null.

Specified by:

perform in interface TaskAction<Set<DataSegment>>

Throws:

IOException

isAudited

public boolean isAudited()

Specified by:

isAudited in interface TaskAction<Set<DataSegment>>

toString

public String toString()

Overrides:

toString in class Object