flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbala...@apache.org
Subject [5/5] incubator-flink git commit: [FLINK-1204] [streaming] Individual, self-contained packaging for streaming examples
Date Thu, 13 Nov 2014 15:06:18 GMT
[FLINK-1204] [streaming] Individual, self-contained packaging for streaming examples


Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/c6dd9b10
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/c6dd9b10
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/c6dd9b10

Branch: refs/heads/master
Commit: c6dd9b104dad2fdf35d3bbca27779060792dc877
Parents: 537d6f6
Author: Marton Balassi <mbalassi@apache.org>
Authored: Mon Nov 10 14:56:45 2014 +0100
Committer: mbalassi <mbalassi@apache.org>
Committed: Thu Nov 13 15:24:04 2014 +0100

----------------------------------------------------------------------
 .../flink-streaming-examples/pom.xml            | 210 ++++++++++++++++++-
 1 file changed, 209 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/c6dd9b10/flink-addons/flink-streaming/flink-streaming-examples/pom.xml
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/pom.xml b/flink-addons/flink-streaming/flink-streaming-examples/pom.xml
index 43a7430..f1480de 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/pom.xml
+++ b/flink-addons/flink-streaming/flink-streaming-examples/pom.xml
@@ -56,14 +56,222 @@ under the License.
 
 	<build>
 		<plugins>
+			
+			<!-- get default data from flink-java-examples package -->
+			<plugin>
+         			<groupId>org.apache.maven.plugins</groupId>
+         			<artifactId>maven-dependency-plugin</artifactId>
+         			<version>2.9</version>
+         			<executions>
+           				<execution>
+             					<id>unpack</id>
+             					<phase>package</phase>
+             					<goals>
+               						<goal>unpack</goal>
+             					</goals>
+             					<configuration>
+               						<artifactItems>
+                 						<artifactItem>
+                   							<groupId>org.apache.flink</groupId>
+                   							<artifactId>flink-java-examples</artifactId>
+                   							<version>${project.version}</version>
+                   							<type>jar</type>
+                   							<overWrite>false</overWrite>
+                   							<outputDirectory>${project.build.directory}/classes</outputDirectory>
+                   							<includes>org/apache/flink/examples/java/wordcount/util/WordCountData.class</includes>
+						                </artifactItem>
+               						</artifactItems>
+             					</configuration>
+           				</execution>
+         			</executions>
+       			</plugin>
+
+			<!-- self-contained jars for each example -->
 			<plugin>
 				<groupId>org.apache.maven.plugins</groupId>
 				<artifactId>maven-jar-plugin</artifactId>
+				
 				<executions>
+					<!-- Basic -->
+					<execution>
+						<id>Basic</id>
+						<phase>package</phase>
+						<goals>
+							<goal>jar</goal>
+						</goals>
+						<configuration>
+							<classifier>Basic</classifier>
+
+							<archive>
+								<manifestEntries>
+									<program-class>org.apache.flink.streaming.examples.basictopology.BasicTopology</program-class>
+								</manifestEntries>
+							</archive>
+
+							<includes>
+								<include>org/apache/flink/streaming/examples/basictopology/BasicTopology.class</include>
+								<include>org/apache/flink/examples/java/wordcount/util/WordCountData.class</include>
			
+							</includes>
+						</configuration>
+					</execution>
+
+					<!-- CellInfo -->
 					<execution>
+						<id>CellInfo</id>
+						<phase>package</phase>
 						<goals>
-							<goal>test-jar</goal>
+							<goal>jar</goal>
 						</goals>
