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
    Description
    static MongoSourceBuilder.Batch<org.bson.Document>
    MongoSourceBuilder.batch(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 BatchSource for the Pipeline API.
    static MongoSourceBuilder.Batch<org.bson.Document>
    MongoSourceBuilder.batch(com.hazelcast.jet.pipeline.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, 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 BatchSource for the Pipeline API.
    static MongoSourceBuilder.Batch<org.bson.Document>
    MongoSourceBuilder.batch(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 BatchSource for the Pipeline API.
    static MongoSourceBuilder.Batch<org.bson.Document>
    MongoSources.batch(com.hazelcast.function.SupplierEx<? extends com.mongodb.client.MongoClient> clientSupplier)
    Creates as builder for new batch mongo source.
    static MongoSourceBuilder.Batch<org.bson.Document>
    MongoSources.batch(com.hazelcast.jet.pipeline.DataConnectionRef dataConnectionRef)
    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.
    <T_NEW> MongoSourceBuilder.Batch<T_NEW>
    MongoSourceBuilder.Batch.mapFn(com.hazelcast.function.FunctionEx<org.bson.Document,T_NEW> mapFn)