Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

| Name | Type | Description | Notes |
|------------ | ------------- | ------------- | -------------|
|**id** | **List<String>** | Table identifier path (namespace + table name) | [optional] |
|**newColumns** | [**List<AddColumnsEntry>**](AddColumnsEntry.md) | List of new columns to add to the table | |


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

| Name | Type | Description | Notes |
|------------ | ------------- | ------------- | -------------|
|**id** | **List<String>** | Table identifier path (namespace + table name) | [optional] |
|**alterations** | [**List<AlterColumnsEntry>**](AlterColumnsEntry.md) | List of column alterations to apply to the table | |


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

| Name | Type | Description | Notes |
|------------ | ------------- | ------------- | -------------|
|**id** | **List<String>** | Table identifier path (namespace + table name) | [optional] |
|**column** | **String** | Column name to backfill | |
|**where** | **String** | Optional WHERE clause filter | [optional] |
|**concurrency** | **Integer** | Optional concurrency override | [optional] |
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

| Name | Type | Description | Notes |
|------------ | ------------- | ------------- | -------------|
|**id** | **List<String>** | Table identifier path (namespace + table name) | [optional] |
|**srcVersion** | **Integer** | Optional source version to refresh from | [optional] |
|**maxRowsPerFragment** | **Integer** | Optional maximum rows per fragment | [optional] |
|**concurrency** | **Integer** | Optional concurrency override | [optional] |
Expand Down
20 changes: 20 additions & 0 deletions docs/src/rest.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -4557,6 +4557,11 @@ components:
required:
- new_columns
properties:
id:
type: array
items:
type: string
description: Table identifier path (namespace + table name)
new_columns:
type: array
items:
Expand Down Expand Up @@ -4629,6 +4634,11 @@ components:
required:
- alterations
properties:
id:
type: array
items:
type: string
description: Table identifier path (namespace + table name)
alterations:
type: array
items:
Expand Down Expand Up @@ -4710,6 +4720,11 @@ components:
required:
- column
properties:
id:
type: array
items:
type: string
description: Table identifier path (namespace + table name)
column:
type: string
description: Column name to backfill
Expand Down Expand Up @@ -4791,6 +4806,11 @@ components:
RefreshMaterializedViewRequest:
type: object
properties:
id:
type: array
items:
type: string
description: Table identifier path (namespace + table name)
src_version:
type:
- integer
Expand Down
32 changes: 32 additions & 0 deletions java/lance-namespace-apache-client/api/openapi.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -7027,7 +7027,15 @@ components:
- input_columns
data_type: "{}"
udf_version: udf_version
id:
- id
- id
properties:
id:
description: Table identifier path (namespace + table name)
items:
type: string
type: array
new_columns:
description: List of new columns to add to the table
items:
Expand Down Expand Up @@ -7137,7 +7145,15 @@ components:
- input_columns
- input_columns
udf_version: udf_version
id:
- id
- id
properties:
id:
description: Table identifier path (namespace + table name)
items:
type: string
type: array
alterations:
description: List of column alterations to apply to the table
items:
Expand Down Expand Up @@ -7237,8 +7253,16 @@ components:
task_size: 7
batch_checkpoint_flush_interval_seconds: 5.637376656633329
where: where
id:
- id
- id
intra_applier_concurrency: 6
properties:
id:
description: Table identifier path (namespace + table name)
items:
type: string
type: array
column:
description: Column name to backfill
type: string
Expand Down Expand Up @@ -7310,10 +7334,18 @@ components:
src_version: 0
cluster: cluster
manifest: manifest
id:
- id
- id
max_rows_per_fragment: 6
intra_applier_concurrency: 5
concurrency: 1
properties:
id:
description: Table identifier path (namespace + table name)
items:
type: string
type: array
src_version:
description: Optional source version to refresh from
nullable: true
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

| Name | Type | Description | Notes |
|------------ | ------------- | ------------- | -------------|
|**id** | **List<String>** | Table identifier path (namespace + table name) | [optional] |
|**newColumns** | [**List<AddColumnsEntry>**](AddColumnsEntry.md) | List of new columns to add to the table | |


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

| Name | Type | Description | Notes |
|------------ | ------------- | ------------- | -------------|
|**id** | **List<String>** | Table identifier path (namespace + table name) | [optional] |
|**alterations** | [**List<AlterColumnsEntry>**](AlterColumnsEntry.md) | List of column alterations to apply to the table | |


Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

