10. GeoMesa数据读取篇之HBase读取

//读取hbase
    def read_hbase(implicit sparkContext: SparkContext) = {


        val query = new Query(schemaName);
        val spatialRDDProvider = GeoMesaSpark(params);
        val hBaseDataStore = DataStoreFinder.getDataStore(params).asInstanceOf[HBaseDataStore]
        val rdd1 = spatialRDDProvider.rdd(new Configuration(), sparkContext, params, query);
        println(rdd1.schema);

        rdd1.collect().foreach(record => {
            println(record)
        });

        println("close")
        hBaseDataStore.dispose();
    }

val params = Map("hbase.zookeepers" -> "geomesa1.com:2181,geomesa2.com:2181,geomesa3.com:2181",
        "hbase.catalog" -> "Test");

    val schemaName = "TestPoint2"

    def main(args: Array[String]): Unit = {
        val sparkContext: SparkContext = SparkUtilsScala.createSparkContext()

        sparkContext.stop();
    }