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

Methods

Modifier and Type	Method and Description
List<io.druid.timeline.DataSegment>	getUsedSegmentsForInterval(String dataSource, org.joda.time.Interval interval) 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

getUsedSegmentsForInterval

public List<io.druid.timeline.DataSegment> getUsedSegmentsForInterval(String dataSource,
                                                             org.joda.time.Interval interval)
                                                               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:

getUsedSegmentsForInterval in interface UsedSegmentLister

Parameters:

dataSource - The datasource to query

interval - The interval for which all applicable and used datasources are requested. Start is inclusive, end is exclusive

Returns:

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

Throws:

IOException