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(com.hazelcast.function.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(com.hazelcast.function.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(com.hazelcast.jet.pipeline.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, com.hazelcast.function.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, com.hazelcast.jet.pipeline.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(com.hazelcast.function.SupplierEx<? extends com.mongodb.client.MongoClient> clientSupplier)
    Creates as builder for new stream mongo source.