Class PredicatePipe<O extends Observation>