• Home
• Index

Index

_

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

A

airflow.providers.apache.hdfs module airflow.providers.apache.hdfs.get_provider_info module airflow.providers.apache.hdfs.hooks module airflow.providers.apache.hdfs.hooks.webhdfs module airflow.providers.apache.hdfs.log module

airflow.providers.apache.hdfs.log.hdfs_task_handler module airflow.providers.apache.hdfs.sensors module airflow.providers.apache.hdfs.sensors.web_hdfs module airflow.providers.apache.hdfs.version_compat module AIRFLOW_V_3_0_PLUS (in module airflow.providers.apache.hdfs.version_compat) AIRFLOW_V_3_1_PLUS (in module airflow.providers.apache.hdfs.version_compat) AirflowWebHDFSHookException

B

base_log_folder (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsRemoteLogIO attribute)

C

check_for_path() (airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook method) close() (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsTaskHandler method)

closed (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsTaskHandler attribute) conn_name_attr (airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook attribute) conn_type (airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook attribute)

D

default_conn_name (airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook attribute)

delete_local_copy (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsRemoteLogIO attribute) directory_path (airflow.providers.apache.hdfs.sensors.web_hdfs.MultipleFilesWebHdfsSensor attribute)

E

expected_filenames (airflow.providers.apache.hdfs.sensors.web_hdfs.MultipleFilesWebHdfsSensor attribute)

F

filepath (airflow.providers.apache.hdfs.sensors.web_hdfs.WebHdfsSensor attribute)

G

get_conn() (airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook method)

get_provider_info() (in module airflow.providers.apache.hdfs.get_provider_info)

H

handler (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsTaskHandler attribute) HdfsRemoteLogIO (class in airflow.providers.apache.hdfs.log.hdfs_task_handler)

HdfsTaskHandler (class in airflow.providers.apache.hdfs.log.hdfs_task_handler) hook (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsRemoteLogIO property) hook_name (airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook attribute)

I

io (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsTaskHandler attribute)

L

load_file() (airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook method)

log (in module airflow.providers.apache.hdfs.hooks.webhdfs) log_relative_path (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsTaskHandler attribute)

M

module airflow.providers.apache.hdfs airflow.providers.apache.hdfs.get_provider_info airflow.providers.apache.hdfs.hooks airflow.providers.apache.hdfs.hooks.webhdfs airflow.providers.apache.hdfs.log airflow.providers.apache.hdfs.log.hdfs_task_handler airflow.providers.apache.hdfs.sensors airflow.providers.apache.hdfs.sensors.web_hdfs airflow.providers.apache.hdfs.version_compat

MultipleFilesWebHdfsSensor (class in airflow.providers.apache.hdfs.sensors.web_hdfs)

P

poke() (airflow.providers.apache.hdfs.sensors.web_hdfs.MultipleFilesWebHdfsSensor method) (airflow.providers.apache.hdfs.sensors.web_hdfs.WebHdfsSensor method)

processors (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsRemoteLogIO attribute) proxy_user (airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook attribute)

R

read() (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsRemoteLogIO method) read_file() (airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook method)

remote_base (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsRemoteLogIO attribute) (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsTaskHandler attribute)

S

set_context() (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsTaskHandler method)

T

template_fields (airflow.providers.apache.hdfs.sensors.web_hdfs.MultipleFilesWebHdfsSensor attribute) (airflow.providers.apache.hdfs.sensors.web_hdfs.WebHdfsSensor attribute)

U

upload() (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsRemoteLogIO method)

upload_on_close (airflow.providers.apache.hdfs.log.hdfs_task_handler.HdfsTaskHandler attribute)

W

webhdfs_conn_id (airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook attribute) (airflow.providers.apache.hdfs.sensors.web_hdfs.MultipleFilesWebHdfsSensor attribute) (airflow.providers.apache.hdfs.sensors.web_hdfs.WebHdfsSensor attribute)

WebHDFSHook (class in airflow.providers.apache.hdfs.hooks.webhdfs) WebHdfsSensor (class in airflow.providers.apache.hdfs.sensors.web_hdfs)

PreviousNext

Was this entry helpful?