Sync Java SDK models from atlanhq/models

Source commit: 9dad3ef0c21ac56fa3c4927762ca06eede9e7d90
Source ref: refs/heads/master

Co-Authored-By: github-actions[bot] <github-actions[bot]@users.noreply.github.com>

Author: github-actions[bot]

sdk/src/main/java/com/atlan/model/assets/AIModelVersion.java

@@ -7,6 +7,7 @@
 import com.atlan.exception.ErrorCode;
 import com.atlan.exception.InvalidRequestException;
 import com.atlan.exception.NotFoundException;
+import com.atlan.model.enums.AIModelVersionStage;
 import com.atlan.model.enums.AtlanAnnouncementType;
 import com.atlan.model.enums.CertificateStatus;
 import com.atlan.model.enums.EthicalAIAccountabilityConfig;
@@ -59,6 +60,19 @@ public class AIModelVersion extends Asset implements IAIModelVersion, IAI, ICata
     @Attribute
     IAIModel aiModel;
 
+    /** Unique name of the AI model to which this version belongs, used to navigate from a version back to its parent model. */
+    @Attribute
+    String aiModelQualifiedName;
+
+    /** Evaluation and performance metrics recorded for this AI model version, stored as key-value pairs (e.g. accuracy, F1 score, precision, recall). */
+    @Attribute
+    @Singular
+    Map<String, String> aiModelVersionMetrics;
+
+    /** Lifecycle deployment stage of this AI model version, indicating its readiness for production use. */
+    @Attribute
+    AIModelVersionStage aiModelVersionStage;
+
     /** Accountability configuration for ensuring the ethical use of an AI asset */
     @Attribute
     EthicalAIAccountabilityConfig ethicalAIAccountabilityConfig;

sdk/src/main/java/com/atlan/model/assets/Asset.java

@@ -489,6 +489,14 @@ public abstract class Asset extends Reference implements IAsset, IReferenceable
     @Attribute
     AtlanIcon assetIcon;
 
+    /** The type of request form on Immuta applicable for the asset. */
+    @Attribute
+    String assetImmutaRequestType;
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    @Attribute
+    String assetImmutaRequestUrl;
+
     /** Internal Popularity score for this asset. */
     @Attribute
     Double assetInternalPopularityScore;

sdk/src/main/java/com/atlan/model/assets/AzureEventHub.java

@@ -51,7 +51,7 @@ public class AzureEventHub extends Asset
     @Builder.Default
     String typeName = TYPE_NAME;
 
-    /** TBC */
+    /** Operational status of the Azure Event Hub at the source. */
     @Attribute
     String azureEventHubStatus;
 
@@ -70,23 +70,44 @@ public class AzureEventHub extends Asset
     @Singular
     SortedSet<ISparkJob> inputToSparkJobs;
 
+    /** Kafka cluster containing this topic. */
+    @Attribute
+    IKafkaCluster kafkaCluster;
+
     /** Consumer groups subscribed to this topic. */
     @Attribute
     @Singular
     SortedSet<IKafkaConsumerGroup> kafkaConsumerGroups;
 
+    /** Schema fields defined within this Kafka topic. */
+    @Attribute
+    @Singular
+    SortedSet<IKafkaField> kafkaFields;
+
     /** Cleanup policy for this topic. */
     @Attribute
     KafkaTopicCleanupPolicy kafkaTopicCleanupPolicy;
 
+    /** Unique name of the Kafka cluster in which this topic exists. */
+    @Attribute
+    String kafkaTopicClusterQualifiedName;
+
     /** Type of compression used for this topic. */
     @Attribute
     KafkaTopicCompressionType kafkaTopicCompressionType;
 
+    /** Number of consumer groups consuming this topic. */
+    @Attribute
+    Long kafkaTopicConsumerCount;
+
     /** Whether this topic is an internal topic (true) or not (false). */
     @Attribute
     Boolean kafkaTopicIsInternal;
 
+    /** Whether this topic is fully managed by a schema registry (true) or not (false). */
+    @Attribute
+    Boolean kafkaTopicIsSchemaManaged;
+
     /** Comma seperated Cleanup policy for this topic. */
     @Attribute
     String kafkaTopicLogCleanupPolicy;
@@ -103,10 +124,18 @@ public class AzureEventHub extends Asset
     @Attribute
     Long kafkaTopicReplicationFactor;
 
