@@ -0,0 +1,675 @@
+/*%0A# Licensed Materials - Property of IBM%0A# Copyright IBM Corp. 2018%0A */%0Apackage testjava;%0A%0Aimport com.ibm.streams.operator.model.InputPortSet;%0Aimport com.ibm.streams.operator.model.OutputPortSet;%0Aimport com.ibm.streams.operator.model.Libraries;%0Aimport com.ibm.streams.operator.model.PrimitiveOperator;%0A%0Aimport com.ibm.streamsx.topology.spi.operators.Pipe;%0Aimport java.util.function.Function;%0A%0A@PrimitiveOperator%0A@Libraries(%22impl/java/lib/com.ibm.streamsx.topology.jar%22)%0Apublic class MyPipe extends Pipe %7B%0A%0A    public void initialize() throws Exception %7B%0A        super.initialize();%0A           %0A        ((Function%3CObject,Object%3E) getLogic()).apply(this.submitter());%0A    %7D%0A%7D%0A

Add missing test file