public static class ChangeStreamOptions.ChangeStreamOptionsBuilder extends Object
ChangeStreamOptions
.Modifier and Type | Method and Description |
---|---|
ChangeStreamOptions |
build() |
ChangeStreamOptions.ChangeStreamOptionsBuilder |
collation(Collation collation)
Set the collation to use.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
filter(Aggregation filter)
Set the filter to apply.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
filter(org.bson.Document... filter)
Set the plain filter chain to apply.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
fullDocumentLookup(com.mongodb.client.model.changestream.FullDocument lookup)
Set the
FullDocument lookup to use. |
ChangeStreamOptions.ChangeStreamOptionsBuilder |
resumeAfter(org.bson.BsonValue resumeToken)
Set the resume token after which to continue emitting notifications.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
resumeAt(org.bson.BsonTimestamp resumeTimestamp)
Set the cluster time to resume from.
|
ChangeStreamOptions.ChangeStreamOptionsBuilder |
resumeAt(Instant resumeTimestamp)
Set the cluster time to resume from.
|
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 |
returnFullDocumentOnUpdate()
Set the
FullDocument lookup to FullDocument.UPDATE_LOOKUP . |
ChangeStreamOptions.ChangeStreamOptionsBuilder |
startAfter(org.bson.BsonValue resumeToken)
Set the resume token after which to start emitting notifications.
|
public ChangeStreamOptions.ChangeStreamOptionsBuilder collation(Collation collation)
collation
- must not be null nor empty.public ChangeStreamOptions.ChangeStreamOptionsBuilder filter(Aggregation filter)
fullDocument
. However operationType, ns,
documentKey and fullDocument are reserved words that will be omitted, and therefore taken
as given, during the mapping procedure. You may want to have a look at the
structure of Change Events.
Use TypedAggregation
to ensure filter expressions are
mapped to domain type fields.filter
- the Aggregation pipeline
to apply for filtering events. Must not be
null.public ChangeStreamOptions.ChangeStreamOptionsBuilder filter(org.bson.Document... filter)
filter
- must not be null nor contain null values.public ChangeStreamOptions.ChangeStreamOptionsBuilder resumeToken(org.bson.BsonValue resumeToken)
BsonDocument
containing a binary
token
) after which to start with listening.resumeToken
- must not be null.public ChangeStreamOptions.ChangeStreamOptionsBuilder returnFullDocumentOnUpdate()
FullDocument
lookup to FullDocument.UPDATE_LOOKUP
.fullDocumentLookup(FullDocument)
public ChangeStreamOptions.ChangeStreamOptionsBuilder fullDocumentLookup(com.mongodb.client.model.changestream.FullDocument lookup)
FullDocument
lookup to use.lookup
- must not be null.public ChangeStreamOptions.ChangeStreamOptionsBuilder resumeAt(Instant resumeTimestamp)
resumeTimestamp
- must not be null.public ChangeStreamOptions.ChangeStreamOptionsBuilder resumeAt(org.bson.BsonTimestamp resumeTimestamp)
resumeTimestamp
- must not be null.public ChangeStreamOptions.ChangeStreamOptionsBuilder resumeAfter(org.bson.BsonValue resumeToken)
resumeToken
- must not be null.public ChangeStreamOptions.ChangeStreamOptionsBuilder startAfter(org.bson.BsonValue resumeToken)
resumeToken
- must not be null.public ChangeStreamOptions build()
ChangeStreamOptions
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.