Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/19535#discussion_r159020029
--- Diff: python/pyspark/streaming/flume.py ---
@@ -54,8 +54,13 @@ def createStream(ssc, hostname, port,
:param bodyDecoder: A function
Github user yhuai commented on a diff in the pull request:
https://github.com/apache/spark/pull/19535#discussion_r159019845
--- Diff: python/pyspark/streaming/flume.py ---
@@ -54,8 +54,13 @@ def createStream(ssc, hostname, port,
:param bodyDecoder: A function used to
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/19535#discussion_r159019418
--- Diff: python/pyspark/streaming/flume.py ---
@@ -54,8 +54,13 @@ def createStream(ssc, hostname, port,
:param bodyDecoder: A function
Github user yhuai commented on a diff in the pull request:
https://github.com/apache/spark/pull/19535#discussion_r159013024
--- Diff: python/pyspark/streaming/flume.py ---
@@ -54,8 +54,13 @@ def createStream(ssc, hostname, port,
:param bodyDecoder: A function used to
Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/19535
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/19535#discussion_r146024871
--- Diff: python/pyspark/streaming/kafka.py ---
@@ -58,6 +60,7 @@ def createStream(ssc, zkQuorum, groupId, topics,
kafkaParams=None,
Github user felixcheung commented on a diff in the pull request:
https://github.com/apache/spark/pull/19535#discussion_r146024844
--- Diff: python/pyspark/streaming/flume.py ---
@@ -56,6 +56,7 @@ def createStream(ssc, hostname, port,
.. note:: Deprecated in 2.3.0
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/19535#discussion_r145655586
--- Diff: python/pyspark/sql/functions.py ---
@@ -44,6 +45,14 @@ def _(col):
return _
+def _wrap_deprecated_function(func,
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/19535#discussion_r145648171
--- Diff: python/pyspark/mllib/classification.py ---
@@ -311,7 +311,7 @@ def train(cls, data, iterations=100, step=1.0,
miniBatchFraction=1.0,
