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	Description
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.
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.
MongoSinkBuilder<T>	MongoSinkBuilder.checkResourceExistence(ResourceChecks checkResourceExistence)	If ResourceChecks.NEVER, the database and collection will be automatically created on the first usage.
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.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.