Flink自定义TableSink TableSource
基本知识 TableSource提供了从外部系统（消息队列，KV存储，数据库，文件系统等）接入数据，以后注册到TableEnvironment中，而后能够经过Table API或者SQL进行查询。java TableSink提供了将flink内部注册的Table中的数据写出到外部系统（Es ,Hbase ,消息队列数据库，文件系统等）。web TableFactory用来建立TableSource
相关文章
- 1. flink自定义 sink
- 2. Flink 自定义trigger
- 3. flink自定义source与自定义sink
- 4. flink实战--自定义source
- 5. Flink自定义窗口
- 6. Flink自定义窗口Trigger
- 7. Flink 自定义触发器
- 8. 聊聊flink Table Schema的定义
- 9. flink自定义窗口函数
- 10. Flink 自定义Sink 之 写入HDFS
- 更多相关文章...
- • 自定义TypeHandler - MyBatis教程
- • MySQL自定义函数（CREATE FUNCTION） - MySQL教程
- • RxJava操作符（十）自定义操作符
- • Flink 数据传输及反压详解
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
欢迎关注本站公众号,获取更多信息
相关文章