CosmosBulkExecutionOptions Classe

Pacote:

com.azure.cosmos.models

Artefato Maven:

com.azure:azure-cosmos:4.56.0

• java.lang.Object
• • com.azure.cosmos.models.CosmosBulkExecutionOptions

public final class CosmosBulkExecutionOptions

Encapsula as opções que podem ser especificadas para operações usadas na execução em massa. Ele pode ser passado durante o processamento de operações em massa.

Resumo do Construtor

Construtor	Description
CosmosBulkExecutionOptions()	Construtor
CosmosBulkExecutionOptions(CosmosBulkExecutionThresholdsState thresholdsState)	Construtor

Resumo do método

Modificador e tipo	Método e descrição
List<String>	getExcludedRegions() Obtém a lista de regiões a serem excluídas para a solicitação/repetições.
int	getInitialMicroBatchSize() Obtém o tamanho inicial de micro lotes que serão enviados para o back-end.
int	getMaxMicroBatchConcurrency() A simultaneidade máxima para executar solicitações para um intervalo de chaves de partição.
CosmosBulkExecutionThresholdsState	getThresholdsState() Retorna o estado limite que pode ser passado para outras opções de execuçãoem massado Cosmosno futuro
String	getThroughputControlGroupName() Obtém o nome do grupo de controle de taxa de transferência.
CosmosBulkExecutionOptions	setExcludedRegions(List<String> excludeRegions) Lista de regiões a serem excluídas para a solicitação/repetições.
CosmosBulkExecutionOptions	setInitialMicroBatchSize(int initialMicroBatchSize) Define o tamanho inicial de microlotes que serão enviados para o back-end.
CosmosBulkExecutionOptions	setMaxMicroBatchConcurrency(int maxMicroBatchConcurrency) Defina a simultaneidade máxima para executar solicitações para um intervalo de chaves de partição.
CosmosBulkExecutionOptions	setThroughputControlGroupName(String throughputControlGroupName) Define o nome do grupo de controle de taxa de transferência.

Métodos herdados de java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Detalhes do construtor

CosmosBulkExecutionOptions

public CosmosBulkExecutionOptions()

Construtor

CosmosBulkExecutionOptions

public CosmosBulkExecutionOptions(CosmosBulkExecutionThresholdsState thresholdsState)

Construtor

Parameters:

thresholdsState - limites

Detalhes do método

getExcludedRegions

public List getExcludedRegions()

Obtém a lista de regiões a serem excluídas para a solicitação/repetições. Essas regiões são excluídas da lista de regiões preferenciais.

Returns:

uma lista de regiões excluídas

getInitialMicroBatchSize

public int getInitialMicroBatchSize()

Obtém o tamanho inicial de micro lotes que serão enviados para o back-end. O tamanho dos microlotes será ajustado dinamicamente com base na taxa de limitação. O valor padrão é 100 – portanto, ele começa com micro lotes relativamente grandes e quando a taxa de limitação é muito alta, reduz o tamanho do lote. Quando os picos curtos de limitação antes de reduzir dinamicamente o tamanho inicial do lote resultam em efeitos colaterais para outras cargas de trabalho, o tamanho inicial do microlote pode ser reduzido - por exemplo, definido como 1 - nesse ponto ele começaria com pequenos micro lotes e, em seguida, aumentaria o tamanho do lote ao longo do tempo.

Returns:

o tamanho inicial do microlote

getMaxMicroBatchConcurrency

public int getMaxMicroBatchConcurrency()

A simultaneidade máxima para executar solicitações para um intervalo de chaves de partição. Por padrão, maxMicroBatchConcurrency é 1.

Returns:

simultaneidade máxima do microlote

getThresholdsState

public CosmosBulkExecutionThresholdsState getThresholdsState()

Retorna o estado limite que pode ser passado para outros CosmosBulkExecutionOptions no futuro

Returns:

limites

getThroughputControlGroupName

public String getThroughputControlGroupName()

Obtém o nome do grupo de controle de taxa de transferência.

Returns:

o nome do grupo de controle de taxa de transferência.

setExcludedRegions

public CosmosBulkExecutionOptions setExcludedRegions(List excludeRegions)

Lista de regiões a serem excluídas para a solicitação/repetições. Exemplo de "Leste dos EUA" ou "Leste dos EUA, Oeste dos EUA" Essas regiões serão excluídas da lista de regiões preferenciais

Parameters:

excludeRegions - lista de regiões

Returns:

O CosmosBulkExecutionOptions

setInitialMicroBatchSize

public CosmosBulkExecutionOptions setInitialMicroBatchSize(int initialMicroBatchSize)

Define o tamanho inicial de microlotes que serão enviados para o back-end. O tamanho dos microlotes será ajustado dinamicamente com base na taxa de limitação. O valor padrão é 100 – portanto, ele começa com micro lotes relativamente grandes e quando a taxa de limitação é muito alta, reduz o tamanho do lote. Quando os picos curtos de limitação antes de reduzir dinamicamente o tamanho inicial do lote resultam em efeitos colaterais para outras cargas de trabalho, o tamanho inicial do microlote pode ser reduzido - por exemplo, definido como 1 - nesse ponto ele começaria com pequenos micro lotes e, em seguida, aumentaria o tamanho do lote ao longo do tempo.

Parameters:

initialMicroBatchSize - o tamanho inicial do microlote a ser usado. Deve ser um número inteiro positivo.

Returns:

as opções de execução em massa.

setMaxMicroBatchConcurrency

public CosmosBulkExecutionOptions setMaxMicroBatchConcurrency(int maxMicroBatchConcurrency)

Defina a simultaneidade máxima para executar solicitações para um intervalo de chaves de partição. Por padrão, maxMicroBatchConcurrency é 1. Ele só permite valores ?1 e ?5. Atenção! Ajuste esse valor com cuidado. Ao aumentar esse valor, mais solicitações simultâneas poderão ser enviadas ao servidor, o que pode causar 429 ou tempo limite de solicitação devido a recursos locais saturados, o que pode prejudicar o desempenho.

Parameters:

maxMicroBatchConcurrency - a simultaneidade do microlote.

Returns:

as opções de processamento em massa.

setThroughputControlGroupName

public CosmosBulkExecutionOptions setThroughputControlGroupName(String throughputControlGroupName)

Define o nome do grupo de controle de taxa de transferência.

Parameters:

throughputControlGroupName - o nome do grupo de controle de taxa de transferência.

Returns:

o CosmosBulkExecutionOptions.