aboutsummaryrefslogtreecommitdiff
path: root/python/pyspark
diff options
context:
space:
mode:
authorPaavo <pparkkin@gmail.com>2015-06-10 23:17:42 +0100
committerSean Owen <sowen@cloudera.com>2015-06-10 23:17:42 +0100
commitb928f543845ddd39e914a0e8f0b0205fd86100c5 (patch)
tree6176fbb68e99ab03e5d4f057a07779c7e20d439a /python/pyspark
parent96a7c888d806adfdb2c722025a1079ed7eaa2052 (diff)
downloadspark-b928f543845ddd39e914a0e8f0b0205fd86100c5.tar.gz
spark-b928f543845ddd39e914a0e8f0b0205fd86100c5.tar.bz2
spark-b928f543845ddd39e914a0e8f0b0205fd86100c5.zip
[SPARK-8200] [MLLIB] Check for empty RDDs in StreamingLinearAlgorithm
Test cases for both StreamingLinearRegression and StreamingLogisticRegression, and code fix. Edit: This contribution is my original work and I license the work to the project under the project's open source license. Author: Paavo <pparkkin@gmail.com> Closes #6713 from pparkkin/streamingmodel-empty-rdd and squashes the following commits: ff5cd78 [Paavo] Update strings to use interpolation. db234cf [Paavo] Use !rdd.isEmpty. 54ad89e [Paavo] Test case for empty stream. 393e36f [Paavo] Ignore empty RDDs. 0bfc365 [Paavo] Test case for empty stream.
Diffstat (limited to 'python/pyspark')
0 files changed, 0 insertions, 0 deletions