case INSERT_DIRECT:
case MERGE_DIRECT:
break;
case INSERT:
if (task.getNewTableSchema().isPresent()) {
<BUG>con.createTableIfNotExists(task.getTable(), task.getNewTableSchema().get());
</BUG>
}
<BUG>con.collectInsert(task.getIntermediateTables().get(), schema, task.getTable(), false);
</BUG>
break;

case INSERT_DIRECT:
case MERGE_DIRECT:
break;
case INSERT:
if (task.getNewTableSchema().isPresent()) {
con.createTableIfNotExists(task.getActualTable(), task.getNewTableSchema().get());
}
con.collectInsert(task.getIntermediateTables().get(), schema, task.getActualTable(), false);
break;
