可以快速搭建一个Flink编写程序 mvn archetype:generate \ -DarchetypeGroupId=org.apache.flink \ -DarchetypeArtifactId=flink-quickstart-java \ -DarchetypeVersion=1.17.1 \ -DgroupId=com.zxx.langhuan \ -DartifactId=langhuan-flink \ -Dversion=1.0.0-SNAPSHOT \ -Dpackage=com.zxx.langhuan.flink \ -DinteractiveMode=false Flink 的 Java DataStream API 可以将任何可序列化的对象转化为流。Flink 自带的序列化器有 基本类型,即 String、Long、Integer、Boolean、Array 复合类型:Tuples、POJOs 和 Scala case classes Flink 的原生序列化器可以高效地操作 tuples 和 POJOs。 对于 Java,Flink 自带有...