Tiny ExchangeNode refactorings
@@ -114,12 +114,12 @@ public class ExchangeNode
this.orderingScheme = orderingScheme;
}
- public static ExchangeNode partitionedExchange(PlanNodeId id, Scope scope, PlanNode child, List<Symbol> partitioningColumns, Optional<Symbol> hashColumns)
+ public static ExchangeNode partitionedExchange(PlanNodeId id, Scope scope, PlanNode child, List<Symbol> partitioningColumns, Optional<Symbol> hashColumn)
{
- return partitionedExchange(id, scope, child, partitioningColumns, hashColumns, false);
+ return partitionedExchange(id, scope, child, partitioningColumns, hashColumn, false);
}
- public static ExchangeNode partitionedExchange(PlanNodeId id, Scope scope, PlanNode child, List<Symbol> partitioningColumns, Optional<Symbol> hashColumns, boolean replicateNullsAndAny)
+ public static ExchangeNode partitionedExchange(PlanNodeId id, Scope scope, PlanNode child, List<Symbol> partitioningColumns, Optional<Symbol> hashColumn, boolean replicateNullsAndAny)
{
return partitionedExchange(
id,
@@ -128,7 +128,7 @@ public class ExchangeNode
new PartitioningScheme(
Partitioning.create(FIXED_HASH_DISTRIBUTION, partitioningColumns),
child.getOutputSymbols(),
- hashColumns,
+ hashColumn,
replicateNullsAndAny,
Optional.empty()));
}
@@ -144,7 +144,7 @@ public class ExchangeNode
scope,
partitioningScheme,
ImmutableList.of(child),
- ImmutableList.of(partitioningScheme.getOutputLayout()).asList(),
+ ImmutableList.of(partitioningScheme.getOutputLayout()),
Optional.empty());
}
