// Path: ooso/src/main/java/fr/d2si/ooso/utils/JobInfo.java
// public class JobInfo {
//     private String jobId;
//     private String jobInputBucket;
//     private String mapperOutputBucket;
//     private String reducerOutputBucket;
//     private String mapperFunctionName;
//     private String mappersDriverFunctionName;
//     private String mappersListenerFunctionName;
//     private String reducerFunctionName;
//     private String reducersDriverFunctionName;
//     private String reducersListenerFunctionName;
//     private String statusTable;
//     private String mapperMemory;
//     private String reducerMemory;
//     private String mapperForceBatchSize;
//     private String reducerForceBatchSize;
//     private String disableReducer;
// 
//     public JobInfo() {
//     }
// 
//     public JobInfo(String jobId, String jobInputBucket, String mapperOutputBucket, String reducerOutputBucket, String mapperFunctionName, String mappersDriverFunctionName, String mappersListenerFunctionName, String reducerFunctionName, String reducersDriverFunctionName, String reducersListenerFunctionName, String statusTable, String mapperMemory, String reducerMemory, String mapperForceBatchSize, String reducerForceBatchSize, String disableReducer) {
//         this.jobId = jobId;
//         this.jobInputBucket = jobInputBucket;
//         this.mapperOutputBucket = mapperOutputBucket;
//         this.reducerOutputBucket = reducerOutputBucket;
//         this.mapperFunctionName = mapperFunctionName;
//         this.mappersDriverFunctionName = mappersDriverFunctionName;
//         this.mappersListenerFunctionName = mappersListenerFunctionName;
//         this.reducerFunctionName = reducerFunctionName;
//         this.reducersDriverFunctionName = reducersDriverFunctionName;
//         this.reducersListenerFunctionName = reducersListenerFunctionName;
//         this.statusTable = statusTable;
//         this.mapperMemory = mapperMemory;
//         this.reducerMemory = reducerMemory;
//         this.mapperForceBatchSize = mapperForceBatchSize;
//         this.reducerForceBatchSize = reducerForceBatchSize;
//         this.disableReducer = disableReducer;
//     }
// 
//     public String getJobInputBucket() {
//         return jobInputBucket;
//     }
// 
//     public void setJobInputBucket(String jobInputBucket) {
//         this.jobInputBucket = jobInputBucket;
//     }
// 
//     public String getMapperOutputBucket() {
//         return mapperOutputBucket;
//     }
// 
//     public void setMapperOutputBucket(String mapperOutputBucket) {
//         this.mapperOutputBucket = mapperOutputBucket;
//     }
// 
//     public String getReducerOutputBucket() {
//         return reducerOutputBucket;
//     }
// 
//     public void setReducerOutputBucket(String reducerOutputBucket) {
//         this.reducerOutputBucket = reducerOutputBucket;
//     }
// 
//     public String getMapperFunctionName() {
//         return mapperFunctionName;
//     }
// 
//     public void setMapperFunctionName(String mapperFunctionName) {
//         this.mapperFunctionName = mapperFunctionName;
//     }
// 
//     public String getReducerFunctionName() {
//         return reducerFunctionName;
//     }
// 
//     public void setReducerFunctionName(String reducerFunctionName) {
//         this.reducerFunctionName = reducerFunctionName;
//     }
// 
//     public String getStatusTable() {
//         return statusTable;
//     }
// 
//     public void setStatusTable(String statusTable) {
//         this.statusTable = statusTable;
//     }
// 
//     public String getJobId() {
//         return jobId;
//     }
// 
//     public void setJobId(String jobId) {
//         this.jobId = jobId;
//     }
// 
//     public int getMapperMemory() {
//         return Integer.parseInt(mapperMemory);
//     }
// 
//     public void setMapperMemory(String mapperMemory) {
//         this.mapperMemory = mapperMemory;
//     }
// 
//     public int getReducerMemory() {
//         return Integer.parseInt(reducerMemory);
//     }
// 
//     public void setReducerMemory(String reducerMemory) {
//         this.reducerMemory = reducerMemory;
//     }
// 
//     public int getMapperForceBatchSize() {
//         return Integer.parseInt(mapperForceBatchSize);
//     }
// 
//     public void setMapperForceBatchSize(String mapperForceBatchSize) {
//         this.mapperForceBatchSize = mapperForceBatchSize;
//     }
// 
//     public int getReducerForceBatchSize() {
//         return Integer.parseInt(reducerForceBatchSize);
//     }
// 
//     public void setReducerForceBatchSize(String reducerForceBatchSize) {
//         this.reducerForceBatchSize = reducerForceBatchSize;
//     }
// 
//     public boolean getDisableReducer() {
//         return Boolean.parseBoolean(disableReducer);
//     }
// 
//     public void setDisableReducer(String disableReducer) {
//         this.disableReducer = disableReducer;
//     }
// 
//     public String getMappersDriverFunctionName() {
//         return mappersDriverFunctionName;
//     }
// 
//     public void setMappersDriverFunctionName(String mappersDriverFunctionName) {
//         this.mappersDriverFunctionName = mappersDriverFunctionName;
//     }
// 
//     public String getMappersListenerFunctionName() {
//         return mappersListenerFunctionName;
//     }
// 
//     public void setMappersListenerFunctionName(String mappersListenerFunctionName) {
//         this.mappersListenerFunctionName = mappersListenerFunctionName;
//     }
// 
//     public String getReducersDriverFunctionName() {
//         return reducersDriverFunctionName;
//     }
// 
//     public void setReducersDriverFunctionName(String reducersDriverFunctionName) {
//         this.reducersDriverFunctionName = reducersDriverFunctionName;
//     }
// 
//     public String getReducersListenerFunctionName() {
//         return reducersListenerFunctionName;
//     }
// 
//     public void setReducersListenerFunctionName(String reducersListenerFunctionName) {
//         this.reducersListenerFunctionName = reducersListenerFunctionName;
//     }
// }


