public Stream map ( MapFunction function ) { projectionValidation ( getOutputFields ( ) ) ; return _topology . addSourcedNode ( this , new ProcessorNode ( _topology . getUniqueStreamId ( ) , _name , getOutputFields ( ) , getOutputFields ( ) , new MapProcessor ( getOutputFields ( ) , new MapFunctionExecutor ( function ) ) ) ) ; }
Returns a stream consisting of the result of applying the given mapping function to the values of this stream .