Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
8 changes: 8 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/Asset.java
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
31 changes: 30 additions & 1 deletion sdk/src/main/java/com/atlan/model/assets/AzureEventHub.java
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand All @@ -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;
Expand All @@ -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;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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
Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IADF.java
Original file line number Diff line number Diff line change
Expand Up @@ -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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IADLS.java
Original file line number Diff line number Diff line change
Expand Up @@ -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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IADLSAccount.java
Original file line number Diff line number Diff line change
Expand Up @@ -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();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IADLSObject.java
Original file line number Diff line number Diff line change
Expand Up @@ -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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAI.java
Original file line number Diff line number Diff line change
Expand Up @@ -367,6 +367,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();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -359,6 +359,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAIModel.java
Original file line number Diff line number Diff line change
Expand Up @@ -378,6 +378,12 @@ default SortedSet<IAIApplication> getApplications() {
/** 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();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -349,6 +349,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAPI.java
Original file line number Diff line number Diff line change
Expand Up @@ -385,6 +385,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAPIField.java
Original file line number Diff line number Diff line change
Expand Up @@ -394,6 +394,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAPIObject.java
Original file line number Diff line number Diff line change
Expand Up @@ -373,6 +373,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAPIPath.java
Original file line number Diff line number Diff line change
Expand Up @@ -408,6 +408,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAPIQuery.java
Original file line number Diff line number Diff line change
Expand Up @@ -387,6 +387,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAPISpec.java
Original file line number Diff line number Diff line change
Expand Up @@ -423,6 +423,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAWS.java
Original file line number Diff line number Diff line change
Expand Up @@ -363,6 +363,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();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -375,6 +375,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAdfActivity.java
Original file line number Diff line number Diff line change
Expand Up @@ -499,6 +499,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAdfDataflow.java
Original file line number Diff line number Diff line change
Expand Up @@ -391,6 +391,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();

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/IAdfDataset.java
Original file line number Diff line number Diff line change
Expand Up @@ -440,6 +440,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();

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -473,6 +473,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();

Expand Down
Loading