You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by we...@apache.org on 2015/06/04 09:38:58 UTC
[6/6] incubator-reef git commit: [REEF-333] Fix 'First sentence ...'
JavaDoc error
[REEF-333] Fix 'First sentence ...' JavaDoc error
This change adds adds periods to the lines reported by the
'First sentence should end with a period.'
checkstyle check.
JIRA:
[REEF-333](https://issues.apache.org/jira/browse/REEF-333)
Pull Request:
This closes #202
Project: http://git-wip-us.apache.org/repos/asf/incubator-reef/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-reef/commit/eeafba31
Tree: http://git-wip-us.apache.org/repos/asf/incubator-reef/tree/eeafba31
Diff: http://git-wip-us.apache.org/repos/asf/incubator-reef/diff/eeafba31
Branch: refs/heads/master
Commit: eeafba31ca296208ae3b01a3b6796f17d8caab15
Parents: cf158e0
Author: Mariia Mykhailova <mi...@gmail.com>
Authored: Wed Jun 3 16:46:39 2015 -0700
Committer: Markus Weimer <we...@apache.org>
Committed: Thu Jun 4 17:34:29 2015 +1000
----------------------------------------------------------------------
.../reef/annotations/audience/package-info.java | 4 +-
.../bridge/client/YarnJobSubmissionClient.java | 2 +-
.../org/apache/reef/javabridge/LibLoader.java | 8 +--
.../reef/javabridge/generic/JobClient.java | 6 +--
.../reef/javabridge/generic/JobDriver.java | 20 ++++----
.../apache/reef/javabridge/generic/Launch.java | 14 ++---
.../reef/javabridge/generic/LaunchHeadless.java | 4 +-
.../reef/javabridge/generic/package-info.java | 4 +-
.../apache/reef/util/logging/package-info.java | 2 +-
.../io/checkpoint/CheckpointNamingService.java | 2 +-
.../client/parameters/JobCompletedHandler.java | 2 +-
.../reef/driver/catalog/ResourceCatalog.java | 2 +-
.../driver/context/ContextConfiguration.java | 2 +-
.../reef/driver/evaluator/CLRProcess.java | 4 +-
.../driver/evaluator/CLRProcessFactory.java | 2 +-
.../reef/driver/evaluator/EvaluatorProcess.java | 8 +--
.../evaluator/EvaluatorProcessFactory.java | 2 +-
.../reef/driver/evaluator/EvaluatorRequest.java | 2 +-
.../reef/driver/evaluator/EvaluatorType.java | 4 +-
.../reef/driver/evaluator/JVMProcess.java | 4 +-
.../driver/evaluator/JVMProcessFactory.java | 2 +-
.../ClientCloseWithMessageHandlers.java | 2 +-
.../parameters/ContextActiveHandlers.java | 2 +-
.../parameters/ContextFailedHandlers.java | 2 +-
.../driver/parameters/DriverIdentifier.java | 2 +-
.../DriverJobSubmissionDirectory.java | 2 +-
.../reef/driver/parameters/DriverMemory.java | 2 +-
.../DriverRestartCompletedHandlers.java | 2 +-
.../DriverRestartContextActiveHandlers.java | 2 +-
.../ServiceContextActiveHandlers.java | 2 +-
.../ServiceContextFailedHandlers.java | 2 +-
.../ServiceDriverRestartCompletedHandlers.java | 2 +-
...rviceDriverRestartContextActiveHandlers.java | 2 +-
.../reef/driver/parameters/package-info.java | 4 +-
.../apache/reef/driver/task/RunningTask.java | 2 +-
.../evaluator/context/parameters/Services.java | 2 +-
...aluatorKilledByResourceManagerException.java | 2 +-
.../exception/evaluator/NetworkException.java | 2 +-
.../java/org/apache/reef/io/ExternalMap.java | 4 +-
.../main/java/org/apache/reef/io/Message.java | 4 +-
.../reef/io/TcpPortConfigurationProvider.java | 4 +-
.../org/apache/reef/io/naming/Identifiable.java | 2 +-
.../apache/reef/io/naming/NameAssignment.java | 6 +--
.../apache/reef/io/naming/NamingRegistry.java | 4 +-
.../java/org/apache/reef/io/package-info.java | 4 +-
.../org/apache/reef/io/serialization/Codec.java | 4 +-
.../runtime/common/client/CompletedJobImpl.java | 2 +-
.../common/client/JobStatusMessageHandler.java | 2 +-
.../common/client/JobSubmissionHelper.java | 4 +-
.../reef/runtime/common/client/RunningJobs.java | 2 +-
.../runtime/common/client/RunningJobsImpl.java | 2 +-
.../common/client/api/JobSubmissionEvent.java | 2 +-
.../client/api/JobSubmissionEventImpl.java | 4 +-
.../runtime/common/client/api/package-info.java | 4 +-
.../DriverRuntimeConfigurationOptions.java | 2 +-
.../common/driver/api/ResourceLaunchEvent.java | 2 +-
.../driver/api/ResourceLaunchEventImpl.java | 6 +--
.../common/driver/api/ResourceReleaseEvent.java | 2 +-
.../common/driver/api/ResourceRequestEvent.java | 2 +-
.../driver/api/ResourceRequestEventImpl.java | 6 +--
.../driver/context/ContextRepresenters.java | 2 +-
.../common/driver/context/package-info.java | 4 +-
.../evaluator/AllocatedEvaluatorImpl.java | 4 +-
.../evaluator/EvaluatorDescriptorImpl.java | 2 +-
.../driver/evaluator/EvaluatorManager.java | 8 +--
.../evaluator/EvaluatorManagerFactory.java | 2 +-
.../common/driver/idle/package-info.java | 4 +-
.../resourcemanager/NodeDescriptorEvent.java | 2 +-
.../resourcemanager/ResourceStatusEvent.java | 2 +-
.../resourcemanager/ResourceStatusHandler.java | 2 +-
.../resourcemanager/RuntimeStatusEvent.java | 2 +-
.../resourcemanager/RuntimeStatusEventImpl.java | 2 +-
.../common/evaluator/DriverConnection.java | 2 +-
.../evaluator/context/ContextLifeCycle.java | 2 +-
.../evaluator/context/ContextManager.java | 4 +-
.../defaults/DefaultContextStartHandler.java | 2 +-
.../defaults/DefaultContextStopHandler.java | 2 +-
.../parameters/RootServiceConfiguration.java | 2 +-
.../common/evaluator/task/TaskRuntime.java | 2 +-
.../common/evaluator/task/TaskStartImpl.java | 2 +-
.../common/evaluator/task/TaskStopImpl.java | 2 +-
.../task/defaults/DefaultCloseHandler.java | 2 +-
.../defaults/DefaultDriverMessageHandler.java | 2 +-
.../task/defaults/DefaultSuspendHandler.java | 2 +-
.../task/exceptions/TaskCallFailure.java | 2 +-
.../exceptions/TaskCloseHandlerFailure.java | 2 +-
.../exceptions/TaskMessageHandlerFailure.java | 2 +-
.../exceptions/TaskStartHandlerFailure.java | 2 +-
.../task/exceptions/TaskStopHandlerFailure.java | 2 +-
.../exceptions/TaskSuspendHandlerFailure.java | 2 +-
.../reef/runtime/common/files/FileResource.java | 2 +-
.../reef/runtime/common/files/FileType.java | 2 +-
.../runtime/common/files/REEFFileNames.java | 6 +--
.../common/files/UnixJVMPathProvider.java | 2 +-
.../reef/runtime/common/launch/ProcessType.java | 2 +-
.../parameters/ClockConfigurationPath.java | 2 +-
.../java/org/apache/reef/util/BuilderUtils.java | 4 +-
.../java/org/apache/reef/util/CommandUtils.java | 2 +-
.../java/org/apache/reef/util/DeadlockInfo.java | 4 +-
.../java/org/apache/reef/util/Exceptions.java | 2 +-
.../main/java/org/apache/reef/util/OSUtils.java | 2 +-
.../java/org/apache/reef/util/REEFVersion.java | 2 +-
.../java/org/apache/reef/util/ThreadLogger.java | 8 +--
.../apache/reef/util/logging/LogLevelName.java | 2 +-
.../org/apache/reef/util/logging/LogParser.java | 10 ++--
.../apache/reef/util/logging/LoggingScope.java | 4 +-
.../reef/util/logging/LoggingScopeFactory.java | 54 ++++++++++----------
.../reef/util/logging/LoggingScopeImpl.java | 6 +--
.../apache/reef/util/logging/LoggingSetup.java | 2 +-
.../reef/examples/helloCLR/HelloDriver.java | 4 +-
.../reef/examples/hello/HelloHDInsight.java | 2 +-
.../examples/data/loading/DataLoadingREEF.java | 4 +-
.../reef/examples/group/bgd/BGDClient.java | 2 +-
.../group/bgd/data/parser/SVMLightParser.java | 2 +-
.../examples/group/bgd/parameters/Lambda.java | 2 +-
.../group/broadcast/BroadcastDriver.java | 2 +-
.../examples/group/broadcast/BroadcastREEF.java | 2 +-
.../utils/math/AbstractImmutableVector.java | 2 +-
.../examples/group/utils/math/DenseVector.java | 8 +--
.../group/utils/math/ImmutableVector.java | 6 +--
.../reef/examples/group/utils/math/Vector.java | 4 +-
.../examples/group/utils/math/VectorCodec.java | 4 +-
.../apache/reef/examples/hello/HelloDriver.java | 4 +-
.../apache/reef/examples/hello/HelloREEF.java | 2 +-
.../reef/examples/hellohttp/HelloREEFHttp.java | 6 +--
.../examples/hellohttp/HelloREEFHttpYarn.java | 2 +-
.../hellohttp/HttpServerShellCmdtHandler.java | 18 +++----
.../examples/hellohttp/HttpShellJobDriver.java | 8 +--
.../apache/reef/examples/library/ShellTask.java | 2 +-
.../org/apache/reef/examples/pool/Launch.java | 4 +-
.../reef/examples/scheduler/Scheduler.java | 2 +-
.../scheduler/SchedulerHttpHandler.java | 2 +-
.../reef/examples/scheduler/SchedulerREEF.java | 6 +--
.../examples/scheduler/SchedulerREEFYarn.java | 2 +-
.../examples/scheduler/SchedulerResponse.java | 8 +--
.../reef/examples/scheduler/package-info.java | 4 +-
.../apache/reef/examples/suspend/Launch.java | 4 +-
.../examples/suspend/ObjectWritableCodec.java | 2 +-
.../reef/examples/suspend/SuspendDriver.java | 2 +-
.../impl/EvaluatorRequestSerializer.java | 2 +-
.../impl/EvaluatorToPartitionMapper.java | 4 +-
.../impl/InputFormatExternalConstructor.java | 2 +-
.../impl/InputSplitExternalConstructor.java | 2 +-
.../io/data/loading/impl/NumberedSplit.java | 4 +-
.../reef/io/network/ConnectionFactory.java | 4 +-
.../org/apache/reef/io/network/Message.java | 8 +--
.../exception/NetworkRuntimeException.java | 10 ++--
.../network/exception/ParentDeadException.java | 2 +-
.../reef/io/network/group/api/GroupChanges.java | 2 +-
.../api/driver/CommunicationGroupDriver.java | 6 +--
.../group/api/driver/GroupCommDriver.java | 6 +--
.../api/driver/GroupCommServiceDriver.java | 6 +--
.../io/network/group/api/driver/TaskNode.java | 8 +--
.../group/api/driver/TaskNodeStatus.java | 8 +--
.../io/network/group/api/driver/Topology.java | 20 ++++----
.../network/group/api/operators/Broadcast.java | 2 +-
.../io/network/group/api/operators/Gather.java | 4 +-
.../io/network/group/api/operators/Reduce.java | 8 +--
.../group/api/operators/ReduceScatter.java | 2 +-
.../group/api/task/CommGroupNetworkHandler.java | 2 +-
.../api/task/CommunicationGroupClient.java | 10 ++--
.../task/CommunicationGroupServiceClient.java | 2 +-
.../network/group/api/task/GroupCommClient.java | 2 +-
.../group/api/task/GroupCommNetworkHandler.java | 2 +-
.../impl/GroupCommunicationMessageCodec.java | 2 +-
.../impl/config/BroadcastOperatorSpec.java | 4 +-
.../group/impl/config/ReduceOperatorSpec.java | 6 +--
.../group/impl/driver/CtrlMsgSender.java | 2 +-
.../network/group/impl/driver/FlatTopology.java | 2 +-
.../group/impl/driver/GroupCommDriverImpl.java | 2 +-
.../impl/driver/GroupCommMessageHandler.java | 2 +-
.../group/impl/driver/GroupCommService.java | 2 +-
.../network/group/impl/driver/IndexedMsg.java | 2 +-
.../io/network/group/impl/driver/MsgKey.java | 2 +-
.../network/group/impl/driver/TaskNodeImpl.java | 6 +--
.../group/impl/driver/TaskNodeStatusImpl.java | 2 +-
.../network/group/impl/driver/TreeTopology.java | 2 +-
.../group/impl/task/OperatorTopologyImpl.java | 4 +-
.../group/impl/utils/ConcurrentCountingMap.java | 2 +-
.../network/group/impl/utils/CountingMap.java | 2 +-
.../io/network/group/impl/utils/SetMap.java | 2 +-
.../reef/io/network/impl/NSConnection.java | 10 ++--
.../apache/reef/io/network/impl/NSMessage.java | 12 ++---
.../reef/io/network/impl/NSMessageCodec.java | 8 +--
.../reef/io/network/impl/NetworkService.java | 2 +-
.../reef/io/network/impl/StreamingCodec.java | 2 +-
.../io/network/naming/NameAssignmentTuple.java | 8 +--
.../reef/io/network/naming/NameCache.java | 8 +--
.../reef/io/network/naming/NameClient.java | 22 ++++----
.../io/network/naming/NameLookupClient.java | 20 ++++----
.../io/network/naming/NameRegistryClient.java | 16 +++---
.../reef/io/network/naming/NameServer.java | 14 ++---
.../network/naming/NameServerConfiguration.java | 8 +--
.../reef/io/network/naming/NameServerImpl.java | 28 +++++-----
.../io/network/naming/NamingCodecFactory.java | 8 +--
.../naming/exception/NamingException.java | 8 +--
.../exception/NamingRuntimeException.java | 8 +--
.../network/naming/serialization/AvroUtils.java | 2 +-
.../serialization/NamingLookupRequest.java | 6 +--
.../serialization/NamingLookupRequestCodec.java | 8 +--
.../serialization/NamingLookupResponse.java | 6 +--
.../NamingLookupResponseCodec.java | 8 +--
.../naming/serialization/NamingMessage.java | 6 +--
.../serialization/NamingRegisterRequest.java | 6 +--
.../NamingRegisterRequestCodec.java | 10 ++--
.../serialization/NamingRegisterResponse.java | 6 +--
.../NamingRegisterResponseCodec.java | 8 +--
.../serialization/NamingUnregisterRequest.java | 6 +--
.../NamingUnregisterRequestCodec.java | 8 +--
.../naming/serialization/package-info.java | 4 +-
.../reef/io/network/util/StringIdentifier.java | 10 ++--
.../network/util/StringIdentifierFactory.java | 4 +-
.../io/storage/local/LocalScratchSpace.java | 2 +-
.../hdinsight/HDInsightJVMPathProvider.java | 2 +-
.../reef/runtime/hdinsight/cli/HDICLI.java | 2 +-
.../runtime/hdinsight/cli/LogFileEntry.java | 2 +-
.../reef/runtime/hdinsight/cli/TFileParser.java | 4 +-
.../runtime/hdinsight/cli/package-info.java | 4 +-
.../client/HDInsightRuntimeConfiguration.java | 2 +-
...safeHDInsightRuntimeConfigurationStatic.java | 2 +-
.../client/DriverConfigurationProvider.java | 2 +-
.../client/PreparedDriverFolderLauncher.java | 2 +-
.../reef/runtime/local/client/package-info.java | 2 +-
.../parameters/MaxNumberOfEvaluators.java | 2 +-
.../runtime/local/driver/ContainerManager.java | 4 +-
.../local/driver/LocalDriverConfiguration.java | 2 +-
.../driver/LocalResourceRequestHandler.java | 2 +-
.../runtime/local/driver/ProcessContainer.java | 2 +-
.../reef/runtime/local/driver/package-info.java | 2 +-
.../process/LoggingRunnableProcessObserver.java | 2 +-
.../process/ReefRunnableProcessObserver.java | 4 +-
.../runtime/local/process/RunnableProcess.java | 2 +-
.../mesos/client/MesosClientConfiguration.java | 6 +--
.../mesos/driver/MesosDriverConfiguration.java | 8 +--
.../runtime/mesos/driver/REEFScheduler.java | 4 +-
.../evaluator/EvaluatorControlHandler.java | 4 +-
.../reef/runtime/yarn/ClassPathBuilder.java | 4 +-
.../runtime/yarn/YarnClasspathProvider.java | 2 +-
.../runtime/yarn/client/uploader/JobFolder.java | 4 +-
.../reef/runtime/yarn/driver/Containers.java | 2 +-
.../yarn/driver/UploaderToJobfolder.java | 2 +-
.../yarn/driver/YarnContainerManager.java | 2 +-
.../reef/runtime/yarn/util/YarnTypes.java | 2 +-
.../org/apache/reef/tang/Configurations.java | 2 +-
.../apache/reef/tang/JavaClassHierarchy.java | 2 +-
.../reef/tang/JavaConfigurationBuilder.java | 4 +-
.../formats/AvroConfigurationSerializer.java | 4 +-
.../tang/formats/ConfigurationSerializer.java | 6 +--
.../protobuf/ProtocolBufferClassHierarchy.java | 2 +-
.../walk/graphviz/GraphvizConfigVisitor.java | 2 +-
.../graphviz/GraphvizInjectionPlanVisitor.java | 2 +-
.../apache/reef/tests/library/package-info.java | 4 +-
.../reef/tests/yarn/failure/FailureREEF.java | 2 +-
.../java/org/apache/reef/util/cache/Cache.java | 4 +-
.../org/apache/reef/util/cache/CacheImpl.java | 2 +-
.../org/apache/reef/util/cache/CurrentTime.java | 2 +-
.../org/apache/reef/util/cache/SystemTime.java | 2 +-
.../apache/reef/util/cache/WrappedValue.java | 2 +-
.../org/apache/reef/wake/AbstractEStage.java | 10 ++--
.../main/java/org/apache/reef/wake/EStage.java | 2 +-
.../java/org/apache/reef/wake/EventHandler.java | 4 +-
.../java/org/apache/reef/wake/Identifiable.java | 2 +-
.../java/org/apache/reef/wake/Identifier.java | 4 +-
.../org/apache/reef/wake/IdentifierFactory.java | 2 +-
.../main/java/org/apache/reef/wake/Stage.java | 2 +-
.../apache/reef/wake/StageConfiguration.java | 2 +-
.../org/apache/reef/wake/WakeConfiguration.java | 2 +-
.../wake/exception/WakeRuntimeException.java | 8 +--
.../wake/impl/DefaultIdentifierFactory.java | 6 +--
.../reef/wake/impl/DefaultThreadFactory.java | 10 ++--
.../reef/wake/impl/LoggingEventHandler.java | 4 +-
.../org/apache/reef/wake/impl/LoggingUtils.java | 4 +-
.../reef/wake/impl/LoggingVoidEventHandler.java | 4 +-
.../reef/wake/impl/MultiEventHandler.java | 6 +--
.../apache/reef/wake/impl/PeriodicEvent.java | 2 +-
.../reef/wake/impl/PubSubEventHandler.java | 10 ++--
.../reef/wake/impl/SingleThreadStage.java | 12 ++---
.../org/apache/reef/wake/impl/StageManager.java | 2 +-
.../org/apache/reef/wake/impl/SyncStage.java | 12 ++---
.../apache/reef/wake/impl/ThreadPoolStage.java | 22 ++++----
.../org/apache/reef/wake/impl/TimerStage.java | 12 ++---
.../wake/impl/WakeUncaughtExceptionHandler.java | 2 +-
.../java/org/apache/reef/wake/metrics/EWMA.java | 10 ++--
.../reef/wake/metrics/EWMAParameters.java | 2 +-
.../org/apache/reef/wake/metrics/Histogram.java | 10 ++--
.../org/apache/reef/wake/metrics/Meter.java | 18 +++----
.../reef/wake/metrics/UniformHistogram.java | 12 ++---
.../org/apache/reef/wake/remote/Decoder.java | 2 +-
.../reef/wake/remote/DefaultErrorHandler.java | 2 +-
.../org/apache/reef/wake/remote/Encoder.java | 2 +-
.../reef/wake/remote/RemoteIdentifier.java | 2 +-
.../wake/remote/RemoteIdentifierFactory.java | 2 +-
.../apache/reef/wake/remote/RemoteMessage.java | 6 +--
.../HostnameBasedLocalAddressProvider.java | 2 +-
.../address/LegacyLocalAddressProvider.java | 2 +-
.../exception/RemoteRuntimeException.java | 8 +--
.../apache/reef/wake/remote/impl/ByteCodec.java | 6 +--
.../DefaultRemoteManagerImplementation.java | 14 ++---
.../wake/remote/impl/DefaultRemoteMessage.java | 8 +--
.../reef/wake/remote/impl/HandlerContainer.java | 6 +--
.../reef/wake/remote/impl/MultiCodec.java | 8 +--
.../reef/wake/remote/impl/MultiDecoder.java | 6 +--
.../reef/wake/remote/impl/MultiEncoder.java | 6 +--
.../remote/impl/ObjectSerializableCodec.java | 6 +--
.../remote/impl/OrderedRemoteReceiverStage.java | 4 +-
.../wake/remote/impl/ProxyEventHandler.java | 8 +--
.../reef/wake/remote/impl/RemoteEvent.java | 26 +++++-----
.../reef/wake/remote/impl/RemoteEventCodec.java | 8 +--
.../wake/remote/impl/RemoteEventComparator.java | 2 +-
.../wake/remote/impl/RemoteEventDecoder.java | 6 +--
.../wake/remote/impl/RemoteEventEncoder.java | 6 +--
.../remote/impl/RemoteReceiverEventHandler.java | 6 +--
.../wake/remote/impl/RemoteReceiverStage.java | 8 +--
.../remote/impl/RemoteSenderEventHandler.java | 6 +--
.../wake/remote/impl/RemoteSenderStage.java | 6 +--
.../wake/remote/impl/RemoteSeqNumGenerator.java | 2 +-
.../remote/impl/SocketRemoteIdentifier.java | 14 ++---
.../reef/wake/remote/impl/StringCodec.java | 6 +--
.../reef/wake/remote/impl/Subscription.java | 8 +--
.../reef/wake/remote/impl/TransportEvent.java | 14 ++---
.../apache/reef/wake/remote/impl/Tuple2.java | 4 +-
.../wake/remote/ports/RandomRangeIterator.java | 4 +-
.../wake/remote/ports/RangeTcpPortProvider.java | 4 +-
.../reef/wake/remote/ports/TcpPortProvider.java | 2 +-
.../ports/parameters/TcpPortRangeBegin.java | 2 +-
.../ports/parameters/TcpPortRangeCount.java | 2 +-
.../ports/parameters/TcpPortRangeTryCount.java | 2 +-
.../wake/remote/transport/LinkListener.java | 4 +-
.../reef/wake/remote/transport/Transport.java | 12 ++---
.../wake/remote/transport/TransportFactory.java | 8 +--
.../exception/TransportRuntimeException.java | 10 ++--
.../remote/transport/netty/ByteEncoder.java | 2 +-
.../netty/ChunkedReadWriteHandler.java | 6 +--
.../transport/netty/LoggingLinkListener.java | 4 +-
.../netty/MessagingTransportFactory.java | 4 +-
.../transport/netty/NettyChannelHandler.java | 8 +--
.../netty/NettyChannelHandlerFactory.java | 4 +-
.../netty/NettyChannelInitializer.java | 2 +-
.../NettyDefaultChannelHandlerFactory.java | 4 +-
.../transport/netty/NettyEventListener.java | 10 ++--
.../wake/remote/transport/netty/NettyLink.java | 12 ++---
.../netty/NettyMessagingTransport.java | 20 ++++----
.../apache/reef/wake/rx/AbstractRxStage.java | 8 +--
.../apache/reef/wake/rx/DynamicObservable.java | 2 +-
.../org/apache/reef/wake/rx/Observable.java | 2 +-
.../java/org/apache/reef/wake/rx/RxStage.java | 2 +-
.../apache/reef/wake/rx/impl/RxSyncStage.java | 10 ++--
.../reef/wake/rx/impl/RxThreadPoolStage.java | 10 ++--
.../apache/reef/wake/rx/impl/SimpleSubject.java | 6 +--
.../java/org/apache/reef/wake/time/Clock.java | 12 ++---
.../java/org/apache/reef/wake/time/Time.java | 4 +-
.../webserver/AvroEvaluatorInfoSerializer.java | 2 +-
.../reef/webserver/AvroHttpSerializer.java | 4 +-
.../reef/webserver/DriverInfoSerializer.java | 6 +--
.../reef/webserver/EvaluatorInfoSerializer.java | 2 +-
.../reef/webserver/EvaluatorListSerializer.java | 6 +--
.../reef/webserver/HttpEventHandlers.java | 2 +-
.../org/apache/reef/webserver/HttpHandler.java | 4 +-
.../webserver/HttpHandlerConfiguration.java | 6 +--
.../webserver/HttpRuntimeConfiguration.java | 4 +-
.../reef/webserver/HttpRuntimeStartHandler.java | 6 +--
.../reef/webserver/HttpRuntimeStopHandler.java | 6 +--
.../org/apache/reef/webserver/HttpServer.java | 10 ++--
.../apache/reef/webserver/HttpServerImpl.java | 12 ++---
.../webserver/HttpServerReefEventHandler.java | 8 +--
.../reef/webserver/HttpTrackingURLProvider.java | 8 +--
.../org/apache/reef/webserver/JettyHandler.java | 10 ++--
.../apache/reef/webserver/MaxPortNumber.java | 4 +-
.../apache/reef/webserver/MaxRetryAttempts.java | 2 +-
.../apache/reef/webserver/MinPortNumber.java | 4 +-
.../reef/webserver/ParsedHttpRequest.java | 26 +++++-----
.../reef/webserver/ReefEventStateManager.java | 46 ++++++++---------
372 files changed, 944 insertions(+), 944 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-annotations/src/main/java/org/apache/reef/annotations/audience/package-info.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-annotations/src/main/java/org/apache/reef/annotations/audience/package-info.java b/lang/java/reef-annotations/src/main/java/org/apache/reef/annotations/audience/package-info.java
index 7a88388..b301b9d 100644
--- a/lang/java/reef-annotations/src/main/java/org/apache/reef/annotations/audience/package-info.java
+++ b/lang/java/reef-annotations/src/main/java/org/apache/reef/annotations/audience/package-info.java
@@ -17,6 +17,6 @@
* under the License.
*/
/**
- * Annotations for interface audience
+ * Annotations for interface audience.
*/
-package org.apache.reef.annotations.audience;
\ No newline at end of file
+package org.apache.reef.annotations.audience;
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-bridge-client/src/main/java/org/apache/reef/bridge/client/YarnJobSubmissionClient.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-bridge-client/src/main/java/org/apache/reef/bridge/client/YarnJobSubmissionClient.java b/lang/java/reef-bridge-client/src/main/java/org/apache/reef/bridge/client/YarnJobSubmissionClient.java
index 248375a..3847bab 100644
--- a/lang/java/reef-bridge-client/src/main/java/org/apache/reef/bridge/client/YarnJobSubmissionClient.java
+++ b/lang/java/reef-bridge-client/src/main/java/org/apache/reef/bridge/client/YarnJobSubmissionClient.java
@@ -47,7 +47,7 @@ import java.util.logging.Level;
import java.util.logging.Logger;
/**
- * The Java-side of the C# YARN Job Submission API
+ * The Java-side of the C# YARN Job Submission API.
*/
public final class YarnJobSubmissionClient {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/LibLoader.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/LibLoader.java b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/LibLoader.java
index aee7350..013bae5 100644
--- a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/LibLoader.java
+++ b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/LibLoader.java
@@ -31,7 +31,7 @@ import java.util.logging.Level;
import java.util.logging.Logger;
/**
- * Loading CLR libraries
+ * Loading CLR libraries.
*/
public class LibLoader {
@@ -52,7 +52,7 @@ public class LibLoader {
}
/**
- * Load CLR libraries
+ * Load CLR libraries.
*/
public void loadLib() throws IOException {
LOG.log(Level.INFO, "Loading DLLs for driver at time {0}." + new Date().toString());
@@ -220,7 +220,7 @@ public class LibLoader {
}
/**
- * load assembly
+ * load assembly.
*
* @param fileOut
* @param managed
@@ -234,4 +234,4 @@ public class LibLoader {
LOG.log(Level.INFO, "Loading DLL not managed done");
}
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/JobClient.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/JobClient.java b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/JobClient.java
index 62bfac1..e06e6eb 100644
--- a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/JobClient.java
+++ b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/JobClient.java
@@ -68,7 +68,7 @@ public class JobClient {
private ConfigurationModule driverConfigModule;
/**
- * A reference to the running job that allows client to send messages back to the job driver
+ * A reference to the running job that allows client to send messages back to the job driver.
*/
private RunningJob runningJob;
@@ -84,7 +84,7 @@ public class JobClient {
private String jobSubmissionDirectory = "reefTmp/job_" + System.currentTimeMillis();
/**
- * A factory that provides LoggingScope
+ * A factory that provides LoggingScope.
*/
private final LoggingScopeFactory loggingScopeFactory;
/**
@@ -211,7 +211,7 @@ public class JobClient {
}
/**
- * Set the driver memory
+ * Set the driver memory.
*/
public void setDriverInfo(final String identifier, final int memory, final String jobSubmissionDirectory) {
if (identifier == null || identifier.isEmpty()) {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/JobDriver.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/JobDriver.java b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/JobDriver.java
index 0d4a211..da75cb7 100644
--- a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/JobDriver.java
+++ b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/JobDriver.java
@@ -89,17 +89,17 @@ public final class JobDriver {
private final EvaluatorRequestor evaluatorRequestor;
/**
- * Driver status manager to monitor driver status
+ * Driver status manager to monitor driver status.
*/
private final DriverStatusManager driverStatusManager;
/**
- * NativeInterop has function to load libs when driver starts
+ * NativeInterop has function to load libs when driver starts.
*/
private final LibLoader libLoader;
/**
- * Factory to setup new CLR process configurations
+ * Factory to setup new CLR process configurations.
*/
private final CLRProcessFactory clrProcessFactory;
@@ -113,7 +113,7 @@ public final class JobDriver {
private final Map<String, ActiveContext> contexts = new HashMap<>();
/**
- * Logging scope factory that provides LoggingScope
+ * Logging scope factory that provides LoggingScope.
*/
private final LoggingScopeFactory loggingScopeFactory;
@@ -278,7 +278,7 @@ public final class JobDriver {
}
/**
- * Handles AllocatedEvaluator: Submit an empty context
+ * Handles AllocatedEvaluator: Submit an empty context.
*/
public final class AllocatedEvaluatorHandler implements EventHandler<AllocatedEvaluator> {
@Override
@@ -398,7 +398,7 @@ public final class JobDriver {
private String uriSpecification;
/**
- * returns URI specification for the handler
+ * returns URI specification for the handler.
*/
@Override
public String getUriSpecification() {
@@ -410,7 +410,7 @@ public final class JobDriver {
}
/**
- * process http request
+ * process http request.
*/
@Override
public void onHttpRequest(final ParsedHttpRequest parsedHttpRequest, final HttpServletResponse response) throws IOException, ServletException {
@@ -509,7 +509,7 @@ public final class JobDriver {
}
/**
- * Receive notification that an context is active on Evaluator when the driver restarted
+ * Receive notification that an context is active on Evaluator when the driver restarted.
*/
public final class DriverRestartActiveContextHandler implements EventHandler<ActiveContext> {
@Override
@@ -555,7 +555,7 @@ public final class JobDriver {
/**
- * Job driver is restarted after previous crash
+ * Job driver is restarted after previous crash.
*/
public final class RestartHandler implements EventHandler<StartTime> {
@Override
@@ -711,7 +711,7 @@ public final class JobDriver {
}
/**
- * Receive notification that a ContextMessage has been received
+ * Receive notification that a ContextMessage has been received.
*/
public final class ContextMessageHandler implements EventHandler<ContextMessage> {
@Override
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/Launch.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/Launch.java b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/Launch.java
index f3f5fae..dc4a9cf 100644
--- a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/Launch.java
+++ b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/Launch.java
@@ -46,11 +46,11 @@ import java.util.logging.Logger;
public final class Launch {
/**
- * The upper limit on the number of Evaluators that the local resourcemanager will hand out concurrently
+ * The upper limit on the number of Evaluators that the local resourcemanager will hand out concurrently.
*/
private static final int MAX_NUMBER_OF_EVALUATORS = 10;
/**
- * Standard Java logger
+ * Standard Java logger.
*/
private static final Logger LOG = Logger.getLogger(Launch.class.getName());
@@ -136,7 +136,7 @@ public final class Launch {
}
/**
- * Main method that starts the CLR Bridge from Java
+ * Main method that starts the CLR Bridge from Java.
*
* @param args command line parameters.
*/
@@ -202,7 +202,7 @@ public final class Launch {
}
/**
- * Command line parameter, driver memory, in MB
+ * Command line parameter, driver memory, in MB.
*/
@NamedParameter(doc = "memory allocated to driver JVM",
short_name = "driver_memory", default_value = "512")
@@ -210,7 +210,7 @@ public final class Launch {
}
/**
- * Command line parameter, driver identifier
+ * Command line parameter, driver identifier.
*/
@NamedParameter(doc = "driver identifier for clr bridge",
short_name = "driver_id", default_value = "ReefClrBridge")
@@ -218,7 +218,7 @@ public final class Launch {
}
/**
- * Command line parameter = true to submit the job with driver config, or false to write config to current directory
+ * Command line parameter = true to submit the job with driver config, or false to write config to current directory.
*/
@NamedParameter(doc = "Whether or not to submit the reef job after driver config is constructed",
short_name = "submit", default_value = "true")
@@ -226,7 +226,7 @@ public final class Launch {
}
/**
- * Command line parameter, job submission directory, if set, user should guarantee its uniqueness
+ * Command line parameter, job submission directory, if set, user should guarantee its uniqueness.
*/
@NamedParameter(doc = "driver job submission directory",
short_name = "submission_directory", default_value = "empty")
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/LaunchHeadless.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/LaunchHeadless.java b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/LaunchHeadless.java
index ba2a5cb..b09fd13 100644
--- a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/LaunchHeadless.java
+++ b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/LaunchHeadless.java
@@ -39,7 +39,7 @@ import java.util.logging.Logger;
public final class LaunchHeadless {
/**
- * Standard Java logger
+ * Standard Java logger.
*/
private static final Logger LOG = Logger.getLogger(LaunchHeadless.class.getName());
@@ -62,7 +62,7 @@ public final class LaunchHeadless {
*/
/**
- * Main method that starts the CLR Bridge from Java
+ * Main method that starts the CLR Bridge from Java.
*
* @param args command line parameters.
*/
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/package-info.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/package-info.java b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/package-info.java
index d93f6f4..486782c 100644
--- a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/package-info.java
+++ b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/javabridge/generic/package-info.java
@@ -17,6 +17,6 @@
* under the License.
*/
/**
- * Generic java bridge driver/client
+ * Generic java bridge driver/client.
*/
-package org.apache.reef.javabridge.generic;
\ No newline at end of file
+package org.apache.reef.javabridge.generic;
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-bridge-java/src/main/java/org/apache/reef/util/logging/package-info.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/util/logging/package-info.java b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/util/logging/package-info.java
index e0e79ce..abc3577 100644
--- a/lang/java/reef-bridge-java/src/main/java/org/apache/reef/util/logging/package-info.java
+++ b/lang/java/reef-bridge-java/src/main/java/org/apache/reef/util/logging/package-info.java
@@ -17,6 +17,6 @@
* under the License.
*/
/**
- * Logging handler for clr bridge
+ * Logging handler for clr bridge.
*/
package org.apache.reef.util.logging;
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-checkpoint/src/main/java/org/apache/reef/io/checkpoint/CheckpointNamingService.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-checkpoint/src/main/java/org/apache/reef/io/checkpoint/CheckpointNamingService.java b/lang/java/reef-checkpoint/src/main/java/org/apache/reef/io/checkpoint/CheckpointNamingService.java
index 4415c46..fa8c128 100644
--- a/lang/java/reef-checkpoint/src/main/java/org/apache/reef/io/checkpoint/CheckpointNamingService.java
+++ b/lang/java/reef-checkpoint/src/main/java/org/apache/reef/io/checkpoint/CheckpointNamingService.java
@@ -24,7 +24,7 @@ package org.apache.reef.io.checkpoint;
public interface CheckpointNamingService {
/**
- * Generate a new checkpoint Name
+ * Generate a new checkpoint Name.
*
* @return the checkpoint name
*/
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/client/parameters/JobCompletedHandler.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/client/parameters/JobCompletedHandler.java b/lang/java/reef-common/src/main/java/org/apache/reef/client/parameters/JobCompletedHandler.java
index 3367ae0..b91013c 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/client/parameters/JobCompletedHandler.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/client/parameters/JobCompletedHandler.java
@@ -25,7 +25,7 @@ import org.apache.reef.tang.annotations.NamedParameter;
import org.apache.reef.wake.EventHandler;
/**
- * Event handler for CompletedJob
+ * Event handler for CompletedJob.
*/
@NamedParameter(doc = "Event handler for CompletedJob",
default_classes = DefaultCompletedJobHandler.class)
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/catalog/ResourceCatalog.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/catalog/ResourceCatalog.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/catalog/ResourceCatalog.java
index 62f4d6b..228dd13 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/catalog/ResourceCatalog.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/catalog/ResourceCatalog.java
@@ -42,7 +42,7 @@ public interface ResourceCatalog {
public Collection<NodeDescriptor> getNodes();
/**
- * The global list of racks
+ * The global list of racks.
*
* @return list of all rack descriptors
*/
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/context/ContextConfiguration.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/context/ContextConfiguration.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/context/ContextConfiguration.java
index a4e61b1..e696c9b 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/context/ContextConfiguration.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/context/ContextConfiguration.java
@@ -84,7 +84,7 @@ public class ContextConfiguration extends ConfigurationModuleBuilder {
public static final OptionalImpl<ContextMessageHandler> ON_MESSAGE = new OptionalImpl<>();
/**
- * Implementation for reconnecting to driver after driver restart
+ * Implementation for reconnecting to driver after driver restart.
*/
public static final OptionalImpl<DriverConnection> ON_DRIVER_RECONNECT = new OptionalImpl<>();
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/CLRProcess.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/CLRProcess.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/CLRProcess.java
index 09f4a00..a9d818c 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/CLRProcess.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/CLRProcess.java
@@ -23,13 +23,13 @@ import org.apache.reef.runtime.common.launch.CLRLaunchCommandBuilder;
import java.util.List;
/**
- * Defines the setup of a CLR process
+ * Defines the setup of a CLR process.
*/
public final class CLRProcess implements EvaluatorProcess {
private final CLRLaunchCommandBuilder commandBuilder = new CLRLaunchCommandBuilder();
/**
- * Instantiated via CLRProcessFactory
+ * Instantiated via CLRProcessFactory.
*/
CLRProcess() {
}
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/CLRProcessFactory.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/CLRProcessFactory.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/CLRProcessFactory.java
index 49d4d80..d5d3d3e 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/CLRProcessFactory.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/CLRProcessFactory.java
@@ -24,7 +24,7 @@ import org.apache.reef.annotations.audience.Private;
import javax.inject.Inject;
/**
- * Factory to setup new CLR processes
+ * Factory to setup new CLR processes.
*/
@Private
@DriverSide
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorProcess.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorProcess.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorProcess.java
index b20b432..2caeb2e 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorProcess.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorProcess.java
@@ -21,7 +21,7 @@ package org.apache.reef.driver.evaluator;
import java.util.List;
/**
- * Defines the setup of an evaluator's process
+ * Defines the setup of an evaluator's process.
*/
public interface EvaluatorProcess {
/**
@@ -35,7 +35,7 @@ public interface EvaluatorProcess {
EvaluatorType getType();
/**
- * Set the error handler remote identifier
+ * Set the error handler remote identifier.
*
* @param errorHandlerRID
* @return this
@@ -43,7 +43,7 @@ public interface EvaluatorProcess {
EvaluatorProcess setErrorHandlerRID(final String errorHandlerRID);
/**
- * Set the launch identifier
+ * Set the launch identifier.
*
* @param launchID
* @return this
@@ -51,7 +51,7 @@ public interface EvaluatorProcess {
EvaluatorProcess setLaunchID(final String launchID);
/**
- * Set memory size of process in megabytes
+ * Set memory size of process in megabytes.
*
* @param megaBytes
* @return this
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorProcessFactory.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorProcessFactory.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorProcessFactory.java
index 3610dc6..2f32f09 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorProcessFactory.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorProcessFactory.java
@@ -23,7 +23,7 @@ import org.apache.reef.annotations.audience.Public;
import org.apache.reef.tang.annotations.DefaultImplementation;
/**
- * Factory to create new evaluator process setups
+ * Factory to create new evaluator process setups.
*/
@Public
@DriverSide
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorRequest.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorRequest.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorRequest.java
index 7094a42..a99fd04 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorRequest.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorRequest.java
@@ -126,7 +126,7 @@ public final class EvaluatorRequest {
}
/**
- * set number of cores
+ * set number of cores.
*
* @param cores the number of cores
* @return
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorType.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorType.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorType.java
index 6c27db8..f08f09d 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorType.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/EvaluatorType.java
@@ -23,11 +23,11 @@ package org.apache.reef.driver.evaluator;
*/
public enum EvaluatorType {
/**
- * Indicates an Evaluator that runs on the JVM
+ * Indicates an Evaluator that runs on the JVM.
*/
JVM,
/**
- * Indicates an Evaluator that runs on the CLR
+ * Indicates an Evaluator that runs on the CLR.
*/
CLR,
/**
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/JVMProcess.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/JVMProcess.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/JVMProcess.java
index f068245..c50e777 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/JVMProcess.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/JVMProcess.java
@@ -25,7 +25,7 @@ import org.apache.reef.runtime.common.launch.JavaLaunchCommandBuilder;
import java.util.List;
/**
- * Defines the setup of a JVM process
+ * Defines the setup of a JVM process.
*/
public final class JVMProcess implements EvaluatorProcess {
private final JavaLaunchCommandBuilder commandBuilder = new JavaLaunchCommandBuilder();
@@ -33,7 +33,7 @@ public final class JVMProcess implements EvaluatorProcess {
private final ClasspathProvider classpathProvider;
/**
- * Instantiated via JVMProcessFactory
+ * Instantiated via JVMProcessFactory.
*/
JVMProcess(final RuntimePathProvider runtimePathProvider,
final ClasspathProvider classpathProvider) {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/JVMProcessFactory.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/JVMProcessFactory.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/JVMProcessFactory.java
index 489751e..e986fd5 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/JVMProcessFactory.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/evaluator/JVMProcessFactory.java
@@ -25,7 +25,7 @@ import org.apache.reef.runtime.common.files.RuntimePathProvider;
import javax.inject.Inject;
/**
- * Factory to setup new JVM processes
+ * Factory to setup new JVM processes.
*/
@DriverSide
public final class JVMProcessFactory implements EvaluatorProcessFactory {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ClientCloseWithMessageHandlers.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ClientCloseWithMessageHandlers.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ClientCloseWithMessageHandlers.java
index 708301d..db7246e 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ClientCloseWithMessageHandlers.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ClientCloseWithMessageHandlers.java
@@ -26,7 +26,7 @@ import org.apache.reef.wake.EventHandler;
import java.util.Set;
/**
- * Handles client close requests
+ * Handles client close requests.
*/
@NamedParameter(doc = "Handles client close requests", default_classes = DefaultClientCloseWithMessageHandler.class)
public final class ClientCloseWithMessageHandlers implements Name<Set<EventHandler<byte[]>>> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ContextActiveHandlers.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ContextActiveHandlers.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ContextActiveHandlers.java
index 724d7a8..85f397b 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ContextActiveHandlers.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ContextActiveHandlers.java
@@ -27,7 +27,7 @@ import org.apache.reef.wake.EventHandler;
import java.util.Set;
/**
- * Handler for ActiveContext
+ * Handler for ActiveContext.
*/
@NamedParameter(doc = "Handler for ActiveContext", default_classes = DefaultContextActiveHandler.class)
public final class ContextActiveHandlers implements Name<Set<EventHandler<ActiveContext>>> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ContextFailedHandlers.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ContextFailedHandlers.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ContextFailedHandlers.java
index 1ded6f9..c44561c 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ContextFailedHandlers.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ContextFailedHandlers.java
@@ -27,7 +27,7 @@ import org.apache.reef.wake.EventHandler;
import java.util.Set;
/**
- * Handler for FailedContext
+ * Handler for FailedContext.
*/
@NamedParameter(doc = "Handler for FailedContext", default_classes = DefaultContextFailureHandler.class)
public final class ContextFailedHandlers implements Name<Set<EventHandler<FailedContext>>> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverIdentifier.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverIdentifier.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverIdentifier.java
index 1a0002b..55bcc06 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverIdentifier.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverIdentifier.java
@@ -22,7 +22,7 @@ import org.apache.reef.tang.annotations.Name;
import org.apache.reef.tang.annotations.NamedParameter;
/**
- * Driver Identifier
+ * Driver Identifier.
*/
@NamedParameter(doc = "Driver Identifier", default_value = DriverIdentifier.DEFAULT_VALUE)
public final class DriverIdentifier implements Name<String> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverJobSubmissionDirectory.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverJobSubmissionDirectory.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverJobSubmissionDirectory.java
index 8201960..f1486db 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverJobSubmissionDirectory.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverJobSubmissionDirectory.java
@@ -22,7 +22,7 @@ import org.apache.reef.tang.annotations.Name;
import org.apache.reef.tang.annotations.NamedParameter;
/**
- * Job submission directory
+ * Job submission directory.
*/
@NamedParameter(doc = "Job submission directory. This is the folder on the DFS used to stage the files for the Driver and subsequently for the Evaluators. It will be created if it doesn't exist yet.")
public final class DriverJobSubmissionDirectory implements Name<String> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverMemory.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverMemory.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverMemory.java
index 8df693c..847d97e 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverMemory.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverMemory.java
@@ -22,7 +22,7 @@ import org.apache.reef.tang.annotations.Name;
import org.apache.reef.tang.annotations.NamedParameter;
/**
- * Driver RAM allocation in MB
+ * Driver RAM allocation in MB.
*/
@NamedParameter(doc = "Driver RAM allocation in MB", default_value = "256")
public final class DriverMemory implements Name<Integer> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverRestartCompletedHandlers.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverRestartCompletedHandlers.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverRestartCompletedHandlers.java
index 341f9e4..c0a6e2d 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverRestartCompletedHandlers.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverRestartCompletedHandlers.java
@@ -27,7 +27,7 @@ import org.apache.reef.wake.EventHandler;
import java.util.Set;
/**
- * Handler for event that all evaluators have checked back in after driver restart and that the restart is completed
+ * Handler for event that all evaluators have checked back in after driver restart and that the restart is completed.
*/
@NamedParameter(doc = "Handler for event of driver restart completion", default_classes = DefaultDriverRestartCompletedHandler.class)
public final class DriverRestartCompletedHandlers implements Name<Set<EventHandler<DriverRestartCompleted>>> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverRestartContextActiveHandlers.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverRestartContextActiveHandlers.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverRestartContextActiveHandlers.java
index e06e5d9..431ee22 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverRestartContextActiveHandlers.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/DriverRestartContextActiveHandlers.java
@@ -27,7 +27,7 @@ import org.apache.reef.wake.EventHandler;
import java.util.Set;
/**
- * Handler for ActiveContext during a driver restart
+ * Handler for ActiveContext during a driver restart.
*/
@NamedParameter(doc = "Handler for ActiveContext received during a driver restart", default_classes = DefaultDriverRestartContextActiveHandler.class)
public final class DriverRestartContextActiveHandlers implements Name<Set<EventHandler<ActiveContext>>> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceContextActiveHandlers.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceContextActiveHandlers.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceContextActiveHandlers.java
index 716b7b9..a420098 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceContextActiveHandlers.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceContextActiveHandlers.java
@@ -26,7 +26,7 @@ import org.apache.reef.wake.EventHandler;
import java.util.Set;
/**
- * Handler for ActiveContext
+ * Handler for ActiveContext.
*/
@NamedParameter(doc = "Handler for ActiveContext")
public final class ServiceContextActiveHandlers implements Name<Set<EventHandler<ActiveContext>>> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceContextFailedHandlers.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceContextFailedHandlers.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceContextFailedHandlers.java
index b7acf0c..4a61ef6 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceContextFailedHandlers.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceContextFailedHandlers.java
@@ -26,7 +26,7 @@ import org.apache.reef.wake.EventHandler;
import java.util.Set;
/**
- * Handler for FailedContext
+ * Handler for FailedContext.
*/
@NamedParameter(doc = "Handler for FailedContext")
public final class ServiceContextFailedHandlers implements Name<Set<EventHandler<FailedContext>>> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceDriverRestartCompletedHandlers.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceDriverRestartCompletedHandlers.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceDriverRestartCompletedHandlers.java
index 106783a..eb8d6bc 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceDriverRestartCompletedHandlers.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceDriverRestartCompletedHandlers.java
@@ -26,7 +26,7 @@ import org.apache.reef.wake.EventHandler;
import java.util.Set;
/**
- * Service handler for driver restart completed event
+ * Service handler for driver restart completed event.
*/
@NamedParameter(doc = "Handler for driver restart completed event")
public final class ServiceDriverRestartCompletedHandlers implements Name<Set<EventHandler<DriverRestartCompleted>>> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceDriverRestartContextActiveHandlers.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceDriverRestartContextActiveHandlers.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceDriverRestartContextActiveHandlers.java
index eb7debf..bb977ad 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceDriverRestartContextActiveHandlers.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/ServiceDriverRestartContextActiveHandlers.java
@@ -26,7 +26,7 @@ import org.apache.reef.wake.EventHandler;
import java.util.Set;
/**
- * Handler for ActiveContext received during driver restart
+ * Handler for ActiveContext received during driver restart.
*/
@NamedParameter(doc = "Handler for ActiveContext received during driver restart")
public final class ServiceDriverRestartContextActiveHandlers implements Name<Set<EventHandler<ActiveContext>>> {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/package-info.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/package-info.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/package-info.java
index 87901e2..9a8665c 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/package-info.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/parameters/package-info.java
@@ -17,6 +17,6 @@
* under the License.
*/
/**
- * Named parameters used by the Driver
+ * Named parameters used by the Driver.
*/
-package org.apache.reef.driver.parameters;
\ No newline at end of file
+package org.apache.reef.driver.parameters;
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/driver/task/RunningTask.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/driver/task/RunningTask.java b/lang/java/reef-common/src/main/java/org/apache/reef/driver/task/RunningTask.java
index 5121c31..b46d3e9 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/driver/task/RunningTask.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/driver/task/RunningTask.java
@@ -25,7 +25,7 @@ import org.apache.reef.driver.context.ActiveContext;
import org.apache.reef.io.naming.Identifiable;
/**
- * Represents a running Task
+ * Represents a running Task.
*/
@DriverSide
@Public
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/evaluator/context/parameters/Services.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/evaluator/context/parameters/Services.java b/lang/java/reef-common/src/main/java/org/apache/reef/evaluator/context/parameters/Services.java
index df5a2ed..88238df 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/evaluator/context/parameters/Services.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/evaluator/context/parameters/Services.java
@@ -26,7 +26,7 @@ import org.apache.reef.util.ObjectInstantiationLogger;
import java.util.Set;
/**
- * A set of classes to be instantiated and shared as singletons within this context and all child context
+ * A set of classes to be instantiated and shared as singletons within this context and all child context.
*/
@NamedParameter(doc = "A set of classes to be instantiated and shared as singletons within this context and all child context",
default_classes = ObjectInstantiationLogger.class)
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/exception/EvaluatorKilledByResourceManagerException.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/exception/EvaluatorKilledByResourceManagerException.java b/lang/java/reef-common/src/main/java/org/apache/reef/exception/EvaluatorKilledByResourceManagerException.java
index 2a0c5f4..1606250 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/exception/EvaluatorKilledByResourceManagerException.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/exception/EvaluatorKilledByResourceManagerException.java
@@ -19,7 +19,7 @@
package org.apache.reef.exception;
/**
- * Reported as part of a FailedEvaluator when the resource manager killed the Evaluator
+ * Reported as part of a FailedEvaluator when the resource manager killed the Evaluator.
*/
public final class EvaluatorKilledByResourceManagerException extends EvaluatorException {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/exception/evaluator/NetworkException.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/exception/evaluator/NetworkException.java b/lang/java/reef-common/src/main/java/org/apache/reef/exception/evaluator/NetworkException.java
index 20c5bdc..6b27da3 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/exception/evaluator/NetworkException.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/exception/evaluator/NetworkException.java
@@ -19,7 +19,7 @@
package org.apache.reef.exception.evaluator;
/**
- * Network exception
+ * Network exception.
*/
public class NetworkException extends ServiceException {
private static final long serialVersionUID = 1L;
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/io/ExternalMap.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/io/ExternalMap.java b/lang/java/reef-common/src/main/java/org/apache/reef/io/ExternalMap.java
index 31350f4..c4075c2 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/io/ExternalMap.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/io/ExternalMap.java
@@ -39,7 +39,7 @@ public interface ExternalMap<T> {
public boolean containsKey(final CharSequence key);
/**
- * Element access
+ * Element access.
*
* @param key
* @return the object stored under key nor null if no such object exists
@@ -47,7 +47,7 @@ public interface ExternalMap<T> {
public T get(final CharSequence key);
/**
- * Put a record into the map
+ * Put a record into the map.
*
* @param key
* @param value
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/io/Message.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/io/Message.java b/lang/java/reef-common/src/main/java/org/apache/reef/io/Message.java
index 17eade3..a5e1331 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/io/Message.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/io/Message.java
@@ -21,13 +21,13 @@ package org.apache.reef.io;
import org.apache.reef.annotations.audience.Public;
/**
- * A message from a REEF component
+ * A message from a REEF component.
*/
@Public
public interface Message {
/**
- * Message payload
+ * Message payload.
*
* @return message payload
*/
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/io/TcpPortConfigurationProvider.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/io/TcpPortConfigurationProvider.java b/lang/java/reef-common/src/main/java/org/apache/reef/io/TcpPortConfigurationProvider.java
index 19f311c..d6e8021 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/io/TcpPortConfigurationProvider.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/io/TcpPortConfigurationProvider.java
@@ -32,7 +32,7 @@ import java.util.logging.Level;
import java.util.logging.Logger;
/**
- * Implements ConfigurationProvider for RangeTcpPortProvider
+ * Implements ConfigurationProvider for RangeTcpPortProvider.
*/
public class TcpPortConfigurationProvider implements ConfigurationProvider {
private final int portRangeBegin;
@@ -51,7 +51,7 @@ public class TcpPortConfigurationProvider implements ConfigurationProvider {
}
/**
- * returns a configuration for the class that implements TcpPortProvider so that class can be instantiated
+ * returns a configuration for the class that implements TcpPortProvider so that class can be instantiated.
* somewhere else
*
* @return Configuration.
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/Identifiable.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/Identifiable.java b/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/Identifiable.java
index 0230434..e2a7ae8 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/Identifiable.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/Identifiable.java
@@ -25,7 +25,7 @@ package org.apache.reef.io.naming;
public interface Identifiable {
/**
- * Returns an identifier of this object
+ * Returns an identifier of this object.
*
* @return an identifier of this object
*/
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/NameAssignment.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/NameAssignment.java b/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/NameAssignment.java
index eb00022..4d569ce 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/NameAssignment.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/NameAssignment.java
@@ -23,19 +23,19 @@ import org.apache.reef.wake.Identifier;
import java.net.InetSocketAddress;
/**
- * Pair of an identifier and an address
+ * Pair of an identifier and an address.
*/
public interface NameAssignment {
/**
- * Returns an identifier of this object
+ * Returns an identifier of this object.
*
* @return an identifier
*/
public Identifier getIdentifier();
/**
- * Returns an address of this object
+ * Returns an address of this object.
*
* @return a socket address
*/
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/NamingRegistry.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/NamingRegistry.java b/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/NamingRegistry.java
index 0d4f6c5..4ade837 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/NamingRegistry.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/io/naming/NamingRegistry.java
@@ -28,7 +28,7 @@ import java.net.InetSocketAddress;
public interface NamingRegistry {
/**
- * Register the given Address for the given Identifier
+ * Register the given Address for the given Identifier.
*
* @param id
* @param addr
@@ -37,7 +37,7 @@ public interface NamingRegistry {
public void register(final Identifier id, final InetSocketAddress addr) throws Exception;
/**
- * Unregister the given Identifier from the registry
+ * Unregister the given Identifier from the registry.
*
* @param id
* @throws Exception
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/io/package-info.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/io/package-info.java b/lang/java/reef-common/src/main/java/org/apache/reef/io/package-info.java
index 702f401..889acdc 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/io/package-info.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/io/package-info.java
@@ -17,8 +17,8 @@
* under the License.
*/
/**
- * APIs for I/O in REEF: {@link org.apache.reef.io.Codec}s and {@link org.apache.reef.io.Serializer}s
+ * APIs for I/O in REEF: {@link org.apache.reef.io.Codec}s and {@link org.apache.reef.io.Serializer}s.
*/
@Unstable package org.apache.reef.io;
-import org.apache.reef.annotations.Unstable;
\ No newline at end of file
+import org.apache.reef.annotations.Unstable;
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/io/serialization/Codec.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/io/serialization/Codec.java b/lang/java/reef-common/src/main/java/org/apache/reef/io/serialization/Codec.java
index 5e69d4f..ce03920 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/io/serialization/Codec.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/io/serialization/Codec.java
@@ -28,7 +28,7 @@ package org.apache.reef.io.serialization;
public interface Codec<T> {
/**
- * Encodes the given object into a Byte Array
+ * Encodes the given object into a Byte Array.
*
* @param obj
* @return a byte[] representation of the object
@@ -36,7 +36,7 @@ public interface Codec<T> {
public byte[] encode(T obj);
/**
- * Decodes the given byte array into an object
+ * Decodes the given byte array into an object.
*
* @param buf
* @return the decoded object
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/CompletedJobImpl.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/CompletedJobImpl.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/CompletedJobImpl.java
index 908ea54..9e54ac9 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/CompletedJobImpl.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/CompletedJobImpl.java
@@ -23,7 +23,7 @@ import org.apache.reef.annotations.audience.Private;
import org.apache.reef.client.CompletedJob;
/**
- * An implementation of CompletedJob
+ * An implementation of CompletedJob.
*/
@ClientSide
@Private
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/JobStatusMessageHandler.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/JobStatusMessageHandler.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/JobStatusMessageHandler.java
index 2ef9706..faf1752 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/JobStatusMessageHandler.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/JobStatusMessageHandler.java
@@ -29,7 +29,7 @@ import java.util.logging.Level;
import java.util.logging.Logger;
/**
- * A Handler for JobStatus messages from running jobs
+ * A Handler for JobStatus messages from running jobs.
*/
@ClientSide
@Private
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/JobSubmissionHelper.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/JobSubmissionHelper.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/JobSubmissionHelper.java
index 964ae8f..b19fd72 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/JobSubmissionHelper.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/JobSubmissionHelper.java
@@ -40,7 +40,7 @@ import java.util.logging.Level;
import java.util.logging.Logger;
/**
- * Shared code between job submission with and without client
+ * Shared code between job submission with and without client.
*/
final class JobSubmissionHelper {
@@ -164,7 +164,7 @@ final class JobSubmissionHelper {
}
/**
- * Turns temporary folder "foo" into a jar file "foo.jar"
+ * Turns temporary folder "foo" into a jar file "foo.jar".
*
* @param file
* @return
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/RunningJobs.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/RunningJobs.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/RunningJobs.java
index 7c9bbb7..ee13571 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/RunningJobs.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/RunningJobs.java
@@ -25,7 +25,7 @@ import org.apache.reef.tang.annotations.DefaultImplementation;
import org.apache.reef.wake.remote.RemoteMessage;
/**
- * Manages the RunningJobs a client knows about
+ * Manages the RunningJobs a client knows about.
*/
@Private
@ClientSide
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/RunningJobsImpl.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/RunningJobsImpl.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/RunningJobsImpl.java
index 7a9ed05..2c7f375 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/RunningJobsImpl.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/RunningJobsImpl.java
@@ -97,7 +97,7 @@ final class RunningJobsImpl implements RunningJobs {
/**
- * A guarded get() that throws an exception if the RunningJob isn't known
+ * A guarded get() that throws an exception if the RunningJob isn't known.
*
* @param jobIdentifier
* @return
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/JobSubmissionEvent.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/JobSubmissionEvent.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/JobSubmissionEvent.java
index ac45b05..bf35386 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/JobSubmissionEvent.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/JobSubmissionEvent.java
@@ -27,7 +27,7 @@ import org.apache.reef.util.Optional;
import java.util.Set;
/**
- * Event sent to Driver Runtime
+ * Event sent to Driver Runtime.
* Submission of a Job to the Driver Runtime
*/
@RuntimeAuthor
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/JobSubmissionEventImpl.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/JobSubmissionEventImpl.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/JobSubmissionEventImpl.java
index e76f554..b72f959 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/JobSubmissionEventImpl.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/JobSubmissionEventImpl.java
@@ -149,7 +149,7 @@ public final class JobSubmissionEventImpl implements JobSubmissionEvent {
}
/**
- * Add an entry to the globalFileSet
+ * Add an entry to the globalFileSet.
* @see JobSubmissionEvent#getGlobalFileSet()
*/
public Builder addGlobalFile(final FileResource globalFile) {
@@ -158,7 +158,7 @@ public final class JobSubmissionEventImpl implements JobSubmissionEvent {
}
/**
- * Add an entry to the localFileSet
+ * Add an entry to the localFileSet.
* @see JobSubmissionEvent#getLocalFileSet()
*/
public Builder addLocalFile(final FileResource localFile) {
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/package-info.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/package-info.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/package-info.java
index 7480e61..d7d0778 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/package-info.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/client/api/package-info.java
@@ -17,6 +17,6 @@
* under the License.
*/
/**
- * Client-Side Event Handlers to be implemented by a specific resourcemanager
+ * Client-Side Event Handlers to be implemented by a specific resourcemanager.
*/
-package org.apache.reef.runtime.common.client.api;
\ No newline at end of file
+package org.apache.reef.runtime.common.client.api;
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/DriverRuntimeConfigurationOptions.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/DriverRuntimeConfigurationOptions.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/DriverRuntimeConfigurationOptions.java
index ae26f8e..c4a1908 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/DriverRuntimeConfigurationOptions.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/DriverRuntimeConfigurationOptions.java
@@ -24,7 +24,7 @@ import org.apache.reef.tang.annotations.NamedParameter;
import org.apache.reef.wake.EventHandler;
/**
- * Houses the Driver resourcemanager configuration's NamedParameters
+ * Houses the Driver resourcemanager configuration's NamedParameters.
*/
public class DriverRuntimeConfigurationOptions {
@NamedParameter(doc = "Called when a job control message is received by the client.")
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceLaunchEvent.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceLaunchEvent.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceLaunchEvent.java
index a078a35..89554e0 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceLaunchEvent.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceLaunchEvent.java
@@ -28,7 +28,7 @@ import org.apache.reef.tang.annotations.DefaultImplementation;
import java.util.Set;
/**
- * Event from Driver Process -> Driver Runtime
+ * Event from Driver Process -> Driver Runtime.
* A request to the Driver Runtime to launch an Evaluator on the allocated Resource
*/
@RuntimeAuthor
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceLaunchEventImpl.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceLaunchEventImpl.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceLaunchEventImpl.java
index faf1d6d..1b9e943 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceLaunchEventImpl.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceLaunchEventImpl.java
@@ -121,7 +121,7 @@ public final class ResourceLaunchEventImpl implements ResourceLaunchEvent {
}
/**
- * Add an entry to the fileSet
+ * Add an entry to the fileSet.
*
* @see ResourceLaunchEvent#getFileSet()
*/
@@ -131,7 +131,7 @@ public final class ResourceLaunchEventImpl implements ResourceLaunchEvent {
}
/**
- * Utility method that adds files to the fileSet
+ * Utility method that adds files to the fileSet.
*
* @param files the files to add.
* @return this
@@ -149,7 +149,7 @@ public final class ResourceLaunchEventImpl implements ResourceLaunchEvent {
}
/**
- * Utility method that adds Libraries to the fileSet
+ * Utility method that adds Libraries to the fileSet.
*
* @param files the files to add.
* @return this
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceReleaseEvent.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceReleaseEvent.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceReleaseEvent.java
index d46aefa..c28f42d 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceReleaseEvent.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceReleaseEvent.java
@@ -23,7 +23,7 @@ import org.apache.reef.annotations.audience.RuntimeAuthor;
import org.apache.reef.tang.annotations.DefaultImplementation;
/**
- * Event from Driver Process -> Driver Runtime
+ * Event from Driver Process -> Driver Runtime.
* A request to the Driver Runtime to release this resource
*/
@RuntimeAuthor
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/eeafba31/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceRequestEvent.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceRequestEvent.java b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceRequestEvent.java
index c843219..d4ed54a 100644
--- a/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceRequestEvent.java
+++ b/lang/java/reef-common/src/main/java/org/apache/reef/runtime/common/driver/api/ResourceRequestEvent.java
@@ -26,7 +26,7 @@ import org.apache.reef.util.Optional;
import java.util.List;
/**
- * Event from Driver Process -> Driver Runtime
+ * Event from Driver Process -> Driver Runtime.
* A request to the Driver Runtime to allocate resources with the given specification
*/
@RuntimeAuthor