E-MapReduce 实现了一套通用的Spark Streaming实时消费LogHub的接口,SDK请转至GitHub下载。