我有地理數(shù)據(jù)的 CSV 文件。我使用 apache spark 將這些文件導(dǎo)入數(shù)據(jù)集，然后我想使用 GeoMesa。所以我需要將數(shù)據(jù)集轉(zhuǎn)換為 simplefeature，并以 GeoMesa 格式將其保存到 Cassandra公共類主要{public static void main(String[] args) throws IOException {    Map<String, String> dsProperties = new HashMap<String, String>();    dsProperties.put("cassandra.keyspace", "t1");    dsProperties.put("cassandra.catalog", "testgeo");    dsProperties.put("cassandra.tableName", "testgeo");    dsProperties.put("cassandra.contact.point", "localhost:9042");    DataStore ds = DataStoreFinder.getDataStore(dsProperties);    SimpleFeatureType sft = SimpleFeatureTypes.createType("testgeo", "geoid:Integer,geopoint:Point:srid=4326");    ds.createSchema(sft);    SparkSession spark = SparkSession.builder().appName("my-app").master("local[*]")            .config("spark.serializer", "org.apache.spark.serializer.KryoSerializer")            .config("spark.kryo.registrator", "org.locationtech.geomesa.spark.GeoMesaSparkKryoRegistrator")            .getOrCreate();    org.apache.spark.sql.SQLTypes.init(spark.sqlContext());    StructType schema = new StructType()            .add(new StructField("id", DataTypes.IntegerType, true, Metadata.empty()))            .add(new StructField("dt", DataTypes.TimestampType, true, Metadata.empty()))            .add(new StructField("lat", DataTypes.DoubleType, true, Metadata.empty()))            .add(new StructField("lon", DataTypes.DoubleType, true, Metadata.empty()));    Dataset<Row> df = spark.read().format("geomesa").option("header", true).option("inferSchema", true)            .option("dateFormat", "yyyy-MM-dd HH:mm:ss").schema(schema).option("delimiter", ",")            .csv("C:\\Users\\h6\\Desktop\\dta.csv");    df.createOrReplaceTempView("testgeo");    df = spark.sql("SELECT id as geoid, st_makePoint(lat, lon) as geopoint FROM testgeo");    df.show();}}