• Home
• Index

Index

_

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

A

add_schema() (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook method) add_table() (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook method) airflow.providers.apache.pinot module airflow.providers.apache.pinot.get_provider_info module

airflow.providers.apache.pinot.hooks module airflow.providers.apache.pinot.hooks.pinot module

C

cmd_path (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute) conn (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute) conn_name_attr (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute) (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook attribute)

conn_type (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute) (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook attribute) create_segment() (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook method)

D

DAG_ID (in module tests.system.apache.pinot.example_pinot)

default_conn_name (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute) (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook attribute)

G

get_conn() (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook method) (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook method) get_first() (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook method)

get_provider_info() (in module airflow.providers.apache.pinot.get_provider_info) get_records() (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook method) get_uri() (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook method)

H

hook_name (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute) (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook attribute)

host (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute)

I

insert_rows() (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook method)

M

module airflow.providers.apache.pinot airflow.providers.apache.pinot.get_provider_info airflow.providers.apache.pinot.hooks airflow.providers.apache.pinot.hooks.pinot tests.system.apache.pinot tests.system.apache.pinot.example_pinot tests.system.apache.pinot.example_pinot_dag

P

password (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute) pinot_admin() (in module tests.system.apache.pinot.example_pinot_dag) pinot_admin_system_exit (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute)

PinotAdminHook (class in airflow.providers.apache.pinot.hooks.pinot) PinotDbApiHook (class in airflow.providers.apache.pinot.hooks.pinot) port (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute)

R

run_cli() (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook method)

S

select_1_task (in module tests.system.apache.pinot.example_pinot)

set_autocommit() (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook method) supports_autocommit (airflow.providers.apache.pinot.hooks.pinot.PinotDbApiHook attribute)

T

test_run (in module tests.system.apache.pinot.example_pinot) (in module tests.system.apache.pinot.example_pinot_dag) tests.system.apache.pinot module

tests.system.apache.pinot.example_pinot module tests.system.apache.pinot.example_pinot_dag module

U

upload_segment() (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook method)

username (airflow.providers.apache.pinot.hooks.pinot.PinotAdminHook attribute)

PreviousNext

Was this entry helpful?