Values Pipeline 连接器可以用作 Pipeline 的 Data Sink，将数据写入到标准输出。 本文档介绍如何设置 Values Pipeline 连接器。

使用限制 #

• Values Pipeline 连接器暂时仅支持在 Flink 1.16-volcano 及以上引擎版本中使用。
• Values Pipeline 连接器仅在数据调试阶段使用，不建议在生产阶段使用。

连接器的功能 #

• 自动建表
• 表结构变更同步
• 数据实时同步

如何创建 Pipeline #

从 MySQL 读取数据同步到 Values 的 Pipeline 可以定义如下：

source:
  type: mysql
  name: MySQL Source
  hostname: 127.0.0.1
  port: 3306
  username: admin
  password: pass
  tables: adb.\., bdb.user_table_[0-9]+, [app|web].order_\.
  server-id: 5401-5404

sink:
  type: values
  name: Values Sink

pipeline:
  name: MySQL to Values Pipeline
  parallelism: 2

Pipeline 连接器配置项 #