Add pipelines

Author: Vallasc

src/main/scala/Pipelines/EdgeDetection.scala

@@ -0,0 +1,10 @@
+package Pipelines
+
+import _root_.Algorithms.{Convolution, Invert}
+import breeze.linalg.DenseMatrix
+
+object EdgeDetection extends Pipeline (
+    List(
+        new Convolution( DenseMatrix((-1.0, -1.0, -1.0), (-1.0, 8.0, -1.0), (-1.0, -1.0, -1.0))),
+        new Invert()
+    )) {}

src/main/scala/Pipelines/GibbsDenoiser.scala

@@ -0,0 +1,9 @@
+package Pipelines
+
+import _root_.Algorithms.{Denoiser, Convolution, Invert}
+import breeze.linalg.DenseMatrix
+
+class GibbsDenoiser(denoiserRuns: Int) extends Pipeline (
+    List(
+        new Denoiser( denoiserRuns )
+    )) {}

src/main/scala/Pipelines/GibbsEdgeDetection.scala

@@ -0,0 +1,11 @@
+package Pipelines
+
+import _root_.Algorithms.{Denoiser, Convolution, Invert}
+import breeze.linalg.DenseMatrix
+
+class GibbsEdgeDetection(denoiserRuns: Int) extends Pipeline (
+    List(
+        new Denoiser( denoiserRuns ),
+        new Convolution( DenseMatrix((-1.0, -1.0, -1.0), (-1.0, 8.0, -1.0), (-1.0, -1.0, -1.0))),
+        new Invert()
+    )) {}

src/main/scala/Pipelines/MedianDenoiser.scala

@@ -0,0 +1,10 @@
+package Pipelines
+
+import _root_.Algorithms.MedianFilter
+import breeze.linalg.DenseMatrix
+
+object MedianDenoiser extends Pipeline (
+    List(
+        MedianFilter,
+        MedianFilter
+    )) {}

src/main/scala/Pipelines/Pipeline.scala

@@ -0,0 +1,14 @@
+package Pipelines
+
+import breeze.linalg.DenseMatrix
+import Algorithms.Algorithm
+import scala.annotation.tailrec
+
+class Pipeline(nodes: List[Algorithm]) extends Serializable {
+    final def run (inputMatrix :DenseMatrix[Double], tasks: List[Algorithm] = nodes): DenseMatrix[Double] = {
+        tasks match {
+            case n::nodes => run( n.run(inputMatrix), nodes)
+            case Nil => inputMatrix        
+        }
+    }
+}