光大银行准实时KPI数据处理平台
2020-5-12 13:30 更新
IDE:idea 应用语言:Java 测试环境:Cloudera Hadoop 应用技术:SparkStreaming+HDFS+kafka+flume+Hbase+hive+zookeeper 数据的处理流程:需要把业务数据抽取成文件,通过Flume把数据文件传给Kafka进行处理,然后被SparkStreaming的消费端消费,经过处理后保存入Hbase中