hbaseOnSpark

所属分类:云数据库/云存储
开发工具:Java
文件大小:0KB
下载次数:0
上传日期:2018-12-10 03:10:11
上 传 者sh-1993
说明:  该项目主要是通过kafka,将pb数据插入到hbase的过程,项目中提供了两种hbase插入方式:分别是bulkload和batch put,并且程序的配置文件在设计的时候已hbase table为中心,支持同表、多topic、多rowkey,多列簇以及多列的对应关系的支持,
(This project is mainly the process of inserting pb data into hbase through kafka. The project provides two ways to insert hbase: bulkload and batch put. In addition, the program configuration file has been designed with hbase table as the center, supporting the same table, multiple topics, multiple rowkeys, multiple column clusters, and multiple column correspondence,)

文件列表:
RealtimeDataStore.iml (80, 2018-12-09)
derby.log (706, 2018-12-09)
pom.xml (6711, 2018-12-09)
src/ (0, 2018-12-09)
src/main/ (0, 2018-12-09)
src/main/resources/ (0, 2018-12-09)
src/main/resources/configure.json (676, 2018-12-09)
src/main/resources/log4j.properties (8939, 2018-12-09)
src/main/resources/mapping.json (686, 2018-12-09)
src/main/scala/ (0, 2018-12-09)
src/main/scala/com/ (0, 2018-12-09)
src/main/scala/com/hxy/ (0, 2018-12-09)
src/main/scala/com/hxy/config/ (0, 2018-12-09)
src/main/scala/com/hxy/config/HBaseContext.scala (1527, 2018-12-09)
src/main/scala/com/hxy/get/ (0, 2018-12-09)
src/main/scala/com/hxy/get/TGet.scala (170, 2018-12-09)
src/main/scala/com/hxy/json/ (0, 2018-12-09)
src/main/scala/com/hxy/json/JsonTemplete.scala (2227, 2018-12-09)
src/main/scala/com/hxy/main/ (0, 2018-12-09)
src/main/scala/com/hxy/main/HBaseAccess.scala (1409, 2018-12-09)
src/main/scala/com/hxy/main/HBaseInsert.scala (848, 2018-12-09)
src/main/scala/com/hxy/protobuf/ (0, 2018-12-09)
src/main/scala/com/hxy/protobuf/DSFusion.java (73458, 2018-12-09)
src/main/scala/com/hxy/put/ (0, 2018-12-09)
src/main/scala/com/hxy/put/BatchPut.scala (1875, 2018-12-09)
src/main/scala/com/hxy/put/BulkPut.scala (1599, 2018-12-09)
src/main/scala/com/hxy/put/TPut.scala (321, 2018-12-09)
src/main/scala/com/hxy/receiver/ (0, 2018-12-09)
src/main/scala/com/hxy/receiver/KafkaReceiver.scala (1512, 2018-12-09)
src/main/scala/com/hxy/source/ (0, 2018-12-09)
src/main/scala/com/hxy/source/DataSource.scala (202, 2018-12-09)
src/main/scala/com/hxy/util/ (0, 2018-12-09)
src/main/scala/com/hxy/util/Json2Object.scala (2508, 2018-12-09)
src/main/scala/com/hxy/util/TableDetailParser.scala (1859, 2018-12-09)

# hbaseOnSpark 该项目主要是通过kafka,将pb数据插入到hbase的过程,项目中提供了两种hbase插入方式:分别是bulkload和batch put,并且程序的配置文件在设计的时候已hbase table为中心,支持同表、多topic、多rowkey,多列簇以及多列的对应关系的支持

近期下载者

相关文件


收藏者