airflow.providers.apache.iceberg.hooks.iceberg¶

Attributes¶

This hook acts as a base hook for iceberg services.

airflow.providers.apache.iceberg.hooks.iceberg.TOKENS_ENDPOINT = 'oauth/tokens'[source]¶

class airflow.providers.apache.iceberg.hooks.iceberg.IcebergHook(iceberg_conn_id=default_conn_name)[source]¶

This hook acts as a base hook for iceberg services.

It offers the ability to generate temporary, short-lived session tokens to use within Airflow submitted jobs.

Parameters:: iceberg_conn_id (str) – The Iceberg connection id which refers to the information to connect to the Iceberg.

classmethod get_ui_field_behaviour()[source]¶

Return custom UI field behaviour for Iceberg connection.

test_connection()[source]¶

Test the Iceberg connection.

Obtain a short-lived access token via a client_id and client_secret.