You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/05/27 19:02:51 UTC
[2/4] git commit: STREAMS-95 | TwitterProfileProcessor now constructs
all StreamsDatums with the user's unique ID (from Twitter)
STREAMS-95 | TwitterProfileProcessor now constructs all StreamsDatums with the user's unique ID (from Twitter)
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/ea3f312c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/ea3f312c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/ea3f312c
Branch: refs/heads/master
Commit: ea3f312c479fb35693b4cbf291ad02b2c77f24d9
Parents: 8fed208
Author: Robert Douglas <rd...@w2odigital.com>
Authored: Thu May 22 15:32:49 2014 -0500
Committer: Robert Douglas <rd...@w2odigital.com>
Committed: Thu May 22 15:32:49 2014 -0500
----------------------------------------------------------------------
.../streams/twitter/processor/TwitterProfileProcessor.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/ea3f312c/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterProfileProcessor.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterProfileProcessor.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterProfileProcessor.java
index 8b09894..c42943f 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterProfileProcessor.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterProfileProcessor.java
@@ -79,17 +79,17 @@ public class TwitterProfileProcessor implements StreamsProcessor, Runnable {
LOGGER.debug("TWEET");
Tweet tweet = mapper.readValue(item, Tweet.class);
user = tweet.getUser();
- result.add(new StreamsDatum(user));
+ result.add(new StreamsDatum(user, user.getIdStr()));
}
else if ( inClass.equals( Retweet.class )) {
LOGGER.debug("RETWEET");
Retweet retweet = mapper.readValue(item, Retweet.class);
user = retweet.getRetweetedStatus().getUser();
- result.add(new StreamsDatum(user));
+ result.add(new StreamsDatum(user, user.getIdStr()));
} else if ( inClass.equals( User.class )) {
LOGGER.debug("USER");
user = mapper.readValue(item, User.class);
- result.add(new StreamsDatum(user));
+ result.add(new StreamsDatum(user, user.getIdStr()));
} else {
return Lists.newArrayList();
}