diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2014-01-14 00:05:37 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-01-14 00:05:37 -0800 |
| commit | 980250b1ee0cdba9cf06ea87c790a2d504bbf03e (patch) | |
| tree | 547a023f4a672ab84299762d71e40d19dc2cf92f /mllib/src/test/java/org | |
| parent | 055be5c6940a82e2d7fa39f968a434643a1eb1e2 (diff) | |
| parent | f8bd828c7ccf1ff69bc35bf95d07183cb35a7c72 (diff) | |
| download | spark-980250b1ee0cdba9cf06ea87c790a2d504bbf03e.tar.gz spark-980250b1ee0cdba9cf06ea87c790a2d504bbf03e.tar.bz2 spark-980250b1ee0cdba9cf06ea87c790a2d504bbf03e.zip | |
Merge pull request #416 from tdas/filestream-fix
Removed unnecessary DStream operations and updated docs
Removed StreamingContext.registerInputStream and registerOutputStream - they were useless. InputDStream has been made to register itself, and just registering a DStream as output stream cause RDD objects to be created but the RDDs will not be computed at all.. Also made DStream.register() private[streaming] for the same reasons.
Updated docs, specially added package documentation for streaming package.
Also, changed NetworkWordCount's input storage level to use MEMORY_ONLY, replication on the local machine causes warning messages (as replication fails) which is scary for a new user trying out his/her first example.
Diffstat (limited to 'mllib/src/test/java/org')
0 files changed, 0 insertions, 0 deletions