object MongoSink extends MongoSinkImpl
Companion object and factory for building a predefined MongoSink.
The current sinks available are (delete, insert, replace and update),
all of them available for one and many elements at a time.
- Source
- MongoSink.scala
- Alphabetic
- By Inheritance
- MongoSink
- MongoSinkImpl
- AnyRef
- Any
- Hide All
- Show All
- 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
- def apply[Doc](collection: MongoCollection[Doc]): MongoSink[Doc]
- 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[Doc](collection: MongoCollection[Doc], deleteOptions: DeleteOptions = DefaultDeleteOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[Bson, Unit]
Provides a sink implementation for MongoSingle.deleteMany that per each element removes all documents from the collection that matched the given query filter.
Provides a sink implementation for MongoSingle.deleteMany that per each element removes all documents from the collection that matched the given query filter.
- Doc
the type of the collection
- collection
the abstraction to work with a determined MongoDB Collection
- deleteOptions
the options to apply to the delete operation, it will use default ones in case it is not passed by the user.
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that expects query filters to apply the delete many operations.
- Definition Classes
- MongoSink → MongoSinkImpl
- See also
com.mongodb.client.model.Filters
- def deleteManyPar[Doc](collection: MongoCollection[Doc], deleteOptions: DeleteOptions = DefaultDeleteOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[Seq[Bson], Unit]
Provides a sink implementation for MongoSingle.deleteMany that per each element removes all documents from the collection that matched the given query filter.
Provides a sink implementation for MongoSingle.deleteMany that per each element removes all documents from the collection that matched the given query filter. The sink requires a sequence of elements, whereas elements from a single sequence will be executed in parallel as a batch operation.
- Doc
the type of the collection
- collection
the abstraction to work with a determined MongoDB Collection
- deleteOptions
the options to apply to the delete operation, it will use default ones in case it is not passed by the user.
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that expects query filter sequences to apply the delete many operations.
- Definition Classes
- MongoSink → MongoSinkImpl
- See also
com.mongodb.client.model.Filters
- def deleteOne[Doc](collection: MongoCollection[Doc], deleteOptions: DeleteOptions = DefaultDeleteOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[Bson, Unit]
Provides a sink implementation for MongoSingle.deleteOne that for each incoming element will remove at most one document from the collection that matches the given filter.
Provides a sink implementation for MongoSingle.deleteOne that for each incoming element will remove at most one document from the collection that matches the given filter.
- Doc
the type of the collection
- collection
the abstraction to work with a determined MongoDB Collection
- deleteOptions
the options to apply to all the delete operations, it will use default ones in case it is not passed by the user
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that expects query filters to apply the delete operations.
- Definition Classes
- MongoSink → MongoSinkImpl
- See also
com.mongodb.client.model.Filters and com.mongodb.client.model.Updates
- def deleteOnePar[Doc](collection: MongoCollection[Doc], deleteOptions: DeleteOptions = DefaultDeleteOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[Seq[Bson], Unit]
Provides a sink implementation for MongoSingle.deleteOne that consumes a sequence of elements.
Provides a sink implementation for MongoSingle.deleteOne that consumes a sequence of elements. The elements inside a single sequence will be executed in parallel as a batch operation. For each incoming element will remove at most one document from the collection that matches the given filter.
- Doc
the type of the collection
- collection
the abstraction to work with a determined MongoDB Collection
- deleteOptions
the options to apply to all the delete operations, it will use default ones in case it is not passed by the user
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that expects sequences of query filters to apply the delete operations.
- Definition Classes
- MongoSink → MongoSinkImpl
- See also
com.mongodb.client.model.Filters and com.mongodb.client.model.Updates
- 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[Doc](collection: MongoCollection[Doc], insertManyOptions: InsertManyOptions = DefaultInsertManyOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[Seq[Doc], Unit]
Provides a sink implementation for MongoSingle.insertMany that expects batches of documents to be inserted at once.
Provides a sink implementation for MongoSingle.insertMany that expects batches of documents to be inserted at once. If the documents is missing an identifier, the driver should generate one.
- Doc
the type of the collection
- collection
the abstraction to work with the determined mongodb collection
- insertManyOptions
the options to apply to the insert operation
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that expects documents in batches of type Doc to be inserted.
- Definition Classes
- MongoSink → MongoSinkImpl
- def insertOne[Doc](collection: MongoCollection[Doc], insertOneOptions: InsertOneOptions = DefaultInsertOneOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[Doc, Unit]
Provides a sink implementation for MongoSingle.insertOne that expects documents to be passed and inserts them one by one.
Provides a sink implementation for MongoSingle.insertOne that expects documents to be passed and inserts them one by one. If the document is missing an identifier, the driver should generate one.
- Doc
the type of the collection and the incoming documents
- collection
the abstraction to work with the determined mongodb collection
- insertOneOptions
the options to apply all the insert operations
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that expects single documents of type Doc to be inserted.
- Definition Classes
- MongoSink → MongoSinkImpl
- def insertOnePar[Doc](collection: MongoCollection[Doc], insertOneOptions: InsertOneOptions = DefaultInsertOneOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[Seq[Doc], Unit]
Provides a sink implementation for MongoSingle.insertOne that expects sequences of documents to be passed and inserts all documents from a single sequence in parallel as a batch operation.
Provides a sink implementation for MongoSingle.insertOne that expects sequences of documents to be passed and inserts all documents from a single sequence in parallel as a batch operation. If the document is missing an identifier, the driver should generate one.
- Doc
the type of the collection and the incoming documents
- collection
the abstraction to work with the determined mongodb collection
- insertOneOptions
the options to apply all the insert operations
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that expects documents in batches of type Doc to be inserted.
- Definition Classes
- MongoSink → MongoSinkImpl
- 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[Doc](collection: MongoCollection[Doc], replaceOptions: ReplaceOptions = DefaultReplaceOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[(Bson, Doc), Unit]
Provides a sink implementation for MongoSingle.replaceOne that expects Tuple2 of a filter and the document replacement that for each element will execute the replace operation to a single filtered element.
Provides a sink implementation for MongoSingle.replaceOne that expects Tuple2 of a filter and the document replacement that for each element will execute the replace operation to a single filtered element.
- Doc
the type of the collection
- collection
the abstraction to work with the determined mongodb collection
- replaceOptions
the options to apply to the replace operation
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that expects a Tuple2 of a filter and a document of type Doc to be replaced.
- Definition Classes
- MongoSink → MongoSinkImpl
- See also
com.mongodb.client.model.Filters If the documents is missing an identifier, the driver should generate one.
- def replaceOnePar[Doc](collection: MongoCollection[Doc], replaceOptions: ReplaceOptions = DefaultReplaceOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[Seq[(Bson, Doc)], Unit]
Provides a sink implementation for MongoSingle.replaceOne that expects sequences of Tuple2 of a filter and the document replacement that for each element will execute the replace operation to a single filtered element.
Provides a sink implementation for MongoSingle.replaceOne that expects sequences of Tuple2 of a filter and the document replacement that for each element will execute the replace operation to a single filtered element. All elements inside a single sequence will be executed in parallel as a batch operation.
- Doc
the type of the collection
- collection
the abstraction to work with the determined mongodb collection
- replaceOptions
the options to apply to the replace operation
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that expects Tuple2 of filters and documents in batches of type Doc to be replaced.
- Definition Classes
- MongoSink → MongoSinkImpl
- See also
com.mongodb.client.model.Filters If the documents is missing an identifier, the driver should generate one.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def updateMany[Doc](collection: MongoCollection[Doc], updateOptions: UpdateOptions = DefaultUpdateOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[(Bson, Bson), Unit]
Provides a sink implementation for MongoSingle.updateOne that expects Tuple2 of a filter and update that will be executed against all the filtered elements.
Provides a sink implementation for MongoSingle.updateOne that expects Tuple2 of a filter and update that will be executed against all the filtered elements.
- Doc
the type of the collection
- collection
the abstraction to work with the determined mongodb collection
- updateOptions
the options to apply to the update operation
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that per each element expects Tuple2 of a filter and the update in form of Bson.
- Definition Classes
- MongoSink → MongoSinkImpl
- See also
com.mongodb.client.model.Filters and com.mongodb.client.model.Updates If the documents is missing an identifier, the driver should generate one.
- def updateManyPar[Doc](collection: MongoCollection[Doc], updateOptions: UpdateOptions = DefaultUpdateOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[Seq[(Bson, Bson)], Unit]
Provides a sink implementation for MongoSingle.updateOne that expects sequences of Tuple2 of a filter and update that will be executed against all the filtered elements.
Provides a sink implementation for MongoSingle.updateOne that expects sequences of Tuple2 of a filter and update that will be executed against all the filtered elements. All elements inside a single sequence will be executed in parallel as a batch operation.
- Doc
the type of the collection
- collection
the abstraction to work with the determined mongodb collection
- updateOptions
the options to apply to the update operation
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that per each element expects a batch of Tuple2 of a filter and the update in form of Bson.
- Definition Classes
- MongoSink → MongoSinkImpl
- See also
com.mongodb.client.model.Filters and com.mongodb.client.model.Updates If the documents is missing an identifier, the driver should generate one.
- def updateOne[Doc](collection: MongoCollection[Doc], updateOptions: UpdateOptions = DefaultUpdateOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[(Bson, Bson), Unit]
Provides a sink implementation for MongoSingle.updateOne that expects Tuple2 of a filter and a update that will be executed against the single filtered element.
Provides a sink implementation for MongoSingle.updateOne that expects Tuple2 of a filter and a update that will be executed against the single filtered element.
- Doc
the type of the collection
- collection
the abstraction to work with the determined mongodb collection
- updateOptions
the options to apply to the update operation
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that per each element expects a Tuple2 of a filter and the update in form of Bson.
- Definition Classes
- MongoSink → MongoSinkImpl
- See also
com.mongodb.client.model.Filters and com.mongodb.client.model.Updates If the documents is missing an identifier, the driver should generate one.
- def updateOnePar[Doc](collection: MongoCollection[Doc], updateOptions: UpdateOptions = DefaultUpdateOptions, retryStrategy: RetryStrategy = DefaultRetryStrategy): Consumer[Seq[(Bson, Bson)], Unit]
Provides a sink implementation for MongoSingle.updateOne that expects sequences of Tuple2 of a filter and a update that will be executed against the single filtered element.
Provides a sink implementation for MongoSingle.updateOne that expects sequences of Tuple2 of a filter and a update that will be executed against the single filtered element. All elements inside a single sequence will be executed in parallel as a batch operation.
- Doc
the type of the collection
- collection
the abstraction to work with the determined mongodb collection
- updateOptions
the options to apply to the update operation
- retryStrategy
defines the amount of retries and backoff delays for failed requests.
- returns
a Consumer that per each element expects a batch of Tuple2 of a filter and the update in form of Bson.
- Definition Classes
- MongoSink → MongoSinkImpl
- See also
com.mongodb.client.model.Filters and com.mongodb.client.model.Updates If the documents is missing an identifier, the driver should generate one.
- 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()