aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/rangepartitioner
diff options
context:
space:
mode:
authorAman Sinha <asinha@maprtech.com>2018-10-13 23:38:17 -0700
committerAman Sinha <asinha@maprtech.com>2018-10-25 16:08:51 -0700
commit7571d52eab9b961687df7d4fb845d0a297b228bb (patch)
tree93c8a2de552c3a90051d523ad26291aacc02d1ef /exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/rangepartitioner
parent387bc4fefc40b645685439fd1da43f7223e5933c (diff)
DRILL-6381: Address code review comments (part 3).
DRILL-6381: Add missing joinControl logic for INTERSECT_DISTINCT. - Modified HashJoin's probe phase to process INTERSECT_DISTINCT. - NOTE: For build phase, the functionality will be same as for SemiJoin when it is added later. DRILL-6381: Address code review comment for intersect_distinct. DRILL-6381: Rebase on latest master and fix compilation issues. DRILL-6381: Generate protobuf files for C++ native client. DRILL-6381: Use shaded Guava classes. Add more comments and Javadoc.
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/rangepartitioner')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/rangepartitioner/RangePartitionRecordBatch.java7
1 files changed, 7 insertions, 0 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/rangepartitioner/RangePartitionRecordBatch.java b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/rangepartitioner/RangePartitionRecordBatch.java
index d8fc94d67..6a548289d 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/rangepartitioner/RangePartitionRecordBatch.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/rangepartitioner/RangePartitionRecordBatch.java
@@ -183,4 +183,11 @@ public class RangePartitionRecordBatch extends AbstractSingleRecordBatch<RangePa
return counter;
}
+
+ @Override
+ public void dump() {
+ logger.error("RangePartitionRecordBatch[container={}, numPartitions={}, recordCount={}, partitionIdVector={}]",
+ container, numPartitions, recordCount, partitionIdVector);
+ }
+
}