Class | Description |
---|---|
KeplerCoGroupStub |
A Spark stub to run a Kepler workflow in a map after the cogroup operator.
|
KeplerCrossStub |
A Spark stub to run a Kepler workflow in a map after the cartesian operator.
|
KeplerMapStub |
A Spark Map stub that runs a Kepler workflow.
|
KeplerMatchStub |
A Spark stub to run a Kepler workflow in a map after the join/match operator.
|
KeplerPairFlatMapFunction<T,K,V> |
A Spark stub to run a Kepler workflow in a map.
|
KeplerReduceStub |
A Spark stub to run a Kepler workflow in a map after the groupByKey operator.
|
PairFlatMapFunctionBase<T,K,V> |
A base class for PairFlatMapFunctions used in Kepler.
|
ScriptEngineMapStub |
A Spark Map stub that executes a ScriptEngine.
|
ScriptEnginePairFlatMapFunction<T,K,V> |
A Spark stub base class for executing a ScriptEngine.
|
ScriptEngineReduceStub |
A Spark Reduce stub that executes a ScriptEngine.
|
StubUtilities |
A collection of utilities used by Kepler Spark stubs.
|