Package | Description |
---|---|
io.druid.client | |
io.druid.client.selector | |
io.druid.guice | |
io.druid.query | |
io.druid.server.coordination |
Modifier and Type | Method and Description |
---|---|
DruidServerMetadata |
ImmutableDruidServer.getMetadata() |
DruidServerMetadata |
DruidServer.getMetadata() |
Modifier and Type | Method and Description |
---|---|
com.google.common.collect.ImmutableSet<DruidServerMetadata> |
ImmutableSegmentLoadInfo.getServers() |
Modifier and Type | Method and Description |
---|---|
boolean |
SegmentLoadInfo.addServer(DruidServerMetadata server) |
boolean |
SegmentLoadInfo.removeServer(DruidServerMetadata server) |
ServerView.CallbackAction |
ServerView.SegmentCallback.segmentAdded(DruidServerMetadata server,
DataSegment segment)
Called when a segment is added to a server.
|
ServerView.CallbackAction |
ServerView.BaseSegmentCallback.segmentAdded(DruidServerMetadata server,
DataSegment segment) |
ServerView.CallbackAction |
ServerView.SegmentCallback.segmentRemoved(DruidServerMetadata server,
DataSegment segment)
Called when a segment is removed from a server.
|
ServerView.CallbackAction |
ServerView.BaseSegmentCallback.segmentRemoved(DruidServerMetadata server,
DataSegment segment) |
Modifier and Type | Method and Description |
---|---|
void |
SingleServerInventoryView.registerSegmentCallback(Executor exec,
ServerView.SegmentCallback callback,
com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter) |
void |
FilteredServerInventoryView.registerSegmentCallback(Executor exec,
ServerView.SegmentCallback callback,
com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter) |
void |
BatchServerInventoryView.registerSegmentCallback(Executor exec,
ServerView.SegmentCallback callback,
com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> filter) |
Constructor and Description |
---|
ImmutableDruidServer(DruidServerMetadata metadata,
long currSize,
com.google.common.collect.ImmutableMap<String,ImmutableDruidDataSource> dataSources,
com.google.common.collect.ImmutableMap<String,DataSegment> segments) |
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) |
ImmutableSegmentLoadInfo(DataSegment segment,
Set<DruidServerMetadata> servers) |
SingleServerInventoryView(ZkPathsConfig zkPaths,
org.apache.curator.framework.CuratorFramework curator,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter) |
Modifier and Type | Method and Description |
---|---|
List<DruidServerMetadata> |
ServerSelector.getCandidates(int numCandidates) |
Modifier and Type | Method and Description |
---|---|
DruidServerMetadata |
StorageNodeModule.getMetadata(DruidNode node,
NodeTypeConfig nodeType,
DruidServerConfig config) |
Modifier and Type | Method and Description |
---|---|
List<DruidServerMetadata> |
LocatedSegmentDescriptor.getLocations() |
Constructor and Description |
---|
LocatedSegmentDescriptor(org.joda.time.Interval interval,
String version,
int partitionNumber,
long size,
List<DruidServerMetadata> locations) |
LocatedSegmentDescriptor(SegmentDescriptor descriptor,
long size,
List<DruidServerMetadata> candidates) |
Constructor and Description |
---|
AbstractDataSegmentAnnouncer(DruidServerMetadata server,
ZkPathsConfig config,
Announcer announcer,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
BatchDataSegmentAnnouncer(DruidServerMetadata server,
BatchDataSegmentAnnouncerConfig config,
ZkPathsConfig zkPaths,
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,
ScheduledExecutorFactory factory) |
Copyright © 2011–2017. All rights reserved.