9. GeoMesa数据读取篇之Postgis读取

1. 读取postgis 表数据
2. 写入数据到postgis 表中

  //读取postgis
    def read_postgis(implicit sparkContext: SparkContext) = {

        val query = new Query(table)
        val rdd = GeoMesaSpark(params).rdd(new Configuration(), sparkContext, params, query)
        println(rdd.schema) //打印数据存储方案
        val feature: SimpleFeature = rdd.first()
        rdd
    }

val table: String = "Hello"

    val params = Map(
        "geotools" -> "true",
        "dbtype" -> "postgis",
        "host" -> "10.0.0.0",
        "schema" -> "public",
        "user" -> "qldsadfm",
        "passwd" -> "qldsadfm",
        "port" -> "5432",
        "database