io.druid.indexing.common.task

Class ConvertSegmentTask.SubTask

java.lang.Object

io.druid.indexing.common.task.AbstractTask

io.druid.indexing.common.task.AbstractFixedIntervalTask

io.druid.indexing.common.task.ConvertSegmentTask.SubTask

All Implemented Interfaces:

Task

Direct Known Subclasses:

ConvertSegmentBackwardsCompatibleTask.SubTask

Enclosing class:

ConvertSegmentTask

public static class ConvertSegmentTask.SubTask
extends AbstractFixedIntervalTask

Constructor Summary

Constructors

Constructor and Description
SubTask(String groupId, DataSegment segment, IndexSpec indexSpec, Boolean force, Boolean validate, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, Map<String,Object> context)

Method Summary

Modifier and Type	Method and Description
DataSegment	getSegment()
String	getType() Returns a descriptive label for this task type.
boolean	isForce()
boolean	isValidate()
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, 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

Constructor Detail

SubTask

public SubTask(String groupId,
               DataSegment segment,
               IndexSpec indexSpec,
               Boolean force,
               Boolean validate,
               @Nullable
               SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
               Map<String,Object> context)

Method Detail

isValidate

public boolean isValidate()

isForce

public boolean isForce()

getSegment

public DataSegment getSegment()

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