| Class | Description |
|---|---|
| AnalyzeSpark |
AnalizeSpark: static methods for
analyzing and
processing
RDD<List<Writable>> and RDD<List<List<Writable>> |
| BaseFlatMapFunctionAdaptee<K,V> |
FlatMapFunction adapter to
hide incompatibilities between Spark 1.x and Spark 2.x
This class should be used instead of direct referral to FlatMapFunction
|
| BatchRecordTest |
Created by agibsonccc on 2/12/17.
|
| CSVRecordTest |
Created by agibsonccc on 2/12/17.
|
| CSVSparkTransform |
CSVSpark Transform runs
the actual
TransformProcess |
| CSVSparkTransformerTest |
Created by agibsonccc on 12/24/16.
|
| CSVSparkTransformServer |
A rest server for using an
TransformProcess based on simple
csv values and a schema via REST. |
| CSVSparkTransformServerTest |
Created by agibsonccc on 1/22/17.
|
| DataFrames |
Namespace for datavec
dataframe interop
|
| DataFramesTests | |
| DataRowsFacade |
Dataframe facade to hide incompatibilities between Spark 1.x and Spark 2.x
This class should be used instead of direct referral to DataFrame / Dataset
|
| ExecutionTest |
Created by Alex on 25/11/2016.
|
| FunctionUtil |
Utility methods for Routing
|
| Normalization |
Simple dataframe based normalization.
|
| NormalizationTests |
Created by agibsonccc on 10/22/16.
|
| SparkTransformExecutor |
Execute a datavec
transform process
on spark rdds.
|
| TestGeoTransforms |