一.简介
- Hbase矢量数据读取
- Hbase矢量数据写入
二.代码
1.写入RDD数据到Hbase
//保存hbase
def write_hbase(spatialRdd: SpatialRDD)(implicit context: SparkContext) = {
val datastore: DataStore = DataStoreFinder.getDataStore(params)
val simpleFeatureTypeBuilder: SimpleFeatureTypeBuilder = new SimpleFeatureTypeBuilder
simpleFeatureTypeBuilder.init(spatialRdd.schema)
simpleFeatureTypeBuilder.setName(schemaName)
val simpleFeatureType: SimpleFeatureType = simpleFeatureTypeBuilder.buildFeatureType
//simpleFeatureType.getUserData.put("override.reserved.words", Boolean(true))
simpleFeatureType.getDescriptor("mc").getUserData.put("index", "true") //给名称字段创建索引
//simpleFeatureType.getUserData().put("geomesa.indices.enabled", "z3,attr:name:dtg");也可以这样子
datastore.createS
