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 2015/04/02 23:21:56 UTC
[5/9] incubator-streams git commit: follow Json detection
follow Json detection
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/c14e335e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/c14e335e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/c14e335e
Branch: refs/heads/master
Commit: c14e335ede2d05c1265af609fbbfea196001802f
Parents: 3dceeb5
Author: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Authored: Thu Mar 26 20:14:28 2015 -0500
Committer: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Committed: Thu Mar 26 20:14:28 2015 -0500
----------------------------------------------------------------------
.../streams/twitter/converter/TwitterDocumentClassifier.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/c14e335e/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterDocumentClassifier.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterDocumentClassifier.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterDocumentClassifier.java
index 9eda110..bdd6682 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterDocumentClassifier.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterDocumentClassifier.java
@@ -68,6 +68,8 @@ public class TwitterDocumentClassifier implements DocumentClassifier {
classList.add(FriendList.class);
else if( objectNode.findValue("target_object") != null )
classList.add(UserstreamEvent.class);
+ else if( objectNode.findValue("follower") != null && objectNode.findValue("followee") != null)
+ classList.add(Follow.class);
else if ( objectNode.findValue("location") != null && objectNode.findValue("user") == null)
classList.add(User.class);
else