update to plugin interface

Author: assaad

org.mwg.experiments.smartgridprofiling/pom.xml

@@ -103,6 +103,11 @@
             <artifactId>httpclient</artifactId>
             <version>4.4.1</version>
         </dependency>
+        <dependency>
+            <groupId>org.kevoree.mwg.plugins</groupId>
+            <artifactId>ml</artifactId>
+            <version>3-SNAPSHOT</version>
+        </dependency>
 
     </dependencies>
 </project>

org.mwg.experiments.smartgridprofiling/src/main/java/org/mwg/experiments/SmartGridSimulationTest.java

@@ -3,6 +3,7 @@
 import org.mwg.*;
 import org.mwg.core.scheduler.NoopScheduler;
 import org.mwg.experiments.smartgridprofiling.utility.GaussianProfile;
+import org.mwg.ml.MLPlugin;
 import org.mwg.ml.algorithm.profiling.GaussianSlotNode;
 
 import java.io.BufferedReader;
@@ -22,7 +23,7 @@ public class SmartGridSimulationTest {
 
     public static void main(String[] arg) {
         final Graph graph = new GraphBuilder()
-                .addNodeType(new GaussianSlotNode.Factory())
+                .withPlugin(new MLPlugin())
                 .withScheduler(new NoopScheduler())
                 .withOffHeapMemory()
                 .withMemorySize(10_000_000)

org.mwg.experiments.smartgridprofiling/src/main/java/org/mwg/experiments/eurusd/TestDbNormalThenPoly.java

@@ -1,6 +1,7 @@
 package org.mwg.experiments.eurusd;
 
 import org.mwg.*;
+import org.mwg.ml.MLPlugin;
 import org.mwg.ml.algorithm.regression.PolynomialNode;
 import org.mwg.ml.common.matrix.Matrix;
 import org.mwg.ml.common.matrix.blassolver.BlasMatrixEngine;
@@ -69,7 +70,7 @@ public static void main(String[] arg) {
                 .withMemorySize(100_000)
                 .saveEvery(10000)
                 .withStorage(new LevelDBStorage("data"))
-                .addNodeType(new PolynomialNode.Factory())
+                .withPlugin(new MLPlugin())
                 .withScheduler(new NoopScheduler()).
                         build();
         graph.connect(new Callback<Boolean>() {

org.mwg.experiments.smartgridprofiling/src/main/java/org/mwg/experiments/eurusd/TestDbPoly.java

@@ -2,6 +2,7 @@
 
 import org.mwg.*;
 import org.mwg.core.scheduler.NoopScheduler;
+import org.mwg.ml.MLPlugin;
 import org.mwg.ml.algorithm.regression.PolynomialNode;
 import org.mwg.ml.common.matrix.Matrix;
 import org.mwg.ml.common.matrix.blassolver.BlasMatrixEngine;
@@ -75,7 +76,7 @@ public static void main(String[] arg) {
                 .withMemorySize(100_000)
                 .saveEvery(10000)
                 .withStorage(new LevelDBStorage("data"))
-                .addNodeType(new PolynomialNode.Factory())
+                .withPlugin(new MLPlugin())
                 .withScheduler(new NoopScheduler()).
                         build();
 

org.mwg.experiments.smartgridprofiling/src/main/java/org/mwg/experiments/eurusd/TestDbPolyThenNormal.java

@@ -1,6 +1,7 @@
 package org.mwg.experiments.eurusd;
 
 import org.mwg.*;
+import org.mwg.ml.MLPlugin;
 import org.mwg.ml.algorithm.regression.PolynomialNode;
 import org.mwg.ml.common.matrix.Matrix;
 import org.mwg.ml.common.matrix.blassolver.BlasMatrixEngine;
@@ -75,7 +76,7 @@ public static void main(String[] arg) {
                 .withMemorySize(100_000)
                 .saveEvery(10000)
                 .withStorage(new LevelDBStorage("data"))
-                .addNodeType(new PolynomialNode.Factory())
+                .withPlugin(new MLPlugin())
                 .withScheduler(new NoopScheduler()).
                         build();
 

org.mwg.experiments.smartgridprofiling/src/main/java/org/mwg/experiments/mlNodeExperiments/TestLookup.java

@@ -2,6 +2,7 @@
 
 import org.mwg.*;
 import org.mwg.core.scheduler.NoopScheduler;
+import org.mwg.ml.MLPlugin;
 import org.mwg.ml.algorithm.profiling.GaussianMixtureNode;
 
 import java.util.ArrayList;
@@ -18,7 +19,7 @@ public static void main(String[] arg) {
                 .withMemorySize(100000)
                 .saveEvery(10000)
                 .withStorage(new LevelDBStorage("/Users/assaad/work/github/data/consumption/londonpower/leveldb"))
-                .addNodeType(new GaussianMixtureNode.Factory())
+                .withPlugin(new MLPlugin())
                 .withScheduler(new NoopScheduler())
                 .build();
 

org.mwg.experiments.smartgridprofiling/src/main/java/org/mwg/experiments/mwgrelated/TestCache.java

@@ -5,6 +5,7 @@
 import org.mwg.LevelDBStorage;
 import org.mwg.Node;
 import org.mwg.core.scheduler.NoopScheduler;
+import org.mwg.ml.MLPlugin;
 import org.mwg.ml.algorithm.profiling.GaussianMixtureNode;
 
 import java.util.Random;
@@ -18,7 +19,7 @@ public static void main(String[] arg) {
 
         final Random random=new Random();
         final Graph graph = new org.mwg.GraphBuilder()
-                .addNodeType(new GaussianMixtureNode.Factory())
+                .withPlugin(new MLPlugin())
                 .withScheduler(new NoopScheduler())
                 .withOffHeapMemory()
                 .withMemorySize(1_000_000)

org.mwg.experiments.smartgridprofiling/src/main/java/org/mwg/experiments/mwgrelated/TestWorld.java

@@ -2,6 +2,7 @@
 
 import org.mwg.*;
 import org.mwg.core.scheduler.NoopScheduler;
+import org.mwg.ml.MLPlugin;
 import org.mwg.ml.algorithm.profiling.GaussianSlotNode;
 
 import java.util.Random;
@@ -13,7 +14,7 @@ public class TestWorld {
     final static String csvdir = "/Users/assaad/work/github/data/consumption/londonpower/";
     public static void main(String[] arg){
         final Graph graph = new GraphBuilder()
-                .addNodeType(new GaussianSlotNode.Factory())
+                .withPlugin(new MLPlugin())
                 .withScheduler(new NoopScheduler())
                 .withOffHeapMemory()
                 .withMemorySize(10_000_000)

org.mwg.experiments.smartgridprofiling/src/main/java/org/mwg/experiments/mwgrelated/TestWorldForkPerf.java

@@ -2,6 +2,7 @@
 
 import org.mwg.*;
 import org.mwg.core.scheduler.NoopScheduler;
+import org.mwg.ml.MLPlugin;
 import org.mwg.ml.algorithm.profiling.GaussianSlotNode;
 
 import java.io.File;
@@ -17,7 +18,7 @@ public class TestWorldForkPerf {
     public static void main(String[] arg) {
 
         final Graph graph = new GraphBuilder()
-                .addNodeType(new GaussianSlotNode.Factory())
+                .withPlugin(new MLPlugin())
                 .withScheduler(new NoopScheduler())
                 .withOffHeapMemory()
                 .withMemorySize(10_000_000)

org.mwg.experiments.smartgridprofiling/src/main/java/org/mwg/experiments/smartgridprofiling/gmm/Graph3D.java

@@ -9,6 +9,7 @@
 import org.mwg.GraphBuilder;
 import org.mwg.LevelDBStorage;
 import org.mwg.core.scheduler.NoopScheduler;
+import org.mwg.ml.MLPlugin;
 import org.mwg.ml.ProgressReporter;
 import org.mwg.ml.algorithm.profiling.GaussianMixtureNode;
 import org.mwg.ml.algorithm.profiling.ProbaDistribution;
@@ -732,7 +733,7 @@ public static void main(String[] args) {
                 .saveEvery(10000)
                 // .withOffHeapMemory()
                 .withStorage(new LevelDBStorage("./"))
-                .addNodeType(new GaussianMixtureNode.Factory())
+                .withPlugin(new MLPlugin())
                 .withScheduler(new NoopScheduler())
                 .build();