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}]