• Home
• Index

Index

_

__version__ (in module airflow.providers.apache.druid)

A

airflow.providers.apache.druid module airflow.providers.apache.druid.get_provider_info module airflow.providers.apache.druid.hooks module airflow.providers.apache.druid.hooks.druid module airflow.providers.apache.druid.operators module

airflow.providers.apache.druid.operators.druid module airflow.providers.apache.druid.transfers module airflow.providers.apache.druid.transfers.hive_to_druid module airflow.providers.apache.druid.version_compat module AIRFLOW_V_3_0_PLUS (in module airflow.providers.apache.druid.version_compat) AIRFLOW_V_3_1_PLUS (in module airflow.providers.apache.druid.version_compat)

B

BATCH (airflow.providers.apache.druid.hooks.druid.IngestionType attribute)

C

conn (airflow.providers.apache.druid.hooks.druid.DruidHook property) conn_id (airflow.providers.apache.druid.operators.druid.DruidOperator attribute) conn_name_attr (airflow.providers.apache.druid.hooks.druid.DruidDbApiHook attribute)

conn_type (airflow.providers.apache.druid.hooks.druid.DruidDbApiHook attribute) construct_ingest_query() (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator method) context (airflow.providers.apache.druid.hooks.druid.DruidDbApiHook attribute)

D

DAG_ID (in module tests.system.apache.druid.example_druid) (in module tests.system.apache.druid.example_druid_dag) default_conn_name (airflow.providers.apache.druid.hooks.druid.DruidDbApiHook attribute) DEFAULT_TARGET_PARTITION_SIZE (in module airflow.providers.apache.druid.transfers.hive_to_druid) druid_datasource (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute)

druid_ingest_conn_id (airflow.providers.apache.druid.hooks.druid.DruidHook attribute) (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute) DruidDbApiHook (class in airflow.providers.apache.druid.hooks.druid) DruidHook (class in airflow.providers.apache.druid.hooks.druid) DruidOperator (class in airflow.providers.apache.druid.operators.druid)

E

ENV_ID (in module tests.system.apache.druid.example_druid_dag)

execute() (airflow.providers.apache.druid.operators.druid.DruidOperator method) (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator method)

G

get_auth() (airflow.providers.apache.druid.hooks.druid.DruidHook method) get_conn() (airflow.providers.apache.druid.hooks.druid.DruidDbApiHook method) get_conn_url() (airflow.providers.apache.druid.hooks.druid.DruidHook method) get_connection_type (airflow.providers.apache.druid.hooks.druid.DruidHook property)

get_provider_info() (in module airflow.providers.apache.druid.get_provider_info) get_status_url() (airflow.providers.apache.druid.hooks.druid.DruidHook method) get_uri() (airflow.providers.apache.druid.hooks.druid.DruidDbApiHook method) get_verify() (airflow.providers.apache.druid.hooks.druid.DruidHook method)

H

hadoop_dependency_coordinates (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute) header (airflow.providers.apache.druid.hooks.druid.DruidHook attribute) hive_cli_conn_id (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute)

hive_tblproperties (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute) HiveToDruidOperator (class in airflow.providers.apache.druid.transfers.hive_to_druid) hook_name (airflow.providers.apache.druid.hooks.druid.DruidDbApiHook attribute)

I

ingestion_type (airflow.providers.apache.druid.operators.druid.DruidOperator attribute) IngestionType (class in airflow.providers.apache.druid.hooks.druid)

insert_rows() (airflow.providers.apache.druid.hooks.druid.DruidDbApiHook method) intervals (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute)

J

job_properties (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute)

json_index_file (airflow.providers.apache.druid.operators.druid.DruidOperator attribute)

L

list_datasources_task (in module tests.system.apache.druid.example_druid)

LOAD_CHECK_INTERVAL (in module airflow.providers.apache.druid.transfers.hive_to_druid)

M

max_ingestion_time (airflow.providers.apache.druid.hooks.druid.DruidHook attribute) (airflow.providers.apache.druid.operators.druid.DruidOperator attribute) metastore_conn_id (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute) metric_spec (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute) module airflow.providers.apache.druid airflow.providers.apache.druid.get_provider_info airflow.providers.apache.druid.hooks airflow.providers.apache.druid.hooks.druid airflow.providers.apache.druid.operators airflow.providers.apache.druid.operators.druid airflow.providers.apache.druid.transfers airflow.providers.apache.druid.transfers.hive_to_druid airflow.providers.apache.druid.version_compat tests.system.apache.druid tests.system.apache.druid.example_druid tests.system.apache.druid.example_druid_dag

MSQ (airflow.providers.apache.druid.hooks.druid.IngestionType attribute)

N

num_shards (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute)

Q

query_granularity (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute)

S

segment_granularity (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute) set_autocommit() (airflow.providers.apache.druid.hooks.druid.DruidDbApiHook method) sql (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute)

status_endpoint (airflow.providers.apache.druid.hooks.druid.DruidHook attribute) submit_indexing_job() (airflow.providers.apache.druid.hooks.druid.DruidHook method) submit_job (in module tests.system.apache.druid.example_druid_dag) supports_autocommit (airflow.providers.apache.druid.hooks.druid.DruidDbApiHook attribute)

T

target_partition_size (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute) template_ext (airflow.providers.apache.druid.operators.druid.DruidOperator attribute) (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute) template_fields (airflow.providers.apache.druid.operators.druid.DruidOperator attribute) (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute) template_fields_renderers (airflow.providers.apache.druid.operators.druid.DruidOperator attribute) (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute) test_run (in module tests.system.apache.druid.example_druid) (in module tests.system.apache.druid.example_druid_dag)

tests.system.apache.druid module tests.system.apache.druid.example_druid module tests.system.apache.druid.example_druid_dag module timeout (airflow.providers.apache.druid.hooks.druid.DruidHook attribute) (airflow.providers.apache.druid.operators.druid.DruidOperator attribute) ts_dim (airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator attribute)

V

verify_ssl (airflow.providers.apache.druid.hooks.druid.DruidHook attribute) (airflow.providers.apache.druid.operators.druid.DruidOperator attribute)

PreviousNext

Was this entry helpful?