io.druid.indexing.common.task

Class SameIntervalMergeTask.SubTask

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.MergeTask

io.druid.indexing.common.task.SameIntervalMergeTask.SubTask

All Implemented Interfaces:

Task

Enclosing class:

SameIntervalMergeTask

public static class SameIntervalMergeTask.SubTask
extends MergeTask

Constructor Summary

Constructors

Constructor and Description
SubTask(String baseId, String dataSource, List<DataSegment> segments, List<AggregatorFactory> aggregators, Boolean rollup, IndexSpec indexSpec, Boolean buildV9Directly, Map<String,Object> context)

Method Summary

Modifier and Type	Method and Description
protected void	verifyInputSegments(List<DataSegment> segments)

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

getAggregators, getIndexSpec, getRollup, getType, merge

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

canRestore, equals, getClasspathPrefix, getContext, getContextValue, getDataSource, getGroupId, getId, getNodeType, getQueryRunner, getTaskLocks, getTaskResource, hashCode, joinId, makeId, stopGracefully, success

Methods inherited from class java.lang.Object

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

Constructor Detail

SubTask

public SubTask(String baseId,
               String dataSource,
               List<DataSegment> segments,
               List<AggregatorFactory> aggregators,
               Boolean rollup,
               IndexSpec indexSpec,
               Boolean buildV9Directly,
               Map<String,Object> context)

Method Detail

verifyInputSegments

protected void verifyInputSegments(List<DataSegment> segments)

Overrides:

verifyInputSegments in class MergeTaskBase