GitHub user srinipunuru opened a pull request: https://github.com/apache/samza/pull/885
Type system for Samza SQL and Support for types in UDFS This checkin adds 1. Type system for Samza SQL. Previously Samza SQL was using Calcite's relational type system. We need an intermediate type system that is specific to Samza SQL so that we could support Beam SQL in future. This intermediate type system also allows to provide typing to Samza SQL UDFs. 2. Java annotations for Samza SQL that allows us to discover the Samza SQL UDFs easily and also provide users to configure name of the UDF, whether it is disabled. 3. Initial support for adding types in Samza SQL UDFs. Right now we are not using these types for validations. Future checkin will add that capability. You can merge this pull request into a Git repository by running: $ git pull https://github.com/srinipunuru/samza sql-schema.2 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/samza/pull/885.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 #885 ---- commit a3af25702f38a06bc38f2fbf1886cf2d2e179762 Author: Srinivasulu Punuru <spunuru@...> Date: 2019-01-16T21:16:11Z Support for types in UDFS ---- ---