Added start time to LocalResultSet
@@ -23,6 +23,9 @@ public class OLocalResultSet implements OResultSet {
private boolean finished = false;
long totalExecutionTime = 0;
+ long startTime = 0;
+
+
public OLocalResultSet(OInternalExecutionPlan executionPlan) {
this.executionPlan = executionPlan;
@@ -32,6 +35,9 @@ public class OLocalResultSet implements OResultSet {
private boolean fetchNext() {
long begin = System.currentTimeMillis();
try {
+ if(lastFetch == null) {
+ startTime = begin;
+ }
lastFetch = executionPlan.fetchNext(100);
if (!lastFetch.hasNext()) {
finished = true;
@@ -87,6 +93,10 @@ public class OLocalResultSet implements OResultSet {
return totalExecutionTime;
}
+ public long getStartTime() {
+ return startTime;
+ }
+
@Override
public void close() {
executionPlan.close();
