diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-01-14 10:03:55 -0800 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-01-14 10:03:55 -0800 |
| commit | d182a57cae6455804773db23d9498d2dcdd02172 (patch) | |
| tree | 752672f24f4fa831043767d97512d9f729a3b22d /examples/src | |
| parent | a292ed8d8af069ee1318cdf7c00d3db8d3ba8db9 (diff) | |
| download | spark-d182a57cae6455804773db23d9498d2dcdd02172.tar.gz spark-d182a57cae6455804773db23d9498d2dcdd02172.tar.bz2 spark-d182a57cae6455804773db23d9498d2dcdd02172.zip | |
Two changes:
- Updating countByX() types based on bug fix
- Porting new documentation to Java
Diffstat (limited to 'examples/src')
| -rw-r--r-- | examples/src/main/scala/spark/streaming/examples/JavaFlumeEventCount.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/examples/src/main/scala/spark/streaming/examples/JavaFlumeEventCount.java b/examples/src/main/scala/spark/streaming/examples/JavaFlumeEventCount.java index 6592d9bc2e..151b71eb81 100644 --- a/examples/src/main/scala/spark/streaming/examples/JavaFlumeEventCount.java +++ b/examples/src/main/scala/spark/streaming/examples/JavaFlumeEventCount.java @@ -38,9 +38,9 @@ public class JavaFlumeEventCount { flumeStream.count(); - flumeStream.count().map(new Function<Integer, String>() { + flumeStream.count().map(new Function<Long, String>() { @Override - public String call(Integer in) { + public String call(Long in) { return "Received " + in + " flume events."; } }).print(); |