4

我无法理解 Hazelcast 分布式执行的概念。据说能够对特定密钥的所有者实例执行执行。
从文档：

   <T> Future<T> submitToKeyOwner(Callable<T> task, Object key)
   Submits task to owner of the specified key and returns a Future representing that task.
       Parameters:
            task - task
            key - key
       Returns:
            a Future representing pending completion of the task

我相信我并不孤单地拥有一个由多个地图构建的集群，这些地图实际上可能将相同的密钥用于不同的目的，持有不同的对象（例如，以下设置中的一些东西）：

IMap<String, ObjectTypeA> firstMap = HazelcastInstance.getMap("firstMap");
IMap<String, ObjectTypeA_AppendixClass> secondMap = HazelcastInstance.getMap("secondMap");

对我来说，文档中关于密钥所有者的内容似乎很令人困惑。我真正的沮丧是我不知道它指的是哪个 - 在哪个地图中 - 键？
该文档还提供了这种方法的“演示”：

import com.hazelcast.core.Member;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.IExecutorService;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;   
import java.util.Set;
import com.hazelcast.config.Config;

public void echoOnTheMemberOwningTheKey(String input, Object key) throws Exception {
   Callable<String> task = new Echo(input);
   HazelcastInstance hz = Hazelcast.newHazelcastInstance();
   IExecutorService executorService = hz.getExecutorService("default");
   Future<String> future = executorService.submitToKeyOwner(task, key);
   String echoResult = future.get();
}

这是文档站点的链接：Hazelcast MultiHTML Documentation 3.0 - Distributed Execution
你们中的任何人过去是否知道它想要什么键？

4

2 回答 2

4

也许我可以用一个代码示例更好地解释它：

   Callable<String> task = new Echo(input);

   String key = "foo";
   IMap map1 = hz.getMap("m1");
   IMap map2 = hz.getMap("m2");
   map1.put(key,1);
   map2.put(key,2);

   IExecutorService executorService = hz.getExecutorService("default");
   Future<String> future = executorService.submitToKeyOwner(task, key);
   String echoResult = future.get();

如您所见，有 2 个地图，map1 和 map2。

这两个映射都有一个映射条目，其键 'foo' 相同，但值不同。

但是这 2 个映射条目将最终在同一个分区中（因此在同一个成员上），因为密钥用于确定分区。

在最后几行中，任务被发送给密钥所有者，在这种情况下，我们将任务发送给拥有密钥 'foo' 的成员。因此，任务将被发送到存储两个映射条目的同一台机器上。

我没有检查你关于支持的讨论；这是对您在此处发布的关于堆栈溢出的原始问题的回答。

于 2013-11-01T08:57:48.030 回答
0

在 Hazelcast 中，您可以对数据进行分区，并在地图中使用密钥。

例如，当我有 2 个使用相同键的映射时，该键的映射条目将被放置在同一分区中的两个映射中。

所以使用哪张地图并不是很重要。

您可以使用执行程序将任务发送给拥有该分区的成员。

我希望这能回答您的问题，否则请随时询问更多信息。

于 2013-10-31T19:59:02.930 回答