io.druid.client

Class BrokerServerView

java.lang.Object

io.druid.client.BrokerServerView

All Implemented Interfaces:

ServerView, TimelineServerView

public class BrokerServerView
extends Object
implements TimelineServerView

Nested Class Summary

Nested classes/interfaces inherited from interface io.druid.client.TimelineServerView

TimelineServerView.TimelineCallback

Nested classes/interfaces inherited from interface io.druid.client.ServerView

ServerView.BaseSegmentCallback, ServerView.CallbackAction, ServerView.SegmentCallback, ServerView.ServerRemovedCallback

Constructor Summary

Constructors

Constructor and Description
BrokerServerView(QueryToolChestWarehouse warehouse, QueryWatcher queryWatcher, com.fasterxml.jackson.databind.ObjectMapper smileMapper, HttpClient httpClient, FilteredServerInventoryView baseView, TierSelectorStrategy tierSelectorStrategy, ServiceEmitter emitter, BrokerSegmentWatcherConfig segmentWatcherConfig)

Method Summary

Modifier and Type	Method and Description
void	clear()
<T> QueryRunner<T>	getQueryRunner(DruidServer server)
VersionedIntervalTimeline<String,ServerSelector>	getTimeline(DataSource dataSource)
boolean	isInitialized()
void	registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback)
void	registerServerRemovedCallback(Executor exec, ServerView.ServerRemovedCallback callback)
void	registerTimelineCallback(Executor exec, TimelineServerView.TimelineCallback callback) Register a callback for state changes in the timeline managed by this TimelineServerView.

Methods inherited from class java.lang.Object

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

Constructor Detail

BrokerServerView

@Inject
public BrokerServerView(QueryToolChestWarehouse warehouse,
                                QueryWatcher queryWatcher,
                                com.fasterxml.jackson.databind.ObjectMapper smileMapper,
                                HttpClient httpClient,
                                FilteredServerInventoryView baseView,
                                TierSelectorStrategy tierSelectorStrategy,
                                ServiceEmitter emitter,
                                BrokerSegmentWatcherConfig segmentWatcherConfig)

Method Detail

isInitialized

public boolean isInitialized()

clear

public void clear()

getTimeline

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

Specified by:

getTimeline in interface TimelineServerView

registerTimelineCallback

public void registerTimelineCallback(Executor exec,
                                     TimelineServerView.TimelineCallback callback)

Description copied from interface: TimelineServerView

Register a callback for state changes in the timeline managed by this TimelineServerView. The callback will be called after the relevant change is made to this TimelineServerView's timeline.

Specified by:

registerTimelineCallback in interface TimelineServerView

Parameters:

exec - executor in which to run the callback

callback - the callback

getQueryRunner

public <T> QueryRunner<T> getQueryRunner(DruidServer server)

Specified by:

getQueryRunner in interface TimelineServerView

registerServerRemovedCallback

public void registerServerRemovedCallback(Executor exec,
                                          ServerView.ServerRemovedCallback callback)

Specified by:

registerServerRemovedCallback in interface ServerView

registerSegmentCallback

public void registerSegmentCallback(Executor exec,
                                    ServerView.SegmentCallback callback)

Specified by:

registerSegmentCallback in interface ServerView