pyflink.datastream.data_stream.DataStreamSink.uid#
- DataStreamSink.uid(uid: str) pyflink.datastream.data_stream.DataStreamSink[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.