Skip to content

Commit

Permalink
[Streaming][Minor] Remove useless type signature of Java Kafka direct…
Browse files Browse the repository at this point in the history
… stream API

cc tdas .

Author: Saisai Shao <saisai.shao@intel.com>

Closes #4817 from jerryshao/signature-minor-fix and squashes the following commits:

eebfaac [Saisai Shao] Remove useless type parameter
  • Loading branch information
jerryshao authored and tdas committed Feb 27, 2015
1 parent d17cb2b commit 5f7f3b9
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -512,7 +512,7 @@ object KafkaUtils {
* @param topics Names of the topics to consume
*/
@Experimental
def createDirectStream[K, V, KD <: Decoder[K], VD <: Decoder[V], R](
def createDirectStream[K, V, KD <: Decoder[K], VD <: Decoder[V]](
jssc: JavaStreamingContext,
keyClass: Class[K],
valueClass: Class[V],
Expand Down

0 comments on commit 5f7f3b9

Please sign in to comment.