spark-rabbitmq：RabbitMQ Spark流媒体接收器-源码

[{"title":"（ 26 个子文件 198KB ） spark-rabbitmq：RabbitMQ Spark流媒体接收器-源码","children":[{"title":"spark-rabbitmq-master","children":[{"title":".gitignore <span style='color:#111;'> 24B </span>","children":null,"spread":false},{"title":"images","children":[{"title":"multipleParallelized.png <span style='color:#111;'> 52.34KB </span>","children":null,"spread":false},{"title":"singleParalellized.png <span style='color:#111;'> 50.22KB </span>","children":null,"spread":false},{"title":"cluster.png <span style='color:#111;'> 55.72KB </span>","children":null,"spread":false}],"spread":true},{"title":"src","children":[{"title":"main","children":[{"title":"scala","children":[{"title":"org","children":[{"title":"apache","children":[{"title":"spark","children":[{"title":"streaming","children":[{"title":"rabbitmq","children":[{"title":"RabbitMQUtils.scala <span style='color:#111;'> 8.70KB </span>","children":null,"spread":false},{"title":"models","children":[{"title":"ExchangeAndRouting.scala <span style='color:#111;'> 1.56KB </span>","children":null,"spread":false},{"title":"QueueConnectionOpts.scala <span style='color:#111;'> 1009B </span>","children":null,"spread":false}],"spread":true},{"title":"ConfigParameters.scala <span style='color:#111;'> 3.15KB </span>","children":null,"spread":false},{"title":"receiver","children":[{"title":"RabbitMQInputDStream.scala <span style='color:#111;'> 4.53KB </span>","children":null,"spread":false}],"spread":false},{"title":"consumer","children":[{"title":"ConsumerParamsUtils.scala <span style='color:#111;'> 5.27KB </span>","children":null,"spread":false},{"title":"Consumer.scala <span style='color:#111;'> 9.65KB </span>","children":null,"spread":false}],"spread":false},{"title":"distributed","children":[{"title":"RabbitMQPartition.scala <span style='color:#111;'> 1.48KB </span>","children":null,"spread":false},{"title":"RabbitMQRDD.scala <span style='color:#111;'> 10.50KB </span>","children":null,"spread":false},{"title":"RabbitMQDStream.scala <span style='color:#111;'> 7.53KB </span>","children":null,"spread":false},{"title":"RabbitMQDistributedKey.scala <span style='color:#111;'> 1.55KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"test","children":[{"title":"scala","children":[{"title":"org","children":[{"title":"apache","children":[{"title":"spark","children":[{"title":"streaming","children":[{"title":"rabbitmq","children":[{"title":"RabbitMQSuite.scala <span style='color:#111;'> 973B </span>","children":null,"spread":false},{"title":"TemporalDataSuite.scala <span style='color:#111;'> 5.64KB </span>","children":null,"spread":false},{"title":"RabbitMQConsumerIT.scala <span style='color:#111;'> 2.13KB </span>","children":null,"spread":false},{"title":"RabbitMQDistributedConsumerIT.scala <span style='color:#111;'> 3.74KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"java","children":[{"title":"org","children":[{"title":"apache","children":[{"title":"spark","children":[{"title":"streaming","children":[{"title":"rabbitmq","children":[{"title":"JavaRabbitMQDistributedConsumer.java <span style='color:#111;'> 2.52KB </span>","children":null,"spread":false},{"title":"JavaRabbitMQConsumer.java <span style='color:#111;'> 2.09KB </span>","children":null,"spread":false}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true}],"spread":true},{"title":"CHANGELOG.md <span style='color:#111;'> 1.13KB </span>","children":null,"spread":false},{"title":"LICENSE.txt <span style='color:#111;'> 11.09KB </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 10.50KB </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 8.77KB </span>","children":null,"spread":false},{"title":"Jenkinsfile <span style='color:#111;'> 682B </span>","children":null,"spread":false}],"spread":true}],"spread":true}]