private void createDefaultExtractOperation ( ) { this . currentStreamOperation = new DStreamOperation ( this . operationIdCounter ++ ) ; this . currentStreamOperation . addStreamOperationFunction ( Ops . extract . name ( ) , s -> s ) ; }
Will create an operation named extract with a pass - thru function