io.druid.indexing.common.task

Class SameIntervalMergeTask

java.lang.Object

io.druid.indexing.common.task.AbstractTask

io.druid.indexing.common.task.AbstractFixedIntervalTask

io.druid.indexing.common.task.SameIntervalMergeTask

All Implemented Interfaces:

Task

public class SameIntervalMergeTask
extends AbstractFixedIntervalTask

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SameIntervalMergeTask.SubTask

Constructor Summary

Constructors

Constructor and Description
SameIntervalMergeTask(String id, String dataSource, org.joda.time.Interval interval, List<AggregatorFactory> aggregators, Boolean rollup, IndexSpec indexSpec, Boolean buildV9Directly, Map<String,Object> context)

Method Summary

Modifier and Type	Method and Description
List<AggregatorFactory>	getAggregators()
Boolean	getBuildV9Directly()
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.

Methods inherited from class io.druid.indexing.common.task.AbstractFixedIntervalTask

getInterval, isReady

Methods inherited from class io.druid.indexing.common.task.AbstractTask

canRestore, equals, getClasspathPrefix, getContext, getContextValue, getDataSource, getGroupId, getId, getNodeType, getQueryRunner, getTaskLocks, getTaskResource, hashCode, joinId, stopGracefully, success, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SameIntervalMergeTask

public SameIntervalMergeTask(String id,
                             String dataSource,
                             org.joda.time.Interval interval,
                             List<AggregatorFactory> aggregators,
                             Boolean rollup,
                             IndexSpec indexSpec,
                             Boolean buildV9Directly,
                             Map<String,Object> context)

Method Detail

getAggregators

public List<AggregatorFactory> getAggregators()

getRollup

public Boolean getRollup()

getIndexSpec

public IndexSpec getIndexSpec()

getBuildV9Directly

public Boolean getBuildV9Directly()

makeId

public static String makeId(String id,
                            String typeName,
                            String dataSource,
                            org.joda.time.Interval interval)

getType

public String getType()

Description copied from interface: Task

Returns a descriptive label for this task type. Used for metrics emission and logging.

Returns:

task type label

run

public TaskStatus run(TaskToolbox toolbox)
               throws Exception

Description copied from interface: Task

Execute a task. This typically runs on a worker as determined by a TaskRunner, and will be run while holding a lock on our dataSource and implicit lock interval (if any). If this method throws an exception, the task should be considered a failure.

Parameters:

toolbox - Toolbox for this task

Returns:

Some kind of finished status (isRunnable must be false).

Throws:

Exception - if this task failed