| Package | Description |
|---|---|
| io.druid.client | |
| io.druid.guice | |
| io.druid.server.bridge | |
| io.druid.server.coordination |
| Modifier and Type | Method and Description |
|---|---|
DruidServerMetadata |
ImmutableDruidServer.getMetadata() |
DruidServerMetadata |
DruidServer.getMetadata() |
| Modifier and Type | Method and Description |
|---|---|
ServerView.CallbackAction |
ServerView.SegmentCallback.segmentAdded(DruidServerMetadata server,
io.druid.timeline.DataSegment segment)
Called when a segment is added to a server.
|
ServerView.CallbackAction |
ServerView.BaseSegmentCallback.segmentAdded(DruidServerMetadata server,
io.druid.timeline.DataSegment segment) |
ServerView.CallbackAction |
ServerView.SegmentCallback.segmentRemoved(DruidServerMetadata server,
io.druid.timeline.DataSegment segment)
Called when a segment is removed from a server.
|
ServerView.CallbackAction |
ServerView.BaseSegmentCallback.segmentRemoved(DruidServerMetadata server,
io.druid.timeline.DataSegment segment) |
| Constructor and Description |
|---|
ImmutableDruidServer(DruidServerMetadata metadata,
long currSize,
com.google.common.collect.ImmutableMap<String,ImmutableDruidDataSource> dataSources,
com.google.common.collect.ImmutableMap<String,io.druid.timeline.DataSegment> segments) |
| Modifier and Type | Method and Description |
|---|---|
DruidServerMetadata |
StorageNodeModule.getMetadata(DruidNode node,
NodeTypeConfig nodeType,
DruidServerConfig config) |
| Constructor and Description |
|---|
BridgeZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ZkPathsConfig zkPaths,
SegmentLoaderConfig config,
DruidServerMetadata me,
org.apache.curator.framework.CuratorFramework curator,
SegmentPublisher dbSegmentPublisher,
MetadataSegmentManager databaseSegmentManager,
ServerView serverView) |
DruidClusterBridge(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
DruidClusterBridgeConfig config,
ZkPathsConfig zkPathsConfig,
DruidServerMetadata druidServerMetadata,
com.metamx.common.concurrent.ScheduledExecutorFactory scheduledExecutorFactory,
DruidNode self,
org.apache.curator.framework.CuratorFramework curator,
AtomicReference<org.apache.curator.framework.recipes.leader.LeaderLatch> leaderLatch,
BridgeZkCoordinator bridgeZkCoordinator,
Announcer announcer,
AbstractDataSegmentAnnouncer dataSegmentAnnouncer,
ServerInventoryView serverInventoryView) |
| Constructor and Description |
|---|
AbstractDataSegmentAnnouncer(DruidServerMetadata server,
ZkPathsConfig config,
Announcer announcer,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
BaseZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ZkPathsConfig zkPaths,
SegmentLoaderConfig config,
DruidServerMetadata me,
org.apache.curator.framework.CuratorFramework curator) |
BatchDataSegmentAnnouncer(DruidServerMetadata server,
BatchDataSegmentAnnouncerConfig config,
ZkPathsConfig zkPaths,
Announcer announcer,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
SingleDataSegmentAnnouncer(DruidServerMetadata server,
ZkPathsConfig config,
Announcer announcer,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
ZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
SegmentLoaderConfig config,
ZkPathsConfig zkPaths,
DruidServerMetadata me,
DataSegmentAnnouncer announcer,
org.apache.curator.framework.CuratorFramework curator,
ServerManager serverManager,
com.metamx.common.concurrent.ScheduledExecutorFactory factory) |
Copyright © 2011–2015. All rights reserved.