jobs

Name

jobs

description

表函数，生成任务临时表，可以查看某个任务类型中的job信息。

该函数用于 from 子句中。

该函数自 2.1.0 版本支持。

syntax

jobs("type"="")

参数说明

参数名说明类型是否必填
type作业类型string是

type 支持的类型：

  • insert：insert into 类型的任务。
  • mv：物化视图类型的任务。
Insert 任务

jobs(“type”=”insert”)表结构：

  1. mysql> desc  function jobs("type"="insert");
  2. +-------------------+------+------+-------+---------+-------+
  3. | Field             | Type | Null | Key   | Default | Extra |
  4. +-------------------+------+------+-------+---------+-------+
  5. | Id                | TEXT | No   | false | NULL    | NONE  |
  6. | Name              | TEXT | No   | false | NULL    | NONE  |
  7. | Definer           | TEXT | No   | false | NULL    | NONE  |
  8. | ExecuteType       | TEXT | No   | false | NULL    | NONE  |
  9. | RecurringStrategy | TEXT | No   | false | NULL    | NONE  |
  10. | Status            | TEXT | No   | false | NULL    | NONE  |
  11. | ExecuteSql        | TEXT | No   | false | NULL    | NONE  |
  12. | CreateTime        | TEXT | No   | false | NULL    | NONE  |
  13. | SucceedTaskCount  | TEXT | No   | false | NULL    | NONE  |
  14. | FailedTaskCount   | TEXT | No   | false | NULL    | NONE  |
  15. | CanceledTaskCount | TEXT | No   | false | NULL    | NONE  |
  16. | Comment           | TEXT | No   | false | NULL    | NONE  |
  17. +-------------------+------+------+-------+---------+-------+
  18. 12 rows in set (0.01 sec)
  • Id：job id.
  • Name：job名称.
  • Definer：job定义者.
  • ExecuteType：执行类型
  • RecurringStrategy：循环策略
  • Status：job状态
  • ExecuteSql：执行SQL
  • CreateTime：job 创建时间
  • SucceedTaskCount：成功任务数量
  • FailedTaskCount：失败任务数量
  • CanceledTaskCount：取消任务数量
  • Comment：job 注释
物化视图任务

jobs(“type”=”mv”)表结构：

  1. mysql> desc function jobs("type"="mv");
  2. +-------------------+------+------+-------+---------+-------+
  3. | Field             | Type | Null | Key   | Default | Extra |
  4. +-------------------+------+------+-------+---------+-------+
  5. | Id                | TEXT | No   | false | NULL    | NONE  |
  6. | Name              | TEXT | No   | false | NULL    | NONE  |
  7. | MvId              | TEXT | No   | false | NULL    | NONE  |
  8. | MvName            | TEXT | No   | false | NULL    | NONE  |
  9. | MvDatabaseId      | TEXT | No   | false | NULL    | NONE  |
  10. | MvDatabaseName    | TEXT | No   | false | NULL    | NONE  |
  11. | ExecuteType       | TEXT | No   | false | NULL    | NONE  |
  12. | RecurringStrategy | TEXT | No   | false | NULL    | NONE  |
  13. | Status            | TEXT | No   | false | NULL    | NONE  |
  14. | CreateTime        | TEXT | No   | false | NULL    | NONE  |
  15. +-------------------+------+------+-------+---------+-------+
  16. 10 rows in set (0.00 sec)
  • Id：job id.
  • Name：job名称.
  • MvId：物化视图id
  • MvName：物化视图名称
  • MvDatabaseId：物化视图所属db id
  • MvDatabaseName：物化视图所属db名称
  • ExecuteType：执行类型
  • RecurringStrategy：循环策略
  • Status：job状态
  • CreateTime：task创建时间

example

  1. 查看所有物化视图的job
  1. mysql> select * from jobs("type"="mv");
  1. 查看 name 为inner_mtmv_75043的 job
  1. mysql> select * from jobs("type"="mv") where Name="inner_mtmv_75043";
  1. 查看所有 insert 任务
  1. mysql> select * from jobs("type"="insert");
  1. 查看 name 为one_insert_job的 job
  1. mysql> select * from jobs("type"="insert") where Name='one_insert_job';

keywords

  1. jobs, job, insert, mv, materialized view, schedule