• Home
• Index

Index

_

__getstate__() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method)

__setstate__() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method)

A

airflow.providers.apache.hive module airflow.providers.apache.hive.hooks module airflow.providers.apache.hive.hooks.hive module airflow.providers.apache.hive.operators module airflow.providers.apache.hive.operators.hive module airflow.providers.apache.hive.operators.hive_stats module airflow.providers.apache.hive.sensors module airflow.providers.apache.hive.sensors.hive_partition module airflow.providers.apache.hive.sensors.metastore_partition module

airflow.providers.apache.hive.sensors.named_hive_partition module airflow.providers.apache.hive.transfers module airflow.providers.apache.hive.transfers.hive_to_mysql module airflow.providers.apache.hive.transfers.hive_to_samba module airflow.providers.apache.hive.transfers.mssql_to_hive module airflow.providers.apache.hive.transfers.mysql_to_hive module airflow.providers.apache.hive.transfers.s3_to_hive module airflow.providers.apache.hive.transfers.vertica_to_hive module analyze_tweets() (in module tests.system.providers.apache.hive.example_twitter_dag)

C

check_for_named_partition() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method) check_for_partition() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method) clean_tweets() (in module tests.system.providers.apache.hive.example_twitter_dag) clear_airflow_vars() (airflow.providers.apache.hive.operators.hive.HiveOperator method) conn_name_attr (airflow.providers.apache.hive.hooks.hive.HiveCliHook attribute) (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook attribute) (airflow.providers.apache.hive.hooks.hive.HiveServer2Hook attribute)

conn_type (airflow.providers.apache.hive.hooks.hive.HiveCliHook attribute) (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook attribute) (airflow.providers.apache.hive.hooks.hive.HiveServer2Hook attribute)

D

DAG_ID (in module tests.system.providers.apache.hive.example_twitter_dag) default_conn_name (airflow.providers.apache.hive.hooks.hive.HiveCliHook attribute) (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook attribute) (airflow.providers.apache.hive.hooks.hive.HiveServer2Hook attribute)

drop_partitions() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method) dry_run() (airflow.providers.apache.hive.operators.hive.HiveOperator method)

E

ENV_ID (in module tests.system.providers.apache.hive.example_twitter_dag) execute() (airflow.providers.apache.hive.operators.hive.HiveOperator method) (airflow.providers.apache.hive.operators.hive_stats.HiveStatsCollectionOperator method) (airflow.providers.apache.hive.transfers.hive_to_mysql.HiveToMySqlOperator method) (airflow.providers.apache.hive.transfers.hive_to_samba.HiveToSambaOperator method) (airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator method) (airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator method) (airflow.providers.apache.hive.transfers.s3_to_hive.S3ToHiveOperator method) (airflow.providers.apache.hive.transfers.vertica_to_hive.VerticaToHiveOperator method)

F

fetch (in module tests.system.providers.apache.hive.example_twitter_dag)

fetch_tweets() (in module tests.system.providers.apache.hive.example_twitter_dag)

G

get_conn() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method) (airflow.providers.apache.hive.hooks.hive.HiveServer2Hook method) get_context_from_env_var() (in module airflow.providers.apache.hive.hooks.hive) get_databases() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method) get_default_exprs() (airflow.providers.apache.hive.operators.hive_stats.HiveStatsCollectionOperator method) get_hook() (airflow.providers.apache.hive.operators.hive.HiveOperator method)

get_metastore_client() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method) get_pandas_df() (airflow.providers.apache.hive.hooks.hive.HiveServer2Hook method) get_partitions() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method) get_records() (airflow.providers.apache.hive.hooks.hive.HiveServer2Hook method) get_results() (airflow.providers.apache.hive.hooks.hive.HiveServer2Hook method) get_table() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method) get_tables() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method)

H

