Skip to content

Commit 5f7f3b9

Browse files
jerryshaotdas
authored andcommitted
[Streaming][Minor] Remove useless type signature of Java Kafka direct stream API
cc tdas . Author: Saisai Shao <[email protected]> Closes apache#4817 from jerryshao/signature-minor-fix and squashes the following commits: eebfaac [Saisai Shao] Remove useless type parameter
1 parent d17cb2b commit 5f7f3b9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -512,7 +512,7 @@ object KafkaUtils {
512512
* @param topics Names of the topics to consume
513513
*/
514514
@Experimental
515-
def createDirectStream[K, V, KD <: Decoder[K], VD <: Decoder[V], R](
515+
def createDirectStream[K, V, KD <: Decoder[K], VD <: Decoder[V]](
516516
jssc: JavaStreamingContext,
517517
keyClass: Class[K],
518518
valueClass: Class[V],

0 commit comments

Comments
 (0)