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

MongoFlow

object MongoFlow

Source: MongoFlow.scala

Linear Supertypes

AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

MongoFlow
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): Flow[Bson, Pair[DeleteResult, Bson], NotUsed]
A Flow that will delete many documents as defined by a Bson filter query.
A Flow 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]): Flow[Bson, Pair[DeleteResult, Bson], NotUsed]
A Flow that will delete many documents as defined by a Bson filter query.
A Flow 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): Flow[Bson, Pair[DeleteResult, Bson], NotUsed]
A Flow that will delete individual documents as defined by a Bson filter query.
A Flow 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]): Flow[Bson, Pair[DeleteResult, Bson], NotUsed]
A Flow that will delete individual documents as defined by a Bson filter query.
A Flow 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): Flow[List[T], List[T], NotUsed]
A Flow that will insert batches of documents into a collection.
A Flow 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]): Flow[List[T], List[T], NotUsed]
A Flow that will insert batches of documents into a collection.
A Flow that will insert batches of documents into a collection.
collection
mongo db collection to insert to.
def insertOne[T](collection: MongoCollection[T], options: InsertOneOptions): Flow[T, T, NotUsed]
A Flow that will insert documents into a collection.
A Flow 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]): Flow[T, T, NotUsed]
A Flow that will insert documents into a collection.
A Flow 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 = DefaultReplaceOptions): Flow[DocumentReplace[T], Pair[UpdateResult, DocumentReplace[T]], NotUsed]
A Flow that will replace document as defined by a DocumentReplace.
A Flow that will replace document as defined by a DocumentReplace.
collection
the mongo db collection to update.
options
options to apply to the operation
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 = DefaultUpdateOptions): Flow[DocumentUpdate, Pair[UpdateResult, DocumentUpdate], NotUsed]
A Flow that will update many documents as defined by a DocumentUpdate.
A Flow 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]): Flow[DocumentUpdate, Pair[UpdateResult, DocumentUpdate], NotUsed]
A Flow that will update many documents as defined by a DocumentUpdate.
A Flow 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): Flow[DocumentUpdate, Pair[UpdateResult, DocumentUpdate], NotUsed]
A Flow that will update documents as defined by a DocumentUpdate.
A Flow that will update documents as defined by a DocumentUpdate.
collection
the mongo db collection to update.
options
options to apply to the operation
def updateOne[T](collection: MongoCollection[T]): Flow[DocumentUpdate, Pair[UpdateResult, DocumentUpdate], NotUsed]
A Flow that will update documents as defined by a DocumentUpdate.
A Flow that will update documents as defined by a 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): Flow[Bson, Pair[DeleteResult, Bson], NotUsed]
A Flow that will delete many documents as defined by a Bson filter query.
A Flow 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]): Flow[Bson, Pair[DeleteResult, Bson], NotUsed]
A Flow that will delete many documents as defined by a Bson filter query.
A Flow 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): Flow[Bson, Pair[DeleteResult, Bson], NotUsed]
A Flow that will delete individual documents as defined by a Bson filter query.
A Flow 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]): Flow[Bson, Pair[DeleteResult, Bson], NotUsed]
A Flow that will delete individual documents as defined by a Bson filter query.
A Flow 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): Flow[List[T], List[T], NotUsed]
A Flow that will insert batches of documents into a collection.
A Flow 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]): Flow[List[T], List[T], NotUsed]
A Flow that will insert batches of documents into a collection.
A Flow that will insert batches of documents into a collection.
collection
mongo db collection to insert to.
def insertOne[T](collection: MongoCollection[T], options: InsertOneOptions): Flow[T, T, NotUsed]
A Flow that will insert documents into a collection.
A Flow 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]): Flow[T, T, NotUsed]
A Flow that will insert documents into a collection.
A Flow 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 = DefaultReplaceOptions): Flow[DocumentReplace[T], Pair[UpdateResult, DocumentReplace[T]], NotUsed]
A Flow that will replace document as defined by a DocumentReplace.
A Flow that will replace document as defined by a DocumentReplace.
collection
the mongo db collection to update.
options
options to apply to the operation
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 = DefaultUpdateOptions): Flow[DocumentUpdate, Pair[UpdateResult, DocumentUpdate], NotUsed]
A Flow that will update many documents as defined by a DocumentUpdate.
A Flow 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]): Flow[DocumentUpdate, Pair[UpdateResult, DocumentUpdate], NotUsed]
A Flow that will update many documents as defined by a DocumentUpdate.
A Flow 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): Flow[DocumentUpdate, Pair[UpdateResult, DocumentUpdate], NotUsed]
A Flow that will update documents as defined by a DocumentUpdate.
A Flow that will update documents as defined by a DocumentUpdate.
collection
the mongo db collection to update.
options
options to apply to the operation
def updateOne[T](collection: MongoCollection[T]): Flow[DocumentUpdate, Pair[UpdateResult, DocumentUpdate], NotUsed]
A Flow that will update documents as defined by a DocumentUpdate.
A Flow that will update documents as defined by a 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

MongoFlow

object MongoFlow

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

Packages

MongoFlow

object MongoFlow

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

MongoFlow