Spark 4.0.0 ScalaDoc - org.apache.spark.streaming.receiver.Receiver (original) (raw)

abstract class Receiver[T] extends Serializable

 

Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. Receiver

2. Serializable

3. AnyRef

4. Any

5. Hide All

6. Show All

Visibility

1. Public
2. Protected

Abstract Value Members

1.  abstract def onStart(): Unit
2.  abstract def onStop(): Unit

Concrete Value Members

1.  final def !=(arg0: Any): Boolean
2.  final def ##: Int
3.  final def ==(arg0: Any): Boolean
4.  final def asInstanceOf[T0]: T0
5.  def clone(): AnyRef
6.  final def eq(arg0: AnyRef): Boolean
7.  def equals(arg0: AnyRef): Boolean
8.  final def getClass(): Class[_ <: AnyRef]
9.  def hashCode(): Int
10.  final def isInstanceOf[T0]: Boolean
11.  def isStarted(): Boolean
12.  def isStopped(): Boolean
13.  final def ne(arg0: AnyRef): Boolean
14.  final def notify(): Unit
15.  final def notifyAll(): Unit
16.  def preferredLocation: Option[String]
17.  def reportError(message: String, throwable: Throwable): Unit
18.  def restart(message: String, error: Throwable, millisecond: Int): Unit
19.  def restart(message: String, error: Throwable): Unit
20.  def restart(message: String): Unit
21.  def stop(message: String, error: Throwable): Unit
22.  def stop(message: String): Unit
23.  val storageLevel: StorageLevel
24.  def store(bytes: ByteBuffer, metadata: Any): Unit
25.  def store(bytes: ByteBuffer): Unit
26.  def store(dataIterator: Iterator[T], metadata: Any): Unit
27.  def store(dataIterator: Iterator[T]): Unit
28.  def store(dataIterator: Iterator[T], metadata: Any): Unit
29.  def store(dataIterator: Iterator[T]): Unit
30.  def store(dataBuffer: ArrayBuffer[T], metadata: Any): Unit
31.  def store(dataBuffer: ArrayBuffer[T]): Unit
32.  def store(dataItem: T): Unit
33.  def streamId: Int
34.  final def synchronized[T0](arg0: => T0): T0
35.  def toString(): String
36.  final def wait(arg0: Long, arg1: Int): Unit
37.  final def wait(arg0: Long): Unit
38.  final def wait(): Unit

Deprecated Value Members

1.  def finalize(): Unit

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped