[
https://issues.apache.org/jira/browse/BEAM-7778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896518#comment-16896518
]
Ismaël Mejía commented on BEAM-7778:
------------------------------------
[~apilloud] or [~kedin] any comments on this one too, is this a Calcite or Beam
issue? Is the function reinstantiated just to ensure consistent internal state
for each call or just something that is not improved yet?
> a new UDF object is constructed every time there is a message
> -------------------------------------------------------------
>
> Key: BEAM-7778
> URL: https://issues.apache.org/jira/browse/BEAM-7778
> Project: Beam
> Issue Type: Bug
> Components: dsl-sql
> Reporter: Yang Zhang
> Priority: Major
>
> Hello Beamers, I want to ask a question about Beam SQL UDF. When I use the
> following statement to register UDF and execute sql,
> {code:java}
> SqlTransform.query("select capitalize([field]) from [bounded] right join
> [unbounded] on [condition]").registerUdf("capitalize", new
> SqlUDF.CapitalizeStringFn()));{code}
> from my observation, every time there is an incoming message, a new UDF
> object is constructed. Is there a way to make this UDF object to be just
> created once instead of unlimited times? Thank you very much!
>
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)