Add ingestion_mode to ADX destination

.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:

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<String> 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.
+   *
+   * <ul>
+   *   <li><code>streaming</code>: Sends events directly to the table using streaming ingestion.
+   *   <li><code>queue</code>: Sends events through queued (batched) ingestion.
+   * </ul>
+   *
+   * <p>Defaults to <code>streaming</code>.
+   *
+   * @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<String> 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");

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
    */

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.
+ *
+ * <ul>
+ *   <li><code>streaming</code>: Sends events directly to the table using streaming ingestion.
+ *   <li><code>queue</code>: Sends events through queued (batched) ingestion.
+ * </ul>
+ *
+ * <p>Defaults to <code>streaming</code>.
+ */
+@JsonSerialize(
+    using =
+        ObservabilityPipelineAzureDataExplorerDestinationIngestionMode
+            .ObservabilityPipelineAzureDataExplorerDestinationIngestionModeSerializer.class)
+public class ObservabilityPipelineAzureDataExplorerDestinationIngestionMode
+    extends ModelEnum<String> {
+
+  private static final Set<String> allowedValues =
+      new HashSet<String>(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<ObservabilityPipelineAzureDataExplorerDestinationIngestionMode> {
+    public ObservabilityPipelineAzureDataExplorerDestinationIngestionModeSerializer(
+        Class<ObservabilityPipelineAzureDataExplorerDestinationIngestionMode> 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);
+  }
+}