diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2016-01-07 15:26:55 -0800 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2016-01-07 15:26:55 -0800 |
| commit | c0c397509bc909b9bf2d5186182f461155b021ab (patch) | |
| tree | 7e223edb4ee97eb0ac9bbd0e20a1fccac32e10be /streaming/src/test | |
| parent | 34dbc8af21da63702bc0694d471fbfee4cd08dda (diff) | |
| download | spark-c0c397509bc909b9bf2d5186182f461155b021ab.tar.gz spark-c0c397509bc909b9bf2d5186182f461155b021ab.tar.bz2 spark-c0c397509bc909b9bf2d5186182f461155b021ab.zip | |
[SPARK-12510][STREAMING] Refactor ActorReceiver to support Java
This PR includes the following changes:
1. Rename `ActorReceiver` to `ActorReceiverSupervisor`
2. Remove `ActorHelper`
3. Add a new `ActorReceiver` for Scala and `JavaActorReceiver` for Java
4. Add `JavaActorWordCount` example
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #10457 from zsxwing/java-actor-stream.
Diffstat (limited to 'streaming/src/test')
0 files changed, 0 insertions, 0 deletions