Package | Description |
---|---|
oracle.spatial.spark.vector.index |
Base definitions and classes for distributed spatial indexes and spatial partitioning algorithms used with spatial RDDs.
|
oracle.spatial.spark.vector.index.quadtree |
QuadTree implementations of DistributedSpatialIndex and SpatialPartitioning
|
oracle.spatial.spark.vector.rdd |
Spatial RDD definitions
|
oracle.spatial.spark.vector.sql | |
oracle.spatial.spark.vector.util |
Utility classes for the Spark Vector API
|
Modifier and Type | Method and Description |
---|---|
abstract SpatialJavaRDD<T> |
DistributedSpatialIndex.filter(<any> filterFunc)
Returns a new spatial RDD containing only the elements that satisfy the filtering function
|
abstract SpatialJavaRDD<T> |
DistributedSpatialIndex.filter(<any> f, SpatialOperationConfig spatialOpConf)
Returns a new spatial RDD containing only the elements that satisfy both, the filtering function and the spatial operation
|
abstract SpatialJavaRDD<T> |
DistributedSpatialIndex.primaryFilter(<any> f, SpatialOperationConfig spatialOpConf)
Returns a new spatial RDD containing the elements which satisfy the filtering lambda function an which are likely to interact with the query window defined in the passes spatial operation configuration.
|
Modifier and Type | Method and Description |
---|---|
static <T> DistributedSpatialIndex<T> |
DistributedSpatialIndex.createIndex(JavaSparkContext sc, SpatialJavaRDD<T> rdd, SpatialPartitioningConfiguration partConf)
Spatially index a spatial RDD using the specified
DistributedSpatialIndex implementing class |
abstract <T2,R> <any> |
DistributedSpatialIndex.join(SpatialJavaRDD<T2> rdd2, <any> f, SpatialOperationConfig spatialOpConf)
Deprecated.
use spatialJoin Joins records from the current index with records of the passed spatial RDD. The records are joined based on a spatial relationship defined by the given instance of
SpatialOperationConfig . The type of the resulting records is defined by the user-provided lambda function. For each pair of joined records, the lambda function should return one result. If it is desired to return more than one results per pair of joined records or it is desired to exclude a pair from the result, use DistributedSpatialIndex#spatialJoin(SpatialJavaRDD, Function2, SpatialOperationConfig) |
abstract <T2,R> <any> |
DistributedSpatialIndex.spatialJoin(SpatialJavaRDD<T2> rdd2, <any> f, SpatialOperationConfig spatialOpConf)
Joins records from the current index with records of the passed spatial RDD.
|
Modifier and Type | Method and Description |
---|---|
SpatialJavaRDD<T> |
QuadTreeDistIndex.filter(<any> filterFunc) |
SpatialJavaRDD<T> |
QuadTreeDistIndex.filter(<any> filterFunc, SpatialOperationConfig spatialOpConf) |
SpatialJavaRDD<T> |
QuadTreeDistIndex.primaryFilter(<any> filterFunc, SpatialOperationConfig spatialOpConf) |
Modifier and Type | Method and Description |
---|---|
<T2,R> <any> |
QuadTreeDistIndex.join(SpatialJavaRDD<T2> rdd2, <any> f, SpatialOperationConfig spatialOpConf) |
static <V> SpatialJavaPairRDD<PartitionKey,V> |
QuadTreePartitioning.partition(SpatialJavaRDD<V> rdd, oracle.spatial.spark.vector.index.quadtree.QuadTreePartition rootPart, JavaSparkContext sc) |
<T2,R> <any> |
QuadTreeDistIndex.spatialJoin(SpatialJavaRDD<T2> rdd2, <any> f, SpatialOperationConfig spatialOpConf) |
Constructor and Description |
---|
QuadTreePartitioning(JavaSparkContext sc, SpatialJavaRDD<T> rdd, QuadTreeConfiguration quadTreConf)
Creates a new instance and partitions the given RDD using the given configuration
|
Modifier and Type | Method and Description |
---|---|
SpatialJavaRDD<T> |
SpatialJavaRDD.filter(<any> f, SpatialOperationConfig spatialOpConf)
Returns a new spatial RDD containing only the elements that satisfy both, the filtering function and the spatial operation
|
static <T> SpatialJavaRDD<SparkRecordInfo> |
SpatialJavaRDD.fromJavaRDD(<any> rdd, SparkRecordInfoProvider<T> recordInfoProvider)
Creates a spatial RDD of type SparkRecordInfo from the given rdd.
|
static <T> SpatialJavaRDD<T> |
SpatialJavaRDD.fromJavaRDD(<any> rdd, SparkRecordInfoProvider<T> recordInfoProvider, java.lang.Class<T> recordType)
Creates a spatial RDD from the given java rdd.
|
static <T> SpatialJavaRDD<T> |
SpatialJavaRDD.fromRDD(<any> rdd, SparkRecordInfoProvider<T> recordInfoProvider)
Creates a spatial RDD from the given rdd.
|
Modifier and Type | Method and Description |
---|---|
static <T> <any> |
SpatialJavaRDDConversions.toDataFrame(SpatialJavaRDD<T> spatialRDD, java.util.List<java.lang.String> nonSpatialFieldsNames, SparkSession spark)
Transforms a spatial RDD to a DataFrame (Dataset<Row>)
|
Modifier and Type | Method and Description |
---|---|
static SpatialJavaRDD<SparkRecordInfo> |
JDBCUtils.createSpatialRDDFromQuery(JavaSparkContext sc, JDBCUtils.ConnectionSupplier getConnection, java.lang.String sql, SparkRecordInfoProvider<java.sql.ResultSet> recordInfoProvider)
Creates a Spatial RDD given a SQL query to a database.
|
static SpatialJavaRDD<SparkRecordInfo> |
JDBCUtils.createSpatialRDDFromQuery(JavaSparkContext sc, JDBCUtils.ConnectionSupplier getConnection, java.lang.String sql, SparkRecordInfoProvider<java.sql.ResultSet> recordInfoProvider, long rowsPerPartition)
Creates a Spatial RDD given a SQL query to a database.
|
static SpatialJavaRDD<SparkRecordInfo> |
JDBCUtils.createSpatialRDDFromTable(JavaSparkContext sc, JDBCUtils.ConnectionSupplier getConnection, java.lang.String tableName, java.util.List<java.lang.String> fields, SparkRecordInfoProvider<java.sql.ResultSet> recordInfoProvider)
Creates a Spatial RDD given the name of a table and the fields to be selected.
|
static SpatialJavaRDD<SparkRecordInfo> |
JDBCUtils.createSpatialRDDFromTable(JavaSparkContext sc, JDBCUtils.ConnectionSupplier getConnection, java.lang.String tableName, java.util.List<java.lang.String> fields, SparkRecordInfoProvider<java.sql.ResultSet> recordInfoProvider, long rowsPerPartition)
Creates a Spatial RDD given the name of a table and the fields to be selected.
|
Copyright © 2017, 2019 Oracle and/or its affiliates. All Rights Reserved.