Kafka-Spark-stream-with-static-data-using-join:使用join的Kafka Spark流与静态数据

[{"title":"（ 18 个子文件 26KB ） Kafka-Spark-stream-with-static-data-using-join:使用join的Kafka Spark流与静态数据","children":[{"title":"Kafka-Spark-stream-with-static-data-using-join-master","children":[{"title":"pom.xml <span style='color:#111;'> 8.24KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"streaming.yml <span style='color:#111;'> 1.08KB </span>","children":null,"spread":false}],"spread":true},{"title":"java","children":[{"title":"com","children":[{"title":"spark","children":[{"title":"streaming","children":[{"title":"tools","children":[{"title":"core","children":[{"title":"Producer.java <span style='color:#111;'> 1.44KB </span>","children":null,"spread":false},{"title":"KafkaSparkStreamold.java <span style='color:#111;'> 4.82KB </span>","children":null,"spread":false},{"title":"ProcessStreamingData.java <span style='color:#111;'> 2.95KB </span>","children":null,"spread":false},{"title":"AbstractSparkLayer.java <span style='color:#111;'> 2.46KB </span>","children":null,"spread":false},{"title":"Functions.java <span style='color:#111;'> 1.03KB </span>","children":null,"spread":false},{"title":"KafkaSparkStream.java <span style='color:#111;'> 4.82KB </span>","children":null,"spread":false},{"title":"UpdateOffsetsFn.java <span style='color:#111;'> 1.78KB </span>","children":null,"spread":false},{"title":"Contact.java <span style='color:#111;'> 2.25KB </span>","children":null,"spread":false},{"title":"KafkaManager.java <span style='color:#111;'> 6.00KB </span>","children":null,"spread":false}],"spread":true},{"title":"StreamingEngine.java <span style='color:#111;'> 3.59KB </span>","children":null,"spread":false},{"title":"utils","children":[{"title":"ConfigLoader.java <span style='color:#111;'> 823B </span>","children":null,"spread":false},{"title":"StreamingConfig.java <span style='color:#111;'> 5.66KB </span>","children":null,"spread":false},{"title":"CommandLineOptionsHandler.java <span style='color:#111;'> 3.44KB </span>","children":null,"spread":false},{"title":"ConnectionManager.java <span style='color:#111;'> 2.55KB </span>","children":null,"spread":false}],"spread":true},{"title":"JSONProcessingExample.java <span style='color:#111;'> 6.17KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"README.md <span style='color:#111;'> 96B </span>","children":null,"spread":false}],"spread":true}],"spread":true}]