`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

json_index_file (str) – The filepath to the druid index specification
druid_ingest_conn_id (str) – The connection id of the Druid overlord which accepts index jobs

template_fields = ['index_spec_str'][source]¶

template_ext = ['.json'][source]¶

execute(self, context)[source]¶

Was this entry helpful?