Packages

object CouchbaseSink

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. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def exists[T](applyId: Function[T, String], asyncCollection: AsyncCollection): Sink[T, CompletionStage[Boolean]]

    reference to CouchbaseFlow.exists

    reference to CouchbaseFlow.exists

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #existsFuture which works like this method worked in 1.x.

  9. def exists[T](applyId: Function[T, String], existsOptions: ExistsOptions, asyncCollection: AsyncCollection): Sink[T, CompletionStage[Boolean]]

    reference to CouchbaseFlow.exists

    reference to CouchbaseFlow.exists

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #existsFuture which works like this method worked in 1.x.

  10. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  12. def insert[T](applyId: Function[T, String], asyncCollection: AsyncCollection): Sink[T, CompletionStage[Done]]

    reference to CouchbaseFlow.insert

    reference to CouchbaseFlow.insert

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #insertFuture which works like this method worked in 1.x.

  13. def insert[T](applyId: Function[T, String], insertOptions: InsertOptions, asyncCollection: AsyncCollection): Sink[T, CompletionStage[Done]]

    reference to CouchbaseFlow.insert

    reference to CouchbaseFlow.insert

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #insertFuture which works like this method worked in 1.x.

  14. def insertDoc[T](asyncCollection: AsyncCollection): Sink[MutationDocument[T], CompletionStage[Done]]

    reference to CouchbaseFlow.insertDoc

    reference to CouchbaseFlow.insertDoc

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #insertDocFuture which works like this method worked in 1.x.

  15. def insertDoc[T](insertOptions: InsertOptions, asyncCollection: AsyncCollection): Sink[MutationDocument[T], CompletionStage[Done]]

    reference to CouchbaseFlow.insertDoc

    reference to CouchbaseFlow.insertDoc

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #insertDocFuture which works like this method worked in 1.x.

  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  20. def remove[T](applyId: Function[T, String], asyncCollection: AsyncCollection): Sink[T, CompletionStage[Done]]

    reference to CouchbaseFlow.remove

    reference to CouchbaseFlow.remove

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #removeFuture which works like this method worked in 1.x.

  21. def remove[T](applyId: Function[T, String], removeOptions: RemoveOptions, asyncCollection: AsyncCollection): Sink[T, CompletionStage[Done]]

    reference to CouchbaseFlow.remove

    reference to CouchbaseFlow.remove

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #removeFuture which works like this method worked in 1.x.

  22. def replace[T](applyId: Function[T, String], asyncCollection: AsyncCollection): Sink[T, CompletionStage[Done]]

    reference to CouchbaseFlow.replace

    reference to CouchbaseFlow.replace

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #replaceFuture which works like this method worked in 1.x.

  23. def replace[T](applyId: Function[T, String], replaceOptions: ReplaceOptions, asyncCollection: AsyncCollection): Sink[T, CompletionStage[Done]]

    reference to CouchbaseFlow.replace

    reference to CouchbaseFlow.replace

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #replaceFuture which works like this method worked in 1.x.

  24. def replaceDoc[T](asyncCollection: AsyncCollection): Sink[MutationDocument[T], CompletionStage[Done]]

    reference to CouchbaseFlow.replaceDoc

    reference to CouchbaseFlow.replaceDoc

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #replaceDocFuture which works like this method worked in 1.x.

  25. def replaceDoc[T](replaceOptions: ReplaceOptions, asyncCollection: AsyncCollection): Sink[MutationDocument[T], CompletionStage[Done]]

    reference to CouchbaseFlow.replaceDoc

    reference to CouchbaseFlow.replaceDoc

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #replaceDocFuture which works like this method worked in 1.x.

  26. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  27. def toString(): String
    Definition Classes
    AnyRef → Any
  28. def upsert[T](applyId: Function[T, String], asyncCollection: AsyncCollection): Sink[T, CompletionStage[Done]]

    reference to CouchbaseFlow.upsert

    reference to CouchbaseFlow.upsert

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #upsertFuture which works like this method worked in 1.x.

  29. def upsert[T](applyId: Function[T, String], upsertOptions: UpsertOptions, asyncCollection: AsyncCollection): Sink[T, CompletionStage[Done]]

    reference to CouchbaseFlow.upsert

    reference to CouchbaseFlow.upsert

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #upsertFuture which works like this method worked in 1.x.

  30. def upsertDoc[T](asyncCollection: AsyncCollection): Sink[MutationDocument[T], CompletionStage[Done]]

    reference to CouchbaseFlow.upsertDoc

    reference to CouchbaseFlow.upsertDoc

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #upsertDocFuture which works like this method worked in 1.x.

  31. def upsertDoc[T](upsertOptions: UpsertOptions, asyncCollection: AsyncCollection): Sink[MutationDocument[T], CompletionStage[Done]]

    reference to CouchbaseFlow.upsertDoc

    reference to CouchbaseFlow.upsertDoc

    This function's return type changed in 2.0.0 to return a Sink with a CompletionStage instead of a Scala Future, to be more consistent with Java usage.

    See also

    #upsertDocFuture which works like this method worked in 1.x.

  32. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  33. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  34. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def existsFuture[T](applyId: (T) => String, existsOptions: ExistsOptions = ExistsOptions.existsOptions())(implicit asyncCollection: AsyncCollection): Sink[T, Future[Boolean]]

    reference to CouchbaseFlow.exists

    reference to CouchbaseFlow.exists

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) Use exists which returns CompletionStage instead

  2. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

  3. def insertDocFuture[T](insertOptions: InsertOptions)(implicit asyncCollection: AsyncCollection): Sink[MutationDocument[T], Future[Done]]

    reference to CouchbaseFlow.insertDoc

    reference to CouchbaseFlow.insertDoc

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) Use insertDoc which returns CompletionStage instead

  4. def insertFuture[T](applyId: (T) => String, insertOptions: InsertOptions)(implicit asyncCollection: AsyncCollection): Sink[T, Future[Done]]

    reference to CouchbaseFlow.insert

    reference to CouchbaseFlow.insert

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) Use insert which returns CompletionStage instead

  5. def removeFuture[T](applyId: (T) => String, removeOptions: RemoveOptions = RemoveOptions.removeOptions())(implicit asyncCollection: AsyncCollection): Sink[T, Future[Done]]

    reference to CouchbaseFlow.remove

    reference to CouchbaseFlow.remove

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) Use remove which returns CompletionStage instead

  6. def replaceDocFuture[T](replaceOptions: ReplaceOptions = ReplaceOptions.replaceOptions())(implicit asyncCollection: AsyncCollection): Sink[MutationDocument[T], Future[Done]]

    reference to CouchbaseFlow.replaceDoc

    reference to CouchbaseFlow.replaceDoc

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) Use replaceDoc which returns CompletionStage instead

  7. def replaceFuture[T](applyId: (T) => String, replaceOptions: ReplaceOptions = ReplaceOptions.replaceOptions())(implicit asyncCollection: AsyncCollection): Sink[T, Future[Done]]

    reference to CouchbaseFlow.replace

    reference to CouchbaseFlow.replace

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) Use replace which returns CompletionStage instead

  8. def upsertDocFuture[T](upsertOptions: UpsertOptions = UpsertOptions.upsertOptions())(implicit asyncCollection: AsyncCollection): Sink[MutationDocument[T], Future[Done]]

    reference to CouchbaseFlow.upsertDoc

    reference to CouchbaseFlow.upsertDoc

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) Use upsertDoc which returns CompletionStage instead

  9. def upsertFuture[T](applyId: (T) => String, upsertOptions: UpsertOptions = UpsertOptions.upsertOptions())(implicit asyncCollection: AsyncCollection): Sink[T, Future[Done]]

    reference to CouchbaseFlow.upsert

    reference to CouchbaseFlow.upsert

    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) Use upsert which returns CompletionStage instead

Inherited from AnyRef

Inherited from Any

Ungrouped