- batchSize(int) - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
-
Sets the number of documents to return per batch.
- batchSize(int) - Method in interface com.mongodb.reactivestreams.client.ChangeStreamPublisher
-
Sets the number of documents to return per batch.
- batchSize(int) - Method in interface com.mongodb.reactivestreams.client.DistinctPublisher
-
Sets the number of documents to return per batch.
- batchSize(int) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the number of documents to return per batch.
- batchSize(int) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSDownloadStream
-
Sets the number of chunks to return per batch.
- batchSize(int) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher
-
Sets the number of documents to return per batch.
- batchSize(int) - Method in interface com.mongodb.reactivestreams.client.ListCollectionsPublisher
-
Sets the number of documents to return per batch.
- batchSize(int) - Method in interface com.mongodb.reactivestreams.client.ListDatabasesPublisher
-
Sets the number of documents to return per batch.
- batchSize(int) - Method in interface com.mongodb.reactivestreams.client.ListIndexesPublisher
-
Sets the number of documents to return per batch.
- batchSize(int) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the number of documents to return per batch.
- bulkWrite(List<? extends WriteModel<? extends TDocument>>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Executes a mix of inserts, updates, replaces, and deletes.
- bulkWrite(List<? extends WriteModel<? extends TDocument>>, BulkWriteOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Executes a mix of inserts, updates, replaces, and deletes.
- bulkWrite(ClientSession, List<? extends WriteModel<? extends TDocument>>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Executes a mix of inserts, updates, replaces, and deletes.
- bulkWrite(ClientSession, List<? extends WriteModel<? extends TDocument>>, BulkWriteOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Executes a mix of inserts, updates, replaces, and deletes.
- bypassDocumentValidation(Boolean) - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
-
Sets the bypass document level validation flag.
- bypassDocumentValidation(Boolean) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the bypass document level validation flag.
- ChangeStreamPublisher<TResult> - Interface in com.mongodb.reactivestreams.client
-
Iterable for change streams.
- ClientSession - Interface in com.mongodb.reactivestreams.client
-
A client session that supports transactions.
- close() - Method in interface com.mongodb.reactivestreams.client.gridfs.AsyncInputStream
-
Closes the input stream
- close() - Method in interface com.mongodb.reactivestreams.client.gridfs.AsyncOutputStream
-
Closes the output stream
- close() - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Close the client, which will close all underlying cached resources, including, for example,
sockets and background monitoring threads.
- collation(Collation) - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
-
Sets the collation options
- collation(Collation) - Method in interface com.mongodb.reactivestreams.client.ChangeStreamPublisher
-
Sets the collation options
- collation(Collation) - Method in interface com.mongodb.reactivestreams.client.DistinctPublisher
-
Sets the collation options
- collation(Collation) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the collation options
- collation(Collation) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher
-
Sets the collation options
- collation(Collation) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the collation options
- collectionName(String) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the collectionName for the output of the MapReduce
- com.mongodb.reactivestreams.client - package com.mongodb.reactivestreams.client
-
This packages contains classes for the reactive stream client implementation
- com.mongodb.reactivestreams.client.gridfs - package com.mongodb.reactivestreams.client.gridfs
-
Contains the classes for supporting MongoDB's specification for storing very large files, GridFS.
- com.mongodb.reactivestreams.client.gridfs.helpers - package com.mongodb.reactivestreams.client.gridfs.helpers
-
- comment(String) - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
-
Sets the comment to the aggregation.
- comment(String) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the comment to the query.
- commitTransaction() - Method in interface com.mongodb.reactivestreams.client.ClientSession
-
Commit a transaction in the context of this session.
- count() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
- count(Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
- count(Bson, CountOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
- count(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
- count(ClientSession, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
- count(ClientSession, Bson, CountOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
- countDocuments() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Counts the number of documents in the collection.
- countDocuments(Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Counts the number of documents in the collection according to the given options.
- countDocuments(Bson, CountOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Counts the number of documents in the collection according to the given options.
- countDocuments(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Counts the number of documents in the collection.
- countDocuments(ClientSession, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Counts the number of documents in the collection according to the given options.
- countDocuments(ClientSession, Bson, CountOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Counts the number of documents in the collection according to the given options.
- create(MongoDatabase) - Static method in class com.mongodb.reactivestreams.client.gridfs.GridFSBuckets
-
Create a new GridFS bucket with the default 'fs'
bucket name
- create(MongoDatabase, String) - Static method in class com.mongodb.reactivestreams.client.gridfs.GridFSBuckets
-
Create a new GridFS bucket with a custom bucket name
- create() - Static method in class com.mongodb.reactivestreams.client.MongoClients
-
Creates a new client with the default connection string "mongodb://localhost".
- create(MongoClientSettings) - Static method in class com.mongodb.reactivestreams.client.MongoClients
-
- create(String) - Static method in class com.mongodb.reactivestreams.client.MongoClients
-
Create a new client with the given connection string.
- create(ConnectionString) - Static method in class com.mongodb.reactivestreams.client.MongoClients
-
Create a new client with the given connection string.
- create(ConnectionString, MongoDriverInformation) - Static method in class com.mongodb.reactivestreams.client.MongoClients
-
Create a new client with the given connection string.
- create(MongoClientSettings, MongoDriverInformation) - Static method in class com.mongodb.reactivestreams.client.MongoClients
-
- create(MongoClientSettings) - Static method in class com.mongodb.reactivestreams.client.MongoClients
-
Create a new client with the given client settings.
- create(MongoClientSettings, MongoDriverInformation) - Static method in class com.mongodb.reactivestreams.client.MongoClients
-
Creates a new client with the given client settings.
- create(MongoClient) - Static method in class com.mongodb.reactivestreams.client.MongoClients
-
Creates a new client with the given async MongoClient.
- createCollection(String) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Create a new collection with the given name.
- createCollection(String, CreateCollectionOptions) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Create a new collection with the selected options
- createCollection(ClientSession, String) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Create a new collection with the given name.
- createCollection(ClientSession, String, CreateCollectionOptions) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Create a new collection with the selected options
- createIndex(Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates an index.
- createIndex(Bson, IndexOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates an index.
- createIndex(ClientSession, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates an index.
- createIndex(ClientSession, Bson, IndexOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates an index.
- createIndexes(List<IndexModel>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Create multiple indexes.
- createIndexes(List<IndexModel>, CreateIndexOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Create multiple indexes.
- createIndexes(ClientSession, List<IndexModel>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Create multiple indexes.
- createIndexes(ClientSession, List<IndexModel>, CreateIndexOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Create multiple indexes.
- createView(String, String, List<? extends Bson>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.
- createView(String, String, List<? extends Bson>, CreateViewOptions) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.
- createView(ClientSession, String, String, List<? extends Bson>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.
- createView(ClientSession, String, String, List<? extends Bson>, CreateViewOptions) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.
- cursorType(CursorType) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the cursor type.
- databaseName(String) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the name of the database to output into.
- delete(ObjectId) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Given a id
, delete this stored file's files collection document and associated chunks from a GridFS bucket.
- delete(BsonValue) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Given a id
, delete this stored file's files collection document and associated chunks from a GridFS bucket.
- delete(ClientSession, ObjectId) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Given a id
, delete this stored file's files collection document and associated chunks from a GridFS bucket.
- delete(ClientSession, BsonValue) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Given a id
, delete this stored file's files collection document and associated chunks from a GridFS bucket.
- deleteMany(Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Removes all documents from the collection that match the given query filter.
- deleteMany(Bson, DeleteOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Removes all documents from the collection that match the given query filter.
- deleteMany(ClientSession, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Removes all documents from the collection that match the given query filter.
- deleteMany(ClientSession, Bson, DeleteOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Removes all documents from the collection that match the given query filter.
- deleteOne(Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Removes at most one document from the collection that matches the given filter.
- deleteOne(Bson, DeleteOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Removes at most one document from the collection that matches the given filter.
- deleteOne(ClientSession, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Removes at most one document from the collection that matches the given filter.
- deleteOne(ClientSession, Bson, DeleteOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Removes at most one document from the collection that matches the given filter.
- distinct(String, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Gets the distinct values of the specified field name.
- distinct(String, Bson, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Gets the distinct values of the specified field name.
- distinct(ClientSession, String, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Gets the distinct values of the specified field name.
- distinct(ClientSession, String, Bson, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Gets the distinct values of the specified field name.
- DistinctPublisher<TResult> - Interface in com.mongodb.reactivestreams.client
-
Iterable for distinct.
- downloadToStream(ObjectId, AsyncOutputStream) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Downloads the contents of the stored file specified by id
and writes the contents to the destination
AsyncOutputStream.
- downloadToStream(BsonValue, AsyncOutputStream) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Downloads the contents of the stored file specified by id
and writes the contents to the destination
AsyncOutputStream.
- downloadToStream(String, AsyncOutputStream) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Downloads the contents of the latest version of the stored file specified by filename
and writes the contents to
the destination
Stream.
- downloadToStream(String, AsyncOutputStream, GridFSDownloadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Downloads the contents of the stored file specified by filename
and by the revision in options
and writes the
contents to the destination
Stream.
- downloadToStream(ClientSession, ObjectId, AsyncOutputStream) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Downloads the contents of the stored file specified by id
and writes the contents to the destination
AsyncOutputStream.
- downloadToStream(ClientSession, BsonValue, AsyncOutputStream) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Downloads the contents of the stored file specified by id
and writes the contents to the destination
AsyncOutputStream.
- downloadToStream(ClientSession, String, AsyncOutputStream) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Downloads the contents of the latest version of the stored file specified by filename
and writes the contents to
the destination
Stream.
- downloadToStream(ClientSession, String, AsyncOutputStream, GridFSDownloadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Downloads the contents of the stored file specified by filename
and by the revision in options
and writes the
contents to the destination
Stream.
- drop() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Drops the data associated with this bucket from the database.
- drop(ClientSession) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Drops the data associated with this bucket from the database.
- drop() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drops this collection from the Database.
- drop(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drops this collection from the Database.
- drop() - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Drops this database.
- drop(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Drops this database.
- dropIndex(String) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drops the given index.
- dropIndex(Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drops the index given the keys used to create it.
- dropIndex(String, DropIndexOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drops the given index.
- dropIndex(Bson, DropIndexOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drops the index given the keys used to create it.
- dropIndex(ClientSession, String) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drops the given index.
- dropIndex(ClientSession, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drops the index given the keys used to create it.
- dropIndex(ClientSession, String, DropIndexOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drops the given index.
- dropIndex(ClientSession, Bson, DropIndexOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drops the index given the keys used to create it.
- dropIndexes() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drop all the indexes on this collection, except for the default on _id.
- dropIndexes(DropIndexOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drop all the indexes on this collection, except for the default on _id.
- dropIndexes(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drop all the indexes on this collection, except for the default on _id.
- dropIndexes(ClientSession, DropIndexOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Drop all the indexes on this collection, except for the default on _id.
- filter(Bson) - Method in interface com.mongodb.reactivestreams.client.DistinctPublisher
-
Sets the query filter to apply to the query.
- filter(Bson) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the query filter to apply to the query.
- filter(Bson) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher
-
Sets the query filter to apply to the query.
- filter(Bson) - Method in interface com.mongodb.reactivestreams.client.ListCollectionsPublisher
-
Sets the query filter to apply to the query.
- filter(Bson) - Method in interface com.mongodb.reactivestreams.client.ListDatabasesPublisher
-
Sets the query filter to apply to the returned database names.
- filter(Bson) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the query filter to apply to the query.
- finalizeFunction(String) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the JavaScript function that follows the reduce method and modifies the output.
- find() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Finds all documents in the files collection.
- find(Bson) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Finds all documents in the collection that match the filter.
- find(ClientSession) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Finds all documents in the files collection.
- find(ClientSession, Bson) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Finds all documents in the collection that match the filter.
- find() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Finds all documents in the collection.
- find(Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Finds all documents in the collection.
- find(Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Finds all documents in the collection.
- find(Bson, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Finds all documents in the collection.
- find(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Finds all documents in the collection.
- find(ClientSession, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Finds all documents in the collection.
- find(ClientSession, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Finds all documents in the collection.
- find(ClientSession, Bson, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Finds all documents in the collection.
- findOneAndDelete(Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and remove it.
- findOneAndDelete(Bson, FindOneAndDeleteOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and remove it.
- findOneAndDelete(ClientSession, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and remove it.
- findOneAndDelete(ClientSession, Bson, FindOneAndDeleteOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and remove it.
- findOneAndReplace(Bson, TDocument) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and replace it.
- findOneAndReplace(Bson, TDocument, FindOneAndReplaceOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and replace it.
- findOneAndReplace(ClientSession, Bson, TDocument) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and replace it.
- findOneAndReplace(ClientSession, Bson, TDocument, FindOneAndReplaceOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and replace it.
- findOneAndUpdate(Bson, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and update it.
- findOneAndUpdate(Bson, Bson, FindOneAndUpdateOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and update it.
- findOneAndUpdate(ClientSession, Bson, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and update it.
- findOneAndUpdate(ClientSession, Bson, Bson, FindOneAndUpdateOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Atomically find a document and update it.
- FindPublisher<TResult> - Interface in com.mongodb.reactivestreams.client
-
Publisher interface for find.
- first() - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
-
Helper to return a publisher limited to the first result.
- first() - Method in interface com.mongodb.reactivestreams.client.ChangeStreamPublisher
-
Helper to return a publisher limited to the first result.
- first() - Method in interface com.mongodb.reactivestreams.client.DistinctPublisher
-
Helper to return a publisher limited to the first result.
- first() - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Helper to return a publisher limited to the first result.
- first() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher
-
Helper to return a publisher limited first from the query.
- first() - Method in interface com.mongodb.reactivestreams.client.ListCollectionsPublisher
-
Helper to return a publisher limited to the first result.
- first() - Method in interface com.mongodb.reactivestreams.client.ListDatabasesPublisher
-
Helper to return a publisher limited to the first result.
- first() - Method in interface com.mongodb.reactivestreams.client.ListIndexesPublisher
-
Helper to return a publisher limited to the first result.
- first() - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Helper to return a publisher limited to the first result.
- fullDocument(FullDocument) - Method in interface com.mongodb.reactivestreams.client.ChangeStreamPublisher
-
Sets the fullDocument value.
- getBucketName() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
The bucket name.
- getChunkSizeBytes() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Sets the chunk size in bytes.
- getCodecRegistry() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Get the codec registry for the MongoCollection.
- getCodecRegistry() - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Get the codec registry for the MongoDatabase.
- getCollection(String) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Gets a collection.
- getCollection(String, Class<TDocument>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Gets a collection, with a specific default document class.
- getDatabase(String) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Gets the database with the given name.
- getDefaultCodecRegistry() - Static method in class com.mongodb.reactivestreams.client.MongoClients
-
Gets the default codec registry.
- getDisableMD5() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Returns true if computing MD5 checksums when uploading files is disabled.
- getDocumentClass() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Get the class of documents stored in this collection.
- getGridFSFile() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSDownloadStream
-
Gets the corresponding
GridFSFile
for the file being downloaded
- getId() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSUploadStream
-
- getName() - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Gets the name of the database.
- getNamespace() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Gets the namespace of this collection.
- getObjectId() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSUploadStream
-
- getReadConcern() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Get the read concern for the GridFSBucket.
- getReadConcern() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Get the read concern for the MongoCollection.
- getReadConcern() - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Get the read concern for the MongoCollection.
- getReadPreference() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Get the read preference for the GridFSBucket.
- getReadPreference() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Get the read preference for the MongoCollection.
- getReadPreference() - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Get the read preference for the MongoDatabase.
- getSettings() - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
- getTransactionOptions() - Method in interface com.mongodb.reactivestreams.client.ClientSession
-
Gets the transaction options.
- getWrapped() - Method in interface com.mongodb.reactivestreams.client.ClientSession
-
For internal use only.
- getWriteConcern() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Get the write concern for the GridFSBucket.
- getWriteConcern() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Get the write concern for the MongoCollection.
- getWriteConcern() - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Get the write concern for the MongoDatabase.
- GridFSBucket - Interface in com.mongodb.reactivestreams.client.gridfs
-
Represents a GridFS Bucket
- GridFSBuckets - Class in com.mongodb.reactivestreams.client.gridfs
-
A factory for GridFSBucket instances.
- GridFSDownloadStream - Interface in com.mongodb.reactivestreams.client.gridfs
-
A GridFS InputStream for downloading data from GridFS
- GridFSFindPublisher - Interface in com.mongodb.reactivestreams.client.gridfs
-
Iterable for the GridFS Files Collection.
- GridFSUploadStream - Interface in com.mongodb.reactivestreams.client.gridfs
-
A GridFS OutputStream for uploading data into GridFS
- limit(int) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the limit to apply.
- limit(int) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher
-
Sets the limit to apply.
- limit(int) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the limit to apply.
- listCollectionNames() - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Gets the names of all the collections in this database.
- listCollectionNames(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Gets the names of all the collections in this database.
- listCollections() - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Finds all the collections in this database.
- listCollections(Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Finds all the collections in this database.
- listCollections(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Finds all the collections in this database.
- listCollections(ClientSession, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Finds all the collections in this database.
- ListCollectionsPublisher<TResult> - Interface in com.mongodb.reactivestreams.client
-
Publisher interface for ListCollections.
- listDatabaseNames() - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Get a list of the database names
- listDatabaseNames(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Get a list of the database names
- listDatabases() - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Gets the list of databases
- listDatabases(Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Gets the list of databases
- listDatabases(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Gets the list of databases
- listDatabases(ClientSession, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Gets the list of databases
- ListDatabasesPublisher<TResult> - Interface in com.mongodb.reactivestreams.client
-
Publisher interface for ListDatabases.
- listIndexes() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Get all the indexes in this collection.
- listIndexes(Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Get all the indexes in this collection.
- listIndexes(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Get all the indexes in this collection.
- listIndexes(ClientSession, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Get all the indexes in this collection.
- ListIndexesPublisher<TResult> - Interface in com.mongodb.reactivestreams.client
-
Publisher interface for ListIndexes.
- mapReduce(String, String) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Aggregates documents according to the specified map-reduce function.
- mapReduce(String, String, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Aggregates documents according to the specified map-reduce function.
- mapReduce(ClientSession, String, String) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Aggregates documents according to the specified map-reduce function.
- mapReduce(ClientSession, String, String, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Aggregates documents according to the specified map-reduce function.
- MapReducePublisher<TResult> - Interface in com.mongodb.reactivestreams.client
-
Publisher for map reduce.
- max(Bson) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the exclusive upper bound for a specific index.
- maxAwaitTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
-
The maximum amount of time for the server to wait on new documents to satisfy a $changeStream
aggregation.
- maxAwaitTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.ChangeStreamPublisher
-
Sets the maximum await execution time on the server for this operation.
- maxAwaitTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
The maximum amount of time for the server to wait on new documents to satisfy a tailable cursor
query.
- maxScan(long) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
- maxTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
-
Sets the maximum execution time on the server for this operation.
- maxTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.DistinctPublisher
-
Sets the maximum execution time on the server for this operation.
- maxTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the maximum execution time on the server for this operation.
- maxTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher
-
Sets the maximum execution time on the server for this operation.
- maxTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.ListCollectionsPublisher
-
Sets the maximum execution time on the server for this operation.
- maxTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.ListDatabasesPublisher
-
Sets the maximum execution time on the server for this operation.
- maxTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.ListIndexesPublisher
-
Sets the maximum execution time on the server for this operation.
- maxTime(long, TimeUnit) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the maximum execution time on the server for this operation.
- min(Bson) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the minimum inclusive lower bound for a specific index.
- modifiers(Bson) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
- MongoClient - Interface in com.mongodb.reactivestreams.client
-
A client-side representation of a MongoDB cluster.
- MongoClients - Class in com.mongodb.reactivestreams.client
-
A factory for MongoClient instances.
- MongoCollection<TDocument> - Interface in com.mongodb.reactivestreams.client
-
The MongoCollection interface.
- MongoDatabase - Interface in com.mongodb.reactivestreams.client
-
The MongoDatabase interface.
- openDownloadStream(ObjectId) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncInputStream from which the application can read the contents of the stored file specified by id
.
- openDownloadStream(BsonValue) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncInputStream from which the application can read the contents of the stored file specified by id
.
- openDownloadStream(String) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncInputStream from which the application can read the contents of the latest version of the stored file specified by the
filename
.
- openDownloadStream(String, GridFSDownloadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncInputStream from which the application can read the contents of the stored file specified by filename
and the
revision in options
.
- openDownloadStream(ClientSession, ObjectId) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncInputStream from which the application can read the contents of the stored file specified by id
.
- openDownloadStream(ClientSession, BsonValue) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncInputStream from which the application can read the contents of the stored file specified by id
.
- openDownloadStream(ClientSession, String) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncInputStream from which the application can read the contents of the latest version of the stored file specified by the
filename
.
- openDownloadStream(ClientSession, String, GridFSDownloadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncInputStream from which the application can read the contents of the stored file specified by filename
and the
revision in options
.
- openUploadStream(String) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncOutputStream that the application can write the contents of the file to.
- openUploadStream(String, GridFSUploadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncOutputStream that the application can write the contents of the file to.
- openUploadStream(BsonValue, String) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncOutputStream that the application can write the contents of the file to.
- openUploadStream(BsonValue, String, GridFSUploadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncOutputStream that the application can write the contents of the file to.
- openUploadStream(ClientSession, String) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncOutputStream that the application can write the contents of the file to.
- openUploadStream(ClientSession, String, GridFSUploadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncOutputStream that the application can write the contents of the file to.
- openUploadStream(ClientSession, BsonValue, String) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncOutputStream that the application can write the contents of the file to.
- openUploadStream(ClientSession, BsonValue, String, GridFSUploadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Opens a AsyncOutputStream that the application can write the contents of the file to.
- oplogReplay(boolean) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Users should not set this under normal circumstances.
- read(ByteBuffer) - Method in interface com.mongodb.reactivestreams.client.gridfs.AsyncInputStream
-
Reads a sequence of bytes from this stream into the given buffer.
- rename(ObjectId, String) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Renames the stored file with the specified id
.
- rename(BsonValue, String) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Renames the stored file with the specified id
.
- rename(ClientSession, ObjectId, String) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Renames the stored file with the specified id
.
- rename(ClientSession, BsonValue, String) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Renames the stored file with the specified id
.
- renameCollection(MongoNamespace) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Rename the collection with oldCollectionName to the newCollectionName.
- renameCollection(MongoNamespace, RenameCollectionOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Rename the collection with oldCollectionName to the newCollectionName.
- renameCollection(ClientSession, MongoNamespace) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Rename the collection with oldCollectionName to the newCollectionName.
- renameCollection(ClientSession, MongoNamespace, RenameCollectionOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Rename the collection with oldCollectionName to the newCollectionName.
- replaceOne(Bson, TDocument) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Replace a document in the collection according to the specified arguments.
- replaceOne(Bson, TDocument, ReplaceOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Replace a document in the collection according to the specified arguments.
- replaceOne(Bson, TDocument, UpdateOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
- replaceOne(ClientSession, Bson, TDocument) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Replace a document in the collection according to the specified arguments.
- replaceOne(ClientSession, Bson, TDocument, ReplaceOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Replace a document in the collection according to the specified arguments.
- replaceOne(ClientSession, Bson, TDocument, UpdateOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
- resumeAfter(BsonDocument) - Method in interface com.mongodb.reactivestreams.client.ChangeStreamPublisher
-
Sets the logical starting point for the new change stream.
- returnKey(boolean) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the returnKey.
- runCommand(Bson) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Executes command in the context of the current database.
- runCommand(Bson, ReadPreference) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Executes command in the context of the current database.
- runCommand(Bson, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Executes command in the context of the current database.
- runCommand(Bson, ReadPreference, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Executes command in the context of the current database.
- runCommand(ClientSession, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Executes command in the context of the current database.
- runCommand(ClientSession, Bson, ReadPreference) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Executes command in the context of the current database.
- runCommand(ClientSession, Bson, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Executes command in the context of the current database.
- runCommand(ClientSession, Bson, ReadPreference, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Executes command in the context of the current database.
- scope(Bson) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the global variables that are accessible in the map, reduce and finalize functions.
- sharded(boolean) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets if the output database is sharded
- showRecordId(boolean) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the showRecordId.
- skip(int) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the number of documents to skip.
- skip(int) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher
-
Sets the number of documents to skip.
- snapshot(boolean) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
- sort(Bson) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
-
Sets the sort criteria to apply to the query.
- sort(Bson) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher
-
Sets the sort criteria to apply to the query.
- sort(Bson) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
-
Sets the sort criteria to apply to the query.
- startAtOperationTime(BsonTimestamp) - Method in interface com.mongodb.reactivestreams.client.ChangeStreamPublisher
-
The change stream will only provide changes that occurred after the specified timestamp.
- startSession() - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Creates a client session.
- startSession(ClientSessionOptions) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Creates a client session.
- startTransaction() - Method in interface com.mongodb.reactivestreams.client.ClientSession
-
Start a transaction in the context of this session with default transaction options.
- startTransaction(TransactionOptions) - Method in interface com.mongodb.reactivestreams.client.ClientSession
-
Start a transaction in the context of this session with the given transaction options.
- Success - Enum in com.mongodb.reactivestreams.client
-
An enum representing a successful operation.
- updateMany(Bson, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Update all documents in the collection according to the specified arguments.
- updateMany(Bson, Bson, UpdateOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Update all documents in the collection according to the specified arguments.
- updateMany(ClientSession, Bson, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Update all documents in the collection according to the specified arguments.
- updateMany(ClientSession, Bson, Bson, UpdateOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Update all documents in the collection according to the specified arguments.
- updateOne(Bson, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Update a single document in the collection according to the specified arguments.
- updateOne(Bson, Bson, UpdateOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Update a single document in the collection according to the specified arguments.
- updateOne(ClientSession, Bson, Bson) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Update a single document in the collection according to the specified arguments.
- updateOne(ClientSession, Bson, Bson, UpdateOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Update a single document in the collection according to the specified arguments.
- uploadFromStream(String, AsyncInputStream) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Uploads the contents of the given AsyncInputStream
to a GridFS bucket.
- uploadFromStream(String, AsyncInputStream, GridFSUploadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Uploads the contents of the given AsyncInputStream
to a GridFS bucket.
- uploadFromStream(BsonValue, String, AsyncInputStream) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Uploads the contents of the given AsyncInputStream
to a GridFS bucket.
- uploadFromStream(BsonValue, String, AsyncInputStream, GridFSUploadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Uploads the contents of the given AsyncInputStream
to a GridFS bucket.
- uploadFromStream(ClientSession, String, AsyncInputStream) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Uploads the contents of the given AsyncInputStream
to a GridFS bucket.
- uploadFromStream(ClientSession, String, AsyncInputStream, GridFSUploadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Uploads the contents of the given AsyncInputStream
to a GridFS bucket.
- uploadFromStream(ClientSession, BsonValue, String, AsyncInputStream) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Uploads the contents of the given AsyncInputStream
to a GridFS bucket.
- uploadFromStream(ClientSession, BsonValue, String, AsyncInputStream, GridFSUploadOptions) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Uploads the contents of the given AsyncInputStream
to a GridFS bucket.
- useCursor(Boolean) - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
-
- watch() - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Creates a change stream for this client.
- watch(Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Creates a change stream for this client.
- watch(List<? extends Bson>) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Creates a change stream for this client.
- watch(List<? extends Bson>, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Creates a change stream for this client.
- watch(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Creates a change stream for this client.
- watch(ClientSession, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Creates a change stream for this client.
- watch(ClientSession, List<? extends Bson>) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Creates a change stream for this client.
- watch(ClientSession, List<? extends Bson>, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoClient
-
Creates a change stream for this client.
- watch() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates a change stream for this collection.
- watch(Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates a change stream for this collection.
- watch(List<? extends Bson>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates a change stream for this collection.
- watch(List<? extends Bson>, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates a change stream for this collection.
- watch(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates a change stream for this collection.
- watch(ClientSession, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates a change stream for this collection.
- watch(ClientSession, List<? extends Bson>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates a change stream for this collection.
- watch(ClientSession, List<? extends Bson>, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Creates a change stream for this collection.
- watch() - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a change stream for this database.
- watch(Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a change stream for this database.
- watch(List<? extends Bson>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a change stream for this database.
- watch(List<? extends Bson>, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a change stream for this database.
- watch(ClientSession) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a change stream for this database.
- watch(ClientSession, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a change stream for this database.
- watch(ClientSession, List<? extends Bson>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a change stream for this database.
- watch(ClientSession, List<? extends Bson>, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Creates a change stream for this database.
- withChunkSizeBytes(int) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Create a new GridFSBucket instance with a new chunk size in bytes.
- withCodecRegistry(CodecRegistry) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Create a new MongoCollection instance with a different codec registry.
- withCodecRegistry(CodecRegistry) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Create a new MongoDatabase instance with a different codec registry.
- withDisableMD5(boolean) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Create a new GridFSBucket instance with the set disable MD5 value.
- withDocumentClass(Class<TDocument>) - Method in interface com.mongodb.reactivestreams.client.ChangeStreamPublisher
-
Returns a MongoIterable
containing the results of the change stream based on the document class provided.
- withDocumentClass(Class<NewTDocument>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Create a new MongoCollection instance with a different default class to cast any documents returned from the database into..
- withReadConcern(ReadConcern) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Create a new MongoDatabase instance with a different read concern.
- withReadConcern(ReadConcern) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Create a new MongoCollection instance with a different read concern.
- withReadConcern(ReadConcern) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Create a new MongoDatabase instance with a different read concern.
- withReadPreference(ReadPreference) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Create a new GridFSBucket instance with a different read preference.
- withReadPreference(ReadPreference) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Create a new MongoCollection instance with a different read preference.
- withReadPreference(ReadPreference) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Create a new MongoDatabase instance with a different read preference.
- withWriteConcern(WriteConcern) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSBucket
-
Create a new GridFSBucket instance with a different write concern.
- withWriteConcern(WriteConcern) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
-
Create a new MongoCollection instance with a different write concern.
- withWriteConcern(WriteConcern) - Method in interface com.mongodb.reactivestreams.client.MongoDatabase
-
Create a new MongoDatabase instance with a different write concern.
- write(ByteBuffer) - Method in interface com.mongodb.reactivestreams.client.gridfs.AsyncOutputStream
-
Writes a sequence of bytes from the given buffer into this stream.