+						<configuration>
+							<classifier>CellInfo</classifier>
+
+							<archive>
+								<manifestEntries>
+									<program-class>org.apache.flink.streaming.examples.cellinfo.CellInfoLocal</program-class>
+								</manifestEntries>
+							</archive>
+
+							<includes>
+								<include>org/apache/flink/streaming/examples/cellinfo/*.class</include>
		
+							</includes>
+						</configuration>
+					</execution>
+
+					<!-- Iteration -->
+					<execution>
+						<id>Iteration</id>
+						<phase>package</phase>
+						<goals>
+							<goal>jar</goal>
+						</goals>
+						<configuration>
+							<classifier>Iteration</classifier>
+
+							<archive>
+								<manifestEntries>
+									<program-class>org.apache.flink.streaming.examples.iteration.IterateExample</program-class>
+								</manifestEntries>
+							</archive>
+
+							<includes>
+								<include>org/apache/flink/streaming/examples/iteration/*.class</include>
		
+							</includes>
+						</configuration>
+					</execution>
+
+					<!-- IncrementalLearning -->
+					<execution>
+						<id>IncrementalLearning</id>
+						<phase>package</phase>
+						<goals>
+							<goal>jar</goal>
+						</goals>
+						<configuration>
+							<classifier>IncrementalLearning</classifier>
+
+							<archive>
+								<manifestEntries>
+									<program-class>org.apache.flink.streaming.examples.ml.IncrementalLearningSkeleton</program-class>
+								</manifestEntries>
+							</archive>
+
+							<includes>
+								<include>org/apache/flink/streaming/examples/ml/*.class</include>			
+							</includes>
+						</configuration>
+					</execution>
+
+					<!-- Twitter -->
+					<execution>
+						<id>Twitter</id>
+						<phase>package</phase>
+						<goals>
+							<goal>jar</goal>
+						</goals>
+						<configuration>
+							<classifier>Twitter</classifier>
+
+							<archive>
+								<manifestEntries>
+									<program-class>org.apache.flink.streaming.examples.twitter.TwitterStream</program-class>
+								</manifestEntries>
+							</archive>
+
+							<includes>
+								<include>org/apache/flink/streaming/examples/twitter/*.class</include>
+								<include>org/apache/flink/streaming/examples/twitter/util/*.class</include>
					
+							</includes>
+						</configuration>
+					</execution>
+
+					<!-- WindowJoin -->
+					<execution>
+						<id>WindowJoin</id>
+						<phase>package</phase>
+						<goals>
+							<goal>jar</goal>
+						</goals>
+						<configuration>
+							<classifier>WindowJoin</classifier>
+
+							<archive>
+								<manifestEntries>
+									<program-class>org.apache.flink.streaming.examples.window.join.WindowJoinLocal</program-class>
+								</manifestEntries>
+							</archive>
+
+							<includes>
+								<include>org/apache/flink/streaming/examples/window/join/*.class</include>
		
+							</includes>
+						</configuration>
+					</execution>
+
+					<!-- WordCountPOJO -->
+					<execution>
+						<id>WordCountPOJO</id>
+						<phase>package</phase>
+						<goals>
+							<goal>jar</goal>
+						</goals>
+						<configuration>
+							<classifier>WordCountPOJO</classifier>
+
+							<archive>
+								<manifestEntries>
+									<program-class>org.apache.flink.streaming.examples.wordcount.PojoWordCount</program-class>
+								</manifestEntries>
+							</archive>
+
+							<includes>
+								<include>org/apache/flink/streaming/examples/wordcount/PojoWordCount.class</include>
+								<include>org/apache/flink/streaming/examples/wordcount/PojoWordCount$*.class</include>
+								<include>org/apache/flink/examples/java/wordcount/util/WordCountData.class</include>
		
+							</includes>
+						</configuration>
+					</execution>
+
+					<!-- WordCount -->
+					<execution>
+						<id>WordCount</id>
+						<phase>package</phase>
+						<goals>
+							<goal>jar</goal>
+						</goals>
+						<configuration>
+							<classifier>WordCount</classifier>
+
+							<archive>
+								<manifestEntries>
+									<program-class>org.apache.flink.streaming.examples.wordcount.WordCount</program-class>
+								</manifestEntries>
+							</archive>
+
+							<includes>
+								<include>org/apache/flink/streaming/examples/wordcount/WordCount.class</include>
+								<include>org/apache/flink/streaming/examples/wordcount/WordCount$*.class</include>
+								<include>org/apache/flink/examples/java/wordcount/util/WordCountData.class</include>
			
+							</includes>
+						</configuration>
 					</execution>
 				</executions>
 			</plugin>


Mime
View raw message