Uses of Class
com.hazelcast.jet.mongodb.MongoSourceBuilder.Batch

Packages that use MongoSourceBuilder.Batch

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

Uses of MongoSourceBuilder.Batch in com.hazelcast.jet.mongodb

Methods in com.hazelcast.jet.mongodb that return MongoSourceBuilder.Batch

Modifier and Type	Method and Description
static MongoSourceBuilder.Batch<org.bson.Document>	MongoSourceBuilder.batch(DataConnectionRef dataConnectionRef) Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB BatchSource for the Pipeline API.
static MongoSourceBuilder.Batch<org.bson.Document>	MongoSources.batch(DataConnectionRef dataConnectionRef) Creates as builder for new batch mongo source.
static MongoSourceBuilder.Batch<org.bson.Document>	MongoSourceBuilder.batch(String name, DataConnectionRef dataConnectionRef) Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB BatchSource for the Pipeline API.
static MongoSourceBuilder.Batch<org.bson.Document>	MongoSourceBuilder.batch(String name, SupplierEx<? extends com.mongodb.client.MongoClient> clientSupplier) Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB BatchSource for the Pipeline API.
static MongoSourceBuilder.Batch<org.bson.Document>	MongoSourceBuilder.batch(SupplierEx<? extends com.mongodb.client.MongoClient> clientSupplier) Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB BatchSource for the Pipeline API.
static MongoSourceBuilder.Batch<org.bson.Document>	MongoSources.batch(SupplierEx<? extends com.mongodb.client.MongoClient> clientSupplier) Creates as builder for new batch mongo source.
MongoSourceBuilder.Batch<org.bson.Document>	MongoSourceBuilder.Batch.collection(String collectionName) Specifies from which collection connector will read documents.
<T_NEW> MongoSourceBuilder.Batch<T_NEW>	MongoSourceBuilder.Batch.collection(String collectionName, Class<T_NEW> mongoType) Specifies from which collection connector will read documents.
MongoSourceBuilder.Batch<T>	MongoSourceBuilder.Batch.database(String database) Specifies which database will be queried.
MongoSourceBuilder.Batch<T>	MongoSourceBuilder.Batch.filter(org.bson.conversions.Bson filter) Adds filter aggregate to this builder, which allows to filter documents in MongoDB, without the need to download all documents.
<T_NEW> MongoSourceBuilder.Batch<T_NEW>	MongoSourceBuilder.Batch.mapFn(FunctionEx<org.bson.Document,T_NEW> mapFn)
MongoSourceBuilder.Batch<T>	MongoSourceBuilder.Batch.project(org.bson.conversions.Bson projection) Adds a projection aggregate.
MongoSourceBuilder.Batch<T>	MongoSourceBuilder.Batch.sort(org.bson.conversions.Bson sort) Adds sort aggregate to this builder.
MongoSourceBuilder.Batch<T>	MongoSourceBuilder.Batch.throwOnNonExisting(boolean throwOnNonExisting) If true, the lack of database or collection will cause an error.