io.druid.client

Class BatchServerInventoryView

java.lang.Object

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

io.druid.client.BatchServerInventoryView

All Implemented Interfaces:

FilteredServerInventoryView, InventoryView, ServerView

public class BatchServerInventoryView
extends ServerInventoryView<Set<DataSegment>>
implements FilteredServerInventoryView

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

Method Summary

Modifier and Type	Method and Description
protected DruidServer	addInnerInventory(DruidServer container, String inventoryKey, Set<DataSegment> inventory)
void	registerSegmentCallback(Executor exec, ServerView.SegmentCallback callback, com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter)
protected DruidServer	removeInnerInventory(DruidServer container, String inventoryKey)
protected void	segmentCallbackRemoved(ServerView.SegmentCallback callback)
protected DruidServer	updateInnerInventory(DruidServer container, String inventoryKey, Set<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

Methods inherited from interface io.druid.client.FilteredServerInventoryView

registerServerCallback

Methods inherited from interface io.druid.client.InventoryView

getInventory, getInventoryValue

Constructor Detail

BatchServerInventoryView

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

Method Detail

addInnerInventory

protected DruidServer addInnerInventory(DruidServer container,
                                        String inventoryKey,
                                        Set<DataSegment> inventory)

Specified by:

addInnerInventory in class ServerInventoryView<Set<DataSegment>>

updateInnerInventory

protected DruidServer updateInnerInventory(DruidServer container,
                                           String inventoryKey,
                                           Set<DataSegment> inventory)

Specified by:

updateInnerInventory in class ServerInventoryView<Set<DataSegment>>

removeInnerInventory

protected DruidServer removeInnerInventory(DruidServer container,
                                           String inventoryKey)

Specified by:

removeInnerInventory in class ServerInventoryView<Set<DataSegment>>

registerSegmentCallback

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

Specified by:

registerSegmentCallback in interface FilteredServerInventoryView

segmentCallbackRemoved

protected void segmentCallbackRemoved(ServerView.SegmentCallback callback)

Specified by:

segmentCallbackRemoved in class ServerInventoryView<Set<DataSegment>>