org.apache.pekko.stream.connectors.mongodb.javadsl

MongoSink

object MongoSink

Source: MongoSink.scala

Linear Supertypes

AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

MongoSink
AnyRef
Any

Hide All
Show All

Visibility

Public
Protected

Value Members

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0
Definition Classes
Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native()
def deleteMany[T](collection: MongoCollection[T], options: DeleteOptions): Sink[Bson, CompletionStage[Done]]
A Sink that will delete many documents as defined by a Bson filter query.
A Sink that will delete many documents as defined by a Bson filter query.
collection
the mongo db collection to update.
options
options to apply to the operation
def deleteMany[T](collection: MongoCollection[T]): Sink[Bson, CompletionStage[Done]]
A Sink that will delete many documents as defined by a Bson filter query.
A Sink that will delete many documents as defined by a Bson filter query.
collection
the mongo db collection to update.
def deleteOne[T](collection: MongoCollection[T], options: DeleteOptions): Sink[Bson, CompletionStage[Done]]
A Sink that will delete individual documents as defined by a Bson filter query.
A Sink that will delete individual documents as defined by a Bson filter query.
collection
the mongo db collection to update.
options
options to apply to the operation
def deleteOne[T](collection: MongoCollection[T]): Sink[Bson, CompletionStage[Done]]
A Sink that will delete individual documents as defined by a Bson filter query.
A Sink that will delete individual documents as defined by a Bson filter query.
collection
the mongo db collection to update.
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable])
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native()
def insertMany[T](collection: MongoCollection[T], options: InsertManyOptions): Sink[List[T], CompletionStage[Done]]
A Sink that will insert batches of documents into a collection.
A Sink that will insert batches of documents into a collection.
collection
mongo db collection to insert to.
options
options to apply to the operation
def insertMany[T](collection: MongoCollection[T]): Sink[List[T], CompletionStage[Done]]
A Sink that will insert batches of documents into a collection.
A Sink that will insert batches of documents into a collection.
collection
mongo db collection to insert to.
def insertOne[T](collection: MongoCollection[T], options: InsertOneOptions): Sink[T, CompletionStage[Done]]
A Sink that will insert documents into a collection.
A Sink that will insert documents into a collection.
collection
mongo db collection to insert to.
options
options to apply to the operation
def insertOne[T](collection: MongoCollection[T]): Sink[T, CompletionStage[Done]]
A Sink that will insert documents into a collection.
A Sink that will insert documents into a collection.
collection
mongo db collection to insert to.
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native()
def replaceOne[T](collection: MongoCollection[T], options: ReplaceOptions): Sink[DocumentReplace[T], CompletionStage[Done]]
A Sink that will replace document as defined by a pekko.stream.connectors.mongodb.DocumentReplace.
A Sink that will replace document as defined by a pekko.stream.connectors.mongodb.DocumentReplace.
collection
the mongo db collection to update.
options
options to apply to the operation
def replaceOne[T](collection: MongoCollection[T]): Sink[DocumentReplace[T], CompletionStage[Done]]
A Sink that will replace document as defined by a pekko.stream.connectors.mongodb.DocumentReplace.
A Sink that will replace document as defined by a pekko.stream.connectors.mongodb.DocumentReplace.
collection
the mongo db collection to update.
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
def updateMany[T](collection: MongoCollection[T], options: UpdateOptions): Sink[DocumentUpdate, CompletionStage[Done]]
A Sink that will update many documents as defined by a DocumentUpdate.
A Sink that will update many documents as defined by a DocumentUpdate.
collection
the mongo db collection to update.
options
options to apply to the operation
def updateMany[T](collection: MongoCollection[T]): Sink[DocumentUpdate, CompletionStage[Done]]
A Sink that will update many documents as defined by a DocumentUpdate.
A Sink that will update many documents as defined by a DocumentUpdate.
collection
the mongo db collection to update.
def updateOne[T](collection: MongoCollection[T], options: UpdateOptions): Sink[DocumentUpdate, CompletionStage[Done]]
A Sink that will update documents as defined by a pekko.stream.connectors.mongodb.DocumentUpdate.
A Sink that will update documents as defined by a pekko.stream.connectors.mongodb.DocumentUpdate.
collection
the mongo db collection to update.
options
options to apply to the operation
def updateOne[T](collection: MongoCollection[T]): Sink[DocumentUpdate, CompletionStage[Done]]
A Sink that will update documents as defined by a pekko.stream.connectors.mongodb.DocumentUpdate.
A Sink that will update documents as defined by a pekko.stream.connectors.mongodb.DocumentUpdate.
collection
the mongo db collection to update.
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()

