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/07/02 15:50:27 UTC
[2/3] git commit: STREAMS-113 | Code review feedback
STREAMS-113 | Code review feedback
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/42debdf2
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/42debdf2
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/42debdf2
Branch: refs/heads/master
Commit: 42debdf2206fc99dc6a57f64e673a71a120adcf2
Parents: bc9fe49
Author: Robert Douglas <rd...@w2odigital.com>
Authored: Mon Jun 30 09:29:18 2014 -0500
Committer: Robert Douglas <rd...@w2odigital.com>
Committed: Mon Jun 30 09:29:18 2014 -0500
----------------------------------------------------------------------
.../org/apache/streams/twitter/processor/TwitterTypeConverter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/42debdf2/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java
index 0737e39..74cce27 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java
@@ -176,7 +176,7 @@ public class TwitterTypeConverter implements StreamsProcessor {
node = (ObjectNode)mapper.valueToTree(item);
// since data is coming from outside provider, we don't know what type the events are
- Class inClass = TwitterEventClassifier.detectClass(item.toString());
+ Class inClass = TwitterEventClassifier.detectClass(mapper.writeValueAsString(item));
Object out = convert(node, inClass, outClass);