• Home
• Index

Index

_

__enter__() (airflow.providers.ydb.hooks.ydb.YDBConnection method) (airflow.providers.ydb.hooks.ydb.YDBCursor method)

__exit__() (airflow.providers.ydb.hooks.ydb.YDBConnection method) (airflow.providers.ydb.hooks.ydb.YDBCursor method) __version__ (in module airflow.providers.ydb)

A

airflow.providers.ydb module airflow.providers.ydb.hooks module airflow.providers.ydb.hooks._vendor module airflow.providers.ydb.hooks._vendor.dbapi module airflow.providers.ydb.hooks._vendor.dbapi.connection module airflow.providers.ydb.hooks._vendor.dbapi.constants module airflow.providers.ydb.hooks._vendor.dbapi.cursor module airflow.providers.ydb.hooks._vendor.dbapi.errors module

airflow.providers.ydb.hooks.ydb module airflow.providers.ydb.operators module airflow.providers.ydb.operators.ydb module airflow.providers.ydb.utils module airflow.providers.ydb.utils.credentials module airflow.providers.ydb.utils.defaults module AIRFLOW_CONN_{CONN_ID} async_connect() (airflow.providers.ydb.hooks._vendor.dbapi.YdbDBApi method) AsyncConnection (class in airflow.providers.ydb.hooks._vendor.dbapi.connection) AsyncCursor (class in airflow.providers.ydb.hooks._vendor.dbapi.cursor) AUTOCOMMIT (airflow.providers.ydb.hooks._vendor.dbapi.connection.IsolationLevel attribute)

B

begin() (airflow.providers.ydb.hooks._vendor.dbapi.connection.Connection method) (airflow.providers.ydb.hooks.ydb.YDBConnection method)

bulk_upsert() (airflow.providers.ydb.hooks.ydb.YDBConnection method) (airflow.providers.ydb.hooks.ydb.YDBHook method)

C

check_exists() (airflow.providers.ydb.hooks._vendor.dbapi.connection.Connection method) (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) close() (airflow.providers.ydb.hooks._vendor.dbapi.connection.Connection method) (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) (airflow.providers.ydb.hooks.ydb.YDBConnection method) (airflow.providers.ydb.hooks.ydb.YDBCursor method) commit() (airflow.providers.ydb.hooks._vendor.dbapi.connection.Connection method) (airflow.providers.ydb.hooks.ydb.YDBConnection method) conn_name_attr (airflow.providers.ydb.hooks.ydb.YDBHook attribute)

CONN_NAME_ATTR (in module airflow.providers.ydb.utils.defaults) conn_type (airflow.providers.ydb.hooks.ydb.YDBHook attribute) CONN_TYPE (in module airflow.providers.ydb.utils.defaults) connect() (airflow.providers.ydb.hooks._vendor.dbapi.YdbDBApi method) Connection (class in airflow.providers.ydb.hooks._vendor.dbapi.connection) create_pet_table (in module tests.system.providers.ydb.example_ydb) Cursor (class in airflow.providers.ydb.hooks._vendor.dbapi.cursor) cursor() (airflow.providers.ydb.hooks._vendor.dbapi.connection.Connection method) (airflow.providers.ydb.hooks.ydb.YDBConnection method)

D

DAG_ID (in module tests.system.providers.ydb.example_ydb) DatabaseError DataError default_conn_name (airflow.providers.ydb.hooks.ydb.YDBHook attribute)

DEFAULT_CONN_NAME (in module airflow.providers.ydb.utils.defaults) DEFAULT_YDB_GRPCS_PORT (in module airflow.providers.ydb.hooks.ydb) describe() (airflow.providers.ydb.hooks._vendor.dbapi.connection.Connection method) describe_table() (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) description (airflow.providers.ydb.hooks.ydb.YDBCursor property)

E

ENV_ID (in module tests.system.providers.ydb.example_ydb) environment variable AIRFLOW_CONN_{CONN_ID} Error execute() (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) (airflow.providers.ydb.hooks.ydb.YDBCursor method)

executemany() (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) (airflow.providers.ydb.hooks.ydb.YDBCursor method) executescript() (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) (airflow.providers.ydb.hooks.ydb.YDBCursor method)

F

fetchall() (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) (airflow.providers.ydb.hooks.ydb.YDBCursor method) fetchmany() (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) (airflow.providers.ydb.hooks.ydb.YDBCursor method)

fetchone() (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) (airflow.providers.ydb.hooks.ydb.YDBCursor method)

G

