GitHub user srinipunuru opened a pull request:
https://github.com/apache/samza/pull/386
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 https://github.com/srinipunuru/samza udf-where.1
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/386.patch
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 <[email protected]>
Date: 2017-12-01T17:46:32Z
Documentation for Samza SQL and tooling associated with it.
commit 9d724184a727a4dffc30d40eb53d8f7c625a25d9
Author: Srinivasulu Punuru <[email protected]>
Date: 2017-12-12T23:11:09Z
Support for Udfs in where clauses
----
---
