diff --git a/.codegen/_openapi_sha b/.codegen/_openapi_sha index 9be95c03f..2907d0774 100644 --- a/.codegen/_openapi_sha +++ b/.codegen/_openapi_sha @@ -1 +1 @@ -4e74b31990bde519c276a6648ff59f50e49ff861 \ No newline at end of file +b2277054b8d295ae3b8666d6d2d89c22ab08e250 \ No newline at end of file diff --git a/.gitattributes b/.gitattributes index 7bcd5ffe0..437bc77b0 100644 --- a/.gitattributes +++ b/.gitattributes @@ -2092,7 +2092,7 @@ databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FieldDefinition. databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FileInfo.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FinalizeLoggedModelRequest.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FinalizeLoggedModelResponse.java linguist-generated=true -databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FirstDistinctNFunction.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FirstDistinctFunction.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FirstFunction.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FirstNFunction.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FlatSchema.java linguist-generated=true @@ -2148,7 +2148,7 @@ databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/KafkaConfig.java databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/KafkaSource.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/KafkaStreamConfig.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/KafkaSubscriptionMode.java linguist-generated=true -databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LastDistinctNFunction.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LastDistinctFunction.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LastFunction.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LastNFunction.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LineageContext.java linguist-generated=true @@ -2188,6 +2188,7 @@ databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LoggedModelInfo. databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LoggedModelParameter.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LoggedModelStatus.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LoggedModelTag.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LongRollingWindow.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/MaterializedFeature.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/MaterializedFeaturePipelineScheduleState.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/MaterializedFeaturesAPI.java linguist-generated=true @@ -2215,6 +2216,7 @@ databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/OnlineStoreConfi databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/OnlineStoreState.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/Param.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/PermissionLevel.java linguist-generated=true +databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/ProtoSchemaSpec.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/PublishSpec.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/PublishSpecPublishMode.java linguist-generated=true databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/PublishTableRequest.java linguist-generated=true diff --git a/NEXT_CHANGELOG.md b/NEXT_CHANGELOG.md index 51e183aad..036132ef5 100644 --- a/NEXT_CHANGELOG.md +++ b/NEXT_CHANGELOG.md @@ -15,3 +15,8 @@ ### Internal Changes ### API Changes +* Add `firstDistinct` and `lastDistinct` fields for `com.databricks.sdk.service.ml.AggregationFunction`. +* Add `avroSchema` and `protoSchema` fields for `com.databricks.sdk.service.ml.SchemaConfig`. +* Add `freshnessTarget` field for `com.databricks.sdk.service.ml.StreamingMode`. +* Add `longRolling` field for `com.databricks.sdk.service.ml.TimeWindow`. +* [Breaking] Remove `firstDistinctN` and `lastDistinctN` fields for `com.databricks.sdk.service.ml.AggregationFunction`. \ No newline at end of file diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/jobs/RunNow.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/jobs/RunNow.java index 96b9a72fd..980c7ab30 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/jobs/RunNow.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/jobs/RunNow.java @@ -86,6 +86,11 @@ public class RunNow { /** * A list of task keys to run inside of the job. If this field is not provided, all tasks in the * job will be run. + * + *

