oracle.spatial.spark.vector.sql

Class SpatialJavaRDDConversions

java.lang.Object

oracle.spatial.spark.vector.sql.SpatialJavaRDDConversions

public class SpatialJavaRDDConversions
extends java.lang.Object

Utilty functions to transform a Spatial RDD into a Dataset of Rows (DataFrame)

Author:

hsaucedo

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SPATIAL_COLUMN_NAME

Constructor Summary

Constructors

Constructor and Description
SpatialJavaRDDConversions()

Method Summary

Modifier and Type	Method and Description
static <T> <any>	toDataFrame(SpatialJavaRDD<T> spatialRDD, java.util.List<java.lang.String> nonSpatialFieldsNames, SparkSession spark) Transforms a spatial RDD to a DataFrame (Dataset<Row>)

Methods inherited from class java.lang.Object

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

Field Detail

SPATIAL_COLUMN_NAME

public static final java.lang.String SPATIAL_COLUMN_NAME

See Also:

Constant Field Values

Constructor Detail

SpatialJavaRDDConversions

public SpatialJavaRDDConversions()

Method Detail

toDataFrame

public static <T> <any> toDataFrame(SpatialJavaRDD<T> spatialRDD,
                                    java.util.List<java.lang.String> nonSpatialFieldsNames,
                                    SparkSession spark)

Transforms a spatial RDD to a DataFrame (Dataset<Row>)

Parameters:

spatialRDD - the source Spatial RDD

nonSpatialFieldsNames - list of columns to be included in the dataframe. The spatial column by default is called geometry and should not be included in this list.

spark - the SparkSession

Returns:

a dataframe