Removed instrument code.
git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_external_gby_fix@1335 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/HashSpillableFrameSortTableFactory.java b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/HashSpillableFrameSortTableFactory.java
index 574a82f..526975b 100644
--- a/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/HashSpillableFrameSortTableFactory.java
+++ b/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/group/HashSpillableFrameSortTableFactory.java
@@ -15,7 +15,6 @@
package edu.uci.ics.hyracks.dataflow.std.group;
import java.nio.ByteBuffer;
-import java.util.logging.Logger;
import edu.uci.ics.hyracks.api.comm.IFrameWriter;
import edu.uci.ics.hyracks.api.context.IHyracksTaskContext;
@@ -41,8 +40,6 @@
private static final long serialVersionUID = 1L;
private final ITuplePartitionComputerFactory tpcf;
- private static final Logger LOGGER = Logger.getLogger(HashSpillableFrameSortTableFactory.class.getName());
-
public HashSpillableFrameSortTableFactory(ITuplePartitionComputerFactory tpcf) {
this.tpcf = tpcf;
}
@@ -127,13 +124,9 @@
private ByteBuffer stateFrame;
- private long insertTimeCounter = 0;
-
@Override
public void sortFrames() {
- long sortTimer = System.currentTimeMillis();
frameSorter.sortFrames();
- LOGGER.warning("[CT]HybridImproved - Sort " + (System.currentTimeMillis() - sortTimer));
}
@Override
@@ -145,7 +138,6 @@
@Override
public boolean insert(FrameTupleAccessor accessor, int tIndex) throws HyracksDataException {
- long insertTimer = System.currentTimeMillis();
if (stateFrame == null) {
// initialize the frame for aggregation result
stateFrame = ctx.allocateFrame();
@@ -182,7 +174,6 @@
if (!stateAppender.append(stateTupleBuilder.getFieldEndOffsets(),
stateTupleBuilder.getByteArray(), 0, stateTupleBuilder.getSize())) {
if (!nextAvailableFrame()) {
- insertTimeCounter += System.currentTimeMillis() - insertTimer;
return false;
}
if (!stateAppender.append(stateTupleBuilder.getFieldEndOffsets(),
@@ -200,7 +191,6 @@
aggregateState);
}
- insertTimeCounter += System.currentTimeMillis() - insertTimer;
return true;
}
@@ -219,7 +209,6 @@
public void close() {
table.close();
aggregateState.close();
- LOGGER.warning("[T]HybridImproved AggregateActivity - HashInsert " + insertTimeCounter);
}
/**