org.locationtech.geowave.analytic.spark

Class GeoWaveRDDLoader

java.lang.Object

org.locationtech.geowave.analytic.spark.GeoWaveRDDLoader

public class GeoWaveRDDLoader
extends Object

Constructor Summary

Constructors

Constructor and Description
GeoWaveRDDLoader()

Method Summary

Modifier and Type	Method and Description
static GeoWaveIndexedRDD	loadIndexedRDD(org.apache.spark.SparkContext sc, DataStorePluginOptions storeOptions, RDDOptions rddOpts, NumericIndexStrategy indexStrategy)
static GeoWaveIndexedRDD	loadIndexedRDD(org.apache.spark.SparkContext sc, GeoWaveRDD inputRDD, NumericIndexStrategy indexStrategy)
static org.apache.spark.api.java.JavaPairRDD<GeoWaveInputKey,org.opengis.coverage.grid.GridCoverage>	loadRawRasterRDD(org.apache.spark.SparkContext sc, DataStorePluginOptions storeOptions, String indexName, Integer minSplits, Integer maxSplits)
static org.apache.spark.api.java.JavaPairRDD<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature>	loadRawRDD(org.apache.spark.SparkContext sc, DataStorePluginOptions storeOptions, RDDOptions rddOpts)
static GeoWaveRDD	loadRDD(org.apache.spark.SparkContext sc, DataStorePluginOptions storeOptions)
static GeoWaveRDD	loadRDD(org.apache.spark.SparkContext sc, DataStorePluginOptions storeOptions, RDDOptions rddOpts)

Methods inherited from class java.lang.Object

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

Constructor Detail

GeoWaveRDDLoader

public GeoWaveRDDLoader()

Method Detail

loadRDD

public static GeoWaveRDD loadRDD(org.apache.spark.SparkContext sc,
                                 DataStorePluginOptions storeOptions)
                          throws IOException

Throws:

IOException

loadRDD

public static GeoWaveRDD loadRDD(org.apache.spark.SparkContext sc,
                                 DataStorePluginOptions storeOptions,
                                 RDDOptions rddOpts)
                          throws IOException

Throws:

IOException

loadIndexedRDD

public static GeoWaveIndexedRDD loadIndexedRDD(org.apache.spark.SparkContext sc,
                                               DataStorePluginOptions storeOptions,
                                               RDDOptions rddOpts,
                                               NumericIndexStrategy indexStrategy)
                                        throws IOException

Throws:

IOException

loadIndexedRDD

public static GeoWaveIndexedRDD loadIndexedRDD(org.apache.spark.SparkContext sc,
                                               GeoWaveRDD inputRDD,
                                               NumericIndexStrategy indexStrategy)
                                        throws IOException

Throws:

IOException

loadRawRDD

public static org.apache.spark.api.java.JavaPairRDD<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature> loadRawRDD(org.apache.spark.SparkContext sc,
                                                                                                                         DataStorePluginOptions storeOptions,
                                                                                                                         RDDOptions rddOpts)
                                                                                                                  throws IOException

Throws:

IOException

loadRawRasterRDD

public static org.apache.spark.api.java.JavaPairRDD<GeoWaveInputKey,org.opengis.coverage.grid.GridCoverage> loadRawRasterRDD(org.apache.spark.SparkContext sc,
                                                                                                                             DataStorePluginOptions storeOptions,
                                                                                                                             String indexName,
                                                                                                                             Integer minSplits,
                                                                                                                             Integer maxSplits)
                                                                                                                      throws IOException

Throws:

IOException