You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Kyle Weaver (Jira)" <ji...@apache.org> on 2021/05/07 17:33:00 UTC

[jira] [Commented] (BEAM-12108) Support STRUCT type in BeamJavaUdfCalcRule.

    [ https://issues.apache.org/jira/browse/BEAM-12108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17340956#comment-17340956 ] 

Kyle Weaver commented on BEAM-12108:
------------------------------------

This one will be difficult because we don't have any way of passing in the expected Schema of the Row return type or argument, and without the Schema we can't infer a SQL type signature from the Java method. But this only affects the SqlTransform path – CREATE FUNCTION shouldn't have a problem, because the user must specify the full type signature in the query.

> Support STRUCT type in BeamJavaUdfCalcRule.
> -------------------------------------------
>
>                 Key: BEAM-12108
>                 URL: https://issues.apache.org/jira/browse/BEAM-12108
>             Project: Beam
>          Issue Type: New Feature
>          Components: dsl-sql-zetasql
>            Reporter: Kyle Weaver
>            Priority: P2
>              Labels: zetasql-java-udf
>
> We want the STRUCT ZetaSQL type to correspond to org.apache.beam.sdk.values.Row in Java UDFs. But the type inference logic doesn't know how to create a Calcite struct type from a Row yet. https://github.com/apache/beam/blob/master/sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java#L288



--
This message was sent by Atlassian Jira
(v8.3.4#803005)