From c8ad3a5cc6aea20d6cf87d8ebf0c8f54eeb28b31 Mon Sep 17 00:00:00 2001
From: Waleed Akbar <wakbar@cttc.es>
Date: Tue, 3 Sep 2024 09:45:12 +0000
Subject: [PATCH] **Changes in Frontend**

- Added the missing `map<string, string>` in the `analytics_frontend.proto` file.
- Removed `pyspark` and `java` from the `requirements.in` file, as they are not required for the Frontend.
---
 proto/analytics_frontend.proto         | 20 ++++++++++----------
 src/analytics/frontend/requirements.in |  2 --
 2 files changed, 10 insertions(+), 12 deletions(-)

diff --git a/proto/analytics_frontend.proto b/proto/analytics_frontend.proto
index 45e910a70..bd28a21bf 100644
--- a/proto/analytics_frontend.proto
+++ b/proto/analytics_frontend.proto
@@ -36,16 +36,16 @@ enum AnalyzerOperationMode {
 
 message Analyzer {
   AnalyzerId                 analyzer_id          = 1;
-  string                     algorithm_name       = 2; // The algorithm to be executed
-  repeated kpi_manager.KpiId input_kpi_ids        = 3; // The KPI Ids to be processed by the analyzer
-  repeated kpi_manager.KpiId output_kpi_ids       = 4; // The KPI Ids produced by the analyzer
-  AnalyzerOperationMode      operation_mode       = 5; // Operation mode of the analyzer
-
-  // In batch mode...
-  float                      batch_min_duration_s = 6; // ..., min duration to collect before executing batch
-  float                      batch_max_duration_s = 7; // ..., max duration collected to execute the batch
-  uint64                     batch_min_size       = 8; // ..., min number of samples to collect before executing batch
-  uint64                     batch_max_size       = 9; // ..., max number of samples collected to execute the batch
+  string                     algorithm_name       = 2;  // The algorithm to be executed
+  repeated kpi_manager.KpiId input_kpi_ids        = 3;  // The KPI Ids to be processed by the analyzer
+  repeated kpi_manager.KpiId output_kpi_ids       = 4;  // The KPI Ids produced by the analyzer
+  AnalyzerOperationMode      operation_mode       = 5;  // Operation mode of the analyzer
+  map<string, string>        parameters           = 6; 
+  // In batch mode... 
+  float                      batch_min_duration_s = 7;  // ..., min duration to collect before executing batch
+  float                      batch_max_duration_s = 8;  // ..., max duration collected to execute the batch
+  uint64                     batch_min_size       = 9;  // ..., min number of samples to collect before executing batch
+  uint64                     batch_max_size       = 10; // ..., max number of samples collected to execute the batch
 }
 
 message AnalyzerFilter {
diff --git a/src/analytics/frontend/requirements.in b/src/analytics/frontend/requirements.in
index 98cf96710..1d22df11b 100644
--- a/src/analytics/frontend/requirements.in
+++ b/src/analytics/frontend/requirements.in
@@ -12,8 +12,6 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
-java==11.0.*
-pyspark==3.5.2
 confluent-kafka==2.3.*
 psycopg2-binary==2.9.*
 SQLAlchemy==1.4.*
-- 
GitLab