pyflink.table.table_environment.StreamTableEnvironment.to_append_stream

StreamTableEnvironment.to_append_stream(table: pyflink.table.table.Table, type_info: pyflink.common.typeinfo.TypeInformation) → pyflink.datastream.data_stream.DataStream

Converts the given Table into a DataStream of a specified type. The Table must only have insert (append) changes. If the Table is also modified by update or delete changes, the conversion will fail.

The fields of the Table are mapped to DataStream as follows: Row and Tuple types: Fields are mapped by position, field types must match.

Parameters

• table – The Table to convert.

• type_info – The TypeInformation that specifies the type of the DataStream.

Returns

The converted DataStream.

New in version 1.12.0.