org.rapidprom.operators.streams.extract