Interface ProcessorMetaSupplier

All Superinterfaces:
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

public interface ProcessorMetaSupplier
extends Serializable
Factory of ProcessorSupplier instances. The starting point of the chain leading to the eventual creation of Processor instances on each cluster member:
  1. client creates ProcessorMetaSupplier as a part of the DAG;
  2. serializes it and sends to a cluster member;
  3. the member deserializes and uses it to create one ProcessorSupplier for each cluster member;
  4. serializes each ProcessorSupplier and sends it to its target member;
  5. the target member deserializes and uses it to instantiate as many instances of Processor as requested by the parallelism property on the corresponding Vertex.
Before being asked to create ProcessorSuppliers this meta-supplier will be given access to the Hazelcast instance and, in particular, its cluster topology and partitioning services. It can use the information from these services to precisely parameterize each Processor instance that will be created on each member.