Packages

p

com.couchbase.spark

streaming

package streaming

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. streaming
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. class CouchbaseInputDStream extends ReceiverInputDStream[StreamMessage]
  2. class CouchbaseReceiver extends Receiver[StreamMessage] with Logging
  3. class DStreamFunctions[D <: Document[_]] extends Serializable
  4. case class Deletion(key: Array[Byte], cas: Long, partition: Short, bySeqno: Long, revisionSeqno: Long, ackBytes: Int) extends StreamMessage with Product with Serializable
  5. 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
  6. class SparkStreamingFunctions extends Serializable
  7. sealed class StreamFrom extends AnyRef
  8. abstract class StreamMessage extends AnyRef
  9. sealed class StreamTo extends AnyRef

Value Members

  1. implicit def toDStreamFunctions[D <: Document[_]](ds: DStream[D]): DStreamFunctions[D]
  2. implicit def toSparkStreamingFunctions(ssc: StreamingContext): SparkStreamingFunctions
  3. object FromBeginning extends StreamFrom with Product with Serializable
  4. object FromNow extends StreamFrom with Product with Serializable
  5. object ToInfinity extends StreamTo with Product with Serializable
  6. object ToNow extends StreamTo with Product with Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped