|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.net.NetUtils
public class NetUtils
Constructor Summary | |
---|---|
NetUtils()
|
Method Summary | |
---|---|
static void |
addStaticResolution(String host,
String resolvedName)
Adds a static resolution for host. |
static InetSocketAddress |
createSocketAddr(String target)
Util method to build socket addr from either: |
static InetSocketAddress |
createSocketAddr(String target,
int defaultPort)
Util method to build socket addr from either: |
static List<String[]> |
getAllStaticResolutions()
This is used to get all the resolutions that were added using addStaticResolution(String, String) . |
static InetSocketAddress |
getConnectAddress(Server server)
Returns InetSocketAddress that a client can use to connect to the server. |
static SocketFactory |
getDefaultSocketFactory(Configuration conf)
Get the default socket factory as specified by the configuration parameter hadoop.rpc.socket.factory.default |
static InputStream |
getInputStream(Socket socket)
Same as getInputStream(socket, socket.getSoTimeout()). From documentation for getInputStream(Socket, long) :Returns InputStream for the socket. |
static InputStream |
getInputStream(Socket socket,
long timeout)
Returns InputStream for the socket. |
static OutputStream |
getOutputStream(Socket socket)
Same as getOutputStream(socket, 0). |
static OutputStream |
getOutputStream(Socket socket,
long timeout)
Returns OutputStream for the socket. |
static String |
getServerAddress(Configuration conf,
String oldBindAddressName,
String oldPortName,
String newBindAddressName)
Deprecated. |
static SocketFactory |
getSocketFactory(Configuration conf,
Class<?> clazz)
Get the socket factory for the given class according to its configuration parameter hadoop.rpc.socket.factory.class.<ClassName>. |
static SocketFactory |
getSocketFactoryFromProperty(Configuration conf,
String propValue)
Get the socket factory corresponding to the given proxy URI. |
static String |
getStaticResolution(String host)
Retrieves the resolved name for the passed host. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public NetUtils()
Method Detail |
---|
public static SocketFactory getSocketFactory(Configuration conf, Class<?> clazz)
conf
- the configurationclazz
- the class (usually a VersionedProtocol
)
public static SocketFactory getDefaultSocketFactory(Configuration conf)
conf
- the configuration
public static SocketFactory getSocketFactoryFromProperty(Configuration conf, String propValue)
propValue
- the property which is the class name of the
SocketFactory to instantiate; assumed non null and non empty.
public static InetSocketAddress createSocketAddr(String target)
public static InetSocketAddress createSocketAddr(String target, int defaultPort)
@Deprecated public static String getServerAddress(Configuration conf, String oldBindAddressName, String oldPortName, String newBindAddressName)
conf
- the configuration to checkoldBindAddressName
- the old address attribute nameoldPortName
- the old port attribute namenewBindAddressName
- the new combined name
public static void addStaticResolution(String host, String resolvedName)
getStaticResolution(String)
can be used to query for
the actual hostname.
host
- resolvedName
- public static String getStaticResolution(String host)
addStaticResolution(String, String)
host
-
public static List<String[]> getAllStaticResolutions()
addStaticResolution(String, String)
. The return
value is a List each element of which contains an array of String
of the form String[0]=hostname, String[1]=resolved-hostname
public static InetSocketAddress getConnectAddress(Server server)
server
-
public static InputStream getInputStream(Socket socket) throws IOException
getInputStream(Socket, long)
:SocketInputStream
with the given timeout. If the socket does not
have a channel, Socket.getInputStream()
is returned. In the later
case, the timeout argument is ignored and the timeout set with
Socket.setSoTimeout(int)
applies for reads.NetUtils()
,
must use this interface instead of Socket.getInputStream()
.
socket
-
IOException
getInputStream(Socket, long)
public static InputStream getInputStream(Socket socket, long timeout) throws IOException
SocketInputStream
with the given timeout. If the socket does not
have a channel, Socket.getInputStream()
is returned. In the later
case, the timeout argument is ignored and the timeout set with
Socket.setSoTimeout(int)
applies for reads.NetUtils()
,
must use this interface instead of Socket.getInputStream()
.
socket
- timeout
- timeout in milliseconds. This may not always apply. zero
for waiting as long as necessary.
IOException
Socket.getChannel()
public static OutputStream getOutputStream(Socket socket) throws IOException
getOutputStream(Socket, long)
: SocketOutputStream
with the given timeout. If the socket does not
have a channel, Socket.getOutputStream()
is returned. In the later
case, the timeout argument is ignored and the write will wait until
data is available.NetUtils()
,
must use this interface instead of Socket.getOutputStream()
.
socket
-
IOException
getOutputStream(Socket, long)
public static OutputStream getOutputStream(Socket socket, long timeout) throws IOException
SocketOutputStream
with the given timeout. If the socket does not
have a channel, Socket.getOutputStream()
is returned. In the later
case, the timeout argument is ignored and the write will wait until
data is available.NetUtils()
,
must use this interface instead of Socket.getOutputStream()
.
socket
- timeout
- timeout in milliseconds. This may not always apply. zero
for waiting as long as necessary.
IOException
Socket.getChannel()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |