[systemds] branch master updated: [SYSTEMDS-2602] Verify PNMF script work with MLContext

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

janardhan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/systemds.git


The following commit(s) were added to refs/heads/master by this push:
     new 0fce525  [SYSTEMDS-2602] Verify PNMF script work with MLContext
0fce525 is described below

commit 0fce525f85b1d9a7828b5c164eb17c1faf7b1934
Author: Janardhan Pulivarthi <j1...@protonmail.com>
AuthorDate: Sun Aug 9 10:02:17 2020 +0530

    [SYSTEMDS-2602] Verify PNMF script work with MLContext
    
      - Input matrices X, W, H
      - Output matrices W, H
      - R vs dml result comparison (~1e-5)
    
    Closes #1013.
---
 .../functions/mlcontext/MLContextPNMFTest.java     | 93 ++++++++++++++++++++++
 1 file changed, 93 insertions(+)

diff --git a/src/test/java/org/apache/sysds/test/functions/mlcontext/MLContextPNMFTest.java b/src/test/java/org/apache/sysds/test/functions/mlcontext/MLContextPNMFTest.java
new file mode 100644
index 0000000..a197834
--- /dev/null
+++ b/src/test/java/org/apache/sysds/test/functions/mlcontext/MLContextPNMFTest.java
@@ -0,0 +1,93 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.sysds.test.functions.mlcontext;
+
+import org.apache.log4j.Logger;
+import org.apache.sysds.api.mlcontext.MLResults;
+import org.apache.sysds.api.mlcontext.Script;
+import org.apache.sysds.runtime.matrix.data.MatrixBlock;
+import org.apache.sysds.runtime.matrix.data.MatrixValue;
+import org.apache.sysds.test.TestUtils;
+import org.junit.Test;
+
+import java.util.HashMap;
+
+import static org.apache.sysds.api.mlcontext.ScriptFactory.dmlFromFile;
+
+public class MLContextPNMFTest extends MLContextTestBase {
+	protected static Logger log = Logger.getLogger(MLContextPNMFTest.class);
+
+	protected final static String TEST_SCRIPT_PNMF = "scripts/staging/PNMF.dml";
+	private final static double sparsity1 = 0.7; // dense
+	private final static double sparsity2 = 0.1; // sparse
+
+	private final static double eps = 1e-5;
+
+	private final static int rows = 1468;
+	private final static int cols = 1207;
+	private final static int rank = 20;
+
+	private final static double epsilon = 0.000000001;//1e-9
+	private final static double maxiter = 10;
+
+	@Test
+	public void testPNMFSparse() {
+		runPNMFTestMLC(true);
+	}
+
+	@Test
+	public void testPNMFDense() {
+		runPNMFTestMLC(false);
+	}
+
+
+	private void runPNMFTestMLC(boolean sparse) {
+
+		//generate actual datasets
+		double[][] X = getRandomMatrix(rows, cols, 0, 1, sparse?sparsity2:sparsity1, 234);
+		double[][] W = getRandomMatrix(rows, rank, 0, 1e-14, 1, 71);
+		double[][] H = getRandomMatrix(rank, cols, 0, 1e-14, 1, 72);
+		writeInputMatrixWithMTD("X", X, true);
+		writeInputMatrixWithMTD("W", W, true);
+		writeInputMatrixWithMTD("H", H, true);
+
+
+		fullRScriptName = "src/test/scripts/functions/codegenalg/Algorithm_PNMF.R";
+
+		rCmd = getRCmd(inputDir(), String.valueOf(rank),
+				String.valueOf(epsilon), String.valueOf(maxiter), expectedDir());
+		runRScript(true);
+
+
+		Script pnmf = dmlFromFile(TEST_SCRIPT_PNMF);
+		pnmf.in("X", X).in("W", W).in("H", H).in("$4", rank)
+				.in("$5", epsilon).in("$6", maxiter)
+				.out("W").out("H");
+		MLResults outres = ml.execute(pnmf);
+		MatrixBlock dmlW = outres.getMatrix("W").toMatrixBlock();
+		MatrixBlock dmlH = outres.getMatrix("H").toMatrixBlock();
+
+		//compare matrices
+		HashMap<MatrixValue.CellIndex, Double> rW = readRMatrixFromFS("W");
+		HashMap<MatrixValue.CellIndex, Double> rH = readRMatrixFromFS("H");
+		TestUtils.compareMatrices(rW, dmlW, eps);
+		TestUtils.compareMatrices(rH, dmlH, eps);
+	}
+}