You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2020/05/01 13:55:50 UTC

[incubator-streampipes] branch rel/0.66.0 updated (edb43f6 -> d606f2c)

This is an automated email from the ASF dual-hosted git repository.

riemer pushed a change to branch rel/0.66.0
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.


    from edb43f6  Set sp.version in archetypes to 0.66.0
     new 73a3272  Set streampipes version to 0.66.0
     new d606f2c  Perform some cleanup

The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../README.md                                      |  2 +-
 .../README.md                                      |  2 +-
 .../streampipes-archetype-pe-sinks-flink/README.md |  2 +-
 .../streampipes-archetype-pe-sinks-jvm/README.md   |  2 +-
 .../streampipes-archetype-pe-sources/README.md     |  2 +-
 .../codegeneration/flink/ConfigGenerator.java      |  2 +-
 .../codegeneration/flink/FlinkCodeGenerator.java   |  2 +-
 .../codegeneration/flink/XmlGeneratorTest.java     | 40 ---------
 .../src/test/resources/DeploymentConfig.json       |  1 -
 .../src/test/resources/Entity.json                 |  1 -
 .../src/test/resources/expected_Config_java        | 11 ---
 .../resources/expected_FlinkSecController_java     | 42 ----------
 .../test/resources/expected_FlinkSecProgram_java   | 25 ------
 .../resources/expected_FlinkSepaController_java    | 44 ----------
 .../test/resources/expected_FlinkSepaProgram_java  | 22 -----
 .../src/test/resources/expected_Init_java          | 13 ---
 .../resources/expected_TestProjectParameters_java  | 24 ------
 .../src/test/resources/expected_TestProject_java   | 19 -----
 .../src/test/resources/expected_pom_xml            | 69 ----------------
 .../src/test/resources/expected_web_xml            | 20 -----
 .../dependency-reduced-pom.xml                     | 29 -------
 streampipes-rest/dependency-reduced-pom.xml        | 96 ----------------------
 ui/package.json                                    |  2 +-
 23 files changed, 8 insertions(+), 464 deletions(-)
 delete mode 100644 streampipes-code-generation/src/test/java/org/apache/streampipes/codegeneration/flink/XmlGeneratorTest.java
 delete mode 100644 streampipes-code-generation/src/test/resources/DeploymentConfig.json
 delete mode 100644 streampipes-code-generation/src/test/resources/Entity.json
 delete mode 100644 streampipes-code-generation/src/test/resources/expected_Config_java
 delete mode 100644 streampipes-code-generation/src/test/resources/expected_FlinkSecController_java
 delete mode 100644 streampipes-code-generation/src/test/resources/expected_FlinkSecProgram_java
 delete mode 100644 streampipes-code-generation/src/test/resources/expected_FlinkSepaController_java
 delete mode 100644 streampipes-code-generation/src/test/resources/expected_FlinkSepaProgram_java
 delete mode 100644 streampipes-code-generation/src/test/resources/expected_Init_java
 delete mode 100644 streampipes-code-generation/src/test/resources/expected_TestProjectParameters_java
 delete mode 100644 streampipes-code-generation/src/test/resources/expected_TestProject_java
 delete mode 100644 streampipes-code-generation/src/test/resources/expected_pom_xml
 delete mode 100644 streampipes-code-generation/src/test/resources/expected_web_xml
 delete mode 100644 streampipes-model-client/dependency-reduced-pom.xml
 delete mode 100644 streampipes-rest/dependency-reduced-pom.xml


[incubator-streampipes] 01/02: Set streampipes version to 0.66.0

Posted by ri...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch rel/0.66.0
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git

commit 73a32721abdbc1fd78d2d89226722cac9ecd3811
Author: Dominik Riemer <ri...@fzi.de>
AuthorDate: Fri May 1 15:48:31 2020 +0200

    Set streampipes version to 0.66.0
---
 ui/package.json | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/ui/package.json b/ui/package.json
