Prints the first ten elements (default to 10) of every batch of data in a DStream on the driver node running the streaming application. This is useful for development and debugging.
Python API This is called pprint() in the Python API.
Example:
messages4.print() ssc.start() ssc.awaitTermination()
Last updated 5 years ago