Package

com.couchbase.spark.sql

streaming

Permalink

package streaming

Visibility
  1. Public
  2. All

Type Members

  1. class CouchbaseSink extends Sink with Logging

    Permalink

    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

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

    Permalink

    An Offset for the CouchbaseSource.

Value Members

  1. object CouchbaseSource

    Permalink
  2. object CouchbaseSourceOffset extends Serializable

    Permalink

    Companion object of the CouchbaseSourceOffset.

  3. object JsonUtils

    Permalink

Ungrouped