Skip to content

Commit 350b2b2

Browse files
authored
add query start time to the interpret method (#5)
1 parent b3fc78b commit 350b2b2

2 files changed

Lines changed: 6 additions & 2 deletions

File tree

src/main/java/com/teragrep/pth_15/DPLExecutor.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@
4949
import org.apache.spark.sql.Row;
5050
import org.apache.spark.sql.SparkSession;
5151

52+
import java.time.ZonedDateTime;
5253
import java.util.concurrent.TimeoutException;
5354
import java.util.function.BiConsumer;
5455

@@ -60,7 +61,8 @@ public DPLExecutorResult interpret(
6061
String queryId,
6162
String noteId,
6263
String paragraphId,
63-
String lines
64+
String lines,
65+
ZonedDateTime startTime
6466
) throws TimeoutException;
6567

6668
public abstract void stop() throws TimeoutException;

src/test/java/com/teragrep/pth_15/DPLExecutorTestImpl.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@
5050
import org.apache.spark.sql.Row;
5151
import org.apache.spark.sql.SparkSession;
5252

53+
import java.time.ZonedDateTime;
5354
import java.util.concurrent.TimeoutException;
5455
import java.util.function.BiConsumer;
5556

@@ -65,7 +66,8 @@ public DPLExecutorResult interpret(
6566
String queryId,
6667
String noteId,
6768
String paragraphId,
68-
String lines
69+
String lines,
70+
ZonedDateTime startTime
6971
) throws TimeoutException {
7072
throw new UnsupportedOperationException("Not supported.");
7173
}

0 commit comments

Comments
 (0)