pyflink.table.table_environment.StreamTableEnvironment.to_retract_stream#
- StreamTableEnvironment.to_retract_stream(table: Table, type_info: TypeInformation) DataStream[source]#
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.
Added in version 1.12.0.