search

IBMStreams / streamsx.topology

Develop streaming applications for IBM Streams in Python, Java & Scala.
http://ibmstreams.github.io/streamsx.topology
Apache License 2.0
29 stars 43 forks source link

Python: Write punctuation markers with Stream.print() to stdout #2516

Closed markheger closed 4 years ago

markheger commented 4 years ago

Stream.print() has a new parameter to print the punctuations to stdout.

topo = Topology()
s = topo.source([1,2,3,4])
s = s.punctor(lambda t : 2 < t)
s.print(write_punctuations=True)
markheger commented 4 years ago

merged to IBMStreams:feature/punct

markheger commented 4 years ago

merged to develop branch for 1.16.0a