pyflink.datastream.data_stream.DataStream.project

DataStream.project(*field_indexes: int) → pyflink.datastream.data_stream.DataStream

Initiates a Project transformation on a Tuple DataStream.

Note that only Tuple DataStreams can be projected.

Parameters

field_indexes – The field indexes of the input tuples that are retained. The order of fields in the output tuple corresponds to the order of field indexes.

Returns

The projected DataStream.