airflow.contrib.operators.druid_operator
¶
Module Contents¶
-
class
airflow.contrib.operators.druid_operator.
DruidOperator
(json_index_file, druid_ingest_conn_id='druid_ingest_default', max_ingestion_time=None, *args, **kwargs)[source]¶ Bases:
airflow.models.BaseOperator
Allows to submit a task directly to druid
- Parameters