@@ -0,0 +1,901 @@
+package com.kryptnostic.rhizome.hazelcast.processors;%0A%0Aimport java.util.Map.Entry;%0A%0Aimport com.google.common.collect.Sets;%0A%0Aimport java.util.Set;%0A%0Apublic abstract class SetContainsAnyEntryProcessor%3CT%3E extends AbstractRhizomeEntryProcessor%3CT, Set%3CT%3E%3E %7B%0A%0A    private static final long serialVersionUID = -1578286848277056995L;%0A    private final Set%3CT%3E      objectsToCheck;%0A%0A    public SetContainsAnyEntryProcessor( Set%3CT%3E objectsToCheck ) %7B%0A        super( false /* don't apply on backup nodes */ );%0A        this.objectsToCheck = objectsToCheck;%0A    %7D%0A%0A    public Set%3CT%3E getObjectsToCheck() %7B%0A        return objectsToCheck;%0A    %7D%0A%0A    @Override%0A    public Object process( Entry%3CT, Set%3CT%3E%3E entry ) %7B%0A        Set%3CT%3E value = entry.getValue();%0A        if ( value == null %7C%7C value.isEmpty() ) %7B%0A            return null;%0A        %7D%0A        return !Sets.intersection( value, objectsToCheck ).isEmpty();%0A    %7D%0A%0A%7D%0A

Add EntryProcessor for checking set intersections