Package | Description |
---|---|
com.azure.cosmos |
This package provides interfaces for interacting with Azure Cosmos DB.
|
com.azure.cosmos.models |
This package provides rest contracts for interacting with Azure Cosmos DB SQL APIs.
|
Modifier and Type | Method and Description |
---|---|
ChangeFeedProcessorBuilder |
ChangeFeedProcessorBuilder.options(ChangeFeedProcessorOptions changeFeedProcessorOptions)
Sets the
ChangeFeedProcessorOptions to be used. |
Modifier and Type | Method and Description |
---|---|
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 (parallel workers) the host can run.
|
ChangeFeedProcessorOptions |
ChangeFeedProcessorOptions.setMinScaleCount(int minScaleCount)
Sets the minimum partition count (parallel workers) for the current 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(Instant startTime)
Sets the time (exclusive) to start looking for changes after (UTC time).
|
Copyright © 2021 Microsoft Corporation. All rights reserved.