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

Constructor Summary

Constructors

Constructor and Description
HttpServerInventoryView(com.fasterxml.jackson.databind.ObjectMapper smileMapper, HttpClient httpClient, DruidNodeDiscoveryProvider druidNodeDiscoveryProvider, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter, HttpServerInventoryViewConfig config)

Method Summary

Modifier and Type	Method and Description
Collection<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	registerServerRemovedCallback(Executor exec, ServerView.ServerRemovedCallback callback)
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 smileMapper,
                                       HttpClient httpClient,
                                       DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
                                       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

registerServerRemovedCallback

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

Specified by:

registerServerRemovedCallback in interface FilteredServerInventoryView

Specified by:

registerServerRemovedCallback 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 Collection<DruidServer> getInventory()

Specified by:

getInventory in interface InventoryView

isStarted

public boolean isStarted()

Specified by:

isStarted in interface InventoryView

isSegmentLoadedByServer

public boolean isSegmentLoadedByServer(String serverKey,
                                       DataSegment segment)

Specified by:

isSegmentLoadedByServer in interface InventoryView