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/09/04 20:19:45 UTC
[4/5] incubator-streams git commit: updated for PR feedback
updated for PR 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/e166f7d6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/e166f7d6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/e166f7d6
Branch: refs/heads/master
Commit: e166f7d60ec84de47db5f165552f1432a3816c27
Parents: 9dc44a4
Author: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Authored: Fri Sep 4 13:13:59 2015 -0500
Committer: Steve Blackmon (@steveblackmon) <sb...@apache.org>
Committed: Fri Sep 4 13:13:59 2015 -0500
----------------------------------------------------------------------
.../src/main/java/org/apache/streams/core/StreamsDatum.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/e166f7d6/streams-core/src/main/java/org/apache/streams/core/StreamsDatum.java
----------------------------------------------------------------------
diff --git a/streams-core/src/main/java/org/apache/streams/core/StreamsDatum.java b/streams-core/src/main/java/org/apache/streams/core/StreamsDatum.java
index 5654240..e0b17de 100644
--- a/streams-core/src/main/java/org/apache/streams/core/StreamsDatum.java
+++ b/streams-core/src/main/java/org/apache/streams/core/StreamsDatum.java
@@ -56,7 +56,7 @@ public class StreamsDatum implements Serializable {
}
public StreamsDatum(Object document, String id, DateTime timestamp) {
- this(document, id, timestamp, null);
+ this(document, id, timestamp, null, new HashMap<String, Object>());
}
public StreamsDatum(Object document, String id, Map<String, Object> metadata) {
@@ -68,7 +68,7 @@ public class StreamsDatum implements Serializable {
}
public StreamsDatum(Object document, String id, BigInteger sequenceid) {
- this(document, id, null, sequenceid);
+ this(document, id, sequenceid, new HashMap<String, Object>());
}
public StreamsDatum(Object document, String id, DateTime timestamp, BigInteger sequenceid) {