/** * @param array such as [1024, 2048, 20480, 102400] * @param unit such as M * @return return proper unit fr…

一、问题 对实时流量日志过滤筛选商户流量，对每个商户的流量进行累计，统计商户实时累计流量。 当时间超过24时时，重新统计当日商户的实时累计流量。 二、实现步骤 1、采用Spark Streaming读取Kafka中的实时…