Interface Processor.Context

    • Method Detail

      • localProcessorIndex

        int localProcessorIndex()
        Returns the index of the processor among all the processors created for this vertex on a single node: it's a unique node-wide index.

        The value is in the range [0...localParallelism-1].

      • globalProcessorIndex

        int globalProcessorIndex()
        Returns the index of the processor among all the processors created for this vertex on all nodes: it's a unique cluster-wide index.

        The value is in the range [0...totalParallelism-1]. For example if there are 2 members in the cluster and local parallelism is 4, the processors on the 1st cluster member will have indexes 0..3 and on the second member they will have indexes 4..7.