io.druid.indexer.path

Class MetadataStoreBasedUsedSegmentLister

java.lang.Object

io.druid.indexer.path.MetadataStoreBasedUsedSegmentLister

All Implemented Interfaces:

UsedSegmentLister

public class MetadataStoreBasedUsedSegmentLister
extends Object
implements UsedSegmentLister

Constructor Summary

Constructors

Constructor and Description
MetadataStoreBasedUsedSegmentLister(IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator)

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

MetadataStoreBasedUsedSegmentLister

@Inject
public MetadataStoreBasedUsedSegmentLister(IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator)

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