my-flink-project：跟着吴翀大神学flink，自己的小测试
需积分: 9 160 浏览量
2021-02-13
17:25:34
上传
评论
收藏 5.66MB ZIP 举报
my-flink-project-master.zip （45个子文件） 
my-flink-project-master 
pom.xml 8KB
beforemerge.txt 10KB beforemove.txt 10KB beforesplit.txt 10KB aftersplit.txt 10KB src main resources log4j.properties 1KB RandomInteger.txt 107KB test.xml 2KB abc.csv 17B UserBehavior.csv 16.99MB java test custom partition MyPartition.java 447B DataStreamMain.java 1KB RandomIntegerStreamSource.java 631B DataSetMain.java 2KB KafkaDeserializationDemo.java 5KB keyby KeyByWithParallel.java 1KB Test1.java 4KB stream ConnectStream.java 3KB myflink HotItems.java 9KB sink RRBFClusterSink.java 48B wordcount WordCount.java 4KB util WordCountData.java 3KB WordCountPojo.java 4KB dataset Broadcast.java 2KB Sink.java 2KB Source.java 1KB datastream SessionWindowing.java 4KB Source.java 525B moa MicroCluster.java 2KB CluStreamRun.java 3KB WindowCluStream.java 7KB MacroCluster.java 1KB kafka schema RRBFDeserializtionSchema.java 2KB RRBFSerializer.java 1KB RRBFEvaluateResultSerializtionSchema.java 947B RRBFDeserializer.java 1KB KafkaProperty.java 1KB util GetFromKafka.java 2KB SendToKafka.java 892B entity RRBFEvaluateResult.java 552B source RRBFSource.java 1KB .gitignore 735B aftermove.txt 10KB aftermerge.txt 10KB README.md 400B资源评论
