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/08/25 20:16:50 UTC
[2/4] incubator-streams git commit: resolves STREAMS-355
resolves STREAMS-355
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/306d5afe
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/306d5afe
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/306d5afe
Branch: refs/heads/master
Commit: 306d5afe4c8011ca9cdf3678d464102e263d1561
Parents: 776a224
Author: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Authored: Wed Aug 19 15:24:05 2015 -0500
Committer: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Committed: Wed Aug 19 15:24:05 2015 -0500
----------------------------------------------------------------------
.../main/java/org/apache/streams/hdfs/WebHdfsPersistReader.java | 3 ++-
.../main/java/org/apache/streams/core/DatumStatusCounter.java | 5 ++++-
2 files changed, 6 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/306d5afe/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReader.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReader.java b/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReader.java
index f1432a5..0312c37 100644
--- a/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReader.java
+++ b/streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReader.java
@@ -68,7 +68,7 @@ public class WebHdfsPersistReader implements StreamsPersistReader, DatumStatusCo
protected volatile Queue<StreamsDatum> persistQueue;
- protected ObjectMapper mapper = StreamsJacksonMapper.getInstance();
+ protected ObjectMapper mapper;
protected HdfsReaderConfiguration hdfsConfiguration;
protected StreamsConfiguration streamsConfiguration;
@@ -177,6 +177,7 @@ public class WebHdfsPersistReader implements StreamsPersistReader, DatumStatusCo
persistQueue = Queues.synchronizedQueue(new LinkedBlockingQueue<StreamsDatum>(streamsConfiguration.getBatchSize().intValue()));
//persistQueue = Queues.synchronizedQueue(new ConcurrentLinkedQueue());
executor = Executors.newSingleThreadExecutor();
+ mapper = StreamsJacksonMapper.getInstance();
}
@Override
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/306d5afe/streams-core/src/main/java/org/apache/streams/core/DatumStatusCounter.java
----------------------------------------------------------------------
diff --git a/streams-core/src/main/java/org/apache/streams/core/DatumStatusCounter.java b/streams-core/src/main/java/org/apache/streams/core/DatumStatusCounter.java
index ad50e3b..2e598ce 100644
--- a/streams-core/src/main/java/org/apache/streams/core/DatumStatusCounter.java
+++ b/streams-core/src/main/java/org/apache/streams/core/DatumStatusCounter.java
@@ -17,8 +17,11 @@
*/
package org.apache.streams.core;
+
+import java.io.Serializable;
+
@Deprecated
-public class DatumStatusCounter
+public class DatumStatusCounter implements Serializable
{
private volatile int attempted = 0;
private volatile int success = 0;