index 21dbb10..3976364 100644
--- a/ui/package.json
+++ b/ui/package.json
@@ -1,6 +1,6 @@
 {
   "name": "apache-streampipes",
-  "version": "0.66.0-SNAPSHOT",
+  "version": "0.66.0",
   "description": "Apache StreamPipes (incubating) user interface",
   "homepage": "http://streampipes.apache.org",
   "repository": {


[incubator-streampipes] 02/02: Perform some cleanup

Posted by ri...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch rel/0.66.0
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git

commit d606f2c2e549e9650ecee884c2ab8baf203756e1
Author: Dominik Riemer <ri...@fzi.de>
AuthorDate: Fri May 1 15:55:32 2020 +0200

    Perform some cleanup
---
 .../README.md                                      |  2 +-
 .../README.md                                      |  2 +-
 .../streampipes-archetype-pe-sinks-flink/README.md |  2 +-
 .../streampipes-archetype-pe-sinks-jvm/README.md   |  2 +-
 .../streampipes-archetype-pe-sources/README.md     |  2 +-
 .../codegeneration/flink/ConfigGenerator.java      |  2 +-
 .../codegeneration/flink/FlinkCodeGenerator.java   |  2 +-
 .../codegeneration/flink/XmlGeneratorTest.java     | 40 ---------
 .../src/test/resources/DeploymentConfig.json       |  1 -
 .../src/test/resources/Entity.json                 |  1 -
 .../src/test/resources/expected_Config_java        | 11 ---
 .../resources/expected_FlinkSecController_java     | 42 ----------
 .../test/resources/expected_FlinkSecProgram_java   | 25 ------
 .../resources/expected_FlinkSepaController_java    | 44 ----------
 .../test/resources/expected_FlinkSepaProgram_java  | 22 -----
 .../src/test/resources/expected_Init_java          | 13 ---
 .../resources/expected_TestProjectParameters_java  | 24 ------
 .../src/test/resources/expected_TestProject_java   | 19 -----
 .../src/test/resources/expected_pom_xml            | 69 ----------------
 .../src/test/resources/expected_web_xml            | 20 -----
 .../dependency-reduced-pom.xml                     | 29 -------
 streampipes-rest/dependency-reduced-pom.xml        | 96 ----------------------
 22 files changed, 7 insertions(+), 463 deletions(-)

diff --git a/archetypes/streampipes-archetype-pe-processors-flink/README.md b/archetypes/streampipes-archetype-pe-processors-flink/README.md
index 92387cb..b29752e 100644
--- a/archetypes/streampipes-archetype-pe-processors-flink/README.md
+++ b/archetypes/streampipes-archetype-pe-processors-flink/README.md
@@ -23,7 +23,7 @@
 mvn archetype:generate                                  \
 			-DarchetypeGroupId=org.apache.streampipes                \
 			-DarchetypeArtifactId=streampipes-archetype-pe-processors-flink          \
-			-DarchetypeVersion=0.60.2-SNAPSHOT                \
+			-DarchetypeVersion=0.66.0               \
 			-DgroupId=my.test.groupId \
 			-DartifactId=my-test-artifact-id
 			-DclassNamePrefix=MyProcessor
diff --git a/archetypes/streampipes-archetype-pe-processors-jvm/README.md b/archetypes/streampipes-archetype-pe-processors-jvm/README.md
index fc11576..016ec38 100644
--- a/archetypes/streampipes-archetype-pe-processors-jvm/README.md
+++ b/archetypes/streampipes-archetype-pe-processors-jvm/README.md
@@ -23,7 +23,7 @@
 mvn archetype:generate                                  \
 			-DarchetypeGroupId=org.apache.streampipes                \
 			-DarchetypeArtifactId=streampipes-archetype-pe-processors-jvm          \
-			-DarchetypeVersion=0.60.2-SNAPSHOT               \
+			-DarchetypeVersion=0.66.0               \
 			-DgroupId=my.groupId \
 			-DartifactId=my-processor-jvm
 			-DclassNamePrefix=MyProcessor
diff --git a/archetypes/streampipes-archetype-pe-sinks-flink/README.md b/archetypes/streampipes-archetype-pe-sinks-flink/README.md
index 1b6301a..da69de9 100644
--- a/archetypes/streampipes-archetype-pe-sinks-flink/README.md
+++ b/archetypes/streampipes-archetype-pe-sinks-flink/README.md
@@ -23,7 +23,7 @@
 mvn archetype:generate                                  \
 			-DarchetypeGroupId=org.apache.streampipes                \
 			-DarchetypeArtifactId=streampipes-archetype-pe-sinks-flink         \
-			-DarchetypeVersion=0.60.2-SNAPSHOT                \
+			-DarchetypeVersion=0.66.0                \
 			-DgroupId=my.groupId \
 			-DartifactId=my-sink-flink
 			-DclassNamePrefix=MySink
diff --git a/archetypes/streampipes-archetype-pe-sinks-jvm/README.md b/archetypes/streampipes-archetype-pe-sinks-jvm/README.md
index a662116..428f789 100644
--- a/archetypes/streampipes-archetype-pe-sinks-jvm/README.md
+++ b/archetypes/streampipes-archetype-pe-sinks-jvm/README.md
@@ -23,7 +23,7 @@
 mvn archetype:generate                                  \
 			-DarchetypeGroupId=org.apache.streampipes                \
 			-DarchetypeArtifactId=streampipes-archetype-pe-sinks-jvm          \
-			-DarchetypeVersion=0.60.2-SNAPSHOT                \
+			-DarchetypeVersion=0.66.0                \
 			-DgroupId=my.groupId \
 			-DartifactId=my-sink-jvm
 			-DclassNamePrefix=MySink
diff --git a/archetypes/streampipes-archetype-pe-sources/README.md b/archetypes/streampipes-archetype-pe-sources/README.md
index b36eb1d..e53b3ec 100644
--- a/archetypes/streampipes-archetype-pe-sources/README.md
+++ b/archetypes/streampipes-archetype-pe-sources/README.md
@@ -23,7 +23,7 @@
 mvn archetype:generate                                  \
 			-DarchetypeGroupId=org.apache.streampipes                \
 			-DarchetypeArtifactId=streampipes-archetype-pe-sources         \
-			-DarchetypeVersion=0.60.2-SNAPSHOT                \
+			-DarchetypeVersion=0.66.0                \
 			-DgroupId=my.groupId \
 			-DartifactId=my-source
 			-DclassNamePrefix=MySource
diff --git a/streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/flink/ConfigGenerator.java b/streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/flink/ConfigGenerator.java
index c775119..b63f1f0 100644
--- a/streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/flink/ConfigGenerator.java
+++ b/streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/flink/ConfigGenerator.java
@@ -37,7 +37,7 @@ public class ConfigGenerator extends Generator {
 	public JavaFile build() {
 		FieldSpec jar = FieldSpec.builder(JFC.STRING, "JAR_FILE")
 			    .addModifiers(Modifier.PUBLIC, Modifier.FINAL, Modifier.STATIC)
-			    .initializer("$S" , "./" + name + "-0.40.3-SNAPSHOT.jar")
+			    .initializer("$S" , "./" + name + "-0.66.0.jar")
 			    .build();
 
 		FieldSpec flinkHost = FieldSpec.builder(JFC.STRING, "FLINK_HOST")
diff --git a/streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/flink/FlinkCodeGenerator.java b/streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/flink/FlinkCodeGenerator.java
index 8e66d02..a85a269 100644
--- a/streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/flink/FlinkCodeGenerator.java
+++ b/streampipes-code-generation/src/main/java/org/apache/streampipes/codegeneration/flink/FlinkCodeGenerator.java
@@ -40,7 +40,7 @@ public abstract class FlinkCodeGenerator extends ImplementationCodeGenerator {
 		super(config, element);
 		packageName = config.getGroupId() + "." + config.getArtifactId();
 		name = config.getClassNamePrefix();
-		version = "0.40.3-SNAPSHOT";
+		version = "0.66.0";
 		port = Integer.toString(config.getPort());
 		
 		src = getTempDir() + "src" + File.separator + "main" + File.separator + "java" + File.separator;
diff --git a/streampipes-code-generation/src/test/java/org/apache/streampipes/codegeneration/flink/XmlGeneratorTest.java b/streampipes-code-generation/src/test/java/org/apache/streampipes/codegeneration/flink/XmlGeneratorTest.java
deleted file mode 100644
index 2d3352e..0000000
--- a/streampipes-code-generation/src/test/java/org/apache/streampipes/codegeneration/flink/XmlGeneratorTest.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- */
-
-package org.apache.streampipes.codegeneration.flink;
-
-public class XmlGeneratorTest {
-
-//	@Test
-//	public void testGetPom() {
-//		String actual = new XmlGenerator(TV.NAME, "", "0.0.1-SNAPSHOT").getPomFile(true);
-//		String expected = Utils.readResourceFile("expected_pom_xml");
-//
-//		//TODO fix test
-////		assertEquals(expected, actual);
-//	}
-//
-//	@Test
-//	public void testGetWebXmlFile() {
-//		String actual = new XmlGenerator("", TV.PACKAGE_NAME, "").getWebXmlFile();
-//		String expected = Utils.readResourceFile("expected_web_xml");
-//
-//		assertEquals(expected, actual);
-//
-//	}
-}
diff --git a/streampipes-code-generation/src/test/resources/DeploymentConfig.json b/streampipes-code-generation/src/test/resources/DeploymentConfig.json
deleted file mode 100644
index f1c950b..0000000
--- a/streampipes-code-generation/src/test/resources/DeploymentConfig.json
+++ /dev/null
@@ -1 +0,0 @@
-{"elementType":"SEPA","outputType":"IMPLEMENTATION","runtimeType":"FLINK","deploymentMethod":"STANDALONE","groupId":"Test","artifactId":"Test","classNamePrefix":"Test","port":"80"}
diff --git a/streampipes-code-generation/src/test/resources/Entity.json b/streampipes-code-generation/src/test/resources/Entity.json
deleted file mode 100644
index ae31ac7..0000000
--- a/streampipes-code-generation/src/test/resources/Entity.json
+++ /dev/null
@@ -1 +0,0 @@
-{"outputStrategies":[{"type":"org.apache.streampipes.model.output.CustomOutputStrategy","properties":{"eventProperties":[],"outputRight":false,"elementName":"urn:streampipes.org:spi:customoutputstrategy:ghwaHf","elementId":"urn:streampipes.org:spi:customoutputstrategy:ghwaHf"}}],"category":["TRANSFORM"],"spDataStreams":[{"sourceType":"org.apache.streampipes.model.SpDataStream","eventSchema":{"eventProperties":[{"type":"org.apache.streampipes.model.schema.EventPropertyPrimitive","properti [...]
diff --git a/streampipes-code-generation/src/test/resources/expected_Config_java b/streampipes-code-generation/src/test/resources/expected_Config_java
deleted file mode 100644
index e0ee1f2..0000000
--- a/streampipes-code-generation/src/test/resources/expected_Config_java
+++ /dev/null
@@ -1,11 +0,0 @@
-package de.fzi.cep.sepa.flink.test.project;
-
-import de.fzi.cep.sepa.commons.config.ClientConfiguration;
-
-public class Config {
-  public static final String JAR_FILE = "./TestProject-0.0.1-SNAPSHOT.jar";
-
-  public static final String FLINK_HOST = ClientConfiguration.INSTANCE.getFlinkHost();
-
-  public static final int FLINK_PORT = ClientConfiguration.INSTANCE.getFlinkPort();
-}
diff --git a/streampipes-code-generation/src/test/resources/expected_FlinkSecController_java b/streampipes-code-generation/src/test/resources/expected_FlinkSecController_java
deleted file mode 100644
index 907616d..0000000
--- a/streampipes-code-generation/src/test/resources/expected_FlinkSecController_java
+++ /dev/null
@@ -1,42 +0,0 @@
-package de.fzi.cep.sepa.flink.test.project;
-
-import de.fzi.cep.sepa.client.util.StandardTransportFormat;
-import de.fzi.cep.sepa.flink.AbstractFlinkConsumerDeclarer;
-import de.fzi.cep.sepa.flink.FlinkDeploymentConfig;
-import de.fzi.cep.sepa.flink.FlinkSecRuntime;
-import de.fzi.cep.sepa.model.builder.SchemaBuilder;
-import de.fzi.cep.sepa.model.builder.StreamBuilder;
-import de.fzi.cep.sepa.model.impl.EventStream;
-import de.fzi.cep.sepa.model.impl.eventproperty.EventProperty;
-import de.fzi.cep.sepa.model.impl.graph.SecDescription;
-import de.fzi.cep.sepa.model.impl.graph.SecInvocation;
-import java.lang.Override;
-import java.util.ArrayList;
-import java.util.List;
-
-public class TestProjectController extends AbstractFlinkConsumerDeclarer {
-  @Override
-  public SecDescription declareModel() {
-    SecDescription desc = new SecDescription("sepa/testProject", "TestProject", "Example description");
-    List<EventProperty> eventProperties0 = new ArrayList<EventProperty>();
-    EventStream stream0 = StreamBuilder.createStream(null, null, "localhost:8080/sepa/testProject").schema(SchemaBuilder.create().properties(eventProperties0).build()).build();
-    desc.addEventStream(stream0);
-    desc.setSupportedGrounding(StandardTransportFormat.getSupportedGrounding());
-    return desc;
-  }
-
-  @Override
-  public boolean isVisualizable() {
-    return false;
-  }
-
-  @Override
-  public String getHtml(SecInvocation graph) {
-    return null;
-  }
-
-  @Override
-  protected FlinkSecRuntime getRuntime(SecInvocation graph) {
-    return new TestProjectProgram(graph, new FlinkDeploymentConfig(Config.JAR_FILE, Config.FLINK_HOST, Config.FLINK_PORT));
-  }
-}
diff --git a/streampipes-code-generation/src/test/resources/expected_FlinkSecProgram_java b/streampipes-code-generation/src/test/resources/expected_FlinkSecProgram_java
deleted file mode 100644
index 312915f..0000000
--- a/streampipes-code-generation/src/test/resources/expected_FlinkSecProgram_java
+++ /dev/null
@@ -1,25 +0,0 @@
-package de.fzi.cep.sepa.flink.test.project;
-
-import de.fzi.cep.sepa.flink.FlinkDeploymentConfig;
-import de.fzi.cep.sepa.flink.FlinkSecRuntime;
-import de.fzi.cep.sepa.model.impl.graph.SecInvocation;
-import java.io.Serializable;
-import java.util.Map;
-import org.apache.flink.streaming.api.datastream.DataStream;
-import org.apache.flink.streaming.api.datastream.DataStreamSink;
-
-public class TestProjectProgram extends FlinkSecRuntime implements Serializable {
-  public TestProjectProgram(SecInvocation graph) {
-    super(graph);
-  }
-
-  public TestProjectProgram(SecInvocation graph, FlinkDeploymentConfig config) {
-    super(graph, config);
-  }
-
-  @Override
-  public DataStreamSink<Map<String, Object>> getSink(DataStream<Map<String, Object>> convertedStream) {
-    // TODO implement
-    return null;
-  }
-}
diff --git a/streampipes-code-generation/src/test/resources/expected_FlinkSepaController_java b/streampipes-code-generation/src/test/resources/expected_FlinkSepaController_java
deleted file mode 100644
index 9f2dc91..0000000
--- a/streampipes-code-generation/src/test/resources/expected_FlinkSepaController_java
+++ /dev/null
@@ -1,44 +0,0 @@
-package de.fzi.cep.sepa.flink.test.project;
-
-import de.fzi.cep.sepa.client.util.StandardTransportFormat;
-import de.fzi.cep.sepa.flink.AbstractFlinkAgentDeclarer;
-import de.fzi.cep.sepa.flink.FlinkDeploymentConfig;
-import de.fzi.cep.sepa.flink.FlinkSepaRuntime;
-import de.fzi.cep.sepa.model.builder.PrimitivePropertyBuilder;
-import de.fzi.cep.sepa.model.builder.SchemaBuilder;
-import de.fzi.cep.sepa.model.builder.StreamBuilder;
-import de.fzi.cep.sepa.model.impl.EventStream;
-import de.fzi.cep.sepa.model.impl.eventproperty.EventProperty;
-import de.fzi.cep.sepa.model.impl.graph.SepaDescription;
-import de.fzi.cep.sepa.model.impl.graph.SepaInvocation;
-import de.fzi.cep.sepa.model.impl.output.AppendOutputStrategy;
-import de.fzi.cep.sepa.model.impl.output.OutputStrategy;
-import java.lang.Override;
-import java.util.ArrayList;
-import java.util.List;
-
-public class TestProjectController extends AbstractFlinkAgentDeclarer<TestProjectParameters> {
-  @Override
-  public SepaDescription declareModel() {
-    SepaDescription desc = new SepaDescription("sepa/testProject", "TestProject", "Example description");
-    List<EventProperty> eventProperties0 = new ArrayList<EventProperty>();
-    EventProperty e0 = PrimitivePropertyBuilder.createPropertyRestriction("http://test.org#mytest").build();
-    eventProperties0.add(e0);
-    EventStream stream0 = StreamBuilder.createStream("sepa/testProject", "TestProject", "Example description").schema(SchemaBuilder.create().properties(eventProperties0).build()).build();
-    desc.addEventStream(stream0);
-    List<OutputStrategy> strategies = new ArrayList<OutputStrategy>();
-    AppendOutputStrategy outputStrategy0 = new AppendOutputStrategy();
-    List<EventProperty> appendProperties = new ArrayList<EventProperty>();
-    outputStrategy0.setEventProperties(appendProperties);
-    strategies.add(outputStrategy0);
-    desc.setOutputStrategies(strategies);
-    desc.setSupportedGrounding(StandardTransportFormat.getSupportedGrounding());
-    return desc;
-  }
-
-  @Override
-  protected FlinkSepaRuntime<TestProjectParameters> getRuntime(SepaInvocation graph) {
-    TestProjectParameters staticParam = new TestProjectParameters(graph);
-    return new TestProjectProgram(staticParam, new FlinkDeploymentConfig(Config.JAR_FILE, Config.FLINK_HOST, Config.FLINK_PORT));
-  }
-}
\ No newline at end of file
diff --git a/streampipes-code-generation/src/test/resources/expected_FlinkSepaProgram_java b/streampipes-code-generation/src/test/resources/expected_FlinkSepaProgram_java
deleted file mode 100644
index 32cf68f..0000000
--- a/streampipes-code-generation/src/test/resources/expected_FlinkSepaProgram_java
+++ /dev/null
@@ -1,22 +0,0 @@
-package de.fzi.cep.sepa.flink.test.project;
-
-import de.fzi.cep.sepa.flink.FlinkDeploymentConfig;
-import de.fzi.cep.sepa.flink.FlinkSepaRuntime;
-import java.util.Map;
-import org.apache.flink.streaming.api.datastream.DataStream;
-
-public class TestProjectProgram extends FlinkSepaRuntime<TestProjectParameters> {
-  public TestProjectProgram(TestProjectParameters params) {
-    super(params);
-  }
-
-  public TestProjectProgram(TestProjectParameters params, FlinkDeploymentConfig config) {
-    super(params, config);
-  }
-
-  @Override
-  protected DataStream<Map<String, Object>> getApplicationLogic(DataStream<Map<String, Object>> messageStream) {
-    // TODO implement
-    return messageStream;
-  }
-}
\ No newline at end of file
diff --git a/streampipes-code-generation/src/test/resources/expected_Init_java b/streampipes-code-generation/src/test/resources/expected_Init_java
deleted file mode 100644
index 7e28dda..0000000
--- a/streampipes-code-generation/src/test/resources/expected_Init_java
+++ /dev/null
@@ -1,13 +0,0 @@
-package de.fzi.cep.sepa.flink.test.project;
-
-import de.fzi.cep.sepa.client.container.init.ContainerModelSubmitter;
-import de.fzi.cep.sepa.client.init.DeclarersSingleton;
-import java.lang.Override;
-
-public class TestProjectInit extends ContainerModelSubmitter {
-  @Override
-  public void init() {
-    DeclarersSingleton.getInstance().setRoute("testproject");
-    DeclarersSingleton.getInstance().add(new "TestProjectController"());
-  }
-}
\ No newline at end of file
diff --git a/streampipes-code-generation/src/test/resources/expected_TestProjectParameters_java b/streampipes-code-generation/src/test/resources/expected_TestProjectParameters_java
deleted file mode 100644
index 7c7b73e..0000000
--- a/streampipes-code-generation/src/test/resources/expected_TestProjectParameters_java
+++ /dev/null
@@ -1,24 +0,0 @@
-package de.fzi.cep.sepa.flink.test.project;
-
-import de.fzi.cep.sepa.model.impl.graph.SepaInvocation;
-import de.fzi.cep.sepa.runtime.param.BindingParameters;
-
-public class TestProjectParameters extends BindingParameters {
-  private String mappingFirst;
-
-  private String freeText;
-
-  public TestProjectParameters(SepaInvocation graph, String mappingFirst, String freeText) {
-    super(graph);
-    this.mappingFirst = mappingFirst;
-    this.freeText = freeText;
-  }
-
-  public String getMappingFirst() {
-    return mappingFirst;
-  }
-
-  public String getFreeText() {
-    return freeText;
-  }
-}
\ No newline at end of file
diff --git a/streampipes-code-generation/src/test/resources/expected_TestProject_java b/streampipes-code-generation/src/test/resources/expected_TestProject_java
deleted file mode 100644
index 6d41c32..0000000
--- a/streampipes-code-generation/src/test/resources/expected_TestProject_java
+++ /dev/null
@@ -1,19 +0,0 @@
-package de.fzi.cep.sepa.flink.test.project;
-
-import java.util.Map;
-import org.apache.flink.api.common.functions.FlatMapFunction;
-import org.apache.flink.util.Collector;
-
-public class TestProject implements FlatMapFunction<Map<String, Object>, Map<String, Object>> {
-  private String propertyName;
-
-  public TestProject(String propertyName) {
-    this.propertyName = propertyName;
-  }
-
-  @Override
-  public void flatMap(Map<String, Object> in, Collector<Map<String, Object>> out) throws Exception {
-    Object o = in.get(propertyName);
-    //TODO implement
-  }
-}
diff --git a/streampipes-code-generation/src/test/resources/expected_pom_xml b/streampipes-code-generation/src/test/resources/expected_pom_xml
deleted file mode 100644
index 08b720f..0000000
--- a/streampipes-code-generation/src/test/resources/expected_pom_xml
+++ /dev/null
@@ -1,69 +0,0 @@
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-	<modelVersion>4.0.0</modelVersion>
-	<artifactId>testproject</artifactId>
-	<groupId>de.fzi.cep.sepa</groupId>
-	<version>0.0.1-SNAPSHOT</version>
-	<packaging>war</packaging>
-
-	<repositories>
-		<repository>
-			<id>laus</id>
-			<name>nexus repository</name>
-			<url>http://laus.fzi.de/nexus/content/repositories/public/</url>
-			<releases>
-				<enabled>true</enabled>
-				<updatePolicy>daily</updatePolicy>
-			</releases>
-			<snapshots>
-				<enabled>true</enabled>
-			</snapshots>
-		</repository>
-	</repositories>
-
-	<dependencies>
-		<dependency>
-			<groupId>de.fzi.cep.sepa</groupId>
-			<artifactId>semantic-epa</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
-		</dependency>
-		<dependency>
-			<groupId>de.fzi.cep.sepa</groupId>
-			<artifactId>semantic-epa-runtime-flat</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
-		</dependency>
-		<dependency>
-			<groupId>de.fzi.cep.sepa</groupId>
-			<artifactId>semantic-epa-commons</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
-		</dependency>
-		<dependency>
-			<groupId>de.fzi.cep.sepa</groupId>
-			<artifactId>semantic-epa-flink</artifactId>
-			<version>0.0.1-SNAPSHOT</version>
-		</dependency>
-	</dependencies>
-	<build>
-		<plugins>
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-compiler-plugin</artifactId>
-				<version>3.1</version>
-				<configuration>
-					<source>1.8</source>
-					<target>1.8</target>
-					<encoding>UTF-8</encoding>
-				</configuration>
-			</plugin>
-			<plugin>
-				<groupId>org.apache.maven.plugins</groupId>
-				<artifactId>maven-war-plugin</artifactId>
-				<version>2.4</version>
-				<configuration>
-					<webXml>WebContent\WEB-INF\web.xml</webXml>
-				</configuration>
-			</plugin>
-		</plugins>
-		<finalName>testproject</finalName>
-	</build>
-</project>
\ No newline at end of file
diff --git a/streampipes-code-generation/src/test/resources/expected_web_xml b/streampipes-code-generation/src/test/resources/expected_web_xml
deleted file mode 100644
index 059f4ea..0000000
--- a/streampipes-code-generation/src/test/resources/expected_web_xml
+++ /dev/null
@@ -1,20 +0,0 @@
-<web-app>
-	<display-name>Archetype Created Web Application</display-name>
-​
-	<context-param>
-		<param-name>org.restlet.application</param-name>
-		<param-value>
-              de.fzi.cep.sepa.flink.test.project.Init
-		</param-value>
-	</context-param>
-	<servlet>
-		<servlet-name>RestletServlet</servlet-name>
-		<servlet-class>
-			org.restlet.ext.servlet.ServerServlet
-		</servlet-class>
-	</servlet>
-	<servlet-mapping>
-		<servlet-name>RestletServlet</servlet-name>
-		<url-pattern>/</url-pattern>
-	</servlet-mapping>
-</web-app>
\ No newline at end of file
diff --git a/streampipes-model-client/dependency-reduced-pom.xml b/streampipes-model-client/dependency-reduced-pom.xml
deleted file mode 100644
index 409de5a..0000000
--- a/streampipes-model-client/dependency-reduced-pom.xml
+++ /dev/null
@@ -1,29 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-  ~ Licensed to the Apache Software Foundation (ASF) under one or more
-  ~ contributor license agreements.  See the NOTICE file distributed with
-  ~ this work for additional information regarding copyright ownership.
-  ~ The ASF licenses this file to You under the Apache License, Version 2.0
-  ~ (the "License"); you may not use this file except in compliance with
-  ~ the License.  You may obtain a copy of the License at
-  ~
-  ~    http://www.apache.org/licenses/LICENSE-2.0
-  ~
-  ~ Unless required by applicable law or agreed to in writing, software
-  ~ distributed under the License is distributed on an "AS IS" BASIS,
-  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  ~ See the License for the specific language governing permissions and
-  ~ limitations under the License.
-  ~
-  -->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
-  <parent>
-    <artifactId>semantic-epa-backend</artifactId>
-    <groupId>de.fzi.cep.sepa</groupId>
-    <version>0.0.1-SNAPSHOT</version>
-  </parent>
-  <modelVersion>4.0.0</modelVersion>
-  <artifactId>semantic-epa-model-client</artifactId>
-</project>
-
diff --git a/streampipes-rest/dependency-reduced-pom.xml b/streampipes-rest/dependency-reduced-pom.xml
deleted file mode 100644
index eaf193e..0000000
--- a/streampipes-rest/dependency-reduced-pom.xml
+++ /dev/null
@@ -1,96 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-  ~ Licensed to the Apache Software Foundation (ASF) under one or more
-  ~ contributor license agreements.  See the NOTICE file distributed with
-  ~ this work for additional information regarding copyright ownership.
-  ~ The ASF licenses this file to You under the Apache License, Version 2.0
-  ~ (the "License"); you may not use this file except in compliance with
-  ~ the License.  You may obtain a copy of the License at
-  ~
-  ~    http://www.apache.org/licenses/LICENSE-2.0
-  ~
-  ~ Unless required by applicable law or agreed to in writing, software
-  ~ distributed under the License is distributed on an "AS IS" BASIS,
-  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  ~ See the License for the specific language governing permissions and
-  ~ limitations under the License.
-  ~
-  -->
-
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
-  <parent>
-    <artifactId>semantic-epa-backend</artifactId>
-    <groupId>de.fzi.cep.sepa</groupId>
-    <version>0.0.1-SNAPSHOT</version>
-  </parent>
-  <modelVersion>4.0.0</modelVersion>
-  <artifactId>semantic-epa-rest</artifactId>
-  <name>Semantic Event Processing REST API</name>
-  <dependencies>
-    <dependency>
-      <groupId>com.jayway.restassured</groupId>
-      <artifactId>rest-assured</artifactId>
-      <version>2.3.2</version>
-      <scope>test</scope>
-      <exclusions>
-        <exclusion>
-          <artifactId>logback-classic</artifactId>
-          <groupId>ch.qos.logback</groupId>
-        </exclusion>
-        <exclusion>
-          <artifactId>httpclient</artifactId>
-          <groupId>org.apache.httpcomponents</groupId>
-        </exclusion>
-        <exclusion>
-          <artifactId>httpcore</artifactId>
-          <groupId>org.apache.httpcomponents</groupId>
-        </exclusion>
-        <exclusion>
-          <artifactId>groovy</artifactId>
-          <groupId>org.codehaus.groovy</groupId>
-        </exclusion>
-        <exclusion>
-          <artifactId>groovy-xml</artifactId>
-          <groupId>org.codehaus.groovy</groupId>
-        </exclusion>
-        <exclusion>
-          <artifactId>httpmime</artifactId>
-          <groupId>org.apache.httpcomponents</groupId>
-        </exclusion>
-        <exclusion>
-          <artifactId>hamcrest-core</artifactId>
-          <groupId>org.hamcrest</groupId>
-        </exclusion>
-        <exclusion>
-          <artifactId>hamcrest-library</artifactId>
-          <groupId>org.hamcrest</groupId>
-        </exclusion>
-        <exclusion>
-          <artifactId>tagsoup</artifactId>
-          <groupId>org.ccil.cowan.tagsoup</groupId>
-        </exclusion>
-        <exclusion>
-          <artifactId>json-path</artifactId>
-          <groupId>com.jayway.restassured</groupId>
-        </exclusion>
-        <exclusion>
-          <artifactId>xml-path</artifactId>
-          <groupId>com.jayway.restassured</groupId>
-        </exclusion>
-      </exclusions>
-    </dependency>
-    <dependency>
-      <groupId>junit</groupId>
-      <artifactId>junit</artifactId>
-      <version>4.11</version>
-      <scope>test</scope>
-      <exclusions>
-        <exclusion>
-          <artifactId>hamcrest-core</artifactId>
-          <groupId>org.hamcrest</groupId>
-        </exclusion>
-      </exclusions>
-    </dependency>
-  </dependencies>
-</project>
-