io.druid.client

Class SingleServerInventoryView

java.lang.Object

io.druid.client.ServerInventoryView<io.druid.timeline.DataSegment>

io.druid.client.SingleServerInventoryView

All Implemented Interfaces:

FilteredServerView, InventoryView, ServerView

public class SingleServerInventoryView
extends ServerInventoryView<io.druid.timeline.DataSegment>
implements FilteredServerView

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
SingleServerInventoryView(ZkPathsConfig zkPaths, org.apache.curator.framework.CuratorFramework curator, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.google.common.base.Predicate<io.druid.timeline.DataSegment> defaultFilter)

Method Summary

Methods

Modifier and Type	Method and Description
protected DruidServer	addInnerInventory(DruidServer container, String inventoryKey, io.druid.timeline.DataSegment inventory)
void	registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback, com.google.common.base.Predicate<io.druid.timeline.DataSegment> filter)
protected DruidServer	removeInnerInventory(DruidServer container, String inventoryKey)
protected DruidServer	updateInnerInventory(DruidServer container, String inventoryKey, io.druid.timeline.DataSegment inventory)

Methods inherited from class io.druid.client.ServerInventoryView

addSingleInventory, getInventory, getInventoryManagerConfig, getInventoryValue, isStarted, registerSegmentCallback, registerServerCallback, removeSingleInventory, runSegmentCallbacks, runServerCallbacks, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleServerInventoryView

@Inject
public SingleServerInventoryView(ZkPathsConfig zkPaths,
                                org.apache.curator.framework.CuratorFramework curator,
                                com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                com.google.common.base.Predicate<io.druid.timeline.DataSegment> defaultFilter)

Method Detail

addInnerInventory

protected DruidServer addInnerInventory(DruidServer container,
                            String inventoryKey,
                            io.druid.timeline.DataSegment inventory)

Specified by:

addInnerInventory in class ServerInventoryView<io.druid.timeline.DataSegment>

updateInnerInventory

protected DruidServer updateInnerInventory(DruidServer container,
                               String inventoryKey,
                               io.druid.timeline.DataSegment inventory)

Specified by:

updateInnerInventory in class ServerInventoryView<io.druid.timeline.DataSegment>

removeInnerInventory

protected DruidServer removeInnerInventory(DruidServer container,
                               String inventoryKey)

Specified by:

removeInnerInventory in class ServerInventoryView<io.druid.timeline.DataSegment>

registerSegmentCallback

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

Specified by:

registerSegmentCallback in interface FilteredServerView