Package | Description |
---|---|
org.springframework.data.mongodb.core |
MongoDB core support.
|
Modifier and Type | Method and Description |
---|---|
static ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.builder()
Obtain a shiny new
ChangeStreamOptions.ChangeStreamOptionsBuilder and start defining options in this fancy fluent way. |
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.collation(Collation collation)
Set the collation to use.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.filter(Aggregation filter)
Set the filter to apply.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.filter(org.bson.Document... filter)
Set the plain filter chain to apply.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.fullDocumentLookup(com.mongodb.client.model.changestream.FullDocument lookup)
Set the
FullDocument lookup to use. |
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.resumeAfter(org.bson.BsonValue resumeToken)
Set the resume token after which to continue emitting notifications.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.resumeAt(org.bson.BsonTimestamp resumeTimestamp)
Set the cluster time to resume from.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.resumeAt(Instant resumeTimestamp)
Set the cluster time to resume from.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.resumeToken(org.bson.BsonValue resumeToken)
Set the resume token (typically a
BsonDocument containing a binary
token ) after which to start with listening. |
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.returnFullDocumentOnUpdate()
Set the
FullDocument lookup to FullDocument.UPDATE_LOOKUP . |
ChangeStreamOptions.ChangeStreamOptionsBuilder |
ChangeStreamOptions.ChangeStreamOptionsBuilder.startAfter(org.bson.BsonValue resumeToken)
Set the resume token after which to start emitting notifications.
|
Modifier and Type | Method and Description |
---|---|
ReactiveChangeStreamOperation.ReactiveChangeStream<T> |
ReactiveChangeStreamOperation.ChangeStreamWithOptions.withOptions(Consumer<ChangeStreamOptions.ChangeStreamOptionsBuilder> optionsConsumer)
Provide some options via the callback by modifying the given
ChangeStreamOptions.ChangeStreamOptionsBuilder . |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.