Differences between revisions 14 and 15
Revision 14 as of 2014-06-09 06:18:01
Size: 1123
Editor: ChiaHungLin
Comment:
Revision 15 as of 2014-06-09 06:28:09
Size: 1180
Editor: ChiaHungLin
Comment:
Deletions are marked like this. Additions are marked like this.
Line 36: Line 36:
   * instantiate split class
   * TrackedRecordReader
   * instantiate and restore InputSplit through split class
   * read next record or pair: TrackedRecordReader

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

BSPPeer (last edited 2014-06-09 06:28:09 by ChiaHungLin)