diff --git a/.codegen/_openapi_sha b/.codegen/_openapi_sha index 890655a3b..3c86080ee 100755 --- a/.codegen/_openapi_sha +++ b/.codegen/_openapi_sha @@ -1 +1 @@ -805d88b51faa37301c51d1848da2db5a2e6ed921 \ No newline at end of file +f7c2fb590bc8a2eb185baf35469a13895528632f \ No newline at end of file diff --git a/.gitattributes b/.gitattributes index 859236152..43f04494a 100755 --- a/.gitattributes +++ b/.gitattributes @@ -1247,6 +1247,8 @@ databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTabl databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableProvisioningStatus.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSchedulingPolicy.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpec.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpecPgSpecificType.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpecTypeOverride.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableState.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableStatus.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableTriggeredUpdateStatus.java linguist-generated=true @@ -2586,7 +2588,9 @@ databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTabl databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTablePosition.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableState.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpec.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpecPgSpecificType.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpecSyncedTableSchedulingPolicy.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpecTypeOverride.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableStatus.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/UndeleteBranchOperation.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/UndeleteBranchRequest.java linguist-generated=true diff --git a/NEXT_CHANGELOG.md b/NEXT_CHANGELOG.md old mode 100644 new mode 100755 index 8f7fec8bd..52efee20e --- a/NEXT_CHANGELOG.md +++ b/NEXT_CHANGELOG.md @@ -15,3 +15,5 @@ ### Internal Changes ### API Changes +* Add `acceleratedSync` and `typeOverrides` fields for `com.databricks.sdk.service.database.SyncedTableSpec`. +* Add `acceleratedSync` and `typeOverrides` fields for `com.databricks.sdk.service.postgres.SyncedTableSyncedTableSpec`. \ No newline at end of file diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ConnectionType.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ConnectionType.java index 095dbc1c8..9c39c590f 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ConnectionType.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ConnectionType.java @@ -4,7 +4,7 @@ import com.databricks.sdk.support.Generated; -/** Next Id: 126 */ +/** Next Id: 127 */ @Generated public enum ConnectionType { BIGQUERY, diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SecurableKind.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SecurableKind.java index 2077d9589..88eaf89ce 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SecurableKind.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SecurableKind.java @@ -5,8 +5,8 @@ import com.databricks.sdk.support.Generated; /** - * Latest kind: CONNECTION_ADOBE_CAMPAIGNS_OAUTH_M2M = 345; Next id: 346. Reserved numbers: 316, - * 317, 327, 330, 341 (former ENDPOINT_LLM_*, MODEL_SERVICE_STANDARD, + * Latest kind: CONNECTION_CONFLUENT_SCHEMA_REGISTRY_BASIC = 346; Next id: 347. Reserved numbers: + * 316, 317, 327, 330, 341 (former ENDPOINT_LLM_*, MODEL_SERVICE_STANDARD, * MODEL_SERVICE_SYSTEM_DELTASHARING, MCP_SERVICE_STANDARD). */ @Generated diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/RevertDashboardRequest.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/RevertDashboardRequest.java index 59857321b..f9cfe3701 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/RevertDashboardRequest.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/RevertDashboardRequest.java @@ -16,8 +16,7 @@ public class RevertDashboardRequest { /** * The etag for the dashboard. Optionally, it can be provided to verify that the dashboard has not - * been modified from its last retrieval. TODO(TSE-3937): update to new non-CMK-encrypted label - * when available + * been modified from its last retrieval. */ @JsonProperty("etag") private String etag; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpec.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpec.java index 6d156777a..c2ad8abd5 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpec.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpec.java @@ -11,6 +11,13 @@ /** Specification of a synced database table. */ @Generated public class SyncedTableSpec { + /** + * When true, enables accelerated sync mode for the initial data load. This significantly improves + * performance for large tables. Requires workspace-level enablement. + */ + @JsonProperty("accelerated_sync") + private Boolean acceleratedSync; + /** * If true, the synced table's logical database and schema resources in PG will be created if they * do not already exist. @@ -57,6 +64,22 @@ public class SyncedTableSpec { @JsonProperty("timeseries_key") private String timeseriesKey; + /** + * Override the default Delta->PG type mapping for specific columns. A TypeOverride with + * PG_SPECIFIC_TYPE_UNSPECIFIED is rejected; a valid pg_type must be set. + */ + @JsonProperty("type_overrides") + private Collection typeOverrides; + + public SyncedTableSpec setAcceleratedSync(Boolean acceleratedSync) { + this.acceleratedSync = acceleratedSync; + return this; + } + + public Boolean getAcceleratedSync() { + return acceleratedSync; + } + public SyncedTableSpec setCreateDatabaseObjectsIfMissing(Boolean createDatabaseObjectsIfMissing) { this.createDatabaseObjectsIfMissing = createDatabaseObjectsIfMissing; return this; @@ -120,35 +143,49 @@ public String getTimeseriesKey() { return timeseriesKey; } + public SyncedTableSpec setTypeOverrides(Collection typeOverrides) { + this.typeOverrides = typeOverrides; + return this; + } + + public Collection getTypeOverrides() { + return typeOverrides; + } + @Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; SyncedTableSpec that = (SyncedTableSpec) o; - return Objects.equals(createDatabaseObjectsIfMissing, that.createDatabaseObjectsIfMissing) + return Objects.equals(acceleratedSync, that.acceleratedSync) + && Objects.equals(createDatabaseObjectsIfMissing, that.createDatabaseObjectsIfMissing) && Objects.equals(existingPipelineId, that.existingPipelineId) && Objects.equals(newPipelineSpec, that.newPipelineSpec) && Objects.equals(primaryKeyColumns, that.primaryKeyColumns) && Objects.equals(schedulingPolicy, that.schedulingPolicy) && Objects.equals(sourceTableFullName, that.sourceTableFullName) - && Objects.equals(timeseriesKey, that.timeseriesKey); + && Objects.equals(timeseriesKey, that.timeseriesKey) + && Objects.equals(typeOverrides, that.typeOverrides); } @Override public int hashCode() { return Objects.hash( + acceleratedSync, createDatabaseObjectsIfMissing, existingPipelineId, newPipelineSpec, primaryKeyColumns, schedulingPolicy, sourceTableFullName, - timeseriesKey); + timeseriesKey, + typeOverrides); } @Override public String toString() { return new ToStringer(SyncedTableSpec.class) + .add("acceleratedSync", acceleratedSync) .add("createDatabaseObjectsIfMissing", createDatabaseObjectsIfMissing) .add("existingPipelineId", existingPipelineId) .add("newPipelineSpec", newPipelineSpec) @@ -156,6 +193,7 @@ public String toString() { .add("schedulingPolicy", schedulingPolicy) .add("sourceTableFullName", sourceTableFullName) .add("timeseriesKey", timeseriesKey) + .add("typeOverrides", typeOverrides) .toString(); } } diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpecPgSpecificType.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpecPgSpecificType.java new file mode 100755 index 000000000..90d026bf9 --- /dev/null +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpecPgSpecificType.java @@ -0,0 +1,11 @@ +// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT. + +package com.databricks.sdk.service.database; + +import com.databricks.sdk.support.Generated; + +/** PostgreSQL-specific target types that can override the default Delta-to-PG mapping. */ +@Generated +public enum SyncedTableSpecPgSpecificType { + PG_SPECIFIC_TYPE_VECTOR, +} diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpecTypeOverride.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpecTypeOverride.java new file mode 100755 index 000000000..5f43ab17a --- /dev/null +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/database/SyncedTableSpecTypeOverride.java @@ -0,0 +1,78 @@ +// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT. + +package com.databricks.sdk.service.database; + +import com.databricks.sdk.support.Generated; +import com.databricks.sdk.support.ToStringer; +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.Objects; + +/** Overrides the default Delta-to-PostgreSQL type mapping for a single column. */ +@Generated +public class SyncedTableSpecTypeOverride { + /** Name of the source column whose target PostgreSQL type should be overridden. */ + @JsonProperty("column_name") + private String columnName; + + /** PostgreSQL-specific target type to use for the column. */ + @JsonProperty("pg_type") + private SyncedTableSpecPgSpecificType pgType; + + /** + * Size parameter for the target type. Required when pg_type is PG_SPECIFIC_TYPE_VECTOR (specifies + * the vector dimension, e.g., 1024). + */ + @JsonProperty("size") + private Long size; + + public SyncedTableSpecTypeOverride setColumnName(String columnName) { + this.columnName = columnName; + return this; + } + + public String getColumnName() { + return columnName; + } + + public SyncedTableSpecTypeOverride setPgType(SyncedTableSpecPgSpecificType pgType) { + this.pgType = pgType; + return this; + } + + public SyncedTableSpecPgSpecificType getPgType() { + return pgType; + } + + public SyncedTableSpecTypeOverride setSize(Long size) { + this.size = size; + return this; + } + + public Long getSize() { + return size; + } + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + SyncedTableSpecTypeOverride that = (SyncedTableSpecTypeOverride) o; + return Objects.equals(columnName, that.columnName) + && Objects.equals(pgType, that.pgType) + && Objects.equals(size, that.size); + } + + @Override + public int hashCode() { + return Objects.hash(columnName, pgType, size); + } + + @Override + public String toString() { + return new ToStringer(SyncedTableSpecTypeOverride.class) + .add("columnName", columnName) + .add("pgType", pgType) + .add("size", size) + .toString(); + } +} diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/marketplace/FileParent.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/marketplace/FileParent.java index d5c91c318..506a76628 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/marketplace/FileParent.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/marketplace/FileParent.java @@ -15,7 +15,7 @@ public class FileParent { @QueryParam("file_parent_type") private FileParentType fileParentType; - /** TODO make the following fields required */ + /** */ @JsonProperty("parent_id") @QueryParam("parent_id") private String parentId; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/marketplace/ListingDetail.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/marketplace/ListingDetail.java index dcf891232..5a80dbc00 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/marketplace/ListingDetail.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/marketplace/ListingDetail.java @@ -63,7 +63,7 @@ public class ListingDetail { /** * What the pricing model is (e.g. paid, subscription, paid upfront); should only be present if - * cost is paid TODO: Not used yet, should deprecate if we will never use it + * cost is paid */ @JsonProperty("pricing_model") private String pricingModel; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/AvgFunction.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/AvgFunction.java index 3d04bca5e..048805404 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/AvgFunction.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/AvgFunction.java @@ -12,9 +12,9 @@ public class AvgFunction { /** * The input column from which the average is computed. For Kafka sources, use dot-prefixed path - * notation (e.g., "value.amount"). For nested fields, the leaf node name is used. TODO(FS-939): - * Colon-prefixed notation (e.g., "value:amount") is supported for backwards compatibility but is - * deprecated; migrate to dot notation. + * notation (e.g., "value.amount"). For nested fields, the leaf node name is used. Colon-prefixed + * notation (e.g., "value:amount") is supported for backwards compatibility but is deprecated; + * migrate to dot notation. */ @JsonProperty("input") private String input; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CountFunction.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CountFunction.java index 78ea3774e..879a11f51 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CountFunction.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/CountFunction.java @@ -12,9 +12,9 @@ public class CountFunction { /** * The input column from which the count is computed. For Kafka sources, use dot-prefixed path - * notation (e.g., "value.amount"). For nested fields, the leaf node name is used. TODO(FS-939): - * Colon-prefixed notation (e.g., "value:amount") is supported for backwards compatibility but is - * deprecated; migrate to dot notation. + * notation (e.g., "value.amount"). For nested fields, the leaf node name is used. Colon-prefixed + * notation (e.g., "value:amount") is supported for backwards compatibility but is deprecated; + * migrate to dot notation. */ @JsonProperty("input") private String input; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/DirectMtlsConfig.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/DirectMtlsConfig.java index 00f861701..e9b6aaafa 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/DirectMtlsConfig.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/DirectMtlsConfig.java @@ -8,8 +8,8 @@ import java.util.Objects; /** - * Direct connection configs for mTLS, as Kafka Connections do not support mTLS yet (XTA-18030). - * Temporarily used until UC Kafka Connections gain mTLS support. + * Direct connection configs for mTLS, as Kafka Connections do not support mTLS yet . Temporarily + * used until UC Kafka Connections gain mTLS support. */ @Generated public class DirectMtlsConfig { diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/EntityColumn.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/EntityColumn.java index 17e0cf207..07684946e 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/EntityColumn.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/EntityColumn.java @@ -13,9 +13,9 @@ public class EntityColumn { * The name of the entity column. For Kafka sources, use dot-prefixed path notation to reference * fields within the key or value schema (e.g., "value.user_id", "key.partition_key"). For nested * fields, the leaf node name (e.g., "user_id" from "value.trip_details.user_id") is what will be - * present in materialized tables and expected to match at query time. TODO(FS-939): - * Colon-prefixed notation (e.g., "value:user_id") is supported for backwards compatibility but is - * deprecated; migrate to dot notation. + * present in materialized tables and expected to match at query time. Colon-prefixed notation + * (e.g., "value:user_id") is supported for backwards compatibility but is deprecated; migrate to + * dot notation. */ @JsonProperty("name") private String name; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LinkedFeature.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LinkedFeature.java index 5842cdf45..bc4e305d3 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LinkedFeature.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LinkedFeature.java @@ -7,7 +7,7 @@ import com.fasterxml.jackson.annotation.JsonProperty; import java.util.Objects; -/** Feature for model version. ([ML-57150] Renamed from Feature to LinkedFeature) */ +/** Feature for model version. */ @Generated public class LinkedFeature { /** Feature name */ diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StddevPopFunction.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StddevPopFunction.java index b9e551b15..483b534ab 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StddevPopFunction.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StddevPopFunction.java @@ -13,8 +13,8 @@ public class StddevPopFunction { /** * The input column from which the population standard deviation is computed. For Kafka sources, * use dot-prefixed path notation (e.g., "value.amount"). For nested fields, the leaf node name is - * used. TODO(FS-939): Colon-prefixed notation (e.g., "value:amount") is supported for backwards - * compatibility but is deprecated; migrate to dot notation. + * used. Colon-prefixed notation (e.g., "value:amount") is supported for backwards compatibility + * but is deprecated; migrate to dot notation. */ @JsonProperty("input") private String input; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamConnectionConfig.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamConnectionConfig.java index 758f1ba5d..1b2f9da58 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamConnectionConfig.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/StreamConnectionConfig.java @@ -12,8 +12,8 @@ public class StreamConnectionConfig { /** * Direct mTLS configuration for stream platform access. This is only used in the short term until - * UC Kafka Connections support mTLS (XTA-18030). Once UC Kafka Connections support mTLS, this - * will be deprecated. + * UC Kafka Connections support mTLS . Once UC Kafka Connections support mTLS, this will be + * deprecated. */ @JsonProperty("direct_mtls_config") private DirectMtlsConfig directMtlsConfig; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SumFunction.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SumFunction.java index 8da774fe0..18783544d 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SumFunction.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SumFunction.java @@ -12,9 +12,9 @@ public class SumFunction { /** * The input column from which the sum is computed. For Kafka sources, use dot-prefixed path - * notation (e.g., "value.amount"). For nested fields, the leaf node name is used. TODO(FS-939): - * Colon-prefixed notation (e.g., "value:amount") is supported for backwards compatibility but is - * deprecated; migrate to dot notation. + * notation (e.g., "value.amount"). For nested fields, the leaf node name is used. Colon-prefixed + * notation (e.g., "value:amount") is supported for backwards compatibility but is deprecated; + * migrate to dot notation. */ @JsonProperty("input") private String input; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TimeseriesColumn.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TimeseriesColumn.java index fef3a9662..951c7030d 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TimeseriesColumn.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TimeseriesColumn.java @@ -14,8 +14,8 @@ public class TimeseriesColumn { * reference fields within the key or value schema (e.g., "value.event_timestamp"). For nested * fields, the leaf node name (e.g., "event_timestamp" from "value.event_details.event_timestamp") * is what will be present in materialized tables and expected to match at query time. - * TODO(FS-939): Colon-prefixed notation (e.g., "value:event_timestamp") is supported for - * backwards compatibility but is deprecated; migrate to dot notation. + * Colon-prefixed notation (e.g., "value:event_timestamp") is supported for backwards + * compatibility but is deprecated; migrate to dot notation. */ @JsonProperty("name") private String name; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpec.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpec.java index 745692c75..f586e1951 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpec.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpec.java @@ -10,6 +10,14 @@ @Generated public class SyncedTableSyncedTableSpec { + /** + * When true, enables accelerated sync mode for the initial data load. This significantly improves + * performance for large tables. Requires workspace-level enablement through Lakebase Accelerated + * Sync preview. + */ + @JsonProperty("accelerated_sync") + private Boolean acceleratedSync; + /** * The full resource name the branch associated with the table. * @@ -81,6 +89,22 @@ public class SyncedTableSyncedTableSpec { @JsonProperty("timeseries_key") private String timeseriesKey; + /** + * Override the default Delta->PG type mapping for specific columns. A TypeOverride with + * PG_SPECIFIC_TYPE_UNSPECIFIED is rejected; a valid pg_type must be set. + */ + @JsonProperty("type_overrides") + private Collection typeOverrides; + + public SyncedTableSyncedTableSpec setAcceleratedSync(Boolean acceleratedSync) { + this.acceleratedSync = acceleratedSync; + return this; + } + + public Boolean getAcceleratedSync() { + return acceleratedSync; + } + public SyncedTableSyncedTableSpec setBranch(String branch) { this.branch = branch; return this; @@ -164,12 +188,23 @@ public String getTimeseriesKey() { return timeseriesKey; } + public SyncedTableSyncedTableSpec setTypeOverrides( + Collection typeOverrides) { + this.typeOverrides = typeOverrides; + return this; + } + + public Collection getTypeOverrides() { + return typeOverrides; + } + @Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; SyncedTableSyncedTableSpec that = (SyncedTableSyncedTableSpec) o; - return Objects.equals(branch, that.branch) + return Objects.equals(acceleratedSync, that.acceleratedSync) + && Objects.equals(branch, that.branch) && Objects.equals(createDatabaseObjectsIfMissing, that.createDatabaseObjectsIfMissing) && Objects.equals(existingPipelineId, that.existingPipelineId) && Objects.equals(newPipelineSpec, that.newPipelineSpec) @@ -177,12 +212,14 @@ public boolean equals(Object o) { && Objects.equals(primaryKeyColumns, that.primaryKeyColumns) && Objects.equals(schedulingPolicy, that.schedulingPolicy) && Objects.equals(sourceTableFullName, that.sourceTableFullName) - && Objects.equals(timeseriesKey, that.timeseriesKey); + && Objects.equals(timeseriesKey, that.timeseriesKey) + && Objects.equals(typeOverrides, that.typeOverrides); } @Override public int hashCode() { return Objects.hash( + acceleratedSync, branch, createDatabaseObjectsIfMissing, existingPipelineId, @@ -191,12 +228,14 @@ public int hashCode() { primaryKeyColumns, schedulingPolicy, sourceTableFullName, - timeseriesKey); + timeseriesKey, + typeOverrides); } @Override public String toString() { return new ToStringer(SyncedTableSyncedTableSpec.class) + .add("acceleratedSync", acceleratedSync) .add("branch", branch) .add("createDatabaseObjectsIfMissing", createDatabaseObjectsIfMissing) .add("existingPipelineId", existingPipelineId) @@ -206,6 +245,7 @@ public String toString() { .add("schedulingPolicy", schedulingPolicy) .add("sourceTableFullName", sourceTableFullName) .add("timeseriesKey", timeseriesKey) + .add("typeOverrides", typeOverrides) .toString(); } } diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpecPgSpecificType.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpecPgSpecificType.java new file mode 100755 index 000000000..ac762b8fa --- /dev/null +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpecPgSpecificType.java @@ -0,0 +1,11 @@ +// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT. + +package com.databricks.sdk.service.postgres; + +import com.databricks.sdk.support.Generated; + +/** PostgreSQL-specific target types that can override the default Delta-to-PG mapping. */ +@Generated +public enum SyncedTableSyncedTableSpecPgSpecificType { + PG_SPECIFIC_TYPE_VECTOR, +} diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpecTypeOverride.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpecTypeOverride.java new file mode 100755 index 000000000..71cf85e26 --- /dev/null +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/postgres/SyncedTableSyncedTableSpecTypeOverride.java @@ -0,0 +1,79 @@ +// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT. + +package com.databricks.sdk.service.postgres; + +import com.databricks.sdk.support.Generated; +import com.databricks.sdk.support.ToStringer; +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.Objects; + +/** Overrides the default Delta-to-PostgreSQL type mapping for a single column. */ +@Generated +public class SyncedTableSyncedTableSpecTypeOverride { + /** Name of the source column whose target PostgreSQL type should be overridden. */ + @JsonProperty("column_name") + private String columnName; + + /** PostgreSQL-specific target type to use for the column. */ + @JsonProperty("pg_type") + private SyncedTableSyncedTableSpecPgSpecificType pgType; + + /** + * Size parameter for the target type. Required when pg_type is PG_SPECIFIC_TYPE_VECTOR (specifies + * the vector dimension, e.g., 1024). + */ + @JsonProperty("size") + private Long size; + + public SyncedTableSyncedTableSpecTypeOverride setColumnName(String columnName) { + this.columnName = columnName; + return this; + } + + public String getColumnName() { + return columnName; + } + + public SyncedTableSyncedTableSpecTypeOverride setPgType( + SyncedTableSyncedTableSpecPgSpecificType pgType) { + this.pgType = pgType; + return this; + } + + public SyncedTableSyncedTableSpecPgSpecificType getPgType() { + return pgType; + } + + public SyncedTableSyncedTableSpecTypeOverride setSize(Long size) { + this.size = size; + return this; + } + + public Long getSize() { + return size; + } + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + SyncedTableSyncedTableSpecTypeOverride that = (SyncedTableSyncedTableSpecTypeOverride) o; + return Objects.equals(columnName, that.columnName) + && Objects.equals(pgType, that.pgType) + && Objects.equals(size, that.size); + } + + @Override + public int hashCode() { + return Objects.hash(columnName, pgType, size); + } + + @Override + public String toString() { + return new ToStringer(SyncedTableSyncedTableSpecTypeOverride.class) + .add("columnName", columnName) + .add("pgType", pgType) + .add("size", size) + .toString(); + } +} diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/provisioning/VpcEndpoint.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/provisioning/VpcEndpoint.java index 7cd94edc4..9de473172 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/provisioning/VpcEndpoint.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/provisioning/VpcEndpoint.java @@ -10,10 +10,7 @@ /** * */ @Generated public class VpcEndpoint { - /** - * The Databricks account ID that hosts the VPC endpoint configuration. TODO - This may signal an - * OpenAPI diff; it does not show up in the generated spec - */ + /** The Databricks account ID that hosts the VPC endpoint configuration. */ @JsonProperty("account_id") private String accountId; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/NetworkPolicyEgress.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/NetworkPolicyEgress.java index a3b0dea02..d21cafce2 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/NetworkPolicyEgress.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/NetworkPolicyEgress.java @@ -7,13 +7,7 @@ import com.fasterxml.jackson.annotation.JsonProperty; import java.util.Objects; -/** - * The network policies applying for egress traffic. This message is used by the UI/REST API. We - * translate this message to the format expected by the dataplane in Lakehouse Network Manager (for - * the format expected by the dataplane, see networkconfig.textproto). This policy should be - * consistent with [[com.databricks.api.proto.settingspolicy.EgressNetworkPolicy]]. Details see - * API-design: https://docs.google.com/document/d/1DKWO_FpZMCY4cF2O62LpwII1lx8gsnDGG-qgE3t3TOA/ - */ +/** The network policies applying for egress traffic. */ @Generated public class NetworkPolicyEgress { /** The access policy enforced for egress traffic to the internet. */ diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sql/SpotInstancePolicy.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sql/SpotInstancePolicy.java index bd5ec7c05..262a17545 100755 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sql/SpotInstancePolicy.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sql/SpotInstancePolicy.java @@ -15,10 +15,6 @@ * Demand Driver with Spot Executors | On Demand Driver and Executors | | AZURE | On Demand Driver * and Executors | On Demand Driver and Executors | * +-------+--------------------------------------+--------------------------------+ - * - *

While including "spot" in the enum name may limit the the future extensibility of this field - * because it limits this enum to denoting "spot or not", this is the field that PM recommends after - * discussion with customers per SC-48783. */ @Generated public enum SpotInstancePolicy {