Skip to content

Commit

Permalink
Remove unused parameter
Browse files Browse the repository at this point in the history
  • Loading branch information
geraint0923 committed Sep 16, 2016
1 parent 75c5b81 commit 8528733
Showing 1 changed file with 2 additions and 4 deletions.
Expand Up @@ -140,7 +140,7 @@ public AddExchanges(Metadata metadata, SqlParser parser)
@Override
public PlanNode optimize(PlanNode plan, Session session, Map<Symbol, Type> types, SymbolAllocator symbolAllocator, PlanNodeIdAllocator idAllocator)
{
PlanWithProperties result = plan.accept(new Rewriter(symbolAllocator, idAllocator, symbolAllocator, session), new Context(PreferredProperties.any(), false));
PlanWithProperties result = plan.accept(new Rewriter(idAllocator, symbolAllocator, session), new Context(PreferredProperties.any(), false));
return result.getNode();
}

Expand Down Expand Up @@ -181,7 +181,6 @@ boolean isDownstreamIsDelete()
private class Rewriter
extends PlanVisitor<Context, PlanWithProperties>
{
private final SymbolAllocator allocator;
private final PlanNodeIdAllocator idAllocator;
private final SymbolAllocator symbolAllocator;
private final Session session;
Expand All @@ -190,9 +189,8 @@ private class Rewriter
private final boolean preferStreamingOperators;
private final boolean redistributeWrites;

public Rewriter(SymbolAllocator allocator, PlanNodeIdAllocator idAllocator, SymbolAllocator symbolAllocator, Session session)
public Rewriter(PlanNodeIdAllocator idAllocator, SymbolAllocator symbolAllocator, Session session)
{
this.allocator = allocator;
this.idAllocator = idAllocator;
this.symbolAllocator = symbolAllocator;
this.session = session;
Expand Down

0 comments on commit 8528733

Please sign in to comment.