import fr.d2si.ooso.utils.JobInfo;
package fr.d2si.ooso.reducers_listener;


public class ReducersListenerInfo {
    private int step;
    private int expectedFilesCount;
    private String reducerInBase64;
    private JobInfo jobInfo;

    public JobInfo getJobInfo() {
        return jobInfo;
    }

    public void setJobInfo(JobInfo jobInfo) {
        this.jobInfo = jobInfo;
    }

// Path: ooso/src/main/java/fr/d2si/ooso/utils/JobInfo.java
// public class JobInfo {
//     private String jobId;
//     private String jobInputBucket;
//     private String mapperOutputBucket;
//     private String reducerOutputBucket;
//     private String mapperFunctionName;
//     private String mappersDriverFunctionName;
//     private String mappersListenerFunctionName;
//     private String reducerFunctionName;
//     private String reducersDriverFunctionName;
//     private String reducersListenerFunctionName;
//     private String statusTable;
//     private String mapperMemory;
//     private String reducerMemory;
//     private String mapperForceBatchSize;
//     private String reducerForceBatchSize;
//     private String disableReducer;
// 
//     public JobInfo() {
//     }
// 
//     public JobInfo(String jobId, String jobInputBucket, String mapperOutputBucket, String reducerOutputBucket, String mapperFunctionName, String mappersDriverFunctionName, String mappersListenerFunctionName, String reducerFunctionName, String reducersDriverFunctionName, String reducersListenerFunctionName, String statusTable, String mapperMemory, String reducerMemory, String mapperForceBatchSize, String reducerForceBatchSize, String disableReducer) {
//         this.jobId = jobId;
//         this.jobInputBucket = jobInputBucket;
//         this.mapperOutputBucket = mapperOutputBucket;
//         this.reducerOutputBucket = reducerOutputBucket;
//         this.mapperFunctionName = mapperFunctionName;
//         this.mappersDriverFunctionName = mappersDriverFunctionName;
//         this.mappersListenerFunctionName = mappersListenerFunctionName;
//         this.reducerFunctionName = reducerFunctionName;
//         this.reducersDriverFunctionName = reducersDriverFunctionName;
//         this.reducersListenerFunctionName = reducersListenerFunctionName;
//         this.statusTable = statusTable;
//         this.mapperMemory = mapperMemory;
//         this.reducerMemory = reducerMemory;
//         this.mapperForceBatchSize = mapperForceBatchSize;
//         this.reducerForceBatchSize = reducerForceBatchSize;
//         this.disableReducer = disableReducer;
//     }
// 
//     public String getJobInputBucket() {
//         return jobInputBucket;
//     }
// 
//     public void setJobInputBucket(String jobInputBucket) {
//         this.jobInputBucket = jobInputBucket;
//     }
// 
//     public String getMapperOutputBucket() {
//         return mapperOutputBucket;
//     }
// 
//     public void setMapperOutputBucket(String mapperOutputBucket) {
//         this.mapperOutputBucket = mapperOutputBucket;
//     }
// 
//     public String getReducerOutputBucket() {
//         return reducerOutputBucket;
//     }
// 
//     public void setReducerOutputBucket(String reducerOutputBucket) {
//         this.reducerOutputBucket = reducerOutputBucket;
//     }
// 
//     public String getMapperFunctionName() {
//         return mapperFunctionName;
//     }
// 
//     public void setMapperFunctionName(String mapperFunctionName) {
//         this.mapperFunctionName = mapperFunctionName;
//     }
// 
//     public String getReducerFunctionName() {
//         return reducerFunctionName;
//     }
// 
//     public void setReducerFunctionName(String reducerFunctionName) {
//         this.reducerFunctionName = reducerFunctionName;
//     }
// 
//     public String getStatusTable() {
//         return statusTable;
//     }
// 
//     public void setStatusTable(String statusTable) {
//         this.statusTable = statusTable;
//     }
// 
//     public String getJobId() {
//         return jobId;
//     }
// 
//     public void setJobId(String jobId) {
//         this.jobId = jobId;
//     }
// 
//     public int getMapperMemory() {
//         return Integer.parseInt(mapperMemory);
//     }
// 
//     public void setMapperMemory(String mapperMemory) {
//         this.mapperMemory = mapperMemory;
//     }
// 
//     public int getReducerMemory() {
//         return Integer.parseInt(reducerMemory);
//     }
// 
//     public void setReducerMemory(String reducerMemory) {
//         this.reducerMemory = reducerMemory;
//     }
// 
//     public int getMapperForceBatchSize() {
//         return Integer.parseInt(mapperForceBatchSize);
//     }
// 
//     public void setMapperForceBatchSize(String mapperForceBatchSize) {
//         this.mapperForceBatchSize = mapperForceBatchSize;
//     }
// 
//     public int getReducerForceBatchSize() {
//         return Integer.parseInt(reducerForceBatchSize);
//     }
// 
//     public void setReducerForceBatchSize(String reducerForceBatchSize) {
//         this.reducerForceBatchSize = reducerForceBatchSize;
//     }
// 
//     public boolean getDisableReducer() {
//         return Boolean.parseBoolean(disableReducer);
//     }
// 
//     public void setDisableReducer(String disableReducer) {
//         this.disableReducer = disableReducer;
//     }
// 
//     public String getMappersDriverFunctionName() {
//         return mappersDriverFunctionName;
//     }
// 
//     public void setMappersDriverFunctionName(String mappersDriverFunctionName) {
//         this.mappersDriverFunctionName = mappersDriverFunctionName;
//     }
// 
//     public String getMappersListenerFunctionName() {
//         return mappersListenerFunctionName;
//     }
// 
//     public void setMappersListenerFunctionName(String mappersListenerFunctionName) {
//         this.mappersListenerFunctionName = mappersListenerFunctionName;
//     }
// 
//     public String getReducersDriverFunctionName() {
//         return reducersDriverFunctionName;
//     }
// 
//     public void setReducersDriverFunctionName(String reducersDriverFunctionName) {
//         this.reducersDriverFunctionName = reducersDriverFunctionName;
//     }
// 
//     public String getReducersListenerFunctionName() {
//         return reducersListenerFunctionName;
//     }
// 
//     public void setReducersListenerFunctionName(String reducersListenerFunctionName) {
//         this.reducersListenerFunctionName = reducersListenerFunctionName;
//     }
// }


// Path: ooso/src/main/java/fr/d2si/ooso/reducers_listener/ReducersListenerInfo.java
import fr.d2si.ooso.utils.JobInfo;

package fr.d2si.ooso.reducers_listener;


public class ReducersListenerInfo {
    private int step;
    private int expectedFilesCount;
    private String reducerInBase64;
    private JobInfo jobInfo;

    public JobInfo getJobInfo() {
        return jobInfo;
    }

    public void setJobInfo(JobInfo jobInfo) {
        this.jobInfo = jobInfo;
    }

    public ReducersListenerInfo() {