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. class PartitionOffset extends Offset

    Permalink

Value Members

  1. object CouchbaseSource

    Permalink

Ungrouped