decrease earliest epoch value of query xml by 3 hours query XML

src/main/java/com/teragrep/pth10/ast/commands/logicalstatement/TimeStatement.java

@@ -49,6 +49,8 @@
 import com.teragrep.pth10.ast.bo.*;
 import com.teragrep.pth10.ast.bo.Token.Type;
 import com.teragrep.pth10.ast.commands.EmitMode;
+import com.teragrep.pth10.ast.time.DecreasedEpochValue;
+import com.teragrep.pth10.ast.time.TimeQualifierInterface;
 import com.teragrep.pth10.ast.time.TimeQualifier;
 import com.teragrep.pth_03.antlr.DPLParser;
 import com.teragrep.pth_03.antlr.DPLParserBaseVisitor;
@@ -188,19 +190,27 @@ private ElementNode timeQualifierEmitXml(DPLParser.TimeQualifierContext ctx) {
         TerminalNode node = (TerminalNode) ctx.getChild(0);
         String value = ctx.getChild(1).getText();
 
-        TimeQualifier tq = new TimeQualifier(value, catCtx.getTimeFormatString(), node.getSymbol().getType(), doc);
-
-        if (tq.isStartTime()) {
-            startTime = tq.epoch();
+        final TimeQualifierInterface timeQualifierInterface = new TimeQualifier(
+                value,
+                catCtx.getTimeFormatString(),
+                node.getSymbol().getType(),
+                doc
+        );
+        final ElementNode returnValue;
+        if (timeQualifierInterface.isStartTime()) {
+            long decreaseValue = 3 * 60 * 60 * 1000;
+            startTime = timeQualifierInterface.epoch() - decreaseValue;
+            returnValue = new ElementNode(new DecreasedEpochValue(timeQualifierInterface, decreaseValue).xmlElement());
         }
-        else if (tq.isEndTime()) {
-            endTime = tq.epoch();
+        else if (timeQualifierInterface.isEndTime()) {
+            endTime = timeQualifierInterface.epoch();
+            returnValue = new ElementNode(timeQualifierInterface.xmlElement());
         }
         else {
             throw new UnsupportedOperationException("Unexpected token: " + node.getSymbol().getText());
         }
 
-        return new ElementNode(tq.xmlElement());
+        return returnValue;
     }
 
     /**

src/main/java/com/teragrep/pth10/ast/time/DecreasedEpochValue.java

@@ -0,0 +1,83 @@
+/*
+ * Teragrep Data Processing Language (DPL) translator for Apache Spark (pth_10)
+ * Copyright (C) 2019-2024 Suomen Kanuuna Oy
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ *
+ *
+ * Additional permission under GNU Affero General Public License version 3
+ * section 7
+ *
+ * If you modify this Program, or any covered work, by linking or combining it
+ * with other code, such other code is not for that reason alone subject to any
+ * of the requirements of the GNU Affero GPL version 3 as long as this Program
+ * is the same Program as licensed from Suomen Kanuuna Oy without any additional
+ * modifications.
+ *
+ * Supplemented terms under GNU Affero General Public License version 3
+ * section 7
+ *
+ * Origin of the software must be attributed to Suomen Kanuuna Oy. Any modified
+ * versions must be marked as "Modified version of" The Program.
+ *
+ * Names of the licensors and authors may not be used for publicity purposes.
+ *
+ * No rights are granted for use of trade names, trademarks, or service marks
+ * which are in The Program if any.
+ *
+ * Licensee must indemnify licensors and authors for any liability that these
+ * contractual assumptions impose on licensors and authors.
+ *
+ * To the extent this program is licensed as part of the Commercial versions of
+ * Teragrep, the applicable Commercial License may apply to this file if you as
+ * a licensee so wish it.
+ */
+package com.teragrep.pth10.ast.time;
+
+import org.w3c.dom.Element;
+
+/** Decreases the amount from qualifier epoch value */
+public class DecreasedEpochValue implements TimeQualifierInterface {
+
+    TimeQualifierInterface origin;
+    long decreaseEpochValue;
+
+    public DecreasedEpochValue(TimeQualifierInterface origin, long decreaseEpochValue) {
+        this.origin = origin;
+        this.decreaseEpochValue = decreaseEpochValue;
+    }
+
+    @Override
+    public Element xmlElement() {
+        final Element el = origin.xmlElement();
+        final long newValue = Long.parseLong(el.getAttribute("value")) - decreaseEpochValue;
+        el.setAttribute("value", Long.toString(newValue));
+        return el;
+    }
+
+    @Override
+    public boolean isStartTime() {
+        return origin.isStartTime();
+    }
+
+    @Override
+    public boolean isEndTime() {
+        return origin.isEndTime();
+    }
+
+    @Override
+    public long epoch() {
+        return origin.epoch() - decreaseEpochValue;
+    }
+}

src/main/java/com/teragrep/pth10/ast/time/TimeQualifier.java

@@ -53,7 +53,7 @@
 
 import java.util.Objects;
 
-public final class TimeQualifier {
+public final class TimeQualifier implements TimeQualifierInterface {
 
     private final int token;
     private final String value;

src/main/java/com/teragrep/pth10/ast/time/TimeQualifierInterface.java

@@ -0,0 +1,59 @@
+/*
+ * Teragrep Data Processing Language (DPL) translator for Apache Spark (pth_10)
+ * Copyright (C) 2019-2024 Suomen Kanuuna Oy
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU Affero General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU Affero General Public License for more details.
+ *
+ * You should have received a copy of the GNU Affero General Public License
+ * along with this program.  If not, see <https://www.gnu.org/licenses/>.
+ *
+ *
+ * Additional permission under GNU Affero General Public License version 3
+ * section 7
+ *
+ * If you modify this Program, or any covered work, by linking or combining it
+ * with other code, such other code is not for that reason alone subject to any
+ * of the requirements of the GNU Affero GPL version 3 as long as this Program
+ * is the same Program as licensed from Suomen Kanuuna Oy without any additional
+ * modifications.
+ *
+ * Supplemented terms under GNU Affero General Public License version 3
+ * section 7
+ *
+ * Origin of the software must be attributed to Suomen Kanuuna Oy. Any modified
+ * versions must be marked as "Modified version of" The Program.
+ *
+ * Names of the licensors and authors may not be used for publicity purposes.
+ *
+ * No rights are granted for use of trade names, trademarks, or service marks
+ * which are in The Program if any.
+ *
+ * Licensee must indemnify licensors and authors for any liability that these
+ * contractual assumptions impose on licensors and authors.
+ *
+ * To the extent this program is licensed as part of the Commercial versions of
+ * Teragrep, the applicable Commercial License may apply to this file if you as
+ * a licensee so wish it.
+ */
+package com.teragrep.pth10.ast.time;
+
+import org.w3c.dom.Element;
+
+public interface TimeQualifierInterface {
+
+    Element xmlElement();
+
+    boolean isStartTime();
+
+    boolean isEndTime();
+
+    long epoch();
+}

src/test/java/com/teragrep/pth10/TimeQualifierTest.java

@@ -45,7 +45,9 @@
  */
 package com.teragrep.pth10;
 
+import com.teragrep.pth10.ast.time.DecreasedEpochValue;
 import com.teragrep.pth10.ast.time.TimeQualifier;
+import com.teragrep.pth10.ast.time.TimeQualifierInterface;
 import com.teragrep.pth_03.antlr.DPLLexer;
 import org.apache.spark.sql.Column;
 import org.apache.spark.sql.functions;
@@ -160,6 +162,24 @@ public void testEndtimeU() {
         Assertions.assertEquals(el.toString(), tq.xmlElement().toString());
     }
 
+    @Test
+    public void testDecreaseDecorator() {
+        long decreaseAmount = 1000L;
+        final String value = "2024-31-10";
+        final String timeformat = "%Y-%d-%m";
+        final int earliestType = DPLLexer.EARLIEST;
+        final Document doc = Assertions
+                .assertDoesNotThrow(() -> DocumentBuilderFactory.newInstance().newDocumentBuilder().newDocument());
+        TimeQualifierInterface tq = new DecreasedEpochValue(
+                new TimeQualifier(value, timeformat, earliestType, doc),
+                decreaseAmount
+        );
+        Element el = doc.createElement("earliest");
+        el.setAttribute("operation", "GE");
+        el.setAttribute("value", Long.toString(1730325600L - decreaseAmount));
+        Assertions.assertEquals(el.toString(), tq.xmlElement().toString());
+    }
+
     @Test
     public void testInvalidToken() {
         final String value = "024-10-31:00:00:00";