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.