pyflink.datastream.data_stream.CachedDataStream.project

CachedDataStream.project(*field_indexes: int) → 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.