Packages

package streaming

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class CouchbaseSink extends Sink with Logging

    A simple Structured Streaming sink which writes the data frame to the bucket.

    A simple Structured Streaming sink which writes the data frame to the bucket.

    Note that for now Upsert is always used internally to not run into document already exists exception, especially when writing aggregates.

  2. class CouchbaseSource extends Source with Logging
  3. case class CouchbaseSourceOffset(partitionToOffsets: Map[Short, Long]) extends Offset with Product with Serializable

    An Offset for the CouchbaseSource.

Value Members

  1. object CouchbaseSource
  2. object CouchbaseSourceOffset extends Serializable

    Companion object of the CouchbaseSourceOffset.

  3. object JsonUtils

Ungrouped