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 2014/12/11 18:48:10 UTC
[5/5] incubator-streams git commit: STREAMS-243 | Changed
ObjectMapper to use StreamsJacksonMapper
STREAMS-243 | Changed ObjectMapper to use StreamsJacksonMapper
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/6c4cf0f1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/6c4cf0f1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/6c4cf0f1
Branch: refs/heads/master
Commit: 6c4cf0f1c78e663e05efdc3b1d954e3228529a1f
Parents: ec23425
Author: Robert Douglas <rd...@w2ogroup.com>
Authored: Tue Dec 9 10:16:17 2014 -0600
Committer: Robert Douglas <rd...@w2ogroup.com>
Committed: Tue Dec 9 10:16:17 2014 -0600
----------------------------------------------------------------------
.../src/main/java/org/apache/streams/s3/S3PersistWriter.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/6c4cf0f1/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java
index c50c94c..ad09b32 100644
--- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java
+++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3PersistWriter.java
@@ -30,6 +30,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
import com.google.common.base.Preconditions;
import com.google.common.base.Strings;
import org.apache.streams.core.*;
+import org.apache.streams.jackson.StreamsJacksonMapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -253,7 +254,7 @@ public class S3PersistWriter implements StreamsPersistWriter, DatumStatusCountab
try {
// if the user has chosen to not set the object mapper, then set a default object mapper for them.
if (this.objectMapper == null)
- this.objectMapper = new ObjectMapper();
+ this.objectMapper = new StreamsJacksonMapper();
// Create the credentials Object
if (this.amazonS3Client == null) {