CosmosBulkExecutionOptions Clase

Paquete:

com.azure.cosmos.models

Artefacto Maven:

com.azure:azure-cosmos:4.56.0

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

public final class CosmosBulkExecutionOptions

Encapsula las opciones que se pueden especificar para las operaciones usadas en ejecución masiva. Se puede pasar mientras se procesan operaciones masivas.

Resumen del constructor

Constructor	Description
CosmosBulkExecutionOptions()	Constructor
CosmosBulkExecutionOptions(CosmosBulkExecutionThresholdsState thresholdsState)	Constructor

Resumen del método

Modificador y tipo	Método y descripción
List<String>	getExcludedRegions() Obtiene la lista de regiones que se excluirán para la solicitud o reintentos.
int	getInitialMicroBatchSize() Obtiene el tamaño inicial de los micro lotes que se enviarán al back-end.
int	getMaxMicroBatchConcurrency() La simultaneidad máxima para ejecutar solicitudes para un intervalo de claves de partición.
CosmosBulkExecutionThresholdsState	getThresholdsState() Devuelve el estado de umbral que se puede pasar a otras opciones de ejecuciónmasivade Cosmosen el futuro.
String	getThroughputControlGroupName() Obtiene el nombre del grupo de control de rendimiento.
CosmosBulkExecutionOptions	setExcludedRegions(List<String> excludeRegions) Lista de regiones que se van a excluir para la solicitud o reintentos.
CosmosBulkExecutionOptions	setInitialMicroBatchSize(int initialMicroBatchSize) Establece el tamaño inicial de los micro lotes que se enviarán al back-end.
CosmosBulkExecutionOptions	setMaxMicroBatchConcurrency(int maxMicroBatchConcurrency) Establezca la simultaneidad máxima para ejecutar solicitudes para un intervalo de claves de partición.
CosmosBulkExecutionOptions	setThroughputControlGroupName(String throughputControlGroupName) Establece el nombre del grupo de control de rendimiento.

Métodos heredados de java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Detalles del constructor

CosmosBulkExecutionOptions

public CosmosBulkExecutionOptions()

Constructor

CosmosBulkExecutionOptions

public CosmosBulkExecutionOptions(CosmosBulkExecutionThresholdsState thresholdsState)

Constructor

Parameters:

thresholdsState - umbrales

Detalles del método

getExcludedRegions

public List getExcludedRegions()

Obtiene la lista de regiones que se excluirán para la solicitud o reintentos. Estas regiones se excluyen de la lista de regiones preferidas.

Returns:

una lista de regiones excluidas

getInitialMicroBatchSize

public int getInitialMicroBatchSize()

Obtiene el tamaño inicial de los micro lotes que se enviarán al back-end. El tamaño de los micro lotes se ajustará dinámicamente en función de la velocidad de limitación. El valor predeterminado es 100, por lo que comienza con micro lotes relativamente grandes y cuando la velocidad de limitación es demasiado alta, reducirá el tamaño del lote. Cuando los picos cortos de limitación antes de reducir dinámicamente el tamaño inicial del lote da como resultado efectos secundarios para otras cargas de trabajo, el tamaño inicial del micro lote se puede reducir( por ejemplo, establecido en 1, momento en el que empezaría con pequeños micro lotes y, a continuación, aumentar el tamaño del lote a lo largo del tiempo.

Returns:

el tamaño inicial de micro lotes

getMaxMicroBatchConcurrency

public int getMaxMicroBatchConcurrency()

La simultaneidad máxima para ejecutar solicitudes para un intervalo de claves de partición. De forma predeterminada, maxMicroBatchConcurrency es 1.

Returns:

simultaneidad máxima de micro lotes

getThresholdsState

public CosmosBulkExecutionThresholdsState getThresholdsState()

Devuelve el estado de umbral que se puede pasar a otros CosmosBulkExecutionOptions en el futuro.

Returns:

umbrales

getThroughputControlGroupName

public String getThroughputControlGroupName()

Obtiene el nombre del grupo de control de rendimiento.

Returns:

el nombre del grupo de control de rendimiento.

setExcludedRegions

public CosmosBulkExecutionOptions setExcludedRegions(List excludeRegions)

Lista de regiones que se van a excluir para la solicitud o reintentos. Ejemplo "Este de EE. UU." o "Este de EE. UU., Oeste de EE. UU." Estas regiones se excluirán de la lista de regiones preferidas.

Parameters:

excludeRegions - lista de regiones

Returns:

el CosmosBulkExecutionOptions

setInitialMicroBatchSize

public CosmosBulkExecutionOptions setInitialMicroBatchSize(int initialMicroBatchSize)

Establece el tamaño inicial de los micro lotes que se enviarán al back-end. El tamaño de los micro lotes se ajustará dinámicamente en función de la velocidad de limitación. El valor predeterminado es 100, por lo que comienza con micro lotes relativamente grandes y cuando la velocidad de limitación es demasiado alta, reducirá el tamaño del lote. Cuando los picos cortos de limitación antes de reducir dinámicamente el tamaño inicial del lote da como resultado efectos secundarios para otras cargas de trabajo, el tamaño inicial del micro lote se puede reducir( por ejemplo, establecido en 1, momento en el que empezaría con pequeños micro lotes y, a continuación, aumentar el tamaño del lote a lo largo del tiempo.

Parameters:

initialMicroBatchSize - el tamaño inicial del micro lote que se va a usar. Debe ser un entero positivo.

Returns:

las opciones de ejecución masiva.

setMaxMicroBatchConcurrency

public CosmosBulkExecutionOptions setMaxMicroBatchConcurrency(int maxMicroBatchConcurrency)

Establezca la simultaneidad máxima para ejecutar solicitudes para un intervalo de claves de partición. De forma predeterminada, maxMicroBatchConcurrency es 1. Solo permite valores ?1 y ?5. Atención Por favor, ajuste este valor con precaución. Al aumentar este valor, se permitirá que se envíen más solicitudes simultáneas al servidor, en cuyo caso puede provocar un tiempo de espera de 429 o una solicitud debido a saturar los recursos locales, lo que podría degradar el rendimiento.

Parameters:

maxMicroBatchConcurrency - la simultaneidad de micro lotes.

Returns:

las opciones de procesamiento masivo.

setThroughputControlGroupName

public CosmosBulkExecutionOptions setThroughputControlGroupName(String throughputControlGroupName)

Establece el nombre del grupo de control de rendimiento.

Parameters:

throughputControlGroupName - el nombre del grupo de control de rendimiento.

Returns:

CosmosBulkExecutionOptions.