From 6448ad58bf3af2127e960c6d861d2bf6fc96fe7e Mon Sep 17 00:00:00 2001 From: "ci.datadog-api-spec" Date: Fri, 23 Oct 2026 17:01:30 +0000 Subject: [PATCH] Regenerate client from commit 7051b32 of spec repo --- .generator/schemas/v2/openapi.yaml | 21 ++++- ...yPipelineAzureDataExplorerDestination.java | 43 +++++++++++ ...lineAzureDataExplorerDestinationBatch.java | 2 +- ...eDataExplorerDestinationIngestionMode.java | 76 +++++++++++++++++++ 4 files changed, 140 insertions(+), 2 deletions(-) create mode 100644 src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationIngestionMode.java diff --git a/.generator/schemas/v2/openapi.yaml b/.generator/schemas/v2/openapi.yaml index 96bcf5becc2..b3c877ef5d0 100644 --- a/.generator/schemas/v2/openapi.yaml +++ b/.generator/schemas/v2/openapi.yaml @@ -84087,6 +84087,8 @@ components: Defaults to `DESTINATION_AZURE_DATA_EXPLORER_INGESTION_ENDPOINT` (prefixed with `DD_OP_` at runtime). example: AZURE_DATA_EXPLORER_INGESTION_ENDPOINT type: string + ingestion_mode: + $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationIngestionMode" inputs: description: A list of component IDs whose output is used as the `input` for this component. example: ["filter-processor"] @@ -84278,7 +84280,7 @@ components: description: Maximum batch size in bytes. example: 2000000 format: int64 - maximum: 4000000 + maximum: 1000000000 minimum: 1 type: integer max_events: @@ -84294,6 +84296,23 @@ components: minimum: 1 type: integer type: object + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode: + default: streaming + description: |- + The ingestion method used to send data to Azure Data Explorer. + + - `streaming`: Sends events directly to the table using streaming ingestion. + - `queue`: Sends events through queued (batched) ingestion. + + Defaults to `streaming`. + enum: + - streaming + - queue + example: queue + type: string + x-enum-varnames: + - STREAMING + - QUEUE ObservabilityPipelineAzureDataExplorerDestinationManagedIdentityIdType: description: The type of the user-assigned managed identity ID. enum: diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestination.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestination.java index 0c5ac90e752..eaa6e0783a3 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestination.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestination.java @@ -34,6 +34,7 @@ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_DATABASE, ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_ID, ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_INGESTION_ENDPOINT_KEY, + ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_INGESTION_MODE, ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_INPUTS, ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_MAPPING_REFERENCE, ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_TABLE, @@ -65,6 +66,10 @@ public class ObservabilityPipelineAzureDataExplorerDestination { public static final String JSON_PROPERTY_INGESTION_ENDPOINT_KEY = "ingestion_endpoint_key"; private String ingestionEndpointKey; + public static final String JSON_PROPERTY_INGESTION_MODE = "ingestion_mode"; + private ObservabilityPipelineAzureDataExplorerDestinationIngestionMode ingestionMode = + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode.STREAMING; + public static final String JSON_PROPERTY_INPUTS = "inputs"; private List inputs = new ArrayList<>(); @@ -272,6 +277,40 @@ public void setIngestionEndpointKey(String ingestionEndpointKey) { this.ingestionEndpointKey = ingestionEndpointKey; } + public ObservabilityPipelineAzureDataExplorerDestination ingestionMode( + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode ingestionMode) { + this.ingestionMode = ingestionMode; + this.unparsed |= !ingestionMode.isValid(); + return this; + } + + /** + * The ingestion method used to send data to Azure Data Explorer. + * + * + * + *

