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

Specified by:

getUsedSegmentsForInterval in interface IndexerMetadataStorageCoordinator

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)

Specified by:

getUnusedSegmentsForInterval in interface IndexerMetadataStorageCoordinator