| :py:mod:`airflow.providers.apache.kylin.hooks.kylin` |
| ==================================================== |
| |
| .. py:module:: airflow.providers.apache.kylin.hooks.kylin |
| |
| |
| Module Contents |
| --------------- |
| |
| Classes |
| ~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.apache.kylin.hooks.kylin.KylinHook |
| |
| |
| |
| |
| .. py:class:: KylinHook(kylin_conn_id = 'kylin_default', project = None, dsn = None) |
| |
| Bases: :py:obj:`airflow.hooks.base.BaseHook` |
| |
| Interact with Kylin to run CubeSource commands and get job status. |
| |
| :param kylin_conn_id: The connection id as configured in Airflow administration. |
| :param project: project name |
| :param dsn: dsn |
| |
| .. py:method:: get_conn(self) |
| |
| Returns connection for the hook. |
| |
| |
| .. py:method:: cube_run(self, datasource_name, op, **op_args) |
| |
| Run CubeSource command which in CubeSource.support_invoke_command |
| |
| :param datasource_name: |
| :param op: command |
| :param op_args: command args |
| :return: response |
| |
| |
| .. py:method:: get_job_status(self, job_id) |
| |
| Get job status |
| |
| :param job_id: kylin job id |
| :return: job status |
| |
| |
| |
