Repository: incubator-streams Updated Branches: refs/heads/blueprints 2d61837df -> 1cf71a4a6
no message Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/1cf71a4a Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/1cf71a4a Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/1cf71a4a Branch: refs/heads/blueprints Commit: 1cf71a4a6f0f69e0b36939c564ec970c2b7a3672 Parents: 2d61837 Author: sblackmon <[email protected]> Authored: Sat Oct 25 14:01:39 2014 -0500 Committer: sblackmon <[email protected]> Committed: Sat Oct 25 14:01:39 2014 -0500 ---------------------------------------------------------------------- .../org/apache/streams/blueprints/BlueprintsPersistWriter.java | 3 +++ .../apache/streams/twitter/processor/TwitterTypeConverter.java | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/1cf71a4a/streams-contrib/streams-persist-blueprints/src/main/java/org/apache/streams/blueprints/BlueprintsPersistWriter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-persist-blueprints/src/main/java/org/apache/streams/blueprints/BlueprintsPersistWriter.java b/streams-contrib/streams-persist-blueprints/src/main/java/org/apache/streams/blueprints/BlueprintsPersistWriter.java index 4a68afc..82727ba 100644 --- a/streams-contrib/streams-persist-blueprints/src/main/java/org/apache/streams/blueprints/BlueprintsPersistWriter.java +++ b/streams-contrib/streams-persist-blueprints/src/main/java/org/apache/streams/blueprints/BlueprintsPersistWriter.java @@ -51,6 +51,8 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; public class BlueprintsPersistWriter implements StreamsPersistWriter { + public static final String STREAMS_ID = BlueprintsPersistWriter.class.getCanonicalName(); + private final static Logger LOGGER = LoggerFactory.getLogger(BlueprintsPersistWriter.class); private final static long MAX_WRITE_LATENCY = 1000; @@ -75,6 +77,7 @@ public class BlueprintsPersistWriter implements StreamsPersistWriter { @Override public void write(StreamsDatum streamsDatum) { + persistElements(streamsDatum); } @Override http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/1cf71a4a/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 871dee8..804aa14 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 @@ -100,7 +100,7 @@ public class TwitterTypeConverter implements StreamsProcessor { LOGGER.debug("DELETE"); result = mapper.convertValue(event, Delete.class); } - } else if( outClass.equals( ObjectNode.class )) { + } else { LOGGER.debug("OBJECTNODE"); result = mapper.convertValue(event, ObjectNode.class); }
