小镜子之flinkLearning.7z

[{"title":"（ 95 个子文件 180KB ） 小镜子之flinkLearning.7z","children":[{"title":"flink-learning","children":[{"title":"flink-day03","children":[{"title":"src","children":[{"title":"test","children":[{"title":"resources","children":null,"spread":false},{"title":"java","children":[{"title":"cn","children":[{"title":"itcast","children":[{"title":"flink","children":[{"title":"test","children":[{"title":"Day03AppTest.java <span style='color:#111;'> 169B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 944B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"cn","children":[{"title":"itcast","children":[{"title":"flink","children":[{"title":"source","children":[{"title":"basic","children":[{"title":"StreamSourceCollectionDemo.java <span style='color:#111;'> 1.11KB </span>","children":null,"spread":false},{"title":"StreamSourceFileDemo.java <span style='color:#111;'> 737B </span>","children":null,"spread":false},{"title":"StreamSourceSocketDemo.java <span style='color:#111;'> 2.64KB </span>","children":null,"spread":false}],"spread":true},{"title":"kafka","children":[{"title":"StreamSourceKafkaOffsetDemo.java <span style='color:#111;'> 2.59KB </span>","children":null,"spread":false},{"title":"StreamSourceKafkaDemo.java <span style='color:#111;'> 1.37KB </span>","children":null,"spread":false}],"spread":true},{"title":"customer","children":[{"title":"StreamSourceOrderDemo.java <span style='color:#111;'> 2.29KB </span>","children":null,"spread":false}],"spread":true},{"title":"mysql","children":[{"title":"StreamSourceMySQLDemo.java <span style='color:#111;'> 3.13KB </span>","children":null,"spread":false}],"spread":false}],"spread":true},{"title":"sink","children":[{"title":"kafka","children":[{"title":"StreamSinkKafkaDemo.java <span style='color:#111;'> 3.95KB </span>","children":null,"spread":false}],"spread":true},{"title":"redis","children":[{"title":"StreamSinkRedisDemo.java <span style='color:#111;'> 3.88KB </span>","children":null,"spread":false}],"spread":true},{"title":"customer","children":[{"title":"StreamSinkMySQLDemo.java <span style='color:#111;'> 2.93KB </span>","children":null,"spread":false}],"spread":false},{"title":"mysql","children":[{"title":"StreamSinkJdbcDemo.java <span style='color:#111;'> 2.16KB </span>","children":null,"spread":false}],"spread":false},{"title":"StreamSinkFileDemo.java <span style='color:#111;'> 2.17KB </span>","children":null,"spread":false}],"spread":true},{"title":"transformation","children":[{"title":"StreamRepartitionDemo.java <span style='color:#111;'> 2.48KB </span>","children":null,"spread":false},{"title":"StreamUnionConnectDemo.java <span style='color:#111;'> 2.08KB </span>","children":null,"spread":false},{"title":"StreamSplitSelectDemo.java <span style='color:#111;'> 2.81KB </span>","children":null,"spread":false}],"spread":true},{"title":"start","children":[{"title":"FlinkWordCount.scala <span style='color:#111;'> 1.27KB </span>","children":null,"spread":false},{"title":"StreamWordCount.java <span style='color:#111;'> 2.11KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 7.80KB </span>","children":null,"spread":false}],"spread":true},{"title":"flink-learning.iml <span style='color:#111;'> 81B </span>","children":null,"spread":false},{"title":".idea","children":[{"title":"misc.xml <span style='color:#111;'> 530B </span>","children":null,"spread":false},{"title":"compiler.xml <span style='color:#111;'> 622B </span>","children":null,"spread":false},{"title":"dataSources.local.xml <span style='color:#111;'> 984B </span>","children":null,"spread":false},{"title":"uiDesigner.xml <span style='color:#111;'> 8.71KB </span>","children":null,"spread":false},{"title":"workspace.xml <span style='color:#111;'> 9.47KB </span>","children":null,"spread":false},{"title":"dataSources.xml <span style='color:#111;'> 907B </span>","children":null,"spread":false},{"title":"$PRODUCT_WORKSPACE_FILE$ <span style='color:#111;'> 1.40KB </span>","children":null,"spread":false},{"title":"encodings.xml <span style='color:#111;'> 404B </span>","children":null,"spread":false},{"title":"codeStyles","children":[{"title":"Project.xml <span style='color:#111;'> 860B </span>","children":null,"spread":false},{"title":"codeStyleConfig.xml <span style='color:#111;'> 153B </span>","children":null,"spread":false}],"spread":true},{"title":"scala_compiler.xml <span style='color:#111;'> 192B </span>","children":null,"spread":false},{"title":"dataSources","children":[{"title":"0202f656-d6e0-4da8-9638-f927136b3b34.xml <span style='color:#111;'> 832.85KB </span>","children":null,"spread":false},{"title":"0202f656-d6e0-4da8-9638-f927136b3b34","children":[{"title":"storage_v2","children":[{"title":"_src_","children":[{"title":"schema","children":[{"title":"db_flink.X6YEfA.meta <span style='color:#111;'> 66B </span>","children":null,"spread":false},{"title":"sys.zb4BAA.meta <span style='color:#111;'> 6B </span>","children":null,"spread":false},{"title":"sys.zb4BAA.zip <span style='color:#111;'> 447.01KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":"flink-day02","children":[{"title":"src","children":[{"title":"test","children":[{"title":"resources","children":null,"spread":false},{"title":"java","children":[{"title":"cn","children":[{"title":"itcast","children":[{"title":"flink","children":[{"title":"test","children":[{"title":"Day02AppTest.java <span style='color:#111;'> 173B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 944B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"cn","children":[{"title":"itcast","children":[{"title":"flink","children":[{"title":"source","children":[{"title":"BatchSourceCollectionDemo.java <span style='color:#111;'> 1.12KB </span>","children":null,"spread":false},{"title":"BatchSourceFileDemo.java <span style='color:#111;'> 1.93KB </span>","children":null,"spread":false}],"spread":true},{"title":"sink","children":[{"title":"BatchSinkFileDemo.java <span style='color:#111;'> 2.25KB </span>","children":null,"spread":false}],"spread":true},{"title":"transformation","children":[{"title":"ClickLog.java <span style='color:#111;'> 613B </span>","children":null,"spread":false},{"title":"BatchBasicDemo.java <span style='color:#111;'> 6.85KB </span>","children":null,"spread":false},{"title":"BatchJoinDemo.java <span style='color:#111;'> 4.26KB </span>","children":null,"spread":false},{"title":"BatchRepartitionDemo.java <span style='color:#111;'> 4.82KB </span>","children":null,"spread":false}],"spread":false},{"title":"other","children":[{"title":"BatchBroadcastDemo.java <span style='color:#111;'> 2.55KB </span>","children":null,"spread":false},{"title":"BatchParameterPassDemo.java <span style='color:#111;'> 2.65KB </span>","children":null,"spread":false},{"title":"BatchDistributedCacheDemo.java <span style='color:#111;'> 2.45KB </span>","children":null,"spread":false},{"title":"BatchAccumulatorDemo.java <span style='color:#111;'> 1.90KB </span>","children":null,"spread":false}],"spread":false},{"title":"start","children":[{"title":"FlinkWordCount.scala <span style='color:#111;'> 1.02KB </span>","children":null,"spread":false},{"title":"BatchWordCount.java <span style='color:#111;'> 2.29KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"flink-day02.iml <span style='color:#111;'> 81B </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 7.61KB </span>","children":null,"spread":false}],"spread":true},{"title":"datas","children":[{"title":"subject.csv <span style='color:#111;'> 58B </span>","children":null,"spread":false},{"title":"u.data <span style='color:#111;'> 195B </span>","children":null,"spread":false},{"title":"wordcount.data <span style='color:#111;'> 94B </span>","children":null,"spread":false},{"title":"stream-wc.txt <span style='color:#111;'> 76.24KB </span>","children":null,"spread":false},{"title":"input","children":[{"title":"click1.log <span style='color:#111;'> 18.51KB </span>","children":null,"spread":false},{"title":"click2.log <span style='color:#111;'> 7.65KB </span>","children":null,"spread":false}],"spread":true},{"title":"distribute_cache_student <span style='color:#111;'> 28B </span>","children":null,"spread":false},{"title":"wordcount.input <span style='color:#111;'> 207B </span>","children":null,"spread":false},{"title":"click.log <span style='color:#111;'> 23.14KB </span>","children":null,"spread":false},{"title":"score.csv <span style='color:#111;'> 475B </span>","children":null,"spread":false},{"title":"subDatas","children":[{"title":"1sub","children":[{"title":"2.txt <span style='color:#111;'> 30B </span>","children":null,"spread":false}],"spread":false},{"title":"1.txt <span style='color:#111;'> 60B </span>","children":null,"spread":false}],"spread":false},{"title":"students <span style='color:#111;'> 28B </span>","children":null,"spread":false}],"spread":false},{"title":"flink-day01","children":[{"title":"dependency-reduced-pom.xml <span style='color:#111;'> 2.82KB </span>","children":null,"spread":false},{"title":"flink-day01.iml <span style='color:#111;'> 81B </span>","children":null,"spread":false},{"title":"src","children":[{"title":"test","children":[{"title":"resources","children":null,"spread":false},{"title":"java","children":[{"title":"cn","children":[{"title":"itcast","children":[{"title":"flink","children":[{"title":"test","children":[{"title":"Day01AppTest.java <span style='color:#111;'> 177B </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"main","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 944B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"cn","children":[{"title":"itcast","children":[{"title":"flink","children":[{"title":"batch","children":[{"title":"FlinkBatchWordCount.java <span style='color:#111;'> 2.81KB </span>","children":null,"spread":false}],"spread":false},{"title":"stream","children":[{"title":"LambdaStreamWordCount.java <span style='color:#111;'> 2.10KB </span>","children":null,"spread":false},{"title":"FlinkStreamWordCount.java <span style='color:#111;'> 1.99KB </span>","children":null,"spread":false}],"spread":false},{"title":"submit","children":[{"title":"StreamWordCount.java <span style='color:#111;'> 2.58KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 5.85KB </span>","children":null,"spread":false}],"spread":true},{"title":"pom.xml <span style='color:#111;'> 597B </span>","children":null,"spread":false}],"spread":true},{"title":"参考代码","children":[{"title":"flink","children":[{"title":"source","children":[{"title":"basic","children":[{"title":"StreamSourceCollectionDemo.java <span style='color:#111;'> 1.05KB </span>","children":null,"spread":false},{"title":"StreamSourceFileDemo.java <span style='color:#111;'> 728B </span>","children":null,"spread":false},{"title":"StreamSourceSocketDemo.java <span style='color:#111;'> 2.42KB </span>","children":null,"spread":false}],"spread":true},{"title":"kafka","children":[{"title":"StreamSourceKafkaOffsetDemo.java <span style='color:#111;'> 2.46KB </span>","children":null,"spread":false},{"title":"StreamSourceKafkaDemo.java <span style='color:#111;'> 1.38KB </span>","children":null,"spread":false}],"spread":true},{"title":"customer","children":[{"title":"StreamSourceOrderDemo.java <span style='color:#111;'> 2.33KB </span>","children":null,"spread":false}],"spread":true},{"title":"mysql","children":[{"title":"StreamSourceMySQLDemo.java <span style='color:#111;'> 3.01KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"sink","children":[{"title":"kafka","children":[{"title":"StreamSinkKafkaDemo.java <span style='color:#111;'> 3.17KB </span>","children":null,"spread":false}],"spread":true},{"title":"redis","children":[{"title":"StreamSinkRedisDemo.java <span style='color:#111;'> 3.56KB </span>","children":null,"spread":false}],"spread":true},{"title":"mysql","children":[{"title":"StreamSinkJdbcDemo.java <span style='color:#111;'> 2.04KB </span>","children":null,"spread":false},{"title":"StreamSinkMySQLDemo.java <span style='color:#111;'> 2.88KB </span>","children":null,"spread":false}],"spread":true},{"title":"StreamSinkFileDemo.java <span style='color:#111;'> 2.30KB </span>","children":null,"spread":false}],"spread":true},{"title":"transformation","children":[{"title":"StreamRepartitionDemo.java <span style='color:#111;'> 2.48KB </span>","children":null,"spread":false},{"title":"StreamUnionConnectDemo.java <span style='color:#111;'> 1.85KB </span>","children":null,"spread":false},{"title":"StreamSplitSelectDemo.java <span style='color:#111;'> 2.53KB </span>","children":null,"spread":false}],"spread":true},{"title":"start","children":[{"title":"FlinkWordCount.scala <span style='color:#111;'> 1.28KB </span>","children":null,"spread":false},{"title":"StreamWordCount.java <span style='color:#111;'> 2.19KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"log4j.properties <span style='color:#111;'> 944B </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 7.60KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}]