org.apache.hadoop.mapred

Class MapCollectiveClientProtocolProvider

java.lang.Object

ClientProtocolProvider

org.apache.hadoop.mapred.MapCollectiveClientProtocolProvider

public class MapCollectiveClientProtocolProvider
extends ClientProtocolProvider

A new ClientProtocalProvider to support map-collective job, modified from YarnClientProtocolProvider

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	MAP_COLLECTIVE_FRAMEWORK_NAME

Constructor Summary

Constructors

Constructor and Description
MapCollectiveClientProtocolProvider()

Method Summary

Modifier and Type	Method and Description
void	close(ClientProtocol clientProtocol)
ClientProtocol	create(Configuration conf)
ClientProtocol	create(java.net.InetSocketAddress addr, Configuration conf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MAP_COLLECTIVE_FRAMEWORK_NAME

public static java.lang.String MAP_COLLECTIVE_FRAMEWORK_NAME

Constructor Detail

MapCollectiveClientProtocolProvider

public MapCollectiveClientProtocolProvider()

Method Detail

create

public ClientProtocol create(Configuration conf)
                      throws java.io.IOException

Throws:

java.io.IOException

create

public ClientProtocol create(java.net.InetSocketAddress addr,
                             Configuration conf)
                      throws java.io.IOException

Throws:

java.io.IOException

close

public void close(ClientProtocol clientProtocol)
           throws java.io.IOException

Throws:

java.io.IOException