**Changes in Frontend**

  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 = 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

  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 {

# 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.*