+    /** Maximum size in bytes that a topic can grow to before discarding old messages; -1 means unlimited. */
+    @Attribute
+    Long kafkaTopicRetentionBytes;
+
     /** Amount of time messages will be retained in this topic, in milliseconds. */
     @Attribute
     Long kafkaTopicRetentionTimeInMs;
 
+    /** Name of the schema registry subject governing this topic, if any. */
+    @Attribute
+    String kafkaTopicSchemaRegistrySubjectName;
+
     /** Segment size for this topic. */
     @Attribute
     Long kafkaTopicSegmentBytes;

sdk/src/main/java/com/atlan/model/assets/AzureEventHubConsumerGroup.java

@@ -9,6 +9,7 @@
 import com.atlan.exception.NotFoundException;
 import com.atlan.model.enums.AtlanAnnouncementType;
 import com.atlan.model.enums.CertificateStatus;
+import com.atlan.model.enums.KafkaConsumerGroupState;
 import com.atlan.model.fields.AtlanField;
 import com.atlan.model.relations.Reference;
 import com.atlan.model.relations.UniqueAttributes;
@@ -73,10 +74,19 @@ public class AzureEventHubConsumerGroup extends Asset
     @Singular
     SortedSet<ISparkJob> inputToSparkJobs;
 
+    /** List of topic-partition pairs assigned to this consumer group. */
+    @Attribute
+    @Singular
+    SortedSet<String> kafkaConsumerGroupAssignedPartitions;
+
     /** Number of members in this consumer group. */
     @Attribute
     Long kafkaConsumerGroupMemberCount;
 
+    /** State of this consumer group. */
+    @Attribute
+    KafkaConsumerGroupState kafkaConsumerGroupState;
+
     /** List of consumption properties for Kafka topics, for this consumer group. */
     @Attribute
     @Singular

sdk/src/main/java/com/atlan/model/assets/DatabricksAIModelVersion.java

@@ -7,6 +7,7 @@
 import com.atlan.exception.ErrorCode;
 import com.atlan.exception.InvalidRequestException;
 import com.atlan.exception.NotFoundException;
+import com.atlan.model.enums.AIModelVersionStage;
 import com.atlan.model.enums.AtlanAnnouncementType;
 import com.atlan.model.enums.CertificateStatus;
 import com.atlan.model.enums.EthicalAIAccountabilityConfig;
@@ -68,6 +69,19 @@ public class DatabricksAIModelVersion extends Asset
     @Attribute
     IAIModel aiModel;
 
+    /** Unique name of the AI model to which this version belongs, used to navigate from a version back to its parent model. */
+    @Attribute
+    String aiModelQualifiedName;
+
+    /** Evaluation and performance metrics recorded for this AI model version, stored as key-value pairs (e.g. accuracy, F1 score, precision, recall). */
+    @Attribute
+    @Singular
+    Map<String, String> aiModelVersionMetrics;
+
+    /** Lifecycle deployment stage of this AI model version, indicating its readiness for production use. */
+    @Attribute
+    AIModelVersionStage aiModelVersionStage;
+
     /** Simple name of the calculation view in which this SQL asset exists, or empty if it does not exist within a calculation view. */
     @Attribute
     String calculationViewName;

sdk/src/main/java/com/atlan/model/assets/IADF.java

@@ -346,6 +346,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();
 

sdk/src/main/java/com/atlan/model/assets/IADLS.java

@@ -352,6 +352,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();
 

sdk/src/main/java/com/atlan/model/assets/IADLSAccount.java

@@ -424,6 +424,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();
 

sdk/src/main/java/com/atlan/model/assets/IADLSContainer.java

@@ -405,6 +405,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();
 

sdk/src/main/java/com/atlan/model/assets/IADLSObject.java

@@ -482,6 +482,12 @@ default IApplicationField getApplicationField() {
     /** Name of the icon to use for this asset. (Only applies to glossaries, currently.) */
     AtlanIcon getAssetIcon();
 
+    /** The type of request form on Immuta applicable for the asset. */
+    String getAssetImmutaRequestType();
+
+    /** URL of the request form on Immuta relevant to the asset. */
+    String getAssetImmutaRequestUrl();
+
     /** Internal Popularity score for this asset. */
     Double getAssetInternalPopularityScore();