Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-7778

a new UDF object is constructed every time there is a message

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Not A Problem
    • None
    • Not applicable
    • dsl-sql
    • None

    Description

      Hello Beamers, I want to ask a question about Beam SQL UDF. When I use the following statement to register UDF and execute sql,

      SqlTransform.query("select capitalize([field]) from [bounded] right join [unbounded] on [condition]").registerUdf("capitalize", new SqlUDF.CapitalizeStringFn()));

      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!

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            yangzhang Yang Zhang
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved:

              Slack

                Issue deployment