Uses of Class
com.hazelcast.jet.mongodb.MongoSinkBuilder

Packages that use MongoSinkBuilder

Package	Description
com.hazelcast.jet.mongodb	Contains sources and sinks for MongoDB.

Uses of MongoSinkBuilder in com.hazelcast.jet.mongodb

Methods in com.hazelcast.jet.mongodb that return MongoSinkBuilder

Modifier and Type	Method and Description
static <T> MongoSinkBuilder<T>	MongoSinks.builder(Class<T> itemClass, DataConnectionRef dataConnectionRef) Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB Sink for the Pipeline API.
static <T> MongoSinkBuilder<T>	MongoSinks.builder(Class<T> itemClass, SupplierEx<com.mongodb.client.MongoClient> clientSupplier) Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB Sink for the Pipeline API.
MongoSinkBuilder<T>	MongoSinkBuilder.commitRetryStrategy(RetryStrategy commitRetryStrategy) Sets the retry strategy in case of commit failure.
MongoSinkBuilder<T>	MongoSinkBuilder.identifyDocumentBy(String fieldName, FunctionEx<T,Object> documentIdentityFn) Sets the filter that decides which document in the collection is equal to processed document.
MongoSinkBuilder<T>	MongoSinkBuilder.into(FunctionEx<T,String> selectDatabaseNameFn, FunctionEx<T,String> selectCollectionNameFn)
MongoSinkBuilder<T>	MongoSinkBuilder.into(String databaseName, String collectionName)
MongoSinkBuilder<T>	MongoSinkBuilder.preferredLocalParallelism(int preferredLocalParallelism) See SinkBuilder.preferredLocalParallelism(int).
MongoSinkBuilder<T>	MongoSinkBuilder.throwOnNonExisting(boolean throwOnNonExisting) If true, the lack of database or collection will cause an error.
MongoSinkBuilder<T>	MongoSinkBuilder.transactionOptions(SupplierEx<com.mongodb.TransactionOptions> transactionOptionsSup) Sets options which will be used by MongoDB transaction mechanism.
MongoSinkBuilder<T>	MongoSinkBuilder.withCustomReplaceOptions(ConsumerEx<com.mongodb.client.model.ReplaceOptions> adjustConsumer) Provides an option to adjust options used in replace action.
MongoSinkBuilder<T>	MongoSinkBuilder.writeMode(WriteMode writeMode) Sets write mode used by the connector.