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 pushBlock API.

  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 extends AnyRef

    A helper with set of defaults for supervisor strategy *