list(ListCatalogsRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::list,
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ConnectionsAPI.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ConnectionsAPI.java
index ff8b2cda9..eb449c1dd 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ConnectionsAPI.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ConnectionsAPI.java
@@ -85,6 +85,10 @@ public ConnectionInfo get(GetConnectionRequest request) {
* List all connections.
*/
public Iterable list(ListConnectionsRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::list,
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ExternalLocationsAPI.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ExternalLocationsAPI.java
index a5c5d698e..0edf3c3eb 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ExternalLocationsAPI.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/ExternalLocationsAPI.java
@@ -88,6 +88,10 @@ public ExternalLocationInfo get(GetExternalLocationRequest request) {
* elements in the array.
*/
public Iterable list(ListExternalLocationsRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::list,
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SchemasAPI.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SchemasAPI.java
index acaa88214..c1345a265 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SchemasAPI.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SchemasAPI.java
@@ -85,6 +85,10 @@ public Iterable list(String catalogName) {
* the array.
*/
public Iterable list(ListSchemasRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::list,
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/StorageCredentialsAPI.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/StorageCredentialsAPI.java
index 89fc74af4..61a532e2e 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/StorageCredentialsAPI.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/StorageCredentialsAPI.java
@@ -86,6 +86,10 @@ public StorageCredentialInfo get(GetStorageCredentialRequest request) {
* specific ordering of the elements in the array.
*/
public Iterable list(ListStorageCredentialsRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::list,
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SystemSchemasAPI.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SystemSchemasAPI.java
index 605036b9e..b08818600 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SystemSchemasAPI.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/SystemSchemasAPI.java
@@ -67,6 +67,10 @@ public Iterable list(String metastoreId) {
* metastore admin.
*/
public Iterable list(ListSystemSchemasRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::list,
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/TablesAPI.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/TablesAPI.java
index 0717b94b0..620144b8e 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/TablesAPI.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/catalog/TablesAPI.java
@@ -99,6 +99,10 @@ public Iterable list(String catalogName, String schemaName) {
* no guarantee of a specific ordering of the elements in the array.
*/
public Iterable list(ListTablesRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::list,
@@ -131,6 +135,10 @@ public Iterable listSummaries(String catalogName) {
* There is no guarantee of a specific ordering of the elements in the array.
*/
public Iterable listSummaries(ListSummariesRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::listSummaries,
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/cleanrooms/CleanRoomAssetNotebook.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/cleanrooms/CleanRoomAssetNotebook.java
index 459ec98c6..20673bbf9 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/cleanrooms/CleanRoomAssetNotebook.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/cleanrooms/CleanRoomAssetNotebook.java
@@ -5,7 +5,6 @@
import com.databricks.sdk.support.Generated;
import com.databricks.sdk.support.ToStringer;
import com.fasterxml.jackson.annotation.JsonProperty;
-import java.util.Collection;
import java.util.Objects;
@Generated
@@ -21,18 +20,6 @@ public class CleanRoomAssetNotebook {
@JsonProperty("notebook_content")
private String notebookContent;
- /** top-level status derived from all reviews */
- @JsonProperty("review_state")
- private CleanRoomNotebookReviewNotebookReviewState reviewState;
-
- /** All existing approvals or rejections */
- @JsonProperty("reviews")
- private Collection reviews;
-
- /** collaborators that can run the notebook */
- @JsonProperty("runner_collaborators")
- private Collection runnerCollaborators;
-
public CleanRoomAssetNotebook setEtag(String etag) {
this.etag = etag;
return this;
@@ -51,50 +38,17 @@ public String getNotebookContent() {
return notebookContent;
}
- public CleanRoomAssetNotebook setReviewState(
- CleanRoomNotebookReviewNotebookReviewState reviewState) {
- this.reviewState = reviewState;
- return this;
- }
-
- public CleanRoomNotebookReviewNotebookReviewState getReviewState() {
- return reviewState;
- }
-
- public CleanRoomAssetNotebook setReviews(Collection reviews) {
- this.reviews = reviews;
- return this;
- }
-
- public Collection getReviews() {
- return reviews;
- }
-
- public CleanRoomAssetNotebook setRunnerCollaborators(
- Collection runnerCollaborators) {
- this.runnerCollaborators = runnerCollaborators;
- return this;
- }
-
- public Collection getRunnerCollaborators() {
- return runnerCollaborators;
- }
-
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
CleanRoomAssetNotebook that = (CleanRoomAssetNotebook) o;
- return Objects.equals(etag, that.etag)
- && Objects.equals(notebookContent, that.notebookContent)
- && Objects.equals(reviewState, that.reviewState)
- && Objects.equals(reviews, that.reviews)
- && Objects.equals(runnerCollaborators, that.runnerCollaborators);
+ return Objects.equals(etag, that.etag) && Objects.equals(notebookContent, that.notebookContent);
}
@Override
public int hashCode() {
- return Objects.hash(etag, notebookContent, reviewState, reviews, runnerCollaborators);
+ return Objects.hash(etag, notebookContent);
}
@Override
@@ -102,9 +56,6 @@ public String toString() {
return new ToStringer(CleanRoomAssetNotebook.class)
.add("etag", etag)
.add("notebookContent", notebookContent)
- .add("reviewState", reviewState)
- .add("reviews", reviews)
- .add("runnerCollaborators", runnerCollaborators)
.toString();
}
}
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/cleanrooms/CleanRoomNotebookReview.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/cleanrooms/CleanRoomNotebookReview.java
deleted file mode 100755
index 765abc3d3..000000000
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/cleanrooms/CleanRoomNotebookReview.java
+++ /dev/null
@@ -1,90 +0,0 @@
-// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT.
-
-package com.databricks.sdk.service.cleanrooms;
-
-import com.databricks.sdk.support.Generated;
-import com.databricks.sdk.support.ToStringer;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import java.util.Objects;
-
-@Generated
-public class CleanRoomNotebookReview {
- /** review comment */
- @JsonProperty("comment")
- private String comment;
-
- /** timestamp of when the review was submitted */
- @JsonProperty("created_at_millis")
- private Long createdAtMillis;
-
- /** review outcome */
- @JsonProperty("review_state")
- private CleanRoomNotebookReviewNotebookReviewState reviewState;
-
- /** collaborator alias of the reviewer */
- @JsonProperty("reviewer_collaborator_alias")
- private String reviewerCollaboratorAlias;
-
- public CleanRoomNotebookReview setComment(String comment) {
- this.comment = comment;
- return this;
- }
-
- public String getComment() {
- return comment;
- }
-
- public CleanRoomNotebookReview setCreatedAtMillis(Long createdAtMillis) {
- this.createdAtMillis = createdAtMillis;
- return this;
- }
-
- public Long getCreatedAtMillis() {
- return createdAtMillis;
- }
-
- public CleanRoomNotebookReview setReviewState(
- CleanRoomNotebookReviewNotebookReviewState reviewState) {
- this.reviewState = reviewState;
- return this;
- }
-
- public CleanRoomNotebookReviewNotebookReviewState getReviewState() {
- return reviewState;
- }
-
- public CleanRoomNotebookReview setReviewerCollaboratorAlias(String reviewerCollaboratorAlias) {
- this.reviewerCollaboratorAlias = reviewerCollaboratorAlias;
- return this;
- }
-
- public String getReviewerCollaboratorAlias() {
- return reviewerCollaboratorAlias;
- }
-
- @Override
- public boolean equals(Object o) {
- if (this == o) return true;
- if (o == null || getClass() != o.getClass()) return false;
- CleanRoomNotebookReview that = (CleanRoomNotebookReview) o;
- return Objects.equals(comment, that.comment)
- && Objects.equals(createdAtMillis, that.createdAtMillis)
- && Objects.equals(reviewState, that.reviewState)
- && Objects.equals(reviewerCollaboratorAlias, that.reviewerCollaboratorAlias);
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(comment, createdAtMillis, reviewState, reviewerCollaboratorAlias);
- }
-
- @Override
- public String toString() {
- return new ToStringer(CleanRoomNotebookReview.class)
- .add("comment", comment)
- .add("createdAtMillis", createdAtMillis)
- .add("reviewState", reviewState)
- .add("reviewerCollaboratorAlias", reviewerCollaboratorAlias)
- .toString();
- }
-}
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/cleanrooms/CleanRoomNotebookReviewNotebookReviewState.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/cleanrooms/CleanRoomNotebookReviewNotebookReviewState.java
deleted file mode 100755
index 6366690c5..000000000
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/cleanrooms/CleanRoomNotebookReviewNotebookReviewState.java
+++ /dev/null
@@ -1,12 +0,0 @@
-// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT.
-
-package com.databricks.sdk.service.cleanrooms;
-
-import com.databricks.sdk.support.Generated;
-
-@Generated
-public enum CleanRoomNotebookReviewNotebookReviewState {
- APPROVED,
- PENDING,
- REJECTED,
-}
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterAttributes.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterAttributes.java
index 586817c27..db0bdc978 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterAttributes.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterAttributes.java
@@ -35,11 +35,11 @@ public class ClusterAttributes {
private AzureAttributes azureAttributes;
/**
- * The configuration for delivering spark logs to a long-term storage destination. Two kinds of
- * destinations (dbfs and s3) are supported. Only one destination can be specified for one
- * cluster. If the conf is given, the logs will be delivered to the destination every `5 mins`.
- * The destination of driver logs is `$destination/$clusterId/driver`, while the destination of
- * executor logs is `$destination/$clusterId/executor`.
+ * The configuration for delivering spark logs to a long-term storage destination. Three kinds of
+ * destinations (DBFS, S3 and Unity Catalog volumes) are supported. Only one destination can be
+ * specified for one cluster. If the conf is given, the logs will be delivered to the destination
+ * every `5 mins`. The destination of driver logs is `$destination/$clusterId/driver`, while the
+ * destination of executor logs is `$destination/$clusterId/executor`.
*/
@JsonProperty("cluster_log_conf")
private ClusterLogConf clusterLogConf;
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterDetails.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterDetails.java
index 2a182f0c9..e8b977c41 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterDetails.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterDetails.java
@@ -57,11 +57,11 @@ public class ClusterDetails {
private String clusterId;
/**
- * The configuration for delivering spark logs to a long-term storage destination. Two kinds of
- * destinations (dbfs and s3) are supported. Only one destination can be specified for one
- * cluster. If the conf is given, the logs will be delivered to the destination every `5 mins`.
- * The destination of driver logs is `$destination/$clusterId/driver`, while the destination of
- * executor logs is `$destination/$clusterId/executor`.
+ * The configuration for delivering spark logs to a long-term storage destination. Three kinds of
+ * destinations (DBFS, S3 and Unity Catalog volumes) are supported. Only one destination can be
+ * specified for one cluster. If the conf is given, the logs will be delivered to the destination
+ * every `5 mins`. The destination of driver logs is `$destination/$clusterId/driver`, while the
+ * destination of executor logs is `$destination/$clusterId/executor`.
*/
@JsonProperty("cluster_log_conf")
private ClusterLogConf clusterLogConf;
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterLogConf.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterLogConf.java
index ef86dbd1b..d73ce9854 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterLogConf.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterLogConf.java
@@ -25,6 +25,13 @@ public class ClusterLogConf {
@JsonProperty("s3")
private S3StorageInfo s3;
+ /**
+ * destination needs to be provided. e.g. `{ "volumes" : { "destination" :
+ * "/Volumes/catalog/schema/volume/cluster_log" } }`
+ */
+ @JsonProperty("volumes")
+ private VolumesStorageInfo volumes;
+
public ClusterLogConf setDbfs(DbfsStorageInfo dbfs) {
this.dbfs = dbfs;
return this;
@@ -43,21 +50,36 @@ public S3StorageInfo getS3() {
return s3;
}
+ public ClusterLogConf setVolumes(VolumesStorageInfo volumes) {
+ this.volumes = volumes;
+ return this;
+ }
+
+ public VolumesStorageInfo getVolumes() {
+ return volumes;
+ }
+
@Override
public boolean equals(Object o) {
if (this == o) return true;
if (o == null || getClass() != o.getClass()) return false;
ClusterLogConf that = (ClusterLogConf) o;
- return Objects.equals(dbfs, that.dbfs) && Objects.equals(s3, that.s3);
+ return Objects.equals(dbfs, that.dbfs)
+ && Objects.equals(s3, that.s3)
+ && Objects.equals(volumes, that.volumes);
}
@Override
public int hashCode() {
- return Objects.hash(dbfs, s3);
+ return Objects.hash(dbfs, s3, volumes);
}
@Override
public String toString() {
- return new ToStringer(ClusterLogConf.class).add("dbfs", dbfs).add("s3", s3).toString();
+ return new ToStringer(ClusterLogConf.class)
+ .add("dbfs", dbfs)
+ .add("s3", s3)
+ .add("volumes", volumes)
+ .toString();
}
}
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterSpec.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterSpec.java
index d0ebea4b3..840b766f0 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterSpec.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/ClusterSpec.java
@@ -49,11 +49,11 @@ public class ClusterSpec {
private AzureAttributes azureAttributes;
/**
- * The configuration for delivering spark logs to a long-term storage destination. Two kinds of
- * destinations (dbfs and s3) are supported. Only one destination can be specified for one
- * cluster. If the conf is given, the logs will be delivered to the destination every `5 mins`.
- * The destination of driver logs is `$destination/$clusterId/driver`, while the destination of
- * executor logs is `$destination/$clusterId/executor`.
+ * The configuration for delivering spark logs to a long-term storage destination. Three kinds of
+ * destinations (DBFS, S3 and Unity Catalog volumes) are supported. Only one destination can be
+ * specified for one cluster. If the conf is given, the logs will be delivered to the destination
+ * every `5 mins`. The destination of driver logs is `$destination/$clusterId/driver`, while the
+ * destination of executor logs is `$destination/$clusterId/executor`.
*/
@JsonProperty("cluster_log_conf")
private ClusterLogConf clusterLogConf;
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/CreateCluster.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/CreateCluster.java
index 4ee21def2..844954914 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/CreateCluster.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/CreateCluster.java
@@ -56,11 +56,11 @@ public class CreateCluster {
private CloneCluster cloneFrom;
/**
- * The configuration for delivering spark logs to a long-term storage destination. Two kinds of
- * destinations (dbfs and s3) are supported. Only one destination can be specified for one
- * cluster. If the conf is given, the logs will be delivered to the destination every `5 mins`.
- * The destination of driver logs is `$destination/$clusterId/driver`, while the destination of
- * executor logs is `$destination/$clusterId/executor`.
+ * The configuration for delivering spark logs to a long-term storage destination. Three kinds of
+ * destinations (DBFS, S3 and Unity Catalog volumes) are supported. Only one destination can be
+ * specified for one cluster. If the conf is given, the logs will be delivered to the destination
+ * every `5 mins`. The destination of driver logs is `$destination/$clusterId/driver`, while the
+ * destination of executor logs is `$destination/$clusterId/executor`.
*/
@JsonProperty("cluster_log_conf")
private ClusterLogConf clusterLogConf;
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/EditCluster.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/EditCluster.java
index 33cd6edda..826ed2bf0 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/EditCluster.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/EditCluster.java
@@ -53,11 +53,11 @@ public class EditCluster {
private String clusterId;
/**
- * The configuration for delivering spark logs to a long-term storage destination. Two kinds of
- * destinations (dbfs and s3) are supported. Only one destination can be specified for one
- * cluster. If the conf is given, the logs will be delivered to the destination every `5 mins`.
- * The destination of driver logs is `$destination/$clusterId/driver`, while the destination of
- * executor logs is `$destination/$clusterId/executor`.
+ * The configuration for delivering spark logs to a long-term storage destination. Three kinds of
+ * destinations (DBFS, S3 and Unity Catalog volumes) are supported. Only one destination can be
+ * specified for one cluster. If the conf is given, the logs will be delivered to the destination
+ * every `5 mins`. The destination of driver logs is `$destination/$clusterId/driver`, while the
+ * destination of executor logs is `$destination/$clusterId/executor`.
*/
@JsonProperty("cluster_log_conf")
private ClusterLogConf clusterLogConf;
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/UpdateClusterResource.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/UpdateClusterResource.java
index 30abd3905..340a9515a 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/UpdateClusterResource.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/UpdateClusterResource.java
@@ -42,11 +42,11 @@ public class UpdateClusterResource {
private AzureAttributes azureAttributes;
/**
- * The configuration for delivering spark logs to a long-term storage destination. Two kinds of
- * destinations (dbfs and s3) are supported. Only one destination can be specified for one
- * cluster. If the conf is given, the logs will be delivered to the destination every `5 mins`.
- * The destination of driver logs is `$destination/$clusterId/driver`, while the destination of
- * executor logs is `$destination/$clusterId/executor`.
+ * The configuration for delivering spark logs to a long-term storage destination. Three kinds of
+ * destinations (DBFS, S3 and Unity Catalog volumes) are supported. Only one destination can be
+ * specified for one cluster. If the conf is given, the logs will be delivered to the destination
+ * every `5 mins`. The destination of driver logs is `$destination/$clusterId/driver`, while the
+ * destination of executor logs is `$destination/$clusterId/executor`.
*/
@JsonProperty("cluster_log_conf")
private ClusterLogConf clusterLogConf;
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/VolumesStorageInfo.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/VolumesStorageInfo.java
index 4a8778c83..a65a5b555 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/VolumesStorageInfo.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/compute/VolumesStorageInfo.java
@@ -9,7 +9,7 @@
@Generated
public class VolumesStorageInfo {
- /** Unity Catalog Volumes file destination, e.g. `/Volumes/my-init.sh` */
+ /** Unity Catalog volumes file destination, e.g. `/Volumes/catalog/schema/volume/dir/file` */
@JsonProperty("destination")
private String destination;
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieAPI.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieAPI.java
index 4b8dd23c6..34392719a 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieAPI.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieAPI.java
@@ -177,6 +177,27 @@ public GenieGetMessageQueryResultResponse getMessageQueryResult(
return impl.getMessageQueryResult(request);
}
+ public GenieGetMessageQueryResultResponse getMessageQueryResultByAttachment(
+ String spaceId, String conversationId, String messageId, String attachmentId) {
+ return getMessageQueryResultByAttachment(
+ new GenieGetQueryResultByAttachmentRequest()
+ .setSpaceId(spaceId)
+ .setConversationId(conversationId)
+ .setMessageId(messageId)
+ .setAttachmentId(attachmentId));
+ }
+
+ /**
+ * Get conversation message SQL query result by attachment id.
+ *
+ * Get the result of SQL query by attachment id This is only available if a message has a query
+ * attachment and the message status is `EXECUTING_QUERY`.
+ */
+ public GenieGetMessageQueryResultResponse getMessageQueryResultByAttachment(
+ GenieGetQueryResultByAttachmentRequest request) {
+ return impl.getMessageQueryResultByAttachment(request);
+ }
+
public Wait startConversation(
String spaceId, String content) {
return startConversation(
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieGetQueryResultByAttachmentRequest.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieGetQueryResultByAttachmentRequest.java
new file mode 100755
index 000000000..d3ec6043d
--- /dev/null
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieGetQueryResultByAttachmentRequest.java
@@ -0,0 +1,86 @@
+// Code generated from OpenAPI specs by Databricks SDK Generator. DO NOT EDIT.
+
+package com.databricks.sdk.service.dashboards;
+
+import com.databricks.sdk.support.Generated;
+import com.databricks.sdk.support.ToStringer;
+import com.fasterxml.jackson.annotation.JsonIgnore;
+import java.util.Objects;
+
+/** Get conversation message SQL query result by attachment id */
+@Generated
+public class GenieGetQueryResultByAttachmentRequest {
+ /** Attachment ID */
+ @JsonIgnore private String attachmentId;
+
+ /** Conversation ID */
+ @JsonIgnore private String conversationId;
+
+ /** Message ID */
+ @JsonIgnore private String messageId;
+
+ /** Genie space ID */
+ @JsonIgnore private String spaceId;
+
+ public GenieGetQueryResultByAttachmentRequest setAttachmentId(String attachmentId) {
+ this.attachmentId = attachmentId;
+ return this;
+ }
+
+ public String getAttachmentId() {
+ return attachmentId;
+ }
+
+ public GenieGetQueryResultByAttachmentRequest setConversationId(String conversationId) {
+ this.conversationId = conversationId;
+ return this;
+ }
+
+ public String getConversationId() {
+ return conversationId;
+ }
+
+ public GenieGetQueryResultByAttachmentRequest setMessageId(String messageId) {
+ this.messageId = messageId;
+ return this;
+ }
+
+ public String getMessageId() {
+ return messageId;
+ }
+
+ public GenieGetQueryResultByAttachmentRequest setSpaceId(String spaceId) {
+ this.spaceId = spaceId;
+ return this;
+ }
+
+ public String getSpaceId() {
+ return spaceId;
+ }
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) return true;
+ if (o == null || getClass() != o.getClass()) return false;
+ GenieGetQueryResultByAttachmentRequest that = (GenieGetQueryResultByAttachmentRequest) o;
+ return Objects.equals(attachmentId, that.attachmentId)
+ && Objects.equals(conversationId, that.conversationId)
+ && Objects.equals(messageId, that.messageId)
+ && Objects.equals(spaceId, that.spaceId);
+ }
+
+ @Override
+ public int hashCode() {
+ return Objects.hash(attachmentId, conversationId, messageId, spaceId);
+ }
+
+ @Override
+ public String toString() {
+ return new ToStringer(GenieGetQueryResultByAttachmentRequest.class)
+ .add("attachmentId", attachmentId)
+ .add("conversationId", conversationId)
+ .add("messageId", messageId)
+ .add("spaceId", spaceId)
+ .toString();
+ }
+}
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieImpl.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieImpl.java
index ce93fcdb5..2c0dd670e 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieImpl.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieImpl.java
@@ -83,6 +83,26 @@ public GenieGetMessageQueryResultResponse getMessageQueryResult(
}
}
+ @Override
+ public GenieGetMessageQueryResultResponse getMessageQueryResultByAttachment(
+ GenieGetQueryResultByAttachmentRequest request) {
+ String path =
+ String.format(
+ "/api/2.0/genie/spaces/%s/conversations/%s/messages/%s/query-result/%s",
+ request.getSpaceId(),
+ request.getConversationId(),
+ request.getMessageId(),
+ request.getAttachmentId());
+ try {
+ Request req = new Request("GET", path);
+ ApiClient.setQuery(req, request);
+ req.withHeader("Accept", "application/json");
+ return apiClient.execute(req, GenieGetMessageQueryResultResponse.class);
+ } catch (IOException e) {
+ throw new DatabricksException("IO error: " + e.getMessage(), e);
+ }
+ }
+
@Override
public GenieStartConversationResponse startConversation(
GenieStartConversationMessageRequest request) {
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieService.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieService.java
index 5dad69dc0..5404c9231 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieService.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/GenieService.java
@@ -48,6 +48,15 @@ GenieGetMessageQueryResultResponse executeMessageQuery(
GenieGetMessageQueryResultResponse getMessageQueryResult(
GenieGetMessageQueryResultRequest genieGetMessageQueryResultRequest);
+ /**
+ * Get conversation message SQL query result by attachment id.
+ *
+ * Get the result of SQL query by attachment id This is only available if a message has a query
+ * attachment and the message status is `EXECUTING_QUERY`.
+ */
+ GenieGetMessageQueryResultResponse getMessageQueryResultByAttachment(
+ GenieGetQueryResultByAttachmentRequest genieGetQueryResultByAttachmentRequest);
+
/**
* Start conversation.
*
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/MessageErrorType.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/MessageErrorType.java
index 12c0af08b..5de4f1042 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/MessageErrorType.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/dashboards/MessageErrorType.java
@@ -39,6 +39,7 @@ public enum MessageErrorType {
REPLY_PROCESS_TIMEOUT_EXCEPTION,
RETRYABLE_PROCESSING_EXCEPTION,
SQL_EXECUTION_EXCEPTION,
+ STOP_PROCESS_DUE_TO_AUTO_REGENERATE,
TABLES_MISSING_EXCEPTION,
TOO_MANY_CERTIFIED_ANSWERS_EXCEPTION,
TOO_MANY_TABLES_EXCEPTION,
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/serving/ExternalModel.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/serving/ExternalModel.java
index f33517662..d8e6c7f7d 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/serving/ExternalModel.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/serving/ExternalModel.java
@@ -50,7 +50,7 @@ public class ExternalModel {
/**
* The name of the provider for the external model. Currently, the supported providers are
* 'ai21labs', 'anthropic', 'amazon-bedrock', 'cohere', 'databricks-model-serving',
- * 'google-cloud-vertex-ai', 'openai', and 'palm'.
+ * 'google-cloud-vertex-ai', 'openai', 'palm', and 'custom'.
*/
@JsonProperty("provider")
private ExternalModelProvider provider;
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/ProvidersAPI.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/ProvidersAPI.java
index 41e7ea41a..8f58e1da1 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/ProvidersAPI.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/ProvidersAPI.java
@@ -77,6 +77,10 @@ public ProviderInfo get(GetProviderRequest request) {
* response. There is no guarantee of a specific ordering of the elements in the array.
*/
public Iterable list(ListProvidersRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::list,
@@ -102,8 +106,21 @@ public Iterable listShares(String name) {
* * the caller is a metastore admin, or * the caller is the owner.
*/
public Iterable listShares(ListSharesRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
- request, impl::listShares, ListProviderSharesResponse::getShares, response -> null);
+ request,
+ impl::listShares,
+ ListProviderSharesResponse::getShares,
+ response -> {
+ String token = response.getNextPageToken();
+ if (token == null || token.isEmpty()) {
+ return null;
+ }
+ return request.setPageToken(token);
+ });
}
public ProviderInfo update(String name) {
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/RecipientsAPI.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/RecipientsAPI.java
index b6e71c102..cdc0717c9 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/RecipientsAPI.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/RecipientsAPI.java
@@ -91,6 +91,10 @@ public RecipientInfo get(GetRecipientRequest request) {
* specific ordering of the elements in the array.
*/
public Iterable list(ListRecipientsRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::list,
diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/SharesAPI.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/SharesAPI.java
index 74c6df95a..f0af7a7c9 100755
--- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/SharesAPI.java
+++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/sharing/SharesAPI.java
@@ -79,6 +79,10 @@ public ShareInfo get(GetShareRequest request) {
* array.
*/
public Iterable list(ListSharesRequest request) {
+
+ if (request.getMaxResults() == null) {
+ request.setMaxResults(0L);
+ }
return new Paginator<>(
request,
impl::list,
diff --git a/databricks-sdk-java/src/test/java/com/databricks/sdk/integration/ClustersIT.java b/databricks-sdk-java/src/test/java/com/databricks/sdk/integration/ClustersIT.java
index 8dd25d2af..1be13d16d 100644
--- a/databricks-sdk-java/src/test/java/com/databricks/sdk/integration/ClustersIT.java
+++ b/databricks-sdk-java/src/test/java/com/databricks/sdk/integration/ClustersIT.java
@@ -54,7 +54,7 @@ void clusterDoesNotExist(WorkspaceClient w) {
assertThrowsExactly(
ResourceDoesNotExist.class,
() -> {
- w.clusters().get("does-not-exist");
+ w.clusters().get("123-does-not-exist");
});
}
}
diff --git a/examples/docs/pom.xml b/examples/docs/pom.xml
index 3673a2a3e..10755eab0 100644
--- a/examples/docs/pom.xml
+++ b/examples/docs/pom.xml
@@ -24,7 +24,7 @@
com.databricks
databricks-sdk-java
- 0.40.0
+ 0.41.0
diff --git a/examples/spring-boot-oauth-u2m-demo/pom.xml b/examples/spring-boot-oauth-u2m-demo/pom.xml
index cd6bf89bb..c502a4ee9 100644
--- a/examples/spring-boot-oauth-u2m-demo/pom.xml
+++ b/examples/spring-boot-oauth-u2m-demo/pom.xml
@@ -37,7 +37,7 @@
com.databricks
databricks-sdk-java
- 0.40.0
+ 0.41.0
com.fasterxml.jackson.datatype
diff --git a/pom.xml b/pom.xml
index 1e92a6c4c..7d6dbb7e2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
4.0.0
com.databricks
databricks-sdk-parent
- 0.40.0
+ 0.41.0
pom
Databricks SDK for Java
The Databricks SDK for Java includes functionality to accelerate development with Java for
diff --git a/shaded/pom.xml b/shaded/pom.xml
index 68c3a39ae..dd5e18661 100644
--- a/shaded/pom.xml
+++ b/shaded/pom.xml
@@ -4,7 +4,7 @@
4.0.0
- 0.40.0
+ 0.41.0
com.databricks