org.apache.druid.sql.calcite.schema

Class SegmentMetadataCache

java.lang.Object

org.apache.druid.sql.calcite.schema.SegmentMetadataCache

public class SegmentMetadataCache
extends Object

Broker-side cache of segment metadata which combines segments to identify datasources which become "tables" in Calcite. This cache provides the "physical" metadata about a datasource which is blended with catalog "logical" metadata to provide the final user-view of each datasource.

Constructor Summary

Constructors

Constructor and Description
SegmentMetadataCache(QueryLifecycleFactory queryLifecycleFactory, TimelineServerView serverView, SegmentManager segmentManager, JoinableFactory joinableFactory, PlannerConfig config, Escalator escalator, BrokerInternalQueryConfig brokerInternalQueryConfig)

Method Summary

Modifier and Type	Method and Description
protected void	addSegment(DruidServerMetadata server, DataSegment segment)
void	awaitInitialization()
protected DatasourceTable.PhysicalDatasourceMetadata	getDatasource(String name)
protected Set<String>	getDatasourceNames()
protected Set<SegmentId>	refreshSegments(Set<SegmentId> segments) Attempt to refresh "segmentSignatures" for a set of segments.
protected Sequence<SegmentAnalysis>	runSegmentMetadataQuery(Iterable<SegmentId> segments) Execute a SegmentMetadata query and return a Sequence of SegmentAnalysis.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentMetadataCache

@Inject
public SegmentMetadataCache(QueryLifecycleFactory queryLifecycleFactory,
                                    TimelineServerView serverView,
                                    SegmentManager segmentManager,
                                    JoinableFactory joinableFactory,
                                    PlannerConfig config,
                                    Escalator escalator,
                                    BrokerInternalQueryConfig brokerInternalQueryConfig)

Method Detail

start

public void start()
           throws InterruptedException

Throws:

InterruptedException

stop

public void stop()

awaitInitialization

public void awaitInitialization()
                         throws InterruptedException

Throws:

InterruptedException

getDatasource

protected DatasourceTable.PhysicalDatasourceMetadata getDatasource(String name)

getDatasourceNames

protected Set<String> getDatasourceNames()

addSegment

protected void addSegment(DruidServerMetadata server,
                          DataSegment segment)

refreshSegments

protected Set<SegmentId> refreshSegments(Set<SegmentId> segments)
                                  throws IOException

Attempt to refresh "segmentSignatures" for a set of segments. Returns the set of segments actually refreshed, which may be a subset of the asked-for set.

Throws:

IOException

runSegmentMetadataQuery

protected Sequence<SegmentAnalysis> runSegmentMetadataQuery(Iterable<SegmentId> segments)

Execute a SegmentMetadata query and return a Sequence of SegmentAnalysis.

Parameters:

segments - Iterable of SegmentId objects that are subject of the SegmentMetadata query.

Returns:

Sequence of SegmentAnalysis objects