kafka实现读文件到hbase 并且实现hbase到hive上的映射
首先还是构建一个父类特质方法package kafkatohbaseimport org.apache.hadoop.hbase.client.Putimport org.apache.kafka.clients.consumer.{ConsumerRecord, ConsumerRecords}trait DataHandler { def transform(topic:String,records:ConsumerRecords[String,String]):Array[Put]
