pyflink.table.table_environment.StreamTableEnvironment.to_retract_stream

StreamTableEnvironment.to_retract_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 add and retract messages. The message will be encoded as Tuple. The first field is a boolean flag, the second field holds the record of the specified type.

A true flag indicates an add message, a false flag indicates a retract message.

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 of the requested record type.

Returns

The converted DataStream.

New in version 1.12.0.