diff --git a/.codegen/_openapi_sha b/.codegen/_openapi_sha index f24617852..d528e3c87 100755 --- a/.codegen/_openapi_sha +++ b/.codegen/_openapi_sha @@ -1 +1 @@ -993160f9786ab5532bba61a5b56c2c47c2e2b745 \ No newline at end of file +3bc0d2bf5d0f3657648cf2148d1edde78b7451ac \ No newline at end of file diff --git a/.gitattributes b/.gitattributes index dc8e5329e..4c7d460d4 100755 --- a/.gitattributes +++ b/.gitattributes @@ -1952,6 +1952,7 @@ databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CreateRunRespons databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CreateTransitionRequest.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CreateTransitionRequestResponse.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CreateWebhookResponse.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CronSchedule.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/DataSource.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/Dataset.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/DatasetInput.java linguist-generated=true @@ -2174,8 +2175,11 @@ databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SlidingWindow.ja databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/Status.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StddevPopFunction.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StddevSampFunction.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamingMode.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamingModeStreamingModeType.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SubscriptionMode.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SumFunction.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TableTrigger.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TestRegistryWebhookRequest.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TestRegistryWebhookResponse.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TimeWindow.java linguist-generated=true diff --git a/NEXT_CHANGELOG.md b/NEXT_CHANGELOG.md index 7327317db..573926e4d 100755 --- a/NEXT_CHANGELOG.md +++ b/NEXT_CHANGELOG.md @@ -29,4 +29,6 @@ * Change `cliVersion` field for `com.databricks.sdk.service.bundle.Version` to be required. * [Breaking] Change `cliVersion` field for `com.databricks.sdk.service.bundle.Version` to be required. * [Breaking] Change `tags` field for `com.databricks.sdk.service.marketplace.ListListingsRequest` to type `com.databricks.sdk.service.marketplace.ListingTag` class. -* [Breaking] Change pagination for `workspaceClient.clusters().events()` method. \ No newline at end of file +* [Breaking] Change pagination for `workspaceClient.clusters().events()` method. +* Add `cronScheduleTrigger`, `streamingMode` and `tableTrigger` fields for `com.databricks.sdk.service.ml.MaterializedFeature`. +* Add `syncedTableId` field for `com.databricks.sdk.service.postgres.SyncedTableSyncedTableStatus`. \ No newline at end of file diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/billing/ActionConfigurationType.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/billing/ActionConfigurationType.java index 01bad4b94..addd26e54 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/billing/ActionConfigurationType.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/billing/ActionConfigurationType.java @@ -4,6 +4,7 @@ import com.databricks.sdk.support.Generated; +/** Type of action that a budget alert executes when its threshold is crossed. */ @Generated public enum ActionConfigurationType { EMAIL_NOTIFICATION, diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CronSchedule.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CronSchedule.java new file mode 100755 index 000000000..7c1e33a1e --- /dev/null +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CronSchedule.java @@ -0,0 +1,43 @@ +// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT. + +package com.databricks.sdk.service.ml; + +import com.databricks.sdk.support.Generated; +import com.databricks.sdk.support.ToStringer; +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.Objects; + +/** A cron-based schedule trigger for the materialization pipeline. */ +@Generated +public class CronSchedule { + /** The cron expression defining the schedule (e.g., "0 0 * * *" for daily at midnight). */ + @JsonProperty("cron_expression") + private String cronExpression; + + public CronSchedule setCronExpression(String cronExpression) { + this.cronExpression = cronExpression; + return this; + } + + public String getCronExpression() { + return cronExpression; + } + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + CronSchedule that = (CronSchedule) o; + return Objects.equals(cronExpression, that.cronExpression); + } + + @Override + public int hashCode() { + return Objects.hash(cronExpression); + } + + @Override + public String toString() { + return new ToStringer(CronSchedule.class).add("cronExpression", cronExpression).toString(); + } +} diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/MaterializedFeature.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/MaterializedFeature.java index f939f14ad..3c2db95fb 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/MaterializedFeature.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/MaterializedFeature.java @@ -17,6 +17,10 @@ public class MaterializedFeature { @JsonProperty("cron_schedule") private String cronSchedule; + /** A cron-based schedule trigger for the materialization pipeline. */ + @JsonProperty("cron_schedule_trigger") + private CronSchedule cronScheduleTrigger; + /** The full name of the feature in Unity Catalog. */ @JsonProperty("feature_name") private String featureName; @@ -50,6 +54,14 @@ public class MaterializedFeature { @JsonProperty("pipeline_schedule_state") private MaterializedFeaturePipelineScheduleState pipelineScheduleState; + /** + * The Structured Streaming trigger mode used for materialization. Real-time mode (RTM) targets + * sub-second latency for operational workloads; micro-batch mode (MBM) favors cost efficiency for + * ETL and analytics workloads. + */ + @JsonProperty("streaming_mode") + private StreamingMode streamingMode; + /** * The fully qualified Unity Catalog path to the table containing the materialized feature (Delta * table or Lakebase table). Output only. @@ -57,6 +69,10 @@ public class MaterializedFeature { @JsonProperty("table_name") private String tableName; + /** A trigger that fires when the upstream source table changes. */ + @JsonProperty("table_trigger") + private TableTrigger tableTrigger; + public MaterializedFeature setCronSchedule(String cronSchedule) { this.cronSchedule = cronSchedule; return this; @@ -66,6 +82,15 @@ public String getCronSchedule() { return cronSchedule; } + public MaterializedFeature setCronScheduleTrigger(CronSchedule cronScheduleTrigger) { + this.cronScheduleTrigger = cronScheduleTrigger; + return this; + } + + public CronSchedule getCronScheduleTrigger() { + return cronScheduleTrigger; + } + public MaterializedFeature setFeatureName(String featureName) { this.featureName = featureName; return this; @@ -130,6 +155,15 @@ public MaterializedFeaturePipelineScheduleState getPipelineScheduleState() { return pipelineScheduleState; } + public MaterializedFeature setStreamingMode(StreamingMode streamingMode) { + this.streamingMode = streamingMode; + return this; + } + + public StreamingMode getStreamingMode() { + return streamingMode; + } + public MaterializedFeature setTableName(String tableName) { this.tableName = tableName; return this; @@ -139,12 +173,22 @@ public String getTableName() { return tableName; } + public MaterializedFeature setTableTrigger(TableTrigger tableTrigger) { + this.tableTrigger = tableTrigger; + return this; + } + + public TableTrigger getTableTrigger() { + return tableTrigger; + } + @Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; MaterializedFeature that = (MaterializedFeature) o; return Objects.equals(cronSchedule, that.cronSchedule) + && Objects.equals(cronScheduleTrigger, that.cronScheduleTrigger) && Objects.equals(featureName, that.featureName) && Objects.equals(isOnline, that.isOnline) && Objects.equals(lastMaterializationTime, that.lastMaterializationTime) @@ -152,13 +196,16 @@ public boolean equals(Object o) { && Objects.equals(offlineStoreConfig, that.offlineStoreConfig) && Objects.equals(onlineStoreConfig, that.onlineStoreConfig) && Objects.equals(pipelineScheduleState, that.pipelineScheduleState) - && Objects.equals(tableName, that.tableName); + && Objects.equals(streamingMode, that.streamingMode) + && Objects.equals(tableName, that.tableName) + && Objects.equals(tableTrigger, that.tableTrigger); } @Override public int hashCode() { return Objects.hash( cronSchedule, + cronScheduleTrigger, featureName, isOnline, lastMaterializationTime, @@ -166,13 +213,16 @@ public int hashCode() { offlineStoreConfig, onlineStoreConfig, pipelineScheduleState, - tableName); + streamingMode, + tableName, + tableTrigger); } @Override public String toString() { return new ToStringer(MaterializedFeature.class) .add("cronSchedule", cronSchedule) + .add("cronScheduleTrigger", cronScheduleTrigger) .add("featureName", featureName) .add("isOnline", isOnline) .add("lastMaterializationTime", lastMaterializationTime) @@ -180,7 +230,9 @@ public String toString() { .add("offlineStoreConfig", offlineStoreConfig) .add("onlineStoreConfig", onlineStoreConfig) .add("pipelineScheduleState", pipelineScheduleState) + .add("streamingMode", streamingMode) .add("tableName", tableName) + .add("tableTrigger", tableTrigger) .toString(); } } diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamingMode.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamingMode.java new file mode 100755 index 000000000..058faf05c --- /dev/null +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamingMode.java @@ -0,0 +1,43 @@ +// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT. + +package com.databricks.sdk.service.ml; + +import com.databricks.sdk.support.Generated; +import com.databricks.sdk.support.ToStringer; +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.Objects; + +/** The streaming mode configuration for a streaming materialization pipeline. */ +@Generated +public class StreamingMode { + /** The type of streaming mode used by the materialization pipeline. */ + @JsonProperty("mode") + private StreamingModeStreamingModeType mode; + + public StreamingMode setMode(StreamingModeStreamingModeType mode) { + this.mode = mode; + return this; + } + + public StreamingModeStreamingModeType getMode() { + return mode; + } + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + StreamingMode that = (StreamingMode) o; + return Objects.equals(mode, that.mode); + } + + @Override + public int hashCode() { + return Objects.hash(mode); + } + + @Override + public String toString() { + return new ToStringer(StreamingMode.class).add("mode", mode).toString(); + } +} diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamingModeStreamingModeType.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamingModeStreamingModeType.java new file mode 100755 index 000000000..984756bc0 --- /dev/null +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamingModeStreamingModeType.java @@ -0,0 +1,11 @@ +// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT. + +package com.databricks.sdk.service.ml; + +import com.databricks.sdk.support.Generated; + +@Generated +public enum StreamingModeStreamingModeType { + STREAMING_MODE_TYPE_MBM, + STREAMING_MODE_TYPE_RTM, +} diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TableTrigger.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TableTrigger.java new file mode 100755 index 000000000..4a1ce2826 --- /dev/null +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TableTrigger.java @@ -0,0 +1,29 @@ +// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT. + +package com.databricks.sdk.service.ml; + +import com.databricks.sdk.support.Generated; +import com.databricks.sdk.support.ToStringer; +import java.util.Objects; + +/** A trigger that fires when the upstream source table changes. */ +@Generated +public class TableTrigger { + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + return true; + } + + @Override + public int hashCode() { + return Objects.hash(); + } + + @Override + public String toString() { + return new ToStringer(TableTrigger.class).toString(); + } +} diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/BranchStatus.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/BranchStatus.java index 9b4dde230..16604dab6 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/BranchStatus.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/BranchStatus.java @@ -10,14 +10,7 @@ @Generated public class BranchStatus { - /** - * The short identifier of the branch, suitable for showing to the users. For a branch with name - * `projects/my-project/branches/my-branch`, the branch_id is `my-branch`. - * - *

Use this field when building UI components that display branches to users (e.g., a drop-down - * selector). Prefer showing `branch_id` instead of the full resource name from `Branch.name`, - * which follows the `projects/{project_id}/branches/{branch_id}` format and is not user-friendly. - */ + /** Part of the resource name. */ @JsonProperty("branch_id") private String branchId; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/CatalogCatalogStatus.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/CatalogCatalogStatus.java index a8f0eb3aa..f257e4fde 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/CatalogCatalogStatus.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/CatalogCatalogStatus.java @@ -18,14 +18,7 @@ public class CatalogCatalogStatus { @JsonProperty("branch") private String branch; - /** - * The short identifier of the catalog, suitable for showing to the users. For a catalog with name - * `catalogs/my-catalog`, the catalog_id is `my-catalog`. - * - *

Use this field when building UI components that display catalogs to users (e.g., a drop-down - * selector). Prefer showing `catalog_id` instead of the full resource name from `Catalog.name`, - * which follows the `catalogs/{catalog_id}` format and is not user-friendly. - */ + /** Part of the resource name. */ @JsonProperty("catalog_id") private String catalogId; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/DatabaseDatabaseStatus.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/DatabaseDatabaseStatus.java index 53aec7344..4a4271d82 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/DatabaseDatabaseStatus.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/DatabaseDatabaseStatus.java @@ -9,16 +9,7 @@ @Generated public class DatabaseDatabaseStatus { - /** - * The short identifier of the database, suitable for showing to the users. For a database with - * name `projects/my-project/branches/my-branch/databases/my-db`, the database_id is `my-db`. - * - *

Use this field when building UI components that display databases to users (e.g., a - * drop-down selector). Prefer showing `database_id` instead of the full resource name from - * `Database.name`, which follows the - * `projects/{project_id}/branches/{branch_id}/databases/{database_id}` format and is not - * user-friendly. - */ + /** Part of the resource name. */ @JsonProperty("database_id") private String databaseId; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/EndpointStatus.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/EndpointStatus.java index ea7cea139..c17c16a5f 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/EndpointStatus.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/EndpointStatus.java @@ -33,17 +33,7 @@ public class EndpointStatus { @JsonProperty("disabled") private Boolean disabled; - /** - * The short identifier of the endpoint, suitable for showing to the users. For an endpoint with - * name `projects/my-project/branches/my-branch/endpoints/my-endpoint`, the endpoint_id is - * `my-endpoint`. - * - *

Use this field when building UI components that display endpoints to users (e.g., a - * drop-down selector). Prefer showing `endpoint_id` instead of the full resource name from - * `Endpoint.name`, which follows the - * `projects/{project_id}/branches/{branch_id}/endpoints/{endpoint_id}` format and is not - * user-friendly. - */ + /** Part of the resource name. */ @JsonProperty("endpoint_id") private String endpointId; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/ProjectStatus.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/ProjectStatus.java index 477fbc49d..8c22dae72 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/ProjectStatus.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/ProjectStatus.java @@ -51,14 +51,7 @@ public class ProjectStatus { @JsonProperty("pg_version") private Long pgVersion; - /** - * The short identifier of the project, suitable for showing to the users. For a project with name - * `projects/my-project`, the project_id is `my-project`. - * - *

Use this field when building UI components that display projects to users (e.g., a drop-down - * selector). Prefer showing `project_id` instead of the full resource name from `Project.name`, - * which follows the `projects/{project_id}` format and is not user-friendly. - */ + /** Part of the resource name. */ @JsonProperty("project_id") private String projectId; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/RoleRoleStatus.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/RoleRoleStatus.java index 2a1b91884..ec722bd95 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/RoleRoleStatus.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/RoleRoleStatus.java @@ -30,15 +30,7 @@ public class RoleRoleStatus { @JsonProperty("postgres_role") private String postgresRole; - /** - * The short identifier of the role, suitable for showing to the users. For a role with name - * `projects/my-project/branches/my-branch/roles/my-role`, the role_id is `my-role`. - * - *

Use this field when building UI components that display roles to users (e.g., a drop-down - * selector). Prefer showing `role_id` instead of the full resource name from `Role.name`, which - * follows the `projects/{project_id}/branches/{branch_id}/roles/{role_id}` format and is not - * user-friendly. - */ + /** Part of the resource name. */ @JsonProperty("role_id") private String roleId; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableStatus.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableStatus.java index e7dc081bc..832155322 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableStatus.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableStatus.java @@ -53,6 +53,10 @@ public class SyncedTableSyncedTableStatus { @JsonProperty("provisioning_phase") private ProvisioningPhase provisioningPhase; + /** Part of the resource name. */ + @JsonProperty("synced_table_id") + private String syncedTableId; + /** The provisioning state of the synced table entity in Unity Catalog. */ @JsonProperty("unity_catalog_provisioning_state") private ProvisioningInfoState unityCatalogProvisioningState; @@ -140,6 +144,15 @@ public ProvisioningPhase getProvisioningPhase() { return provisioningPhase; } + public SyncedTableSyncedTableStatus setSyncedTableId(String syncedTableId) { + this.syncedTableId = syncedTableId; + return this; + } + + public String getSyncedTableId() { + return syncedTableId; + } + public SyncedTableSyncedTableStatus setUnityCatalogProvisioningState( ProvisioningInfoState unityCatalogProvisioningState) { this.unityCatalogProvisioningState = unityCatalogProvisioningState; @@ -164,6 +177,7 @@ public boolean equals(Object o) { && Objects.equals(pipelineId, that.pipelineId) && Objects.equals(project, that.project) && Objects.equals(provisioningPhase, that.provisioningPhase) + && Objects.equals(syncedTableId, that.syncedTableId) && Objects.equals(unityCatalogProvisioningState, that.unityCatalogProvisioningState); } @@ -179,6 +193,7 @@ public int hashCode() { pipelineId, project, provisioningPhase, + syncedTableId, unityCatalogProvisioningState); } @@ -194,6 +209,7 @@ public String toString() { .add("pipelineId", pipelineId) .add("project", project) .add("provisioningPhase", provisioningPhase) + .add("syncedTableId", syncedTableId) .add("unityCatalogProvisioningState", unityCatalogProvisioningState) .toString(); }