package org.datavec.api.transform.ops;

import java.util.function.Consumer;
import java.util.function.Supplier;

/**
 * Created by huitseeker on 4/28/17.
 */
public interface IAggregableReduceOp<T, V> extends Consumer<T>, Supplier<V> {

    public <W extends IAggregableReduceOp<T, V>> void combine(W accu);

}

@@ -33,16 +33,45 @@
 m.ops;%0A%0A
+import java.io.Serializable;%0A
 import j
@@ -255,16 +255,30 @@
 plier%3CV%3E
+, Serializable
  %7B%0A%0A    

Mark IAggregableReduceOp as Serializable.