Defaults to streaming. + * + * @return ingestionMode + */ + @jakarta.annotation.Nullable + @JsonProperty(JSON_PROPERTY_INGESTION_MODE) + @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS) + public ObservabilityPipelineAzureDataExplorerDestinationIngestionMode getIngestionMode() { + return ingestionMode; + } + + public void setIngestionMode( + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode ingestionMode) { + if (!ingestionMode.isValid()) { + this.unparsed = true; + } + this.ingestionMode = ingestionMode; + } + public ObservabilityPipelineAzureDataExplorerDestination inputs(List inputs) { this.inputs = inputs; return this; @@ -466,6 +505,8 @@ public boolean equals(Object o) { && Objects.equals( this.ingestionEndpointKey, observabilityPipelineAzureDataExplorerDestination.ingestionEndpointKey) + && Objects.equals( + this.ingestionMode, observabilityPipelineAzureDataExplorerDestination.ingestionMode) && Objects.equals(this.inputs, observabilityPipelineAzureDataExplorerDestination.inputs) && Objects.equals( this.mappingReference, @@ -489,6 +530,7 @@ public int hashCode() { database, id, ingestionEndpointKey, + ingestionMode, inputs, mappingReference, table, @@ -510,6 +552,7 @@ public String toString() { sb.append(" ingestionEndpointKey: ") .append(toIndentedString(ingestionEndpointKey)) .append("\n"); + sb.append(" ingestionMode: ").append(toIndentedString(ingestionMode)).append("\n"); sb.append(" inputs: ").append(toIndentedString(inputs)).append("\n"); sb.append(" mappingReference: ").append(toIndentedString(mappingReference)).append("\n"); sb.append(" table: ").append(toIndentedString(table)).append("\n"); diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationBatch.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationBatch.java index aa850d358df..63be84f5474 100644 --- a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationBatch.java +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationBatch.java @@ -41,7 +41,7 @@ public ObservabilityPipelineAzureDataExplorerDestinationBatch maxBytes(Long maxB } /** - * Maximum batch size in bytes. minimum: 1 maximum: 4000000 + * Maximum batch size in bytes. minimum: 1 maximum: 1000000000 * * @return maxBytes */ diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationIngestionMode.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationIngestionMode.java new file mode 100644 index 00000000000..de938f99834 --- /dev/null +++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationIngestionMode.java @@ -0,0 +1,76 @@ +/* + * Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License. + * This product includes software developed at Datadog (https://www.datadoghq.com/). + * Copyright 2019-Present Datadog, Inc. + */ + +package com.datadog.api.client.v2.model; + +import com.datadog.api.client.ModelEnum; +import com.fasterxml.jackson.annotation.JsonCreator; +import com.fasterxml.jackson.core.JsonGenerator; +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.SerializerProvider; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.databind.ser.std.StdSerializer; +import java.io.IOException; +import java.util.Arrays; +import java.util.HashSet; +import java.util.Set; + +/** + * The ingestion method used to send data to Azure Data Explorer. + * + *

+ * + *

Defaults to streaming. + */ +@JsonSerialize( + using = + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode + .ObservabilityPipelineAzureDataExplorerDestinationIngestionModeSerializer.class) +public class ObservabilityPipelineAzureDataExplorerDestinationIngestionMode + extends ModelEnum { + + private static final Set allowedValues = + new HashSet(Arrays.asList("streaming", "queue")); + + public static final ObservabilityPipelineAzureDataExplorerDestinationIngestionMode STREAMING = + new ObservabilityPipelineAzureDataExplorerDestinationIngestionMode("streaming"); + public static final ObservabilityPipelineAzureDataExplorerDestinationIngestionMode QUEUE = + new ObservabilityPipelineAzureDataExplorerDestinationIngestionMode("queue"); + + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode(String value) { + super(value, allowedValues); + } + + public static class ObservabilityPipelineAzureDataExplorerDestinationIngestionModeSerializer + extends StdSerializer { + public ObservabilityPipelineAzureDataExplorerDestinationIngestionModeSerializer( + Class t) { + super(t); + } + + public ObservabilityPipelineAzureDataExplorerDestinationIngestionModeSerializer() { + this(null); + } + + @Override + public void serialize( + ObservabilityPipelineAzureDataExplorerDestinationIngestionMode value, + JsonGenerator jgen, + SerializerProvider provider) + throws IOException, JsonProcessingException { + jgen.writeObject(value.value); + } + } + + @JsonCreator + public static ObservabilityPipelineAzureDataExplorerDestinationIngestionMode fromValue( + String value) { + return new ObservabilityPipelineAzureDataExplorerDestinationIngestionMode(value); + } +}