Procedure
- Listen on peer host:port
- Initialize IO
- Input
- Split class
- Restore split data from BSPTask.split
- Output Dir
- Reinitialize Writer
- Initialize Messaging service (HamaMessageManagerImpl.java)
- Initialize Barrier Sync service
BSPPeerImpl
- Task
- MessageManager
- IO init input
- instantiate and restore InputSplit through split class
- read next record or pair: TrackedRecordReader
- output dir: "bsp.output.dir" - tmp-${currentTimeMillis}/part-${partition}
collector: OutputCollector encapsulates writer (default TextOutputFormat).
{"serverDuration": 101, "requestCorrelationId": "add412a42d45c72a"}