package streaming
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
-
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.
- class CouchbaseSource extends Source with Logging
-
case class
CouchbaseSourceOffset(partitionToOffsets: Map[Short, Long]) extends Offset with Product with Serializable
An Offset for the CouchbaseSource.
Value Members
- object CouchbaseSource
-
object
CouchbaseSourceOffset extends Serializable
Companion object of the CouchbaseSourceOffset.
- object JsonUtils