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

Posted to commits@flink.apache.org by he...@apache.org on 2019/10/12 12:06:05 UTC

[flink] branch master updated (cee9bf0 -> 345bfef)

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

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


    from cee9bf0  [FLINK-14004][runtime] Define SourceReaderOperator to verify the integration with StreamOneInputProcessor
     add 345bfef  [FLINK-14212][python] Support no-argument Python UDFs.

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/table/tests/test_udf.py       |  16 +++
 .../table/planner/codegen/ExpressionReducer.scala  | 124 ++++++++++++---------
 .../functions/utils/ScalarSqlFunction.scala        |   2 +-
 .../table/planner/plan/utils}/PythonUtil.scala     |  10 +-
 .../rules/logical/ExpressionReductionRulesTest.xml |  17 +++
 .../logical/ExpressionReductionRulesTest.scala     |  16 +++
 .../flink/table/codegen/ExpressionReducer.scala    |  69 +++++++-----
 .../apache/flink/table/plan/util/PythonUtil.scala  |   2 +-
 .../table/plan/ExpressionReductionRulesTest.scala  |  29 ++++-
 9 files changed, 197 insertions(+), 88 deletions(-)
 copy flink-table/{flink-table-planner/src/main/scala/org/apache/flink/table/plan/util => flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils}/PythonUtil.scala (89%)