Jianfeng Jia has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/713
Change subject: Fix the ExternalGroupby for fuzzy join
......................................................................
Fix the ExternalGroupby for fuzzy join
Change-Id: I5a3852d08f9a3e2738ea2952f05aa082a2e6dbbb
---
M
hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/HashSpillableTableFactory.java
1 file changed, 1 insertion(+), 6 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/hyracks refs/changes/13/713/1
diff --git
a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/HashSpillableTableFactory.java
b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/HashSpillableTableFactory.java
index 44ddf44..e08041d 100644
---
a/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/HashSpillableTableFactory.java
+++
b/hyracks/hyracks-dataflow-std/src/main/java/org/apache/hyracks/dataflow/std/group/HashSpillableTableFactory.java
@@ -83,12 +83,7 @@
final AggregateState aggregateState =
aggregator.createAggregateStates();
- final ArrayTupleBuilder stateTupleBuilder;
- if (keyFields.length < outRecordDescriptor.getFields().length) {
- stateTupleBuilder = new
ArrayTupleBuilder(outRecordDescriptor.getFields().length);
- } else {
- stateTupleBuilder = new
ArrayTupleBuilder(outRecordDescriptor.getFields().length + 1);
- }
+ final ArrayTupleBuilder stateTupleBuilder = new
ArrayTupleBuilder(outRecordDescriptor.getFields().length);
//TODO(jf) research on the optimized partition size
final int numPartitions = getNumOfPartitions((int) (dataBytesSize /
ctx.getInitialFrameSize()),
--
To view, visit https://asterix-gerrit.ics.uci.edu/713
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I5a3852d08f9a3e2738ea2952f05aa082a2e6dbbb
Gerrit-PatchSet: 1
Gerrit-Project: hyracks
Gerrit-Branch: master
Gerrit-Owner: Jianfeng Jia <[email protected]>
