You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2020/09/04 11:14:56 UTC
[flink] branch master updated (41c3a19 -> bffc61a)
This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 41c3a19 [FLINK-19121][hive] Avoid accessing HDFS frequently in HiveBulkWriterFactory
add bffc61a [FLINK-15974][python] Support to use the Python UDF directly in the Python Table API (#13325)
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/table/expressions.py | 44 +++-
.../pyflink/table/tests/test_pandas_udf.py | 189 ++++++---------
flink-python/pyflink/table/tests/test_udf.py | 254 +++++++++++++++++----
flink-python/pyflink/table/tests/test_udtf.py | 13 +-
flink-python/pyflink/table/udf.py | 5 +
.../table/planner/calcite/FlinkTypeFactory.scala | 12 +-
6 files changed, 324 insertions(+), 193 deletions(-)