HIVE_QUEUE_PRIORITIES (in module airflow.providers.apache.hive.hooks.hive) HiveCliHook (class in airflow.providers.apache.hive.hooks.hive) HiveMetastoreHook (class in airflow.providers.apache.hive.hooks.hive) HiveOperator (class in airflow.providers.apache.hive.operators.hive) HivePartitionSensor (class in airflow.providers.apache.hive.sensors.hive_partition) HiveServer2Hook (class in airflow.providers.apache.hive.hooks.hive)

HiveStatsCollectionOperator (class in airflow.providers.apache.hive.operators.hive_stats) HiveToMySqlOperator (class in airflow.providers.apache.hive.transfers.hive_to_mysql) HiveToSambaOperator (class in airflow.providers.apache.hive.transfers.hive_to_samba) hook_name (airflow.providers.apache.hive.hooks.hive.HiveCliHook attribute) (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook attribute) (airflow.providers.apache.hive.hooks.hive.HiveServer2Hook attribute)

I

is_smart_sensor_compatible() (airflow.providers.apache.hive.sensors.named_hive_partition.NamedHivePartitionSensor method)

K

kill() (airflow.providers.apache.hive.hooks.hive.HiveCliHook method)

L

load_df() (airflow.providers.apache.hive.hooks.hive.HiveCliHook method)

load_file() (airflow.providers.apache.hive.hooks.hive.HiveCliHook method)

M

MAX_PART_COUNT (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook attribute) max_partition() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method) MetastorePartitionSensor (class in airflow.providers.apache.hive.sensors.metastore_partition) module airflow.providers.apache.hive airflow.providers.apache.hive.hooks airflow.providers.apache.hive.hooks.hive airflow.providers.apache.hive.operators airflow.providers.apache.hive.operators.hive airflow.providers.apache.hive.operators.hive_stats airflow.providers.apache.hive.sensors airflow.providers.apache.hive.sensors.hive_partition airflow.providers.apache.hive.sensors.metastore_partition airflow.providers.apache.hive.sensors.named_hive_partition airflow.providers.apache.hive.transfers airflow.providers.apache.hive.transfers.hive_to_mysql airflow.providers.apache.hive.transfers.hive_to_samba airflow.providers.apache.hive.transfers.mssql_to_hive airflow.providers.apache.hive.transfers.mysql_to_hive airflow.providers.apache.hive.transfers.s3_to_hive airflow.providers.apache.hive.transfers.vertica_to_hive tests.system.providers.apache.hive tests.system.providers.apache.hive.example_twitter_dag

MsSqlToHiveOperator (class in airflow.providers.apache.hive.transfers.mssql_to_hive) MYSQL_RENDERER (in module airflow.providers.apache.hive.transfers.hive_to_mysql) MySqlToHiveOperator (class in airflow.providers.apache.hive.transfers.mysql_to_hive)

N

NamedHivePartitionSensor (class in airflow.providers.apache.hive.sensors.named_hive_partition)

O

on_kill() (airflow.providers.apache.hive.operators.hive.HiveOperator method)

P

parse_partition_name() (airflow.providers.apache.hive.sensors.named_hive_partition.NamedHivePartitionSensor static method) poke() (airflow.providers.apache.hive.sensors.hive_partition.HivePartitionSensor method) (airflow.providers.apache.hive.sensors.metastore_partition.MetastorePartitionSensor method) (airflow.providers.apache.hive.sensors.named_hive_partition.NamedHivePartitionSensor method)

poke_context_fields (airflow.providers.apache.hive.sensors.metastore_partition.MetastorePartitionSensor attribute) (airflow.providers.apache.hive.sensors.named_hive_partition.NamedHivePartitionSensor attribute) poke_partition() (airflow.providers.apache.hive.sensors.named_hive_partition.NamedHivePartitionSensor method) prepare_template() (airflow.providers.apache.hive.operators.hive.HiveOperator method)

R

run_cli() (airflow.providers.apache.hive.hooks.hive.HiveCliHook method)

S

S3ToHiveOperator (class in airflow.providers.apache.hive.transfers.s3_to_hive)

