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

ServerView.BaseSegmentCallback, ServerView.CallbackAction, ServerView.SegmentCallback, ServerView.ServerCallback

Constructor Summary

Constructors

Constructor and Description
BrokerServerView(QueryToolChestWarehouse warehouse, QueryWatcher queryWatcher, com.fasterxml.jackson.databind.ObjectMapper smileMapper, com.metamx.http.client.HttpClient httpClient, ServerInventoryView baseView, TierSelectorStrategy tierSelectorStrategy)

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
<T> QueryRunner<T>	getQueryRunner(DruidServer server)
TimelineLookup<String,ServerSelector>	getTimeline(DataSource dataSource)
boolean	isInitialized()
void	registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback)
void	registerServerCallback(Executor exec, ServerView.ServerCallback callback)

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,
                       com.metamx.http.client.HttpClient httpClient,
                       ServerInventoryView baseView,
                       TierSelectorStrategy tierSelectorStrategy)

Method Detail

isInitialized

public boolean isInitialized()

clear

public void clear()

getTimeline

public TimelineLookup<String,ServerSelector> getTimeline(DataSource dataSource)

Specified by:

getTimeline in interface TimelineServerView

getQueryRunner

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

Specified by:

getQueryRunner in interface TimelineServerView

registerServerCallback

public void registerServerCallback(Executor exec,
                          ServerView.ServerCallback callback)

Specified by:

registerServerCallback in interface ServerView

registerSegmentCallback

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

Specified by:

registerSegmentCallback in interface ServerView