currentWorkerFor

protected abstract WorkerId currentWorkerFor(NodeId node)

Returns an identifier of the current worker that is now going to process the shard.

An example of such an identifier could be ID of the thread which performs processing.

Parameters

node

the node to which the resulted worker belongs