pyflink.datastream.data_stream.CachedDataStream.project#
- CachedDataStream.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.