org.locationtech.geowave.analytic.spark.sparksql

Class SimpleFeatureDataFrame

java.lang.Object

org.locationtech.geowave.analytic.spark.sparksql.SimpleFeatureDataFrame

public class SimpleFeatureDataFrame
extends Object

Constructor Summary

Constructors

Constructor and Description
SimpleFeatureDataFrame(org.apache.spark.sql.SparkSession sparkSession)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	getDataFrame(GeoWaveRDD pairRDD)
org.opengis.feature.simple.SimpleFeatureType	getFeatureType()
org.apache.spark.api.java.JavaRDD<org.apache.spark.sql.Row>	getRowRDD()
org.apache.spark.sql.types.StructType	getSchema()
boolean	init(DataStorePluginOptions dataStore, String typeName)
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	resetDataFrame(GeoWaveRDD pairRDD)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleFeatureDataFrame

public SimpleFeatureDataFrame(org.apache.spark.sql.SparkSession sparkSession)

Method Detail

init

public boolean init(DataStorePluginOptions dataStore,
                    String typeName)

getFeatureType

public org.opengis.feature.simple.SimpleFeatureType getFeatureType()

getSchema

public org.apache.spark.sql.types.StructType getSchema()

getRowRDD

public org.apache.spark.api.java.JavaRDD<org.apache.spark.sql.Row> getRowRDD()

getDataFrame

public org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> getDataFrame(GeoWaveRDD pairRDD)

resetDataFrame

public org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> resetDataFrame(GeoWaveRDD pairRDD)