Procedure
- Listen on peer host:port
- Initialize IO
- Input
- Split class
- Restore split data from BSPTask.split
- Output Dir
- Reinitialize Writer
- Input
- Initialize Messaging service (HamaMessageManagerImpl.java)
- Initialize Barrier Sync service
BSPPeerImpl
- Task
- TaskAttemptID
- partition
- splitClass
- split: ByteWritable
- superstep