org.locationtech.geowave.analytic.spark

Class GeoWaveIndexedRDD

java.lang.Object

org.locationtech.geowave.analytic.spark.GeoWaveIndexedRDD

All Implemented Interfaces:

Serializable

public class GeoWaveIndexedRDD
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GeoWaveIndexedRDD(GeoWaveRDD geowaveRDD, org.apache.spark.broadcast.Broadcast<NumericIndexStrategy> indexStrategy)

Method Summary

Modifier and Type	Method and Description
GeoWaveRDD	getGeoWaveRDD()
org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature>>	getIndexedFeatureRDD()
org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature>>	getIndexedFeatureRDD(double bufferAmount)
org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.locationtech.jts.geom.Geometry>>	getIndexedGeometryRDD()
org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.locationtech.jts.geom.Geometry>>	getIndexedGeometryRDD(double bufferAmount, boolean recalculate)
org.apache.spark.broadcast.Broadcast<NumericIndexStrategy>	getIndexStrategy()
void	reindex(org.apache.spark.broadcast.Broadcast<? extends NumericIndexStrategy> newIndexStrategy)
void	reset()

Methods inherited from class java.lang.Object

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

Constructor Detail

GeoWaveIndexedRDD

public GeoWaveIndexedRDD(GeoWaveRDD geowaveRDD,
                         org.apache.spark.broadcast.Broadcast<NumericIndexStrategy> indexStrategy)

Method Detail

reset

public void reset()

reindex

public void reindex(org.apache.spark.broadcast.Broadcast<? extends NumericIndexStrategy> newIndexStrategy)

getIndexedFeatureRDD

public org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature>> getIndexedFeatureRDD()

getIndexedFeatureRDD

public org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature>> getIndexedFeatureRDD(double bufferAmount)

getIndexedGeometryRDD

public org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.locationtech.jts.geom.Geometry>> getIndexedGeometryRDD()

getIndexedGeometryRDD

public org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.locationtech.jts.geom.Geometry>> getIndexedGeometryRDD(double bufferAmount,
                                                                                                                                               boolean recalculate)

getIndexStrategy

public org.apache.spark.broadcast.Broadcast<NumericIndexStrategy> getIndexStrategy()

getGeoWaveRDD

public GeoWaveRDD getGeoWaveRDD()