-
- Downloads
[SPARK-13069][STREAMING] Add "ask" style store() to ActorReciever
Introduces a "ask" style ```store``` in ```ActorReceiver``` as a way to allow actor receiver blocked by back pressure or maxRate. Author: Lin Zhao <lin@exabeam.com> Closes #11176 from lin-zhao/SPARK-13069.
Showing
- external/akka/src/main/scala/org/apache/spark/streaming/akka/ActorReceiver.scala 38 additions, 1 deletion...scala/org/apache/spark/streaming/akka/ActorReceiver.scala
- external/akka/src/test/java/org/apache/spark/streaming/akka/JavaAkkaUtilsSuite.java 2 additions, 0 deletions...a/org/apache/spark/streaming/akka/JavaAkkaUtilsSuite.java
- external/akka/src/test/scala/org/apache/spark/streaming/akka/AkkaUtilsSuite.scala 3 additions, 0 deletions...cala/org/apache/spark/streaming/akka/AkkaUtilsSuite.scala
Loading
Please register or sign in to comment