get_column_type() (in module airflow.providers.ydb.hooks._vendor.dbapi.cursor) get_conn() (airflow.providers.ydb.hooks.ydb.YDBHook method) get_connection_form_widgets() (airflow.providers.ydb.hooks.ydb.YDBHook class method) get_credentials_from_connection() (in module airflow.providers.ydb.utils.credentials)

get_isolation_level() (airflow.providers.ydb.hooks._vendor.dbapi.connection.Connection method) get_table_names() (airflow.providers.ydb.hooks._vendor.dbapi.connection.Connection method) (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) get_ui_field_behaviour() (airflow.providers.ydb.hooks.ydb.YDBHook class method)

H

hook_name (airflow.providers.ydb.hooks.ydb.YDBHook attribute)

I

IntegrityError InterfaceError

InternalError is_ddl (airflow.providers.ydb.hooks._vendor.dbapi.cursor.YdbQuery attribute) IsolationLevel (class in airflow.providers.ydb.hooks._vendor.dbapi.connection)

L

log (in module airflow.providers.ydb.utils.credentials)

logger (in module airflow.providers.ydb.hooks._vendor.dbapi.cursor)

M

module airflow.providers.ydb airflow.providers.ydb.hooks airflow.providers.ydb.hooks._vendor airflow.providers.ydb.hooks._vendor.dbapi airflow.providers.ydb.hooks._vendor.dbapi.connection airflow.providers.ydb.hooks._vendor.dbapi.constants airflow.providers.ydb.hooks._vendor.dbapi.cursor airflow.providers.ydb.hooks._vendor.dbapi.errors airflow.providers.ydb.hooks.ydb airflow.providers.ydb.operators airflow.providers.ydb.operators.ydb airflow.providers.ydb.utils airflow.providers.ydb.utils.credentials airflow.providers.ydb.utils.defaults tests.system.providers.ydb tests.system.providers.ydb.example_ydb

N

nextset() (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) (airflow.providers.ydb.hooks.ydb.YDBCursor method)

NotSupportedError

O

ONLINE_READONLY (airflow.providers.ydb.hooks._vendor.dbapi.connection.IsolationLevel attribute)

ONLINE_READONLY_INCONSISTENT (airflow.providers.ydb.hooks._vendor.dbapi.connection.IsolationLevel attribute) OperationalError

P

parameters_types (airflow.providers.ydb.hooks._vendor.dbapi.cursor.YdbQuery attribute)

ProgrammingError

R

rollback() (airflow.providers.ydb.hooks._vendor.dbapi.connection.Connection method) (airflow.providers.ydb.hooks.ydb.YDBConnection method)

rowcount (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor property) (airflow.providers.ydb.hooks.ydb.YDBCursor property)

S

SERIALIZABLE (airflow.providers.ydb.hooks._vendor.dbapi.connection.IsolationLevel attribute) set_isolation_level() (airflow.providers.ydb.hooks._vendor.dbapi.connection.Connection method) setinputsizes() (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) (airflow.providers.ydb.hooks.ydb.YDBCursor method) setoutputsize() (airflow.providers.ydb.hooks._vendor.dbapi.cursor.Cursor method) (airflow.providers.ydb.hooks.ydb.YDBCursor method)

SNAPSHOT_READONLY (airflow.providers.ydb.hooks._vendor.dbapi.connection.IsolationLevel attribute) sqlalchemy_url (airflow.providers.ydb.hooks.ydb.YDBHook property) STALE_READONLY (airflow.providers.ydb.hooks._vendor.dbapi.connection.IsolationLevel attribute) supports_autocommit (airflow.providers.ydb.hooks.ydb.YDBHook attribute) supports_executemany (airflow.providers.ydb.hooks.ydb.YDBHook attribute)

T

test_run (in module tests.system.providers.ydb.example_ydb) tests.system.providers.ydb module

tests.system.providers.ydb.example_ydb module

U

ui_color (airflow.providers.ydb.operators.ydb.YDBExecuteQueryOperator attribute)

W

Warning

Y

YDB_KEYWORDS (in module airflow.providers.ydb.hooks._vendor.dbapi.constants) YDBConnection (class in airflow.providers.ydb.hooks.ydb) YDBCursor (class in airflow.providers.ydb.hooks.ydb) YdbDBApi (class in airflow.providers.ydb.hooks._vendor.dbapi)

YDBExecuteQueryOperator (class in airflow.providers.ydb.operators.ydb) YDBHook (class in airflow.providers.ydb.hooks.ydb) YdbQuery (class in airflow.providers.ydb.hooks._vendor.dbapi.cursor) yql_text (airflow.providers.ydb.hooks._vendor.dbapi.cursor.YdbQuery attribute)

PreviousNext

Was this entry helpful?