一.简介
- 读取postgis 表数据
- 写入数据到postgis 表中
二.代码
1.保持RDD到Postgis
//保存postgis
def save_postgis(rdd: SpatialRDD)(implicit context: SparkContext) = {
var dataStore: DataStore = DataStoreFinder.getDataStore(params);
val simpleFeatureTypeBuilder = new SimpleFeatureTypeBuilder
simpleFeatureTypeBuilder.init(rdd.schema)
simpleFeatureTypeBuilder.setName(table)
val simpleFeatureType = simpleFeatureTypeBuilder.buildFeatureType
dataStore.createSchema(simpleFeatureType)
//修改simplefeature id值为int
val newRdd: RDD[SimpleFeature] = rdd.map(item => {
val builder = new SimpleFeatureBuilder(item.getFeatureType)
builder.init(item)
val feature: SimpleFeature = builder.buildFeature(item.getID.substring(item.getID.indexOf(".") + 1))
fe
