public Stream project ( Fields keepFields ) { projectionValidation ( keepFields ) ; return _topology . addSourcedNode ( this , new ProcessorNode ( _topology . getUniqueStreamId ( ) , _name , keepFields , new Fields ( ) , new ProjectedProcessor ( keepFields ) ) ) ; }
Filters out fields from a stream resulting in a Stream containing only the fields specified by keepFields .