outputSuppliers[ replicaIndex ] = createOutputSupplier( operatorDef, isLastOperator );
}
return outputSuppliers;
}
private Supplier<TuplesImpl> createOutputSupplier ( final OperatorDef operatorDef, final boolean isLastOperator )
<BUG>{
return isLastOperator
? new NonCachedTuplesImplSupplier( operatorDef.outputPortCount() )</BUG>
: new CachedTuplesImplSupplier( operatorDef.outputPortCount() );
}

outputSuppliers[ replicaIndex ] = createOutputSupplier( operatorDef, isLastOperator );
}
return outputSuppliers;
}
private Supplier<TuplesImpl> createOutputSupplier ( final OperatorDef operatorDef, final boolean isLastOperator )
{
return isLastOperator ? OutputSupplierUtils.newInstance( lastOperatorOutputSupplierClass, operatorDef.outputPortCount() )
: new CachedTuplesImplSupplier( operatorDef.outputPortCount() );
}
