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

Freedom123

发布于 2024-03-29 10:47:03

16700

代码可运行

文章被收录于专栏：DevOpsDevOps

运行总次数：0

代码可运行

一.简介

二.代码

1.从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();
    }

2.Main调用

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();
    }

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2024-03-28，如有侵权请联系 cloudcommunity@tencent.com 删除

record