Uses of Class
com.hazelcast.jet.mongodb.MongoSinkBuilder
-
Uses of MongoSinkBuilder in com.hazelcast.jet.mongodb
Modifier and TypeMethodDescriptionstatic <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 MongoDBSink
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 MongoDBSink
for the Pipeline API.MongoSinkBuilder.checkResourceExistence
(ResourceChecks checkResourceExistence) IfResourceChecks.NEVER
, the database and collection will be automatically created on the first usage.MongoSinkBuilder.commitRetryStrategy
(RetryStrategy commitRetryStrategy) Sets the retry strategy in case of commit failure.MongoSinkBuilder.identifyDocumentBy
(String fieldName, FunctionEx<T, Object> documentIdentityFn) Sets the filter that decides which document in the collection is equal to processed document.MongoSinkBuilder.into
(FunctionEx<T, String> selectDatabaseNameFn, FunctionEx<T, String> selectCollectionNameFn) MongoSinkBuilder.preferredLocalParallelism
(int preferredLocalParallelism) MongoSinkBuilder.transactionOptions
(SupplierEx<com.mongodb.TransactionOptions> transactionOptionsSup) Sets options which will be used by MongoDB transaction mechanism.MongoSinkBuilder.withCustomReplaceOptions
(ConsumerEx<com.mongodb.client.model.ReplaceOptions> adjustConsumer) Provides an option to adjust options used in replace action.Sets write mode used by the connector.