Jiang Xin created FLINK-31240:
---------------------------------
Summary: Reduce the overhead of conversion between DataStream and
Table
Key: FLINK-31240
URL: https://issues.apache.org/jira/browse/FLINK-31240
Project: Flink
Issue Type: Improvement
Components: Table SQL / API
Reporter: Jiang Xin
In some cases, users may need to convert the underlying DataStream to Table and
then convert it back to DataStream(e.g. some Flink ML libraries accept a Table
as input and convert it to DataStream for calculation.). This would cause
unnecessary overhead because of data conversion between the internal data type
and the external data type.
We can reduce the overhead by checking if there are paired
`fromDataStream`/`toDataStream` function call without any transformation, if so
using the source datastream directly.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
