© 1999-2048 dssz.net 粤ICP备11031372号
[flink] flink 流式表自定义StreamTableSource、RetractStreamSink,并使用flink kafkaDataStream.pdf
说明:本文件是自己根据flink1.8官网文档https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/table/streaming/time_attributes.html#using-a-tablesource里实现的自定义StreamTableSource,并且输入流也用的是kafkaStream(更贴近实际应用),由于官网的文档过于简单,并且有漏洞,你如果按照官网文档编写是会运行不成功的。附件文档的代码是亲测完全可以运行的<bestchenwu123> 上传 | 大小:348kb