Prefix a task key with `+` to also run its upstream tasks, or suffix it with `+` to also run + * its downstream tasks. For example, `+my_task` runs `my_task` and everything upstream of it, + * `my_task+` runs `my_task` and everything downstream of it, and `+my_task+` runs both. A task + * key with no `+` runs only that task. */ @JsonProperty("only") private Collection only; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/AggregationFunction.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/AggregationFunction.java index 1c26f6bdd..b141ca9fb 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/AggregationFunction.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/AggregationFunction.java @@ -31,8 +31,8 @@ public class AggregationFunction { private FirstFunction first; /** */ - @JsonProperty("first_distinct_n") - private FirstDistinctNFunction firstDistinctN; + @JsonProperty("first_distinct") + private FirstDistinctFunction firstDistinct; /** */ @JsonProperty("first_n") @@ -43,8 +43,8 @@ public class AggregationFunction { private LastFunction last; /** */ - @JsonProperty("last_distinct_n") - private LastDistinctNFunction lastDistinctN; + @JsonProperty("last_distinct") + private LastDistinctFunction lastDistinct; /** */ @JsonProperty("last_n") @@ -128,13 +128,13 @@ public FirstFunction getFirst() { return first; } - public AggregationFunction setFirstDistinctN(FirstDistinctNFunction firstDistinctN) { - this.firstDistinctN = firstDistinctN; + public AggregationFunction setFirstDistinct(FirstDistinctFunction firstDistinct) { + this.firstDistinct = firstDistinct; return this; } - public FirstDistinctNFunction getFirstDistinctN() { - return firstDistinctN; + public FirstDistinctFunction getFirstDistinct() { + return firstDistinct; } public AggregationFunction setFirstN(FirstNFunction firstN) { @@ -155,13 +155,13 @@ public LastFunction getLast() { return last; } - public AggregationFunction setLastDistinctN(LastDistinctNFunction lastDistinctN) { - this.lastDistinctN = lastDistinctN; + public AggregationFunction setLastDistinct(LastDistinctFunction lastDistinct) { + this.lastDistinct = lastDistinct; return this; } - public LastDistinctNFunction getLastDistinctN() { - return lastDistinctN; + public LastDistinctFunction getLastDistinct() { + return lastDistinct; } public AggregationFunction setLastN(LastNFunction lastN) { @@ -255,10 +255,10 @@ public boolean equals(Object o) { && Objects.equals(avg, that.avg) && Objects.equals(countFunction, that.countFunction) && Objects.equals(first, that.first) - && Objects.equals(firstDistinctN, that.firstDistinctN) + && Objects.equals(firstDistinct, that.firstDistinct) && Objects.equals(firstN, that.firstN) && Objects.equals(last, that.last) - && Objects.equals(lastDistinctN, that.lastDistinctN) + && Objects.equals(lastDistinct, that.lastDistinct) && Objects.equals(lastN, that.lastN) && Objects.equals(max, that.max) && Objects.equals(min, that.min) @@ -278,10 +278,10 @@ public int hashCode() { avg, countFunction, first, - firstDistinctN, + firstDistinct, firstN, last, - lastDistinctN, + lastDistinct, lastN, max, min, @@ -301,10 +301,10 @@ public String toString() { .add("avg", avg) .add("countFunction", countFunction) .add("first", first) - .add("firstDistinctN", firstDistinctN) + .add("firstDistinct", firstDistinct) .add("firstN", firstN) .add("last", last) - .add("lastDistinctN", lastDistinctN) + .add("lastDistinct", lastDistinct) .add("lastN", lastN) .add("max", max) .add("min", min) diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FirstDistinctNFunction.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FirstDistinctFunction.java similarity index 78% rename from databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FirstDistinctNFunction.java rename to databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FirstDistinctFunction.java index c2a7c81ea..552310260 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FirstDistinctNFunction.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/FirstDistinctFunction.java @@ -9,7 +9,7 @@ /** Returns the first N distinct values, ordered by the feature's timeseries column. */ @Generated -public class FirstDistinctNFunction { +public class FirstDistinctFunction { /** The input column from which the first N distinct values are returned. */ @JsonProperty("input") private String input; @@ -18,7 +18,7 @@ public class FirstDistinctNFunction { @JsonProperty("n") private Long n; - public FirstDistinctNFunction setInput(String input) { + public FirstDistinctFunction setInput(String input) { this.input = input; return this; } @@ -27,7 +27,7 @@ public String getInput() { return input; } - public FirstDistinctNFunction setN(Long n) { + public FirstDistinctFunction setN(Long n) { this.n = n; return this; } @@ -40,7 +40,7 @@ public Long getN() { public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; - FirstDistinctNFunction that = (FirstDistinctNFunction) o; + FirstDistinctFunction that = (FirstDistinctFunction) o; return Objects.equals(input, that.input) && Objects.equals(n, that.n); } @@ -51,6 +51,6 @@ public int hashCode() { @Override public String toString() { - return new ToStringer(FirstDistinctNFunction.class).add("input", input).add("n", n).toString(); + return new ToStringer(FirstDistinctFunction.class).add("input", input).add("n", n).toString(); } } diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LastDistinctNFunction.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LastDistinctFunction.java similarity index 79% rename from databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LastDistinctNFunction.java rename to databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LastDistinctFunction.java index 45242979a..76c6de35e 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LastDistinctNFunction.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LastDistinctFunction.java @@ -9,7 +9,7 @@ /** Returns the last N distinct values, ordered by the feature's timeseries column. */ @Generated -public class LastDistinctNFunction { +public class LastDistinctFunction { /** The input column from which the last N distinct values are returned. */ @JsonProperty("input") private String input; @@ -18,7 +18,7 @@ public class LastDistinctNFunction { @JsonProperty("n") private Long n; - public LastDistinctNFunction setInput(String input) { + public LastDistinctFunction setInput(String input) { this.input = input; return this; } @@ -27,7 +27,7 @@ public String getInput() { return input; } - public LastDistinctNFunction setN(Long n) { + public LastDistinctFunction setN(Long n) { this.n = n; return this; } @@ -40,7 +40,7 @@ public Long getN() { public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; - LastDistinctNFunction that = (LastDistinctNFunction) o; + LastDistinctFunction that = (LastDistinctFunction) o; return Objects.equals(input, that.input) && Objects.equals(n, that.n); } @@ -51,6 +51,6 @@ public int hashCode() { @Override public String toString() { - return new ToStringer(LastDistinctNFunction.class).add("input", input).add("n", n).toString(); + return new ToStringer(LastDistinctFunction.class).add("input", input).add("n", n).toString(); } } diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LongRollingWindow.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LongRollingWindow.java new file mode 100644 index 000000000..5f6a112ff --- /dev/null +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/LongRollingWindow.java @@ -0,0 +1,73 @@ +// 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 com.google.protobuf.Duration; +import java.util.Objects; + +/** + * A long (multi-day) rolling window served via the hybrid batch + streaming path. The batch + * pipeline maintains daily partial aggregates for the bulk of the window while the streaming + * pipeline maintains the most recent day(s), and serving merges them on read. Distinct from + * RollingWindow so the control plane can explicitly identify long rolling window features rather + * than inferring hybrid behavior from window_duration. + */ +@Generated +public class LongRollingWindow { + /** + * The delay applied to the end of the rolling window (must be non-negative). For example, + * delay=1d shifts the window end 1 day before the evaluation time. + */ + @JsonProperty("delay") + private Duration delay; + + /** + * The duration of the rolling window. Must be positive and span more than two days, so that both + * the batch (N-1 day) and stale-path (N-2 day) partial aggregates are well defined. The duration + * need not be a whole number of days (e.g. 3 days 15 minutes is allowed). + */ + @JsonProperty("window_duration") + private Duration windowDuration; + + public LongRollingWindow setDelay(Duration delay) { + this.delay = delay; + return this; + } + + public Duration getDelay() { + return delay; + } + + public LongRollingWindow setWindowDuration(Duration windowDuration) { + this.windowDuration = windowDuration; + return this; + } + + public Duration getWindowDuration() { + return windowDuration; + } + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + LongRollingWindow that = (LongRollingWindow) o; + return Objects.equals(delay, that.delay) && Objects.equals(windowDuration, that.windowDuration); + } + + @Override + public int hashCode() { + return Objects.hash(delay, windowDuration); + } + + @Override + public String toString() { + return new ToStringer(LongRollingWindow.class) + .add("delay", delay) + .add("windowDuration", windowDuration) + .toString(); + } +} diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/ProtoSchemaSpec.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/ProtoSchemaSpec.java new file mode 100644 index 000000000..9d579b034 --- /dev/null +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/ProtoSchemaSpec.java @@ -0,0 +1,72 @@ +// 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 Protocol Buffer schema paired with the name of the message within it that describes the Kafka + * payload. A .proto file may declare multiple messages; message_name disambiguates. + */ +@Generated +public class ProtoSchemaSpec { + /** + * The fully-qualified name of the message within schema_text that describes the Kafka payload + * (e.g. "Event" or "com.example.Event" if schema_text declares a package). Identifies which + * message is used to decode each Kafka record — a .proto file may declare multiple messages but + * only one represents the payload. Must not be empty. + */ + @JsonProperty("message_name") + private String messageName; + + /** + * The raw .proto file text (proto2 and proto3 syntax supported, see + * https://protobuf.dev/programming-guides/proto3/ and + * https://protobuf.dev/programming-guides/proto2/). + */ + @JsonProperty("schema_text") + private String schemaText; + + public ProtoSchemaSpec setMessageName(String messageName) { + this.messageName = messageName; + return this; + } + + public String getMessageName() { + return messageName; + } + + public ProtoSchemaSpec setSchemaText(String schemaText) { + this.schemaText = schemaText; + return this; + } + + public String getSchemaText() { + return schemaText; + } + + @Override + public boolean equals(Object o) { + if (this == o) return true; + if (o == null || getClass() != o.getClass()) return false; + ProtoSchemaSpec that = (ProtoSchemaSpec) o; + return Objects.equals(messageName, that.messageName) + && Objects.equals(schemaText, that.schemaText); + } + + @Override + public int hashCode() { + return Objects.hash(messageName, schemaText); + } + + @Override + public String toString() { + return new ToStringer(ProtoSchemaSpec.class) + .add("messageName", messageName) + .add("schemaText", schemaText) + .toString(); + } +} diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SchemaConfig.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SchemaConfig.java index a69cd5281..07a6858ae 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SchemaConfig.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/SchemaConfig.java @@ -9,10 +9,27 @@ @Generated public class SchemaConfig { + /** Avro schema in JSON format (https://avro.apache.org/docs/current/specification/). */ + @JsonProperty("avro_schema") + private String avroSchema; + /** Schema of the JSON object in standard IETF JSON schema format (https://json-schema.org/). */ @JsonProperty("json_schema") private String jsonSchema; + /** Protocol Buffer schema with its payload message name. */ + @JsonProperty("proto_schema") + private ProtoSchemaSpec protoSchema; + + public SchemaConfig setAvroSchema(String avroSchema) { + this.avroSchema = avroSchema; + return this; + } + + public String getAvroSchema() { + return avroSchema; + } + public SchemaConfig setJsonSchema(String jsonSchema) { this.jsonSchema = jsonSchema; return this; @@ -22,21 +39,36 @@ public String getJsonSchema() { return jsonSchema; } + public SchemaConfig setProtoSchema(ProtoSchemaSpec protoSchema) { + this.protoSchema = protoSchema; + return this; + } + + public ProtoSchemaSpec getProtoSchema() { + return protoSchema; + } + @Override public boolean equals(Object o) { if (this == o) return true; if (o == null || getClass() != o.getClass()) return false; SchemaConfig that = (SchemaConfig) o; - return Objects.equals(jsonSchema, that.jsonSchema); + return Objects.equals(avroSchema, that.avroSchema) + && Objects.equals(jsonSchema, that.jsonSchema) + && Objects.equals(protoSchema, that.protoSchema); } @Override public int hashCode() { - return Objects.hash(jsonSchema); + return Objects.hash(avroSchema, jsonSchema, protoSchema); } @Override public String toString() { - return new ToStringer(SchemaConfig.class).add("jsonSchema", jsonSchema).toString(); + return new ToStringer(SchemaConfig.class) + .add("avroSchema", avroSchema) + .add("jsonSchema", jsonSchema) + .add("protoSchema", protoSchema) + .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 index 058faf05c..67af1a4ab 100644 --- 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 @@ -10,10 +10,26 @@ /** The streaming mode configuration for a streaming materialization pipeline. */ @Generated public class StreamingMode { + /** + * The desired data freshness for feature materialization, expressed as a duration string (e.g. "1 + * minute"). + */ + @JsonProperty("freshness_target") + private String freshnessTarget; + /** The type of streaming mode used by the materialization pipeline. */ @JsonProperty("mode") private StreamingModeStreamingModeType mode; + public StreamingMode setFreshnessTarget(String freshnessTarget) { + this.freshnessTarget = freshnessTarget; + return this; + } + + public String getFreshnessTarget() { + return freshnessTarget; + } + public StreamingMode setMode(StreamingModeStreamingModeType mode) { this.mode = mode; return this; @@ -28,16 +44,19 @@ 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); + return Objects.equals(freshnessTarget, that.freshnessTarget) && Objects.equals(mode, that.mode); } @Override public int hashCode() { - return Objects.hash(mode); + return Objects.hash(freshnessTarget, mode); } @Override public String toString() { - return new ToStringer(StreamingMode.class).add("mode", mode).toString(); + return new ToStringer(StreamingMode.class) + .add("freshnessTarget", freshnessTarget) + .add("mode", mode) + .toString(); } } diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TimeWindow.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TimeWindow.java index aa837f280..b427d59e4 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TimeWindow.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/ml/TimeWindow.java @@ -13,6 +13,10 @@ public class TimeWindow { @JsonProperty("continuous") private ContinuousWindow continuous; + /** A long (multi-day) rolling window served via the hybrid batch + streaming path. */ + @JsonProperty("long_rolling") + private LongRollingWindow longRolling; + /** */ @JsonProperty("rolling") private RollingWindow rolling; @@ -34,6 +38,15 @@ public ContinuousWindow getContinuous() { return continuous; } + public TimeWindow setLongRolling(LongRollingWindow longRolling) { + this.longRolling = longRolling; + return this; + } + + public LongRollingWindow getLongRolling() { + return longRolling; + } + public TimeWindow setRolling(RollingWindow rolling) { this.rolling = rolling; return this; @@ -67,6 +80,7 @@ public boolean equals(Object o) { if (o == null || getClass() != o.getClass()) return false; TimeWindow that = (TimeWindow) o; return Objects.equals(continuous, that.continuous) + && Objects.equals(longRolling, that.longRolling) && Objects.equals(rolling, that.rolling) && Objects.equals(sliding, that.sliding) && Objects.equals(tumbling, that.tumbling); @@ -74,13 +88,14 @@ public boolean equals(Object o) { @Override public int hashCode() { - return Objects.hash(continuous, rolling, sliding, tumbling); + return Objects.hash(continuous, longRolling, rolling, sliding, tumbling); } @Override public String toString() { return new ToStringer(TimeWindow.class) .add("continuous", continuous) + .add("longRolling", longRolling) .add("rolling", rolling) .add("sliding", sliding) .add("tumbling", tumbling) diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicy.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicy.java index ae22e4730..2c162aa31 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicy.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicy.java @@ -7,10 +7,7 @@ import com.fasterxml.jackson.annotation.JsonProperty; import java.util.Objects; -/** - * This proto is under development. The network policies applying for ingress traffic. Any changes - * here should also be synced to estore/namespaces/lakehousenetworkmanager/latest.proto. - */ +/** The network policies applying for ingress traffic. */ @Generated public class CustomerFacingIngressNetworkPolicy { /** */ @@ -18,8 +15,8 @@ public class CustomerFacingIngressNetworkPolicy { private CustomerFacingIngressNetworkPolicyCrossWorkspaceAccess crossWorkspaceAccess; /** - * The network policy restrictions for private access to the workspace. Configures how registered - * private endpoints are allowed or denied access. + * The network policy restrictions for private access. Configures how requests arriving over + * private connectivity are governed. */ @JsonProperty("private_access") private CustomerFacingIngressNetworkPolicyPrivateAccess privateAccess; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyAccountApiDestination.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyAccountApiDestination.java index 9cc26ae21..e013ff976 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyAccountApiDestination.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyAccountApiDestination.java @@ -15,7 +15,7 @@ public class CustomerFacingIngressNetworkPolicyAccountApiDestination { @JsonProperty("scope_qualifier") private CustomerFacingIngressNetworkPolicyApiScopeQualifier scopeQualifier; - /** */ + /** The API scopes to match. Use "all-apis" to match any account-level API. */ @JsonProperty("scopes") private Collection scopes; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyAccountUiDestination.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyAccountUiDestination.java index f52cffa86..82cde5034 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyAccountUiDestination.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyAccountUiDestination.java @@ -7,6 +7,7 @@ import com.fasterxml.jackson.annotation.JsonProperty; import java.util.Objects; +/** The account console UI destination. */ @Generated public class CustomerFacingIngressNetworkPolicyAccountUiDestination { /** Must be set to true. */ diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyEndpoints.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyEndpoints.java index 9cd6c46ac..cac5594bd 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyEndpoints.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyEndpoints.java @@ -8,9 +8,10 @@ import java.util.Collection; import java.util.Objects; +/** A set of registered endpoints, identified by their endpoint IDs. */ @Generated public class CustomerFacingIngressNetworkPolicyEndpoints { - /** */ + /** The IDs of the registered endpoints. Must contain at least one endpoint ID. */ @JsonProperty("endpoint_ids") private Collection endpointIds; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateAccess.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateAccess.java index e375938aa..6ca0453b1 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateAccess.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateAccess.java @@ -8,17 +8,28 @@ import java.util.Collection; import java.util.Objects; +/** + * Configures how requests arriving over private connectivity, such as registered endpoints, are + * allowed or denied access. + */ @Generated public class CustomerFacingIngressNetworkPolicyPrivateAccess { - /** */ + /** + * Allow rules are evaluated after deny rules. A request matching any allow rule is allowed; a + * request matching no rule is denied by default. Only applies when restriction_mode is + * RESTRICTED_ACCESS. + */ @JsonProperty("allow_rules") private Collection allowRules; - /** */ + /** + * Deny rules are evaluated first. A request matching any deny rule is denied, regardless of allow + * rules. Only applies when restriction_mode is RESTRICTED_ACCESS. + */ @JsonProperty("deny_rules") private Collection denyRules; - /** */ + /** The restriction mode for private access. */ @JsonProperty("restriction_mode") private CustomerFacingIngressNetworkPolicyPrivateAccessRestrictionMode restrictionMode; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateAccessRestrictionMode.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateAccessRestrictionMode.java index 138933fbc..8cf560bb9 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateAccessRestrictionMode.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateAccessRestrictionMode.java @@ -4,6 +4,12 @@ import com.databricks.sdk.support.Generated; +/** + * The restriction mode for private access. In ALLOW_ALL_REGISTERED_ENDPOINTS mode, requests + * arriving through any endpoint registered to the account are allowed, and deny rules and allow + * rules cannot be set. In RESTRICTED_ACCESS mode, access is restricted based on deny rules and + * allow rules; requests that do not match any allow rule are denied. + */ @Generated public enum CustomerFacingIngressNetworkPolicyPrivateAccessRestrictionMode { ALLOW_ALL_REGISTERED_ENDPOINTS, diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateIngressRule.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateIngressRule.java index 9a5671dcc..4123e0f61 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateIngressRule.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateIngressRule.java @@ -7,13 +7,25 @@ import com.fasterxml.jackson.annotation.JsonProperty; import java.util.Objects; +/** + * An ingress rule is enforced when a request satisfies all specified attributes — including request + * origin, destination, and authentication. + */ @Generated public class CustomerFacingIngressNetworkPolicyPrivateIngressRule { - /** */ + /** + * The authenticated identity the request must match. When unset, the rule matches all users and + * service principals. On the account-level network policy, scoping to specific identities is not + * currently supported, so this field must be unset (the rule matches all users and service + * principals). + */ @JsonProperty("authentication") private CustomerFacingIngressNetworkPolicyAuthentication authentication; - /** */ + /** + * The destination the request must match — the resource being accessed, for example the workspace + * UI, workspace APIs, or account-level APIs. See RequestDestination. + */ @JsonProperty("destination") private CustomerFacingIngressNetworkPolicyRequestDestination destination; @@ -21,7 +33,11 @@ public class CustomerFacingIngressNetworkPolicyPrivateIngressRule { @JsonProperty("label") private String label; - /** */ + /** + * The origin the request must match — the private connectivity the request arrives through, for + * example a specific set of registered endpoints or any endpoint registered to the account. See + * PrivateRequestOrigin. + */ @JsonProperty("origin") private CustomerFacingIngressNetworkPolicyPrivateRequestOrigin origin; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateRequestOrigin.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateRequestOrigin.java index 9af4ecce6..ed91ddac3 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateRequestOrigin.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyPrivateRequestOrigin.java @@ -7,21 +7,36 @@ import com.fasterxml.jackson.annotation.JsonProperty; import java.util.Objects; +/** + * The origin of a private access request, identified by the endpoint through which the request + * arrives. + */ @Generated public class CustomerFacingIngressNetworkPolicyPrivateRequestOrigin { - /** */ + /** + * Matches requests arriving over any private connectivity, including registered endpoints and the + * workspace's Azure Private Link (ui-api) endpoints. Can only be used in deny rules of + * workspace-level network policies. Must be set to true when specified. + */ @JsonProperty("all_private_access") private Boolean allPrivateAccess; - /** */ + /** + * Matches requests arriving through any endpoint registered to the account. Must be set to true + * when specified. + */ @JsonProperty("all_registered_endpoints") private Boolean allRegisteredEndpoints; - /** */ + /** + * Matches requests arriving through the workspace's Azure Private Link (ui-api) endpoints. Can + * only be used in deny rules of workspace-level network policies. Must be set to true when + * specified. + */ @JsonProperty("azure_workspace_private_link") private Boolean azureWorkspacePrivateLink; - /** */ + /** Matches requests arriving through any of the specified registered endpoints. */ @JsonProperty("endpoints") private CustomerFacingIngressNetworkPolicyEndpoints endpoints; diff --git a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyRequestDestination.java b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyRequestDestination.java index 143f6e5c5..9657f0896 100644 --- a/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyRequestDestination.java +++ b/databricks-sdk-java/src/main/java/com/databricks/sdk/service/settings/CustomerFacingIngressNetworkPolicyRequestDestination.java @@ -9,18 +9,20 @@ @Generated public class CustomerFacingIngressNetworkPolicyRequestDestination { - /** */ + /** + * Matches requests to account-level APIs. Can only be used in the account-level network policy. + */ @JsonProperty("account_api") private CustomerFacingIngressNetworkPolicyAccountApiDestination accountApi; - /** - * Account DatabricksOne destination is not supported. DO NOT change the stage of this destination - * past PRIVATE_PREVIEW. - */ + /** Account DatabricksOne destination is not supported. */ @JsonProperty("account_databricks_one") private CustomerFacingIngressNetworkPolicyAccountDatabricksOneDestination accountDatabricksOne; - /** */ + /** + * Matches requests to the account console UI. Can only be used in the account-level network + * policy. + */ @JsonProperty("account_ui") private CustomerFacingIngressNetworkPolicyAccountUiDestination accountUi;