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

Packages that use MongoSourceBuilder.Stream

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

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

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

Modifier and Type	Method	Description
MongoSourceBuilder.Stream<org.bson.Document>	MongoSourceBuilder.Stream.collection(String collectionName)	Specifies from which collection connector will read documents.
<T_NEW> MongoSourceBuilder.Stream<T_NEW>	MongoSourceBuilder.Stream.collection(String collectionName, Class<T_NEW> mongoType)	Specifies from which collection connector will read documents.
<T_NEW> MongoSourceBuilder.Stream<T_NEW>	MongoSourceBuilder.Stream.mapFn(BiFunctionEx<com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document>,Long,T_NEW> mapFn)
MongoSourceBuilder.Stream<T>	MongoSourceBuilder.Stream.startAtOperationTime(org.bson.BsonTimestamp startAtOperationTime)	Specifies time from which MongoDB's events will be read.
static MongoSourceBuilder.Stream<org.bson.Document>	MongoSourceBuilder.stream(SupplierEx<? extends com.mongodb.client.MongoClient> clientSupplier)	Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB StreamSource for the Pipeline API.
static MongoSourceBuilder.Stream<org.bson.Document>	MongoSourceBuilder.stream(DataConnectionRef dataConnectionRef)	Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB StreamSource for the Pipeline API.
static MongoSourceBuilder.Stream<org.bson.Document>	MongoSourceBuilder.stream(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 StreamSource for the Pipeline API.
static MongoSourceBuilder.Stream<org.bson.Document>	MongoSourceBuilder.stream(String name, DataConnectionRef dataConnectionRef)	Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB StreamSource for the Pipeline API.
static MongoSourceBuilder.Stream<org.bson.Document>	MongoSources.stream(SupplierEx<? extends com.mongodb.client.MongoClient> clientSupplier)	Creates as builder for new stream mongo source.