【文件属性】：
文件名称：flink 流式表自定义StreamTableSource、RetractStreamSink，并使用flink kafkaDataStream.pdf
文件大小：348KB
文件格式：PDF
更新时间：2023-06-04 13:03:59
flink TableSource RetractStreamSin kafkStream
本文件是自己根据flink1.8官网文档https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/table/streaming/time_attributes.html#using-a-tablesource里实现的自定义StreamTableSource，并且输入流也用的是kafkaStream(更贴近实际应用)，由于官网的文档过于简单，并且有漏洞，你如果按照官网文档编写是会运行不成功的。附件文档的代码是亲测完全可以运行的，里面也自己实现了RetractStreamSink，可以供大家参考。