package receiver

  1. Public
  2. All

Type Members

  1. trait ActorHelper extends Logging

    :: DeveloperApi :: A receiver trait to be mixed in with your Actor to gain access to the API for pushing received data into Spark Streaming for being processed.

  2. abstract class Receiver[T] extends Serializable

    :: DeveloperApi :: Abstract class of a receiver that can be run on worker nodes to receive external data.

  3. case class Statistics(numberOfMsgs: Int, numberOfWorkers: Int, numberOfHiccups: Int, otherInfo: String) extends Product with Serializable

    :: DeveloperApi :: Statistics for querying the supervisor about state of workers.

Value Members

  1. object ActorSupervisorStrategy

    :: DeveloperApi :: A helper with set of defaults for supervisor strategy