You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by td...@apache.org on 2015/02/27 22:01:48 UTC
spark git commit: [Streaming][Minor] Remove useless type signature of
Java Kafka direct stream API
Repository: spark
Updated Branches:
refs/heads/master d17cb2ba3 -> 5f7f3b938
[Streaming][Minor] Remove useless type signature of Java Kafka direct stream API
cc tdas .
Author: Saisai Shao <sa...@intel.com>
Closes #4817 from jerryshao/signature-minor-fix and squashes the following commits:
eebfaac [Saisai Shao] Remove useless type parameter
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/5f7f3b93
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/5f7f3b93
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/5f7f3b93
Branch: refs/heads/master
Commit: 5f7f3b938e1776168be866fc9ee87dc7494696cc
Parents: d17cb2b
Author: Saisai Shao <sa...@intel.com>
Authored: Fri Feb 27 13:01:42 2015 -0800
Committer: Tathagata Das <ta...@gmail.com>
Committed: Fri Feb 27 13:01:42 2015 -0800
----------------------------------------------------------------------
.../main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/5f7f3b93/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
----------------------------------------------------------------------
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
index 62a6595..5a9bd42 100644
--- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
+++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
@@ -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],
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org