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]