org.apache.druid.sql.calcite.schema

Class MetadataSegmentView

java.lang.Object

org.apache.druid.sql.calcite.schema.MetadataSegmentView

public class MetadataSegmentView
extends Object

This class polls the Coordinator in background to keep the latest published segments. Provides getPublishedSegments() for others to get segments in metadata store. The difference between this class and SegmentsMetadataManager is that this class resides in Broker's memory, while SegmentsMetadataManager resides in Coordinator's memory. In fact, this class polls the data from SegmentsMetadataManager object in the memory of the currently leading Coordinator via HTTP queries.

Constructor Summary

Constructors

Constructor and Description
MetadataSegmentView(DruidLeaderClient druidLeaderClient, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, BrokerSegmentWatcherConfig segmentWatcherConfig, PlannerConfig plannerConfig)

Method Summary

Modifier and Type	Method and Description
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataSegmentView

@Inject
public MetadataSegmentView(DruidLeaderClient druidLeaderClient,
                                   com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                   BrokerSegmentWatcherConfig segmentWatcherConfig,
                                   PlannerConfig plannerConfig)

Method Detail

start

public void start()

stop

public void stop()