io.druid.indexing.common.task

Class AbstractFixedIntervalTask

java.lang.Object

io.druid.indexing.common.task.AbstractTask

io.druid.indexing.common.task.AbstractFixedIntervalTask

All Implemented Interfaces:

Task

Direct Known Subclasses:

ArchiveTask, ConvertSegmentTask, ConvertSegmentTask.SubTask, KillTask, MergeTaskBase, MoveTask, RestoreTask, SameIntervalMergeTask

public abstract class AbstractFixedIntervalTask
extends AbstractTask

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractFixedIntervalTask(String id, String dataSource, org.joda.time.Interval interval, Map<String,Object> context)
protected	AbstractFixedIntervalTask(String id, String groupId, String dataSource, org.joda.time.Interval interval, Map<String,Object> context)
protected	AbstractFixedIntervalTask(String id, String groupId, TaskResource taskResource, String dataSource, org.joda.time.Interval interval, Map<String,Object> context)

Method Summary

Modifier and Type	Method and Description
org.joda.time.Interval	getInterval()
boolean	isReady(TaskActionClient taskActionClient) Execute preflight actions for a task.

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.druid.indexing.common.task.Task

getContextValue, getContextValue, getPriority, getType, run

Constructor Detail

AbstractFixedIntervalTask

protected AbstractFixedIntervalTask(String id,
                                    String dataSource,
                                    org.joda.time.Interval interval,
                                    Map<String,Object> context)

AbstractFixedIntervalTask

protected AbstractFixedIntervalTask(String id,
                                    String groupId,
                                    String dataSource,
                                    org.joda.time.Interval interval,
                                    Map<String,Object> context)

AbstractFixedIntervalTask

protected AbstractFixedIntervalTask(String id,
                                    String groupId,
                                    TaskResource taskResource,
                                    String dataSource,
                                    org.joda.time.Interval interval,
                                    Map<String,Object> context)

Method Detail

isReady

public boolean isReady(TaskActionClient taskActionClient)
                throws Exception

Description copied from interface: Task

Execute preflight actions for a task. This can be used to acquire locks, check preconditions, and so on. The actions must be idempotent, since this method may be executed multiple times. This typically runs on the coordinator. If this method throws an exception, the task should be considered a failure.

This method must be idempotent, as it may be run multiple times per task.

Parameters:

taskActionClient - action client for this task (not the full toolbox)

Returns:

true if ready, false if not ready yet

Throws:

Exception - if the task should be considered a failure

getInterval

public org.joda.time.Interval getInterval()