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 2e475477 [FLINK-17254][python][docs] Improve the PyFlink documentation
and examples to use SQL DDL for source/sink definition.
add c54293b [FLINK-17148][python] Support converting pandas DataFrame to
Flink Table (#11832)
No new revisions were added by this update.
Summary of changes:
docs/dev/table/python/conversion_of_pandas.md | 59 ++++
docs/dev/table/python/conversion_of_pandas.zh.md | 59 ++++
docs/dev/table/python/index.md | 1 +
docs/dev/table/python/index.zh.md | 1 +
flink-python/pyflink/fn_execution/coder_impl.py | 52 +---
flink-python/pyflink/table/serializers.py | 53 ++++
flink-python/pyflink/table/table_environment.py | 91 ++++++-
.../pyflink/table/tests/test_pandas_conversion.py | 147 ++++++++++
flink-python/pyflink/table/tests/test_types.py | 2 +-
flink-python/pyflink/table/types.py | 72 ++++-
flink-python/pyflink/table/utils.py | 69 +++++
.../flink/table/runtime/arrow/ArrowUtils.java | 105 ++++++-
.../arrow/sources/AbstractArrowSourceFunction.java | 220 +++++++++++++++
.../arrow/sources/AbstractArrowTableSource.java | 55 ++++
.../runtime/arrow/sources/ArrowSourceFunction.java | 54 ++++
.../runtime/arrow/sources/ArrowTableSource.java | 40 +++
.../arrow/sources/RowArrowSourceFunction.java | 54 ++++
.../runtime/arrow/sources/RowArrowTableSource.java | 40 +++
.../arrow/ArrowPythonScalarFunctionFlatMap.java | 2 +-
.../arrow/ArrowPythonScalarFunctionOperator.java | 2 +-
.../RowDataArrowPythonScalarFunctionOperator.java | 2 +-
.../AbstractArrowPythonScalarFunctionRunner.java | 12 +-
.../flink/table/runtime/arrow/ArrowUtilsTest.java | 39 ++-
.../runtime/arrow/RowArrowReaderWriterTest.java | 2 +-
.../arrow/RowDataArrowReaderWriterTest.java | 2 +-
.../arrow/sources/ArrowSourceFunctionTest.java | 119 ++++++++
.../arrow/sources/ArrowSourceFunctionTestBase.java | 303 +++++++++++++++++++++
.../arrow/sources/RowArrowSourceFunctionTest.java | 85 ++++++
28 files changed, 1671 insertions(+), 71 deletions(-)
create mode 100644 docs/dev/table/python/conversion_of_pandas.md
create mode 100644 docs/dev/table/python/conversion_of_pandas.zh.md
create mode 100644 flink-python/pyflink/table/serializers.py
create mode 100644 flink-python/pyflink/table/tests/test_pandas_conversion.py
create mode 100644 flink-python/pyflink/table/utils.py
create mode 100644
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/AbstractArrowSourceFunction.java
create mode 100644
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/AbstractArrowTableSource.java
create mode 100644
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/ArrowSourceFunction.java
create mode 100644
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/ArrowTableSource.java
create mode 100644
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/RowArrowSourceFunction.java
create mode 100644
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/RowArrowTableSource.java
create mode 100644
flink-python/src/test/java/org/apache/flink/table/runtime/arrow/sources/ArrowSourceFunctionTest.java
create mode 100644
flink-python/src/test/java/org/apache/flink/table/runtime/arrow/sources/ArrowSourceFunctionTestBase.java
create mode 100644
flink-python/src/test/java/org/apache/flink/table/runtime/arrow/sources/RowArrowSourceFunctionTest.java
