计算网络

分发集群跨节点计算。

分布式计算，并行方式执行来获得高性能, 低延迟,和线性扩展.Ignite计算网络提供了一组简单的API,允许用户在集群中的多个节点进行分布式计算与分布式数据处理.分布式并行处理的基础上采取任何形式的计算和集群中的任何一组节点执行并且返回结果的功能.

Features

• Distributed Closure Execution
• MapReduce & ForkJoin Processing
• Clustered Executor Service
• Collocation of Compute and Data
• Load Balancing
• Fault Tolerance
• Job State Checkpointing
• Job Scheduling

IgniteCompute

IgniteCompute interface provides methods for running many types of computations over nodes in a cluster or a cluster group. These methods can be used to execute Tasks or Closures in distributed fashion.

All jobs and closures are guaranteed to be executed as long as there is at least one node standing. If a job execution is rejected due to lack of resources, a failover mechanism is provided. In case of failover, the load balancer picks the next available node to execute the job. Here is how you can get an IgniteCompute instance:

Java

Ignite ignite = Ignition.ignite();

// Get compute instance over all nodes in the cluster.
IgniteCompute compute = ignite.compute();

You can also limit the scope of computations to a Cluster Group. In this case, computation will only execute on the nodes within the cluster group.

Java

Ignite ignite = Ignitition.ignite();

ClusterGroup remoteGroup = ignite.cluster().forRemotes();

// Limit computations only to remote nodes (exclude local node).
IgniteCompute compute = ignite.compute(remoteGroup);