public class SegmentAllocateAction extends Object implements TaskAction<SegmentIdentifier>
Constructor and Description |
---|
SegmentAllocateAction(String dataSource,
org.joda.time.DateTime timestamp,
Granularity queryGranularity,
Granularity preferredSegmentGranularity,
String sequenceName,
String previousSegmentId,
boolean skipSegmentLineageCheck) |
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() |
boolean |
isSkipSegmentLineageCheck() |
SegmentIdentifier |
perform(Task task,
TaskActionToolbox toolbox) |
String |
toString() |
public SegmentAllocateAction(String dataSource, org.joda.time.DateTime timestamp, Granularity queryGranularity, Granularity preferredSegmentGranularity, String sequenceName, String previousSegmentId, boolean skipSegmentLineageCheck)
public String getDataSource()
public org.joda.time.DateTime getTimestamp()
public Granularity getQueryGranularity()
public Granularity getPreferredSegmentGranularity()
public String getSequenceName()
public String getPreviousSegmentId()
public boolean isSkipSegmentLineageCheck()
public com.fasterxml.jackson.core.type.TypeReference<SegmentIdentifier> getReturnTypeReference()
getReturnTypeReference
in interface TaskAction<SegmentIdentifier>
public SegmentIdentifier perform(Task task, TaskActionToolbox toolbox) throws IOException
perform
in interface TaskAction<SegmentIdentifier>
IOException
public boolean isAudited()
isAudited
in interface TaskAction<SegmentIdentifier>
Copyright © 2011–2018. All rights reserved.