You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sm...@apache.org on 2016/10/27 01:33:56 UTC
[1/3] incubator-streams-examples git commit: [maven-release-plugin]
prepare release streams-examples-0.4-incubating
Repository: incubator-streams-examples
Updated Branches:
refs/heads/master d9347a0e6 -> 8d1c9fad6
[maven-release-plugin] prepare release streams-examples-0.4-incubating
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/commit/00f5a5de
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/tree/00f5a5de
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/diff/00f5a5de
Branch: refs/heads/master
Commit: 00f5a5de7aef02595da60297cf79736960394472
Parents: d9347a0
Author: Steve Blackmon <sb...@apache.org>
Authored: Sun Oct 23 23:00:51 2016 -0500
Committer: Steve Blackmon <sb...@apache.org>
Committed: Sun Oct 23 23:00:51 2016 -0500
----------------------------------------------------------------------
flink/flink-twitter-collection/pom.xml | 18 ++++++------
flink/pom.xml | 2 +-
local/elasticsearch-hdfs/pom.xml | 18 ++++++------
local/elasticsearch-reindex/pom.xml | 8 +++---
local/mongo-elasticsearch-sync/pom.xml | 16 +++++------
local/pom.xml | 4 +--
local/twitter-follow-neo4j/pom.xml | 12 ++++----
local/twitter-history-elasticsearch/pom.xml | 16 +++++------
local/twitter-userstream-elasticsearch/pom.xml | 16 +++++------
pom.xml | 32 ++++++++++-----------
10 files changed, 70 insertions(+), 72 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/00f5a5de/flink/flink-twitter-collection/pom.xml
----------------------------------------------------------------------
diff --git a/flink/flink-twitter-collection/pom.xml b/flink/flink-twitter-collection/pom.xml
index 4cf0b89..d4a0f91 100644
--- a/flink/flink-twitter-collection/pom.xml
+++ b/flink/flink-twitter-collection/pom.xml
@@ -17,13 +17,11 @@
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/xsd/maven-4.0.0.xsd">
+<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">
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-flink</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<relativePath>..</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -71,7 +69,7 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-core</artifactId>
- <version>${project.version}</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>com.typesafe</groupId>
@@ -80,27 +78,27 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-config</artifactId>
- <version>${project.version}</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-util</artifactId>
- <version>${project.version}</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-pojo</artifactId>
- <version>${project.version}</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-provider-twitter</artifactId>
- <version>${project.version}</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-hdfs</artifactId>
- <version>${project.version}</version>
+ <version>0.4-incubating</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/00f5a5de/flink/pom.xml
----------------------------------------------------------------------
diff --git a/flink/pom.xml b/flink/pom.xml
index 6c50ca2..75abf05 100644
--- a/flink/pom.xml
+++ b/flink/pom.xml
@@ -22,7 +22,7 @@
<parent>
<artifactId>streams-examples</artifactId>
<groupId>org.apache.streams</groupId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<relativePath>..</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/00f5a5de/local/elasticsearch-hdfs/pom.xml
----------------------------------------------------------------------
diff --git a/local/elasticsearch-hdfs/pom.xml b/local/elasticsearch-hdfs/pom.xml
index eb52506..0146729 100644
--- a/local/elasticsearch-hdfs/pom.xml
+++ b/local/elasticsearch-hdfs/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<relativePath>..</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -67,7 +67,7 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-core</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>com.typesafe</groupId>
@@ -76,41 +76,41 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-config</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-util</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-schema-activitystreams</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-runtime-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-elasticsearch</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-elasticsearch</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-hdfs</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/00f5a5de/local/elasticsearch-reindex/pom.xml
----------------------------------------------------------------------
diff --git a/local/elasticsearch-reindex/pom.xml b/local/elasticsearch-reindex/pom.xml
index 3b0067a..4049be8 100644
--- a/local/elasticsearch-reindex/pom.xml
+++ b/local/elasticsearch-reindex/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<relativePath>..</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -83,7 +83,7 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-schema-activitystreams</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
</dependency>
<dependency>
@@ -93,12 +93,12 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-elasticsearch</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-elasticsearch</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/00f5a5de/local/mongo-elasticsearch-sync/pom.xml
----------------------------------------------------------------------
diff --git a/local/mongo-elasticsearch-sync/pom.xml b/local/mongo-elasticsearch-sync/pom.xml
index 435a40b..6e8f302 100644
--- a/local/mongo-elasticsearch-sync/pom.xml
+++ b/local/mongo-elasticsearch-sync/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<relativePath>..</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -66,7 +66,7 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-core</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>com.typesafe</groupId>
@@ -75,34 +75,34 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-config</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-runtime-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-elasticsearch</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-mongo</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-mongo</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-schema-activitystreams</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
</dependency>
<dependency>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/00f5a5de/local/pom.xml
----------------------------------------------------------------------
diff --git a/local/pom.xml b/local/pom.xml
index e515606..7b8126f 100644
--- a/local/pom.xml
+++ b/local/pom.xml
@@ -22,12 +22,12 @@
<parent>
<artifactId>streams-examples</artifactId>
<groupId>org.apache.streams</groupId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<relativePath>..</relativePath>
</parent>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<packaging>pom</packaging>
<name>streams-examples-local</name>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/00f5a5de/local/twitter-follow-neo4j/pom.xml
----------------------------------------------------------------------
diff --git a/local/twitter-follow-neo4j/pom.xml b/local/twitter-follow-neo4j/pom.xml
index d9b7053..27e9629 100644
--- a/local/twitter-follow-neo4j/pom.xml
+++ b/local/twitter-follow-neo4j/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<relativePath>..</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -49,17 +49,17 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-config</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-runtime-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-provider-twitter</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<exclusions>
<exclusion>
<groupId>commons-logging</groupId>
@@ -70,12 +70,12 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-graph</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-pojo</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
</dependency>
<dependency>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/00f5a5de/local/twitter-history-elasticsearch/pom.xml
----------------------------------------------------------------------
diff --git a/local/twitter-history-elasticsearch/pom.xml b/local/twitter-history-elasticsearch/pom.xml
index 1a96fb9..b0cc541 100644
--- a/local/twitter-history-elasticsearch/pom.xml
+++ b/local/twitter-history-elasticsearch/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -69,7 +69,7 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-core</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>com.typesafe</groupId>
@@ -78,29 +78,29 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-config</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-util</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-pojo</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-runtime-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-provider-twitter</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<exclusions>
<exclusion>
<groupId>commons-logging</groupId>
@@ -111,7 +111,7 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-elasticsearch</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/00f5a5de/local/twitter-userstream-elasticsearch/pom.xml
----------------------------------------------------------------------
diff --git a/local/twitter-userstream-elasticsearch/pom.xml b/local/twitter-userstream-elasticsearch/pom.xml
index 559e1b9..d4998b0 100644
--- a/local/twitter-userstream-elasticsearch/pom.xml
+++ b/local/twitter-userstream-elasticsearch/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -67,7 +67,7 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-core</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>com.typesafe</groupId>
@@ -76,32 +76,32 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-config</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-runtime-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-filters</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-provider-twitter</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-elasticsearch</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-pojo</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
</dependency>
<dependency>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/00f5a5de/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 0602cb3..1b418de 100644
--- a/pom.xml
+++ b/pom.xml
@@ -22,11 +22,11 @@
<parent>
<artifactId>streams-master</artifactId>
<groupId>org.apache.streams</groupId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</parent>
<artifactId>streams-examples</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<packaging>pom</packaging>
<name>streams-examples</name>
@@ -48,7 +48,7 @@
<connection>scm:git:git@github.com:apache/incubator-streams-examples.git</connection>
<developerConnection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-streams-examples.git</developerConnection>
<url>scm:git:git@github.com:apache/incubator-streams-examples.git</url>
- <tag>HEAD</tag>
+ <tag>streams-examples-0.4-incubating</tag>
</scm>
<developers>
@@ -187,39 +187,39 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-config</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-core</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-filters</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-pojo</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-pojo</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-util</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-util</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
<type>test-jar</type>
<scope>test</scope>
</dependency>
@@ -231,32 +231,32 @@
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-runtime-local</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-provider-twitter</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-elasticsearch</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-graph</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-hdfs</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
<dependency>
<groupId>org.apache.streams</groupId>
<artifactId>streams-persist-mongo</artifactId>
- <version>0.4-incubating-SNAPSHOT</version>
+ <version>0.4-incubating</version>
</dependency>
</dependencies>
[3/3] incubator-streams-examples git commit: Trivial Fix,
to trigger github mirroring resync
Posted by sm...@apache.org.
Trivial Fix, to trigger github mirroring resync
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/commit/8d1c9fad
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/tree/8d1c9fad
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/diff/8d1c9fad
Branch: refs/heads/master
Commit: 8d1c9fad609125ce8cd34ab164e2de073562ff5f
Parents: 64f8d6e
Author: smarthi <sm...@apache.org>
Authored: Wed Oct 26 21:33:26 2016 -0400
Committer: smarthi <sm...@apache.org>
Committed: Wed Oct 26 21:33:26 2016 -0400
----------------------------------------------------------------------
.../streams/examples/flink/FlinkBase.scala | 32 ++++++++++----------
.../FlinkTwitterFollowingPipeline.scala | 14 +++------
.../collection/FlinkTwitterPostsPipeline.scala | 11 +++----
.../FlinkTwitterSpritzerPipeline.scala | 15 ++++-----
.../FlinkTwitterUserInformationPipeline.scala | 14 ++++-----
5 files changed, 36 insertions(+), 50 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/8d1c9fad/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala
----------------------------------------------------------------------
diff --git a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala
index a94dd61..49ca5b9 100644
--- a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala
+++ b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/FlinkBase.scala
@@ -50,7 +50,7 @@ trait FlinkBase {
*/
def main(args: Array[String]): Unit = {
// if only one argument, use it as the config URL
- if( args.size > 0 ) {
+ if( args.length > 0 ) {
BASELOGGER.info("Args: {}", args)
configUrl = args(0)
setup(configUrl)
@@ -79,7 +79,7 @@ trait FlinkBase {
typesafe = StreamsConfigurator.getConfig
}
- return setup(typesafe)
+ setup(typesafe)
}
@@ -91,13 +91,13 @@ trait FlinkBase {
if( this.typesafe.getString("mode").equals("streaming")) {
val streamingConfiguration: FlinkStreamingConfiguration =
new ComponentConfigurator[FlinkStreamingConfiguration](classOf[FlinkStreamingConfiguration]).detectConfiguration(typesafe)
- return setupStreaming(streamingConfiguration)
+ setupStreaming(streamingConfiguration)
} else if( this.typesafe.getString("mode").equals("batch")) {
val batchConfiguration: FlinkBatchConfiguration =
new ComponentConfigurator[FlinkBatchConfiguration](classOf[FlinkBatchConfiguration]).detectConfiguration(typesafe)
- return setupBatch(batchConfiguration)
+ setupBatch(batchConfiguration)
} else {
- return false;
+ false
}
}
@@ -123,7 +123,7 @@ trait FlinkBase {
if( streamExecutionEnvironment == null )
streamExecutionEnvironment = streamEnvironment(streamingConfiguration)
- return false
+ false
}
@@ -138,17 +138,17 @@ trait FlinkBase {
if( executionEnvironment == null )
executionEnvironment = batchEnvironment(batchConfiguration)
- return true
+ true
}
def batchEnvironment(config: FlinkBatchConfiguration = new FlinkBatchConfiguration()) : ExecutionEnvironment = {
if (config.getTest == false && config.getLocal == false) {
val env = ExecutionEnvironment.getExecutionEnvironment
- return env
+ env
} else {
val env = ExecutionEnvironment.createLocalEnvironment(config.getParallel.toInt)
- return env
+ env
}
}
@@ -156,7 +156,7 @@ trait FlinkBase {
if( config.getTest == false && config.getLocal == false) {
val env = StreamExecutionEnvironment.getExecutionEnvironment
- env.setRestartStrategy(RestartStrategies.noRestart());
+ env.setRestartStrategy(RestartStrategies.noRestart())
// start a checkpoint every hour
env.enableCheckpointing(config.getCheckpointIntervalMs)
@@ -169,10 +169,10 @@ trait FlinkBase {
// allow only one checkpoint to be in progress at the same time
env.getCheckpointConfig.setMaxConcurrentCheckpoints(1)
- return env
+ env
}
- else return StreamExecutionEnvironment.createLocalEnvironment(config.getParallel.toInt)
+ else StreamExecutionEnvironment.createLocalEnvironment(config.getParallel.toInt)
}
def buildReaderPath(configObject: HdfsReaderConfiguration) : String = {
@@ -188,7 +188,7 @@ trait FlinkBase {
} else {
throw new Exception("scheme not recognized: " + configObject.getScheme)
}
- return inPathBuilder
+ inPathBuilder
}
def buildWriterPath(configObject: HdfsWriterConfiguration) : String = {
@@ -204,15 +204,15 @@ trait FlinkBase {
} else {
throw new Exception("output scheme not recognized: " + configObject.getScheme)
}
- return outPathBuilder
+ outPathBuilder
}
def toProviderId(input : String) : String = {
if( input.startsWith("@") )
return input.substring(1)
if( input.contains(':'))
- return input.substring(input.lastIndexOf(':')+1)
- else return input
+ input.substring(input.lastIndexOf(':')+1)
+ else input
}
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/8d1c9fad/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala
----------------------------------------------------------------------
diff --git a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala
index 0e77ef8..a5a4f72 100644
--- a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala
+++ b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterFollowingPipeline.scala
@@ -43,12 +43,6 @@ import org.apache.flink.api.scala._
import scala.collection.JavaConversions._
-/**
- * Created by sblackmon on 4/20/16.
- */
-/**
- * Created by sblackmon on 3/15/16.
- */
object FlinkTwitterFollowingPipeline extends FlinkBase {
val STREAMS_ID: String = "FlinkTwitterFollowingPipeline"
@@ -59,7 +53,7 @@ object FlinkTwitterFollowingPipeline extends FlinkBase {
override def main(args: Array[String]) = {
super.main(args)
val jobConfig = new ComponentConfigurator[TwitterFollowingPipelineConfiguration](classOf[TwitterFollowingPipelineConfiguration]).detectConfiguration(typesafe)
- if( setup(jobConfig) == false ) System.exit(1)
+ if( !setup(jobConfig) ) System.exit(1)
val pipeline: FlinkTwitterFollowingPipeline = new FlinkTwitterFollowingPipeline(jobConfig)
val thread = new Thread(pipeline)
thread.start()
@@ -100,7 +94,7 @@ object FlinkTwitterFollowingPipeline extends FlinkBase {
Preconditions.checkArgument(!Strings.isNullOrEmpty(jobConfig.getTwitter.getOauth.getConsumerKey))
Preconditions.checkArgument(!Strings.isNullOrEmpty(jobConfig.getTwitter.getOauth.getConsumerSecret))
- return true
+ true
}
@@ -114,7 +108,7 @@ class FlinkTwitterFollowingPipeline(config: TwitterFollowingPipelineConfiguratio
val env: StreamExecutionEnvironment = streamEnvironment(MAPPER.convertValue(config, classOf[FlinkStreamingConfiguration]))
- env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime);
+ env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime)
env.setNumberOfExecutionRetries(0)
val inPath = buildReaderPath(config.getSource)
@@ -140,7 +134,7 @@ class FlinkTwitterFollowingPipeline(config: TwitterFollowingPipelineConfiguratio
jsons.addSink(new RollingSink[String](outPath)).setParallelism(3)
else
jsons.writeAsText(outPath,FileSystem.WriteMode.OVERWRITE)
- .setParallelism(env.getParallelism);
+ .setParallelism(env.getParallelism)
// if( test == true ) jsons.print();
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/8d1c9fad/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala
----------------------------------------------------------------------
diff --git a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala
index 6a070d0..8bb2997 100644
--- a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala
+++ b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterPostsPipeline.scala
@@ -52,9 +52,6 @@ import org.apache.flink.api.scala._
import scala.collection.JavaConversions._
-/**
- * Created by sblackmon on 7/29/15.
- */
object FlinkTwitterPostsPipeline extends FlinkBase {
val STREAMS_ID: String = "FlinkTwitterPostsPipeline"
@@ -65,7 +62,7 @@ object FlinkTwitterPostsPipeline extends FlinkBase {
override def main(args: Array[String]) = {
super.main(args)
val jobConfig = new ComponentConfigurator[TwitterPostsPipelineConfiguration](classOf[TwitterPostsPipelineConfiguration]).detectConfiguration(typesafe)
- if( setup(jobConfig) == false ) System.exit(1)
+ if( !setup(jobConfig) ) System.exit(1)
val pipeline: FlinkTwitterPostsPipeline = new FlinkTwitterPostsPipeline(jobConfig)
val thread = new Thread(pipeline)
thread.start()
@@ -106,7 +103,7 @@ object FlinkTwitterPostsPipeline extends FlinkBase {
Preconditions.checkArgument(!Strings.isNullOrEmpty(jobConfig.getTwitter.getOauth.getConsumerKey))
Preconditions.checkArgument(!Strings.isNullOrEmpty(jobConfig.getTwitter.getOauth.getConsumerSecret))
- return true
+ true
}
@@ -120,7 +117,7 @@ class FlinkTwitterPostsPipeline(config: TwitterPostsPipelineConfiguration = new
val env: StreamExecutionEnvironment = streamEnvironment(MAPPER.convertValue(config, classOf[FlinkStreamingConfiguration]))
- env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime);
+ env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime)
env.setNumberOfExecutionRetries(0)
val inPath = buildReaderPath(config.getSource)
@@ -148,7 +145,7 @@ class FlinkTwitterPostsPipeline(config: TwitterPostsPipelineConfiguration = new
jsons.addSink(new RollingSink[String](outPath)).setParallelism(3).name("hdfs")
else
jsons.writeAsText(outPath,FileSystem.WriteMode.OVERWRITE)
- .setParallelism(env.getParallelism);
+ .setParallelism(env.getParallelism)
// if( test == true ) jsons.print();
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/8d1c9fad/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala
----------------------------------------------------------------------
diff --git a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala
index 7e7cc5c..56d892b 100644
--- a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala
+++ b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterSpritzerPipeline.scala
@@ -45,9 +45,6 @@ import org.apache.streams.twitter.converter.TwitterDateTimeFormat
import scala.collection.JavaConversions._
-/**
- * Created by sblackmon on 7/29/15.
- */
object FlinkTwitterSpritzerPipeline extends FlinkBase {
val STREAMS_ID: String = "FlinkTwitterSpritzerPipeline"
@@ -58,7 +55,7 @@ object FlinkTwitterSpritzerPipeline extends FlinkBase {
override def main(args: Array[String]) = {
super.main(args)
val jobConfig = new ComponentConfigurator(classOf[TwitterSpritzerPipelineConfiguration]).detectConfiguration(typesafe)
- if( setup(jobConfig) == false ) System.exit(1)
+ if( !setup(jobConfig) ) System.exit(1)
val pipeline: FlinkTwitterSpritzerPipeline = new FlinkTwitterSpritzerPipeline(jobConfig)
val thread = new Thread(pipeline)
thread.start()
@@ -93,7 +90,7 @@ object FlinkTwitterSpritzerPipeline extends FlinkBase {
Preconditions.checkArgument(!Strings.isNullOrEmpty(jobConfig.getTwitter.getOauth.getConsumerKey))
Preconditions.checkArgument(!Strings.isNullOrEmpty(jobConfig.getTwitter.getOauth.getConsumerSecret))
- return true
+ true
}
@@ -109,18 +106,18 @@ class FlinkTwitterSpritzerPipeline(config: TwitterSpritzerPipelineConfiguration
val env: StreamExecutionEnvironment = streamEnvironment(MAPPER.convertValue(config, classOf[FlinkStreamingConfiguration]))
- env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime);
+ env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime)
env.setNumberOfExecutionRetries(0)
val outPath = buildWriterPath(config.getDestination)
- val streamSource : DataStream[String] = env.addSource(spritzerSource);
+ val streamSource : DataStream[String] = env.addSource(spritzerSource)
if( config.getTest == false )
streamSource.addSink(new RollingSink[String](outPath)).setParallelism(3).name("hdfs")
else
streamSource.writeAsText(outPath,FileSystem.WriteMode.OVERWRITE)
- .setParallelism(env.getParallelism);
+ .setParallelism(env.getParallelism)
// if( test == true ) jsons.print();
@@ -160,7 +157,7 @@ class FlinkTwitterSpritzerPipeline(config: TwitterSpritzerPipelineConfiguration
}
override def stop(): Unit = {
- close();
+ close()
}
}
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/8d1c9fad/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala
----------------------------------------------------------------------
diff --git a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala
index 0ff8648..01425f6 100644
--- a/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala
+++ b/flink/flink-twitter-collection/src/main/scala/org/apache/streams/examples/flink/twitter/collection/FlinkTwitterUserInformationPipeline.scala
@@ -45,9 +45,6 @@ import org.slf4j.{Logger, LoggerFactory}
import scala.collection.JavaConversions._
-/**
- * Created by sblackmon on 3/15/16.
- */
object FlinkTwitterUserInformationPipeline extends FlinkBase {
val STREAMS_ID: String = "FlinkTwitterUserInformationPipeline"
@@ -58,7 +55,7 @@ object FlinkTwitterUserInformationPipeline extends FlinkBase {
override def main(args: Array[String]) = {
super.main(args)
val jobConfig = new ComponentConfigurator[TwitterUserInformationPipelineConfiguration](classOf[TwitterUserInformationPipelineConfiguration]).detectConfiguration(typesafe)
- if( setup(jobConfig) == false ) System.exit(1)
+ if( !setup(jobConfig) ) System.exit(1)
val pipeline: FlinkTwitterUserInformationPipeline = new FlinkTwitterUserInformationPipeline(jobConfig)
val thread = new Thread(pipeline)
thread.start()
@@ -99,7 +96,7 @@ object FlinkTwitterUserInformationPipeline extends FlinkBase {
Preconditions.checkArgument(!Strings.isNullOrEmpty(jobConfig.getTwitter.getOauth.getConsumerKey))
Preconditions.checkArgument(!Strings.isNullOrEmpty(jobConfig.getTwitter.getOauth.getConsumerSecret))
- return true
+ true
}
@@ -113,7 +110,7 @@ class FlinkTwitterUserInformationPipeline(config: TwitterUserInformationPipeline
val env: StreamExecutionEnvironment = streamEnvironment(MAPPER.convertValue(config, classOf[FlinkStreamingConfiguration]))
- env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime);
+ env.setStreamTimeCharacteristic(TimeCharacteristic.IngestionTime)
env.setNumberOfExecutionRetries(0)
val inPath = buildReaderPath(config.getSource)
@@ -142,7 +139,7 @@ class FlinkTwitterUserInformationPipeline(config: TwitterUserInformationPipeline
jsons.addSink(new RollingSink[String](outPath)).setParallelism(3).name("hdfs")
else
jsons.writeAsText(outPath,FileSystem.WriteMode.OVERWRITE)
- .setParallelism(env.getParallelism);
+ .setParallelism(env.getParallelism)
LOGGER.info("StreamExecutionEnvironment: {}", env.toString )
@@ -150,7 +147,8 @@ class FlinkTwitterUserInformationPipeline(config: TwitterUserInformationPipeline
}
class idListWindowFunction extends WindowFunction[String, List[String], Int, GlobalWindow] {
- override def apply(key: Int, window: GlobalWindow, input: Iterable[String], out: Collector[List[String]]): Unit = {if( input.size > 0 )
+ override def apply(key: Int, window: GlobalWindow, input: Iterable[String], out: Collector[List[String]]): Unit = {
+ if( input.nonEmpty )
out.collect(input.map(id => toProviderId(id)).toList)
}
}
[2/3] incubator-streams-examples git commit: [maven-release-plugin]
prepare for next development iteration
Posted by sm...@apache.org.
[maven-release-plugin] prepare for next development iteration
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/commit/64f8d6e9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/tree/64f8d6e9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/diff/64f8d6e9
Branch: refs/heads/master
Commit: 64f8d6e9e5486990e055d593c6861a12f80d64d5
Parents: 00f5a5d
Author: Steve Blackmon <sb...@apache.org>
Authored: Sun Oct 23 23:01:06 2016 -0500
Committer: Steve Blackmon <sb...@apache.org>
Committed: Sun Oct 23 23:01:06 2016 -0500
----------------------------------------------------------------------
flink/flink-twitter-collection/pom.xml | 2 +-
flink/pom.xml | 2 +-
local/elasticsearch-hdfs/pom.xml | 2 +-
local/elasticsearch-reindex/pom.xml | 2 +-
local/mongo-elasticsearch-sync/pom.xml | 2 +-
local/pom.xml | 4 ++--
local/twitter-follow-neo4j/pom.xml | 2 +-
local/twitter-history-elasticsearch/pom.xml | 2 +-
local/twitter-userstream-elasticsearch/pom.xml | 2 +-
pom.xml | 6 +++---
10 files changed, 13 insertions(+), 13 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/64f8d6e9/flink/flink-twitter-collection/pom.xml
----------------------------------------------------------------------
diff --git a/flink/flink-twitter-collection/pom.xml b/flink/flink-twitter-collection/pom.xml
index d4a0f91..40c9497 100644
--- a/flink/flink-twitter-collection/pom.xml
+++ b/flink/flink-twitter-collection/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-flink</artifactId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/64f8d6e9/flink/pom.xml
----------------------------------------------------------------------
diff --git a/flink/pom.xml b/flink/pom.xml
index 75abf05..84f93f0 100644
--- a/flink/pom.xml
+++ b/flink/pom.xml
@@ -22,7 +22,7 @@
<parent>
<artifactId>streams-examples</artifactId>
<groupId>org.apache.streams</groupId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/64f8d6e9/local/elasticsearch-hdfs/pom.xml
----------------------------------------------------------------------
diff --git a/local/elasticsearch-hdfs/pom.xml b/local/elasticsearch-hdfs/pom.xml
index 0146729..39dbd57 100644
--- a/local/elasticsearch-hdfs/pom.xml
+++ b/local/elasticsearch-hdfs/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/64f8d6e9/local/elasticsearch-reindex/pom.xml
----------------------------------------------------------------------
diff --git a/local/elasticsearch-reindex/pom.xml b/local/elasticsearch-reindex/pom.xml
index 4049be8..c4098e7 100644
--- a/local/elasticsearch-reindex/pom.xml
+++ b/local/elasticsearch-reindex/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/64f8d6e9/local/mongo-elasticsearch-sync/pom.xml
----------------------------------------------------------------------
diff --git a/local/mongo-elasticsearch-sync/pom.xml b/local/mongo-elasticsearch-sync/pom.xml
index 6e8f302..bffcff4 100644
--- a/local/mongo-elasticsearch-sync/pom.xml
+++ b/local/mongo-elasticsearch-sync/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/64f8d6e9/local/pom.xml
----------------------------------------------------------------------
diff --git a/local/pom.xml b/local/pom.xml
index 7b8126f..8c8f2a0 100644
--- a/local/pom.xml
+++ b/local/pom.xml
@@ -22,12 +22,12 @@
<parent>
<artifactId>streams-examples</artifactId>
<groupId>org.apache.streams</groupId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
<packaging>pom</packaging>
<name>streams-examples-local</name>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/64f8d6e9/local/twitter-follow-neo4j/pom.xml
----------------------------------------------------------------------
diff --git a/local/twitter-follow-neo4j/pom.xml b/local/twitter-follow-neo4j/pom.xml
index 27e9629..671e19b 100644
--- a/local/twitter-follow-neo4j/pom.xml
+++ b/local/twitter-follow-neo4j/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/64f8d6e9/local/twitter-history-elasticsearch/pom.xml
----------------------------------------------------------------------
diff --git a/local/twitter-history-elasticsearch/pom.xml b/local/twitter-history-elasticsearch/pom.xml
index b0cc541..1f24fe5 100644
--- a/local/twitter-history-elasticsearch/pom.xml
+++ b/local/twitter-history-elasticsearch/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/64f8d6e9/local/twitter-userstream-elasticsearch/pom.xml
----------------------------------------------------------------------
diff --git a/local/twitter-userstream-elasticsearch/pom.xml b/local/twitter-userstream-elasticsearch/pom.xml
index d4998b0..135ddb5 100644
--- a/local/twitter-userstream-elasticsearch/pom.xml
+++ b/local/twitter-userstream-elasticsearch/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.streams</groupId>
<artifactId>streams-examples-local</artifactId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/64f8d6e9/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 1b418de..9f07d86 100644
--- a/pom.xml
+++ b/pom.xml
@@ -22,11 +22,11 @@
<parent>
<artifactId>streams-master</artifactId>
<groupId>org.apache.streams</groupId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
</parent>
<artifactId>streams-examples</artifactId>
- <version>0.4-incubating</version>
+ <version>0.5-incubating-SNAPSHOT</version>
<packaging>pom</packaging>
<name>streams-examples</name>
@@ -48,7 +48,7 @@
<connection>scm:git:git@github.com:apache/incubator-streams-examples.git</connection>
<developerConnection>scm:git:https://git-wip-us.apache.org/repos/asf/incubator-streams-examples.git</developerConnection>
<url>scm:git:git@github.com:apache/incubator-streams-examples.git</url>
- <tag>streams-examples-0.4-incubating</tag>
+ <tag>HEAD</tag>
</scm>
<developers>