Ungrouped

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0
Definition Classes
Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native()
def deleteMany[T](collection: MongoCollection[T], options: DeleteOptions): Sink[Bson, CompletionStage[Done]]
A Sink that will delete many documents as defined by a Bson filter query.
A Sink that will delete many documents as defined by a Bson filter query.
collection
the mongo db collection to update.
options
options to apply to the operation
def deleteMany[T](collection: MongoCollection[T]): Sink[Bson, CompletionStage[Done]]
A Sink that will delete many documents as defined by a Bson filter query.
A Sink that will delete many documents as defined by a Bson filter query.
collection
the mongo db collection to update.
def deleteOne[T](collection: MongoCollection[T], options: DeleteOptions): Sink[Bson, CompletionStage[Done]]
A Sink that will delete individual documents as defined by a Bson filter query.
A Sink that will delete individual documents as defined by a Bson filter query.
collection
the mongo db collection to update.
options
options to apply to the operation
def deleteOne[T](collection: MongoCollection[T]): Sink[Bson, CompletionStage[Done]]
A Sink that will delete individual documents as defined by a Bson filter query.
A Sink that will delete individual documents as defined by a Bson filter query.
collection
the mongo db collection to update.
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable])
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native()
def insertMany[T](collection: MongoCollection[T], options: InsertManyOptions): Sink[List[T], CompletionStage[Done]]
A Sink that will insert batches of documents into a collection.
A Sink that will insert batches of documents into a collection.
collection
mongo db collection to insert to.
options
options to apply to the operation
def insertMany[T](collection: MongoCollection[T]): Sink[List[T], CompletionStage[Done]]
A Sink that will insert batches of documents into a collection.
A Sink that will insert batches of documents into a collection.
collection
mongo db collection to insert to.
def insertOne[T](collection: MongoCollection[T], options: InsertOneOptions): Sink[T, CompletionStage[Done]]
A Sink that will insert documents into a collection.
A Sink that will insert documents into a collection.
collection
mongo db collection to insert to.
options
options to apply to the operation
def insertOne[T](collection: MongoCollection[T]): Sink[T, CompletionStage[Done]]
A Sink that will insert documents into a collection.
A Sink that will insert documents into a collection.
collection
mongo db collection to insert to.
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native()
def replaceOne[T](collection: MongoCollection[T], options: ReplaceOptions): Sink[DocumentReplace[T], CompletionStage[Done]]
A Sink that will replace document as defined by a pekko.stream.connectors.mongodb.DocumentReplace.
A Sink that will replace document as defined by a pekko.stream.connectors.mongodb.DocumentReplace.
collection
the mongo db collection to update.
options
options to apply to the operation
def replaceOne[T](collection: MongoCollection[T]): Sink[DocumentReplace[T], CompletionStage[Done]]
A Sink that will replace document as defined by a pekko.stream.connectors.mongodb.DocumentReplace.
A Sink that will replace document as defined by a pekko.stream.connectors.mongodb.DocumentReplace.
collection
the mongo db collection to update.
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
def updateMany[T](collection: MongoCollection[T], options: UpdateOptions): Sink[DocumentUpdate, CompletionStage[Done]]
A Sink that will update many documents as defined by a DocumentUpdate.
A Sink that will update many documents as defined by a DocumentUpdate.
collection
the mongo db collection to update.
options
options to apply to the operation
def updateMany[T](collection: MongoCollection[T]): Sink[DocumentUpdate, CompletionStage[Done]]
A Sink that will update many documents as defined by a DocumentUpdate.
A Sink that will update many documents as defined by a DocumentUpdate.
collection
the mongo db collection to update.
def updateOne[T](collection: MongoCollection[T], options: UpdateOptions): Sink[DocumentUpdate, CompletionStage[Done]]
A Sink that will update documents as defined by a pekko.stream.connectors.mongodb.DocumentUpdate.
A Sink that will update documents as defined by a pekko.stream.connectors.mongodb.DocumentUpdate.
collection
the mongo db collection to update.
options
options to apply to the operation
def updateOne[T](collection: MongoCollection[T]): Sink[DocumentUpdate, CompletionStage[Done]]
A Sink that will update documents as defined by a pekko.stream.connectors.mongodb.DocumentUpdate.
A Sink that will update documents as defined by a pekko.stream.connectors.mongodb.DocumentUpdate.
collection
the mongo db collection to update.
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()

Packages

MongoSink

object MongoSink

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

Packages

MongoSink

object MongoSink

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

MongoSink