This is an automated email from the ASF dual-hosted git repository.
sorabh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/drill.git.
from efd6d29 DRILL-5796 : implement ROWS_MATCH enum to keep inside
rowgroup the filter result information, used to prune the filter if all rows
match.
new f7ae370 DRILL-6635: PartitionLimit for Lateral/Unnest Protobuf
changes to add new operator PartitionLimit
new f859399 DRILL-6635: PartitionLimit for Lateral/Unnest
PartitionLimitBatch initial implementation Add unit tests for
PartitionLimitBatch
new f3246a4 DRILL-6635: Update UnnesRecordBatch to handle kill
differently with respect to PartitionLimitBatch in the subquery Fix in
MockLateralJoinBatch for unnest kill tests
new 0d48f6b DRILL-6636: Planner side changes to use PartitionLimitBatch
in place of LimitBatch.
new 006dc10 DRILL-6652: PartitionLimit changes for Lateral and Unnest
Removing Ignore from TestE2EUnnestAndLateral
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../native/client/src/protobuf/UserBitShared.pb.cc | 14 +-
.../native/client/src/protobuf/UserBitShared.pb.h | 5 +-
.../config/{Limit.java => PartitionLimit.java} | 35 +-
.../exec/physical/impl/limit/LimitRecordBatch.java | 18 +-
...reator.java => PartitionLimitBatchCreator.java} | 14 +-
...rdBatch.java => PartitionLimitRecordBatch.java} | 193 ++--
.../physical/impl/unnest/UnnestRecordBatch.java | 41 +-
.../drill/exec/planner/physical/LimitPrel.java | 27 +-
.../physical/impl/BaseTestOpBatchEmitOutcome.java | 5 +
.../drill/exec/physical/impl/MockRecordBatch.java | 36 +-
.../PartitionLimit/TestPartitionLimitBatch.java | 1022 ++++++++++++++++++++
.../impl/lateraljoin/TestE2EUnnestAndLateral.java | 35 +-
.../physical/impl/unnest/MockLateralJoinBatch.java | 4 +-
.../org/apache/drill/exec/proto/UserBitShared.java | 22 +-
.../drill/exec/proto/beans/CoreOperatorType.java | 4 +-
protocol/src/main/protobuf/UserBitShared.proto | 1 +
16 files changed, 1284 insertions(+), 192 deletions(-)
copy
exec/java-exec/src/main/java/org/apache/drill/exec/physical/config/{Limit.java
=> PartitionLimit.java} (73%)
copy
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/limit/{LimitBatchCreator.java
=> PartitionLimitBatchCreator.java} (74%)
copy
exec/java-exec/src/main/java/org/apache/drill/exec/physical/impl/limit/{LimitRecordBatch.java
=> PartitionLimitRecordBatch.java} (55%)
create mode 100644
exec/java-exec/src/test/java/org/apache/drill/exec/physical/impl/PartitionLimit/TestPartitionLimitBatch.java
