| Class | Description |
|---|---|
| DefaultStreamingContext |
Default implementation of StreamingContext for Spark.
|
| DStreamCollection<T> |
JavaDStream backed
SparkCollection |
| DynamicDriverContext |
Serializable context that can be used to dynamically instantiate plugins from a driver context.
|
| PairDStreamCollection<K,V> |
JavaPairDStream backed
SparkPairCollection |
| SparkStreamingExecutionContext |
Implementation of
SparkExecutionPluginContext by delegating to JavaSparkExecutionContext. |
Copyright © 2018 Cask Data, Inc. Licensed under the Apache License, Version 2.0.