Flink JavaAPI开发

[{"title":"（ 97 个子文件 41.65MB ） Flink JavaAPI开发","children":[{"title":"FlinkDemo","children":[{"title":"pom.xml <span style='color:#111;'> 3.77KB </span>","children":null,"spread":false},{"title":"out","children":[{"title":"artifacts","children":[{"title":"FlinkDemo_jar","children":[{"title":"FlinkDemo.jar <span style='color:#111;'> 46.90MB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"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":"FlinkDemo.kotlin_module <span style='color:#111;'> 16B </span>","children":null,"spread":false}],"spread":true},{"title":"streaming","children":[{"title":"StreamWordCountPOJO$1.class <span style='color:#111;'> 1.60KB </span>","children":null,"spread":false},{"title":"StreamSQLDemo.class <span style='color:#111;'> 2.97KB </span>","children":null,"spread":false},{"title":"StreamStateDemo.class <span style='color:#111;'> 3.73KB </span>","children":null,"spread":false},{"title":"watermark","children":[{"title":"StreamWatermarkDemo$3.class <span style='color:#111;'> 3.96KB </span>","children":null,"spread":false},{"title":"StreamWatermarkDemo$1.class <span style='color:#111;'> 1.84KB </span>","children":null,"spread":false},{"title":"StreamWatermarkDemo$2.class <span style='color:#111;'> 2.60KB </span>","children":null,"spread":false},{"title":"StreamWatermarkDemo.class <span style='color:#111;'> 3.72KB </span>","children":null,"spread":false}],"spread":true},{"title":"StreamTableDemo.class <span style='color:#111;'> 3.08KB </span>","children":null,"spread":false},{"title":"StreamTableToDataStream$1.class <span style='color:#111;'> 1.84KB </span>","children":null,"spread":false},{"title":"StreamWordCount$1.class <span style='color:#111;'> 1.87KB </span>","children":null,"spread":false},{"title":"window","children":[{"title":"StreamWindowReduce$2.class <span style='color:#111;'> 1.90KB </span>","children":null,"spread":false},{"title":"StreamCountWindowProcess$1.class <span style='color:#111;'> 3.87KB </span>","children":null,"spread":false},{"title":"StreamCountWindowProcess.class <span style='color:#111;'> 2.56KB </span>","children":null,"spread":false},{"title":"StreamTimeWindowProcess$2.class <span style='color:#111;'> 1.92KB </span>","children":null,"spread":false},{"title":"StreamWindowReduce$1.class <span style='color:#111;'> 1.77KB </span>","children":null,"spread":false},{"title":"StreamTimeWindowProcess.class <span style='color:#111;'> 2.56KB </span>","children":null,"spread":false},{"title":"StreamTimeWindowProcess$1.class <span style='color:#111;'> 3.87KB </span>","children":null,"spread":false},{"title":"StreamWindowReduce.class <span style='color:#111;'> 2.16KB </span>","children":null,"spread":false},{"title":"StreamCountWindowProcess$2.class <span style='color:#111;'> 1.93KB </span>","children":null,"spread":false}],"spread":false},{"title":"StreamTableToDataStream.class <span style='color:#111;'> 3.06KB </span>","children":null,"spread":false},{"title":"StreamWordCountPOJO.class <span style='color:#111;'> 2.05KB </span>","children":null,"spread":false},{"title":"StreamStateDemo$1.class <span style='color:#111;'> 1.58KB </span>","children":null,"spread":false},{"title":"StreamWordCount.class <span style='color:#111;'> 2.01KB </span>","children":null,"spread":false}],"spread":false},{"title":"model","children":[{"title":"demo.class <span style='color:#111;'> 955B </span>","children":null,"spread":false},{"title":"WordCount.class <span style='color:#111;'> 1.16KB </span>","children":null,"spread":false}],"spread":true},{"title":"batch","children":[{"title":"BatchBroadCast$1.class <span style='color:#111;'> 1.53KB </span>","children":null,"spread":false},{"title":"BatchDistributedCache.class <span style='color:#111;'> 1.53KB </span>","children":null,"spread":false},{"title":"BatchSQLDemo.class <span style='color:#111;'> 2.87KB </span>","children":null,"spread":false},{"title":"BatchBroadCast$2.class <span style='color:#111;'> 2.21KB </span>","children":null,"spread":false},{"title":"BatchWordCount$1.class <span style='color:#111;'> 2.01KB </span>","children":null,"spread":false},{"title":"BatchTableDemo.class <span style='color:#111;'> 2.95KB </span>","children":null,"spread":false},{"title":"BatchAccumulator$1.class <span style='color:#111;'> 2.36KB </span>","children":null,"spread":false},{"title":"BatchWordCount.class <span style='color:#111;'> 2.33KB </span>","children":null,"spread":false},{"title":"BatchAccumulator.class <span style='color:#111;'> 2.68KB </span>","children":null,"spread":false},{"title":"BatchBroadCast.class <span style='color:#111;'> 1.86KB </span>","children":null,"spread":false},{"title":"BatchDistributedCache$1.class <span style='color:#111;'> 2.38KB </span>","children":null,"spread":false}],"spread":false}],"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":"words.txt <span style='color:#111;'> 85B </span>","children":null,"spread":false},{"title":"username <span style='color:#111;'> 22B </span>","children":null,"spread":false},{"title":"output","children":[{"title":"users_tablesink.csv <span style='color:#111;'> 9B </span>","children":null,"spread":false},{"title":"checkpoints","children":[{"title":"d85e2e401883880f9449cde7ad7bf444","children":[{"title":"chk-17","children":[{"title":"dcc9fccc-001c-45f7-8057-c55e246a1548 <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"b897a7f4-6533-4493-bb64-756f39489b0c <span style='color:#111;'> 5.45KB </span>","children":null,"spread":false},{"title":"67afd1c0-af89-4183-9589-cb1df056fe4b <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"0df7d58e-acd4-400d-b4ad-f012db156b31 <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"2cf58b85-971c-4aa9-9e88-d9df05d4f132 <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"_metadata <span style='color:#111;'> 2.88KB </span>","children":null,"spread":false},{"title":"d48921f8-5612-4d65-8bff-afc5e1722269 <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"2ea0086f-17bc-4475-ac6c-28619a5187ae <span style='color:#111;'> 5.47KB </span>","children":null,"spread":false},{"title":"bc37854e-7c2a-4ea2-b3a5-0e299ee1a693 <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false}],"spread":false},{"title":"taskowned","children":null,"spread":false},{"title":"shared","children":null,"spread":false}],"spread":false},{"title":"70e11e8fbb3bc1981b228533fbab4bb4","children":[{"title":"chk-39","children":[{"title":"57942710-8bf0-49e7-96e2-383da44ed705 <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"8a6c3710-aef1-455e-a875-dd1900a7e3ed <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"4f2fc73c-a38f-45fb-ba52-47ecb0a8fc8d <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"4e562a13-41ab-41f4-bdb0-13dab146a19c <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"_metadata <span style='color:#111;'> 2.88KB </span>","children":null,"spread":false},{"title":"ed944f43-951c-424e-b22b-8656ed79a6ff <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"b7368619-9ead-4855-9be3-8502f96a0c9f <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"bcc511ea-3487-48f1-baa9-9741fd744f09 <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false},{"title":"91d29659-eb68-481b-a127-ebdfac70da95 <span style='color:#111;'> 5.43KB </span>","children":null,"spread":false}],"spread":false},{"title":"taskowned","children":null,"spread":false},{"title":"shared","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"wordcount_accu.txt <span style='color:#111;'> 66B </span>","children":null,"spread":false},{"title":"users_datastream.csv <span style='color:#111;'> 12B </span>","children":null,"spread":false},{"title":"user_tablebatch.csv <span style='color:#111;'> 12B </span>","children":null,"spread":false},{"title":"wordcount.txt <span style='color:#111;'> 76B </span>","children":null,"spread":false}],"spread":true},{"title":"users.csv <span style='color:#111;'> 31B </span>","children":null,"spread":false}],"spread":true},{"title":"META-INF","children":[{"title":"MANIFEST.MF <span style='color:#111;'> 64B </span>","children":null,"spread":false}],"spread":true},{"title":"streaming","children":[{"title":"StreamWordCountPOJO.java <span style='color:#111;'> 1.27KB </span>","children":null,"spread":false},{"title":"StreamTableDemo.java <span style='color:#111;'> 2.26KB </span>","children":null,"spread":false},{"title":"watermark","children":[{"title":"StreamWatermarkSideOutDemo.java <span style='color:#111;'> 5.75KB </span>","children":null,"spread":false},{"title":"StreamWatermarkDemo.java <span style='color:#111;'> 5.15KB </span>","children":null,"spread":false},{"title":"StreamWatermarkAlloewLateDemo.java <span style='color:#111;'> 5.10KB </span>","children":null,"spread":false}],"spread":false},{"title":"StreamSQLDemo.java <span style='color:#111;'> 2.11KB </span>","children":null,"spread":false},{"title":"window","children":[{"title":"StreamCountWindowProcess.java <span style='color:#111;'> 2.92KB </span>","children":null,"spread":false},{"title":"StreamTimeWindowProcess.java <span style='color:#111;'> 2.82KB </span>","children":null,"spread":false},{"title":"StreamWindowReduce.java <span style='color:#111;'> 2.23KB </span>","children":null,"spread":false}],"spread":false},{"title":"StreamStateDemo.java <span style='color:#111;'> 2.94KB </span>","children":null,"spread":false},{"title":"StreamTableToDataStream.java <span style='color:#111;'> 2.11KB </span>","children":null,"spread":false},{"title":"StreamWordCount.java <span style='color:#111;'> 1.38KB </span>","children":null,"spread":false}],"spread":true},{"title":"model","children":[{"title":"WordCount.java <span style='color:#111;'> 1.20KB </span>","children":null,"spread":false},{"title":"demo.java <span style='color:#111;'> 575B </span>","children":null,"spread":false}],"spread":true},{"title":"batch","children":[{"title":"BatchDistributedCache.java <span style='color:#111;'> 1.74KB </span>","children":null,"spread":false},{"title":"BatchTableDemo.java <span style='color:#111;'> 1.97KB </span>","children":null,"spread":false},{"title":"BatchSQLDemo.java <span style='color:#111;'> 1.95KB </span>","children":null,"spread":false},{"title":"BatchBroadCast.java <span style='color:#111;'> 2.50KB </span>","children":null,"spread":false},{"title":"BatchWordCount.java <span style='color:#111;'> 2.00KB </span>","children":null,"spread":false},{"title":"BatchAccumulator.java <span style='color:#111;'> 2.19KB </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;'> 8.54KB </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":"artifacts","children":[{"title":"FlinkDemo_jar.xml <span style='color:#111;'> 6.80KB </span>","children":null,"spread":false}],"spread":true},{"title":"compiler.xml <span style='color:#111;'> 542B </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":"FlinkDemo.iml <span style='color:#111;'> 81B </span>","children":null,"spread":false}],"spread":true}],"spread":true}]