Package | Description |
---|---|
com.mongodb.async.client |
This packages contains classes for the new async client
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
ChangeStreamIterableImpl<TResult> |
Modifier and Type | Method and Description |
---|---|
ChangeStreamIterable<TResult> |
ChangeStreamIterableImpl.batchSize(int batchSize) |
ChangeStreamIterable<TResult> |
ChangeStreamIterable.batchSize(int batchSize)
Sets the number of documents to return per batch.
|
ChangeStreamIterable<TResult> |
ChangeStreamIterableImpl.collation(Collation collation) |
ChangeStreamIterable<TResult> |
ChangeStreamIterable.collation(Collation collation)
Sets the collation options
|
private <TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.createChangeStreamIterable(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
ChangeStreamIterable<TResult> |
ChangeStreamIterableImpl.fullDocument(FullDocument fullDocument) |
ChangeStreamIterable<TResult> |
ChangeStreamIterable.fullDocument(FullDocument fullDocument)
Sets the fullDocument value.
|
ChangeStreamIterable<TResult> |
ChangeStreamIterableImpl.maxAwaitTime(long maxAwaitTime,
java.util.concurrent.TimeUnit timeUnit) |
ChangeStreamIterable<TResult> |
ChangeStreamIterable.maxAwaitTime(long maxAwaitTime,
java.util.concurrent.TimeUnit timeUnit)
Sets the maximum await execution time on the server for this operation.
|
ChangeStreamIterable<TResult> |
ChangeStreamIterableImpl.resumeAfter(BsonDocument resumeAfter) |
ChangeStreamIterable<TResult> |
ChangeStreamIterable.resumeAfter(BsonDocument resumeToken)
Sets the logical starting point for the new change stream.
|
ChangeStreamIterable<TDocument> |
MongoCollectionImpl.watch() |
ChangeStreamIterable<TDocument> |
MongoCollection.watch()
Creates a change stream for this collection.
|
<TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.watch(java.lang.Class<TResult> resultClass) |
<TResult> ChangeStreamIterable<TResult> |
MongoCollection.watch(java.lang.Class<TResult> resultClass)
Creates a change stream for this collection.
|
ChangeStreamIterable<TDocument> |
MongoCollectionImpl.watch(ClientSession clientSession) |
ChangeStreamIterable<TDocument> |
MongoCollection.watch(ClientSession clientSession)
Creates a change stream for this collection.
|
<TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.watch(ClientSession clientSession,
java.lang.Class<TResult> resultClass) |
<TResult> ChangeStreamIterable<TResult> |
MongoCollection.watch(ClientSession clientSession,
java.lang.Class<TResult> resultClass)
Creates a change stream for this collection.
|
ChangeStreamIterable<TDocument> |
MongoCollectionImpl.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline) |
ChangeStreamIterable<TDocument> |
MongoCollection.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline)
Creates a change stream for this collection.
|
<TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
<TResult> ChangeStreamIterable<TResult> |
MongoCollection.watch(ClientSession clientSession,
java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass)
Creates a change stream for this collection.
|
ChangeStreamIterable<TDocument> |
MongoCollectionImpl.watch(java.util.List<? extends Bson> pipeline) |
ChangeStreamIterable<TDocument> |
MongoCollection.watch(java.util.List<? extends Bson> pipeline)
Creates a change stream for this collection.
|
<TResult> ChangeStreamIterable<TResult> |
MongoCollectionImpl.watch(java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass) |
<TResult> ChangeStreamIterable<TResult> |
MongoCollection.watch(java.util.List<? extends Bson> pipeline,
java.lang.Class<TResult> resultClass)
Creates a change stream for this collection.
|