package
streaming
Type Members
-
-
-
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
-
-
sealed
class
StreamFrom extends AnyRef
-
abstract
class
StreamMessage extends AnyRef
-
sealed
class
StreamTo extends AnyRef
Inherited from AnyRef
Inherited from Any