airflow.providers.apache.kylin.hooks.kylin

Module Contents

Classes

KylinHook

Interact with Kylin to run CubeSource commands and get job status.
class airflow.providers.apache.kylin.hooks.kylin.KylinHook(kylin_conn_id='kylin_default', 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

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?