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 135d2e2c [FLINK-16598][k8s] Respect the rest port exposed by Service
in Fabric8FlinkKubeClient#getRestEndpoint
add 177976b [FLINK-16983][python] Support RowType in vectorized Python
UDF (#11656)
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/fn_execution/coders.py | 4 ++
.../pyflink/table/tests/test_pandas_udf.py | 31 +++++++++---
flink-python/pyflink/table/types.py | 10 +++-
.../flink/table/runtime/arrow/ArrowUtils.java | 57 ++++++++++++++++++++--
.../{DateFieldReader.java => RowFieldReader.java} | 26 ++++++----
...wArrowReader.java => ArrowRowColumnVector.java} | 46 ++++++++---------
.../{RowArrayWriter.java => RowRowWriter.java} | 44 ++++++++++-------
.../writers/{ArrayWriter.java => RowWriter.java} | 46 +++++++++--------
.../flink/table/runtime/arrow/ArrowUtilsTest.java | 16 ++++++
.../arrow/BaseRowArrowReaderWriterTest.java | 28 ++++++++---
.../runtime/arrow/RowArrowReaderWriterTest.java | 19 ++++++--
.../apache/flink/table/dataformat/ColumnarRow.java | 3 +-
...{ByteColumnVector.java => RowColumnVector.java} | 8 +--
.../dataformat/vector/VectorizedColumnBatch.java | 5 ++
.../table/runtime/util/StreamRecordUtils.java | 5 ++
15 files changed, 248 insertions(+), 100 deletions(-)
copy
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/{DateFieldReader.java
=> RowFieldReader.java} (61%)
copy
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/{BaseRowArrowReader.java
=> ArrowRowColumnVector.java} (53%)
copy
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/{RowArrayWriter.java
=> RowRowWriter.java} (52%)
copy
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/{ArrayWriter.java
=> RowWriter.java} (50%)
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/dataformat/vector/{ByteColumnVector.java
=> RowColumnVector.java} (84%)
