io.druid.server

Class SegmentManager

java.lang.Object

io.druid.server.SegmentManager

public class SegmentManager
extends Object

This class is responsible for managing data sources and their states like timeline, total segment size, and number of segments. All public methods of this class must be thread-safe.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SegmentManager.DataSourceState Represent the state of a data source including the timeline, total segment size, and number of segments.

Constructor Summary

Constructors

Constructor and Description
SegmentManager(SegmentLoader segmentLoader)

Method Summary

Modifier and Type	Method and Description
void	dropSegment(DataSegment segment)
Map<String,Long>	getDataSourceCounts() Returns a map of dataSource to the number of segments managed by this segmentManager.
Map<String,Long>	getDataSourceSizes() Returns a map of dataSource to the total byte size of segments managed by this segmentManager.
VersionedIntervalTimeline<String,ReferenceCountingSegment>	getTimeline(String dataSource)
boolean	isSegmentCached(DataSegment segment)
boolean	loadSegment(DataSegment segment) Load a single segment.

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentManager

@Inject
public SegmentManager(SegmentLoader segmentLoader)

Method Detail

getDataSourceSizes

public Map<String,Long> getDataSourceSizes()

Returns a map of dataSource to the total byte size of segments managed by this segmentManager. This method should be used carefully because the returned map might be different from the actual data source states.

Returns:

a map of dataSources and their total byte sizes

getDataSourceCounts

public Map<String,Long> getDataSourceCounts()

Returns a map of dataSource to the number of segments managed by this segmentManager. This method should be carefully because the returned map might be different from the actual data source states.

Returns:

a map of dataSources and number of segments

isSegmentCached

public boolean isSegmentCached(DataSegment segment)
                        throws SegmentLoadingException

Throws:

SegmentLoadingException

getTimeline

@Nullable
public VersionedIntervalTimeline<String,ReferenceCountingSegment> getTimeline(String dataSource)

loadSegment

public boolean loadSegment(DataSegment segment)
                    throws SegmentLoadingException

Load a single segment.

Parameters:

segment - segment to load

Returns:

true if the segment was newly loaded, false if it was already loaded

Throws:

SegmentLoadingException - if the segment cannot be loaded

dropSegment

public void dropSegment(DataSegment segment)
                 throws SegmentLoadingException

Throws:

SegmentLoadingException