[
https://issues.apache.org/jira/browse/BEAM-3325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Beam JIRA Bot updated BEAM-3325:
--------------------------------
Priority: P3 (was: P2)
> optional parameter is not supported in BeamSQL
> ----------------------------------------------
>
> Key: BEAM-3325
> URL: https://issues.apache.org/jira/browse/BEAM-3325
> Project: Beam
> Issue Type: Bug
> Components: dsl-sql
> Reporter: Mingmin Xu
> Priority: P3
> Labels: stale-P2
>
> I'm wring a UDF with optional parameters, the method code is:
> {code}
> public static String eval(String kvString, String keyName
> , @Parameter(name = "pd", optional = true) String pairSeperator
> , @Parameter(name = "kvd", optional = true) String kvSeperator){
> //...
> }
> {code}
> And I see this error when assembling a Beam pipeline:
> {code}
> Execution Plan:
> BeamProjectRel(ITEM_ID=[CAST(KV_EXT($0, 'itemId', DEFAULT(),
> DEFAULT())):BIGINT], TRANSACTION_ID=[CAST(KV_EXT($0, 'transactionId',
> DEFAULT(), DEFAULT())):BIGINT], TRANSACTION_TIME=[KV_EXT($0, 'createdDT',
> DEFAULT(), DEFAULT())])
> BeamIOSourceRel(table=[[....]])
> Exception in thread "main" java.lang.RuntimeException:
> java.lang.UnsupportedOperationException: Operator: DEFAULT is not supported
> yet!
> at .........
> Caused by: java.lang.UnsupportedOperationException: Operator: DEFAULT is not
> supported yet!
> at
> org.apache.beam.sdk.extensions.sql.impl.interpreter.BeamSqlFnExecutor.buildExpression(BeamSqlFnExecutor.java:425)
> at
> org.apache.beam.sdk.extensions.sql.impl.interpreter.BeamSqlFnExecutor.buildExpression(BeamSqlFnExecutor.java:202)
> at
> org.apache.beam.sdk.extensions.sql.impl.interpreter.BeamSqlFnExecutor.buildExpression(BeamSqlFnExecutor.java:202)
> at
> org.apache.beam.sdk.extensions.sql.impl.interpreter.BeamSqlFnExecutor.<init>(BeamSqlFnExecutor.java:126)
> at
> org.apache.beam.sdk.extensions.sql.impl.rel.BeamProjectRel.buildBeamPipeline(BeamProjectRel.java:70)
> at
> org.apache.beam.sdk.extensions.sql.impl.planner.BeamQueryPlanner.compileBeamPipeline(BeamQueryPlanner.java:116)
> at
> org.apache.beam.sdk.extensions.sql.BeamSqlCli.compilePipeline(BeamSqlCli.java:112)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
