This is an automated email from the ASF dual-hosted git repository.
rongr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from f503664 [FLINK-14765][runtime] Remove STATE_UPDATER in Execution
add a483524 [FLINK-13596][ml] Add DataStream and DataSet to Table
transformations.
add ec8ea8b [FLINK-13596][ml] Improve fallback conversion and test for
Table transformation.
No new revisions were added by this update.
Summary of changes:
.../ml/common/utils/DataSetConversionUtil.java | 168 +++++++++++++++++++
.../ml/common/utils/DataStreamConversionUtil.java | 161 ++++++++++++++++++
.../ml/common/utils/DataSetConversionUtilTest.java | 182 +++++++++++++++++++++
.../common/utils/DataStreamConversionUtilTest.java | 181 ++++++++++++++++++++
4 files changed, 692 insertions(+)
create mode 100644
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/utils/DataSetConversionUtil.java
create mode 100644
flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/utils/DataStreamConversionUtil.java
create mode 100644
flink-ml-parent/flink-ml-lib/src/test/java/org/apache/flink/ml/common/utils/DataSetConversionUtilTest.java
create mode 100644
flink-ml-parent/flink-ml-lib/src/test/java/org/apache/flink/ml/common/utils/DataStreamConversionUtilTest.java
