Skip to content

[UUID 3/8] UUID result rendering (DataSchema, Arrow/JSON encoders) #18871

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
xiangfu0 merged 1 commit into from
Jul 26, 2026
Merged

[UUID 3/8] UUID result rendering (DataSchema, Arrow/JSON encoders) #18871

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
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
6 changes: 6 additions & 0 deletions ...t-common/src/main/java/org/apache/pinot/common/response/encoder/ArrowResponseEncoder.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -107,6 +107,7 @@ private VectorSchemaRoot createVectorSchemaRoot(ResultTable resultTable, DataSch
case STRING:
case JSON:
case BYTES:
case UUID:
case OBJECT:
field = new Field(colName, FieldType.nullable(new ArrowType.Utf8()), null);
vector = new VarCharVector(colName, ALLOCATOR);
Expand Down Expand Up @@ -181,6 +182,7 @@ private VectorSchemaRoot createVectorSchemaRoot(ResultTable resultTable, DataSch
case TIMESTAMP_ARRAY:
case STRING_ARRAY:
case BYTES_ARRAY:
case UUID_ARRAY:
// Define the inner field for a string element.
children = List.of(new Field("element", FieldType.nullable(new ArrowType.Utf8()), null));
// Define the field for the list column.
Expand Down Expand Up @@ -234,6 +236,7 @@ private VectorSchemaRoot createVectorSchemaRoot(ResultTable resultTable, DataSch
case STRING:
case JSON:
case BYTES:
case UUID:
case OBJECT:
byte[] bytes = ((String) value).getBytes(StandardCharsets.UTF_8);
((VarCharVector) vector).setSafe(rowIndex, bytes);
Expand Down Expand Up @@ -345,6 +348,7 @@ private VectorSchemaRoot createVectorSchemaRoot(ResultTable resultTable, DataSch
case TIMESTAMP_ARRAY:
case STRING_ARRAY:
case BYTES_ARRAY:
case UUID_ARRAY:
ListVector listVector = (ListVector) vector;
String[] stringArray = (String[]) value;
// Start a new list entry for the current row.
Expand Down Expand Up @@ -411,6 +415,7 @@ public ResultTable decodeResultTable(byte[] bytes, int rowSize, DataSchema schem
case STRING:
case JSON:
case BYTES:
case UUID:
case OBJECT:
row[col] = new String(((VarCharVector) vector).get(i), StandardCharsets.UTF_8);
break;
Expand Down Expand Up @@ -469,6 +474,7 @@ public ResultTable decodeResultTable(byte[] bytes, int rowSize, DataSchema schem
case TIMESTAMP_ARRAY:
case STRING_ARRAY:
case BYTES_ARRAY:
case UUID_ARRAY:
ListVector listVector = (ListVector) vector;
List<?> arrayValues = listVector.getObject(i);
String[] array = new String[arrayValues.size()];
Expand Down
2 changes: 2 additions & 0 deletions pinot-common/src/main/java/org/apache/pinot/common/response/encoder/JsonResponseEncoder.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -194,6 +194,7 @@ private static Object extractArray(DataSchema.ColumnDataType columnDataType, Jso
case TIMESTAMP_ARRAY:
case STRING_ARRAY:
case BYTES_ARRAY:
case UUID_ARRAY:
String[] stringArray = new String[jsonValue.size()];
for (int k = 0; k < jsonValue.size(); k++) {
stringArray[k] = jsonValue.get(k).textValue();
Expand Down Expand Up @@ -224,6 +225,7 @@ private static Object extractValue(DataSchema.ColumnDataType columnDataType, Jso
case STRING:
case JSON:
case BYTES:
case UUID:
case OBJECT:
return jsonValue.textValue();
case UNKNOWN:
Expand Down
Loading
Loading