git-svn-id: https://hyracks.googlecode.com/svn/branches/fullstack_genomix@2728 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/hybridhash/HybridHashGroupOperatorDescriptor.java b/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/hybridhash/HybridHashGroupOperatorDescriptor.java
index 8a94c9f..dcefc59 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/hybridhash/HybridHashGroupOperatorDescriptor.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/hybridhash/HybridHashGroupOperatorDescriptor.java
@@ -97,6 +97,10 @@
private final boolean doInputAdjustment;
private final static double FUDGE_FACTOR_ESTIMATION = 1.2;
+
+
+
+ private int open_times ;
public HybridHashGroupOperatorDescriptor(JobSpecification spec, int[] keyFields, int framesLimit,
long inputSizeInRawRecords, long inputSizeInUniqueKeys, int recordSizeInBytes, int tableSize,
@@ -107,6 +111,7 @@
this(spec, keyFields, framesLimit, inputSizeInRawRecords, inputSizeInUniqueKeys, recordSizeInBytes, tableSize,
comparatorFactories, hashFamilies, hashFuncStartLevel, firstNormalizerFactory, aggregatorFactory,
mergerFactory, outRecDesc, true);
+ open_times = 0;
}
public HybridHashGroupOperatorDescriptor(JobSpecification spec, int[] keyFields, int framesLimit,
@@ -148,6 +153,8 @@
recordDescriptors[0] = outRecDesc;
this.doInputAdjustment = doInputAdjustment;
+
+ open_times = 0;
}
@Override
@@ -233,6 +240,9 @@
writer.open();
topProcessor.open();
+
+ open_times += 1;
+ System.err.println(open_times);
}
@Override