Tim Armstrong has uploaded this change for review. ( http://gerrit.cloudera.org:8080/15083
Change subject: IMPALA-4224: part 2: refactor filter routing table to support sinks ...................................................................... IMPALA-4224: part 2: refactor filter routing table to support sinks This is some refactoring that will enable us to correctly construct a routing table where join build sinks produce filters: * The previous code relied (non-obviously) on producers being visited before consumers when walking the plan tree. This is no longer true when build sinks produce filters. The code is changed so it can construct the routing table entry when the first producer or consumer is visited (using GetOrCreateFilterState()) * The source plan node ID is added to TRuntimeFilterDesc, so that it's available when visiting consumer nodes. * The logic for adding a filter source to the routing table is factored out into a separate function AddFilterSource(), which can be used (in a later patch) for join build sinks. This change is not expected to change behaviour in any way. Change-Id: Idc53ae0167af45e32093a024ff2d6e2c6466c876 --- M be/src/runtime/coordinator-filter-state.h M be/src/runtime/coordinator.cc M be/src/runtime/coordinator.h M common/thrift/PlanNodes.thrift M fe/src/main/java/org/apache/impala/planner/RuntimeFilterGenerator.java 5 files changed, 78 insertions(+), 54 deletions(-) git pull ssh://gerrit.cloudera.org:29418/Impala-ASF refs/changes/83/15083/4 -- To view, visit http://gerrit.cloudera.org:8080/15083 To unsubscribe, visit http://gerrit.cloudera.org:8080/settings Gerrit-Project: Impala-ASF Gerrit-Branch: master Gerrit-MessageType: newchange Gerrit-Change-Id: Idc53ae0167af45e32093a024ff2d6e2c6466c876 Gerrit-Change-Number: 15083 Gerrit-PatchSet: 4 Gerrit-Owner: Tim Armstrong <[email protected]> Gerrit-Reviewer: Impala Public Jenkins <[email protected]>
