diff --git a/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaListOperationHandler.java b/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaListOperationHandler.java index 8d70dbb07..6a1f3107c 100644 --- a/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaListOperationHandler.java +++ b/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaListOperationHandler.java @@ -26,6 +26,7 @@ public void executeOperation(TOperation operation, NebulaDbConnectionState state final String queryString = getQueryString(state, operation); state.logQuery(operation.getClass().getSimpleName(), queryString); final ResultSet result; + long startTime = System.currentTimeMillis(); try { result = session.execute(queryString); if (state.isPrintErrors() && !result.isSucceeded()) { @@ -46,6 +47,11 @@ public void executeOperation(TOperation operation, NebulaDbConnectionState state } catch (Exception e) { throw new DbException(e); + } finally { + long threadID = Thread.currentThread().getId(); + long consumeTime = (System.currentTimeMillis() - startTime) / 1000; + System.out.println("Query SimpleName : " + operation.getClass().getSimpleName()); + System.out.println("threadID : " + threadID + " startTime : " + startTime / 1000 + " consumeTime : " + consumeTime); } } diff --git a/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaMultipleUpdateOperationHandler.java b/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaMultipleUpdateOperationHandler.java index 6252c2d92..5e91dd90b 100644 --- a/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaMultipleUpdateOperationHandler.java +++ b/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaMultipleUpdateOperationHandler.java @@ -16,6 +16,7 @@ public abstract class NebulaMultipleUpdateOperationHandler queryStrings = getQueryString(state, operation); for (String queryString : queryStrings) { @@ -27,6 +28,11 @@ public void executeOperation(TOperation operation, NebulaDbConnectionState state } } catch (Exception e) { throw new DbException(e); + } finally { + long threadID = Thread.currentThread().getId(); + long consumeTime = (System.currentTimeMillis() - startTime) / 1000; + System.out.println("Query SimpleName : " + operation.getClass().getSimpleName()); + System.out.println("threadID : " + threadID + " startTime : " + startTime / 1000 + " consumeTime : " + consumeTime); } resultReporter.report(0, LdbcNoResult.INSTANCE, operation); } diff --git a/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaSingletonOperationHandler.java b/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaSingletonOperationHandler.java index 139dcd97e..468544bad 100644 --- a/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaSingletonOperationHandler.java +++ b/nebula/src/main/java/org/ldbcouncil/snb/impls/workloads/nebula/operationhandlers/NebulaSingletonOperationHandler.java @@ -16,10 +16,10 @@ public abstract class NebulaSingletonOperationHandler