public class QueryPlanPostProcessor extends Object
GenTezUtils.removeUnionOperators(GenTezProcContext, BaseWork, int)
so that statementId can be properly assigned to ensure unique ROW__IDs
UnionProcFactory
is another example where
Union All optimizations create new FileSinkDescSConstructor and Description |
---|
QueryPlanPostProcessor(List<Task<?>> rootTasks,
Set<FileSinkDesc> acidSinks,
String executionId) |
public QueryPlanPostProcessor(List<Task<?>> rootTasks, Set<FileSinkDesc> acidSinks, String executionId)
Copyright © 2022 The Apache Software Foundation. All rights reserved.