@@ -0,0 +1,483 @@
+package eu.stratosphere.streaming.api.function;%0D%0A%0D%0Aimport eu.stratosphere.api.java.tuple.Tuple;%0D%0A%0D%0A/**%0D%0A * Dummy implementation of the SinkFunction writing every tuple to the standard%0D%0A * output. Used for print.%0D%0A * %0D%0A * @param %3CIN%3E%0D%0A *            Input tuple type%0D%0A */%0D%0Apublic class PrintSinkFunction%3CIN extends Tuple%3E extends SinkFunction%3CIN%3E %7B%0D%0A%09private static final long serialVersionUID = 1L;%0D%0A%0D%0A%09@Override%0D%0A%09public void invoke(IN tuple) %7B%0D%0A%09%09System.out.println(tuple);%0D%0A%09%7D%0D%0A%0D%0A%7D

package restructure