Skip to content

Commit 9764a82

Browse files
committed
update pth_15 to 3.0.0
1 parent 036936c commit 9764a82

2 files changed

Lines changed: 4 additions & 8 deletions

File tree

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@
5454
<teragrep.jue_01.version>0.4.3</teragrep.jue_01.version>
5555
<teragrep.pth_03.version>9.3.0</teragrep.pth_03.version>
5656
<teragrep.pth_06.version>3.6.3</teragrep.pth_06.version>
57-
<teragrep.pth_15.version>2.0.0</teragrep.pth_15.version>
57+
<teragrep.pth_15.version>3.0.0</teragrep.pth_15.version>
5858
<teragrep.rlp_01.version>4.0.1</teragrep.rlp_01.version>
5959
<teragrep.rlp_03.version>9.0.0</teragrep.rlp_03.version>
6060
</properties>

src/main/java/com/teragrep/pth_10/executor/DPLExecutorImpl.java

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -101,18 +101,14 @@ public DPLExecutorResult interpret(
101101
String queryId,
102102
String noteId,
103103
String paragraphId,
104-
String lines
104+
String lines,
105+
ZonedDateTime startTime
105106
) throws TimeoutException {
106107
LOGGER.debug("Running in interpret()");
107108
batchCollect.clear(); // do not store old values // TODO remove from NotebookDatasetStore too
108109

109110
LOGGER.info("DPL-interpreter initialized sparkInterpreter incoming query:<{}>", lines);
110-
// TODO update ctor to use method start time after available from in pth_15
111-
DPLParserCatalystContext catalystContext = new DPLParserCatalystContext(
112-
sparkSession,
113-
config,
114-
ZonedDateTime.now()
115-
);
111+
DPLParserCatalystContext catalystContext = new DPLParserCatalystContext(sparkSession, config, startTime);
116112

117113
LOGGER.debug("Adding audit information");
118114
catalystContext.setAuditInformation(setupAuditInformation(lines));

0 commit comments

Comments
 (0)