Repository: incubator-reef Updated Branches: refs/heads/master cf158e098 -> eeafba31c
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/TcpPortProvider.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/TcpPortProvider.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/TcpPortProvider.java index 1b4803c..51a8f6e 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/TcpPortProvider.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/TcpPortProvider.java @@ -29,7 +29,7 @@ import java.util.Iterator; @DefaultImplementation(RangeTcpPortProvider.class) public interface TcpPortProvider extends Iterable<Integer> { /** - * Returns an iterator over a set of tcp ports + * Returns an iterator over a set of tcp ports. * * @return an Iterator. */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeBegin.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeBegin.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeBegin.java index 83bf9a1..f3ab969 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeBegin.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeBegin.java @@ -22,7 +22,7 @@ import org.apache.reef.tang.annotations.Name; import org.apache.reef.tang.annotations.NamedParameter; /** - * First tcp port number to try + * First tcp port number to try. */ @NamedParameter(doc = "First tcp port number to try", default_value = TcpPortRangeBegin.default_value) public class TcpPortRangeBegin implements Name<Integer> { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeCount.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeCount.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeCount.java index e5727e2..23fada5 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeCount.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeCount.java @@ -22,7 +22,7 @@ import org.apache.reef.tang.annotations.Name; import org.apache.reef.tang.annotations.NamedParameter; /** - * Number of tcp ports in the range + * Number of tcp ports in the range. */ @NamedParameter(doc = "Number of tcp ports in the range", default_value = TcpPortRangeCount.default_value) public class TcpPortRangeCount implements Name<Integer> { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeTryCount.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeTryCount.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeTryCount.java index 7aaa4af..daaafac 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeTryCount.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/ports/parameters/TcpPortRangeTryCount.java @@ -22,7 +22,7 @@ import org.apache.reef.tang.annotations.Name; import org.apache.reef.tang.annotations.NamedParameter; /** - * Max number tries for port numbers + * Max number tries for port numbers. */ @NamedParameter(doc = "Max number tries for port numbers", default_value = TcpPortRangeTryCount.default_value) public class TcpPortRangeTryCount implements Name<Integer> { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/LinkListener.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/LinkListener.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/LinkListener.java index 7cd101d..cdc7040 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/LinkListener.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/LinkListener.java @@ -21,14 +21,14 @@ package org.apache.reef.wake.remote.transport; import java.net.SocketAddress; /** - * Link listener + * Link listener. * * @param <T> type */ public interface LinkListener<T> { /** - * Called when the sent message is successfully transferred + * Called when the sent message is successfully transferred. * * @param message the sent message */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/Transport.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/Transport.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/Transport.java index 4a79fc1..5881deb 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/Transport.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/Transport.java @@ -26,7 +26,7 @@ import java.io.IOException; import java.net.SocketAddress; /** - * Transport for sending and receiving data + * Transport for sending and receiving data. */ public interface Transport extends Stage { @@ -35,7 +35,7 @@ public interface Transport extends Stage { */ /** - * Returns a link for the remote address if cached; otherwise opens, caches and returns + * Returns a link for the remote address if cached; otherwise opens, caches and returns. * When it opens a link for the remote address, only one attempt for the address is made at a given time * * @param remoteAddr the remote socket address @@ -47,7 +47,7 @@ public interface Transport extends Stage { public <T> Link<T> open(SocketAddress remoteAddr, Encoder<? super T> encoder, LinkListener<? super T> listener) throws IOException; /** - * Returns a link for the remote address if already cached; otherwise, returns null + * Returns a link for the remote address if already cached; otherwise, returns null. * * @param remoteAddr the remote address * @return a link if already cached; otherwise, null @@ -55,21 +55,21 @@ public interface Transport extends Stage { public <T> Link<T> get(SocketAddress remoteAddr); /** - * Gets a server listening port of this transport + * Gets a server listening port of this transport. * * @return a listening port number */ public int getListeningPort(); /** - * Gets a server local socket address of this transport + * Gets a server local socket address of this transport. * * @return a server local socket address */ public SocketAddress getLocalAddress(); /** - * Registers the exception handler + * Registers the exception handler. * * @param handler the exception handler */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/TransportFactory.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/TransportFactory.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/TransportFactory.java index a09339b..2bdcff9 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/TransportFactory.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/TransportFactory.java @@ -26,13 +26,13 @@ import org.apache.reef.wake.remote.ports.TcpPortProvider; import org.apache.reef.wake.remote.transport.netty.MessagingTransportFactory; /** - * Factory that creates a transport + * Factory that creates a transport. */ @DefaultImplementation(MessagingTransportFactory.class) public interface TransportFactory { /** - * Creates a transport + * Creates a transport. * * @param port a listening port * @param clientHandler a transport client-side handler @@ -46,7 +46,7 @@ public interface TransportFactory { EventHandler<Exception> exHandler); /** - * Creates a transport + * Creates a transport. * * @param hostAddress a host address * @param port a listening port @@ -63,7 +63,7 @@ public interface TransportFactory { final int retryTimeout); /** - * Creates a transport + * Creates a transport. * * @param hostAddress a host address * @param port a listening port http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/exception/TransportRuntimeException.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/exception/TransportRuntimeException.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/exception/TransportRuntimeException.java index 457b4c0..0b40c23 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/exception/TransportRuntimeException.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/exception/TransportRuntimeException.java @@ -19,13 +19,13 @@ package org.apache.reef.wake.remote.transport.exception; /** - * Transport runtime exception + * Transport runtime exception. */ public class TransportRuntimeException extends RuntimeException { private static final long serialVersionUID = 1L; /** - * Constructs a new runtime transport exception with the specified detail message and cause + * Constructs a new runtime transport exception with the specified detail message and cause. * * @param s the detailed message * @param e the cause @@ -35,7 +35,7 @@ public class TransportRuntimeException extends RuntimeException { } /** - * Constructs a new runtime transport exception with the specified detail message + * Constructs a new runtime transport exception with the specified detail message. * * @param s the detailed message */ @@ -44,11 +44,11 @@ public class TransportRuntimeException extends RuntimeException { } /** - * Constructs a new runtime transport exception with the specified cause + * Constructs a new runtime transport exception with the specified cause. * * @param e the cause */ public TransportRuntimeException(Throwable e) { super(e); } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/ByteEncoder.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/ByteEncoder.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/ByteEncoder.java index d296673..88fb348 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/ByteEncoder.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/ByteEncoder.java @@ -21,7 +21,7 @@ package org.apache.reef.wake.remote.transport.netty; import org.apache.reef.wake.remote.Encoder; /** - * Wrapping encoder for byte[] + * Wrapping encoder for byte[]. */ public class ByteEncoder implements Encoder<byte[]> { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/ChunkedReadWriteHandler.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/ChunkedReadWriteHandler.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/ChunkedReadWriteHandler.java index 09184a6..1693dc8 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/ChunkedReadWriteHandler.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/ChunkedReadWriteHandler.java @@ -135,7 +135,7 @@ public class ChunkedReadWriteHandler extends ChunkedWriteHandler { } /** - * Converts the int size into a byte[] + * Converts the int size into a byte[]. * * @return the bit representation of size */ @@ -149,14 +149,14 @@ public class ChunkedReadWriteHandler extends ChunkedWriteHandler { } /** - * Get expected size encoded as the first 4 bytes of data + * Get expected size encoded as the first 4 bytes of data. */ private int getSize(final byte[] data) { return getSize(data, 0); } /** - * Get expected size encoded as offset + 4 bytes of data + * Get expected size encoded as offset + 4 bytes of data. */ private int getSize(final byte[] data, final int offset) { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/LoggingLinkListener.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/LoggingLinkListener.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/LoggingLinkListener.java index 1f77684..b96729c 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/LoggingLinkListener.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/LoggingLinkListener.java @@ -25,7 +25,7 @@ import java.util.logging.Level; import java.util.logging.Logger; /** - * Link listener that logs whether the message is sent successfully + * Link listener that logs whether the message is sent successfully. * * @param <T> type */ @@ -34,7 +34,7 @@ public class LoggingLinkListener<T> implements LinkListener<T> { private static final Logger LOG = Logger.getLogger(LoggingLinkListener.class.getName()); /** - * Called when the sent message is transferred successfully + * Called when the sent message is transferred successfully. */ @Override public void onSuccess(T message) { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/MessagingTransportFactory.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/MessagingTransportFactory.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/MessagingTransportFactory.java index b77f804..8921486 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/MessagingTransportFactory.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/MessagingTransportFactory.java @@ -36,7 +36,7 @@ import org.apache.reef.wake.remote.transport.TransportFactory; import javax.inject.Inject; /** - * Factory that creates a messaging transport + * Factory that creates a messaging transport. */ public class MessagingTransportFactory implements TransportFactory { @@ -60,7 +60,7 @@ public class MessagingTransportFactory implements TransportFactory { } /** - * Creates a transport + * Creates a transport. * * @param port a listening port * @param clientHandler a transport client side handler http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelHandler.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelHandler.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelHandler.java index 00f53ba..e33333b 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelHandler.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelHandler.java @@ -37,7 +37,7 @@ class NettyChannelHandler extends ChannelInboundHandlerAdapter { private final NettyEventListener listener; /** - * Constructs a Netty channel handler + * Constructs a Netty channel handler. * * @param tag tag string * @param channelGroup the channel group @@ -69,7 +69,7 @@ class NettyChannelHandler extends ChannelInboundHandlerAdapter { } /** - * Handles the channel active event + * Handles the channel active event. * * @param ctx the context object for this handler * @throws Exception @@ -82,7 +82,7 @@ class NettyChannelHandler extends ChannelInboundHandlerAdapter { } /** - * Handles the channel inactive event + * Handles the channel inactive event. * * @param ctx the context object for this handler * @throws Exception @@ -94,7 +94,7 @@ class NettyChannelHandler extends ChannelInboundHandlerAdapter { } /** - * Handles the exception event + * Handles the exception event. * * @param ctx the context object for this handler * @param cause the cause http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelHandlerFactory.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelHandlerFactory.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelHandlerFactory.java index 61606cb..cd782f7 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelHandlerFactory.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelHandlerFactory.java @@ -22,12 +22,12 @@ import io.netty.channel.ChannelInboundHandlerAdapter; /** - * Factory that creates a Netty channel handler + * Factory that creates a Netty channel handler. */ interface NettyChannelHandlerFactory { /** - * Creates a channel inbound handler + * Creates a channel inbound handler. * * @return a channel inbound handler adapter */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelInitializer.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelInitializer.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelInitializer.java index 535a232..f090adf 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelInitializer.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyChannelInitializer.java @@ -26,7 +26,7 @@ import io.netty.handler.codec.bytes.ByteArrayDecoder; import io.netty.handler.codec.bytes.ByteArrayEncoder; /** - * Netty channel initializer for Transport + * Netty channel initializer for Transport. * <p/> * MAXFRAMELENGTH : the buffer size of the frame decoder */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyDefaultChannelHandlerFactory.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyDefaultChannelHandlerFactory.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyDefaultChannelHandlerFactory.java index 5707dc2..022504f 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyDefaultChannelHandlerFactory.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyDefaultChannelHandlerFactory.java @@ -22,7 +22,7 @@ import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.channel.group.ChannelGroup; /** - * Default Netty channel handler factory + * Default Netty channel handler factory. */ final class NettyDefaultChannelHandlerFactory implements NettyChannelHandlerFactory { @@ -38,7 +38,7 @@ final class NettyDefaultChannelHandlerFactory implements NettyChannelHandlerFact } /** - * Creates a Netty channel handler + * Creates a Netty channel handler. * * @return a simple channel upstream handler. */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyEventListener.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyEventListener.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyEventListener.java index 1d6ffe1..2ebd991 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyEventListener.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyEventListener.java @@ -21,12 +21,12 @@ package org.apache.reef.wake.remote.transport.netty; import io.netty.channel.ChannelHandlerContext; /** - * Netty event listener + * Netty event listener. */ interface NettyEventListener { /** - * Handles the message + * Handles the message. * * @param ctx the channel handler context * @param msg the message @@ -34,7 +34,7 @@ interface NettyEventListener { void channelRead(ChannelHandlerContext ctx, Object msg); /** - * Handles the exception event + * Handles the exception event. * * @param ctx the channel handler context * @param cause the cause @@ -42,14 +42,14 @@ interface NettyEventListener { void exceptionCaught(ChannelHandlerContext ctx, Throwable cause); /** - * Handles the channel active event + * Handles the channel active event. * * @param ctx the channel handler context */ void channelActive(ChannelHandlerContext ctx); /** - * Handles the channel inactive event + * Handles the channel inactive event. * * @param ctx the channel handler context */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyLink.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyLink.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyLink.java index 5971d98..ffc8e33 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyLink.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyLink.java @@ -45,7 +45,7 @@ public class NettyLink<T> implements Link<T> { private final LinkListener<? super T> listener; /** - * Constructs a link + * Constructs a link. * * @param channel the channel * @param encoder the encoder @@ -55,7 +55,7 @@ public class NettyLink<T> implements Link<T> { } /** - * Constructs a link + * Constructs a link. * * @param channel the channel * @param encoder the encoder @@ -70,7 +70,7 @@ public class NettyLink<T> implements Link<T> { /** - * Writes the message to this link + * Writes the message to this link. * * @param message the message */ @@ -88,7 +88,7 @@ public class NettyLink<T> implements Link<T> { } /** - * Gets a local address of the link + * Gets a local address of the link. * * @return a local socket address */ @@ -98,7 +98,7 @@ public class NettyLink<T> implements Link<T> { } /** - * Gets a remote address of the link + * Gets a remote address of the link. * * @return a remote socket address */ @@ -131,4 +131,4 @@ class NettyChannelFutureListener<T> implements ChannelFutureListener { listener.onException(channelFuture.cause(), channelFuture.channel().remoteAddress(), message); } } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyMessagingTransport.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyMessagingTransport.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyMessagingTransport.java index dff38bd..301a8c7 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyMessagingTransport.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/remote/transport/netty/NettyMessagingTransport.java @@ -61,7 +61,7 @@ import java.util.logging.Level; import java.util.logging.Logger; /** - * Messaging transport implementation with Netty + * Messaging transport implementation with Netty. */ public class NettyMessagingTransport implements Transport { @@ -100,7 +100,7 @@ public class NettyMessagingTransport implements Transport { /** - * Constructs a messaging transport + * Constructs a messaging transport. * * @param hostAddress the server host address * @param port the server listening port; when it is 0, randomly assign a port number @@ -125,7 +125,7 @@ public class NettyMessagingTransport implements Transport { retryTimeout, tcpPortProvider, LocalAddressProviderFactory.getInstance()); } /** - * Constructs a messaging transport + * Constructs a messaging transport. * * @param hostAddress the server host address * @param port the server listening port; when it is 0, randomly assign a port number @@ -220,7 +220,7 @@ public class NettyMessagingTransport implements Transport { } /** - * Constructs a messaging transport + * Constructs a messaging transport. * * @param hostAddress the server host address * @param port the server listening port; when it is 0, randomly assign a port number @@ -241,7 +241,7 @@ public class NettyMessagingTransport implements Transport { } /** - * Closes all channels and releases all resources + * Closes all channels and releases all resources. */ @Override public void close() throws Exception { @@ -259,7 +259,7 @@ public class NettyMessagingTransport implements Transport { } /** - * Returns a link for the remote address if cached; otherwise opens, caches and returns + * Returns a link for the remote address if cached; otherwise opens, caches and returns. * When it opens a link for the remote address, only one attempt for the address is made at a given time * * @param remoteAddr the remote socket address @@ -358,7 +358,7 @@ public class NettyMessagingTransport implements Transport { } /** - * Returns a link for the remote address if already cached; otherwise, returns null + * Returns a link for the remote address if already cached; otherwise, returns null. * * @param remoteAddr the remote address * @return a link if already cached; otherwise, null @@ -369,7 +369,7 @@ public class NettyMessagingTransport implements Transport { } /** - * Gets a server local socket address of this transport + * Gets a server local socket address of this transport. * * @return a server local socket address */ @@ -379,7 +379,7 @@ public class NettyMessagingTransport implements Transport { } /** - * Gets a server listening port of this transport + * Gets a server listening port of this transport. * * @return a listening port number */ @@ -389,7 +389,7 @@ public class NettyMessagingTransport implements Transport { } /** - * Registers the exception event handler + * Registers the exception event handler. * * @param handler the exception event handler */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/AbstractRxStage.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/AbstractRxStage.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/AbstractRxStage.java index 6aa2e8e..4452656 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/AbstractRxStage.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/AbstractRxStage.java @@ -23,7 +23,7 @@ import org.apache.reef.wake.metrics.Meter; import java.util.concurrent.atomic.AtomicBoolean; /** - * An {@link RxStage} that implements metering + * An {@link RxStage} that implements metering. * * @param <T> type */ @@ -35,7 +35,7 @@ public abstract class AbstractRxStage<T> implements RxStage<T> { protected final Meter outMeter; /** - * Constructs an abstact rxstage + * Constructs an abstact rxstage. * * @param stageName the stage name */ @@ -67,7 +67,7 @@ public abstract class AbstractRxStage<T> implements RxStage<T> { } /** - * Gets the input meter of this stage + * Gets the input meter of this stage. * * @return the input meter */ @@ -76,7 +76,7 @@ public abstract class AbstractRxStage<T> implements RxStage<T> { } /** - * Gets the output meter of this stage + * Gets the output meter of this stage. * * @return the output meter */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/DynamicObservable.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/DynamicObservable.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/DynamicObservable.java index e178328..e87cd16 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/DynamicObservable.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/DynamicObservable.java @@ -27,7 +27,7 @@ package org.apache.reef.wake.rx; public interface DynamicObservable<T> extends Observable { /** - * Subscribes the observer to this observable object + * Subscribes the observer to this observable object. * * @param o the observer * @return a subscription handle http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/Observable.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/Observable.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/Observable.java index a82b4fd..5e4521c 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/Observable.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/Observable.java @@ -19,7 +19,7 @@ package org.apache.reef.wake.rx; /** - * Defines a provider for push-based notification + * Defines a provider for push-based notification. */ public interface Observable { } http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/RxStage.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/RxStage.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/RxStage.java index 36d1193..4b7d399 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/RxStage.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/RxStage.java @@ -21,7 +21,7 @@ package org.apache.reef.wake.rx; import org.apache.reef.wake.Stage; /** - * Stage that executes the observer + * Stage that executes the observer. * * @param <T> type */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/RxSyncStage.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/RxSyncStage.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/RxSyncStage.java index bd20868..2c6d28c 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/RxSyncStage.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/RxSyncStage.java @@ -28,7 +28,7 @@ import org.apache.reef.wake.rx.Observer; import javax.inject.Inject; /** - * Stage that executes the observer synchronously + * Stage that executes the observer synchronously. * * @param <T> type */ @@ -37,7 +37,7 @@ public final class RxSyncStage<T> extends AbstractRxStage<T> { private final Observer<T> observer; /** - * Constructs a Rx synchronous stage + * Constructs a Rx synchronous stage. * * @param observer the observer */ @@ -47,7 +47,7 @@ public final class RxSyncStage<T> extends AbstractRxStage<T> { } /** - * Constructs a Rx synchronous stage + * Constructs a Rx synchronous stage. * * @param name the stage name * @param observer the observer @@ -61,7 +61,7 @@ public final class RxSyncStage<T> extends AbstractRxStage<T> { } /** - * Provides the observer with the new value + * Provides the observer with the new value. * * @param value the new value */ @@ -93,7 +93,7 @@ public final class RxSyncStage<T> extends AbstractRxStage<T> { } /** - * Closes the stage + * Closes the stage. * * @throws Exception */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/RxThreadPoolStage.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/RxThreadPoolStage.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/RxThreadPoolStage.java index 6fcb53f..6b0a00b 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/RxThreadPoolStage.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/RxThreadPoolStage.java @@ -59,7 +59,7 @@ public final class RxThreadPoolStage<T> extends AbstractRxStage<T> { private DefaultThreadFactory tf; /** - * Constructs a Rx thread pool stage + * Constructs a Rx thread pool stage. * * @param observer the observer to execute * @param numThreads the number of threads @@ -71,7 +71,7 @@ public final class RxThreadPoolStage<T> extends AbstractRxStage<T> { } /** - * Constructs a Rx thread pool stage + * Constructs a Rx thread pool stage. * * @param name the stage name * @param observer the observer to execute @@ -92,7 +92,7 @@ public final class RxThreadPoolStage<T> extends AbstractRxStage<T> { } /** - * Provides the observer with the new value + * Provides the observer with the new value. * * @param value the new value */ @@ -165,7 +165,7 @@ public final class RxThreadPoolStage<T> extends AbstractRxStage<T> { } /** - * Closes the stage + * Closes the stage. * * @return Exception */ @@ -188,7 +188,7 @@ public final class RxThreadPoolStage<T> extends AbstractRxStage<T> { } /** - * Gets the queue length of this stage + * Gets the queue length of this stage. * * @return the queue length */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/SimpleSubject.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/SimpleSubject.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/SimpleSubject.java index e2ded58..6f6395f 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/SimpleSubject.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/rx/impl/SimpleSubject.java @@ -33,7 +33,7 @@ public class SimpleSubject<T> implements Subject<T, T> { private final Observer<T> observer; /** - * Constructs a simple subject + * Constructs a simple subject. * * @param observer the observer */ @@ -43,7 +43,7 @@ public class SimpleSubject<T> implements Subject<T, T> { } /** - * Provides the observer with the new value + * Provides the observer with the new value. * * @param value the new value */ @@ -53,7 +53,7 @@ public class SimpleSubject<T> implements Subject<T, T> { } /** - * Provides the observer with the error + * Provides the observer with the error. * * @param error the error */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/time/Clock.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/time/Clock.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/time/Clock.java index 782581d..27deb0b 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/time/Clock.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/time/Clock.java @@ -42,7 +42,7 @@ import java.util.Set; public interface Clock extends Runnable, AutoCloseable { /** - * Schedule a TimerEvent at the given future offset + * Schedule a TimerEvent at the given future offset. * * @param handler to be called * @param offset into the future @@ -71,35 +71,35 @@ public interface Clock extends Runnable, AutoCloseable { public boolean isIdle(); /** - * Bind this to an event handler to statically subscribe to the StartTime Event + * Bind this to an event handler to statically subscribe to the StartTime Event. */ @NamedParameter(default_class = MissingStartHandlerHandler.class, doc = "Will be called upon the start event") public class StartHandler implements Name<Set<EventHandler<StartTime>>> { } /** - * Bind this to an event handler to statically subscribe to the StopTime Event + * Bind this to an event handler to statically subscribe to the StopTime Event. */ @NamedParameter(default_class = LoggingEventHandler.class, doc = "Will be called upon the stop event") public class StopHandler implements Name<Set<EventHandler<StopTime>>> { } /** - * Bind this to an event handler to statically subscribe to the RuntimeStart Event + * Bind this to an event handler to statically subscribe to the RuntimeStart Event. */ @NamedParameter(default_class = LoggingEventHandler.class, doc = "Will be called upon the runtime start event") public class RuntimeStartHandler implements Name<Set<EventHandler<RuntimeStart>>> { } /** - * Bind this to an event handler to statically subscribe to the RuntimeStart Event + * Bind this to an event handler to statically subscribe to the RuntimeStart Event. */ @NamedParameter(default_class = LoggingEventHandler.class, doc = "Will be called upon the runtime stop event") public class RuntimeStopHandler implements Name<Set<EventHandler<RuntimeStop>>> { } /** - * Bind this to an event handler to statically subscribe to the IdleClock Event + * Bind this to an event handler to statically subscribe to the IdleClock Event. */ @NamedParameter(default_class = LoggingEventHandler.class, doc = "Will be called upon the Idle event") public class IdleHandler implements Name<Set<EventHandler<IdleClock>>> { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/time/Time.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/time/Time.java b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/time/Time.java index 9678d0b..17cb1a8 100644 --- a/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/time/Time.java +++ b/lang/java/reef-wake/wake/src/main/java/org/apache/reef/wake/time/Time.java @@ -19,7 +19,7 @@ package org.apache.reef.wake.time; /** - * Time object + * Time object. */ public abstract class Time implements Comparable<Time> { @@ -59,4 +59,4 @@ public abstract class Time implements Comparable<Time> { public final int hashCode() { return super.hashCode(); } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/AvroEvaluatorInfoSerializer.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/AvroEvaluatorInfoSerializer.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/AvroEvaluatorInfoSerializer.java index 85bda5b..4de45cd 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/AvroEvaluatorInfoSerializer.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/AvroEvaluatorInfoSerializer.java @@ -84,7 +84,7 @@ public class AvroEvaluatorInfoSerializer implements EvaluatorInfoSerializer { } /** - * Convert AvroEvaluatorsInfo object to JSON string + * Convert AvroEvaluatorsInfo object to JSON string. */ @Override public String toString(final AvroEvaluatorsInfo avroEvaluatorsInfo) { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/AvroHttpSerializer.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/AvroHttpSerializer.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/AvroHttpSerializer.java index f3fe9d9..1bac080 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/AvroHttpSerializer.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/AvroHttpSerializer.java @@ -87,7 +87,7 @@ public class AvroHttpSerializer { } /** - * Conver AvroHttpRequest to a file + * Conver AvroHttpRequest to a file. * @param avroHttpRequest * @param file * @throws IOException @@ -102,7 +102,7 @@ public class AvroHttpSerializer { } /** - * Convert a file to AvroHttpRequest + * Convert a file to AvroHttpRequest. * @param file * @return * @throws IOException http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/DriverInfoSerializer.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/DriverInfoSerializer.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/DriverInfoSerializer.java index 13eda79..e789f48 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/DriverInfoSerializer.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/DriverInfoSerializer.java @@ -23,12 +23,12 @@ import org.apache.reef.tang.annotations.DefaultImplementation; import java.util.List; /** - * Interface for DriverInfoSerializer + * Interface for DriverInfoSerializer. */ @DefaultImplementation(AvroDriverInfoSerializer.class) public interface DriverInfoSerializer { /** - * Build AvroDriverInfo object from raw data + * Build AvroDriverInfo object from raw data. * * @param id * @param startTime @@ -37,7 +37,7 @@ public interface DriverInfoSerializer { public AvroDriverInfo toAvro(final String id, final String startTime, final List<AvroReefServiceInfo> services); /** - * Convert AvroDriverInfo object to JSon string + * Convert AvroDriverInfo object to JSon string. * * @param avroDriverInfo * @return http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/EvaluatorInfoSerializer.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/EvaluatorInfoSerializer.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/EvaluatorInfoSerializer.java index be7738b..3282f03 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/EvaluatorInfoSerializer.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/EvaluatorInfoSerializer.java @@ -28,7 +28,7 @@ import java.util.Map; public interface EvaluatorInfoSerializer { /** - * Build AvroEvaluatorsInfo object from raw data + * Build AvroEvaluatorsInfo object from raw data. */ AvroEvaluatorsInfo toAvro( final List<String> ids, final Map<String, EvaluatorDescriptor> evaluators); http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/EvaluatorListSerializer.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/EvaluatorListSerializer.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/EvaluatorListSerializer.java index 4cada51..ea7ab71 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/EvaluatorListSerializer.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/EvaluatorListSerializer.java @@ -24,12 +24,12 @@ import org.apache.reef.tang.annotations.DefaultImplementation; import java.util.Map; /** - * interface for EvaluatorListSerializer + * interface for EvaluatorListSerializer. */ @DefaultImplementation(AvroEvaluatorListSerializer.class) public interface EvaluatorListSerializer { /** - * Build AvroEvaluatorList object + * Build AvroEvaluatorList object. * * @param evaluatorMap * @param totalEvaluators @@ -39,7 +39,7 @@ public interface EvaluatorListSerializer { public AvroEvaluatorList toAvro(final Map<String, EvaluatorDescriptor> evaluatorMap, final int totalEvaluators, final String startTime); /** - * Convert AvroEvaluatorList to JSon string + * Convert AvroEvaluatorList to JSon string. * * @param avroEvaluatorList * @return http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpEventHandlers.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpEventHandlers.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpEventHandlers.java index 76a2010..cc2ffab 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpEventHandlers.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpEventHandlers.java @@ -24,7 +24,7 @@ import org.apache.reef.tang.annotations.NamedParameter; import java.util.Set; /** - * HttpEventHandlers + * HttpEventHandlers. */ @NamedParameter(doc = "Http Event Handlers") public class HttpEventHandlers implements Name<Set<HttpHandler>> { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpHandler.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpHandler.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpHandler.java index 8ff835c..43971f7 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpHandler.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpHandler.java @@ -23,7 +23,7 @@ import javax.servlet.http.HttpServletResponse; import java.io.IOException; /** - * HttpHandler interface + * HttpHandler interface. */ public interface HttpHandler { /** @@ -41,7 +41,7 @@ public interface HttpHandler { public void setUriSpecification(final String s); /** - * Will be called when request comes + * Will be called when request comes. * * @param parsedHttpRequest * @param response http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpHandlerConfiguration.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpHandlerConfiguration.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpHandlerConfiguration.java index bf48d90..98476e8 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpHandlerConfiguration.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpHandlerConfiguration.java @@ -24,17 +24,17 @@ import org.apache.reef.tang.formats.ConfigurationModuleBuilder; import org.apache.reef.tang.formats.OptionalParameter; /** - * Configuration Module Builder for Http Handler + * Configuration Module Builder for Http Handler. */ public final class HttpHandlerConfiguration extends ConfigurationModuleBuilder { /** - * Specify optional parameter for HttpEventHandlers + * Specify optional parameter for HttpEventHandlers. */ public static final OptionalParameter<HttpHandler> HTTP_HANDLERS = new OptionalParameter<>(); /** - * HttpHandlerConfiguration merged with HttpRuntimeConfiguration + * HttpHandlerConfiguration merged with HttpRuntimeConfiguration. */ public static final ConfigurationModule CONF = new HttpHandlerConfiguration().merge(HttpRuntimeConfiguration.CONF) .bindSetEntry(HttpEventHandlers.class, HTTP_HANDLERS) http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeConfiguration.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeConfiguration.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeConfiguration.java index e33e80c..187798c 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeConfiguration.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeConfiguration.java @@ -23,11 +23,11 @@ import org.apache.reef.tang.formats.ConfigurationModuleBuilder; import org.apache.reef.wake.time.Clock; /** - * Configuration Module Builder for HttpRuntime + * Configuration Module Builder for HttpRuntime. */ public final class HttpRuntimeConfiguration extends ConfigurationModuleBuilder { /** - * HttpRuntimeConfiguration + * HttpRuntimeConfiguration. */ public static final ConfigurationModule CONF = new HttpRuntimeConfiguration() .bindSetEntry(Clock.RuntimeStartHandler.class, HttpRuntimeStartHandler.class) http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeStartHandler.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeStartHandler.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeStartHandler.java index c51f068..cff332c 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeStartHandler.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeStartHandler.java @@ -26,7 +26,7 @@ import java.util.logging.Level; import java.util.logging.Logger; /** - * RuntimeStartHandler for Http server + * RuntimeStartHandler for Http server. */ final class HttpRuntimeStartHandler implements EventHandler<RuntimeStart> { /** @@ -35,7 +35,7 @@ final class HttpRuntimeStartHandler implements EventHandler<RuntimeStart> { private static final Logger LOG = Logger.getLogger(HttpRuntimeStartHandler.class.getName()); /** - * HttpServer + * HttpServer. */ private final HttpServer httpServer; @@ -50,7 +50,7 @@ final class HttpRuntimeStartHandler implements EventHandler<RuntimeStart> { } /** - * Override EventHandler<RuntimeStart> + * Override EventHandler<RuntimeStart>. * * @param runtimeStart */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeStopHandler.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeStopHandler.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeStopHandler.java index b974ee4..3493462 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeStopHandler.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpRuntimeStopHandler.java @@ -26,7 +26,7 @@ import java.util.logging.Level; import java.util.logging.Logger; /** - * Http Runtime Stop Handler + * Http Runtime Stop Handler. */ final class HttpRuntimeStopHandler implements EventHandler<RuntimeStop> { /** @@ -35,7 +35,7 @@ final class HttpRuntimeStopHandler implements EventHandler<RuntimeStop> { private static final Logger LOG = Logger.getLogger(HttpRuntimeStopHandler.class.getName()); /** - * HttpServer + * HttpServer. */ private final HttpServer httpServer; @@ -50,7 +50,7 @@ final class HttpRuntimeStopHandler implements EventHandler<RuntimeStop> { } /** - * Override EventHandler<RuntimeStop> + * Override EventHandler<RuntimeStop>. * * @param runtimeStop */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServer.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServer.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServer.java index 37c2d74..0a9cdd7 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServer.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServer.java @@ -21,33 +21,33 @@ package org.apache.reef.webserver; import org.apache.reef.tang.annotations.DefaultImplementation; /** - * HttpServer interface + * HttpServer interface. */ public interface HttpServer { /** - * start the server + * start the server. * * @throws Exception */ public void start() throws Exception; /** - * stop the server + * stop the server. * * @throws Exception */ public void stop() throws Exception; /** - * get port number of the server + * get port number of the server. * * @return */ public int getPort(); /** - * Add a httpHandler to the server + * Add a httpHandler to the server. * * @param httpHandler */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerImpl.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerImpl.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerImpl.java index 94772ca..e8f60ce 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerImpl.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerImpl.java @@ -38,7 +38,7 @@ public final class HttpServerImpl implements HttpServer { private static final Logger LOG = Logger.getLogger(HttpServerImpl.class.getName()); /** - * JettyHandler injected in the constructor + * JettyHandler injected in the constructor. */ private JettyHandler jettyHandler; @@ -48,17 +48,17 @@ public final class HttpServerImpl implements HttpServer { private final Server server; /** - * port number used in Jetty Server + * port number used in Jetty Server. */ private final int port; /** - * Logging scope factory + * Logging scope factory. */ private final LoggingScopeFactory loggingScopeFactory; /** - * Constructor of HttpServer that wraps Jetty Server + * Constructor of HttpServer that wraps Jetty Server. * * @param jettyHandler * @param portNumber @@ -104,7 +104,7 @@ public final class HttpServerImpl implements HttpServer { } /** - * get a random port number in min and max range + * get a random port number in min and max range. * * @return */ @@ -137,7 +137,7 @@ public final class HttpServerImpl implements HttpServer { } /** - * Add a HttpHandler to Jetty Handler + * Add a HttpHandler to Jetty Handler. * * @param httpHandler */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerReefEventHandler.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerReefEventHandler.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerReefEventHandler.java index 49f7d0b..3e4445b 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerReefEventHandler.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpServerReefEventHandler.java @@ -58,7 +58,7 @@ public final class HttpServerReefEventHandler implements HttpHandler { private final LoggingScopeFactory loggingScopeFactory; /** - * Log level string prefix in the log lines + * Log level string prefix in the log lines. */ private final String logLevelPrefix; @@ -184,7 +184,7 @@ public final class HttpServerReefEventHandler implements HttpHandler { } /** - * handle HTTP queries + * handle HTTP queries. * Example of a query: http://localhost:8080/reef/Evaluators/?id=Node-2-1403225213803&id=Node-1-1403225213712 */ private void handleQueries( @@ -286,7 +286,7 @@ public final class HttpServerReefEventHandler implements HttpHandler { } /** - * Get all evaluator ids and send it back to response so that can be displayed on web + * Get all evaluator ids and send it back to response so that can be displayed on web. * * @param response * @throws IOException @@ -366,7 +366,7 @@ public final class HttpServerReefEventHandler implements HttpHandler { } /** - * Write lines in ArrayList to the response writer + * Write lines in ArrayList to the response writer. * @param response * @param lines * @param header http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpTrackingURLProvider.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpTrackingURLProvider.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpTrackingURLProvider.java index 02003e9..4d3cae4 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpTrackingURLProvider.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/HttpTrackingURLProvider.java @@ -27,7 +27,7 @@ import java.util.logging.Level; import java.util.logging.Logger; /** - * Http TrackingURLProvider + * Http TrackingURLProvider. */ public final class HttpTrackingURLProvider implements TrackingURLProvider { /** @@ -36,12 +36,12 @@ public final class HttpTrackingURLProvider implements TrackingURLProvider { private static final Logger LOG = Logger.getLogger(HttpTrackingURLProvider.class.getName()); /** - * HttpServer + * HttpServer. */ private final HttpServer httpServer; /** - * Constructor of HttpTrackingURLProvider + * Constructor of HttpTrackingURLProvider. * * @param httpServer */ @@ -51,7 +51,7 @@ public final class HttpTrackingURLProvider implements TrackingURLProvider { } /** - * get tracking URI + * get tracking URI. * * @return */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/JettyHandler.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/JettyHandler.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/JettyHandler.java index 03ff055..5907e30 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/JettyHandler.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/JettyHandler.java @@ -35,12 +35,12 @@ import java.util.logging.Level; import java.util.logging.Logger; /** - * Jetty Event Handler + * Jetty Event Handler. */ class JettyHandler extends AbstractHandler { private static final Logger LOG = Logger.getLogger(JettyHandler.class.getName()); /** - * a map that contains eventHandler's specification and the reference + * a map that contains eventHandler's specification and the reference. */ private final Map<String, HttpHandler> eventHandlers = new HashMap<>(); @@ -61,7 +61,7 @@ class JettyHandler extends AbstractHandler { } /** - * handle http request + * handle http request. * * @param target * @param request @@ -97,7 +97,7 @@ class JettyHandler extends AbstractHandler { } /** - * Validate request and get http handler for the request + * Validate request and get http handler for the request. * * @param request * @param response @@ -130,7 +130,7 @@ class JettyHandler extends AbstractHandler { } /** - * process write message and status on the response + * process write message and status on the response. * * @param response * @param message http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MaxPortNumber.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MaxPortNumber.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MaxPortNumber.java index b55adb5..e9458fa 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MaxPortNumber.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MaxPortNumber.java @@ -22,8 +22,8 @@ import org.apache.reef.tang.annotations.Name; import org.apache.reef.tang.annotations.NamedParameter; /** - * max port number range when generating a port number for the Http Server + * max port number range when generating a port number for the Http Server. */ @NamedParameter(doc = "Max port number for Jetty Server", default_value = "49151") public class MaxPortNumber implements Name<Integer> { -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MaxRetryAttempts.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MaxRetryAttempts.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MaxRetryAttempts.java index c953b44..3f8a810 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MaxRetryAttempts.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MaxRetryAttempts.java @@ -22,7 +22,7 @@ import org.apache.reef.tang.annotations.Name; import org.apache.reef.tang.annotations.NamedParameter; /** - * Max retry times when generating a port number for the Http Server + * Max retry times when generating a port number for the Http Server. */ @NamedParameter(doc = "Maximum retry attempts for port number of Jetty Server", default_value = "100") public class MaxRetryAttempts implements Name<Integer> { http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MinPortNumber.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MinPortNumber.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MinPortNumber.java index c0a88c2..2fa3ff6 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MinPortNumber.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/MinPortNumber.java @@ -22,8 +22,8 @@ import org.apache.reef.tang.annotations.Name; import org.apache.reef.tang.annotations.NamedParameter; /** - * minimum port number range when generating a port number for the Http Server + * minimum port number range when generating a port number for the Http Server. */ @NamedParameter(doc = "Minimum port number for Jetty Server", default_value = "1024") public class MinPortNumber implements Name<Integer> { -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/ParsedHttpRequest.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/ParsedHttpRequest.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/ParsedHttpRequest.java index 55138bf..745973b 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/ParsedHttpRequest.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/ParsedHttpRequest.java @@ -25,7 +25,7 @@ import java.net.URLDecoder; import java.util.*; /** - * Parsed HttpServletRequest + * Parsed HttpServletRequest. */ public final class ParsedHttpRequest { private final String pathInfo; @@ -42,7 +42,7 @@ public final class ParsedHttpRequest { private final Map<String, List<String>> queryPairs = new LinkedHashMap<>(); /** - * parse HttpServletRequest + * parse HttpServletRequest. * * @param request * @throws IOException @@ -94,7 +94,7 @@ public final class ParsedHttpRequest { } /** - * get http header as a list of HeaderEntry + * get http header as a list of HeaderEntry. * @return */ public List<HeaderEntry> getHeaderEntryList() { @@ -114,7 +114,7 @@ public final class ParsedHttpRequest { } /** - * get target to match specification like "Reef" + * get target to match specification like "Reef". * * @return specification */ @@ -132,7 +132,7 @@ public final class ParsedHttpRequest { } /** - * get target target entity like "Evaluators" + * get target target entity like "Evaluators". * * @return */ @@ -141,7 +141,7 @@ public final class ParsedHttpRequest { } /** - * get http request method like "Get" + * get http request method like "Get". * * @return */ @@ -150,7 +150,7 @@ public final class ParsedHttpRequest { } /** - * get input Stream + * get input Stream. * * @return */ @@ -159,7 +159,7 @@ public final class ParsedHttpRequest { } /** - * get request headers + * get request headers. * * @return */ @@ -168,7 +168,7 @@ public final class ParsedHttpRequest { } /** - * get parsed queries + * get parsed queries. * * @return */ @@ -177,7 +177,7 @@ public final class ParsedHttpRequest { } /** - * get URL like //http://localhost:8080/Reef/Evaluators/ + * get URL like //http://localhost:8080/Reef/Evaluators/. * * @return */ @@ -186,7 +186,7 @@ public final class ParsedHttpRequest { } /** - * get path infor, like /Reef/Evaluators/ + * get path infor, like /Reef/Evaluators/. * * @return */ @@ -195,7 +195,7 @@ public final class ParsedHttpRequest { } /** - * get URI, like /Reef/Evaluators/ + * get URI, like /Reef/Evaluators/. * * @return */ @@ -204,7 +204,7 @@ public final class ParsedHttpRequest { } /** - * get version of the request for Rest API + * get version of the request for Rest API. * * @return */ http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/ReefEventStateManager.java ---------------------------------------------------------------------- diff --git a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/ReefEventStateManager.java b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/ReefEventStateManager.java index 1f75110..acfaddf 100644 --- a/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/ReefEventStateManager.java +++ b/lang/java/reef-webserver/src/main/java/org/apache/reef/webserver/ReefEventStateManager.java @@ -38,7 +38,7 @@ import java.util.logging.Level; import java.util.logging.Logger; /** - * Reef Event Manager that manages Reef states + * Reef Event Manager that manages Reef states. */ @Unit public final class ReefEventStateManager { @@ -48,12 +48,12 @@ public final class ReefEventStateManager { private static final Logger LOG = Logger.getLogger(ReefEventStateManager.class.getName()); /** - * date format + * date format. */ private static final Format format = new SimpleDateFormat("yyyy MM dd HH:mm:ss"); /** - * Map of evaluators + * Map of evaluators. */ private final Map<String, EvaluatorDescriptor> evaluators = new HashMap<>(); @@ -65,27 +65,27 @@ public final class ReefEventStateManager { private final List<AvroReefServiceInfo> serviceInfoList = new ArrayList<AvroReefServiceInfo>(); /** - * Remote manager in driver the carries information such as driver endpoint identifier + * Remote manager in driver the carries information such as driver endpoint identifier. */ private final RemoteManager remoteManager; /** - * Driver Status Manager that controls the driver status + * Driver Status Manager that controls the driver status. */ private final DriverStatusManager driverStatusManager; /** - * Evaluator start time + * Evaluator start time. */ private StartTime startTime; /** - * Evaluator stop time + * Evaluator stop time. */ private StopTime stopTime; /** - * ReefEventStateManager that keeps the states of Reef components + * ReefEventStateManager that keeps the states of Reef components. */ @Inject public ReefEventStateManager(final RemoteManager remoteManager, final DriverStatusManager driverStatusManager) { @@ -94,7 +94,7 @@ public final class ReefEventStateManager { } /** - * get start time + * get start time. * * @return */ @@ -106,7 +106,7 @@ public final class ReefEventStateManager { } /** - * get stop time + * get stop time. * * @return */ @@ -118,7 +118,7 @@ public final class ReefEventStateManager { } /** - * convert time from long to formatted string + * convert time from long to formatted string. * * @param time * @return @@ -129,7 +129,7 @@ public final class ReefEventStateManager { } /** - * get evaluator map + * get evaluator map. * * @return */ @@ -138,7 +138,7 @@ public final class ReefEventStateManager { } /** - * get driver endpoint identifier + * get driver endpoint identifier. */ public String getDriverEndpointIdentifier() { return remoteManager.getMyIdentifier(); @@ -156,7 +156,7 @@ public final class ReefEventStateManager { } /** - * get a map of contexts + * get a map of contexts. * * @return */ @@ -165,7 +165,7 @@ public final class ReefEventStateManager { } /** - * pus a entry to evaluators + * pus a entry to evaluators. * * @param key * @param value @@ -175,7 +175,7 @@ public final class ReefEventStateManager { } /** - * get a value from evaluators by key + * get a value from evaluators by key. * * @param key * @return @@ -185,7 +185,7 @@ public final class ReefEventStateManager { } /** - * getEvaluatorDescriptor + * getEvaluatorDescriptor. * * @param evaluatorId * @return @@ -195,7 +195,7 @@ public final class ReefEventStateManager { } /** - * get Evaluator NodeDescriptor + * get Evaluator NodeDescriptor. * * @param evaluatorId * @return @@ -212,7 +212,7 @@ public final class ReefEventStateManager { } /** - * Job Driver is ready and the clock is set up + * Job Driver is ready and the clock is set up. */ public final class StartStateHandler implements EventHandler<StartTime> { @Override @@ -236,7 +236,7 @@ public final class ReefEventStateManager { } /** - * Receive notification that an Evaluator had been allocated + * Receive notification that an Evaluator had been allocated. */ public final class AllocatedEvaluatorStateHandler implements EventHandler<AllocatedEvaluator> { @Override @@ -248,7 +248,7 @@ public final class ReefEventStateManager { } /** - * Receive event when task is running + * Receive event when task is running. */ public final class TaskRunningStateHandler implements EventHandler<RunningTask> { @Override @@ -258,7 +258,7 @@ public final class ReefEventStateManager { } /** - * Receive event during driver restart that a task is running in previous evaluator + * Receive event during driver restart that a task is running in previous evaluator. */ public final class DriverRestartTaskRunningStateHandler implements EventHandler<RunningTask> { @Override @@ -305,4 +305,4 @@ public final class ReefEventStateManager { } } } -} \ No newline at end of file +}
