Flink+Kafka的JavaAPI应用

[{"title":"（ 39 个子文件 37KB ） Flink+Kafka的JavaAPI应用","children":[{"title":"FlinkKafkaDemo","children":[{"title":"pom.xml <span style='color:#111;'> 4.55KB </span>","children":null,"spread":false},{"title":"target","children":[{"title":"generated-sources","children":[{"title":"annotations","children":null,"spread":false}],"spread":true},{"title":"classes","children":[{"title":"log4j.properties <span style='color:#111;'> 290B </span>","children":null,"spread":false},{"title":"META-INF","children":[{"title":"FlinkKafkaDemo.kotlin_module <span style='color:#111;'> 16B </span>","children":null,"spread":false}],"spread":true},{"title":"hbase","children":[{"title":"DefinedSource$1.class <span style='color:#111;'> 1.84KB </span>","children":null,"spread":false},{"title":"HBaseDemo.class <span style='color:#111;'> 3.83KB </span>","children":null,"spread":false},{"title":"DefinedSink.class <span style='color:#111;'> 1.58KB </span>","children":null,"spread":false},{"title":"DefinedSink$1.class <span style='color:#111;'> 1.31KB </span>","children":null,"spread":false},{"title":"HBaseSink.class <span style='color:#111;'> 1.52KB </span>","children":null,"spread":false},{"title":"DefinedSource.class <span style='color:#111;'> 1.35KB </span>","children":null,"spread":false}],"spread":true},{"title":"cases","children":[{"title":"SinkToHBase$1.class <span style='color:#111;'> 1.94KB </span>","children":null,"spread":false},{"title":"SinkToHBase$2.class <span style='color:#111;'> 2.29KB </span>","children":null,"spread":false},{"title":"SinkToHBase.class <span style='color:#111;'> 2.93KB </span>","children":null,"spread":false},{"title":"SourceToKafka.class <span style='color:#111;'> 1.76KB </span>","children":null,"spread":false}],"spread":true},{"title":"kafka","children":[{"title":"KafkaSink.class <span style='color:#111;'> 2.04KB </span>","children":null,"spread":false},{"title":"KafkaWordCount.class <span style='color:#111;'> 2.89KB </span>","children":null,"spread":false},{"title":"KafkaWordCount$1.class <span style='color:#111;'> 1.91KB </span>","children":null,"spread":false},{"title":"KafkaWordCount$2.class <span style='color:#111;'> 1.86KB </span>","children":null,"spread":false},{"title":"KafkaSource.class <span style='color:#111;'> 2.15KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"src","children":[{"title":"test","children":[{"title":"java","children":null,"spread":false}],"spread":true},{"title":"main","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 290B </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"dataset","children":[{"title":"names.txt <span style='color:#111;'> 62B </span>","children":null,"spread":false}],"spread":true},{"title":"hbase","children":[{"title":"RandomSource.java <span style='color:#111;'> 356B </span>","children":null,"spread":false},{"title":"DefinedSource.java <span style='color:#111;'> 1.32KB </span>","children":null,"spread":false},{"title":"HBaseSink.java <span style='color:#111;'> 769B </span>","children":null,"spread":false},{"title":"DefinedSink.java <span style='color:#111;'> 1.12KB </span>","children":null,"spread":false},{"title":"HBaseDemo.java <span style='color:#111;'> 3.23KB </span>","children":null,"spread":false}],"spread":true},{"title":"cases","children":[{"title":"DefineSourceToKafka.java <span style='color:#111;'> 2.11KB </span>","children":null,"spread":false},{"title":"SourceToKafka.java <span style='color:#111;'> 911B </span>","children":null,"spread":false},{"title":"SinkToHBase.java <span style='color:#111;'> 3.06KB </span>","children":null,"spread":false}],"spread":true},{"title":"kafka","children":[{"title":"KafkaWordCount.java <span style='color:#111;'> 3.14KB </span>","children":null,"spread":false},{"title":"KafkaSink.java <span style='color:#111;'> 1.15KB </span>","children":null,"spread":false},{"title":"KafkaSource.java <span style='color:#111;'> 1.42KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":".idea","children":[{"title":"uiDesigner.xml <span style='color:#111;'> 8.71KB </span>","children":null,"spread":false},{"title":"$PRODUCT_WORKSPACE_FILE$ <span style='color:#111;'> 1.44KB </span>","children":null,"spread":false},{"title":"workspace.xml <span style='color:#111;'> 7.22KB </span>","children":null,"spread":false},{"title":"encodings.xml <span style='color:#111;'> 182B </span>","children":null,"spread":false},{"title":"misc.xml <span style='color:#111;'> 526B </span>","children":null,"spread":false},{"title":"compiler.xml <span style='color:#111;'> 547B </span>","children":null,"spread":false},{"title":"codeStyles","children":[{"title":"codeStyleConfig.xml <span style='color:#111;'> 153B </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"FlinkKafkaDemo.iml <span style='color:#111;'> 81B </span>","children":null,"spread":false}],"spread":true}],"spread":true}]