Window DStream print(n)

print(n)

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()

Previouswindow(windowLength, slideInterval)NextsaveAsTextFiles(prefix, [suffix])

Last updated