| Class | Description |
|---|---|
| SparkPipelinePluginContext |
Wraps spark specific plugin types.
|
| WrappedJavaSparkMain |
Wrapper around a
JavaSparkMain that makes sure logging, classloading, and other pipeline capabilities
are setup correctly. |
| WrappedSparkCompute<IN,OUT> |
Wrapper around a
SparkCompute that makes sure logging, classloading, and other pipeline capabilities
are setup correctly. |
| WrappedSparkSink<IN> |
Wrapper around a
SparkCompute that makes sure logging, classloading, and other pipeline capabilities
are setup correctly. |
| WrappedStreamingSource<T> |
Wrapper around a
Windower that makes sure logging, classloading, and other pipeline capabilities
are setup correctly. |
| WrappedWindower |
Wrapper around a
Windower that makes sure logging, classloading, and other pipeline capabilities
are setup correctly. |
Copyright © 2018 Cask Data, Inc. Licensed under the Apache License, Version 2.0.