io.druid.client

Class HttpServerInventoryView

java.lang.Object

io.druid.client.HttpServerInventoryView

All Implemented Interfaces:

FilteredServerInventoryView, InventoryView, ServerInventoryView, ServerView

public class HttpServerInventoryView
extends Object
implements ServerInventoryView, FilteredServerInventoryView

This class uses CuratorInventoryManager to listen for queryable server membership which serve segments(e.g. Historicals). For each queryable server, it uses HTTP GET /druid-internal/v1/segments (see docs in SegmentListerResource.getSegments(..).

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
HttpServerInventoryView(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.fasterxml.jackson.databind.ObjectMapper smileMapper, com.metamx.http.client.HttpClient httpClient, DruidServerDiscovery serverDiscovery, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter, HttpServerInventoryViewConfig config)

Method Summary

Modifier and Type	Method and Description
Iterable<DruidServer>	getInventory()
DruidServer	getInventoryValue(String containerKey)
boolean	isSegmentLoadedByServer(String serverKey, DataSegment segment)
boolean	isStarted()
void	registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback)
void	registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter)
void	registerServerCallback(Executor exec, ServerView.ServerCallback callback)
DruidServer	serverUpdated(DruidServer oldServer, DruidServer newServer)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpServerInventoryView

@Inject
public HttpServerInventoryView(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                       com.fasterxml.jackson.databind.ObjectMapper smileMapper,
                                       com.metamx.http.client.HttpClient httpClient,
                                       DruidServerDiscovery serverDiscovery,
                                       com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter,
                                       HttpServerInventoryViewConfig config)

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

stop

public void stop()
          throws IOException

Throws:

IOException

registerSegmentCallback

public void registerSegmentCallback(Executor exec,
                                    ServerView.SegmentCallback callback,
                                    com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter)

Specified by:

registerSegmentCallback in interface FilteredServerInventoryView

registerServerCallback

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

Specified by:

registerServerCallback in interface FilteredServerInventoryView

Specified by:

registerServerCallback in interface ServerView

registerSegmentCallback

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

Specified by:

registerSegmentCallback in interface ServerView

getInventoryValue

public DruidServer getInventoryValue(String containerKey)

Specified by:

getInventoryValue in interface InventoryView

getInventory

public Iterable<DruidServer> getInventory()

Specified by:

getInventory in interface InventoryView

serverUpdated

public DruidServer serverUpdated(DruidServer oldServer,
                                 DruidServer newServer)

isStarted

public boolean isStarted()

Specified by:

isStarted in interface InventoryView

isSegmentLoadedByServer

public boolean isSegmentLoadedByServer(String serverKey,
                                       DataSegment segment)

Specified by:

isSegmentLoadedByServer in interface InventoryView