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)

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']

template_ext = ['.json']

execute(self, context)