[streaming] Package naming refactor

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/JobGraphBuilder.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/JobGraphBuilder.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.api;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -14,6 +14,9 @@ import eu.stratosphere.nephele.jobgraph.JobOutputVertex;
 import eu.stratosphere.nephele.jobgraph.JobTaskVertex;
 import eu.stratosphere.nephele.template.AbstractInputTask;
 import eu.stratosphere.pact.runtime.task.util.TaskConfig;
+import eu.stratosphere.streaming.api.invokable.UserSinkInvokable;
+import eu.stratosphere.streaming.api.invokable.UserSourceInvokable;
+import eu.stratosphere.streaming.api.invokable.UserTaskInvokable;
 import eu.stratosphere.streaming.partitioner.DefaultPartitioner;
 import eu.stratosphere.types.Record;
 
@@ -89,6 +92,7 @@ public class JobGraphBuilder {
 		components.put(sinkName, sink);
 	}
 
+	//TODO refactor connects
 	public void connect(String upStreamComponentName,
       String downStreamComponentName,
       ChannelType channelType) {

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/StreamSink.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/StreamSink.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.api;
 
 import eu.stratosphere.nephele.io.RecordReader;
 import eu.stratosphere.nephele.template.AbstractOutputTask;
+import eu.stratosphere.streaming.api.invokable.UserSinkInvokable;
+import eu.stratosphere.streaming.test.TestSinkInvokable;
 import eu.stratosphere.types.Record;
 
 public class StreamSink extends AbstractOutputTask{

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/StreamSource.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/StreamSource.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.api;
 
 import eu.stratosphere.nephele.io.ChannelSelector;
 import eu.stratosphere.nephele.io.RecordWriter;
 import eu.stratosphere.nephele.template.AbstractInputTask;
+import eu.stratosphere.streaming.api.invokable.UserSourceInvokable;
 import eu.stratosphere.streaming.partitioner.DefaultPartitioner;
+import eu.stratosphere.streaming.test.RandIS;
+import eu.stratosphere.streaming.test.TestSourceInvokable;
 import eu.stratosphere.types.Record;
 
 public class StreamSource extends AbstractInputTask<RandIS> {

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/StreamTask.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/StreamTask.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.api;
 
 import java.util.LinkedList;
 import java.util.List;
@@ -7,7 +7,9 @@ import eu.stratosphere.nephele.io.ChannelSelector;
 import eu.stratosphere.nephele.io.RecordReader;
 import eu.stratosphere.nephele.io.RecordWriter;
 import eu.stratosphere.nephele.template.AbstractTask;
+import eu.stratosphere.streaming.api.invokable.UserTaskInvokable;
 import eu.stratosphere.streaming.partitioner.DefaultPartitioner;
+import eu.stratosphere.streaming.test.TestTaskInvokable;
 import eu.stratosphere.types.Record;
 
 public class StreamTask extends AbstractTask {

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/DefaultSourceInvokable.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/invokable/DefaultSourceInvokable.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.api.invokable;
 
 import eu.stratosphere.nephele.io.RecordWriter;
 import eu.stratosphere.types.Record;

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/DefaultTaskInvokable.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/invokable/DefaultTaskInvokable.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.api.invokable;
 
 import eu.stratosphere.nephele.io.RecordWriter;
 import eu.stratosphere.types.Record;

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/UserSinkInvokable.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/invokable/UserSinkInvokable.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.api.invokable;
 
 import eu.stratosphere.nephele.io.RecordReader;
 import eu.stratosphere.types.Record;

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/UserSourceInvokable.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/invokable/UserSourceInvokable.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.api.invokable;
 
 import eu.stratosphere.nephele.io.RecordWriter;
 import eu.stratosphere.types.Record;

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/UserTaskInvokable.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/invokable/UserTaskInvokable.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.api.invokable;
 
 import eu.stratosphere.nephele.io.RecordWriter;
 import eu.stratosphere.types.Record;

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/MyStream.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/test/MyStream.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.test;
 
 import eu.stratosphere.nephele.io.channels.ChannelType;
 import eu.stratosphere.nephele.jobgraph.JobGraph;
-import eu.stratosphere.streaming.JobGraphBuilder.Partitioning;
+import eu.stratosphere.streaming.api.JobGraphBuilder;
+import eu.stratosphere.streaming.api.JobGraphBuilder.Partitioning;
 import eu.stratosphere.test.util.TestBase2;
 
 public class MyStream extends TestBase2 {
@@ -15,10 +16,10 @@ public class MyStream extends TestBase2 {
     graphBuilder.setTask("cellTask", TestTaskInvokable.class, Partitioning.BROADCAST, 2);
     graphBuilder.setSink("sink", TestSinkInvokable.class);
     
-    graphBuilder.connect("infoSource", "cellTask",Partitioning.BROADCAST, ChannelType.INMEMORY);
-    graphBuilder.connect("querySource", "cellTask",Partitioning.BROADCAST, ChannelType.INMEMORY);
-    graphBuilder.connect("cellTask", "sink",Partitioning.BROADCAST, ChannelType.INMEMORY);
-   
+    graphBuilder.connect("infoSource", "cellTask", Partitioning.BROADCAST, ChannelType.INMEMORY);
+    graphBuilder.connect("querySource", "cellTask", Partitioning.BROADCAST, ChannelType.INMEMORY);
+    graphBuilder.connect("cellTask", "sink", Partitioning.BROADCAST, ChannelType.INMEMORY);
+
     return graphBuilder.getJobGraph();
   }
 

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/QuerySourceInvokable.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/test/QuerySourceInvokable.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.test;
 
 import eu.stratosphere.nephele.io.RecordWriter;
+import eu.stratosphere.streaming.api.invokable.UserSourceInvokable;
 import eu.stratosphere.types.IntValue;
 import eu.stratosphere.types.LongValue;
 import eu.stratosphere.types.Record;

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/RandIS.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/test/RandIS.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.test;
 
 import java.io.DataInput;
 import java.io.DataOutput;

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/TestSinkInvokable.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/test/TestSinkInvokable.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.test;
 
 import eu.stratosphere.nephele.io.RecordReader;
+import eu.stratosphere.streaming.api.invokable.UserSinkInvokable;
 import eu.stratosphere.types.Record;
 import eu.stratosphere.types.StringValue;
 

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/TestSourceInvokable.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/test/TestSourceInvokable.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.test;
 
 
 import eu.stratosphere.nephele.io.RecordWriter;
+import eu.stratosphere.streaming.api.invokable.UserSourceInvokable;
 import eu.stratosphere.types.IntValue;
 import eu.stratosphere.types.LongValue;
 import eu.stratosphere.types.Record;

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/TestTaskInvokable.java → flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/test/TestTaskInvokable.java

-package eu.stratosphere.streaming;
+package eu.stratosphere.streaming.test;
 
 import eu.stratosphere.nephele.io.RecordWriter;
+import eu.stratosphere.streaming.api.invokable.UserTaskInvokable;
 import eu.stratosphere.streaming.cellinfo.WorkerEngineExact;
 import eu.stratosphere.types.IntValue;
 import eu.stratosphere.types.LongValue;