org.apache.flink.table.runtime.operators.python.utils (Flink : Python 1.14.2 API)

Class Summary
Class Description

StreamRecordRowDataWrappingCollector
The collector is used to convert a RowData to a StreamRecord.

Class Summary
Class	Description
StreamRecordRowDataWrappingCollector	The collector is used to convert a `RowData` to a `StreamRecord`.

Package org.apache.flink.table.runtime.operators.python.utils