TransformPipeline
2021-04-13 14:53:18 0 举报模拟flink的TransformPipeline
作者其他创作
大纲/内容
addSinkMapper
FileSourceFunction
输入接口：实现相关接口，完成数据输入一条pipline，只有一条输入
source to sink
SinkFunctions
SingStringSourceFunction
TransfromPipeline
addSourceMapper
PrintlnSinkFunction
输入转换器，将输入SQL（可以根据SourceFunction自定义类型，和遍历规则）转换
...
map
将上一步的输入，转换成输出，交给SinkFunction
SinkMapper
SourceMapper
map to sink
SqlStatement
输出接口：将数传的数据，输出。一条pipline可以有多个输出端
no mapper
ListSinkFunction
SourceFunction
领域模型，包括转换配置，以及转换日志
0 条评论
下一页
为你推荐
查看更多
抱歉，暂无相关内容