supports_autocommit (airflow.providers.apache.hive.hooks.hive.HiveServer2Hook attribute)

T

table_exists() (airflow.providers.apache.hive.hooks.hive.HiveMetastoreHook method) template_ext (airflow.providers.apache.hive.operators.hive.HiveOperator attribute) (airflow.providers.apache.hive.transfers.hive_to_mysql.HiveToMySqlOperator attribute) (airflow.providers.apache.hive.transfers.hive_to_samba.HiveToSambaOperator attribute) (airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator attribute) (airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator attribute) (airflow.providers.apache.hive.transfers.s3_to_hive.S3ToHiveOperator attribute) (airflow.providers.apache.hive.transfers.vertica_to_hive.VerticaToHiveOperator attribute) template_fields (airflow.providers.apache.hive.operators.hive.HiveOperator attribute) (airflow.providers.apache.hive.operators.hive_stats.HiveStatsCollectionOperator attribute) (airflow.providers.apache.hive.sensors.hive_partition.HivePartitionSensor attribute) (airflow.providers.apache.hive.sensors.metastore_partition.MetastorePartitionSensor attribute) (airflow.providers.apache.hive.sensors.named_hive_partition.NamedHivePartitionSensor attribute) (airflow.providers.apache.hive.transfers.hive_to_mysql.HiveToMySqlOperator attribute) (airflow.providers.apache.hive.transfers.hive_to_samba.HiveToSambaOperator attribute) (airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator attribute) (airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator attribute) (airflow.providers.apache.hive.transfers.s3_to_hive.S3ToHiveOperator attribute) (airflow.providers.apache.hive.transfers.vertica_to_hive.VerticaToHiveOperator attribute)

template_fields_renderers (airflow.providers.apache.hive.operators.hive.HiveOperator attribute) (airflow.providers.apache.hive.transfers.hive_to_mysql.HiveToMySqlOperator attribute) (airflow.providers.apache.hive.transfers.hive_to_samba.HiveToSambaOperator attribute) (airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator attribute) (airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator attribute) (airflow.providers.apache.hive.transfers.vertica_to_hive.VerticaToHiveOperator attribute) test_hql() (airflow.providers.apache.hive.hooks.hive.HiveCliHook method) test_run (in module tests.system.providers.apache.hive.example_twitter_dag) tests.system.providers.apache.hive module tests.system.providers.apache.hive.example_twitter_dag module to_csv() (airflow.providers.apache.hive.hooks.hive.HiveServer2Hook method) transfer_to_db() (in module tests.system.providers.apache.hive.example_twitter_dag) type_map() (airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator class method) (airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator class method) (airflow.providers.apache.hive.transfers.vertica_to_hive.VerticaToHiveOperator class method)

U

ui_color (airflow.providers.apache.hive.operators.hive.HiveOperator attribute) (airflow.providers.apache.hive.operators.hive_stats.HiveStatsCollectionOperator attribute) (airflow.providers.apache.hive.sensors.hive_partition.HivePartitionSensor attribute) (airflow.providers.apache.hive.sensors.metastore_partition.MetastorePartitionSensor attribute) (airflow.providers.apache.hive.sensors.named_hive_partition.NamedHivePartitionSensor attribute) (airflow.providers.apache.hive.transfers.hive_to_mysql.HiveToMySqlOperator attribute) (airflow.providers.apache.hive.transfers.mssql_to_hive.MsSqlToHiveOperator attribute) (airflow.providers.apache.hive.transfers.mysql_to_hive.MySqlToHiveOperator attribute) (airflow.providers.apache.hive.transfers.s3_to_hive.S3ToHiveOperator attribute) (airflow.providers.apache.hive.transfers.vertica_to_hive.VerticaToHiveOperator attribute)

V

VerticaToHiveOperator (class in airflow.providers.apache.hive.transfers.vertica_to_hive)

PreviousNext

Was this entry helpful?