io.druid.indexing.common.actions

Class SegmentAllocateAction

java.lang.Object

io.druid.indexing.common.actions.SegmentAllocateAction

All Implemented Interfaces:

TaskAction<SegmentIdentifier>

public class SegmentAllocateAction
extends Object
implements TaskAction<SegmentIdentifier>

Allocates a pending segment for a given timestamp. The preferredSegmentGranularity is used if there are no prior segments for the given timestamp, or if the prior segments for the given timestamp are already at the preferredSegmentGranularity. Otherwise, the prior segments will take precedence.

This action implicitly acquires locks when it allocates segments. You do not have to acquire them beforehand, although you *do* have to release them yourself.

If this action cannot acquire an appropriate lock, or if it cannot expand an existing segment set, it returns null.

Constructor Summary

Constructors

Constructor and Description
SegmentAllocateAction(String dataSource, org.joda.time.DateTime timestamp, Granularity queryGranularity, Granularity preferredSegmentGranularity, String sequenceName, String previousSegmentId)

Method Summary

Modifier and Type	Method and Description
String	getDataSource()
Granularity	getPreferredSegmentGranularity()
String	getPreviousSegmentId()
Granularity	getQueryGranularity()
com.fasterxml.jackson.core.type.TypeReference<SegmentIdentifier>	getReturnTypeReference()
String	getSequenceName()
org.joda.time.DateTime	getTimestamp()
boolean	isAudited()
SegmentIdentifier	perform(Task task, TaskActionToolbox toolbox)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentAllocateAction

public SegmentAllocateAction(String dataSource,
                             org.joda.time.DateTime timestamp,
                             Granularity queryGranularity,
                             Granularity preferredSegmentGranularity,
                             String sequenceName,
                             String previousSegmentId)

Method Detail

getDataSource

public String getDataSource()

getTimestamp

public org.joda.time.DateTime getTimestamp()

getQueryGranularity

public Granularity getQueryGranularity()

getPreferredSegmentGranularity

public Granularity getPreferredSegmentGranularity()

getSequenceName

public String getSequenceName()

getPreviousSegmentId

public String getPreviousSegmentId()

getReturnTypeReference

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

Specified by:

getReturnTypeReference in interface TaskAction<SegmentIdentifier>

perform

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

Specified by:

perform in interface TaskAction<SegmentIdentifier>

Throws:

IOException

isAudited

public boolean isAudited()

Specified by:

isAudited in interface TaskAction<SegmentIdentifier>

toString

public String toString()

Overrides:

toString in class Object