protected abstract List<? extends OperatorFactory> createOperatorFactories();
protected DriverFactory createDriverFactory()
{
List<OperatorFactory> operatorFactories = new ArrayList<>(createOperatorFactories());
operatorFactories.add(new NullOutputOperatorFactory(999, new PlanNodeId("test"), Iterables.getLast(operatorFactories).getTypes()));
<BUG>return new DriverFactory(true, true, operatorFactories, OptionalInt.empty());
</BUG>
}
@Override
protected List<Driver> createDrivers(TaskContext taskContext)

protected abstract List<? extends OperatorFactory> createOperatorFactories();
protected DriverFactory createDriverFactory()
{
List<OperatorFactory> operatorFactories = new ArrayList<>(createOperatorFactories());
operatorFactories.add(new NullOutputOperatorFactory(999, new PlanNodeId("test"), Iterables.getLast(operatorFactories).getTypes()));
return new DriverFactory(0, true, true, operatorFactories, OptionalInt.empty());
}
@Override
protected List<Driver> createDrivers(TaskContext taskContext)
