public class BatchServerInventoryView extends ServerInventoryView<Set<io.druid.timeline.DataSegment>>
ServerView.BaseSegmentCallback, ServerView.CallbackAction, ServerView.SegmentCallback, ServerView.ServerCallback
Constructor and Description |
---|
BatchServerInventoryView(ZkPathsConfig zkPaths,
org.apache.curator.framework.CuratorFramework curator,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Modifier and Type | Method and Description |
---|---|
protected DruidServer |
addInnerInventory(DruidServer container,
String inventoryKey,
Set<io.druid.timeline.DataSegment> inventory) |
protected DruidServer |
removeInnerInventory(DruidServer container,
String inventoryKey) |
protected DruidServer |
updateInnerInventory(DruidServer container,
String inventoryKey,
Set<io.druid.timeline.DataSegment> inventory) |
addSingleInventory, getInventory, getInventoryManagerConfig, getInventoryValue, isStarted, registerSegmentCallback, registerServerCallback, removeSingleInventory, runSegmentCallbacks, runServerCallbacks, start, stop
@Inject public BatchServerInventoryView(ZkPathsConfig zkPaths, org.apache.curator.framework.CuratorFramework curator, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
protected DruidServer addInnerInventory(DruidServer container, String inventoryKey, Set<io.druid.timeline.DataSegment> inventory)
addInnerInventory
in class ServerInventoryView<Set<io.druid.timeline.DataSegment>>
protected DruidServer updateInnerInventory(DruidServer container, String inventoryKey, Set<io.druid.timeline.DataSegment> inventory)
updateInnerInventory
in class ServerInventoryView<Set<io.druid.timeline.DataSegment>>
protected DruidServer removeInnerInventory(DruidServer container, String inventoryKey)
removeInnerInventory
in class ServerInventoryView<Set<io.druid.timeline.DataSegment>>
Copyright © 2011–2016. All rights reserved.