Recommender and mining implemented.

Author: klerisson

pom.xml

@@ -13,6 +13,7 @@
 		<module>prefrec-stratification</module>
 		<module>prefrec-pref-mining</module>
 		<module>prefrec-execution</module>
+		<module>prefrec-recommender</module>
 	</modules>
 	<dependencies>
 		<dependency>
@@ -63,7 +64,7 @@
 		<dependency>
 			<groupId>cprefminer</groupId>
 			<artifactId>cprefminermulti</artifactId>
-			<version>1.0.0</version>
+			<version>1.0.2</version>
 		</dependency>
 	</dependencies>
 

prefrec-agregation/src/main/java/br/ufu/facom/lsi/prefrec/agregation/Agregator.java

@@ -0,0 +1,122 @@
+package br.ufu.facom.lsi.prefrec.agregation;
+
+import java.util.Iterator;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+
+public class Agregator {
+
+	private Map<Long, List<Map<Long, Double[][]>>> clusterToUserMatrixScorer = new LinkedHashMap<>();
+	private Map<Double[][], List<Map<Long, Double[][]>>> concensualMatrixMap = new LinkedHashMap<>();
+
+	public Agregator(Map<Long, List<Map<Long, Double[][]>>> clusterToUserMatrixScorer) {
+		this.clusterToUserMatrixScorer = clusterToUserMatrixScorer;
+	}
+	
+	public void execute() {
+
+		try {
+			// Read input
+			//readInput();
+
+			int length = clusterToUserMatrixScorer.values().iterator().next()
+					.get(0).values().iterator().next().length;
+
+			// Reading cluster
+			for (Long id : clusterToUserMatrixScorer.keySet()) {
+				Double[][] concensualMatrix = initMatrix(length);
+
+				// Reading Matrix
+				Iterator<Map<Long, Double[][]>> it = clusterToUserMatrixScorer
+						.get(id).iterator();
+				while (it.hasNext()) {
+					Map<Long, Double[][]> map = it.next();
+					for (Double[][] temp : map.values()) {
+						for (int k = 0; k < temp.length; k++) {
+							for (int h = 0; h < temp[k].length; h++) {
+								concensualMatrix[k][h] += temp[k][h];
+							}
+						}
+					}
+				}
+
+				for (int k = 0; k < concensualMatrix.length; k++) {
+					for (int h = 0; h < concensualMatrix[k].length; h++) {
+						concensualMatrix[k][h] = concensualMatrix[k][h]
+								/ clusterToUserMatrixScorer.get(id).size();
+					}
+				}
+
+				concensualMatrixMap.put(concensualMatrix,
+						clusterToUserMatrixScorer.get(id.intValue()));
+			}
+
+			//writeConcensualMatrizMapOutput();
+
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+
+	}
+
+//	private void writeConcensualMatrizMapOutput() throws Exception {
+//
+//		try (FileOutputStream fout = new FileOutputStream("../ConcensualMatrixMap.prefrecmining");
+//				ObjectOutputStream oos = new ObjectOutputStream(fout)) {
+//
+//			oos.writeObject(concensualMatrixMap);
+//			oos.flush();
+//			fout.flush();
+//			
+//		} catch (Exception e) {
+//			throw e;
+//		}
+//	}
+
+	private Double[][] initMatrix(int length) {
+
+		Double[][] result = new Double[length][length];
+		for (int i = 0; i < length; i++) {
+			for (int j = 0; j < length; j++) {
+				result[i][j] = 0.0;
+			}
+		}
+		return result;
+	}
+
+	/**
+	 * @return the clusterToUserMatrixScorer
+	 */
+	public Map<Long, List<Map<Long, Double[][]>>> getClusterToUserMatrixScorer() {
+		return clusterToUserMatrixScorer;
+	}
+
+	/**
+	 * @return the concensualMatrixMap
+	 */
+	public Map<Double[][], List<Map<Long, Double[][]>>> getConcensualMatrixMap() {
+		return concensualMatrixMap;
+	}
+
+//	/**
+//	 * Deserialize the output file
+//	 */
+//	@SuppressWarnings("unchecked")
+//	public static void readInput() throws Exception {
+//
+//		File f = new File("../ClusterOutput.prefrecCluster");
+//
+//		try (InputStream file = new FileInputStream(f);
+//				InputStream buffer = new BufferedInputStream(file);
+//				ObjectInput input = new ObjectInputStream(buffer);) {
+//
+//			// deserialize the Map
+//			clusterToUserMatrixScorer = (Map<Long, List<Map<Long, Double[][]>>>) input
+//					.readObject();
+//
+//		} catch (Exception e) {
+//			throw e;
+//		}
+//	}
+}

prefrec-agregation/src/main/java/br/ufu/facom/lsi/prefrec/agregation/Main.java

@@ -28,6 +28,11 @@
 		<artifactId>prefrec-pref-mining</artifactId>
   		<version>0.0.1-SNAPSHOT</version>
   	</dependency>
+  	<dependency>
+  		<groupId>br.ufu.facom.lsi</groupId>
+		<artifactId>prefrec-recommender</artifactId>
+  		<version>0.0.1-SNAPSHOT</version>
+  	</dependency>
   </dependencies>
 
 </project>

prefrec-execution/pom.xml

@@ -0,0 +1,24 @@
+/**
+ * 
+ */
+package br.ufu.facom.lsi.prefrec.execution;
+
+import br.ufu.facom.lsi.prefrec.execution.crossvalidation.CrossValidation;
+
+/**
+ * @author Klerisson
+ *
+ */
+public class Main {
+
+	/**
+	 * @param args
+	 */
+	public static void main(String[] args) {
+		
+		CrossValidation cv = new CrossValidation(5);
+		cv.execute();
+		
+	}
+
+}