Modifier and Type | Method and Description |
---|---|
ChangeFeedOptions |
ChangeFeedOptions.maxItemCount(Integer maxItemCount)
Sets the maximum number of items to be returned in the enumeration
operation.
|
ChangeFeedOptions |
ChangeFeedOptions.partitionKey(PartitionKey partitionkey)
Sets the partition key used to identify the current request's target
partition.
|
ChangeFeedOptions |
ChangeFeedOptions.properties(Map<String,Object> properties)
Sets the properties used to identify the request token.
|
ChangeFeedOptions |
ChangeFeedOptions.requestContinuation(String requestContinuation)
Sets the request continuation token.
|
ChangeFeedOptions |
ChangeFeedOptions.startDateTime(OffsetDateTime startDateTime)
Sets the zoned date time (exclusive) to start looking for changes after.
|
ChangeFeedOptions |
ChangeFeedOptions.startFromBeginning(boolean startFromBeginning)
Set whether change feed should start from beginning (true) or from current
(false).
|
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<FeedResponse<CosmosItemProperties>> |
CosmosContainer.queryChangeFeedItems(ChangeFeedOptions changeFeedOptions)
Query for documents in a items in a container
After subscription the operation will be performed.
|
Constructor and Description |
---|
ChangeFeedOptions(ChangeFeedOptions options) |
Copyright © 2019. All rights reserved.