org.apache.flink.util

Class NetUtils.Port

java.lang.Object

org.apache.flink.util.NetUtils.Port

All Implemented Interfaces:

AutoCloseable

Enclosing class:

NetUtils

public static class NetUtils.Port
extends Object
implements AutoCloseable

Port wrapper class which holds a FileLock until it releases. Used to avoid race condition among multiple threads/processes.

Constructor Summary

Constructors

Constructor and Description
Port(int port, FileLock fileLock)

Method Summary

Modifier and Type	Method and Description
void	close()
int	getPort()

Methods inherited from class java.lang.Object

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

Constructor Detail

Port

public Port(int port,
            FileLock fileLock)
     throws IOException

Throws:

IOException

Method Detail

getPort

public int getPort()

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception