Packages

object CouchbaseSink

Java API: Factory methods for Couchbase sinks.

Source
CouchbaseSink.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CouchbaseSink
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def delete(sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Sink[String, CompletionStage[Done]]

    Create a sink to delete documents from Couchbase by id.

  2. def replace(sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Sink[JsonDocument, CompletionStage[Done]]

    Create a sink to replace a Couchbase JsonDocument.

  3. def replaceDoc[T <: Document[_]](sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Sink[T, CompletionStage[Done]]

    Create a sink to replace a Couchbase document of the given class.

  4. def upsert(sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Sink[JsonDocument, CompletionStage[Done]]

    Create a sink to update or insert a Couchbase JsonDocument.

  5. def upsertDoc[T <: Document[_]](sessionSettings: CouchbaseSessionSettings, writeSettings: CouchbaseWriteSettings, bucketName: String): Sink[T, CompletionStage[Done]]

    Create a sink to update or insert a Couchbase document of the given class.