public class HadoopConverterTask extends ConvertSegmentTask
Modifier and Type | Class and Description |
---|---|
static class |
HadoopConverterTask.ConverterSubTask |
static class |
HadoopConverterTask.JobInvoker
Called indirectly in
HadoopConverterTask.ConverterSubTask.run(TaskToolbox) . |
ConvertSegmentTask.SubTask
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,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
protected Iterable<Task> |
generateSubTasks(String groupId,
Iterable<DataSegment> segments,
IndexSpec indexSpec,
boolean force,
boolean validate,
Map<String,Object> context) |
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() |
DataSegment |
getSegment() |
String |
getSegmentOutputPath() |
String |
getType()
Returns a descriptive label for this task type.
|
create, create, equals, getIndexSpec, getSegmentWriteOutMediumFactory, isForce, isValidate, makeId, run
getInterval, isReady
canRestore, getContext, getDataSource, getGroupId, getId, getNodeType, getQueryRunner, getTaskResource, hashCode, stopGracefully, success, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getContextValue, getContextValue, getPriority
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, @Nullable SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, Map<String,Object> context)
public URI getDistributedSuccessCache()
public String getJobPriority()
public String getSegmentOutputPath()
public String getClasspathPrefix()
Task
getClasspathPrefix
in interface Task
getClasspathPrefix
in class AbstractTask
protected Iterable<Task> generateSubTasks(String groupId, Iterable<DataSegment> segments, IndexSpec indexSpec, boolean force, boolean validate, Map<String,Object> context)
generateSubTasks
in class ConvertSegmentTask
public DataSegment getSegment()
getSegment
in class ConvertSegmentTask
Copyright © 2011–2018. All rights reserved.