BaseFetcher¶

BaseIndexQueryGenerator¶

BasePreparer¶

BasicDruidJobWatcher¶

CallbackBasedIndexingTaskDruidJobWatcher¶

IndexingTaskDruidJobWatcher¶

AlreadyWatchingJobException¶

CannotWriteException¶

MalformedFilePathException¶

UnableToDeleteFileException¶

UnexpectedTypeException¶

MySQLBatchFetcher¶

Class MySQLBatchFetcher fetches data from an app MySQL database using a query.

ReferralBatchFetcher¶

Class ReferralBatchFetcher fetches Referral Data from an app MySQL database.

LocalFilePreparer¶

Class LocalFilePreparer prepares files locally on the file system.

LocalPhpArrayToJsonFilePreparer¶

Class LocalFilePreparer prepares files locally on the file system.

RemoteSCPPreparer¶

Class RemoteSCPPreparer prepares files on remote machines via SCP/SSH.

IndexingTaskStatusQueryGenerator¶

Class IndexingTaskStatusQueryGenerator acts as a no-operation class for checking the status of tasks.

SimpleIndexQueryGenerator¶

IndexingTaskStatusQueryParameters¶

Represents parameters used in generation of Druid POST bodies for indexing tasks and querying tasks.

IndexTaskQueryParameters¶

Class IndexTaskQueryParameters represents parameter values for an indexing task for Druid.

ReferralReportIndexTaskQueryParameters¶

Class IndexTaskQueryParameters represents parameter values for an indexing task for Druid.

IndexingTaskStatusQueryResponse¶

IndexingTaskResponseHandler¶

Class IndexingTaskResponseHandler returns the task id.

IndexingTaskStatusResponseHandler¶

IngestCommand¶

IngestCommand is a base command to wrap common ingestion tasks. Handles getting start/end time window arguments.

ReferralIngestCommand¶

ReferralIngestCommand runs ReferralBatchIngester giving it the passed CLI parameters.

DruidTime¶

Class Interval represents Web ISO style date ranges for use in Druid queries.

Interval¶

Class Interval represents Web ISO style date ranges for use in Druid queries.

ReferralsByCompanyGroupByQueryGenerator¶

ReferralsByCompanyGroupByQueryParameters¶

Represents parameters used in generation of Druid POST bodies for indexing tasks and querying tasks.

ReferralsByCompanyGroupByResponseHandler¶

Class ReferralsByCompanyGroupByResponseHandler attempts to convert a Druid response into a ExampleReferralByCompanyResponseObject.

ReferralsByCompanyGroupByWithResponseObject¶

ExampleReferralByCompanyResponseObject¶

AbstractTaskParameters¶

Represents parameters used in generation of Druid POST bodies for indexing tasks and querying tasks.

ConnectionLostException¶

DruidBusyException¶

DruidUnavailableException¶

EmptyParametersException¶

Class EmptyParametersException

MalformedQueryException¶

MissingParametersException¶

UnexpectedTypeException¶

DruidNodeDruidQueryExecutor¶

JSONDruidNodeDruidQueryExecutor¶

Class JSONDruidNodeDruidQueryExecutor

GroupByQueryGenerator¶

Class GroupByQueryGenerator

SegmentMetadataDruidQueryGenerator¶

Class SegmentMetadataDruidQueryGenerator generates Segment Metadata queries intended for use with Druid.

SimpleGroupByDruidQueryGenerator¶

TimeBoundaryDruidQueryGenerator¶

GroupByQueryParameters¶

Class GroupByQueryParameters

SegmentMetadataQueryParameters¶

Represents parameters used in generation of Druid POST bodies for indexing tasks and querying tasks.

SimpleGroupByQueryParameters¶

Class SimpleGroupByQueryParameters represents parameter values for a typical group by Druid query.

TimeBoundaryQueryParameters¶

Represents parameters used in generation of Druid POST bodies for indexing tasks and querying tasks.

GroupByResponse¶

Class GroupByResponse

TimeBoundaryResponse¶

Class TimeBoundaryResponse

DoNothingResponseHandler¶

Class DoNothingResponseHandler simply returns a response unchanged.

GroupByResponseHandler¶

Class GroupByResponseHandler

JsonFormattingResponseHandler¶

Class JsonFormattingResponseHandler decodes a JSON response and returns the result.

TimeBoundaryResponseHandler¶

Class TimeBoundaryResponseHandler attempts to convert a Druid response into a TimeBoundaryResponse.

DruidTimeTest¶

IntervalTest¶

AbstractTaskParametersTest¶

EmptyParametersExceptionTest¶

Class EmptyParametersExceptionTest

MissingParametersExceptionTest¶

DruidNodeDruidQueryExecutorTest¶

Class DruidNodeDruidQueryExecutorTest

GroupByQueryGeneratorTest¶

Class GroupByQueryGeneratorTest

SegmentMetadataDruidQueryGeneratorTest¶

SimpleGroupByDruidQueryGeneratorTest¶

TimeBoundaryDruidQueryGeneratorTest¶

GroupByQueryParametersTest¶

Class GroupByQueryParametersTest

SegmentMetadataQueryParametersTest¶

SimpleGroupByQueryParametersTest¶

TimeBoundaryQueryParametersTest¶

DoNothingResponseHandlerTest¶

GroupByResponseHandlerTest¶

Class GroupByResponseHandlerTest

TimeBoundaryResponseHandlerTest¶