diff options
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala b/streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala index c3b28bd516..dcd698c860 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala @@ -70,10 +70,14 @@ import org.apache.spark.util.ClosureCleaner @Experimental sealed abstract class StateSpec[KeyType, ValueType, StateType, MappedType] extends Serializable { - /** Set the RDD containing the initial states that will be used by `mapWithState` */ + /** + * Set the RDD containing the initial states that will be used by `mapWithState` + */ def initialState(rdd: RDD[(KeyType, StateType)]): this.type - /** Set the RDD containing the initial states that will be used by `mapWithState` */ + /** + * Set the RDD containing the initial states that will be used by `mapWithState` + */ def initialState(javaPairRDD: JavaPairRDD[KeyType, StateType]): this.type /** |