I'm trying to call submit() from an SPL function (that is called from a Custom operator), but it is not working. It complains about the name of my stream:
submit({prop1=value1, prop2=value2}, MyStream);
ERROR: An unknown identifier was referenced in the SPL program: MyStream
Is this supported?
No, this is not supported.
submit()
can only be called inside the Custom operator, within itsonTuple
,onPunct
, oronProcess
clauses. It cannot be called from an SPL function.