io.druid.indexing.common.task

Class HadoopConverterTask

java.lang.Object

io.druid.indexing.common.task.AbstractTask

io.druid.indexing.common.task.AbstractFixedIntervalTask

io.druid.indexing.common.task.ConvertSegmentTask

io.druid.indexing.common.task.HadoopConverterTask

All Implemented Interfaces:

Task

public class HadoopConverterTask
extends ConvertSegmentTask

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HadoopConverterTask.ConverterSubTask
static class	HadoopConverterTask.JobInvoker

Nested classes/interfaces inherited from class io.druid.indexing.common.task.ConvertSegmentTask

ConvertSegmentTask.SubTask

Constructor Summary

Constructors

Constructor and Description
HadoopConverterTask(String id, String dataSource, org.joda.time.Interval interval, IndexSpec indexSpec, boolean force, Boolean validate, List<String> hadoopDependencyCoordinates, URI distributedSuccessCache, String jobPriority, String segmentOutputPath, String classpathPrefix)

Method Summary

Methods

Modifier and Type	Method and Description
protected Iterable<Task>	generateSubTasks(String groupId, Iterable<io.druid.timeline.DataSegment> segments, IndexSpec indexSpec, boolean force, boolean validate)
String	getClasspathPrefix() Returns an extra classpath that should be prepended to the default classpath when running this task.
URI	getDistributedSuccessCache()
List<String>	getHadoopDependencyCoordinates()
String	getJobPriority()
io.druid.timeline.DataSegment	getSegment()
String	getSegmentOutputPath()
String	getType() Returns a descriptive label for this task type.

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

create, create, equals, getIndexSpec, isForce, isValidate, run

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

getInterval, isReady

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopConverterTask

public HadoopConverterTask(String id,
                   String dataSource,
                   org.joda.time.Interval interval,
                   IndexSpec indexSpec,
                   boolean force,
                   Boolean validate,
                   List<String> hadoopDependencyCoordinates,
                   URI distributedSuccessCache,
                   String jobPriority,
                   String segmentOutputPath,
                   String classpathPrefix)

Method Detail

getHadoopDependencyCoordinates

public List<String> getHadoopDependencyCoordinates()

getDistributedSuccessCache

public URI getDistributedSuccessCache()

getJobPriority

public String getJobPriority()

getSegmentOutputPath

public String getSegmentOutputPath()

getClasspathPrefix

public String getClasspathPrefix()

Description copied from interface: Task

Returns an extra classpath that should be prepended to the default classpath when running this task. If no extra classpath should be prepended, this should return null or the empty string.

Specified by:

getClasspathPrefix in interface Task

Overrides:

getClasspathPrefix in class AbstractTask

generateSubTasks

protected Iterable<Task> generateSubTasks(String groupId,
                              Iterable<io.druid.timeline.DataSegment> segments,
                              IndexSpec indexSpec,
                              boolean force,
                              boolean validate)

Overrides:

generateSubTasks in class ConvertSegmentTask

getSegment

public io.druid.timeline.DataSegment getSegment()

Overrides:

getSegment in class ConvertSegmentTask

getType

public String getType()

Description copied from interface: Task

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

Specified by:

getType in interface Task

Overrides:

getType in class ConvertSegmentTask

Returns:

task type label