Skip to content

Commit

Permalink
Fix formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
kokosing committed Jan 13, 2018
1 parent 5d233a8 commit d8e1f59
Showing 1 changed file with 15 additions and 3 deletions.
Expand Up @@ -312,7 +312,12 @@ public TableScanNode tableScan(TableHandle tableHandle, List<Symbol> symbols, Ma
return tableScan(tableHandle, symbols, assignments, originalConstraint, Optional.empty());
}

public TableScanNode tableScan(TableHandle tableHandle, List<Symbol> symbols, Map<Symbol, ColumnHandle> assignments, Expression originalConstraint, Optional<TableLayoutHandle> tableLayout)
public TableScanNode tableScan(
TableHandle tableHandle,
List<Symbol> symbols,
Map<Symbol, ColumnHandle> assignments,
Expression originalConstraint,
Optional<TableLayoutHandle> tableLayout)
{
return new TableScanNode(
idAllocator.getNextId(),
Expand Down Expand Up @@ -435,12 +440,19 @@ public ExchangeBuilder singleDistributionPartitioningScheme(List<Symbol> outputS

public ExchangeBuilder fixedHashDistributionParitioningScheme(List<Symbol> outputSymbols, List<Symbol> partitioningSymbols)
{
return partitioningScheme(new PartitioningScheme(Partitioning.create(FIXED_HASH_DISTRIBUTION, ImmutableList.copyOf(partitioningSymbols)), ImmutableList.copyOf(outputSymbols)));
return partitioningScheme(new PartitioningScheme(Partitioning.create(
FIXED_HASH_DISTRIBUTION,
ImmutableList.copyOf(partitioningSymbols)),
ImmutableList.copyOf(outputSymbols)));
}

public ExchangeBuilder fixedHashDistributionParitioningScheme(List<Symbol> outputSymbols, List<Symbol> partitioningSymbols, Symbol hashSymbol)
{
return partitioningScheme(new PartitioningScheme(Partitioning.create(FIXED_HASH_DISTRIBUTION, ImmutableList.copyOf(partitioningSymbols)), ImmutableList.copyOf(outputSymbols), Optional.of(hashSymbol)));
return partitioningScheme(new PartitioningScheme(Partitioning.create(
FIXED_HASH_DISTRIBUTION,
ImmutableList.copyOf(partitioningSymbols)),
ImmutableList.copyOf(outputSymbols),
Optional.of(hashSymbol)));
}

public ExchangeBuilder partitioningScheme(PartitioningScheme partitioningScheme)
Expand Down

0 comments on commit d8e1f59

Please sign in to comment.