You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2016/03/02 20:54:40 UTC
[1/2] incubator-streams-examples git commit: resolves STREAMS-395
Repository: incubator-streams-examples
Updated Branches:
refs/heads/master b3653ce1f -> 5ddc67c06
resolves STREAMS-395
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/e6b0d948
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/tree/e6b0d948
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/diff/e6b0d948
Branch: refs/heads/master
Commit: e6b0d9488298a5e6b1d4ebe67a0f58270486dba8
Parents: b3653ce
Author: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Authored: Mon Dec 7 13:37:55 2015 -0700
Committer: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Committed: Mon Dec 7 13:37:55 2015 -0700
----------------------------------------------------------------------
.../org/apache/streams/example/graph/TwitterFollowGraph.java | 5 +++--
.../src/main/jsonschema/TwitterFollowGraphConfiguration.json | 2 +-
.../streams/example/twitter/TwitterHistoryElasticsearch.java | 2 +-
.../streams/twitter/example/TwitterUserstreamElasticsearch.java | 4 ++++
4 files changed, 9 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/e6b0d948/local/twitter-follow-graph/src/main/java/org/apache/streams/example/graph/TwitterFollowGraph.java
----------------------------------------------------------------------
diff --git a/local/twitter-follow-graph/src/main/java/org/apache/streams/example/graph/TwitterFollowGraph.java b/local/twitter-follow-graph/src/main/java/org/apache/streams/example/graph/TwitterFollowGraph.java
index 1e2224b..e88f299 100644
--- a/local/twitter-follow-graph/src/main/java/org/apache/streams/example/graph/TwitterFollowGraph.java
+++ b/local/twitter-follow-graph/src/main/java/org/apache/streams/example/graph/TwitterFollowGraph.java
@@ -32,6 +32,7 @@ import org.apache.streams.data.DocumentClassifier;
import org.apache.streams.graph.GraphHttpConfiguration;
import org.apache.streams.graph.GraphHttpPersistWriter;
import org.apache.streams.local.builders.LocalStreamBuilder;
+import org.apache.streams.twitter.TwitterFollowingConfiguration;
import org.apache.streams.twitter.TwitterUserInformationConfiguration;
import org.apache.streams.twitter.converter.TwitterFollowActivityConverter;
import org.apache.streams.twitter.pojo.Follow;
@@ -58,8 +59,8 @@ public class TwitterFollowGraph {
TwitterFollowingGraphConfiguration configuration = new ComponentConfigurator<>(TwitterFollowingGraphConfiguration.class).detectConfiguration(StreamsConfigurator.getConfig());
- TwitterUserInformationConfiguration twitterUserInformationConfiguration = configuration.getTwitter();
- TwitterFollowingProvider followingProvider = new TwitterFollowingProvider(twitterUserInformationConfiguration);
+ TwitterFollowingConfiguration twitterFollowingConfiguration = configuration.getTwitter();
+ TwitterFollowingProvider followingProvider = new TwitterFollowingProvider(twitterFollowingConfiguration);
TypeConverterProcessor converter = new TypeConverterProcessor(String.class);
ActivityConverterProcessorConfiguration activityConverterProcessorConfiguration =
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/e6b0d948/local/twitter-follow-graph/src/main/jsonschema/TwitterFollowGraphConfiguration.json
----------------------------------------------------------------------
diff --git a/local/twitter-follow-graph/src/main/jsonschema/TwitterFollowGraphConfiguration.json b/local/twitter-follow-graph/src/main/jsonschema/TwitterFollowGraphConfiguration.json
index 23e3b91..129be4c 100644
--- a/local/twitter-follow-graph/src/main/jsonschema/TwitterFollowGraphConfiguration.json
+++ b/local/twitter-follow-graph/src/main/jsonschema/TwitterFollowGraphConfiguration.json
@@ -7,7 +7,7 @@
"javaType" : "org.apache.streams.example.graph.TwitterFollowingGraphConfiguration",
"javaInterfaces": ["java.io.Serializable"],
"properties": {
- "twitter": { "javaType": "org.apache.streams.twitter.TwitterUserInformationConfiguration", "type": "object", "required": true },
+ "twitter": { "javaType": "org.apache.streams.twitter.TwitterFollowingConfiguration", "type": "object", "required": true },
"graph": { "javaType": "org.apache.streams.graph.GraphHttpConfiguration", "type": "object", "required": true }
}
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/e6b0d948/local/twitter-history-elasticsearch/src/main/java/org/apache/streams/example/twitter/TwitterHistoryElasticsearch.java
----------------------------------------------------------------------
diff --git a/local/twitter-history-elasticsearch/src/main/java/org/apache/streams/example/twitter/TwitterHistoryElasticsearch.java b/local/twitter-history-elasticsearch/src/main/java/org/apache/streams/example/twitter/TwitterHistoryElasticsearch.java
index 49dcd42..090b9ed 100644
--- a/local/twitter-history-elasticsearch/src/main/java/org/apache/streams/example/twitter/TwitterHistoryElasticsearch.java
+++ b/local/twitter-history-elasticsearch/src/main/java/org/apache/streams/example/twitter/TwitterHistoryElasticsearch.java
@@ -76,7 +76,7 @@ public class TwitterHistoryElasticsearch implements Runnable {
public void run() {
- TwitterTimelineProvider provider = new TwitterTimelineProvider(config.getTwitter(), ObjectNode.class);
+ TwitterTimelineProvider provider = new TwitterTimelineProvider(config.getTwitter());
ActivityConverterProcessor converter = new ActivityConverterProcessor();
ElasticsearchPersistWriter writer = new ElasticsearchPersistWriter(config.getElasticsearch());
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/e6b0d948/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/twitter/example/TwitterUserstreamElasticsearch.java
----------------------------------------------------------------------
diff --git a/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/twitter/example/TwitterUserstreamElasticsearch.java b/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/twitter/example/TwitterUserstreamElasticsearch.java
index fb9d1ed..c483742 100644
--- a/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/twitter/example/TwitterUserstreamElasticsearch.java
+++ b/local/twitter-userstream-elasticsearch/src/main/java/org/apache/streams/twitter/example/TwitterUserstreamElasticsearch.java
@@ -114,6 +114,10 @@ public class TwitterUserstreamElasticsearch implements Runnable {
protected class SetDeleteIdProcessor implements StreamsProcessor {
+ public String getId() {
+ return "TwitterUserstreamElasticsearch.SetDeleteIdProcessor";
+ }
+
@Override
public List<StreamsDatum> process(StreamsDatum entry) {
[2/2] incubator-streams-examples git commit: travis didn't run
Posted by sb...@apache.org.
travis didn't run
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/5ddc67c0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/tree/5ddc67c0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/diff/5ddc67c0
Branch: refs/heads/master
Commit: 5ddc67c06f122933bcb81aaabbb65a8b39bcd3dc
Parents: e6b0d94
Author: Steve Blackmon @steveblackmon <sb...@apache.org>
Authored: Wed Mar 2 13:27:27 2016 -0600
Committer: Steve Blackmon @steveblackmon <sb...@apache.org>
Committed: Wed Mar 2 13:27:27 2016 -0600
----------------------------------------------------------------------
.travis.yml | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams-examples/blob/5ddc67c0/.travis.yml
----------------------------------------------------------------------
diff --git a/.travis.yml b/.travis.yml
new file mode 100644
index 0000000..64bc45a
--- /dev/null
+++ b/.travis.yml
@@ -0,0 +1,7 @@
+sudo: false
+language: java
+jdk:
+ - oraclejdk7
+install: mvn -Dmaven.test.skip.exec=true clean -q
+# tests take too long to run and produce too much output to enable at this time
+script: mvn -Dmaven.test.skip.exec=true install -q