Add TableProvisionJob CRD and JobTemplate support for CREATE TABLE #196
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,26 @@ | ||
| apiVersion: hoptimator.linkedin.com/v1alpha1 | ||
| kind: Database | ||
| metadata: | ||
| name: iceberg | ||
| spec: | ||
| catalog: ICEBERG | ||
| url: jdbc:demodb://names=ads | ||
| dialect: Calcite | ||
|
|
||
| --- | ||
|
|
||
| apiVersion: hoptimator.linkedin.com/v1alpha1 | ||
| kind: JobTemplate | ||
| metadata: | ||
| name: table-provisioning-job-template | ||
| spec: | ||
| databases: | ||
| - iceberg | ||
| yaml: | | ||
| apiVersion: hoptimator.linkedin.com/v1alpha1 | ||
| kind: TableProvisionJob | ||
| metadata: | ||
| name: {{name}}-provision-job | ||
| spec: | ||
| table: {{table}} | ||
| database: {{database}} |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,219 @@ | ||
| /* | ||
| * Kubernetes | ||
| * No description provided (generated by Openapi Generator https://github.com/openapitools/openapi-generator) | ||
| * | ||
| * The version of the OpenAPI document: v1.21.1 | ||
| * | ||
| * | ||
| * NOTE: This class is auto generated by OpenAPI Generator (https://openapi-generator.tech). | ||
| * https://openapi-generator.tech | ||
| * Do not edit the class manually. | ||
| */ | ||
|
|
||
|
|
||
| package com.linkedin.hoptimator.k8s.models; | ||
|
|
||
| import java.util.Objects; | ||
| import java.util.Arrays; | ||
| import com.google.gson.TypeAdapter; | ||
| import com.google.gson.annotations.JsonAdapter; | ||
| import com.google.gson.annotations.SerializedName; | ||
| import com.google.gson.stream.JsonReader; | ||
| import com.google.gson.stream.JsonWriter; | ||
| import com.linkedin.hoptimator.k8s.models.V1alpha1TableProvisionJobSpec; | ||
| import com.linkedin.hoptimator.k8s.models.V1alpha1TableProvisionJobStatus; | ||
| import io.kubernetes.client.openapi.models.V1ObjectMeta; | ||
| import io.swagger.annotations.ApiModel; | ||
| import io.swagger.annotations.ApiModelProperty; | ||
| import java.io.IOException; | ||
|
|
||
| /** | ||
| * Job to provision backing infrastructure for a table. | ||
| */ | ||
| @ApiModel(description = "Job to provision backing infrastructure for a table.") | ||
| @javax.annotation.Generated(value = "org.openapitools.codegen.languages.JavaClientCodegen", date = "2026-03-13T23:58:00.641Z[Etc/UTC]") | ||
| public class V1alpha1TableProvisionJob implements io.kubernetes.client.common.KubernetesObject { | ||
| public static final String SERIALIZED_NAME_API_VERSION = "apiVersion"; | ||
| @SerializedName(SERIALIZED_NAME_API_VERSION) | ||
| private String apiVersion; | ||
|
|
||
| public static final String SERIALIZED_NAME_KIND = "kind"; | ||
| @SerializedName(SERIALIZED_NAME_KIND) | ||
| private String kind; | ||
|
|
||
| public static final String SERIALIZED_NAME_METADATA = "metadata"; | ||
| @SerializedName(SERIALIZED_NAME_METADATA) | ||
| private V1ObjectMeta metadata = null; | ||
|
|
||
| public static final String SERIALIZED_NAME_SPEC = "spec"; | ||
| @SerializedName(SERIALIZED_NAME_SPEC) | ||
| private V1alpha1TableProvisionJobSpec spec; | ||
|
|
||
| public static final String SERIALIZED_NAME_STATUS = "status"; | ||
| @SerializedName(SERIALIZED_NAME_STATUS) | ||
| private V1alpha1TableProvisionJobStatus status; | ||
|
|
||
|
|
||
| public V1alpha1TableProvisionJob apiVersion(String apiVersion) { | ||
|
|
||
| this.apiVersion = apiVersion; | ||
| return this; | ||
| } | ||
|
|
||
| /** | ||
| * APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources | ||
| * @return apiVersion | ||
| **/ | ||
| @javax.annotation.Nullable | ||
| @ApiModelProperty(value = "APIVersion defines the versioned schema of this representation of an object. Servers should convert recognized schemas to the latest internal value, and may reject unrecognized values. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#resources") | ||
|
|
||
| public String getApiVersion() { | ||
| return apiVersion; | ||
| } | ||
|
|
||
|
|
||
| public void setApiVersion(String apiVersion) { | ||
| this.apiVersion = apiVersion; | ||
| } | ||
|
|
||
|
|
||
| public V1alpha1TableProvisionJob kind(String kind) { | ||
|
|
||
| this.kind = kind; | ||
| return this; | ||
| } | ||
|
|
||
| /** | ||
| * Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds | ||
| * @return kind | ||
| **/ | ||
| @javax.annotation.Nullable | ||
| @ApiModelProperty(value = "Kind is a string value representing the REST resource this object represents. Servers may infer this from the endpoint the client submits requests to. Cannot be updated. In CamelCase. More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#types-kinds") | ||
|
|
||
| public String getKind() { | ||
| return kind; | ||
| } | ||
|
|
||
|
|
||
| public void setKind(String kind) { | ||
| this.kind = kind; | ||
| } | ||
|
|
||
|
|
||
| public V1alpha1TableProvisionJob metadata(V1ObjectMeta metadata) { | ||
|
|
||
| this.metadata = metadata; | ||
| return this; | ||
| } | ||
|
|
||
| /** | ||
| * Get metadata | ||
| * @return metadata | ||
| **/ | ||
| @javax.annotation.Nullable | ||
| @ApiModelProperty(value = "") | ||
|
|
||
| public V1ObjectMeta getMetadata() { | ||
| return metadata; | ||
| } | ||
|
|
||
|
|
||
| public void setMetadata(V1ObjectMeta metadata) { | ||
| this.metadata = metadata; | ||
| } | ||
|
|
||
|
|
||
| public V1alpha1TableProvisionJob spec(V1alpha1TableProvisionJobSpec spec) { | ||
|
|
||
| this.spec = spec; | ||
| return this; | ||
| } | ||
|
|
||
| /** | ||
| * Get spec | ||
| * @return spec | ||
| **/ | ||
| @javax.annotation.Nullable | ||
| @ApiModelProperty(value = "") | ||
|
|
||
| public V1alpha1TableProvisionJobSpec getSpec() { | ||
| return spec; | ||
| } | ||
|
|
||
|
|
||
| public void setSpec(V1alpha1TableProvisionJobSpec spec) { | ||
| this.spec = spec; | ||
| } | ||
|
|
||
|
|
||
| public V1alpha1TableProvisionJob status(V1alpha1TableProvisionJobStatus status) { | ||
|
|
||
| this.status = status; | ||
| return this; | ||
| } | ||
|
|
||
| /** | ||
| * Get status | ||
| * @return status | ||
| **/ | ||
| @javax.annotation.Nullable | ||
| @ApiModelProperty(value = "") | ||
|
|
||
| public V1alpha1TableProvisionJobStatus getStatus() { | ||
| return status; | ||
| } | ||
|
|
||
|
|
||
| public void setStatus(V1alpha1TableProvisionJobStatus status) { | ||
| this.status = status; | ||
| } | ||
|
|
||
|
|
||
| @Override | ||
| public boolean equals(Object o) { | ||
| if (this == o) { | ||
| return true; | ||
| } | ||
| if (o == null || getClass() != o.getClass()) { | ||
| return false; | ||
| } | ||
| V1alpha1TableProvisionJob v1alpha1TableProvisionJob = (V1alpha1TableProvisionJob) o; | ||
| return Objects.equals(this.apiVersion, v1alpha1TableProvisionJob.apiVersion) && | ||
| Objects.equals(this.kind, v1alpha1TableProvisionJob.kind) && | ||
| Objects.equals(this.metadata, v1alpha1TableProvisionJob.metadata) && | ||
| Objects.equals(this.spec, v1alpha1TableProvisionJob.spec) && | ||
| Objects.equals(this.status, v1alpha1TableProvisionJob.status); | ||
| } | ||
|
|
||
| @Override | ||
| public int hashCode() { | ||
| return Objects.hash(apiVersion, kind, metadata, spec, status); | ||
| } | ||
|
|
||
|
|
||
| @Override | ||
| public String toString() { | ||
| StringBuilder sb = new StringBuilder(); | ||
| sb.append("class V1alpha1TableProvisionJob {\n"); | ||
| sb.append(" apiVersion: ").append(toIndentedString(apiVersion)).append("\n"); | ||
| sb.append(" kind: ").append(toIndentedString(kind)).append("\n"); | ||
| sb.append(" metadata: ").append(toIndentedString(metadata)).append("\n"); | ||
| sb.append(" spec: ").append(toIndentedString(spec)).append("\n"); | ||
| sb.append(" status: ").append(toIndentedString(status)).append("\n"); | ||
| sb.append("}"); | ||
| return sb.toString(); | ||
| } | ||
|
|
||
| /** | ||
| * Convert the given object to string with each line indented by 4 spaces | ||
| * (except the first line). | ||
| */ | ||
| private String toIndentedString(Object o) { | ||
| if (o == null) { | ||
| return "null"; | ||
| } | ||
| return o.toString().replace("\n", "\n "); | ||
| } | ||
|
|
||
| } | ||
|
|
Oops, something went wrong.
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do we actually use this file? I think just the top level
generate-models.shis used. We can likely delete this file.