diff --git a/.generator/schemas/v2/openapi.yaml b/.generator/schemas/v2/openapi.yaml
index 91955c670c9..ff4bd1b9d24 100644
--- a/.generator/schemas/v2/openapi.yaml
+++ b/.generator/schemas/v2/openapi.yaml
@@ -83218,6 +83218,296 @@ components:
description: A session identifier used for logging and tracing the assumed role session.
type: string
type: object
+ ObservabilityPipelineAzureDataExplorerDestination:
+ description: |-
+ The `azure_data_explorer` destination sends log events to an Azure Data Explorer table.
+
+ **Supported pipeline types:** logs
+ properties:
+ auth:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuth"
+ batch:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationBatch"
+ buffer:
+ $ref: "#/components/schemas/ObservabilityPipelineBufferOptions"
+ compression:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureStorageDestinationCompressionGzip"
+ database:
+ description: The name of the Azure Data Explorer database to ingest into. Supports template syntax.
+ example: logs_db
+ type: string
+ id:
+ description: The unique identifier for this component.
+ example: azure-data-explorer-destination
+ type: string
+ ingestion_endpoint_key:
+ description: |-
+ Name of the environment variable or secret that holds the Azure Data Explorer ingestion endpoint URL.
+ Defaults to `DESTINATION_AZURE_DATA_EXPLORER_INGESTION_ENDPOINT` (prefixed with `DD_OP_` at runtime).
+ example: AZURE_DATA_EXPLORER_INGESTION_ENDPOINT
+ type: string
+ inputs:
+ description: A list of component IDs whose output is used as the `input` for this component.
+ example: ["filter-processor"]
+ items:
+ description: The ID of a component whose output is used as input for this destination.
+ type: string
+ type: array
+ mapping_reference:
+ description: The name of a pre-created ingestion mapping on the table used to map incoming events to columns. Supports template syntax.
+ example: application_logs_mapping
+ nullable: true
+ type: string
+ table:
+ description: The name of the Azure Data Explorer table to ingest into. Supports template syntax.
+ example: application_logs
+ type: string
+ token_scope:
+ description: |-
+ The OAuth scope requested when acquiring an access token for Azure Data Explorer.
+ Defaults to `https://kusto.kusto.windows.net/.default`.
+ example: https://kusto.kusto.windows.net/.default
+ type: string
+ type:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationType"
+ required:
+ - id
+ - type
+ - inputs
+ - database
+ - table
+ - auth
+ type: object
+ x-pipeline-types: [logs]
+ ObservabilityPipelineAzureDataExplorerDestinationAuth:
+ description: Authentication configuration for Azure Data Explorer. The `azure_credential_kind` field selects the credential type.
+ oneOf:
+ - $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli"
+ - $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret"
+ - $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate"
+ - $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity"
+ - $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion"
+ - $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity"
+ ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli:
+ description: Authenticate using the Azure CLI credentials available in the environment.
+ properties:
+ azure_credential_kind:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCliKind"
+ required:
+ - azure_credential_kind
+ type: object
+ ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCliKind:
+ default: azure_cli
+ description: The Azure credential kind. The value should always be `azure_cli`.
+ enum:
+ - azure_cli
+ example: azure_cli
+ type: string
+ x-enum-varnames:
+ - AZURE_CLI
+ ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate:
+ description: Authenticate using a Microsoft Entra application client certificate.
+ properties:
+ azure_client_id:
+ description: The Microsoft Entra application (client) ID.
+ example: 22222222-2222-2222-2222-222222222222
+ type: string
+ azure_credential_kind:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificateKind"
+ azure_tenant_id:
+ description: The Microsoft Entra tenant ID.
+ example: 11111111-1111-1111-1111-111111111111
+ type: string
+ certificate_password_key:
+ description: Name of the environment variable or secret that holds the password for the client certificate.
+ example: AZURE_CERTIFICATE_PASSWORD
+ nullable: true
+ type: string
+ certificate_path:
+ description: Path to the `.pfx` client certificate file on the Worker.
+ example: /etc/certs/client.pfx
+ type: string
+ required:
+ - azure_credential_kind
+ - azure_tenant_id
+ - azure_client_id
+ - certificate_path
+ type: object
+ ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificateKind:
+ default: client_certificate_credential
+ description: The Azure credential kind. The value should always be `client_certificate_credential`.
+ enum:
+ - client_certificate_credential
+ example: client_certificate_credential
+ type: string
+ x-enum-varnames:
+ - CLIENT_CERTIFICATE_CREDENTIAL
+ ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret:
+ description: Authenticate using a Microsoft Entra application client secret.
+ properties:
+ azure_client_id:
+ description: The Microsoft Entra application (client) ID.
+ example: 22222222-2222-2222-2222-222222222222
+ type: string
+ azure_client_secret_key:
+ description: Name of the environment variable or secret that holds the Microsoft Entra application client secret.
+ example: AZURE_CLIENT_SECRET
+ type: string
+ azure_credential_kind:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecretKind"
+ azure_tenant_id:
+ description: The Microsoft Entra tenant ID.
+ example: 11111111-1111-1111-1111-111111111111
+ type: string
+ required:
+ - azure_credential_kind
+ - azure_tenant_id
+ - azure_client_id
+ - azure_client_secret_key
+ type: object
+ ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecretKind:
+ default: client_secret_credential
+ description: The Azure credential kind. The value should always be `client_secret_credential`.
+ enum:
+ - client_secret_credential
+ example: client_secret_credential
+ type: string
+ x-enum-varnames:
+ - CLIENT_SECRET_CREDENTIAL
+ ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity:
+ description: Authenticate using an Azure managed identity.
+ properties:
+ azure_credential_kind:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityKind"
+ user_assigned_managed_identity_id:
+ description: The ID of the user-assigned managed identity. If omitted, the system-assigned managed identity is used.
+ example: 00000000-0000-0000-0000-000000000000
+ nullable: true
+ type: string
+ user_assigned_managed_identity_id_type:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationManagedIdentityIdType"
+ required:
+ - azure_credential_kind
+ type: object
+ ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion:
+ description: Authenticate using a managed identity as a client assertion for a Microsoft Entra application.
+ properties:
+ azure_credential_kind:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertionKind"
+ client_assertion_client_id:
+ description: The client ID of the Microsoft Entra application that trusts the managed identity.
+ example: 22222222-2222-2222-2222-222222222222
+ type: string
+ client_assertion_tenant_id:
+ description: The tenant ID of the Microsoft Entra application that trusts the managed identity.
+ example: 11111111-1111-1111-1111-111111111111
+ type: string
+ user_assigned_managed_identity_id:
+ description: The ID of the user-assigned managed identity. If omitted, the system-assigned managed identity is used.
+ example: 00000000-0000-0000-0000-000000000000
+ nullable: true
+ type: string
+ user_assigned_managed_identity_id_type:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationManagedIdentityIdType"
+ required:
+ - azure_credential_kind
+ - client_assertion_client_id
+ - client_assertion_tenant_id
+ type: object
+ ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertionKind:
+ default: managed_identity_client_assertion
+ description: The Azure credential kind. The value should always be `managed_identity_client_assertion`.
+ enum:
+ - managed_identity_client_assertion
+ example: managed_identity_client_assertion
+ type: string
+ x-enum-varnames:
+ - MANAGED_IDENTITY_CLIENT_ASSERTION
+ ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityKind:
+ default: managed_identity
+ description: The Azure credential kind. The value should always be `managed_identity`.
+ enum:
+ - managed_identity
+ example: managed_identity
+ type: string
+ x-enum-varnames:
+ - MANAGED_IDENTITY
+ ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity:
+ description: Authenticate using Azure Workload Identity (for example, on Kubernetes).
+ properties:
+ azure_credential_kind:
+ $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentityKind"
+ client_id:
+ description: The client ID of the Microsoft Entra application. If omitted, it is read from the environment.
+ example: 22222222-2222-2222-2222-222222222222
+ nullable: true
+ type: string
+ tenant_id:
+ description: The Microsoft Entra tenant ID. If omitted, it is read from the environment.
+ example: 11111111-1111-1111-1111-111111111111
+ nullable: true
+ type: string
+ token_file_path:
+ description: Path to the federated token file. If omitted, it is read from the environment.
+ example: /var/run/secrets/azure/tokens/azure-identity-token
+ nullable: true
+ type: string
+ required:
+ - azure_credential_kind
+ type: object
+ ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentityKind:
+ default: workload_identity
+ description: The Azure credential kind. The value should always be `workload_identity`.
+ enum:
+ - workload_identity
+ example: workload_identity
+ type: string
+ x-enum-varnames:
+ - WORKLOAD_IDENTITY
+ ObservabilityPipelineAzureDataExplorerDestinationBatch:
+ description: Event batching settings for Azure Data Explorer ingestion.
+ properties:
+ max_bytes:
+ description: Maximum batch size in bytes.
+ example: 2000000
+ format: int64
+ maximum: 4000000
+ minimum: 1
+ type: integer
+ max_events:
+ description: Maximum number of events per batch before it is flushed.
+ example: 1000
+ format: int64
+ minimum: 1
+ type: integer
+ timeout_secs:
+ description: Maximum number of seconds to wait before flushing a partial batch.
+ example: 1
+ format: int64
+ minimum: 1
+ type: integer
+ type: object
+ ObservabilityPipelineAzureDataExplorerDestinationManagedIdentityIdType:
+ description: The type of the user-assigned managed identity ID.
+ enum:
+ - client_id
+ - object_id
+ - resource_id
+ example: client_id
+ type: string
+ x-enum-varnames:
+ - CLIENT_ID
+ - OBJECT_ID
+ - RESOURCE_ID
+ ObservabilityPipelineAzureDataExplorerDestinationType:
+ default: azure_data_explorer
+ description: The destination type. The value should always be `azure_data_explorer`.
+ enum:
+ - azure_data_explorer
+ example: azure_data_explorer
+ type: string
+ x-enum-varnames:
+ - AZURE_DATA_EXPLORER
ObservabilityPipelineAzureStorageDestinationCompression:
description: |-
Compression configuration for archived logs. When omitted, logs are compressed with gzip
@@ -83630,6 +83920,7 @@ components:
- $ref: "#/components/schemas/ObservabilityPipelineAmazonS3GenericDestination"
- $ref: "#/components/schemas/ObservabilityPipelineAmazonSecurityLakeDestination"
- $ref: "#/components/schemas/AzureStorageDestination"
+ - $ref: "#/components/schemas/ObservabilityPipelineAzureDataExplorerDestination"
- $ref: "#/components/schemas/ObservabilityPipelineClickhouseDestination"
- $ref: "#/components/schemas/ObservabilityPipelineCloudPremDestination"
- $ref: "#/components/schemas/ObservabilityPipelineCrowdStrikeNextGenSiemDestination"
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
new file mode 100644
index 00000000000..0c5ac90e752
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestination.java
@@ -0,0 +1,534 @@
+/*
+ * 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.fasterxml.jackson.annotation.JsonAnyGetter;
+import com.fasterxml.jackson.annotation.JsonAnySetter;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import com.fasterxml.jackson.annotation.JsonPropertyOrder;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import org.openapitools.jackson.nullable.JsonNullable;
+
+/**
+ * The azure_data_explorer destination sends log events to an Azure Data Explorer
+ * table.
+ *
+ *
Supported pipeline types: logs
+ */
+@JsonPropertyOrder({
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_AUTH,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_BATCH,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_BUFFER,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_COMPRESSION,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_DATABASE,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_ID,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_INGESTION_ENDPOINT_KEY,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_INPUTS,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_MAPPING_REFERENCE,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_TABLE,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_TOKEN_SCOPE,
+ ObservabilityPipelineAzureDataExplorerDestination.JSON_PROPERTY_TYPE
+})
+@jakarta.annotation.Generated(
+ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
+public class ObservabilityPipelineAzureDataExplorerDestination {
+ @JsonIgnore public boolean unparsed = false;
+ public static final String JSON_PROPERTY_AUTH = "auth";
+ private ObservabilityPipelineAzureDataExplorerDestinationAuth auth;
+
+ public static final String JSON_PROPERTY_BATCH = "batch";
+ private ObservabilityPipelineAzureDataExplorerDestinationBatch batch;
+
+ public static final String JSON_PROPERTY_BUFFER = "buffer";
+ private ObservabilityPipelineBufferOptions buffer;
+
+ public static final String JSON_PROPERTY_COMPRESSION = "compression";
+ private ObservabilityPipelineAzureStorageDestinationCompressionGzip compression;
+
+ public static final String JSON_PROPERTY_DATABASE = "database";
+ private String database;
+
+ public static final String JSON_PROPERTY_ID = "id";
+ private String id;
+
+ public static final String JSON_PROPERTY_INGESTION_ENDPOINT_KEY = "ingestion_endpoint_key";
+ private String ingestionEndpointKey;
+
+ public static final String JSON_PROPERTY_INPUTS = "inputs";
+ private List inputs = new ArrayList<>();
+
+ public static final String JSON_PROPERTY_MAPPING_REFERENCE = "mapping_reference";
+ private JsonNullable mappingReference = JsonNullable.undefined();
+
+ public static final String JSON_PROPERTY_TABLE = "table";
+ private String table;
+
+ public static final String JSON_PROPERTY_TOKEN_SCOPE = "token_scope";
+ private String tokenScope;
+
+ public static final String JSON_PROPERTY_TYPE = "type";
+ private ObservabilityPipelineAzureDataExplorerDestinationType type =
+ ObservabilityPipelineAzureDataExplorerDestinationType.AZURE_DATA_EXPLORER;
+
+ public ObservabilityPipelineAzureDataExplorerDestination() {}
+
+ @JsonCreator
+ public ObservabilityPipelineAzureDataExplorerDestination(
+ @JsonProperty(required = true, value = JSON_PROPERTY_AUTH)
+ ObservabilityPipelineAzureDataExplorerDestinationAuth auth,
+ @JsonProperty(required = true, value = JSON_PROPERTY_DATABASE) String database,
+ @JsonProperty(required = true, value = JSON_PROPERTY_ID) String id,
+ @JsonProperty(required = true, value = JSON_PROPERTY_INPUTS) List inputs,
+ @JsonProperty(required = true, value = JSON_PROPERTY_TABLE) String table,
+ @JsonProperty(required = true, value = JSON_PROPERTY_TYPE)
+ ObservabilityPipelineAzureDataExplorerDestinationType type) {
+ this.auth = auth;
+ this.unparsed |= auth.unparsed;
+ this.database = database;
+ this.id = id;
+ this.inputs = inputs;
+ this.table = table;
+ this.type = type;
+ this.unparsed |= !type.isValid();
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination auth(
+ ObservabilityPipelineAzureDataExplorerDestinationAuth auth) {
+ this.auth = auth;
+ this.unparsed |= auth.unparsed;
+ return this;
+ }
+
+ /**
+ * Authentication configuration for Azure Data Explorer. The azure_credential_kind
+ * field selects the credential type.
+ *
+ * @return auth
+ */
+ @JsonProperty(JSON_PROPERTY_AUTH)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineAzureDataExplorerDestinationAuth getAuth() {
+ return auth;
+ }
+
+ public void setAuth(ObservabilityPipelineAzureDataExplorerDestinationAuth auth) {
+ this.auth = auth;
+ if (auth != null) {
+ this.unparsed |= auth.unparsed;
+ }
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination batch(
+ ObservabilityPipelineAzureDataExplorerDestinationBatch batch) {
+ this.batch = batch;
+ this.unparsed |= batch.unparsed;
+ return this;
+ }
+
+ /**
+ * Event batching settings for Azure Data Explorer ingestion.
+ *
+ * @return batch
+ */
+ @jakarta.annotation.Nullable
+ @JsonProperty(JSON_PROPERTY_BATCH)
+ @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+ public ObservabilityPipelineAzureDataExplorerDestinationBatch getBatch() {
+ return batch;
+ }
+
+ public void setBatch(ObservabilityPipelineAzureDataExplorerDestinationBatch batch) {
+ this.batch = batch;
+ if (batch != null) {
+ this.unparsed |= batch.unparsed;
+ }
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination buffer(
+ ObservabilityPipelineBufferOptions buffer) {
+ this.buffer = buffer;
+ this.unparsed |= buffer.unparsed;
+ return this;
+ }
+
+ /**
+ * Configuration for buffer settings on destination components.
+ *
+ * @return buffer
+ */
+ @jakarta.annotation.Nullable
+ @JsonProperty(JSON_PROPERTY_BUFFER)
+ @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+ public ObservabilityPipelineBufferOptions getBuffer() {
+ return buffer;
+ }
+
+ public void setBuffer(ObservabilityPipelineBufferOptions buffer) {
+ this.buffer = buffer;
+ if (buffer != null) {
+ this.unparsed |= buffer.unparsed;
+ }
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination compression(
+ ObservabilityPipelineAzureStorageDestinationCompressionGzip compression) {
+ this.compression = compression;
+ this.unparsed |= compression.unparsed;
+ return this;
+ }
+
+ /**
+ * Gzip compression.
+ *
+ * @return compression
+ */
+ @jakarta.annotation.Nullable
+ @JsonProperty(JSON_PROPERTY_COMPRESSION)
+ @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+ public ObservabilityPipelineAzureStorageDestinationCompressionGzip getCompression() {
+ return compression;
+ }
+
+ public void setCompression(
+ ObservabilityPipelineAzureStorageDestinationCompressionGzip compression) {
+ this.compression = compression;
+ if (compression != null) {
+ this.unparsed |= compression.unparsed;
+ }
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination database(String database) {
+ this.database = database;
+ return this;
+ }
+
+ /**
+ * The name of the Azure Data Explorer database to ingest into. Supports template syntax.
+ *
+ * @return database
+ */
+ @JsonProperty(JSON_PROPERTY_DATABASE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getDatabase() {
+ return database;
+ }
+
+ public void setDatabase(String database) {
+ this.database = database;
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination id(String id) {
+ this.id = id;
+ return this;
+ }
+
+ /**
+ * The unique identifier for this component.
+ *
+ * @return id
+ */
+ @JsonProperty(JSON_PROPERTY_ID)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getId() {
+ return id;
+ }
+
+ public void setId(String id) {
+ this.id = id;
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination ingestionEndpointKey(
+ String ingestionEndpointKey) {
+ this.ingestionEndpointKey = ingestionEndpointKey;
+ return this;
+ }
+
+ /**
+ * Name of the environment variable or secret that holds the Azure Data Explorer ingestion
+ * endpoint URL. Defaults to DESTINATION_AZURE_DATA_EXPLORER_INGESTION_ENDPOINT
+ * (prefixed with DD_OP_ at runtime).
+ *
+ * @return ingestionEndpointKey
+ */
+ @jakarta.annotation.Nullable
+ @JsonProperty(JSON_PROPERTY_INGESTION_ENDPOINT_KEY)
+ @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+ public String getIngestionEndpointKey() {
+ return ingestionEndpointKey;
+ }
+
+ public void setIngestionEndpointKey(String ingestionEndpointKey) {
+ this.ingestionEndpointKey = ingestionEndpointKey;
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination inputs(List inputs) {
+ this.inputs = inputs;
+ return this;
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination addInputsItem(String inputsItem) {
+ this.inputs.add(inputsItem);
+ return this;
+ }
+
+ /**
+ * A list of component IDs whose output is used as the input for this component.
+ *
+ * @return inputs
+ */
+ @JsonProperty(JSON_PROPERTY_INPUTS)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public List getInputs() {
+ return inputs;
+ }
+
+ public void setInputs(List inputs) {
+ this.inputs = inputs;
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination mappingReference(
+ String mappingReference) {
+ this.mappingReference = JsonNullable.of(mappingReference);
+ return this;
+ }
+
+ /**
+ * The name of a pre-created ingestion mapping on the table used to map incoming events to
+ * columns. Supports template syntax.
+ *
+ * @return mappingReference
+ */
+ @jakarta.annotation.Nullable
+ @JsonIgnore
+ public String getMappingReference() {
+ return mappingReference.orElse(null);
+ }
+
+ @JsonProperty(JSON_PROPERTY_MAPPING_REFERENCE)
+ @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+ public JsonNullable getMappingReference_JsonNullable() {
+ return mappingReference;
+ }
+
+ @JsonProperty(JSON_PROPERTY_MAPPING_REFERENCE)
+ public void setMappingReference_JsonNullable(JsonNullable mappingReference) {
+ this.mappingReference = mappingReference;
+ }
+
+ public void setMappingReference(String mappingReference) {
+ this.mappingReference = JsonNullable.of(mappingReference);
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination table(String table) {
+ this.table = table;
+ return this;
+ }
+
+ /**
+ * The name of the Azure Data Explorer table to ingest into. Supports template syntax.
+ *
+ * @return table
+ */
+ @JsonProperty(JSON_PROPERTY_TABLE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public String getTable() {
+ return table;
+ }
+
+ public void setTable(String table) {
+ this.table = table;
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination tokenScope(String tokenScope) {
+ this.tokenScope = tokenScope;
+ return this;
+ }
+
+ /**
+ * The OAuth scope requested when acquiring an access token for Azure Data Explorer. Defaults to
+ * https://kusto.kusto.windows.net/.default.
+ *
+ * @return tokenScope
+ */
+ @jakarta.annotation.Nullable
+ @JsonProperty(JSON_PROPERTY_TOKEN_SCOPE)
+ @JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
+ public String getTokenScope() {
+ return tokenScope;
+ }
+
+ public void setTokenScope(String tokenScope) {
+ this.tokenScope = tokenScope;
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestination type(
+ ObservabilityPipelineAzureDataExplorerDestinationType type) {
+ this.type = type;
+ this.unparsed |= !type.isValid();
+ return this;
+ }
+
+ /**
+ * The destination type. The value should always be azure_data_explorer.
+ *
+ * @return type
+ */
+ @JsonProperty(JSON_PROPERTY_TYPE)
+ @JsonInclude(value = JsonInclude.Include.ALWAYS)
+ public ObservabilityPipelineAzureDataExplorerDestinationType getType() {
+ return type;
+ }
+
+ public void setType(ObservabilityPipelineAzureDataExplorerDestinationType type) {
+ if (!type.isValid()) {
+ this.unparsed = true;
+ }
+ this.type = type;
+ }
+
+ /**
+ * A container for additional, undeclared properties. This is a holder for any undeclared
+ * properties as specified with the 'additionalProperties' keyword in the OAS document.
+ */
+ private Map additionalProperties;
+
+ /**
+ * Set the additional (undeclared) property with the specified name and value. If the property
+ * does not already exist, create it otherwise replace it.
+ *
+ * @param key The arbitrary key to set
+ * @param value The associated value
+ * @return ObservabilityPipelineAzureDataExplorerDestination
+ */
+ @JsonAnySetter
+ public ObservabilityPipelineAzureDataExplorerDestination putAdditionalProperty(
+ String key, Object value) {
+ if (this.additionalProperties == null) {
+ this.additionalProperties = new HashMap();
+ }
+ this.additionalProperties.put(key, value);
+ return this;
+ }
+
+ /**
+ * Return the additional (undeclared) property.
+ *
+ * @return The additional properties
+ */
+ @JsonAnyGetter
+ public Map getAdditionalProperties() {
+ return additionalProperties;
+ }
+
+ /**
+ * Return the additional (undeclared) property with the specified name.
+ *
+ * @param key The arbitrary key to get
+ * @return The specific additional property for the given key
+ */
+ public Object getAdditionalProperty(String key) {
+ if (this.additionalProperties == null) {
+ return null;
+ }
+ return this.additionalProperties.get(key);
+ }
+
+ /** Return true if this ObservabilityPipelineAzureDataExplorerDestination object is equal to o. */
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+ ObservabilityPipelineAzureDataExplorerDestination
+ observabilityPipelineAzureDataExplorerDestination =
+ (ObservabilityPipelineAzureDataExplorerDestination) o;
+ return Objects.equals(this.auth, observabilityPipelineAzureDataExplorerDestination.auth)
+ && Objects.equals(this.batch, observabilityPipelineAzureDataExplorerDestination.batch)
+ && Objects.equals(this.buffer, observabilityPipelineAzureDataExplorerDestination.buffer)
+ && Objects.equals(
+ this.compression, observabilityPipelineAzureDataExplorerDestination.compression)
+ && Objects.equals(this.database, observabilityPipelineAzureDataExplorerDestination.database)
+ && Objects.equals(this.id, observabilityPipelineAzureDataExplorerDestination.id)
+ && Objects.equals(
+ this.ingestionEndpointKey,
+ observabilityPipelineAzureDataExplorerDestination.ingestionEndpointKey)
+ && Objects.equals(this.inputs, observabilityPipelineAzureDataExplorerDestination.inputs)
+ && Objects.equals(
+ this.mappingReference,
+ observabilityPipelineAzureDataExplorerDestination.mappingReference)
+ && Objects.equals(this.table, observabilityPipelineAzureDataExplorerDestination.table)
+ && Objects.equals(
+ this.tokenScope, observabilityPipelineAzureDataExplorerDestination.tokenScope)
+ && Objects.equals(this.type, observabilityPipelineAzureDataExplorerDestination.type)
+ && Objects.equals(
+ this.additionalProperties,
+ observabilityPipelineAzureDataExplorerDestination.additionalProperties);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(
+ auth,
+ batch,
+ buffer,
+ compression,
+ database,
+ id,
+ ingestionEndpointKey,
+ inputs,
+ mappingReference,
+ table,
+ tokenScope,
+ type,
+ additionalProperties);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("class ObservabilityPipelineAzureDataExplorerDestination {\n");
+ sb.append(" auth: ").append(toIndentedString(auth)).append("\n");
+ sb.append(" batch: ").append(toIndentedString(batch)).append("\n");
+ sb.append(" buffer: ").append(toIndentedString(buffer)).append("\n");
+ sb.append(" compression: ").append(toIndentedString(compression)).append("\n");
+ sb.append(" database: ").append(toIndentedString(database)).append("\n");
+ sb.append(" id: ").append(toIndentedString(id)).append("\n");
+ sb.append(" ingestionEndpointKey: ")
+ .append(toIndentedString(ingestionEndpointKey))
+ .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");
+ sb.append(" tokenScope: ").append(toIndentedString(tokenScope)).append("\n");
+ sb.append(" type: ").append(toIndentedString(type)).append("\n");
+ sb.append(" additionalProperties: ")
+ .append(toIndentedString(additionalProperties))
+ .append("\n");
+ sb.append('}');
+ return sb.toString();
+ }
+
+ /**
+ * Convert the given object to string with each line indented by 4 spaces (except the first line).
+ */
+ private String toIndentedString(Object o) {
+ if (o == null) {
+ return "null";
+ }
+ return o.toString().replace("\n", "\n ");
+ }
+}
diff --git a/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationAuth.java b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationAuth.java
new file mode 100644
index 00000000000..bac719bbcf4
--- /dev/null
+++ b/src/main/java/com/datadog/api/client/v2/model/ObservabilityPipelineAzureDataExplorerDestinationAuth.java
@@ -0,0 +1,815 @@
+/*
+ * 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.AbstractOpenApiSchema;
+import com.datadog.api.client.JSON;
+import com.datadog.api.client.UnparsedObject;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import com.fasterxml.jackson.core.JsonGenerator;
+import com.fasterxml.jackson.core.JsonParser;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.core.JsonToken;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.DeserializationContext;
+import com.fasterxml.jackson.databind.JsonMappingException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.MapperFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializerProvider;
+import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
+import com.fasterxml.jackson.databind.annotation.JsonSerialize;
+import com.fasterxml.jackson.databind.deser.std.StdDeserializer;
+import com.fasterxml.jackson.databind.ser.std.StdSerializer;
+import jakarta.ws.rs.core.GenericType;
+import java.io.IOException;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+@jakarta.annotation.Generated(
+ value = "https://github.com/DataDog/datadog-api-client-java/blob/master/.generator")
+@JsonDeserialize(
+ using =
+ ObservabilityPipelineAzureDataExplorerDestinationAuth
+ .ObservabilityPipelineAzureDataExplorerDestinationAuthDeserializer.class)
+@JsonSerialize(
+ using =
+ ObservabilityPipelineAzureDataExplorerDestinationAuth
+ .ObservabilityPipelineAzureDataExplorerDestinationAuthSerializer.class)
+public class ObservabilityPipelineAzureDataExplorerDestinationAuth extends AbstractOpenApiSchema {
+ private static final Logger log =
+ Logger.getLogger(ObservabilityPipelineAzureDataExplorerDestinationAuth.class.getName());
+
+ @JsonIgnore public boolean unparsed = false;
+
+ public static class ObservabilityPipelineAzureDataExplorerDestinationAuthSerializer
+ extends StdSerializer {
+ public ObservabilityPipelineAzureDataExplorerDestinationAuthSerializer(
+ Class t) {
+ super(t);
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestinationAuthSerializer() {
+ this(null);
+ }
+
+ @Override
+ public void serialize(
+ ObservabilityPipelineAzureDataExplorerDestinationAuth value,
+ JsonGenerator jgen,
+ SerializerProvider provider)
+ throws IOException, JsonProcessingException {
+ jgen.writeObject(value.getActualInstance());
+ }
+ }
+
+ public static class ObservabilityPipelineAzureDataExplorerDestinationAuthDeserializer
+ extends StdDeserializer {
+ public ObservabilityPipelineAzureDataExplorerDestinationAuthDeserializer() {
+ this(ObservabilityPipelineAzureDataExplorerDestinationAuth.class);
+ }
+
+ public ObservabilityPipelineAzureDataExplorerDestinationAuthDeserializer(Class> vc) {
+ super(vc);
+ }
+
+ @Override
+ public ObservabilityPipelineAzureDataExplorerDestinationAuth deserialize(
+ JsonParser jp, DeserializationContext ctxt) throws IOException, JsonProcessingException {
+ JsonNode tree = jp.readValueAsTree();
+ Object deserialized = null;
+ Object tmp = null;
+ boolean typeCoercion = ctxt.isEnabled(MapperFeature.ALLOW_COERCION_OF_SCALARS);
+ int match = 0;
+ JsonToken token = tree.traverse(jp.getCodec()).nextToken();
+ // deserialize ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class.equals(
+ Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class.equals(
+ Long.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class.equals(
+ Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class.equals(
+ Double.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class.equals(
+ Boolean.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class.equals(
+ String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class.equals(
+ Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class
+ .equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class.equals(
+ Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class
+ .equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class.equals(
+ Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class.equals(
+ String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec())
+ .readValueAs(ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli) tmp).unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(
+ Level.FINER,
+ "Input data matches schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthAzureCli'",
+ e);
+ }
+
+ // deserialize ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class.equals(
+ Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class.equals(
+ Long.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class.equals(
+ Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class.equals(
+ Double.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class.equals(
+ Boolean.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class.equals(
+ String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class.equals(
+ Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class
+ .equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class.equals(
+ Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class
+ .equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class.equals(
+ Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class.equals(
+ String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec())
+ .readValueAs(
+ ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret) tmp).unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(
+ Level.FINER,
+ "Input data matches schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthClientSecret'",
+ e);
+ }
+
+ // deserialize ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class.equals(
+ Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class.equals(
+ Long.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class.equals(
+ Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class.equals(
+ Double.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class.equals(
+ Boolean.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class.equals(
+ String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class
+ .equals(Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate
+ .class
+ .equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class
+ .equals(Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate
+ .class
+ .equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class
+ .equals(Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class
+ .equals(String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec())
+ .readValueAs(
+ ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate) tmp)
+ .unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(
+ Level.FINER,
+ "Input data matches schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthClientCertificate'",
+ e);
+ }
+
+ // deserialize ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class.equals(
+ Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class.equals(
+ Long.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class.equals(
+ Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class.equals(
+ Double.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class.equals(
+ Boolean.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class.equals(
+ String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class.equals(
+ Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity
+ .class
+ .equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class.equals(
+ Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity
+ .class
+ .equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class.equals(
+ Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class.equals(
+ String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec())
+ .readValueAs(
+ ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity) tmp)
+ .unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(
+ Level.FINER,
+ "Input data matches schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentity'",
+ e);
+ }
+
+ // deserialize
+ // ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(Long.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(Double.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(Boolean.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class
+ .equals(String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec())
+ .readValueAs(
+ ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion
+ .class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion)
+ tmp)
+ .unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(
+ Level.FINER,
+ "Input data matches schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthManagedIdentityClientAssertion'",
+ e);
+ }
+
+ // deserialize ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity
+ try {
+ boolean attemptParsing = true;
+ // ensure that we respect type coercion as set on the client ObjectMapper
+ if (ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class.equals(
+ Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class.equals(
+ Long.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class.equals(
+ Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class.equals(
+ Double.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class.equals(
+ Boolean.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class.equals(
+ String.class)) {
+ attemptParsing = typeCoercion;
+ if (!attemptParsing) {
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class
+ .equals(Integer.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity
+ .class
+ .equals(Long.class))
+ && token == JsonToken.VALUE_NUMBER_INT);
+ attemptParsing |=
+ ((ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class
+ .equals(Float.class)
+ || ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity
+ .class
+ .equals(Double.class))
+ && (token == JsonToken.VALUE_NUMBER_FLOAT
+ || token == JsonToken.VALUE_NUMBER_INT));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class.equals(
+ Boolean.class)
+ && (token == JsonToken.VALUE_FALSE || token == JsonToken.VALUE_TRUE));
+ attemptParsing |=
+ (ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class.equals(
+ String.class)
+ && token == JsonToken.VALUE_STRING);
+ }
+ }
+ if (attemptParsing) {
+ tmp =
+ tree.traverse(jp.getCodec())
+ .readValueAs(
+ ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity.class);
+ // TODO: there is no validation against JSON schema constraints
+ // (min, max, enum, pattern...), this does not perform a strict JSON
+ // validation, which means the 'match' count may be higher than it should be.
+ if (!((ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity) tmp)
+ .unparsed) {
+ deserialized = tmp;
+ match++;
+ }
+ log.log(
+ Level.FINER,
+ "Input data matches schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity'");
+ }
+ } catch (Exception e) {
+ // deserialization failed, continue
+ log.log(
+ Level.FINER,
+ "Input data does not match schema"
+ + " 'ObservabilityPipelineAzureDataExplorerDestinationAuthWorkloadIdentity'",
+ e);
+ }
+
+ ObservabilityPipelineAzureDataExplorerDestinationAuth ret =
+ new ObservabilityPipelineAzureDataExplorerDestinationAuth();
+ if (match == 1) {
+ ret.setActualInstance(deserialized);
+ } else {
+ Map res =
+ new ObjectMapper()
+ .readValue(
+ tree.traverse(jp.getCodec()).readValueAsTree().toString(),
+ new TypeReference