ClickHouse
diff --git a/‎src/Storages/TimeSeries/PrometheusQueryToSQL/Converter.cpp‎
Lines changed: 9 additions & 0 deletions b/‎src/Storages/TimeSeries/PrometheusQueryToSQL/Converter.cpp‎
Lines changed: 9 additions & 0 deletions
diff --git a/‎src/Storages/TimeSeries/PrometheusQueryToSQL/applyBinaryOperator.cpp‎
Lines changed: 27 additions & 0 deletions b/‎src/Storages/TimeSeries/PrometheusQueryToSQL/applyBinaryOperator.cpp‎
Lines changed: 27 additions & 0 deletions
diff --git a/‎src/Storages/TimeSeries/PrometheusQueryToSQL/applyBinaryOperator.h‎
Lines changed: 13 additions & 0 deletions b/‎src/Storages/TimeSeries/PrometheusQueryToSQL/applyBinaryOperator.h‎
Lines changed: 13 additions & 0 deletions
@@ -2,6 +2,7 @@
 
 #include <Storages/TimeSeries/PrometheusQueryToSQL/ConverterContext.h>
 #include <Storages/TimeSeries/PrometheusQueryToSQL/SQLQueryPiece.h>
+#include <Storages/TimeSeries/PrometheusQueryToSQL/applyBinaryOperator.h>
 #include <Storages/TimeSeries/PrometheusQueryToSQL/applyFunction.h>
 #include <Storages/TimeSeries/PrometheusQueryToSQL/applyOffset.h>
 #include <Storages/TimeSeries/PrometheusQueryToSQL/applySubquery.h>
@@ -84,6 +85,14 @@ namespace
                 return applyUnaryOperator(unary_operator, std::move(argument), context);
             }
 
+            case NodeType::BinaryOperator:
+            {
+                const auto * binary_operator = static_cast<const PQT::BinaryOperator *>(node);
+                SQLQueryPiece left_argument = visitNode(binary_operator->getLeftArgument(), context);
+                SQLQueryPiece right_argument = visitNode(binary_operator->getRightArgument(), context);
+                return applyBinaryOperator(binary_operator, std::move(left_argument), std::move(right_argument), context);
+            }
+
             default:
             {
                 throw Exception(ErrorCodes::NOT_IMPLEMENTED, "Prometheus query node type {} is not implemented", node->node_type);
 
@@ -0,0 +1,27 @@
+#include <Storages/TimeSeries/PrometheusQueryToSQL/applyBinaryOperator.h>
+
+#include <Common/Exception.h>
+#include <Storages/TimeSeries/PrometheusQueryToSQL/applyMathBinaryOperator.h>
+
+
+namespace DB::ErrorCodes
+{
+    extern const int NOT_IMPLEMENTED;
+}
+
+
+namespace DB::PrometheusQueryToSQL
+{
+
+SQLQueryPiece applyBinaryOperator(
+    const PQT::BinaryOperator * operator_node, SQLQueryPiece && left_argument, SQLQueryPiece && right_argument, ConverterContext & context)
+{
+    std::string_view operator_name = operator_node->operator_name;
+
+    if (isMathBinaryOperator(operator_name))
+        return applyMathBinaryOperator(operator_node, std::move(left_argument), std::move(right_argument), context);
+
+    throw Exception(ErrorCodes::NOT_IMPLEMENTED, "Binary operator {} is not implemented", operator_name);
+}
+
+}
@@ -0,0 +1,13 @@
+#pragma once
+
+#include <Storages/TimeSeries/PrometheusQueryToSQL/SQLQueryPiece.h>
+
+
+namespace DB::PrometheusQueryToSQL
+{
+
+/// Applies a binary operator.
+SQLQueryPiece applyBinaryOperator(
+    const PQT::BinaryOperator * operator_node, SQLQueryPiece && left_argument, SQLQueryPiece && right_argument, ConverterContext & context);
+
+}