Modifier and Type | Interface and Description |
---|---|
interface |
CliCommandCreator |
Modifier and Type | Interface and Description |
---|---|
interface |
Committer
Committer includes a Runnable and a Jackson-serialized metadata object containing the offset
|
interface |
Firehose
This is an interface that holds onto the stream of incoming data.
|
interface |
FirehoseFactory<T extends InputRowParser>
FirehoseFactory creates a
Firehose which is an interface holding onto the stream of incoming data. |
interface |
FirehoseFactoryV2<T extends InputRowParser>
Initialization method that connects up the FirehoseV2.
|
interface |
FirehoseV2
This is an interface that holds onto the stream of incoming data.
|
interface |
InputRow
An InputRow is the interface definition of an event being input into the data ingestion layer.
|
Modifier and Type | Interface and Description |
---|---|
interface |
InputRowParser<T> |
class |
ParseSpec |
Modifier and Type | Interface and Description |
---|---|
interface |
AutoScaler<T>
The AutoScaler has the actual methods to provision and terminate worker nodes.
|
interface |
ProvisioningStrategy<T extends TaskRunner>
In general, the resource management is tied to the runner.
|
Modifier and Type | Interface and Description |
---|---|
interface |
WorkerBehaviorConfig
Outside of
PendingTaskBasedWorkerProvisioningStrategy and
SimpleWorkerProvisioningStrategy , WorkerBehaviorConfig is used only
in TaskRunner , and only WorkerBehaviorConfig.getSelectStrategy() method is used. |
Modifier and Type | Interface and Description |
---|---|
interface |
DruidModule |
Modifier and Type | Interface and Description |
---|---|
interface |
PasswordProvider
Implement this for different ways to (optionally securely) access secrets.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseQuery<T extends Comparable<T>> |
interface |
CacheStrategy<T,CacheType,QueryType extends Query<T>> |
interface |
Query<T> |
interface |
QueryMetrics<QueryType extends Query<?>>
Abstraction wrapping
ServiceMetricEvent.Builder and allowing to control what
metrics are actually emitted, what dimensions do they have, etc. |
interface |
QueryRunner<T> |
interface |
QueryRunnerFactory<T,QueryType extends Query<T>>
An interface that defines the nitty gritty implementation detauls of a Query on a Segment
|
class |
QueryToolChest<ResultType,QueryType extends Query<ResultType>>
The broker-side (also used by server in some cases) API for a specific Query type.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Aggregator
An Aggregator is an object that can aggregate metrics.
|
class |
AggregatorFactory
AggregatorFactory is a strategy (in the terms of Design Patterns) that represents column aggregation, e.
|
interface |
BufferAggregator
A BufferAggregator is an object that can aggregate metrics into a ByteBuffer.
|
interface |
PostAggregator
Functionally similar to an Aggregator.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ExtractionFn |
Modifier and Type | Interface and Description |
---|---|
interface |
GroupByQueryMetrics
Specialization of
QueryMetrics for GroupByQuery . |
Modifier and Type | Interface and Description |
---|---|
interface |
TimeseriesQueryMetrics
Specialization of
QueryMetrics for TimeseriesQuery . |
Modifier and Type | Interface and Description |
---|---|
interface |
TopNQueryMetrics
Specialization of
QueryMetrics for TopNQuery . |
Modifier and Type | Interface and Description |
---|---|
interface |
GenericColumnSerializer |
Modifier and Type | Interface and Description |
---|---|
interface |
ObjectStrategy<T> |
Modifier and Type | Interface and Description |
---|---|
interface |
DataSegmentArchiver |
interface |
DataSegmentFinder
A DataSegmentFinder is responsible for finding Druid segments underneath a specified directory and optionally updates
all descriptor.json files on deep storage with correct loadSpec.
|
interface |
DataSegmentKiller |
interface |
DataSegmentMover |
interface |
DataSegmentPuller
A DataSegmentPuller is responsible for pulling data for a particular segment into a particular directory
|
interface |
DataSegmentPusher |
interface |
LoadSpec
A means of pulling segment files into a destination directory
|
interface |
URIDataPuller
A URIDataPuller has handlings for URI based data
|
Modifier and Type | Interface and Description |
---|---|
interface |
ComplexMetricExtractor |
class |
ComplexMetricSerde |
Modifier and Type | Interface and Description |
---|---|
interface |
ServletFilterHolder
A ServletFilterHolder is a class that holds all of the information required to attach a Filter to a Servlet.
|
Modifier and Type | Interface and Description |
---|---|
interface |
TaskLogKiller |
interface |
TaskLogPusher
Something that knows how to persist local task logs to some form of long-term storage.
|
interface |
TaskLogs |
interface |
TaskLogStreamer
Something that knows how to stream logs for tasks.
|
Copyright © 2011–2018. All rights reserved.