Freigeben über

CosmosBulkExecutionOptions Klasse

  • Referenz
Paket:
com.azure.cosmos.models
Maven-Artefakt:
com.azure:azure-cosmos:4.56.0
  • java.lang.Object
    • com.azure.cosmos.models.CosmosBulkExecutionOptions

public final class CosmosBulkExecutionOptions

Kapselt Optionen, die für Vorgänge angegeben werden können, die in der Massenausführung verwendet werden. Sie kann beim Verarbeiten von Massenvorgängen übergeben werden.

Zusammenfassung zum Konstruktor

Konstruktor Beschreibung
CosmosBulkExecutionOptions()

Konstruktor
CosmosBulkExecutionOptions(CosmosBulkExecutionThresholdsState thresholdsState)

Konstruktor

Methodenzusammenfassung

Modifizierer und Typ Methode und Beschreibung
List<String> getExcludedRegions()

Ruft die Liste der Regionen ab, die für die Anforderung/Wiederholung ausgeschlossen werden sollen.
int getInitialMicroBatchSize()

Ruft die anfängliche Größe von Mikrobatches ab, die an das Back-End gesendet werden.
int getMaxMicroBatchConcurrency()

Die maximale Parallelität für die Ausführung von Anforderungen für einen Partitionsschlüsselbereich.
CosmosBulkExecutionThresholdsState getThresholdsState()

Gibt den Schwellenwertstatus zurück, der in Zukunft an andere Cosmos-Massenausführungsoptionenübergeben werden kann.
String getThroughputControlGroupName()

Ruft den Namen der Durchsatzsteuerungsgruppe ab.
CosmosBulkExecutionOptions setExcludedRegions(List<String> excludeRegions)

Liste der Regionen, die für die Anforderung/Wiederholung ausgeschlossen werden sollen.
CosmosBulkExecutionOptions setInitialMicroBatchSize(int initialMicroBatchSize)

Legt die anfängliche Größe von Mikrobatches fest, die an das Back-End gesendet werden.
CosmosBulkExecutionOptions setMaxMicroBatchConcurrency(int maxMicroBatchConcurrency)

Legen Sie die maximale Parallelität für die Ausführung von Anforderungen für einen Partitionsschlüsselbereich fest.
CosmosBulkExecutionOptions setThroughputControlGroupName(String throughputControlGroupName)

Legt den Namen der Durchsatzsteuerungsgruppe fest.

Geerbte Methoden von java.lang.Object

clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Details zum Konstruktor

CosmosBulkExecutionOptions

public CosmosBulkExecutionOptions()

Konstruktor

CosmosBulkExecutionOptions

public CosmosBulkExecutionOptions(CosmosBulkExecutionThresholdsState thresholdsState)

Konstruktor

Parameters:

thresholdsState - Schwellenwerte

Details zur Methode

getExcludedRegions

public List getExcludedRegions()

Ruft die Liste der Regionen ab, die für die Anforderung/Wiederholung ausgeschlossen werden sollen. Diese Regionen werden aus der Liste der bevorzugten Regionen ausgeschlossen.

Returns:

Liste der ausgeschlossenen Regionen

getInitialMicroBatchSize

public int getInitialMicroBatchSize()

Ruft die anfängliche Größe von Mikrobatches ab, die an das Back-End gesendet werden. Die Größe von Mikrobatches wird basierend auf der Drosselungsrate dynamisch angepasst. Der Standardwert ist 100. Er beginnt also mit relativ großen Mikrobatches, und wenn die Drosselungsrate zu hoch ist, wird die Batchgröße reduziert. Wenn die kurzen Spitzen der Drosselung vor der dynamischen Reduzierung der anfänglichen Batchgröße zu Nebenwirkungen für andere Workloads führen, kann die anfängliche Mikrobatchgröße reduziert werden - z. B. auf 1 festgelegt -, ab dem sie mit kleinen Mikrobatches beginnt und dann die Batchgröße im Laufe der Zeit erhöht.

Returns:

die anfängliche Mikrobatchgröße

getMaxMicroBatchConcurrency

public int getMaxMicroBatchConcurrency()

Die maximale Parallelität für die Ausführung von Anforderungen für einen Partitionsschlüsselbereich. Standardmäßig ist maxMicroBatchConcurrency 1.

Returns:

Maximale Mikrobatchkoncurrency

getThresholdsState

public CosmosBulkExecutionThresholdsState getThresholdsState()

Gibt den Schwellenwertstatus zurück, der in Zukunft an andere CosmosBulkExecutionOptions übergeben werden kann.

Returns:

Schwellenwerte

getThroughputControlGroupName

public String getThroughputControlGroupName()

Ruft den Namen der Durchsatzsteuerungsgruppe ab.

Returns:

der Name der Durchsatzsteuerungsgruppe.

setExcludedRegions

public CosmosBulkExecutionOptions setExcludedRegions(List excludeRegions)

Liste der Regionen, die für die Anforderung/Wiederholung ausgeschlossen werden sollen. Beispiel "USA, Osten" oder "USA, Osten, USA, Westen" Diese Regionen werden aus der Liste der bevorzugten Regionen ausgeschlossen.

Parameters:

excludeRegions - Liste der Regionen

Returns:

setInitialMicroBatchSize

public CosmosBulkExecutionOptions setInitialMicroBatchSize(int initialMicroBatchSize)

Legt die anfängliche Größe von Mikrobatches fest, die an das Back-End gesendet werden. Die Größe von Mikrobatches wird basierend auf der Drosselungsrate dynamisch angepasst. Der Standardwert ist 100. Er beginnt also mit relativ großen Mikrobatches, und wenn die Drosselungsrate zu hoch ist, wird die Batchgröße reduziert. Wenn die kurzen Spitzen der Drosselung vor der dynamischen Reduzierung der anfänglichen Batchgröße zu Nebenwirkungen für andere Workloads führen, kann die anfängliche Mikrobatchgröße reduziert werden - z. B. auf 1 festgelegt -, ab dem sie mit kleinen Mikrobatches beginnt und dann die Batchgröße im Laufe der Zeit erhöht.

Parameters:

initialMicroBatchSize - die anfängliche Mikrobatchgröße, die verwendet werden soll. Der Wert muss eine positive ganze Zahl sein.

Returns:

die Massenausführungsoptionen.

setMaxMicroBatchConcurrency

public CosmosBulkExecutionOptions setMaxMicroBatchConcurrency(int maxMicroBatchConcurrency)

Legen Sie die maximale Parallelität für die Ausführung von Anforderungen für einen Partitionsschlüsselbereich fest. Standardmäßig ist maxMicroBatchConcurrency 1. Sie lässt nur die Werte ?1 und ?5 zu. Achtung! Passen Sie diesen Wert mit Vorsicht an. Durch Erhöhen dieses Werts können mehr gleichzeitige Anforderungen an den Server gesendet werden. In diesem Fall kann es zu einem Zeitlimit von 429 oder einer Anforderung aufgrund der Sättigung lokaler Ressourcen führen, was die Leistung beeinträchtigen kann.

Parameters:

maxMicroBatchConcurrency - Die Parallelität des Mikrobatches.

Returns:

die Massenverarbeitungsoptionen.

setThroughputControlGroupName

public CosmosBulkExecutionOptions setThroughputControlGroupName(String throughputControlGroupName)

Legt den Namen der Durchsatzsteuerungsgruppe fest.

Parameters:

throughputControlGroupName - der Name der Durchsatzsteuerungsgruppe.

Returns:

CosmosBulkExecutionOptions.

Gilt für: