org.rapidprom.operators.streams.discovery.abstr