[
https://issues.apache.org/jira/browse/BEAM-11533?focusedWorklogId=529621&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-529621
]
ASF GitHub Bot logged work on BEAM-11533:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 30/Dec/20 20:44
Start Date: 30/Dec/20 20:44
Worklog Time Spent: 10m
Work Description: robinyqiu commented on a change in pull request #13588:
URL: https://github.com/apache/beam/pull/13588#discussion_r550321908
##########
File path:
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/SchemaUtils.java
##########
@@ -128,18 +128,15 @@ private static ColumnSchema fromBeamField(Schema.Field
field) {
}
ColumnSchema column =
fromBeamField(Field.of(field.getName(),
fieldType.getCollectionElementType()));
- if (!column.getMode().isEmpty()) {
Review comment:
Done.
I think this check is redundant for now because the only place that sets
mode is the else branch below that the array element check will surely enter,
because we already checked array element is not ARRAY type. And we have also
checked the array element is not nullable above so it is always `REQUIRED`. But
I agree leaving this check here can prevent code change that breaks this in the
future.
##########
File path:
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/DataCatalogTableProvider.java
##########
@@ -178,6 +214,23 @@ private Table toCalciteTable(String tableName, Entry
entry) {
return tableBuilder.get().schema(schema).name(tableName).build();
}
+ public boolean setSchemaIfNotPresent(String resource, Schema schema) {
Review comment:
Done.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 529621)
Time Spent: 40m (was: 0.5h)
> PubSub support types: TIMESTAMP, DATE, TIME, DATETIME
> -----------------------------------------------------
>
> Key: BEAM-11533
> URL: https://issues.apache.org/jira/browse/BEAM-11533
> Project: Beam
> Issue Type: Improvement
> Components: dsl-sql-zetasql, io-java-gcp
> Reporter: Robin Qiu
> Assignee: Robin Qiu
> Priority: P2
> Time Spent: 40m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
