diff options
author | Yadong Qi <qiyadong2010@gmail.com> | 2015-01-02 15:09:41 -0800 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-01-02 15:09:41 -0800 |
commit | bd88b7185358ae60efc83dc6cbb3fb1d2bff6074 (patch) | |
tree | aa59d0302cd6dda73f527d9a76fb25030f745b4b /docs/streaming-kafka-integration.md | |
parent | 012839807c3dc6e7c8c41ac6e956d52a550bb031 (diff) | |
download | spark-bd88b7185358ae60efc83dc6cbb3fb1d2bff6074.tar.gz spark-bd88b7185358ae60efc83dc6cbb3fb1d2bff6074.tar.bz2 spark-bd88b7185358ae60efc83dc6cbb3fb1d2bff6074.zip |
[SPARK-3325][Streaming] Add a parameter to the method print in class DStream
This PR is a fixed version of the original PR #3237 by watermen and scwf.
This adds the ability to specify how many elements to print in `DStream.print`.
Author: Yadong Qi <qiyadong2010@gmail.com>
Author: q00251598 <qiyadong@huawei.com>
Author: Tathagata Das <tathagata.das1565@gmail.com>
Author: wangfei <wangfei1@huawei.com>
Closes #3865 from tdas/print-num and squashes the following commits:
cd34e9e [Tathagata Das] Fix bug
7c09f16 [Tathagata Das] Merge remote-tracking branch 'apache-github/master' into HEAD
bb35d1a [Yadong Qi] Update MimaExcludes.scala
f8098ca [Yadong Qi] Update MimaExcludes.scala
f6ac3cb [Yadong Qi] Update MimaExcludes.scala
e4ed897 [Yadong Qi] Update MimaExcludes.scala
3b9d5cf [wangfei] fix conflicts
ec8a3af [q00251598] move to Spark 1.3
26a70c0 [q00251598] extend the Python DStream's print
b589a4b [q00251598] add another print function
Diffstat (limited to 'docs/streaming-kafka-integration.md')
0 files changed, 0 insertions, 0 deletions