2014-10-02 40 views
0

我已经使用分区方案并使用数据关联将相关数据一起存储在集群成员上。Oracle Coherence - 使用密钥检索特定成员

我只关心在整个数据的子集上执行我的Invocable。我可以找到存储我感兴趣的数据子集的特定成员吗?

目前我这样做:partitionedService.getOwnershipEnabledMembers()它让我所有节点在群集中运行此服务。

回答

0

您可以使用EntryProcessor并执行它针对的是要处理的数据,例如。

public class MyProc extends AbstractProcessor implements Serializable 
    { 
    public Object process(Entry entry) 
    { 
    System.out.println("*** processing " + entry.getKey()); 
    } 
    } 

现在运行的是,刚:

cache.invokeAll(collKeys, new MyProc()); 

...其中 “collKeys” 是键的集合缓存,或:

cache.invokeAll(filter, new MyProc()); 

...其中“过滤器”是对缓存的查询。