You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by sh...@apache.org on 2019/10/17 18:37:36 UTC

[samza] branch master updated (493b275 -> e2928e1)

This is an automated email from the ASF dual-hosted git repository.

shanthoosh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.


    from 493b275  Revert "SAMZA-2324: Adding KV store metrics for rocksdb (#1158)" (#1194)
     add e2928e1  SAMZA-2354: Improve UDF discovery in samza-sql. (#1192)

No new revisions were added by this update.

Summary of changes:
 build.gradle                                       |  1 +
 .../samza/sql/client/impl/SamzaExecutor.java       |  6 --
 .../apache/samza/sql/interfaces/UdfMetadata.java   | 17 +++-
 .../sql/runner/SamzaSqlApplicationConfig.java      |  5 +-
 .../samza/sql/udf/ReflectionBasedUdfResolver.java  | 96 ++++++++++++++++++++++
 .../sql/runner/TestSamzaSqlApplicationConfig.java  |  4 -
 .../udf/impl/TestReflectionBasedUdfResolver.java   | 60 ++++++++++++++
 .../samza/sql/udf/impl/TestSamzaSqlUdf.java}       | 17 ++--
 .../apache/samza/sql/util/SamzaSqlTestConfig.java  |  8 --
 .../org/apache/samza/tools/SamzaSqlConsole.java    |  6 --
 10 files changed, 184 insertions(+), 36 deletions(-)
 create mode 100644 samza-sql/src/main/java/org/apache/samza/sql/udf/ReflectionBasedUdfResolver.java
 create mode 100644 samza-sql/src/test/java/org/apache/samza/sql/udf/impl/TestReflectionBasedUdfResolver.java
 copy samza-sql/src/{main/java/org/apache/samza/sql/fn/FlattenUdf.java => test/java/org/apache/samza/sql/udf/impl/TestSamzaSqlUdf.java} (76%)