You need to enable JavaScript to run this app.
导航
Values
最近更新时间:2024.10.23 20:28:33首次发布时间:2024.10.23 20:28:33

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 连接器配置项

Option

Required

Default

Type

Description

type

required

(none)

String

指定要使用的连接器, 这里需要设置成 'values'。

name

optional

(none)

String

Sink 的名称。