io.druid.indexing.overlord

Interface IndexerMetadataStorageCoordinator

All Known Implementing Classes:

IndexerSQLMetadataStorageCoordinator

public interface IndexerMetadataStorageCoordinator

Method Summary

Methods

Modifier and Type	Method and Description
Set<io.druid.timeline.DataSegment>	announceHistoricalSegments(Set<io.druid.timeline.DataSegment> segments) Attempts to insert a set of segments to the metadata storage.
void	deleteSegments(Set<io.druid.timeline.DataSegment> segments)
List<io.druid.timeline.DataSegment>	getUnusedSegmentsForInterval(String dataSource, org.joda.time.Interval interval)
List<io.druid.timeline.DataSegment>	getUsedSegmentsForInterval(String dataSource, org.joda.time.Interval interval)
void	updateSegmentMetadata(Set<io.druid.timeline.DataSegment> segments)

Method Detail

getUsedSegmentsForInterval

List<io.druid.timeline.DataSegment> getUsedSegmentsForInterval(String dataSource,
                                                             org.joda.time.Interval interval)
                                                               throws IOException

Throws:

IOException

announceHistoricalSegments

Set<io.druid.timeline.DataSegment> announceHistoricalSegments(Set<io.druid.timeline.DataSegment> segments)
                                                              throws IOException

Attempts to insert a set of segments to the metadata storage. Returns the set of segments actually added (segments with identifiers already in the metadata storage will not be added).

Parameters:

segments - set of segments to add

Returns:

set of segments actually added

Throws:

IOException

updateSegmentMetadata

void updateSegmentMetadata(Set<io.druid.timeline.DataSegment> segments)
                           throws IOException

Throws:

IOException

deleteSegments

void deleteSegments(Set<io.druid.timeline.DataSegment> segments)
                    throws IOException

Throws:

IOException

getUnusedSegmentsForInterval

List<io.druid.timeline.DataSegment> getUnusedSegmentsForInterval(String dataSource,
                                                               org.joda.time.Interval interval)