[flink] branch master updated (c2df238 -> 722a6d7)

[hx...@apache.org]

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

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


    from c2df238  [FLINK-22963][doc] correct the description of taskmanager.memory.task.heap.size.
     add 722a6d7  [FLINK-22712][python] Support accessing Row fields by attribute name in PyFlink Row-based Operation

No new revisions were added by this update.

Summary of changes:
 .../table/operations/row_based_operations.md       | 24 ++++++------
 docs/content.zh/docs/dev/table/tableApi.md         | 29 +++++++--------
 .../table/operations/row_based_operations.md       | 24 ++++++------
 docs/content/docs/dev/table/tableApi.md            | 29 +++++++--------
 .../pyflink/fn_execution/coder_impl_fast.pxd       |  2 +
 .../pyflink/fn_execution/coder_impl_fast.pyx       | 15 ++++++++
 .../pyflink/fn_execution/operation_utils.py        | 37 ++++++++++++-------
 flink-python/pyflink/fn_execution/operations.py    |  4 +-
 .../pyflink/fn_execution/table/aggregate_fast.pxd  |  4 +-
 .../pyflink/fn_execution/table/aggregate_fast.pyx  | 30 ++++++++++-----
 .../pyflink/fn_execution/table/aggregate_slow.py   | 20 +++++-----
 .../fn_execution/table/window_aggregate_fast.pxd   |  4 +-
 .../fn_execution/table/window_aggregate_fast.pyx   | 26 +++++++++----
 .../fn_execution/table/window_aggregate_slow.py    | 16 ++++----
 .../table/tests/test_row_based_operation.py        | 43 ++++++++++++----------
 .../RowDataPythonScalarFunctionOperator.java       | 12 +++++-
 .../table/AbstractPythonTableFunctionOperator.java | 11 +++++-
 .../plan/rules/logical/PythonMapMergeRule.java     | 39 ++++++++------------
 .../plan/rules/logical/PythonMapMergeRuleTest.xml  |  7 ++--
 19 files changed, 217 insertions(+), 159 deletions(-)