利用Kafka作为中间件，通过spring boot项目开放一个接口传数据，通过生产者发送，消费者来接收数据后按照小时划分存为文件，后load到hive仓库。原因百度应该是有什么特殊符号问题可能是命令行换行符，，但是我截取出来只有数字。可能是shell哪里的问题吧。一开始直接把时间切分剩小时，结果报错 ambiguous redirect，又切分一下就好了。把文件load到hive数据仓库，根据小

主要难点是计算一定时间内订单总数topN，使用aggregate算子，重写方法自定义聚合函数