pyflink.datastream.data_stream.DataStream.uid#
- DataStream.uid(uid: str) DataStream[source]#
Sets an ID for this operator. The specified ID is used to assign the same operator ID across job submissions (for example when starting a job from a savepoint).
Important: this ID needs to be unique per transformation and job. Otherwise, job submission will fail.
- Parameters:
uid – The unique user-specified ID of this transformation.
- Returns:
The operator with the specified ID.