Restrictions and known bugs¶
No support for nested parallel regions at sources, i.e. nested
streamsx.topology.topology.Stream.set_parallel(), for example:
topo = Topology() s = topo.source(S()) s.set_parallel(3).set_parallel(2)
In this example, set_parallel(3) is ignored.
No support for nested types when defining stream schemas, for example:
class NamedTupleNestedTupleSchema(typing.NamedTuple): key: str spotted: SpottedSchema
No support of collections of NamedTuple as stream schema, for example:
class NamedTupleListOfTupleSchema(typing.NamedTuple): spotted: typing.List[SpottedSchema]
Python Composites (derived from
streamsx.topology.composite.Composite) can have only one input port.
No support to process window markers or final marker (end of stream) in Python Callables like in SPL operators
No hook for drain processing in consistent region for Python Callables