| 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.