streamsx.topology.functions module

streamsx.topology.functions.identity(t)

Returns its single argument. :returns: Its argument.

streamsx.topology.functions.print_flush(v)

Prints argument to stdout flushing after each tuple. :returns: None