Skip navigation links
A B C D E F G H I J L M N O P R S T U V W 

A

abort() - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSUploadStream
Aborts the upload and deletes any data.
abortTransaction() - Method in interface com.mongodb.reactivestreams.client.ClientSession
Abort a transaction in the context of this session.
action(MapReduceAction) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
Specify the MapReduceAction to be used when writing to a collection.
aggregate(List<? extends Bson>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Aggregates documents according to the specified aggregation pipeline.
aggregate(List<? extends Bson>, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Aggregates documents according to the specified aggregation pipeline.
aggregate(ClientSession, List<? extends Bson>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Aggregates documents according to the specified aggregation pipeline.
aggregate(ClientSession, List<? extends Bson>, Class<TResult>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Aggregates documents according to the specified aggregation pipeline.
AggregatePublisher<TResult> - Interface in com.mongodb.reactivestreams.client
Publisher for aggregate.
allowDiskUse(Boolean) - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
Enables writing to temporary files.
AsyncInputStream - Interface in com.mongodb.reactivestreams.client.gridfs
The Async Input Stream interface represents some asynchronous input stream of bytes.
AsyncOutputStream - Interface in com.mongodb.reactivestreams.client.gridfs
The Async Output Stream interface represents some asynchronous output stream of bytes.
AsyncStreamHelper - Class in com.mongodb.reactivestreams.client.gridfs.helpers
A general helper class that creates AsyncInputStream or AsyncOutputStream instances.

B

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.

C

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
Contains helper classes to create AsyncInputStream and AsyncOutputStream's from external sources.
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
Deprecated.
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.

D

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.

E

estimatedDocumentCount() - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Gets an estimate of the count of documents in a collection using collection metadata.
estimatedDocumentCount(EstimatedDocumentCountOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Gets an estimate of the count of documents in a collection using collection metadata.

F

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.

G

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
The BsonValue id for this file.
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
Gets the ObjectId for the file to be uploaded Throws a MongoGridFSException if the file id is not an ObjectId.
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
Deprecated.
this method is being removed
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

H

hasActiveTransaction() - Method in interface com.mongodb.reactivestreams.client.ClientSession
Returns true if there is an active transaction on this session, and false otherwise
hint(Bson) - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
Sets the hint for which index to use.
hint(Bson) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
Sets the hint for which index to use.

I

insertMany(List<? extends TDocument>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Inserts a batch of documents.
insertMany(List<? extends TDocument>, InsertManyOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Inserts a batch of documents.
insertMany(ClientSession, List<? extends TDocument>) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Inserts a batch of documents.
insertMany(ClientSession, List<? extends TDocument>, InsertManyOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Inserts a batch of documents.
insertOne(TDocument) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Inserts the provided document.
insertOne(TDocument, InsertOneOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Inserts the provided document.
insertOne(ClientSession, TDocument) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Inserts the provided document.
insertOne(ClientSession, TDocument, InsertOneOptions) - Method in interface com.mongodb.reactivestreams.client.MongoCollection
Inserts the provided document.

J

jsMode(boolean) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
Sets the flag that specifies whether to convert intermediate data into BSON format between the execution of the map and reduce functions.

L

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.

M

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
Deprecated.
Deprecated as of MongoDB 4.0 release
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
Deprecated.
use the individual setters instead
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.

N

nameOnly(Boolean) - Method in interface com.mongodb.reactivestreams.client.ListDatabasesPublisher
Sets the nameOnly flag that indicates whether the command should return just the database names or return the database names and size information.
noCursorTimeout(boolean) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use.
noCursorTimeout(boolean) - Method in interface com.mongodb.reactivestreams.client.gridfs.GridFSFindPublisher
The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use.
nonAtomic(boolean) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
Sets if the post-processing step will prevent MongoDB from locking the database.

O

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.

P

partial(boolean) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
Get partial results from a sharded cluster if one or more shards are unreachable (instead of throwing an error).
projection(Bson) - Method in interface com.mongodb.reactivestreams.client.FindPublisher
Sets a document describing the fields to return for all matching documents.

R

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.

S

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
Deprecated.
Deprecated in MongoDB 3.6 release and removed in MongoDB 4.0 release
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.

T

toAsyncInputStream(byte[]) - Static method in class com.mongodb.reactivestreams.client.gridfs.helpers.AsyncStreamHelper
Converts a byte[] into a AsyncInputStream
toAsyncInputStream(ByteBuffer) - Static method in class com.mongodb.reactivestreams.client.gridfs.helpers.AsyncStreamHelper
Converts a ByteBuffer into a AsyncInputStream
toAsyncInputStream(InputStream) - Static method in class com.mongodb.reactivestreams.client.gridfs.helpers.AsyncStreamHelper
Converts a InputStream into a AsyncInputStream
toAsyncOutputStream(byte[]) - Static method in class com.mongodb.reactivestreams.client.gridfs.helpers.AsyncStreamHelper
Converts a byte[] into a AsyncOutputStream
toAsyncOutputStream(ByteBuffer) - Static method in class com.mongodb.reactivestreams.client.gridfs.helpers.AsyncStreamHelper
Converts a ByteBuffer into a AsyncOutputStream
toAsyncOutputStream(OutputStream) - Static method in class com.mongodb.reactivestreams.client.gridfs.helpers.AsyncStreamHelper
toCollection() - Method in interface com.mongodb.reactivestreams.client.AggregatePublisher
Aggregates documents according to the specified aggregation pipeline, which must end with a $out stage.
toCollection() - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
Aggregates documents to a collection according to the specified map-reduce function with the given options, which must specify a non-inline result.

U

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
Deprecated.
There is no replacement for this. Applications can assume that the driver will use a cursor for server versions that support it (>= 2.6). The driver will ignore this as of MongoDB 3.6, which does not support inline results for the aggregate command.

V

valueOf(String) - Static method in enum com.mongodb.reactivestreams.client.Success
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.mongodb.reactivestreams.client.Success
Returns an array containing the constants of this enum type, in the order they are declared.
verbose(boolean) - Method in interface com.mongodb.reactivestreams.client.MapReducePublisher
Sets whether to include the timing information in the result information.

W

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.
A B C D E F G H I J L M N O P R S T U V W 
Skip navigation links