Index (hazelcast-jet-mongodb 5.4.5 API)

A B C D E F G H I L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values

A

AUTH_DB_PROPERTY - Static variable in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Name of the property holding the name of the database in which user is created.

B

batch(SupplierEx<? extends MongoClient>) - Static method in class com.hazelcast.jet.mongodb.MongoSourceBuilder: Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB BatchSource for the Pipeline API.
batch(SupplierEx<? extends MongoClient>) - Static method in class com.hazelcast.jet.mongodb.MongoSources: Creates as builder for new batch mongo source.
batch(DataConnectionRef) - Static method in class com.hazelcast.jet.mongodb.MongoSourceBuilder: Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB BatchSource for the Pipeline API.
batch(DataConnectionRef) - Static method in class com.hazelcast.jet.mongodb.MongoSources: Creates as builder for new batch mongo source.
batch(DataConnectionRef, String, String, Bson, Bson) - Static method in class com.hazelcast.jet.mongodb.MongoSources: Returns a MongoDB batch source which queries the collection using given filter and applies the given projection on the documents.
batch(String, SupplierEx<? extends MongoClient>) - Static method in class com.hazelcast.jet.mongodb.MongoSourceBuilder: Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB BatchSource for the Pipeline API.
batch(String, DataConnectionRef) - Static method in class com.hazelcast.jet.mongodb.MongoSourceBuilder: Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB BatchSource for the Pipeline API.
batch(String, String, String, Bson, Bson) - Static method in class com.hazelcast.jet.mongodb.MongoSources: Returns a MongoDB batch source which queries the collection using given filter and applies the given projection on the documents.
build() - Method in class com.hazelcast.jet.mongodb.MongoSinkBuilder: Creates and returns the MongoDB Sink with the components you supplied to this builder.
build() - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Batch: Creates and returns the MongoDB BatchSource.
build() - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream: Creates and returns the MongoDB StreamSource which watches the given collection.
builder(Class<T>, SupplierEx<MongoClient>) - Static method in class com.hazelcast.jet.mongodb.MongoSinks: Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB Sink for the Pipeline API.
builder(Class<T>, DataConnectionRef) - Static method in class com.hazelcast.jet.mongodb.MongoSinks: Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB Sink for the Pipeline API.

C

checkResourceExistence(ResourceChecks) - Method in class com.hazelcast.jet.mongodb.MongoSinkBuilder: If ResourceChecks.NEVER, the database and collection will be automatically created on the first usage.
checkResourceExistence(ResourceChecks) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream: If ResourceChecks.NEVER, the database and collection will be automatically created on the first usage.
collection(String) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Batch: Specifies from which collection connector will read documents.
collection(String) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream: Specifies from which collection connector will read documents.
collection(String, Class<T_NEW>) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Batch: Specifies from which collection connector will read documents.
collection(String, Class<T_NEW>) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream: Specifies from which collection connector will read documents.
com.hazelcast.jet.mongodb - package com.hazelcast.jet.mongodb: Contains sources and sinks for MongoDB.
com.hazelcast.jet.mongodb.compact - package com.hazelcast.jet.mongodb.compact: Contains helpful serializers for the usage with the connector.
com.hazelcast.jet.mongodb.dataconnection - package com.hazelcast.jet.mongodb.dataconnection: Contains classes related to Mongo DB Data Connection.
commitRetryStrategy(RetryStrategy) - Method in class com.hazelcast.jet.mongodb.MongoSinkBuilder: Sets the retry strategy in case of commit failure.
CONNECTION_POOL_MAX - Static variable in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Name of the property holding the maximum size of Mongo Client connection pool.
CONNECTION_POOL_MIN - Static variable in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Name of the property holding the minimum size of Mongo Client connection pool.
CONNECTION_STRING_PROPERTY - Static variable in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Name of a property which holds connection string to the mongodb instance.

D

database(String) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream
DATABASE_PROPERTY - Static variable in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Name of a property with a database name hint.
DEFAULT_COMMIT_RETRY_STRATEGY - Static variable in class com.hazelcast.jet.mongodb.MongoSinkBuilder: Default retry strategy used by the processors.
DEFAULT_TRANSACTION_OPTION - Static variable in class com.hazelcast.jet.mongodb.MongoSinkBuilder: Default transaction options used by the processors.
destroy() - Method in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Closes underlying client.

