Skip to content

Commit 6f5c694

Browse files
committed
More nits
1 parent 495b982 commit 6f5c694

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

streaming/src/main/scala/org/apache/spark/streaming/StateSpec.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ import org.apache.spark.{HashPartitioner, Partitioner}
6060
* }
6161
* };
6262
*
63-
* JavaMapWithStateDStream<Integer, Integer, Integer, String> mapWithStateDStream =
63+
* JavaMapWithStateDStream<String, Integer, Integer, String> mapWithStateDStream =
6464
* keyValueDStream.<Integer, String>mapWithState(
6565
* StateSpec.function(mappingFunction).numPartitions(10));
6666
* }}}
@@ -136,7 +136,7 @@ sealed abstract class StateSpec[KeyType, ValueType, StateType, MappedType] exten
136136
* }
137137
* };
138138
*
139-
* JavaMapWithStateDStream<Integer, Integer, Integer, String> mapWithStateDStream =
139+
* JavaMapWithStateDStream<String, Integer, Integer, String> mapWithStateDStream =
140140
* keyValueDStream.<Integer, String>mapWithState(
141141
* StateSpec.function(mappingFunction).numPartitions(10));
142142
* }}}

streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaPairDStream.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -448,7 +448,7 @@ class JavaPairDStream[K, V](val dstream: DStream[(K, V)])(
448448
* }
449449
* };
450450
*
451-
* JavaMapWithStateDStream<Integer, Integer, Integer, String> mapWithStateDStream =
451+
* JavaMapWithStateDStream<String, Integer, Integer, String> mapWithStateDStream =
452452
* keyValueDStream.<Integer, String>mapWithState(
453453
* StateSpec.function(mappingFunction).numPartitions(10));
454454
* }}}

0 commit comments

Comments
 (0)