spark_streaming_aggregation:使用Spark Streaming进行事件聚合

spark_streaming_aggregation 通过Spark Streaming进行事件聚合。 该示例包括基于Kafka或TCP事件流的事件聚合。 这些说明是但是应该在独立群集上工作。 生成并运行Kafka示例 生成程序集./sbt/sbt package 确保您有正在运行的Spark服务器和Cassandra节点在本地主机上侦听 确保您已在本地主机上运行Kafka服务器，并预先设置了主题events 。 启动Kafka生产者./sbt/sbt "run-main KafkaProducer" 将程序集提交到spark服务器dse spark-submit --class KafkaConsumer ./target/scala-2.10/sparkstreamingaggregation_2.10-0.2.jar 数据将发布到C *列系列demo.event_log和