package streaming
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- streaming
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Type Members
- class CouchbaseInputDStream extends ReceiverInputDStream[StreamMessage]
- class CouchbaseReceiver extends Receiver[StreamMessage] with Logging
- class DStreamFunctions[D <: Document[_]] extends Serializable
- case class Deletion(key: Array[Byte], cas: Long, partition: Short, bySeqno: Long, revisionSeqno: Long, ackBytes: Int) extends StreamMessage with Product with Serializable
- case class Mutation(key: Array[Byte], content: Array[Byte], expiry: Integer, cas: Long, partition: Short, flags: Int, lockTime: Int, bySeqno: Long, revisionSeqno: Long, ackBytes: Int) extends StreamMessage with Product with Serializable
- class SparkStreamingFunctions extends Serializable
- sealed class StreamFrom extends AnyRef
- abstract class StreamMessage extends AnyRef
- sealed class StreamTo extends AnyRef
Value Members
- implicit def toDStreamFunctions[D <: Document[_]](ds: DStream[D]): DStreamFunctions[D]
- implicit def toSparkStreamingFunctions(ssc: StreamingContext): SparkStreamingFunctions
- object FromBeginning extends StreamFrom with Product with Serializable
- object FromNow extends StreamFrom with Product with Serializable
- object ToInfinity extends StreamTo with Product with Serializable
- object ToNow extends StreamTo with Product with Serializable