org.apache.flink.util

Class NetUtils

java.lang.Object

org.apache.flink.util.NetUtils

@Internal
public class NetUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	NetUtils.SocketFactory

Constructor Summary

Constructors

Constructor and Description
NetUtils()

Method Summary

Modifier and Type	Method and Description
static ServerSocket	createSocketFromPorts(Iterator<Integer> portsIterator, NetUtils.SocketFactory factory) Tries to allocate a socket from the given sets of ports.
static int	getAvailablePort() Find a non-occupied port.
static URL	getCorrectHostnamePort(String hostPort) Method to validate if the given String represents a hostname:port.
static String	getHostnameFromFQDN(String fqdn) Turn a fully qualified domain name (fqdn) into a hostname.
static Iterator<Integer>	getPortRangeFromString(String rangeDefinition) Returns an iterator over available ports defined by the range definition.
static String	hostAndPortToUrlString(String host, int port) Normalizes and encodes a hostname and port to be included in URL.
static String	ipAddressAndPortToUrlString(InetAddress address, int port) Encodes an IP address and port to be included in URL.
static String	ipAddressToUrlString(InetAddress address) Encodes an IP address properly as a URL string.
static String	socketAddressToUrlString(InetSocketAddress address) Encodes an IP address and port to be included in URL.

Methods inherited from class java.lang.Object

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

Constructor Detail

NetUtils

public NetUtils()

Method Detail

getHostnameFromFQDN

public static String getHostnameFromFQDN(String fqdn)

Turn a fully qualified domain name (fqdn) into a hostname. If the fqdn has multiple subparts (separated by a period '.'), it will take the first part. Otherwise it takes the entire fqdn.

Parameters:

fqdn - The fully qualified domain name.

Returns:

The hostname.

getCorrectHostnamePort

public static URL getCorrectHostnamePort(String hostPort)

Method to validate if the given String represents a hostname:port. Works also for ipv6. See: http://stackoverflow.com/questions/2345063/java-common-way-to-validate-and-convert-hostport-to-inetsocketaddress

Returns:

URL object for accessing host and Port

getAvailablePort

public static int getAvailablePort()

Find a non-occupied port.

Returns:

A non-occupied port.

ipAddressToUrlString

public static String ipAddressToUrlString(InetAddress address)

Encodes an IP address properly as a URL string. This method makes sure that IPv6 addresses have the proper formatting to be included in URLs.

This method internally uses Guava's functionality to properly encode IPv6 addresses.

Parameters:

address - The IP address to encode.

Returns:

The proper URL string encoded IP address.

ipAddressAndPortToUrlString

public static String ipAddressAndPortToUrlString(InetAddress address,
                                                 int port)

Encodes an IP address and port to be included in URL. in particular, this method makes sure that IPv6 addresses have the proper formatting to be included in URLs.

Parameters:

address - The address to be included in the URL.

port - The port for the URL address.

Returns:

The proper URL string encoded IP address and port.

socketAddressToUrlString

public static String socketAddressToUrlString(InetSocketAddress address)

Encodes an IP address and port to be included in URL. in particular, this method makes sure that IPv6 addresses have the proper formatting to be included in URLs.

Parameters:

address - The socket address with the IP address and port.

Returns:

The proper URL string encoded IP address and port.

hostAndPortToUrlString

public static String hostAndPortToUrlString(String host,
                                            int port)
                                     throws UnknownHostException

Normalizes and encodes a hostname and port to be included in URL. In particular, this method makes sure that IPv6 address literals have the proper formatting to be included in URLs.

Parameters:

host - The address to be included in the URL.

port - The port for the URL address.

Returns:

The proper URL string encoded IP address and port.

Throws:

UnknownHostException - Thrown, if the hostname cannot be translated into a URL.

getPortRangeFromString

public static Iterator<Integer> getPortRangeFromString(String rangeDefinition)
                                                throws NumberFormatException

Returns an iterator over available ports defined by the range definition.

Parameters:

rangeDefinition - String describing a single port, a range of ports or multiple ranges.

Returns:

Set of ports from the range definition

Throws:

NumberFormatException - If an invalid string is passed.

createSocketFromPorts

public static ServerSocket createSocketFromPorts(Iterator<Integer> portsIterator,
                                                 NetUtils.SocketFactory factory)
                                          throws IOException

Tries to allocate a socket from the given sets of ports.

Parameters:

portsIterator - A set of ports to choose from.

factory - A factory for creating the SocketServer

Returns:

null if no port was available or an allocated socket.

Throws:

IOException