samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From srinipunuru <>
Subject [GitHub] samza pull request #386: Support for UDFs in where clauses
Date Tue, 12 Dec 2017 23:14:26 GMT
GitHub user srinipunuru opened a pull request:

    Support for UDFs in where clauses

    The existing version of the udf implementation doesn't seem to supported in the where
clauses because the Type of the object returned is "ANY" and when you do a 
    `select * from kafka.topic where regexMatch('.*foo', Name)` it fails in the query validation,
because calcite doesn't know the type of regexMatch. 
    To solve the problem, We made the scalarUdf generic with a strongly typed return type.

You can merge this pull request into a Git repository by running:

    $ git pull udf-where.1

Alternatively you can review and apply these changes as the patch at:

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

    This closes #386
commit 514ce3e386810f4dba0c31d393185f56d2f47aed
Author: Srinivasulu Punuru <>
Date:   2017-12-01T17:46:32Z

    Documentation for Samza SQL and tooling associated with it.

commit 9d724184a727a4dffc30d40eb53d8f7c625a25d9
Author: Srinivasulu Punuru <>
Date:   2017-12-12T23:11:09Z

    Support for Udfs in where clauses



View raw message