• 1.定义SourceTransformation的主要作用是将一个数据源转换为DataStream,以便对数据源进行各种处理操作,例如map、filter、join等。在Flink中,数据源可以是各种不同的数据源,例如Kafka、Socke
    admin9小时前
    10