pyflink.datastream.data_stream.KeyedStream.print#
- KeyedStream.print(sink_identifier=None)[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.