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
|
CSVSparkTransform |
CSVSpark Transform runs
the actual
TransformProcess |
CSVSparkTransformServer |
A rest server for using an
TransformProcess based on simple
csv values and a schema via REST. |
DataFrames |
Namespace for datavec
dataframe interop
|
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
|
FunctionUtil |
Utility methods for Routing
|
ImageSparkTransform |
Created by kepricon on 17.
|
ImageSparkTransformServer |
Created by kepricon on 17.
|
Normalization |
Simple dataframe based normalization.
|
SparkTransformExecutor |
Execute a datavec
transform process
on spark rdds.
|
SparkTransformServer |
Created by kepricon on 17.
|
SparkTransformServerChooser |
Created by kepricon on 17.
|
Enum | Description |
---|---|
TransformDataType |
Created by kepricon on 17.
|