| Name | Type | Description | Notes |
|------------ | ------------- | ------------- | -------------|
|**id** | **List<String>** | Table identifier path (namespace + table name) | [optional] |
|**column** | **String** | Column name to backfill | |
|**where** | **String** | Optional WHERE clause filter | [optional] |
|**concurrency** | **Integer** | Optional concurrency override | [optional] |
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@

| Name | Type | Description | Notes |
|------------ | ------------- | ------------- | -------------|
|**id** | **List<String>** | Table identifier path (namespace + table name) | [optional] |
|**srcVersion** | **Integer** | Optional source version to refresh from | [optional] |
|**maxRowsPerFragment** | **Integer** | Optional maximum rows per fragment | [optional] |
|**concurrency** | **Integer** | Optional concurrency override | [optional] |
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,22 +17,62 @@
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.annotation.JsonPropertyOrder;

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.util.ArrayList;
import java.util.List;
import java.util.Objects;
import java.util.StringJoiner;

/** AlterTableAddColumnsRequest */
@JsonPropertyOrder({AlterTableAddColumnsRequest.JSON_PROPERTY_NEW_COLUMNS})
@JsonPropertyOrder({
AlterTableAddColumnsRequest.JSON_PROPERTY_ID,
AlterTableAddColumnsRequest.JSON_PROPERTY_NEW_COLUMNS
})
@javax.annotation.Generated(
value = "org.openapitools.codegen.languages.JavaClientCodegen",
comments = "Generator version: 7.12.0")
public class AlterTableAddColumnsRequest {
public static final String JSON_PROPERTY_ID = "id";
@javax.annotation.Nullable private List<String> id = new ArrayList<>();

public static final String JSON_PROPERTY_NEW_COLUMNS = "new_columns";
@javax.annotation.Nonnull private List<AddColumnsEntry> newColumns = new ArrayList<>();

public AlterTableAddColumnsRequest() {}

public AlterTableAddColumnsRequest id(@javax.annotation.Nullable List<String> id) {

this.id = id;
return this;
}

public AlterTableAddColumnsRequest addIdItem(String idItem) {
if (this.id == null) {
this.id = new ArrayList<>();
}
this.id.add(idItem);
return this;
}

/**
* Table identifier path (namespace + table name)
*
* @return id
*/
@javax.annotation.Nullable
@JsonProperty(JSON_PROPERTY_ID)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public List<String> getId() {
return id;
}

@JsonProperty(JSON_PROPERTY_ID)
@JsonInclude(value = JsonInclude.Include.USE_DEFAULTS)
public void setId(@javax.annotation.Nullable List<String> id) {
this.id = id;
}

public AlterTableAddColumnsRequest newColumns(
@javax.annotation.Nonnull List<AddColumnsEntry> newColumns) {

Expand Down Expand Up @@ -75,18 +115,20 @@ public boolean equals(Object o) {
return false;
}
AlterTableAddColumnsRequest alterTableAddColumnsRequest = (AlterTableAddColumnsRequest) o;
return Objects.equals(this.newColumns, alterTableAddColumnsRequest.newColumns);
return Objects.equals(this.id, alterTableAddColumnsRequest.id)
&& Objects.equals(this.newColumns, alterTableAddColumnsRequest.newColumns);
}

@Override
public int hashCode() {
return Objects.hash(newColumns);
return Objects.hash(id, newColumns);
}

@Override
public String toString() {
StringBuilder sb = new StringBuilder();
sb.append("class AlterTableAddColumnsRequest {\n");
sb.append(" id: ").append(toIndentedString(id)).append("\n");
sb.append(" newColumns: ").append(toIndentedString(newColumns)).append("\n");
sb.append("}");
return sb.toString();
Expand Down Expand Up @@ -134,6 +176,27 @@ public String toUrlQueryString(String prefix) {

StringJoiner joiner = new StringJoiner("&");

// add `id` to the URL query string
if (getId() != null) {
for (int i = 0; i < getId().size(); i++) {
try {
joiner.add(
String.format(
"%sid%s%s=%s",
prefix,
suffix,
"".equals(suffix)
? ""
: String.format("%s%d%s", containerPrefix, i, containerSuffix),
URLEncoder.encode(String.valueOf(getId().get(i)), "UTF-8")
.replaceAll("\\+", "%20")));
} catch (UnsupportedEncodingException e) {
// Should never happen, UTF-8 is always supported
throw new RuntimeException(e);
}
}
}

// add `new_columns` to the URL query string
if (getNewColumns() != null) {
for (int i = 0; i < getNewColumns().size(); i++) {
Expand Down
Loading
Loading