Package | Description |
---|---|
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Field and Description |
---|---|
private ChangeStreamOperation<T> |
AsyncChangeStreamBatchCursor.changeStreamOperation |
private ChangeStreamOperation<T> |
ChangeStreamBatchCursor.changeStreamOperation |
Modifier and Type | Method and Description |
---|---|
ChangeStreamOperation<T> |
ChangeStreamOperation.batchSize(java.lang.Integer batchSize)
Sets the number of documents to return per batch.
|
ChangeStreamOperation<T> |
ChangeStreamOperation.collation(Collation collation)
Sets the collation options
|
ChangeStreamOperation<T> |
ChangeStreamOperation.maxAwaitTime(long maxAwaitTime,
java.util.concurrent.TimeUnit timeUnit)
Sets the maximum await execution time on the server for this operation.
|
ChangeStreamOperation<T> |
ChangeStreamOperation.readConcern(ReadConcern readConcern)
Sets the read concern
|
ChangeStreamOperation<T> |
ChangeStreamOperation.resumeAfter(BsonDocument resumeToken)
Sets the logical starting point for the new change stream.
|
Constructor and Description |
---|
AsyncChangeStreamBatchCursor(ChangeStreamOperation<T> changeStreamOperation,
AsyncBatchCursor<RawBsonDocument> wrapped,
AsyncReadBinding binding) |
ChangeStreamBatchCursor(ChangeStreamOperation<T> changeStreamOperation,
BatchCursor<RawBsonDocument> wrapped,
ReadBinding binding) |