E

existenceChecks - Variable in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream

F

filter(Bson) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream: Adds filter aggregate to this builder, which allows to filter documents in MongoDB, without the need to download all documents.
forceReadTotalParallelismOne - Variable in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream
forceReadTotalParallelismOne(boolean) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream: If set to true, reading will be done in only one thread.
fromString(String) - Static method in enum class com.hazelcast.jet.mongodb.ResourceChecks: Resolves given string value to one of values of this enum.

G

getClient() - Method in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Returns an instance of MongoClient.
getCompactClass() - Method in class com.hazelcast.jet.mongodb.compact.ObjectIdCompactSerializer
getDatabaseName() - Method in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Returns the database name hint.
getTypeName() - Method in class com.hazelcast.jet.mongodb.compact.ObjectIdCompactSerializer

H

HOST_PROPERTY - Static variable in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Name of a property which holds host:port address of the mongodb instance.

I

identifyDocumentBy(String, FunctionEx<T, Object>) - Method in class com.hazelcast.jet.mongodb.MongoSinkBuilder: Sets the filter that decides which document in the collection is equal to processed document.
INSERT_ONLY - Enum constant in enum class com.hazelcast.jet.mongodb.WriteMode: Items will be inserted to MongoDB; in case of ID clash, error will be thrown.
into(FunctionEx<T, String>, FunctionEx<T, String>) - Method in class com.hazelcast.jet.mongodb.MongoSinkBuilder
into(String, String) - Method in class com.hazelcast.jet.mongodb.MongoSinkBuilder
isEverPerformed() - Method in enum class com.hazelcast.jet.mongodb.ResourceChecks

L

listResources() - Method in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Lists all MongoDB collections in all databases.

M

mapFn(BiFunctionEx<ChangeStreamDocument<Document>, Long, T_NEW>) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream
mapFn(FunctionEx<Document, T_NEW>) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Batch
MongoDataConnection - Class in com.hazelcast.jet.mongodb.dataconnection: Creates a MongoDB DataConnection.
MongoDataConnection(DataConnectionConfig) - Constructor for class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Creates a new data connection based on given config.
mongoDataConnectionConf(String, String) - Static method in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Helper method to create new MongoDataConnection with given name and connection string.
mongodb(DataConnectionRef, String, String) - Static method in class com.hazelcast.jet.mongodb.MongoSinks: Convenience for MongoSinks.builder(java.lang.Class<T>, com.hazelcast.function.SupplierEx<com.mongodb.client.MongoClient>).
mongodb(String, String, String) - Static method in class com.hazelcast.jet.mongodb.MongoSinks: Convenience for MongoSinks.builder(java.lang.Class<T>, com.hazelcast.function.SupplierEx<com.mongodb.client.MongoClient>).
MongoSinkBuilder<T> - Class in com.hazelcast.jet.mongodb: See MongoSinks.builder(java.lang.Class<T>, com.hazelcast.function.SupplierEx<com.mongodb.client.MongoClient>)
MongoSinks - Class in com.hazelcast.jet.mongodb: Contains factory methods for MongoDB sinks.
MongoSourceBuilder - Class in com.hazelcast.jet.mongodb: Top-level class for MongoDB custom source builders.
MongoSourceBuilder.Batch<T> - Class in com.hazelcast.jet.mongodb: See MongoSourceBuilder.batch(String, SupplierEx).
MongoSourceBuilder.Stream<T> - Class in com.hazelcast.jet.mongodb: See MongoSourceBuilder.stream(String, SupplierEx).
MongoSources - Class in com.hazelcast.jet.mongodb: Contains factory methods for MongoDB sources.

N

name - Variable in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream
NEVER - Enum constant in enum class com.hazelcast.jet.mongodb.ResourceChecks: Check won't be ever done, meaning that the database and collection will be created automatically by Mongo when it's accessed for the first time.

O

