Modifier and Type | Method and Description |
---|---|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setDiscardExistingLeases(boolean discardExistingLeases)
Sets a value indicating whether on start of the host all existing leases should be deleted and the host
should start from scratch.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setFeedPollDelay(Duration feedPollDelay)
Sets the delay in between polling a partition for new changes on the feed, after all current changes are drained.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setLeaseAcquireInterval(Duration leaseAcquireInterval)
Sets he interval to kick off a task to compute if partitions are distributed evenly among known host instances.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setLeaseExpirationInterval(Duration leaseExpirationInterval)
Sets the interval for which the lease is taken on a lease representing a partition.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setLeasePrefix(String leasePrefix)
Sets a prefix to be used as part of the lease ID.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setLeaseRenewInterval(Duration leaseRenewInterval)
Sets the renew interval for all leases for partitions currently held by
ChangeFeedProcessor instance. |
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setMaxItemCount(int maxItemCount)
Sets the maximum number of items to be returned in the enumeration operation.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setMaxScaleCount(int maxScaleCount)
Sets the maximum number of partitions the host can serve.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setMinScaleCount(int minScaleCount)
Sets the minimum partition count for the host.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setStartContinuation(String startContinuation)
Sets the start request continuation token to start looking for changes after.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setStartFromBeginning(boolean startFromBeginning)
Sets a value indicating whether change feed in the Azure Cosmos DB service should start from beginning.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setStartTime(OffsetDateTime startTime)
Sets the time (exclusive) to start looking for changes after (UTC time).
|
Modifier and Type | Method and Description |
---|---|
ChangeFeedProcessor.BuilderDefinition |
ChangeFeedProcessor.BuilderDefinition.setOptions(ChangeFeedProcessorOptions changeFeedProcessorOptions)
Sets the
ChangeFeedProcessorOptions to be used. |
Copyright © 2020 Microsoft Corporation. All rights reserved.