Package

com.couchbase.spark

streaming

Permalink

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]

    Permalink
  2. class CouchbaseReceiver extends Receiver[StreamMessage] with Logging

    Permalink
  3. class DStreamFunctions[D <: Document[_]] extends Serializable

    Permalink
  4. case class Deletion(key: Array[Byte], cas: Long, partition: Short, bySeqno: Long, revisionSeqno: Long, ackBytes: Int) extends StreamMessage with Product with Serializable

    Permalink
  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

    Permalink
  6. class SparkStreamingFunctions extends Serializable

    Permalink
  7. sealed class StreamFrom extends AnyRef

    Permalink
  8. abstract class StreamMessage extends AnyRef

    Permalink
  9. sealed class StreamTo extends AnyRef

    Permalink

Value Members

  1. object FromBeginning extends StreamFrom with Product with Serializable

    Permalink
  2. object FromNow extends StreamFrom with Product with Serializable

    Permalink
  3. object ToInfinity extends StreamTo with Product with Serializable

    Permalink
  4. object ToNow extends StreamTo with Product with Serializable

    Permalink
  5. implicit def toDStreamFunctions[D <: Document[_]](ds: DStream[D]): DStreamFunctions[D]

    Permalink
  6. implicit def toSparkStreamingFunctions(ssc: StreamingContext): SparkStreamingFunctions

    Permalink

Inherited from AnyRef

Inherited from Any

Ungrouped