transportActionProvider,
new ImplementationSymbolVisitor(referenceResolver, functions, RowGranularity.CLUSTER),
node,
statsTables));
} else {
context.addTask(new DistributedMergeTask(
transportActionProvider.transportMergeNodeAction(), node));
}
return null;
}