DruidOperator
Apache DruidAllows to submit a task directly to druid
Access Instructions
Install the Apache Druid provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
json_index_fileRequiredThe filepath to the druid index specification
druid_ingest_conn_idThe connection id of the Druid overlord which accepts index jobs
timeoutThe interval (in seconds) between polling the Druid job for the status of the ingestion job. Must be greater than or equal to 1
max_ingestion_timeThe maximum ingestion time before assuming the job failed
Documentation
Allows to submit a task directly to druid