Spark实战(二):Kafka-SparkStreaming-Elasticsearch

本文介绍saprk实时部分----spark-streaming。spark-streaming能够实现实时批处理功能,实际上仍是至关于小的批处理,可是是7*24工做,能够近实时但须要维护成本。本文里的用java写的demo,实现功能是将kafka做为spark-streaming的输入源,Elasticsearch做为输出源来实现实时处理架构。html 仍是先上代码 mavenjava <dep
相关文章
相关标签/搜索