flinkExamples-master.zip

[{"title":"（ 83 个子文件 161KB ） flinkExamples-master.zip","children":[{"title":"flinkExamples-master","children":[{"title":"pom.xml <span style='color:#111;'> 12.88KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 1.17KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"TableSQL","children":[{"title":"WordCountSQL.java <span style='color:#111;'> 3.11KB </span>","children":null,"spread":false},{"title":"WordCountTable.java <span style='color:#111;'> 2.61KB </span>","children":null,"spread":false}],"spread":true},{"title":"quickstart","children":[{"title":"StreamingJob.java <span style='color:#111;'> 2.19KB </span>","children":null,"spread":false},{"title":"BatchJob.java <span style='color:#111;'> 2.13KB </span>","children":null,"spread":false}],"spread":true},{"title":"Batch","children":[{"title":"misc","children":[{"title":"PiEstimation.java <span style='color:#111;'> 3.09KB </span>","children":null,"spread":false},{"title":"CollectionExecutionExample.java <span style='color:#111;'> 3.25KB </span>","children":null,"spread":false}],"spread":true},{"title":"relational","children":[{"title":"EmptyFieldsCountAccumulator.java <span style='color:#111;'> 8.52KB </span>","children":null,"spread":false},{"title":"TPCHQuery3.java <span style='color:#111;'> 9.05KB </span>","children":null,"spread":false},{"title":"WebLogAnalysis.java <span style='color:#111;'> 10.14KB </span>","children":null,"spread":false},{"title":"util","children":[{"title":"WebLogDataGenerator.java <span style='color:#111;'> 6.09KB </span>","children":null,"spread":false},{"title":"WebLogData.java <span style='color:#111;'> 33.75KB </span>","children":null,"spread":false}],"spread":false},{"title":"TPCHQuery10.java <span style='color:#111;'> 7.60KB </span>","children":null,"spread":false}],"spread":true},{"title":"graph","children":[{"title":"EnumTriangles.java <span style='color:#111;'> 7.55KB </span>","children":null,"spread":false},{"title":"TransitiveClosureNaive.java <span style='color:#111;'> 4.83KB </span>","children":null,"spread":false},{"title":"util","children":[{"title":"ConnectedComponentsData.java <span style='color:#111;'> 2.29KB </span>","children":null,"spread":false},{"title":"EnumTrianglesData.java <span style='color:#111;'> 1.66KB </span>","children":null,"spread":false},{"title":"EnumTrianglesDataTypes.java <span style='color:#111;'> 3.94KB </span>","children":null,"spread":false},{"title":"PageRankData.java <span style='color:#111;'> 2.11KB </span>","children":null,"spread":false}],"spread":false},{"title":"ConnectedComponents.java <span style='color:#111;'> 8.85KB </span>","children":null,"spread":false},{"title":"PageRank.java <span style='color:#111;'> 9.71KB </span>","children":null,"spread":false}],"spread":true},{"title":"ml","children":[{"title":"LinearRegression.java <span style='color:#111;'> 8.02KB </span>","children":null,"spread":false},{"title":"util","children":[{"title":"LinearRegressionDataGenerator.java <span style='color:#111;'> 3.35KB </span>","children":null,"spread":false},{"title":"LinearRegressionData.java <span style='color:#111;'> 2.70KB </span>","children":null,"spread":false}],"spread":false}],"spread":true},{"title":"clustering","children":[{"title":"KMeans.java <span style='color:#111;'> 10.07KB </span>","children":null,"spread":false},{"title":"util","children":[{"title":"KMeansDataGenerator.java <span style='color:#111;'> 5.86KB </span>","children":null,"spread":false},{"title":"KMeansData.java <span style='color:#111;'> 3.44KB </span>","children":null,"spread":false}],"spread":false}],"spread":true},{"title":"wordcount","children":[{"title":"WordCount.java <span style='color:#111;'> 3.99KB </span>","children":null,"spread":false},{"title":"util","children":[{"title":"WordCountData.java <span style='color:#111;'> 2.93KB </span>","children":null,"spread":false}],"spread":false},{"title":"WordCountPojo.java <span style='color:#111;'> 4.31KB </span>","children":null,"spread":false}],"spread":false},{"title":"distcp","children":[{"title":"FileCopyTaskInputSplit.java <span style='color:#111;'> 1.36KB </span>","children":null,"spread":false},{"title":"FileCopyTaskInputFormat.java <span style='color:#111;'> 3.34KB </span>","children":null,"spread":false},{"title":"DistCp.java <span style='color:#111;'> 6.82KB </span>","children":null,"spread":false},{"title":"FileCopyTask.java <span style='color:#111;'> 1.67KB </span>","children":null,"spread":false}],"spread":false}],"spread":true},{"title":"Streaming","children":[{"title":"iteration","children":[{"title":"IterateExample.java <span style='color:#111;'> 7.80KB </span>","children":null,"spread":false},{"title":"util","children":[{"title":"IterateExampleData.java <span style='color:#111;'> 1.56KB </span>","children":null,"spread":false}],"spread":true}],"spread":true},{"title":"socket","children":[{"title":"SocketWindowWordCount.java <span style='color:#111;'> 3.79KB </span>","children":null,"spread":false}],"spread":true},{"title":"windowing","children":[{"title":"SessionWindowing.java <span style='color:#111;'> 3.56KB </span>","children":null,"spread":false},{"title":"WindowWordCount.java <span style='color:#111;'> 3.36KB </span>","children":null,"spread":false},{"title":"TopSpeedWindowing.java <span style='color:#111;'> 6.19KB </span>","children":null,"spread":false},{"title":"util","children":[{"title":"TopSpeedWindowingExampleData.java <span style='color:#111;'> 18.07KB </span>","children":null,"spread":false},{"title":"SessionWindowingData.java <span style='color:#111;'> 1.04KB </span>","children":null,"spread":false}],"spread":false},{"title":"GroupedProcessingTimeWindowExample.java <span style='color:#111;'> 4.25KB </span>","children":null,"spread":false}],"spread":true},{"title":"ml","children":[{"title":"IncrementalLearningSkeleton.java <span style='color:#111;'> 6.64KB </span>","children":null,"spread":false},{"title":"util","children":[{"title":"IncrementalLearningSkeletonData.java <span style='color:#111;'> 1.54KB </span>","children":null,"spread":false}],"spread":false}],"spread":true},{"title":"async","children":[{"title":"AsyncIOExample.java <span style='color:#111;'> 9.98KB </span>","children":null,"spread":false}],"spread":false},{"title":"sideoutput","children":[{"title":"SideOutputExample.java <span style='color:#111;'> 5.34KB </span>","children":null,"spread":false}],"spread":false},{"title":"statemachine","children":[{"title":"dfa","children":[{"title":"EventTypeAndState.java <span style='color:#111;'> 1.14KB </span>","children":null,"spread":false},{"title":"Transition.java <span style='color:#111;'> 2.93KB </span>","children":null,"spread":false},{"title":"State.java <span style='color:#111;'> 4.35KB </span>","children":null,"spread":false}],"spread":false},{"title":"KafkaEventsGeneratorJob.java <span style='color:#111;'> 2.11KB </span>","children":null,"spread":false},{"title":"StateMachineExample.java <span style='color:#111;'> 7.21KB </span>","children":null,"spread":false},{"title":"generator","children":[{"title":"EventsGenerator.java <span style='color:#111;'> 5.15KB </span>","children":null,"spread":false},{"title":"StandaloneThreadedGenerator.java <span style='color:#111;'> 6.11KB </span>","children":null,"spread":false},{"title":"EventsGeneratorSource.java <span style='color:#111;'> 2.27KB </span>","children":null,"spread":false}],"spread":false},{"title":"kafka","children":[{"title":"EventDeSerializer.java <span style='color:#111;'> 2.13KB </span>","children":null,"spread":false},{"title":"KafkaStandaloneGenerator.java <span style='color:#111;'> 3.14KB </span>","children":null,"spread":false}],"spread":false},{"title":"event","children":[{"title":"Event.java <span style='color:#111;'> 2.78KB </span>","children":null,"spread":false},{"title":"EventType.java <span style='color:#111;'> 960B </span>","children":null,"spread":false},{"title":"Alert.java <span style='color:#111;'> 2.38KB </span>","children":null,"spread":false}],"spread":false},{"title":"README.md <span style='color:#111;'> 2.18KB </span>","children":null,"spread":false}],"spread":false},{"title":"wordcount","children":[{"title":"WordCount.java <span style='color:#111;'> 4.08KB </span>","children":null,"spread":false},{"title":"util","children":[{"title":"WordCountData.java <span style='color:#111;'> 2.72KB </span>","children":null,"spread":false}],"spread":false}],"spread":false},{"title":"join","children":[{"title":"WindowJoinSampleData.java <span style='color:#111;'> 2.99KB </span>","children":null,"spread":false},{"title":"WindowJoin.java <span style='color:#111;'> 4.32KB </span>","children":null,"spread":false}],"spread":false},{"title":"twitter","children":[{"title":"util","children":[{"title":"TwitterExampleData.java <span style='color:#111;'> 5.21KB </span>","children":null,"spread":false}],"spread":false},{"title":"TwitterExample.java <span style='color:#111;'> 5.78KB </span>","children":null,"spread":false}],"spread":false},{"title":"kafka","children":[{"title":"Kafka010Example.java <span style='color:#111;'> 7.63KB </span>","children":null,"spread":false},{"title":"KafkaEventSchema.java <span style='color:#111;'> 1.81KB </span>","children":null,"spread":false},{"title":"kafkaproducer.java <span style='color:#111;'> 3.06KB </span>","children":null,"spread":false},{"title":"KafkaEvent.java <span style='color:#111;'> 2.12KB </span>","children":null,"spread":false}],"spread":false},{"title":"utils","children":[{"title":"ThrottledIterator.java <span style='color:#111;'> 2.79KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":".idea","children":[{"title":"uiDesigner.xml <span style='color:#111;'> 8.71KB </span>","children":null,"spread":false},{"title":"misc.xml <span style='color:#111;'> 513B </span>","children":null,"spread":false},{"title":"vcs.xml <span style='color:#111;'> 180B </span>","children":null,"spread":false},{"title":"dictionaries","children":[{"title":"meitu.xml <span style='color:#111;'> 84B </span>","children":null,"spread":false}],"spread":true},{"title":"encodings.xml <span style='color:#111;'> 172B </span>","children":null,"spread":false},{"title":"compiler.xml <span style='color:#111;'> 542B </span>","children":null,"spread":false},{"title":"workspace.xml <span style='color:#111;'> 49.50KB </span>","children":null,"spread":false},{"title":"sbt.xml <span style='color:#111;'> 159B </span>","children":null,"spread":false}],"spread":true},{"title":"dependency-reduced-pom.xml <span style='color:#111;'> 7.33KB </span>","children":null,"spread":false},{"title":".gitignore <span style='color:#111;'> 83B </span>","children":null,"spread":false}],"spread":true}],"spread":true}]