Class | Description |
---|---|
CollectiveMapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT> |
CollectiveMapper is extended from original
mapper in Hadoop.
|
MapCollectiveClientProtocolProvider |
A new ClientProtocalProvider to support
map-collective job, modified from
YarnClientProtocolProvider
|
MapCollectiveRunner |
This class is modified from YARNRunner for
submitting map-collective jobs.
|