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

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

MetadataStoreBasedUsedSegmentLister

@Inject
public MetadataStoreBasedUsedSegmentLister(IndexerMetadataStorageCoordinator indexerMetadataStorageCoordinator)

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