File tree Expand file tree Collapse file tree
src/main/java/com/teragrep/pth_10/executor Expand file tree Collapse file tree Original file line number Diff line number Diff line change 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.5.0</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 >
Original file line number Diff line number Diff 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 ));
You can’t perform that action at this time.
0 commit comments