org.apache.spark.streaming

receivers

package receivers

Visibility
  1. Public
  2. All

Type Members

  1. trait Receiver extends AnyRef

    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. case class Statistics(numberOfMsgs: Int, numberOfWorkers: Int, numberOfHiccups: Int, otherInfo: String) extends Product with Serializable

    Statistics for querying the supervisor about state of workers.

Value Members

  1. object ReceiverSupervisorStrategy

    A helper with set of defaults for supervisor strategy

Ungrouped