ObjectIdCompactSerializer - Class in com.hazelcast.jet.mongodb.compact: Compact serializer for ObjectId.
ObjectIdCompactSerializer() - Constructor for class com.hazelcast.jet.mongodb.compact.ObjectIdCompactSerializer
ON_EACH_CONNECT - Enum constant in enum class com.hazelcast.jet.mongodb.ResourceChecks: Check will be done on every connect action on every processor.
ONCE_PER_JOB - Enum constant in enum class com.hazelcast.jet.mongodb.ResourceChecks: Check will be done once per each job execution (when job starts from scratch or from snapshot).
ONLY_INITIAL - Enum constant in enum class com.hazelcast.jet.mongodb.ResourceChecks: (SQL-only) check will be done only during initial mapping creation.

P

params - Variable in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream
PASSWORD_PROPERTY - Static variable in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Name of the property holding user password.
preferredLocalParallelism(int) - Method in class com.hazelcast.jet.mongodb.MongoSinkBuilder: See SinkBuilder.preferredLocalParallelism(int).
project(Bson) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream: Adds a projection aggregate.

R

read(CompactReader) - Method in class com.hazelcast.jet.mongodb.compact.ObjectIdCompactSerializer
REPLACE - Enum constant in enum class com.hazelcast.jet.mongodb.WriteMode: Performs replace.
ResourceChecks - Enum Class in com.hazelcast.jet.mongodb: Defines when and if database and collection existence will be checked.
resourceTypes() - Method in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection

S

sort(Bson) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream: Adds sort aggregate to this builder.
startAtOperationTime(BsonTimestamp) - Method in class com.hazelcast.jet.mongodb.MongoSourceBuilder.Stream: Specifies time from which MongoDB's events will be read.
stream(SupplierEx<? extends MongoClient>) - Static method in class com.hazelcast.jet.mongodb.MongoSourceBuilder: Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB StreamSource for the Pipeline API.
stream(SupplierEx<? extends MongoClient>) - Static method in class com.hazelcast.jet.mongodb.MongoSources: Creates as builder for new stream mongo source.
stream(DataConnectionRef) - Static method in class com.hazelcast.jet.mongodb.MongoSourceBuilder: Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB StreamSource for the Pipeline API.
stream(String, SupplierEx<? extends MongoClient>) - Static method in class com.hazelcast.jet.mongodb.MongoSourceBuilder: Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB StreamSource for the Pipeline API.
stream(String, DataConnectionRef) - Static method in class com.hazelcast.jet.mongodb.MongoSourceBuilder: Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB StreamSource for the Pipeline API.
stream(String, String, String, Document, Document) - Static method in class com.hazelcast.jet.mongodb.MongoSources: Returns a MongoDB stream source which watches the changes on the collection.

T

transactionOptions(SupplierEx<TransactionOptions>) - Method in class com.hazelcast.jet.mongodb.MongoSinkBuilder: Sets options which will be used by MongoDB transaction mechanism.

U

UPDATE_ONLY - Enum constant in enum class com.hazelcast.jet.mongodb.WriteMode: Performs update.
UPSERT - Enum constant in enum class com.hazelcast.jet.mongodb.WriteMode: Performs update.
USERNAME_PROPERTY - Static variable in class com.hazelcast.jet.mongodb.dataconnection.MongoDataConnection: Name of the property holding username.

V

valueOf(String) - Static method in enum class com.hazelcast.jet.mongodb.ResourceChecks: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.hazelcast.jet.mongodb.WriteMode: Returns the enum constant of this class with the specified name.
values() - Static method in enum class com.hazelcast.jet.mongodb.ResourceChecks: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.hazelcast.jet.mongodb.WriteMode: Returns an array containing the constants of this enum class, in the order they are declared.

W

withCustomReplaceOptions(ConsumerEx<ReplaceOptions>) - Method in class com.hazelcast.jet.mongodb.MongoSinkBuilder: Provides an option to adjust options used in replace action.
write(CompactWriter, ObjectId) - Method in class com.hazelcast.jet.mongodb.compact.ObjectIdCompactSerializer
writeMode(WriteMode) - Method in class com.hazelcast.jet.mongodb.MongoSinkBuilder: Sets write mode used by the connector.
WriteMode - Enum Class in com.hazelcast.jet.mongodb: Defines allowed operations.

A B C D E F G H I L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values