pyflink.datastream.data_stream.DataStream.print

DataStream.print(sink_identifier: Optional[str] = None) → pyflink.datastream.data_stream.DataStreamSink

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.