diff options
| author | aokolnychyi <okolnychyyanton@gmail.com> | 2016-11-29 13:49:39 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-11-29 13:49:39 +0000 |
| commit | f045d9dade66d44f5ca4768bfe6a484e9288ec8d (patch) | |
| tree | d73b817ac52e3bf89ee4038f0d7884b86d7e3196 /streaming | |
| parent | f830bb9170f6b853565d9dd30ca7418b93a54fe3 (diff) | |
| download | spark-f045d9dade66d44f5ca4768bfe6a484e9288ec8d.tar.gz spark-f045d9dade66d44f5ca4768bfe6a484e9288ec8d.tar.bz2 spark-f045d9dade66d44f5ca4768bfe6a484e9288ec8d.zip | |
[MINOR][DOCS] Updates to the Accumulator example in the programming guide. Fixed typos, AccumulatorV2 in Java
## What changes were proposed in this pull request?
This pull request contains updates to Scala and Java Accumulator code snippets in the programming guide.
- For Scala, the pull request fixes the signature of the 'add()' method in the custom Accumulator, which contained two params (as the old AccumulatorParam) instead of one (as in AccumulatorV2).
- The Java example was updated to use the AccumulatorV2 class since AccumulatorParam is marked as deprecated.
- Scala and Java examples are more consistent now.
## How was this patch tested?
This patch was tested manually by building the docs locally.
Author: aokolnychyi <okolnychyyanton@gmail.com>
Closes #16024 from aokolnychyi/fixed_accumulator_example.
Diffstat (limited to 'streaming')
0 files changed, 0 insertions, 0 deletions