io.druid.indexing.hadoop

Class OverlordActionBasedUsedSegmentLister

java.lang.Object

io.druid.indexing.hadoop.OverlordActionBasedUsedSegmentLister

All Implemented Interfaces:

UsedSegmentLister

public class OverlordActionBasedUsedSegmentLister
extends Object
implements UsedSegmentLister

Constructor Summary

Constructors

Constructor and Description
OverlordActionBasedUsedSegmentLister(TaskToolbox toolbox)

Method Summary

Modifier and Type	Method and Description
List<DataSegment>	getUsedSegmentsForIntervals(String dataSource, List<org.joda.time.Interval> intervals) Get all segments which may include any data in the interval and are flagged as used.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OverlordActionBasedUsedSegmentLister

@Inject
public OverlordActionBasedUsedSegmentLister(TaskToolbox toolbox)

Method Detail

getUsedSegmentsForIntervals

public List<DataSegment> getUsedSegmentsForIntervals(String dataSource,
                                                     List<org.joda.time.Interval> intervals)
                                              throws IOException

Description copied from interface: UsedSegmentLister

Get all segments which may include any data in the interval and are flagged as used.

Specified by:

getUsedSegmentsForIntervals in interface UsedSegmentLister

Parameters:

dataSource - The datasource to query

intervals - The intervals for which used segments are to be returned

Returns:

The DataSegments which include data in the requested intervals. These segments may contain data outside the requested interval.

Throws:

IOException