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