tbds flink支持的数据源和它们的用途如下表所示
用途 | 类型 | 支持的输入和输出 | 支持的数据格式 | demo链接 | 说明 |
---|---|---|---|---|---|
TableSource/Sink | console | 可撤回输出 | - | ||
oracle | 维表输入,可撤回输出 | - | |||
hippo | 流输入,只追加输出 | 默认 | |||
tpg | 维表输入,可撤回输出 | - | |||
tsdb | 只追加输出 | - | 已经不维护,请勿使用 | ||
redis | 维表输入,可撤回输出 | - | |||
hdfsSource | 流输入 | 默认 | 监听hdfs目录,读取hdfs目录新增的文件内容 | ||
tube | 流输入,只追加输出 | 默认、kv、protobuf | |||
elasticsearch | 只追加输出 | json | |||
tde | 维表输入,可撤回输出 | - | |||
clickhouse | 只追加输出 | - | 仅1.14版本支持 | ||
kafka | 流输入,只追加输出 | ||||
iceberg | 可撤回输出 | 仅1.14版本支持 | |||
hdfs | 只追加输出 | ||||
mysql | 维表输入,可撤回输出 | ||||
hbase | 维表输入,可撤回输出 | ||||
pulsar | 流输入,只追加输出 | ||||
StreamSource | tube | 流输入,只追加输出 | |||
hippo | 流输入,只追加输出 | ||||
API Source/Sink | httpSink | 可撤回输出 | |||
jarSource | 流输入 | ||||
jarSink | 可撤回输出 | ||||
View |
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。