OneForOneStreamManager

OneForOneStreamManager is a StreamManager.

Creating Instance

OneForOneStreamManager takes no arguments to be created.

OneForOneStreamManager is created for ExternalShuffleBlockHandler and ExternalShuffleClient (indirectly via NoOpRpcHandler).

registerStream Method

long registerStream(
  String appId,
  Iterator<ManagedBuffer> buffers)

registerStream…​FIXME

registerStream is used when…​FIXME