io.druid.indexing.overlord

Class IndexerDBCoordinator

java.lang.Object

io.druid.indexing.overlord.IndexerDBCoordinator

public class IndexerDBCoordinator
extends Object

Constructor Summary

Constructors

Constructor and Description
IndexerDBCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, DbTablesConfig dbTables, DbConnector dbConnector)

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

IndexerDBCoordinator

@Inject
public IndexerDBCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                           DbTablesConfig dbTables,
                           DbConnector dbConnector)

Method Detail

getUsedSegmentsForInterval

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

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).

Parameters:

segments - set of segments to add

Returns:

set of segments actually added

Throws:

IOException - if a database error occurs

updateSegmentMetadata

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

Throws:

IOException

deleteSegments

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

Throws:

IOException

getUnusedSegmentsForInterval

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