• 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.hooks module airflow.providers.apache.pinot.hooks.pinot module

C

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

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_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)

I

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

M

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

P

pinot_admin() (in module tests.system.providers.apache.pinot.example_pinot_dag)

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

R

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

S

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.providers.apache.pinot.example_pinot_dag) tests.system.providers.apache.pinot module

tests.system.providers.apache.pinot.example_pinot_dag module

U

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

PreviousNext

Was this entry helpful?