org.locationtech.geowave.analytic.spark.sparksql

Class SimpleFeatureMapper

java.lang.Object

org.locationtech.geowave.analytic.spark.sparksql.SimpleFeatureMapper

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.Function<org.opengis.feature.simple.SimpleFeature,org.apache.spark.sql.Row>

public class SimpleFeatureMapper
extends Object
implements org.apache.spark.api.java.function.Function<org.opengis.feature.simple.SimpleFeature,org.apache.spark.sql.Row>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SimpleFeatureMapper(org.apache.spark.sql.types.StructType schema)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.Row	call(org.opengis.feature.simple.SimpleFeature feature)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleFeatureMapper

public SimpleFeatureMapper(org.apache.spark.sql.types.StructType schema)

Method Detail

call

public org.apache.spark.sql.Row call(org.opengis.feature.simple.SimpleFeature feature)
                              throws Exception

Specified by:

call in interface org.apache.spark.api.java.function.Function<org.opengis.feature.simple.SimpleFeature,org.apache.spark.sql.Row>

Throws:

Exception