io.druid.indexing.common.task

Class AppendTask

java.lang.Object

io.druid.indexing.common.task.AbstractTask

io.druid.indexing.common.task.AbstractFixedIntervalTask

io.druid.indexing.common.task.MergeTaskBase

io.druid.indexing.common.task.AppendTask

All Implemented Interfaces:

Task

public class AppendTask
extends MergeTaskBase

Constructor Summary

Constructors

Constructor and Description
AppendTask(String id, String dataSource, List<io.druid.timeline.DataSegment> segments, IndexSpec indexSpec)

Method Summary

Methods

Modifier and Type	Method and Description
String	getType() Returns a descriptive label for this task type.
File	merge(Map<io.druid.timeline.DataSegment,File> segments, File outDir)

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

getSegments, isReady, run, toString

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

getInterval

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AppendTask

public AppendTask(String id,
          String dataSource,
          List<io.druid.timeline.DataSegment> segments,
          IndexSpec indexSpec)

Method Detail

merge

public File merge(Map<io.druid.timeline.DataSegment,File> segments,
         File outDir)
           throws Exception

Specified by:

merge in class MergeTaskBase

Throws:

Exception

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