Added ability to create arbitrary reducers from the Reducer object …

…in dynaml-pipes module
tailhq · Dec 21, 2016 · 1058d26 · 1058d26
1 parent eb82d45
commit 1058d26
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/dynaml-pipes/src/main/scala-2.11/io/github/mandar2812/dynaml/pipes/Reducer.scala b/dynaml-pipes/src/main/scala-2.11/io/github/mandar2812/dynaml/pipes/Reducer.scala
@@ -31,4 +31,11 @@ object Reducer {
     * Represents product of values
     * */
   val :*: = ProductReducer
+
+  /**
+    * Create an arbitrary reducer
+    * */
+  def apply(reducerFunc: (Array[Double]) => Double): Reducer = new Reducer {
+    override def run(data: Array[Double]) = reducerFunc(data)
+  }
 }