public class SameIntervalMergeTask extends AbstractFixedIntervalTask
Modifier and Type | Class and Description |
---|---|
static class |
SameIntervalMergeTask.SubTask |
Constructor and Description |
---|
SameIntervalMergeTask(String id,
String dataSource,
org.joda.time.Interval interval,
List<AggregatorFactory> aggregators,
Boolean rollup,
IndexSpec indexSpec,
Boolean buildV9Directly,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
getAggregators() |
Boolean |
getBuildV9Directly()
Deprecated.
|
IndexSpec |
getIndexSpec() |
Boolean |
getRollup() |
String |
getType()
Returns a descriptive label for this task type.
|
static String |
makeId(String id,
String typeName,
String dataSource,
org.joda.time.Interval interval) |
TaskStatus |
run(TaskToolbox toolbox)
Execute a task.
|
getInterval, isReady
canRestore, equals, getClasspathPrefix, getContext, getDataSource, getGroupId, getId, getNodeType, getQueryRunner, getTaskResource, hashCode, stopGracefully, success, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getContextValue, getContextValue, getPriority
public SameIntervalMergeTask(String id, String dataSource, org.joda.time.Interval interval, List<AggregatorFactory> aggregators, Boolean rollup, IndexSpec indexSpec, Boolean buildV9Directly, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, Map<String,Object> context)
public List<AggregatorFactory> getAggregators()
public Boolean getRollup()
public IndexSpec getIndexSpec()
@Deprecated public Boolean getBuildV9Directly()
public static String makeId(String id, String typeName, String dataSource, org.joda.time.Interval interval)
public String getType()
Task
public TaskStatus run(TaskToolbox toolbox) throws Exception
Task
toolbox
- Toolbox for this taskException
- if this task failedCopyright © 2011–2018. All rights reserved.