更新时间:2023-03-17 GMT+08:00

使用Flink WebUI的流表管理

操作场景

通过数据表,定义源表、维表、输出表的基本属性和字段信息。

新建流表

  1. 访问Flink WebUI,请参考访问Flink WebUI
  2. 单击“流表管理”进入流表管理页面。
  3. 单击“新建流表”,在新建流表页面参考表1填写信息,单击“确定”,完成流表创建。

    表1 新建流表信息

    参数名称

    参数描述

    备注

    流/表名称

    流/表的名称,只能包含英文字母、数字和下划线,且长度为1~64个字符。

    例如:flink_sink

    描述

    流/表的描述信息,且长度为1~1024个字符。

    -

    映射表类型

    Flink SQL本身不带有数据存储功能,所有涉及表创建的操作,实际上均是对于外部数据表、存储的引用映射。

    类型包含Kafka、HDFS、Redis。

    -

    类型

    包含数据源表Source,数据结果表Sink,数据维表Table。不同映射表类型包含的表如下所示。

    • Kafka:Source、Sink
    • HDFS:Source、Sink
    • Redis:Sink、Table

    -

    数据连接

    选择数据连接。

    -

    Topic

    读取的Kafka的topic,支持从多个Kakfa topic中读取,topic之间使用英文分隔符进行分隔。

    “映射表类型”选择“Kafka”时存在此参数。

    -

    文件路径

    要传输的HDFS目录或单个文件路径。

    “映射表类型”选择“HDFS”时存在此参数。

    例如:

    “/user/sqoop/ ”或“/user/sqoop/example.csv”

    编码

    选择不同“映射表类型”对应的编码如下:

    • Kafka:CSV、JSON
    • HDFS:CSV
    • Redis:
      • “类型”为“Sink”时:String、List、Set、Zset、Hash
      • “类型”为“Table”时:String、Zset

    -

    前缀

    “映射表类型”选择“Kafka”,且“类型”选择“Source”,“编码”选择“JSON”时含义为:多层嵌套json的层级前缀,使用英文逗号(,)进行分隔。

    例如:data,info表示取嵌套json中data,info下的内容,作为json格式数据输入

    “映射表类型”选择“Redis”时含义为:操作数据时会自动在key上补充前缀或手动输入。

    例如:key的值是key1,前缀是test,则最终写入redis的key是test:key1

    分隔符

    选择不同“映射表类型”对应的含义如下:

    • Kafka:用于指定CSV字段分隔符。当数据“编码”为“CSV”时存在此参数。
    • Redis:字段分隔符。

    例如:“,”

    行分隔符

    文件中的换行符,包含“\r”、“\n”、“\r\n”。

    “映射表类型”选择“HDFS”时存在此参数。

    -

    列分隔符

    文件中的字段分隔符。

    “映射表类型”选择“HDFS”时存在此参数。

    例如:“,”

    数据有效期

    数据的有效期。分为“永久有效”、“有效时长”和“截止日期”三类。

    “映射表类型”选择“Redis”,“类型”选择“Sink”时存在此参数。

    -

    流/表结构

    填写流/表结构,包含名称,类型。

    -

    Proctime

    指系统时间,与数据本身的时间戳无关,即在Flink算子内计算完成的时间。

    “类型”选择“Source”时存在此参数。

    -

    Event Time

    指事件产生的时间,即数据产生时自带时间戳。

    “类型”选择“Source”时存在此参数。

    -

编辑流表

  1. 访问Flink WebUI,请参考访问Flink WebUI
  2. 单击“流表管理”进入流表管理页面。
  3. 在待修改项的“操作”列单击“编辑”,在弹出的页面中参考表1修改流表信息,单击“确定”完成修改。

搜索流表

  1. 访问Flink WebUI,请参考访问Flink WebUI
  2. 单击“流表管理”进入流表管理页面。
  3. 在页面右上角,用户可以输入关键字搜索查看流表信息。

删除流表

  1. 访问Flink WebUI,请参考访问Flink WebUI
  2. 单击“流表管理”进入流表管理页面。
  3. 在待删除项的“操作”列单击“删除”,在弹出的页面单击“确定”完成删除。