STREAMS-236 | Entities are now passed through a Set to ensure that no duplicates make it into the Activity Object
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/bd1718aa Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/bd1718aa Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/bd1718aa Branch: refs/heads/STREAMS-212 Commit: bd1718aafe10b785342db05c7bd390d49da3ca29 Parents: 7afd6e0 Author: Robert Douglas <[email protected]> Authored: Tue Nov 25 17:10:47 2014 -0600 Committer: Robert Douglas <[email protected]> Committed: Tue Nov 25 17:10:47 2014 -0600 ---------------------------------------------------------------------- .../apache/streams/regex/AbstractRegexExtensionExtractor.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/bd1718aa/streams-contrib/streams-processor-regex/src/main/java/org/apache/streams/regex/AbstractRegexExtensionExtractor.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-processor-regex/src/main/java/org/apache/streams/regex/AbstractRegexExtensionExtractor.java b/streams-contrib/streams-processor-regex/src/main/java/org/apache/streams/regex/AbstractRegexExtensionExtractor.java index 88b2880..11f4b32 100644 --- a/streams-contrib/streams-processor-regex/src/main/java/org/apache/streams/regex/AbstractRegexExtensionExtractor.java +++ b/streams-contrib/streams-processor-regex/src/main/java/org/apache/streams/regex/AbstractRegexExtensionExtractor.java @@ -81,6 +81,12 @@ public abstract class AbstractRegexExtensionExtractor<T> implements StreamsProce for (String key : matches.keySet()) { entities.add(prepareObject(key)); } + + Set<T> set = Sets.newHashSet(); + set.addAll(entities); + entities.clear(); + entities.addAll(set); + entry.setDocument(activity); return Lists.newArrayList(entry); }
