airflow.providers.apache.kylin.hooks.kylin

Classes

KylinHook

Interact with Kylin to run CubeSource commands and get job status.

Module Contents

class airflow.providers.apache.kylin.hooks.kylin.KylinHook(kylin_conn_id=default_conn_name, project=None, dsn=None)[source]

Bases: airflow.hooks.base.BaseHook

Interact with Kylin to run CubeSource commands and get job status.

Parameters:

  • kylin_conn_id (str) – The connection id as configured in Airflow administration.

  • project (str | None) – project name

  • dsn (str | None) – dsn

conn_name_attr = 'kylin_conn_id'[source]
default_conn_name = 'kylin_default'[source]
conn_type = 'kylin'[source]
hook_name = 'Apache Kylin'[source]
kylin_conn_id = 'kylin_default'[source]
project = None[source]
dsn = None[source]
get_conn()[source]

Return connection for the hook.

cube_run(datasource_name, op, **op_args)[source]

Run CubeSource command which in CubeSource.support_invoke_command.

Parameters:

  • datasource_name

  • op – command

  • op_args – command args

Returns:

response

get_job_status(job_id)[source]

Get job status.

Parameters:

job_id – kylin job id

Returns:

job status

Was this entry helpful?