package io.github.mattthomson.depijp;

import cascading.tap.Tap;

public interface DePijpTap<T> extends DePijpSource<T>, DePijpSink<T> {
    Tap createLocalTap();

    Tap createHadoopTap();

    @Override
    public default Tap createLocalSourceTap() {
        return createLocalTap();
    }

    @Override
    public default Tap createHadoopSourceTap() {
        return createHadoopTap();
    }

    @Override
    public default Tap createLocalSinkTap() {
        return createLocalTap();
    }

    @Override
    public default Tap createHadoopSinkTap() {
        return createHadoopTap();
    }
}

@@ -32,16 +32,46 @@
 epijp;%0A%0A
+import java.io.Serializable;%0A%0A
 import c
@@ -157,16 +157,30 @@
 pSink%3CT%3E
+, Serializable
  %7B%0A    T

Make taps serializable.