pyflink.datastream.data_stream.DataStream.print#
- DataStream.print(sink_identifier: str | None = None) DataStreamSink[source]#
Writes a DataStream to the standard output stream (stdout). For each element of the DataStream the object string is written.
NOTE: This will print to stdout on the machine where the code is executed, i.e. the Flink worker, and is not fault tolerant.
- Parameters:
sink_identifier – The string to prefix the output with.
- Returns:
The closed DataStream.