io.druid.metadata

Class IndexerSQLMetadataStorageCoordinator

java.lang.Object

io.druid.metadata.IndexerSQLMetadataStorageCoordinator

All Implemented Interfaces:

IndexerMetadataStorageCoordinator

public class IndexerSQLMetadataStorageCoordinator
extends Object
implements IndexerMetadataStorageCoordinator

Constructor Summary

Constructors

Constructor and Description
IndexerSQLMetadataStorageCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, MetadataStorageTablesConfig dbTables, SQLMetadataConnector connector)

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 database.
void	deleteSegments(Set<io.druid.timeline.DataSegment> segments)
List<io.druid.timeline.DataSegment>	getUnusedSegmentsForInterval(String dataSource, org.joda.time.Interval interval) Get all segments which include ONLY data within the given interval and are not flagged as used.
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.
void	updateSegmentMetadata(Set<io.druid.timeline.DataSegment> segments)

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexerSQLMetadataStorageCoordinator

@Inject
public IndexerSQLMetadataStorageCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                           MetadataStorageTablesConfig dbTables,
                                           SQLMetadataConnector connector)

Method Detail

getUsedSegmentsForInterval

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

Description copied from interface: IndexerMetadataStorageCoordinator

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

Specified by:

getUsedSegmentsForInterval in interface IndexerMetadataStorageCoordinator

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

announceHistoricalSegments

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

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

Specified by:

announceHistoricalSegments in interface IndexerMetadataStorageCoordinator

Parameters:

segments - set of segments to add

Returns:

set of segments actually added

Throws:

IOException

updateSegmentMetadata

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

Specified by:

updateSegmentMetadata in interface IndexerMetadataStorageCoordinator

Throws:

IOException

deleteSegments

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

Specified by:

deleteSegments in interface IndexerMetadataStorageCoordinator

Throws:

IOException

getUnusedSegmentsForInterval

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

Description copied from interface: IndexerMetadataStorageCoordinator

Get all segments which include ONLY data within the given interval and are not flagged as used.

Specified by:

getUnusedSegmentsForInterval in interface IndexerMetadataStorageCoordinator

Parameters:

dataSource - The datasource the segments belong to

interval - Filter the data segments to ones that include data in this interval exclusively. Start is inclusive, end is exclusive

Returns:

DataSegments which include ONLY data within the requested interval and are not flagged as used. Data segments NOT returned here may include data in the interval