microberw:kafka in kafka out 基于Spark Streams的通用代码调用器-源码

[{"title":"（ 31 个子文件 31KB ） microberw:kafka in kafka out 基于Spark Streams的通用代码调用器-源码","children":[{"title":"microberw-master","children":[{"title":"src","children":[{"title":"JavaCustomReceiver.java <span style='color:#111;'> 5.33KB </span>","children":null,"spread":false},{"title":"infrastracture","children":[{"title":"events","children":[{"title":"generators","children":[{"title":"IEventGenerator.java <span style='color:#111;'> 221B </span>","children":null,"spread":false},{"title":"SingleImidiateEventGenerator.java <span style='color:#111;'> 655B </span>","children":null,"spread":false},{"title":"TriggerdEventGenerator.java <span style='color:#111;'> 832B </span>","children":null,"spread":false}],"spread":true},{"title":"types","children":[{"title":"FlexibleEvent.java <span style='color:#111;'> 215B </span>","children":null,"spread":false},{"title":"SingleElementEvent.java <span style='color:#111;'> 119B </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true},{"title":"testers","children":[{"title":"GenericTester.java <span style='color:#111;'> 2.88KB </span>","children":null,"spread":false},{"title":"KafkaTester.java <span style='color:#111;'> 2.88KB </span>","children":null,"spread":false}],"spread":true},{"title":"JavaKafkaWordCount.java <span style='color:#111;'> 4.03KB </span>","children":null,"spread":false},{"title":"JavaNetworkWordCount.java <span style='color:#111;'> 3.61KB </span>","children":null,"spread":false},{"title":"brews","children":[{"title":"GenericSparkBrew.java <span style='color:#111;'> 461B </span>","children":null,"spread":false},{"title":"GenericKafkaBrew.java <span style='color:#111;'> 2.69KB </span>","children":null,"spread":false},{"title":"GenericBrew.java <span style='color:#111;'> 1008B </span>","children":null,"spread":false}],"spread":true},{"title":"kernels","children":[{"title":"ILogic.java <span style='color:#111;'> 139B </span>","children":null,"spread":false},{"title":"GenericLogic.java <span style='color:#111;'> 219B </span>","children":null,"spread":false}],"spread":true},{"title":"GenericBrew.java <span style='color:#111;'> 3.77KB </span>","children":null,"spread":false}],"spread":true},{"title":".idea","children":[{"title":"uiDesigner.xml <span style='color:#111;'> 8.59KB </span>","children":null,"spread":false},{"title":"scopes","children":[{"title":"scope_settings.xml <span style='color:#111;'> 139B </span>","children":null,"spread":false}],"spread":true},{"title":"misc.xml <span style='color:#111;'> 6.86KB </span>","children":null,"spread":false},{"title":"vcs.xml <span style='color:#111;'> 167B </span>","children":null,"spread":false},{"title":".name <span style='color:#111;'> 9B </span>","children":null,"spread":false},{"title":"copyright","children":[{"title":"profiles_settings.xml <span style='color:#111;'> 74B </span>","children":null,"spread":false}],"spread":true},{"title":"modules.xml <span style='color:#111;'> 258B </span>","children":null,"spread":false},{"title":"encodings.xml <span style='color:#111;'> 164B </span>","children":null,"spread":false},{"title":"compiler.xml <span style='color:#111;'> 709B </span>","children":null,"spread":false},{"title":"workspace.xml <span style='color:#111;'> 69.87KB </span>","children":null,"spread":false},{"title":"libraries","children":[{"title":"spark.xml <span style='color:#111;'> 643B </span>","children":null,"spread":false}],"spread":true}],"spread":false},{"title":".gitignore <span style='color:#111;'> 606B </span>","children":null,"spread":false},{"title":"microberw.iml <span style='color:#111;'> 486B </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 370B </span>","children":null,"spread":false},{"title":".gitattributes <span style='color:#111;'> 483B </span>","children":null,"spread":false}],"spread":true}],"spread":true}]