You are viewing a plain text version of this content. The canonical link for it is here.
Posted to s4-commits@incubator.apache.org by mm...@apache.org on 2012/01/03 11:19:16 UTC
[45/50] [abbrv] git commit: Include key in checkpointed data
Include key in checkpointed data
Project: http://git-wip-us.apache.org/repos/asf/incubator-s4/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-s4/commit/cf685ab0
Tree: http://git-wip-us.apache.org/repos/asf/incubator-s4/tree/cf685ab0
Diff: http://git-wip-us.apache.org/repos/asf/incubator-s4/diff/cf685ab0
Branch: refs/heads/dev
Commit: cf685ab080870764d5aee4037587ebe918ce890b
Parents: c22c2ee
Author: Bruce Robbins <ro...@thosespent.corp.yahoo.com>
Authored: Wed Oct 19 13:31:03 2011 -0700
Committer: Bruce Robbins <ro...@thosespent.corp.yahoo.com>
Committed: Wed Oct 19 13:31:03 2011 -0700
----------------------------------------------------------------------
.../src/main/java/io/s4/processor/AbstractPE.java | 2 +-
1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-s4/blob/cf685ab0/s4-core/src/main/java/io/s4/processor/AbstractPE.java
----------------------------------------------------------------------
diff --git a/s4-core/src/main/java/io/s4/processor/AbstractPE.java b/s4-core/src/main/java/io/s4/processor/AbstractPE.java
index 2f0480a..ff6f17c 100644
--- a/s4-core/src/main/java/io/s4/processor/AbstractPE.java
+++ b/s4-core/src/main/java/io/s4/processor/AbstractPE.java
@@ -94,7 +94,7 @@ public abstract class AbstractPE implements Cloneable {
transient private List<EventAdvice> eventAdviceList = new ArrayList<EventAdvice>();
transient private List<Object> keyValue;
transient private List<Object> keyRecord;
- transient private String keyValueString;
+ private String keyValueString;
transient private String streamName;
transient private boolean saveKeyRecord = false;
transient private int outputsBeforePause = -1;