Show how to use when it is the schema for a topology.source() and invoking SPL operators.
Show how to use when it is the schema for a topology.source() and invoking SPL operators.