io.druid.indexing.common.task

Class VersionConverterTask

java.lang.Object

io.druid.indexing.common.task.AbstractTask

io.druid.indexing.common.task.AbstractFixedIntervalTask

io.druid.indexing.common.task.VersionConverterTask

All Implemented Interfaces:

Task

public class VersionConverterTask
extends AbstractFixedIntervalTask

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	VersionConverterTask.SubTask

Method Summary

Methods

Modifier and Type	Method and Description
static VersionConverterTask	create(io.druid.timeline.DataSegment segment)
static VersionConverterTask	create(String dataSource, org.joda.time.Interval interval)
boolean	equals(Object o)
io.druid.timeline.DataSegment	getSegment()
String	getType() Returns a descriptive label for this task type.
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

getClasspathPrefix, getDataSource, getGroupId, getId, getNodeType, getQueryRunner, getTaskLocks, getTaskResource, hashCode, joinId, success, toString

Methods inherited from class java.lang.Object

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

Method Detail

create

public static VersionConverterTask create(String dataSource,
                          org.joda.time.Interval interval)

create

public static VersionConverterTask create(io.druid.timeline.DataSegment segment)

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

getSegment

public io.druid.timeline.DataSegment getSegment()

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

equals

public boolean equals(Object o)

Overrides:

equals in class AbstractTask