pipe = new GroupBy( "vote", pipes.toArray( new Pipe[ pipes.size() ] ), keyFields );
SelectionBuffer buffer;
if( isCategorical )
buffer = new CategoricalSelectionBuffer( ensembleSpec );
else
buffer = new PredictionSelectionBuffer( ensembleSpec );
pipe = new Every( pipe, predictedFields, buffer, Fields.SWAP );