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/01/23 00:47:24 UTC
[51/51] [partial] incubator-reef git commit: [REEF-93] Move java
sources to lang/java
[REEF-93] Move java sources to lang/java
This moves all current Java code to the new folder lang/java.
JIRA: [REEF-93]: https://issues.apache.org/jira/browse/REEF-93
Pull Request: This closes #53
Project: http://git-wip-us.apache.org/repos/asf/incubator-reef/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-reef/commit/53ea32cc
Tree: http://git-wip-us.apache.org/repos/asf/incubator-reef/tree/53ea32cc
Diff: http://git-wip-us.apache.org/repos/asf/incubator-reef/diff/53ea32cc
Branch: refs/heads/master
Commit: 53ea32cce6cf4649315febaf27d71acda3b632d2
Parents: c908a52
Author: Julia Wang <ju...@microsoft.com>
Authored: Tue Jan 20 16:58:25 2015 -0800
Committer: Markus Weimer <we...@apache.org>
Committed: Thu Jan 22 15:44:12 2015 -0800
----------------------------------------------------------------------
lang/java/pom.xml | 656 +++++++++
lang/java/reef-annotations/pom.xml | 31 +
.../org/apache/reef/annotations/Optional.java | 26 +
.../org/apache/reef/annotations/Provided.java | 26 +
.../org/apache/reef/annotations/Unstable.java | 25 +
.../reef/annotations/audience/ClientSide.java | 26 +
.../reef/annotations/audience/DriverSide.java | 26 +
.../annotations/audience/EvaluatorSide.java | 25 +
.../reef/annotations/audience/Private.java | 26 +
.../reef/annotations/audience/Public.java | 26 +
.../annotations/audience/RuntimeAuthor.java | 26 +
.../reef/annotations/audience/TaskSide.java | 26 +
.../reef/annotations/audience/package-info.java | 22 +
.../apache/reef/annotations/package-info.java | 22 +
.../reef/annotations/semantics/Idempotent.java | 25 +
lang/java/reef-bridge-project/.gitignore | 34 +
lang/java/reef-bridge-project/pom.xml | 101 ++
.../reef-bridge-project/reef-bridge-clr/pom.xml | 162 +++
.../CSharp/CSharp/ClrHandler/ClrHandler.csproj | 66 +
.../ClrHandler/Properties/AssemblyInfo.cs | 49 +
.../externals/Microsoft.Reef.Driver.dll | Bin 0 -> 123392 bytes
.../CSharp/ClrHandler/externals/msvcr110.dll | Bin 0 -> 849360 bytes
.../ClrHandler/interface/IInteropReturnInfo.cs | 30 +
.../CSharp/ClrHandler/interface/ILogger.cs | 37 +
.../JavaClrBridge/ActiveContextClr2Java.cpp | 106 ++
.../AllocatedEvaluatorClr2Java.cpp | 164 +++
.../CppBridge/JavaClrBridge/AssemblyInfo.cpp | 50 +
.../CppBridge/JavaClrBridge/AssemblyUtil.cpp | 53 +
.../Cpp/CppBridge/JavaClrBridge/BinaryUtil.cpp | 102 ++
.../Cpp/CppBridge/JavaClrBridge/BinaryUtil.h | 26 +
.../JavaClrBridge/ClosedContextClr2Java.cpp | 86 ++
.../CppBridge/JavaClrBridge/Clr2JavaImpl.cpp | 44 +
.../Cpp/CppBridge/JavaClrBridge/Clr2JavaImpl.h | 220 +++
.../CppBridge/JavaClrBridge/CommonUtilities.cpp | 51 +
.../CompletedEvaluatorClr2Java.cpp | 58 +
.../JavaClrBridge/CompletedTaskClr2Java.cpp | 69 +
.../JavaClrBridge/ContextMessageClr2Java.cpp | 76 +
.../EvaluatorRequestorClr2Java.cpp | 69 +
.../JavaClrBridge/FailedContextClr2Java.cpp | 94 ++
.../JavaClrBridge/FailedEvaluatorClr2Java.cpp | 72 +
.../JavaClrBridge/FailedTaskClr2Java.cpp | 79 +
.../JavaClrBridge/HttpServerClr2Java.cpp | 135 ++
.../CppBridge/JavaClrBridge/InteropAssemblies.h | 40 +
.../CppBridge/JavaClrBridge/InteropLogger.cpp | 50 +
.../Cpp/CppBridge/JavaClrBridge/InteropLogger.h | 47 +
.../JavaClrBridge/InteropReturnInfo.cpp | 91 ++
.../CppBridge/JavaClrBridge/InteropReturnInfo.h | 57 +
.../Cpp/CppBridge/JavaClrBridge/InteropUtil.cpp | 129 ++
.../Cpp/CppBridge/JavaClrBridge/InteropUtil.h | 65 +
.../CppBridge/JavaClrBridge/JavaClrBridge.cpp | 492 +++++++
.../Cpp/CppBridge/JavaClrBridge/JavaClrBridge.h | 33 +
.../CppBridge/JavaClrBridge/JavaClrBridge.sln | 56 +
.../JavaClrBridge/JavaClrBridge.vcxproj | 173 +++
.../JavaClrBridge/JavaClrBridge.vcxproj.filters | 104 ++
.../CppBridge/JavaClrBridge/ManagedLogger.cpp | 47 +
.../main/Cpp/CppBridge/JavaClrBridge/ReadMe.txt | 57 +
.../JavaClrBridge/RunningTaskClr2Java.cpp | 90 ++
.../JavaClrBridge/SuspendedTaskClr2Java.cpp | 83 ++
.../JavaClrBridge/TaskMessageClr2Java.cpp | 58 +
.../reef-bridge-java/pom.xml | 116 ++
.../reef/javabridge/ActiveContextBridge.java | 80 ++
.../javabridge/AllocatedEvaluatorBridge.java | 141 ++
.../reef/javabridge/ClosedContextBridge.java | 81 ++
.../javabridge/CompletedEvaluatorBridge.java | 43 +
.../reef/javabridge/CompletedTaskBridge.java | 40 +
.../reef/javabridge/ContextMessageBridge.java | 56 +
.../javabridge/EvaluatorRequestorBridge.java | 76 +
.../reef/javabridge/FailedContextBridge.java | 83 ++
.../reef/javabridge/FailedEvaluatorBridge.java | 47 +
.../reef/javabridge/FailedTaskBridge.java | 60 +
.../reef/javabridge/HttpServerEventBridge.java | 79 +
.../apache/reef/javabridge/InteropLogger.java | 55 +
.../reef/javabridge/InteropReturnInfo.java | 52 +
.../org/apache/reef/javabridge/JavaBridge.java | 31 +
.../org/apache/reef/javabridge/LibLoader.java | 154 ++
.../apache/reef/javabridge/NativeBridge.java | 32 +
.../apache/reef/javabridge/NativeInterop.java | 166 +++
.../reef/javabridge/RunningTaskBridge.java | 49 +
.../reef/javabridge/SuspendedTaskBridge.java | 54 +
.../reef/javabridge/TaskMessageBridge.java | 36 +
.../org/apache/reef/javabridge/Utilities.java | 57 +
.../reef/javabridge/generic/JobClient.java | 322 +++++
.../reef/javabridge/generic/JobDriver.java | 724 ++++++++++
.../apache/reef/javabridge/generic/Launch.java | 236 +++
.../reef/javabridge/generic/LaunchHeadless.java | 100 ++
.../reef/javabridge/generic/package-info.java | 22 +
.../util/logging/CLRBufferedLogHandler.java | 167 +++
.../reef/util/logging/CLRLoggingConfig.java | 31 +
.../apache/reef/util/logging/package-info.java | 22 +
.../org/apache/reef/clr.logging.properties | 82 ++
.../reef-bridge-project/reef-bridge/pom.xml | 111 ++
lang/java/reef-checkpoint/maven-eclipse.xml | 28 +
lang/java/reef-checkpoint/pom.xml | 68 +
.../apache/reef/io/checkpoint/CheckpointID.java | 31 +
.../io/checkpoint/CheckpointNamingService.java | 33 +
.../reef/io/checkpoint/CheckpointService.java | 100 ++
.../reef/io/checkpoint/RandomNameCNS.java | 49 +
.../reef/io/checkpoint/SimpleNamingService.java | 55 +
.../fs/FSCheckPointServiceConfiguration.java | 110 ++
.../reef/io/checkpoint/fs/FSCheckpointID.java | 74 +
.../io/checkpoint/fs/FSCheckpointService.java | 221 +++
lang/java/reef-common/maven-eclipse.xml | 28 +
lang/java/reef-common/pom.xml | 142 ++
.../reef-common/src/main/conf/log4j.properties | 40 +
.../reef-common/src/main/conf/reef-site.xml | 21 +
.../apache/reef/client/ClientConfiguration.java | 83 ++
.../org/apache/reef/client/CompletedJob.java | 39 +
.../apache/reef/client/DriverConfiguration.java | 253 ++++
.../org/apache/reef/client/DriverLauncher.java | 220 +++
.../reef/client/DriverServiceConfiguration.java | 196 +++
.../java/org/apache/reef/client/FailedJob.java | 48 +
.../org/apache/reef/client/FailedRuntime.java | 82 ++
.../java/org/apache/reef/client/JobMessage.java | 74 +
.../org/apache/reef/client/LauncherStatus.java | 123 ++
.../main/java/org/apache/reef/client/REEF.java | 55 +
.../java/org/apache/reef/client/RunningJob.java | 62 +
.../org/apache/reef/client/package-info.java | 23 +
.../client/parameters/JobCompletedHandler.java | 35 +
.../client/parameters/JobFailedHandler.java | 35 +
.../client/parameters/JobMessageHandler.java | 35 +
.../client/parameters/JobRunningHandler.java | 35 +
.../parameters/ResourceManagerErrorHandler.java | 35 +
.../reef/client/parameters/package-info.java | 22 +
.../org/apache/reef/common/AbstractFailure.java | 151 ++
.../java/org/apache/reef/common/Failure.java | 58 +
.../reef/driver/ContextAndTaskSubmittable.java | 64 +
.../apache/reef/driver/ContextSubmittable.java | 49 +
.../reef/driver/FlexiblePreemptionEvent.java | 47 +
.../org/apache/reef/driver/PreemptionEvent.java | 47 +
.../apache/reef/driver/PreemptionHandler.java | 36 +
.../reef/driver/StrictPreemptionEvent.java | 37 +
.../org/apache/reef/driver/TaskSubmittable.java | 40 +
.../reef/driver/catalog/NodeDescriptor.java | 42 +
.../reef/driver/catalog/RackDescriptor.java | 35 +
.../reef/driver/catalog/ResourceCatalog.java | 65 +
.../reef/driver/client/JobMessageObserver.java | 44 +
.../apache/reef/driver/client/package-info.java | 25 +
.../reef/driver/context/ActiveContext.java | 71 +
.../reef/driver/context/ClosedContext.java | 37 +
.../apache/reef/driver/context/ContextBase.java | 56 +
.../driver/context/ContextConfiguration.java | 109 ++
.../reef/driver/context/ContextMessage.java | 52 +
.../reef/driver/context/FailedContext.java | 44 +
.../driver/context/ServiceConfiguration.java | 79 +
.../driver/evaluator/AllocatedEvaluator.java | 101 ++
.../driver/evaluator/CompletedEvaluator.java | 33 +
.../driver/evaluator/EvaluatorDescriptor.java | 47 +
.../reef/driver/evaluator/EvaluatorRequest.java | 171 +++
.../driver/evaluator/EvaluatorRequestor.java | 38 +
.../reef/driver/evaluator/EvaluatorType.java | 38 +
.../reef/driver/evaluator/FailedEvaluator.java | 55 +
.../org/apache/reef/driver/package-info.java | 22 +
.../driver/parameters/ClientCloseHandlers.java | 35 +
.../ClientCloseWithMessageHandlers.java | 35 +
.../parameters/ClientMessageHandlers.java | 35 +
.../parameters/ContextActiveHandlers.java | 36 +
.../parameters/ContextClosedHandlers.java | 36 +
.../parameters/ContextFailedHandlers.java | 36 +
.../parameters/ContextMessageHandlers.java | 36 +
.../driver/parameters/DriverIdentifier.java | 35 +
.../driver/parameters/DriverIdleSources.java | 34 +
.../DriverJobSubmissionDirectory.java | 32 +
.../driver/parameters/DriverLocalFiles.java | 33 +
.../driver/parameters/DriverLocalLibraries.java | 33 +
.../reef/driver/parameters/DriverMemory.java | 31 +
.../DriverRestartCompletedHandlers.java | 36 +
.../DriverRestartContextActiveHandlers.java | 36 +
.../driver/parameters/DriverRestartHandler.java | 31 +
.../DriverRestartTaskRunningHandlers.java | 36 +
.../driver/parameters/DriverStartHandler.java | 33 +
.../parameters/EvaluatorAllocatedHandlers.java | 36 +
.../parameters/EvaluatorCompletedHandlers.java | 36 +
.../parameters/EvaluatorDispatcherThreads.java | 33 +
.../parameters/EvaluatorFailedHandlers.java | 36 +
.../reef/driver/parameters/JobGlobalFiles.java | 33 +
.../driver/parameters/JobGlobalLibraries.java | 33 +
.../ServiceContextActiveHandlers.java | 35 +
.../ServiceContextClosedHandlers.java | 35 +
.../ServiceContextFailedHandlers.java | 35 +
.../ServiceContextMessageHandlers.java | 35 +
.../ServiceDriverRestartCompletedHandlers.java | 35 +
...rviceDriverRestartContextActiveHandlers.java | 35 +
...ServiceDriverRestartTaskRunningHandlers.java | 35 +
.../ServiceEvaluatorAllocatedHandlers.java | 35 +
.../ServiceEvaluatorCompletedHandlers.java | 35 +
.../ServiceEvaluatorFailedHandlers.java | 35 +
.../ServiceTaskCompletedHandlers.java | 35 +
.../parameters/ServiceTaskFailedHandlers.java | 35 +
.../parameters/ServiceTaskMessageHandlers.java | 35 +
.../parameters/ServiceTaskRunningHandlers.java | 35 +
.../ServiceTaskSuspendedHandlers.java | 35 +
.../parameters/TaskCompletedHandlers.java | 36 +
.../driver/parameters/TaskFailedHandlers.java | 36 +
.../driver/parameters/TaskMessageHandlers.java | 36 +
.../driver/parameters/TaskRunningHandlers.java | 36 +
.../parameters/TaskSuspendedHandlers.java | 36 +
.../reef/driver/parameters/package-info.java | 22 +
.../apache/reef/driver/task/CompletedTask.java | 46 +
.../org/apache/reef/driver/task/FailedTask.java | 75 +
.../apache/reef/driver/task/RunningTask.java | 73 +
.../apache/reef/driver/task/SuspendedTask.java | 41 +
.../reef/driver/task/TaskConfiguration.java | 92 ++
.../driver/task/TaskConfigurationOptions.java | 77 +
.../apache/reef/driver/task/TaskMessage.java | 56 +
.../reef/evaluator/context/ContextMessage.java | 69 +
.../context/ContextMessageHandler.java | 39 +
.../evaluator/context/ContextMessageSource.java | 39 +
.../evaluator/context/events/ContextStart.java | 39 +
.../evaluator/context/events/ContextStop.java | 39 +
.../context/parameters/ContextIdentifier.java | 29 +
.../parameters/ContextMessageHandlers.java | 34 +
.../parameters/ContextMessageSources.java | 34 +
.../parameters/ContextStartHandlers.java | 35 +
.../context/parameters/ContextStopHandlers.java | 35 +
.../evaluator/context/parameters/Services.java | 35 +
.../apache/reef/exception/DriverException.java | 65 +
.../reef/exception/EvaluatorException.java | 66 +
...aluatorKilledByResourceManagerException.java | 29 +
.../exception/EvaluatorTimeoutException.java | 44 +
.../exception/evaluator/NetworkException.java | 38 +
.../exception/evaluator/ServiceException.java | 53 +
.../evaluator/ServiceRuntimeException.java | 75 +
.../exception/evaluator/StorageException.java | 36 +
.../reef/exception/evaluator/package-info.java | 23 +
.../org/apache/reef/exception/package-info.java | 22 +
.../java/org/apache/reef/io/Accumulable.java | 39 +
.../java/org/apache/reef/io/Accumulator.java | 45 +
.../java/org/apache/reef/io/ExternalMap.java | 93 ++
.../main/java/org/apache/reef/io/Message.java | 36 +
.../java/org/apache/reef/io/PartitionSpec.java | 49 +
.../src/main/java/org/apache/reef/io/Spool.java | 60 +
.../apache/reef/io/SystemTempFileCreator.java | 66 +
.../org/apache/reef/io/TempFileCreator.java | 65 +
.../src/main/java/org/apache/reef/io/Tuple.java | 67 +
.../io/WorkingDirectoryTempFileCreator.java | 76 +
.../org/apache/reef/io/naming/Identifiable.java | 33 +
.../apache/reef/io/naming/NameAssignment.java | 44 +
.../java/org/apache/reef/io/naming/Naming.java | 26 +
.../org/apache/reef/io/naming/NamingLookup.java | 43 +
.../apache/reef/io/naming/NamingRegistry.java | 46 +
.../java/org/apache/reef/io/package-info.java | 24 +
.../org/apache/reef/io/serialization/Codec.java | 45 +
.../reef/io/serialization/Deserializer.java | 37 +
.../io/serialization/SerializableCodec.java | 67 +
.../reef/io/serialization/Serializer.java | 38 +
.../runtime/common/DriverRestartCompleted.java | 28 +
.../apache/reef/runtime/common/Launcher.java | 156 ++
.../runtime/common/client/ClientWireUp.java | 104 ++
.../client/CommonClientConfigurationModule.java | 28 +
.../runtime/common/client/CompletedJobImpl.java | 46 +
.../common/client/JobStatusMessageHandler.java | 50 +
.../common/client/JobSubmissionHelper.java | 180 +++
.../common/client/REEFImplementation.java | 110 ++
.../runtime/common/client/RunningJobImpl.java | 168 +++
.../reef/runtime/common/client/RunningJobs.java | 55 +
.../runtime/common/client/RunningJobsImpl.java | 148 ++
.../common/client/RuntimeErrorProtoHandler.java | 51 +
.../client/api/ClientRuntimeParameters.java | 29 +
.../common/client/api/JobSubmissionHandler.java | 30 +
.../runtime/common/client/api/package-info.java | 22 +
.../defaults/DefaultCompletedJobHandler.java | 47 +
.../defaults/DefaultFailedJobHandler.java | 43 +
.../defaults/DefaultJobMessageHandler.java | 48 +
.../defaults/DefaultRunningJobHandler.java | 47 +
.../defaults/DefaultRuntimeErrorHandler.java | 52 +
.../common/client/defaults/package-info.java | 22 +
.../runtime/common/client/package-info.java | 22 +
.../common/client/parameters/ClientPresent.java | 33 +
.../common/driver/DriverExceptionHandler.java | 53 +
.../driver/DriverRuntimeConfiguration.java | 73 +
.../DriverRuntimeConfigurationOptions.java | 33 +
.../driver/DriverRuntimeStartHandler.java | 80 ++
.../common/driver/DriverRuntimeStopHandler.java | 71 +
.../runtime/common/driver/DriverSingleton.java | 18 +
.../runtime/common/driver/DriverSingletons.java | 90 ++
.../common/driver/DriverStartHandler.java | 93 ++
.../runtime/common/driver/DriverStatus.java | 30 +
.../common/driver/DriverStatusManager.java | 330 +++++
.../common/driver/EvaluatorRequestorImpl.java | 95 ++
.../api/AbstractDriverRuntimeConfiguration.java | 124 ++
.../api/DefaultResourceManagerLifeCycle.java | 18 +
.../driver/api/ResourceLaunchHandler.java | 30 +
.../driver/api/ResourceManagerLifeCycle.java | 18 +
.../driver/api/ResourceReleaseHandler.java | 30 +
.../driver/api/ResourceRequestHandler.java | 30 +
.../common/driver/api/RuntimeParameters.java | 50 +
.../runtime/common/driver/api/package-info.java | 22 +
.../driver/catalog/NodeDescriptorImpl.java | 78 +
.../driver/catalog/RackDescriptorImpl.java | 78 +
.../driver/catalog/ResourceCatalogImpl.java | 88 ++
.../common/driver/client/ClientConnection.java | 82 ++
.../common/driver/client/ClientManager.java | 148 ++
.../driver/client/JobMessageObserverImpl.java | 44 +
.../driver/client/LoggingJobStatusHandler.java | 42 +
.../common/driver/client/package-info.java | 25 +
.../driver/context/ClosedContextImpl.java | 88 ++
.../driver/context/ContextControlHandler.java | 62 +
.../common/driver/context/ContextFactory.java | 97 ++
.../driver/context/ContextMessageImpl.java | 55 +
.../driver/context/ContextRepresenters.java | 247 ++++
.../common/driver/context/EvaluatorContext.java | 280 ++++
.../driver/context/FailedContextImpl.java | 95 ++
.../common/driver/context/package-info.java | 26 +
.../defaults/DefaultClientCloseHandler.java | 46 +
.../DefaultClientCloseWithMessageHandler.java | 39 +
.../defaults/DefaultClientMessageHandler.java | 42 +
.../defaults/DefaultContextActiveHandler.java | 44 +
.../defaults/DefaultContextClosureHandler.java | 47 +
.../defaults/DefaultContextFailureHandler.java | 44 +
.../defaults/DefaultContextMessageHandler.java | 43 +
.../DefaultDriverRestartCompletedHandler.java | 44 +
...efaultDriverRestartContextActiveHandler.java | 44 +
.../DefaultDriverRestartTaskRunningHandler.java | 43 +
.../DefaultEvaluatorAllocationHandler.java | 44 +
.../DefaultEvaluatorCompletionHandler.java | 43 +
.../DefaultEvaluatorFailureHandler.java | 41 +
.../defaults/DefaultTaskCompletionHandler.java | 47 +
.../defaults/DefaultTaskFailureHandler.java | 39 +
.../defaults/DefaultTaskMessageHandler.java | 43 +
.../defaults/DefaultTaskRunningHandler.java | 43 +
.../defaults/DefaultTaskSuspensionHandler.java | 39 +
.../common/driver/defaults/package-info.java | 22 +
.../evaluator/AllocatedEvaluatorImpl.java | 224 +++
.../evaluator/CompletedEvaluatorImpl.java | 49 +
.../evaluator/EvaluatorControlHandler.java | 100 ++
.../evaluator/EvaluatorDescriptorImpl.java | 75 +
.../EvaluatorHeartBeatSanityChecker.java | 57 +
.../evaluator/EvaluatorHeartbeatHandler.java | 74 +
.../driver/evaluator/EvaluatorManager.java | 529 +++++++
.../evaluator/EvaluatorManagerFactory.java | 105 ++
.../evaluator/EvaluatorMessageDispatcher.java | 247 ++++
.../EvaluatorResourceManagerErrorHandler.java | 67 +
.../common/driver/evaluator/EvaluatorState.java | 38 +
.../evaluator/EvaluatorStatusManager.java | 106 ++
.../common/driver/evaluator/Evaluators.java | 128 ++
.../driver/evaluator/FailedEvaluatorImpl.java | 73 +
.../common/driver/evaluator/package-info.java | 26 +
.../common/driver/idle/ClockIdlenessSource.java | 60 +
.../common/driver/idle/DriverIdleManager.java | 73 +
.../driver/idle/DriverIdlenessSource.java | 31 +
.../driver/idle/EventHandlerIdlenessSource.java | 59 +
.../runtime/common/driver/idle/IdleMessage.java | 61 +
.../common/driver/idle/package-info.java | 22 +
.../runtime/common/driver/package-info.java | 22 +
.../resourcemanager/NodeDescriptorHandler.java | 46 +
.../ResourceAllocationHandler.java | 63 +
.../ResourceManagerErrorHandler.java | 44 +
.../resourcemanager/ResourceManagerStatus.java | 156 ++
.../resourcemanager/ResourceStatusHandler.java | 71 +
.../driver/resourcemanager/package-info.java | 22 +
.../common/driver/task/CompletedTaskImpl.java | 60 +
.../common/driver/task/RunningTaskImpl.java | 138 ++
.../common/driver/task/SuspendedTaskImpl.java | 58 +
.../common/driver/task/TaskMessageImpl.java | 61 +
.../common/driver/task/TaskRepresenter.java | 202 +++
.../common/driver/task/package-info.java | 26 +
.../evaluator/DefaultDriverConnection.java | 48 +
.../common/evaluator/DriverConnection.java | 31 +
.../evaluator/EvaluatorConfiguration.java | 68 +
.../common/evaluator/EvaluatorRuntime.java | 207 +++
.../common/evaluator/HeartBeatManager.java | 173 +++
.../common/evaluator/PIDStoreStartHandler.java | 56 +
.../context/ContextClientCodeException.java | 78 +
.../evaluator/context/ContextLifeCycle.java | 97 ++
.../evaluator/context/ContextManager.java | 374 +++++
.../evaluator/context/ContextRuntime.java | 436 ++++++
.../evaluator/context/ContextStartImpl.java | 37 +
.../evaluator/context/ContextStopImpl.java | 35 +
.../evaluator/context/RootContextLauncher.java | 134 ++
.../defaults/DefaultContextMessageHandler.java | 45 +
.../defaults/DefaultContextMessageSource.java | 44 +
.../defaults/DefaultContextStartHandler.java | 43 +
.../defaults/DefaultContextStopHandler.java | 43 +
.../context/defaults/package-info.java | 22 +
.../common/evaluator/context/package-info.java | 22 +
.../runtime/common/evaluator/package-info.java | 22 +
.../parameters/ApplicationIdentifier.java | 33 +
.../parameters/DriverRemoteIdentifier.java | 31 +
.../parameters/EvaluatorIdentifier.java | 31 +
.../evaluator/parameters/HeartbeatPeriod.java | 31 +
.../parameters/InitialTaskConfiguration.java | 31 +
.../parameters/RootContextConfiguration.java | 31 +
.../parameters/RootServiceConfiguration.java | 31 +
.../common/evaluator/task/CloseEventImpl.java | 45 +
.../evaluator/task/DriverMessageImpl.java | 44 +
.../common/evaluator/task/SuspendEventImpl.java | 45 +
.../evaluator/task/TaskClientCodeException.java | 77 +
.../evaluator/task/TaskLifeCycleHandlers.java | 90 ++
.../common/evaluator/task/TaskRuntime.java | 313 ++++
.../common/evaluator/task/TaskStartImpl.java | 43 +
.../common/evaluator/task/TaskStatus.java | 310 ++++
.../common/evaluator/task/TaskStopImpl.java | 42 +
.../task/defaults/DefaultCloseHandler.java | 41 +
.../defaults/DefaultDriverMessageHandler.java | 41 +
.../task/defaults/DefaultSuspendHandler.java | 41 +
.../evaluator/task/defaults/package-info.java | 22 +
.../task/exceptions/TaskCallFailure.java | 37 +
.../exceptions/TaskCloseHandlerFailure.java | 37 +
.../exceptions/TaskMessageHandlerFailure.java | 37 +
.../exceptions/TaskStartHandlerFailure.java | 39 +
.../task/exceptions/TaskStopHandlerFailure.java | 39 +
.../exceptions/TaskSuspendHandlerFailure.java | 37 +
.../common/evaluator/task/package-info.java | 22 +
.../runtime/common/files/ClasspathProvider.java | 83 ++
.../reef/runtime/common/files/JobJarMaker.java | 136 ++
.../runtime/common/files/REEFFileNames.java | 216 +++
.../common/files/RuntimeClasspathProvider.java | 48 +
.../reef/runtime/common/files/package-info.java | 22 +
.../common/launch/CLRLaunchCommandBuilder.java | 99 ++
.../common/launch/JavaLaunchCommandBuilder.java | 163 +++
.../reef/runtime/common/launch/LaunchClass.java | 191 +++
.../common/launch/LaunchCommandBuilder.java | 66 +
.../common/launch/LauncherSingletons.java | 18 +
.../common/launch/ProfilingStopHandler.java | 58 +
.../runtime/common/launch/REEFErrorHandler.java | 101 ++
.../runtime/common/launch/REEFMessageCodec.java | 96 ++
.../launch/REEFUncaughtExceptionHandler.java | 67 +
.../runtime/common/launch/package-info.java | 22 +
.../parameters/ClockConfigurationPath.java | 30 +
.../launch/parameters/ErrorHandlerRID.java | 37 +
.../common/launch/parameters/LaunchID.java | 27 +
.../common/launch/parameters/package-info.java | 22 +
.../reef/runtime/common/package-info.java | 26 +
.../common/parameters/DeleteTempFiles.java | 31 +
.../runtime/common/parameters/JVMHeapSlack.java | 29 +
.../common/utils/BroadCastEventHandler.java | 44 +
.../common/utils/DefaultExceptionCodec.java | 64 +
.../runtime/common/utils/DispatchingEStage.java | 143 ++
.../runtime/common/utils/ExceptionCodec.java | 50 +
.../runtime/common/utils/RemoteManager.java | 76 +
.../reef/task/HeartBeatTriggerManager.java | 53 +
.../main/java/org/apache/reef/task/Task.java | 48 +
.../java/org/apache/reef/task/TaskMessage.java | 67 +
.../org/apache/reef/task/TaskMessageSource.java | 39 +
.../org/apache/reef/task/events/CloseEvent.java | 38 +
.../apache/reef/task/events/DriverMessage.java | 38 +
.../apache/reef/task/events/SuspendEvent.java | 38 +
.../org/apache/reef/task/events/TaskStart.java | 37 +
.../org/apache/reef/task/events/TaskStop.java | 36 +
.../main/java/org/apache/reef/util/Builder.java | 35 +
.../java/org/apache/reef/util/CommandUtils.java | 55 +
.../org/apache/reef/util/EnvironmentUtils.java | 153 ++
.../util/ExceptionHandlingEventHandler.java | 50 +
.../java/org/apache/reef/util/Exceptions.java | 42 +
.../java/org/apache/reef/util/JARFileMaker.java | 114 ++
.../java/org/apache/reef/util/MemoryUtils.java | 120 ++
.../main/java/org/apache/reef/util/OSUtils.java | 105 ++
.../reef/util/ObjectInstantiationLogger.java | 33 +
.../java/org/apache/reef/util/REEFVersion.java | 84 ++
.../main/java/org/apache/reef/util/SetOnce.java | 51 +
.../org/apache/reef/util/SingletonAsserter.java | 41 +
.../java/org/apache/reef/util/ThreadLogger.java | 94 ++
.../org/apache/reef/util/logging/Config.java | 31 +
.../apache/reef/util/logging/LogLevelName.java | 30 +
.../org/apache/reef/util/logging/LogParser.java | 164 +++
.../apache/reef/util/logging/LoggingScope.java | 29 +
.../reef/util/logging/LoggingScopeFactory.java | 343 +++++
.../reef/util/logging/LoggingScopeImpl.java | 104 ++
.../apache/reef/util/logging/LoggingSetup.java | 37 +
.../reef/util/logging/ThreadLogFormatter.java | 141 ++
.../java/org/apache/reef/util/package-info.java | 22 +
.../src/main/proto/client_runtime.proto | 54 +
.../src/main/proto/driver_runtime.proto | 89 ++
.../src/main/proto/evaluator_runtime.proto | 90 ++
.../src/main/proto/reef_protocol.proto | 42 +
.../src/main/proto/reef_service_protos.proto | 116 ++
.../src/main/resources/log4j.properties | 27 +
.../org/apache/reef/logging.properties | 85 ++
.../src/main/resources/version.properties | 18 +
.../driver/EvaluatorRequestorImplTest.java | 110 ++
.../common/driver/catalog/CatalogTest.java | 54 +
.../org/apache/reef/util/LoggingScopeTest.java | 100 ++
.../apache/reef/util/SingletonAsserterTest.java | 34 +
lang/java/reef-examples-clr/pom.xml | 182 +++
.../apache/reef/examples/helloCLR/HelloCLR.java | 93 ++
.../reef/examples/helloCLR/HelloDriver.java | 183 +++
.../reef/examples/helloCLR/package-info.java | 22 +
.../examples/retained_evalCLR/JobClient.java | 317 ++++
.../examples/retained_evalCLR/JobDriver.java | 489 +++++++
.../reef/examples/retained_evalCLR/Launch.java | 189 +++
.../examples/retained_evalCLR/package-info.java | 22 +
lang/java/reef-examples-hdinsight/pom.xml | 128 ++
.../reef/examples/hello/HelloHDInsight.java | 33 +
lang/java/reef-examples/.gitignore | 1 +
lang/java/reef-examples/pom.xml | 365 +++++
.../examples/data/loading/DataLoadingREEF.java | 128 ++
.../reef/examples/data/loading/LineCounter.java | 126 ++
.../examples/data/loading/LineCountingTask.java | 59 +
.../apache/reef/examples/hello/HelloDriver.java | 84 ++
.../apache/reef/examples/hello/HelloREEF.java | 77 +
.../reef/examples/hello/HelloREEFMesos.java | 55 +
.../reef/examples/hello/HelloREEFNoClient.java | 64 +
.../reef/examples/hello/HelloReefYarn.java | 70 +
.../apache/reef/examples/hello/HelloTask.java | 39 +
.../reef/examples/hello/package-info.java | 22 +
.../reef/examples/hellohttp/HelloREEFHttp.java | 112 ++
.../examples/hellohttp/HelloREEFHttpYarn.java | 52 +
.../hellohttp/HttpServerShellCmdtHandler.java | 168 +++
.../examples/hellohttp/HttpShellJobDriver.java | 364 +++++
.../apache/reef/examples/library/Command.java | 29 +
.../apache/reef/examples/library/ShellTask.java | 73 +
.../apache/reef/examples/pool/JobDriver.java | 306 ++++
.../org/apache/reef/examples/pool/Launch.java | 216 +++
.../apache/reef/examples/pool/SleepTask.java | 73 +
.../apache/reef/examples/pool/package-info.java | 23 +
.../reef/examples/retained_eval/JobClient.java | 335 +++++
.../reef/examples/retained_eval/JobDriver.java | 370 +++++
.../reef/examples/retained_eval/Launch.java | 185 +++
.../examples/retained_eval/package-info.java | 22 +
.../reef/examples/scheduler/Scheduler.java | 226 +++
.../examples/scheduler/SchedulerDriver.java | 339 +++++
.../scheduler/SchedulerHttpHandler.java | 107 ++
.../reef/examples/scheduler/SchedulerREEF.java | 109 ++
.../examples/scheduler/SchedulerREEFYarn.java | 46 +
.../examples/scheduler/SchedulerResponse.java | 114 ++
.../reef/examples/scheduler/TaskEntity.java | 71 +
.../reef/examples/scheduler/package-info.java | 22 +
.../apache/reef/examples/suspend/Control.java | 103 ++
.../apache/reef/examples/suspend/Launch.java | 174 +++
.../examples/suspend/ObjectWritableCodec.java | 93 ++
.../reef/examples/suspend/SuspendClient.java | 172 +++
.../examples/suspend/SuspendClientControl.java | 92 ++
.../reef/examples/suspend/SuspendDriver.java | 340 +++++
.../reef/examples/suspend/SuspendTestTask.java | 179 +++
.../reef/examples/suspend/package-info.java | 22 +
.../utils/wake/BlockingEventHandler.java | 63 +
.../utils/wake/LoggingEventHandler.java | 58 +
.../reef/examples/hello/HelloHttpTest.java | 41 +
.../suspend/ObjectWritableCodecTest.java | 50 +
lang/java/reef-io/pom.xml | 143 ++
.../java/reef-io/src/main/avro/nameservice.avsc | 64 +
.../reef/io/data/loading/api/DataLoader.java | 236 +++
.../api/DataLoadingDriverConfiguration.java | 33 +
.../loading/api/DataLoadingRequestBuilder.java | 190 +++
.../io/data/loading/api/DataLoadingService.java | 68 +
.../reef/io/data/loading/api/DataSet.java | 43 +
.../loading/api/ResourceRequestHandler.java | 64 +
.../impl/EvaluatorRequestSerializer.java | 63 +
.../impl/EvaluatorToPartitionMapper.java | 154 ++
.../impl/InMemoryInputFormatDataSet.java | 53 +
.../data/loading/impl/InputFormatDataSet.java | 156 ++
.../impl/InputFormatExternalConstructor.java | 50 +
.../loading/impl/InputFormatLoadingService.java | 172 +++
.../impl/InputSplitExternalConstructor.java | 57 +
.../impl/JobConfExternalConstructor.java | 88 ++
.../io/data/loading/impl/NumberedSplit.java | 65 +
.../data/loading/impl/WritableSerializer.java | 93 ++
.../java/org/apache/reef/io/network/Cache.java | 53 +
.../org/apache/reef/io/network/Connection.java | 52 +
.../reef/io/network/ConnectionFactory.java | 37 +
.../org/apache/reef/io/network/Message.java | 50 +
.../reef/io/network/TransportFactory.java | 43 +
.../exception/NetworkRuntimeException.java | 54 +
.../network/exception/ParentDeadException.java | 48 +
.../reef/io/network/exception/package-info.java | 19 +
.../reef/io/network/impl/BindNSToTask.java | 45 +
.../network/impl/MessagingTransportFactory.java | 60 +
.../reef/io/network/impl/NSConnection.java | 134 ++
.../apache/reef/io/network/impl/NSMessage.java | 90 ++
.../reef/io/network/impl/NSMessageCodec.java | 134 ++
.../network/impl/NameServiceCloseHandler.java | 49 +
.../reef/io/network/impl/NetworkService.java | 235 +++
.../impl/NetworkServiceClosingHandler.java | 43 +
.../network/impl/NetworkServiceParameters.java | 60 +
.../reef/io/network/impl/StreamingCodec.java | 35 +
.../reef/io/network/impl/UnbindNSFromTask.java | 45 +
.../reef/io/network/impl/package-info.java | 19 +
.../io/network/naming/NameAssignmentTuple.java | 65 +
.../reef/io/network/naming/NameCache.java | 72 +
.../reef/io/network/naming/NameClient.java | 212 +++
.../io/network/naming/NameLookupClient.java | 257 ++++
.../io/network/naming/NameRegistryClient.java | 200 +++
.../reef/io/network/naming/NameServer.java | 88 ++
.../network/naming/NameServerConfiguration.java | 51 +
.../reef/io/network/naming/NameServerImpl.java | 300 ++++
.../io/network/naming/NameServerParameters.java | 40 +
.../io/network/naming/NamingCodecFactory.java | 82 ++
.../naming/exception/NamingException.java | 56 +
.../exception/NamingRuntimeException.java | 56 +
.../network/naming/exception/package-info.java | 19 +
.../reef/io/network/naming/package-info.java | 19 +
.../network/naming/serialization/AvroUtils.java | 68 +
.../serialization/NamingLookupRequest.java | 46 +
.../serialization/NamingLookupRequestCodec.java | 79 +
.../serialization/NamingLookupResponse.java | 48 +
.../NamingLookupResponseCodec.java | 94 ++
.../naming/serialization/NamingMessage.java | 46 +
.../serialization/NamingRegisterRequest.java | 46 +
.../NamingRegisterRequestCodec.java | 76 +
.../serialization/NamingRegisterResponse.java | 44 +
.../NamingRegisterResponseCodec.java | 60 +
.../serialization/NamingUnregisterRequest.java | 46 +
.../NamingUnregisterRequestCodec.java | 72 +
.../naming/serialization/package-info.java | 22 +
.../apache/reef/io/network/package-info.java | 19 +
.../apache/reef/io/network/util/ListCodec.java | 83 ++
.../org/apache/reef/io/network/util/Pair.java | 42 +
.../reef/io/network/util/StringCodec.java | 42 +
.../reef/io/network/util/StringIdentifier.java | 80 ++
.../network/util/StringIdentifierFactory.java | 46 +
.../reef/io/network/util/package-info.java | 19 +
.../reef/io/storage/FramingInputStream.java | 76 +
.../reef/io/storage/FramingOutputStream.java | 134 ++
.../io/storage/FramingTupleDeserializer.java | 100 ++
.../reef/io/storage/FramingTupleSerializer.java | 86 ++
.../apache/reef/io/storage/MergingIterator.java | 62 +
.../apache/reef/io/storage/ScratchSpace.java | 27 +
.../apache/reef/io/storage/StorageService.java | 25 +
.../io/storage/local/CodecFileAccumulable.java | 52 +
.../io/storage/local/CodecFileAccumulator.java | 58 +
.../io/storage/local/CodecFileIterable.java | 53 +
.../io/storage/local/CodecFileIterator.java | 82 ++
.../io/storage/local/LocalScratchSpace.java | 87 ++
.../io/storage/local/LocalStorageService.java | 44 +
.../io/storage/local/SerializerFileSpool.java | 101 ++
.../apache/reef/io/storage/ram/CodecRamMap.java | 84 ++
.../org/apache/reef/io/storage/ram/RamMap.java | 74 +
.../apache/reef/io/storage/ram/RamSpool.java | 72 +
.../reef/io/storage/ram/RamStorageService.java | 38 +
.../reef/io/storage/ram/SortingRamSpool.java | 90 ++
.../reef/io/storage/util/GetAllIterable.java | 95 ++
.../reef/io/storage/util/IntegerCodec.java | 35 +
.../io/storage/util/IntegerDeserializer.java | 62 +
.../reef/io/storage/util/IntegerSerializer.java | 62 +
.../io/storage/util/StringDeserializer.java | 66 +
.../reef/io/storage/util/StringSerializer.java | 65 +
.../io/storage/util/TupleKeyComparator.java | 37 +
.../reef-io/src/main/proto/ns_protocol.proto | 32 +
.../reef/services/network/NameClientTest.java | 123 ++
.../reef/services/network/NamingTest.java | 367 +++++
.../services/network/NetworkServiceTest.java | 495 +++++++
.../apache/reef/services/network/TestEvent.java | 38 +
.../services/network/util/LoggingUtils.java | 43 +
.../reef/services/network/util/Monitor.java | 39 +
.../reef/services/network/util/StringCodec.java | 34 +
.../services/network/util/TimeoutHandler.java | 36 +
.../services/network/util/package-info.java | 19 +
.../reef/services/storage/ExternalMapTest.java | 94 ++
.../reef/services/storage/FramingTest.java | 104 ++
.../services/storage/MergingIteratorTest.java | 54 +
.../reef/services/storage/SortingSpoolTest.java | 117 ++
.../reef/services/storage/SpoolFileTest.java | 206 +++
.../services/storage/TupleSerializerTest.java | 105 ++
lang/java/reef-poison/pom.xml | 52 +
.../org/apache/reef/poison/PoisonException.java | 28 +
.../reef/poison/PoisonedAlarmHandler.java | 33 +
.../reef/poison/PoisonedConfiguration.java | 57 +
.../context/PoisonedContextStartHandler.java | 77 +
.../PoissonPoisonedContextStartHandler.java | 57 +
.../reef/poison/context/package-info.java | 22 +
.../org/apache/reef/poison/package-info.java | 22 +
.../reef/poison/params/CrashProbability.java | 30 +
.../apache/reef/poison/params/CrashTimeout.java | 27 +
.../poison/task/PoisonedTaskStartHandler.java | 77 +
.../task/PoissonPoisonedTaskStartHandler.java | 57 +
.../apache/reef/poison/task/package-info.java | 22 +
lang/java/reef-runtime-hdinsight/pom.xml | 82 ++
.../hdinsight/HDInsightClasspathProvider.java | 73 +
.../reef/runtime/hdinsight/cli/HDICLI.java | 173 +++
.../reef/runtime/hdinsight/cli/LogFetcher.java | 134 ++
.../runtime/hdinsight/cli/LogFileEntry.java | 113 ++
.../reef/runtime/hdinsight/cli/TFileParser.java | 97 ++
.../runtime/hdinsight/cli/package-info.java | 22 +
.../runtime/hdinsight/client/AzureUploader.java | 151 ++
.../client/HDInsightDriverConfiguration.java | 95 ++
.../client/HDInsightJobSubmissionHandler.java | 180 +++
.../client/HDInsightRuntimeConfiguration.java | 123 ++
.../HDInsightRuntimeConfigurationStatic.java | 53 +
.../UnsafeHDInsightRuntimeConfiguration.java | 118 ++
...safeHDInsightRuntimeConfigurationStatic.java | 50 +
.../runtime/hdinsight/client/package-info.java | 22 +
.../sslhacks/DefaultClientConstructor.java | 39 +
.../sslhacks/UnsafeClientConstructor.java | 72 +
.../client/sslhacks/UnsafeHostNameVerifier.java | 50 +
.../client/sslhacks/UnsafeTrustManager.java | 49 +
.../client/yarnrest/ApplicationID.java | 52 +
.../client/yarnrest/ApplicationResponse.java | 44 +
.../client/yarnrest/ApplicationState.java | 214 +++
.../client/yarnrest/ApplicationSubmission.java | 167 +++
.../client/yarnrest/ContainerInfo.java | 125 ++
.../client/yarnrest/EnvironmentEntry.java | 76 +
.../hdinsight/client/yarnrest/FileResource.java | 89 ++
.../client/yarnrest/HDInsightInstance.java | 211 +++
.../client/yarnrest/LocalResourcesEntry.java | 48 +
.../hdinsight/client/yarnrest/Resource.java | 54 +
.../hdinsight/client/yarnrest/package-info.java | 24 +
.../reef/runtime/hdinsight/package-info.java | 22 +
.../AzureStorageAccountContainerName.java | 29 +
.../parameters/AzureStorageAccountKey.java | 29 +
.../parameters/AzureStorageAccountName.java | 29 +
.../parameters/AzureStorageBaseFolder.java | 29 +
.../parameters/HDInsightInstanceURL.java | 29 +
.../hdinsight/parameters/HDInsightPassword.java | 29 +
.../hdinsight/parameters/HDInsightUsername.java | 29 +
lang/java/reef-runtime-local/pom.xml | 62 +
.../runtime/local/LocalClasspathProvider.java | 134 ++
.../reef/runtime/local/client/DriverFiles.java | 174 +++
.../client/ExecutorServiceConstructor.java | 44 +
.../reef/runtime/local/client/FileSet.java | 113 ++
.../local/client/LocalJobSubmissionHandler.java | 166 +++
.../local/client/LocalRuntimeConfiguration.java | 82 ++
.../reef/runtime/local/client/package-info.java | 22 +
.../client/parameters/DefaultMemorySize.java | 29 +
.../client/parameters/DefaultNumberOfCores.java | 29 +
.../client/parameters/NumberOfProcesses.java | 29 +
.../local/client/parameters/RootFolder.java | 30 +
.../local/client/parameters/package-info.java | 22 +
.../reef/runtime/local/driver/Container.java | 85 ++
.../runtime/local/driver/ContainerManager.java | 202 +++
.../reef/runtime/local/driver/IDMaker.java | 47 +
.../local/driver/LocalDriverConfiguration.java | 81 ++
.../driver/LocalDriverRuntimeConfiguration.java | 30 +
.../driver/LocalResourceLaunchHandler.java | 46 +
.../driver/LocalResourceReleaseHandler.java | 47 +
.../driver/LocalResourceRequestHandler.java | 46 +
.../runtime/local/driver/ProcessContainer.java | 178 +++
.../runtime/local/driver/ResourceManager.java | 270 ++++
.../runtime/local/driver/ResourceRequest.java | 63 +
.../local/driver/ResourceRequestQueue.java | 70 +
.../reef/runtime/local/driver/package-info.java | 22 +
.../local/driver/parameters/GlobalFiles.java | 31 +
.../driver/parameters/GlobalLibraries.java | 31 +
.../local/driver/parameters/LocalFiles.java | 31 +
.../local/driver/parameters/LocalLibraries.java | 31 +
.../local/driver/parameters/package-info.java | 22 +
.../process/LoggingRunnableProcessObserver.java | 44 +
.../process/ReefRunnableProcessObserver.java | 125 ++
.../runtime/local/process/RunnableProcess.java | 277 ++++
.../local/process/RunnableProcessObserver.java | 39 +
.../runtime/local/process/package-info.java | 22 +
.../local/driver/ResourceRequestQueueTest.java | 63 +
.../local/driver/ResourceRequestTest.java | 61 +
lang/java/reef-runtime-mesos/pom.xml | 95 ++
.../src/main/avro/EvaluatorControl.avsc | 47 +
.../runtime/mesos/MesosClasspathProvider.java | 92 ++
.../mesos/client/MesosClientConfiguration.java | 68 +
.../mesos/client/MesosJobSubmissionHandler.java | 141 ++
.../mesos/client/parameters/MasterIp.java | 26 +
.../mesos/client/parameters/RootFolder.java | 26 +
.../mesos/driver/MesosDriverConfiguration.java | 98 ++
.../driver/MesosResourceLaunchHandler.java | 129 ++
.../driver/MesosResourceReleaseHandler.java | 42 +
.../driver/MesosResourceRequestHandler.java | 42 +
.../mesos/driver/MesosRuntimeStartHandler.java | 38 +
.../mesos/driver/MesosRuntimeStopHandler.java | 38 +
.../driver/MesosSchedulerDriverExecutor.java | 42 +
.../runtime/mesos/driver/REEFEventHandlers.java | 65 +
.../reef/runtime/mesos/driver/REEFExecutor.java | 50 +
.../runtime/mesos/driver/REEFExecutors.java | 64 +
.../runtime/mesos/driver/REEFScheduler.java | 506 +++++++
.../mesos/driver/parameters/MesosMasterIp.java | 26 +
.../evaluator/EvaluatorControlHandler.java | 55 +
.../runtime/mesos/evaluator/REEFExecutor.java | 249 ++++
.../evaluator/parameters/MesosExecutorId.java | 26 +
.../util/HDFSConfigurationConstructor.java | 35 +
.../runtime/mesos/util/MesosErrorHandler.java | 43 +
.../runtime/mesos/util/MesosRemoteManager.java | 62 +
.../mesos/util/MesosRemoteManagerCodec.java | 68 +
lang/java/reef-runtime-yarn/pom.xml | 80 ++
.../reef/runtime/yarn/ClassPathBuilder.java | 109 ++
.../runtime/yarn/YarnClasspathProvider.java | 140 ++
.../yarn/client/YarnClientConfiguration.java | 73 +
.../yarn/client/YarnJobSubmissionHandler.java | 277 ++++
.../yarn/client/parameters/JobPriority.java | 29 +
.../yarn/client/parameters/JobQueue.java | 29 +
.../driver/ApplicationMasterRegistration.java | 62 +
.../yarn/driver/ContainerRequestCounter.java | 71 +
.../reef/runtime/yarn/driver/Containers.java | 109 ++
.../yarn/driver/DefaultTrackingURLProvider.java | 33 +
.../yarn/driver/EvaluatorSetupHelper.java | 147 ++
.../runtime/yarn/driver/GlobalJarUploader.java | 92 ++
.../runtime/yarn/driver/REEFEventHandlers.java | 91 ++
.../yarn/driver/TrackingURLProvider.java | 29 +
.../yarn/driver/UploaderToJobfolder.java | 94 ++
.../yarn/driver/YARNResourceLaunchHandler.java | 125 ++
.../yarn/driver/YARNResourceReleaseHandler.java | 50 +
.../yarn/driver/YARNRuntimeStartHandler.java | 42 +
.../yarn/driver/YARNRuntimeStopHandler.java | 42 +
.../yarn/driver/YarnContainerManager.java | 680 +++++++++
.../driver/YarnContainerRequestHandler.java | 32 +
.../driver/YarnContainerRequestHandlerImpl.java | 47 +
.../yarn/driver/YarnDriverConfiguration.java | 95 ++
.../yarn/driver/YarnResourceRequestHandler.java | 111 ++
.../reef/runtime/yarn/driver/package-info.java | 22 +
.../parameters/JobSubmissionDirectory.java | 29 +
.../driver/parameters/YarnHeartbeatPeriod.java | 29 +
.../yarn/util/YarnConfigurationConstructor.java | 38 +
.../reef/runtime/yarn/util/YarnTypes.java | 59 +
.../driver/YarnResourceRequestHandlerTest.java | 127 ++
lang/java/reef-tang/.gitattributes | 3 +
lang/java/reef-tang/.gitignore | 15 +
lang/java/reef-tang/README.md | 562 ++++++++
lang/java/reef-tang/doc/tangdoc.png | Bin 0 -> 32351 bytes
lang/java/reef-tang/doc/tooltip.png | Bin 0 -> 9677 bytes
lang/java/reef-tang/pom.xml | 40 +
lang/java/reef-tang/tang-test-jarA/pom.xml | 31 +
.../java/org/apache/reef/tang/examples/A.java | 23 +
lang/java/reef-tang/tang-test-jarAB/pom.xml | 38 +
.../java/org/apache/reef/tang/examples/A.java | 25 +
.../java/org/apache/reef/tang/examples/B.java | 25 +
.../reef-tang/tang-test-jarB-conflictA/pom.xml | 31 +
lang/java/reef-tang/tang-test-jarB/pom.xml | 39 +
.../java/org/apache/reef/tang/examples/B.java | 23 +
lang/java/reef-tang/tang/.gitignore | 2 +
lang/java/reef-tang/tang/maven-eclipse.xml | 28 +
lang/java/reef-tang/tang/pom.xml | 171 +++
.../tang/src/main/avro/configuration.avsc | 37 +
.../main/java/org/apache/reef/tang/Aspect.java | 74 +
.../java/org/apache/reef/tang/BindLocation.java | 38 +
.../org/apache/reef/tang/ClassHierarchy.java | 86 ++
.../org/apache/reef/tang/Configuration.java | 167 +++
.../apache/reef/tang/ConfigurationBuilder.java | 251 ++++
.../org/apache/reef/tang/Configurations.java | 59 +
.../apache/reef/tang/ExternalConstructor.java | 40 +
.../org/apache/reef/tang/InjectionFuture.java | 136 ++
.../java/org/apache/reef/tang/Injector.java | 133 ++
.../apache/reef/tang/JavaClassHierarchy.java | 67 +
.../reef/tang/JavaConfigurationBuilder.java | 98 ++
.../main/java/org/apache/reef/tang/Tang.java | 149 ++
.../tang/annotations/DefaultImplementation.java | 42 +
.../org/apache/reef/tang/annotations/Name.java | 23 +
.../reef/tang/annotations/NamedParameter.java | 40 +
.../apache/reef/tang/annotations/Parameter.java | 31 +
.../org/apache/reef/tang/annotations/Unit.java | 47 +
.../reef/tang/annotations/package-info.java | 23 +
.../reef/tang/examples/PrintTypeHierarchy.java | 105 ++
.../org/apache/reef/tang/examples/Timer.java | 73 +
.../org/apache/reef/tang/examples/TimerV1.java | 66 +
.../apache/reef/tang/examples/package-info.java | 22 +
.../apache/reef/tang/examples/timer/Timer.java | 33 +
.../reef/tang/examples/timer/TimerImpl.java | 42 +
.../reef/tang/examples/timer/TimerMock.java | 66 +
.../reef/tang/examples/timer/package-info.java | 23 +
.../reef/tang/exceptions/BindException.java | 43 +
.../exceptions/ClassHierarchyException.java | 40 +
.../tang/exceptions/InjectionException.java | 44 +
.../exceptions/NameResolutionException.java | 40 +
.../reef/tang/exceptions/ParseException.java | 36 +
.../reef/tang/exceptions/package-info.java | 28 +
.../formats/AvroConfigurationSerializer.java | 313 ++++
.../apache/reef/tang/formats/CommandLine.java | 218 +++
.../reef/tang/formats/ConfigurationFile.java | 253 ++++
.../reef/tang/formats/ConfigurationModule.java | 299 ++++
.../formats/ConfigurationModuleBuilder.java | 385 +++++
.../tang/formats/ConfigurationSerializer.java | 154 ++
.../java/org/apache/reef/tang/formats/Impl.java | 22 +
.../apache/reef/tang/formats/OptionalImpl.java | 22 +
.../reef/tang/formats/OptionalParameter.java | 22 +
.../org/apache/reef/tang/formats/Param.java | 22 +
.../reef/tang/formats/ParameterParser.java | 150 ++
.../org/apache/reef/tang/formats/Provides.java | 22 +
.../apache/reef/tang/formats/RequiredImpl.java | 22 +
.../reef/tang/formats/RequiredParameter.java | 22 +
.../apache/reef/tang/formats/package-info.java | 29 +
.../ConfigurationBuilderImpl.java | 378 +++++
.../tang/implementation/ConfigurationImpl.java | 143 ++
.../reef/tang/implementation/Constructor.java | 186 +++
.../implementation/InjectionFuturePlan.java | 64 +
.../reef/tang/implementation/InjectionPlan.java | 161 +++
.../tang/implementation/ListInjectionPlan.java | 106 ++
.../tang/implementation/SetInjectionPlan.java | 106 ++
.../tang/implementation/StackBindLocation.java | 46 +
.../reef/tang/implementation/Subplan.java | 188 +++
.../reef/tang/implementation/TangImpl.java | 161 +++
.../implementation/java/ClassHierarchyImpl.java | 448 ++++++
.../tang/implementation/java/InjectorImpl.java | 760 ++++++++++
.../java/JavaConfigurationBuilderImpl.java | 238 +++
.../tang/implementation/java/JavaInstance.java | 75 +
.../implementation/java/JavaNodeFactory.java | 333 +++++
.../tang/implementation/java/package-info.java | 29 +
.../reef/tang/implementation/package-info.java | 27 +
.../protobuf/ProtocolBufferClassHierarchy.java | 396 +++++
.../protobuf/ProtocolBufferInjectionPlan.java | 148 ++
.../implementation/protobuf/package-info.java | 25 +
.../tang/implementation/types/AbstractNode.java | 127 ++
.../implementation/types/ClassNodeImpl.java | 141 ++
.../types/ConstructorArgImpl.java | 77 +
.../types/ConstructorDefImpl.java | 150 ++
.../types/NamedParameterNodeImpl.java | 86 ++
.../implementation/types/PackageNodeImpl.java | 43 +
.../tang/implementation/types/package-info.java | 26 +
.../java/org/apache/reef/tang/package-info.java | 27 +
.../org/apache/reef/tang/types/ClassNode.java | 47 +
.../apache/reef/tang/types/ConstructorArg.java | 30 +
.../apache/reef/tang/types/ConstructorDef.java | 29 +
.../reef/tang/types/NamedParameterNode.java | 36 +
.../java/org/apache/reef/tang/types/Node.java | 42 +
.../org/apache/reef/tang/types/PackageNode.java | 23 +
.../org/apache/reef/tang/types/Traversable.java | 26 +
.../apache/reef/tang/types/package-info.java | 26 +
.../tang/util/AbstractMonotonicMultiMap.java | 206 +++
.../apache/reef/tang/util/MonotonicHashMap.java | 58 +
.../apache/reef/tang/util/MonotonicHashSet.java | 91 ++
.../reef/tang/util/MonotonicMultiHashMap.java | 25 +
.../reef/tang/util/MonotonicMultiMap.java | 25 +
.../org/apache/reef/tang/util/MonotonicSet.java | 91 ++
.../apache/reef/tang/util/MonotonicTreeMap.java | 119 ++
.../reef/tang/util/ReflectionUtilities.java | 397 +++++
.../java/org/apache/reef/tang/util/Tint.java | 735 ++++++++++
.../reef/tang/util/TracingMonotonicMap.java | 25 +
.../reef/tang/util/TracingMonotonicTreeMap.java | 146 ++
.../reef/tang/util/ValidateConfiguration.java | 150 ++
.../org/apache/reef/tang/util/package-info.java | 24 +
.../walk/AbstractClassHierarchyNodeVisitor.java | 79 +
.../walk/AbstractInjectionPlanNodeVisitor.java | 80 ++
.../apache/reef/tang/util/walk/EdgeVisitor.java | 35 +
.../apache/reef/tang/util/walk/NodeVisitor.java | 35 +
.../org/apache/reef/tang/util/walk/Walk.java | 66 +
.../walk/graphviz/GraphvizConfigVisitor.java | 244 ++++
.../graphviz/GraphvizInjectionPlanVisitor.java | 168 +++
.../tang/util/walk/graphviz/package-info.java | 22 +
.../reef/tang/util/walk/package-info.java | 22 +
.../reef-tang/tang/src/main/proto/.gitignore | 1 +
.../tang/src/main/proto/class_hierarchy.proto | 167 +++
.../tang/src/main/proto/injection_plan.proto | 38 +
.../tang/ClassHierarchyDeserializationTest.java | 112 ++
.../org/apache/reef/tang/TestBindSingleton.java | 420 ++++++
.../org/apache/reef/tang/TestClassLoaders.java | 118 ++
.../apache/reef/tang/TestConfFileParser.java | 119 ++
.../reef/tang/TestExternalConstructor.java | 89 ++
.../reef/tang/TestImplicitConversions.java | 167 +++
.../apache/reef/tang/TestInjectionFuture.java | 195 +++
.../org/apache/reef/tang/TestListInjection.java | 344 +++++
.../reef/tang/TestNamedParameterRoundTrip.java | 105 ++
.../org/apache/reef/tang/TestSetInjection.java | 181 +++
.../java/org/apache/reef/tang/TestTang.java | 1356 ++++++++++++++++++
.../org/apache/reef/tang/TestTweetExample.java | 120 ++
...onfigurationSerializerAvroRoundtripTest.java | 41 +
...urationSerializerByteArrayRoundtripTest.java | 42 +
...onfigurationSerializerFileRoundtripTest.java | 50 +
...figurationSerializerStringRoundtripTest.java | 40 +
...gurationSerializerTextFileRoundtripTest.java | 50 +
.../tang/formats/ConfigurationFileTest.java | 54 +
.../reef/tang/formats/NamedParameters.java | 38 +
.../reef/tang/formats/TestCommandLine.java | 79 +
.../tang/formats/TestConfigurationModule.java | 445 ++++++
.../tang/implementation/TestClassHierarchy.java | 642 +++++++++
.../java/TestConfigurationBuilder.java | 60 +
.../java/TestParameterParser.java | 245 ++++
.../protobuf/TestClassHierarchyRoundTrip.java | 401 ++++++
.../org/apache/reef/tang/test/AnInterface.java | 29 +
.../tang/test/AnInterfaceImplementation.java | 52 +
.../apache/reef/tang/test/CyclicDependency.java | 56 +
.../tang/test/CyclicDependencyClassOne.java | 50 +
.../tang/test/CyclicDependencyClassTwo.java | 48 +
.../java/org/apache/reef/tang/test/Handler.java | 30 +
.../apache/reef/tang/test/InjectableClass.java | 47 +
.../apache/reef/tang/test/ListInterface.java | 23 +
.../reef/tang/test/ListInterfaceImplOne.java | 55 +
.../reef/tang/test/ListInterfaceImplTwo.java | 55 +
.../apache/reef/tang/test/ListOfBaseTypes.java | 82 ++
.../reef/tang/test/ListOfImplementations.java | 55 +
.../apache/reef/tang/test/ObjectTreeTest.java | 61 +
.../reef/tang/test/RootImplementation.java | 166 +++
.../test/RootImplementationWithoutList.java | 155 ++
.../apache/reef/tang/test/RootInterface.java | 31 +
.../apache/reef/tang/test/RoundTripTest.java | 56 +
.../org/apache/reef/tang/test/SetInterface.java | 27 +
.../reef/tang/test/SetInterfaceImplOne.java | 56 +
.../reef/tang/test/SetInterfaceImplTwo.java | 54 +
.../apache/reef/tang/test/SetOfBaseTypes.java | 85 ++
.../reef/tang/test/SetOfImplementations.java | 55 +
.../reef/tang/test/TestConfiguration.java | 110 ++
.../tang/test/TestConfigurationWithoutList.java | 92 ++
.../org/apache/reef/tang/test/UnitClass.java | 119 ++
.../org/apache/reef/tang/test/package-info.java | 22 +
.../reef-tang/tang/src/test/resources/Event.bin | Bin 0 -> 24188 bytes
.../reef-tang/tang/src/test/resources/Task.bin | Bin 0 -> 128600 bytes
lang/java/reef-tests/pom.xml | 161 +++
.../assembly/test-jar-with-dependencies.xml | 38 +
.../apache/reef/tests/TestDriverLauncher.java | 132 ++
.../tests/driver/DriverTestStartHandler.java | 43 +
.../apache/reef/tests/driver/package-info.java | 22 +
.../EvaluatorReuseTestDriver.java | 118 ++
.../reef/tests/evaluatorreuse/package-info.java | 23 +
.../tests/fail/driver/DriverFailOnFail.java | 98 ++
.../reef/tests/fail/driver/FailClient.java | 65 +
.../reef/tests/fail/driver/FailDriver.java | 371 +++++
.../tests/fail/driver/FailDriverDelayedMsg.java | 128 ++
.../apache/reef/tests/fail/driver/NoopTask.java | 117 ++
.../org/apache/reef/tests/fail/task/Client.java | 57 +
.../org/apache/reef/tests/fail/task/Driver.java | 169 +++
.../apache/reef/tests/fail/task/FailTask.java | 49 +
.../reef/tests/fail/task/FailTaskCall.java | 46 +
.../reef/tests/fail/task/FailTaskClose.java | 65 +
.../reef/tests/fail/task/FailTaskMsg.java | 65 +
.../reef/tests/fail/task/FailTaskStart.java | 65 +
.../reef/tests/fail/task/FailTaskStop.java | 79 +
.../reef/tests/fail/task/FailTaskSuspend.java | 69 +
.../driver/ExpectedTaskFailureHandler.java | 59 +
.../driver/OnDriverStartedAllocateOne.java | 48 +
.../library/exceptions/ClientSideFailure.java | 40 +
.../library/exceptions/DriverSideFailure.java | 42 +
.../exceptions/ExpectedTaskException.java | 43 +
.../exceptions/SimulatedDriverFailure.java | 41 +
.../exceptions/SimulatedTaskFailure.java | 41 +
.../library/exceptions/TaskSideFailure.java | 41 +
.../exceptions/UnexpectedTaskReturnValue.java | 40 +
.../apache/reef/tests/library/package-info.java | 22 +
.../reef/tests/library/tasks/EchoTask.java | 38 +
.../reef/tests/library/tasks/NoopTask.java | 38 +
.../tests/messaging/driver/DriverMessaging.java | 173 +++
.../messaging/driver/DriverMessagingDriver.java | 87 ++
.../messaging/task/TaskMessagingDriver.java | 98 ++
.../tests/messaging/task/TaskMessagingTask.java | 83 ++
.../apache/reef/tests/statepassing/Counter.java | 38 +
.../tests/statepassing/StatePassingDriver.java | 126 ++
.../tests/statepassing/StatePassingTask.java | 50 +
.../reef/tests/yarn/failure/FailureDriver.java | 109 ++
.../reef/tests/yarn/failure/FailureREEF.java | 120 ++
.../org/apache/reef/tests/AllTestsSuite.java | 54 +
.../java/org/apache/reef/tests/FailureTest.java | 54 +
.../apache/reef/tests/LocalTestEnvironment.java | 68 +
.../apache/reef/tests/MesosTestEnvironment.java | 68 +
.../apache/reef/tests/ProbabilisticTests.java | 33 +
.../org/apache/reef/tests/TestEnvironment.java | 58 +
.../apache/reef/tests/TestEnvironmentBase.java | 39 +
.../reef/tests/TestEnvironmentFactory.java | 54 +
.../java/org/apache/reef/tests/TestUtils.java | 63 +
.../apache/reef/tests/YarnTestEnvironment.java | 60 +
.../tests/close_eval/CloseEvaluatorDriver.java | 65 +
.../tests/close_eval/CloseEvaluatorTest.java | 68 +
.../apache/reef/tests/driver/DriverTest.java | 68 +
.../tests/evaluatorexit/EvaluatorExitTest.java | 66 +
.../evaluatorexit/EvaluatorExitTestDriver.java | 79 +
.../evaluatorexit/EvaluatorExitTestTask.java | 39 +
.../reef/tests/evaluatorexit/package-info.java | 22 +
.../EvaluatorFailureDuringAlarmDriver.java | 106 ++
.../evaluatorfailure/EvaluatorFailureTest.java | 75 +
.../evaluatorfailure/ExpectedException.java | 25 +
.../FailureSchedulingContextStartHandler.java | 52 +
.../tests/evaluatorfailure/package-info.java | 22 +
.../evaluatorreuse/EvaluatorReuseTest.java | 72 +
.../tests/evaluatorsize/EvaluatorSizeTest.java | 79 +
.../EvaluatorSizeTestConfiguration.java | 38 +
.../evaluatorsize/EvaluatorSizeTestDriver.java | 97 ++
.../tests/evaluatorsize/MemorySizeTask.java | 49 +
.../reef/tests/evaluatorsize/package-info.java | 22 +
.../reef/tests/examples/ExamplesTestSuite.java | 33 +
.../reef/tests/examples/TestHelloREEF.java | 61 +
.../tests/examples/TestRetainedEvaluators.java | 81 ++
.../reef/tests/examples/package-info.java | 22 +
.../reef/tests/fail/DriverFailOnFailTest.java | 71 +
.../tests/fail/FailDriverDelayedMsgTest.java | 73 +
.../apache/reef/tests/fail/FailDriverTest.java | 133 ++
.../apache/reef/tests/fail/FailTaskTest.java | 93 ++
.../apache/reef/tests/fail/FailTestSuite.java | 32 +
.../reef/tests/files/FileResourceTest.java | 144 ++
.../tests/files/FileResourceTestDriver.java | 127 ++
.../FileResourceTestDriverConfiguration.java | 40 +
.../reef/tests/files/FileResourceTestTask.java | 67 +
.../FileResourceTestTaskConfiguration.java | 44 +
.../apache/reef/tests/files/package-info.java | 22 +
.../messaging/driver/DriverMessagingTest.java | 51 +
.../tests/messaging/driver/package-info.java | 22 +
.../tests/messaging/task/TaskMessagingTest.java | 72 +
.../reef/tests/messaging/task/package-info.java | 22 +
.../ActiveContextHandler.java | 63 +
.../AllocatedEvaluatorHandler.java | 60 +
.../multipleEventHandlerInstances/Client.java | 76 +
.../ClosedContextHandler.java | 51 +
.../CompletedEvaluatorHandler.java | 52 +
.../CompletedTaskHandler.java | 51 +
.../EmptyTask.java | 39 +
.../RunningTaskHandler.java | 51 +
.../StartHandler.java | 62 +
.../tests/roguethread/RogueThreadDriver.java | 50 +
.../reef/tests/roguethread/RogueThreadTask.java | 44 +
.../reef/tests/roguethread/RogueThreadTest.java | 70 +
.../reef/tests/roguethread/package-info.java | 22 +
.../tests/statepassing/StatePassingTest.java | 71 +
.../reef/tests/statepassing/package-info.java | 22 +
.../tests/subcontexts/ContextStartHandler1.java | 39 +
.../tests/subcontexts/ContextStartHandler2.java | 38 +
.../tests/subcontexts/ContextStopHandler1.java | 38 +
.../tests/subcontexts/ContextStopHandler2.java | 38 +
.../tests/subcontexts/SubContextDriver.java | 143 ++
.../reef/tests/subcontexts/SubContextTest.java | 93 ++
.../reef/tests/subcontexts/package-info.java | 22 +
.../tests/taskcounting/TaskCountingDriver.java | 109 ++
.../tests/taskcounting/TaskCountingTest.java | 70 +
.../reef/tests/taskcounting/package-info.java | 22 +
.../tests/taskresubmit/TaskResubmitDriver.java | 85 ++
.../tests/taskresubmit/TaskResubmitTest.java | 72 +
.../reef/tests/taskresubmit/package-info.java | 22 +
lang/java/reef-utils-hadoop/pom.xml | 45 +
.../org/apache/reef/util/HadoopEnvironment.java | 37 +
.../apache/reef/util/logging/DFSHandler.java | 146 ++
lang/java/reef-utils/pom.xml | 45 +
.../java/org/apache/reef/util/Optional.java | 128 ++
.../java/org/apache/reef/util/package-info.java | 22 +
.../java/org/apache/reef/util/OptionalTest.java | 99 ++
lang/java/reef-wake/.gitattributes | 3 +
lang/java/reef-wake/.gitignore | 16 +
lang/java/reef-wake/README.md | 94 ++
lang/java/reef-wake/pom.xml | 38 +
lang/java/reef-wake/wake/pom.xml | 123 ++
.../org/apache/reef/wake/AbstractEStage.java | 91 ++
.../apache/reef/wake/ComparableIdentifier.java | 27 +
.../main/java/org/apache/reef/wake/EStage.java | 27 +
.../java/org/apache/reef/wake/EventHandler.java | 34 +
.../java/org/apache/reef/wake/Identifiable.java | 30 +
.../java/org/apache/reef/wake/Identifier.java | 54 +
.../org/apache/reef/wake/IdentifierFactory.java | 31 +
.../org/apache/reef/wake/IdentifierParser.java | 55 +
.../main/java/org/apache/reef/wake/Stage.java | 25 +
.../apache/reef/wake/StageConfiguration.java | 68 +
.../org/apache/reef/wake/WakeConfiguration.java | 62 +
.../org/apache/reef/wake/WakeParameters.java | 46 +
.../wake/examples/accumulate/CombinerStage.java | 161 +++
.../reef/wake/examples/join/BlockingJoin.java | 95 ++
.../reef/wake/examples/join/EventPrinter.java | 39 +
.../wake/examples/join/NonBlockingJoin.java | 121 ++
.../reef/wake/examples/join/TupleEvent.java | 45 +
.../reef/wake/examples/join/TupleSource.java | 58 +
.../reef/wake/examples/join/package-info.java | 22 +
.../reef/wake/examples/p2p/EventSource.java | 33 +
.../reef/wake/examples/p2p/Pull2Push.java | 94 ++
.../reef/wake/examples/p2p/package-info.java | 22 +
.../apache/reef/wake/examples/package-info.java | 22 +
.../wake/exception/WakeRuntimeException.java | 56 +
.../reef/wake/exception/package-info.java | 22 +
.../reef/wake/impl/BlockingEventHandler.java | 79 +
.../wake/impl/BlockingSignalEventHandler.java | 56 +
.../wake/impl/DefaultIdentifierFactory.java | 90 ++
.../reef/wake/impl/DefaultThreadFactory.java | 85 ++
.../apache/reef/wake/impl/ForkPoolStage.java | 103 ++
.../IndependentIterationsThreadPoolStage.java | 80 ++
.../reef/wake/impl/LoggingEventHandler.java | 49 +
.../org/apache/reef/wake/impl/LoggingUtils.java | 52 +
.../reef/wake/impl/LoggingVoidEventHandler.java | 47 +
.../reef/wake/impl/MergingEventHandler.java | 152 ++
.../wake/impl/MissingStartHandlerHandler.java | 43 +
.../reef/wake/impl/MultiEventHandler.java | 60 +
.../reef/wake/impl/OpaqueLocalIdentifier.java | 28 +
.../apache/reef/wake/impl/PeriodicEvent.java | 25 +
.../reef/wake/impl/PubSubEventHandler.java | 105 ++
.../reef/wake/impl/SingleThreadStage.java | 144 ++
.../org/apache/reef/wake/impl/StageManager.java | 78 +
.../org/apache/reef/wake/impl/SyncStage.java | 113 ++
.../apache/reef/wake/impl/ThreadPoolStage.java | 223 +++
.../org/apache/reef/wake/impl/TimerStage.java | 135 ++
.../apache/reef/wake/impl/WakeSharedPool.java | 108 ++
.../wake/impl/WakeUncaughtExceptionHandler.java | 46 +
.../org/apache/reef/wake/impl/package-info.java | 22 +
.../java/org/apache/reef/wake/metrics/EWMA.java | 79 +
.../reef/wake/metrics/EWMAParameters.java | 35 +
.../org/apache/reef/wake/metrics/Histogram.java | 55 +
.../org/apache/reef/wake/metrics/Meter.java | 147 ++
.../reef/wake/metrics/UniformHistogram.java | 90 ++
.../apache/reef/wake/metrics/package-info.java | 22 +
.../java/org/apache/reef/wake/package-info.java | 22 +
.../org/apache/reef/wake/profiler/Vertex.java | 100 ++
.../apache/reef/wake/profiler/WakeProfiler.java | 321 +++++
.../java/org/apache/reef/wake/remote/Codec.java | 28 +
.../org/apache/reef/wake/remote/Decoder.java | 36 +
.../reef/wake/remote/DefaultErrorHandler.java | 38 +
.../org/apache/reef/wake/remote/Encoder.java | 36 +
.../org/apache/reef/wake/remote/NetUtils.java | 106 ++
.../reef/wake/remote/RemoteConfiguration.java | 71 +
.../reef/wake/remote/RemoteIdentifier.java | 27 +
.../wake/remote/RemoteIdentifierFactory.java | 41 +
.../apache/reef/wake/remote/RemoteManager.java | 91 ++
.../apache/reef/wake/remote/RemoteMessage.java | 42 +
.../exception/RemoteRuntimeException.java | 54 +
.../wake/remote/exception/package-info.java | 22 +
.../apache/reef/wake/remote/impl/ByteCodec.java | 50 +
.../wake/remote/impl/ConnectFutureTask.java | 40 +
...ltRemoteIdentifierFactoryImplementation.java | 47 +
.../DefaultRemoteManagerImplementation.java | 229 +++
.../wake/remote/impl/DefaultRemoteMessage.java | 65 +
.../reef/wake/remote/impl/HandlerContainer.java | 154 ++
.../reef/wake/remote/impl/MultiCodec.java | 75 +
.../reef/wake/remote/impl/MultiDecoder.java | 72 +
.../reef/wake/remote/impl/MultiEncoder.java | 64 +
.../remote/impl/ObjectSerializableCodec.java | 72 +
.../remote/impl/OrderedRemoteReceiverStage.java | 201 +++
.../wake/remote/impl/ProxyEventHandler.java | 89 ++
.../reef/wake/remote/impl/RemoteEvent.java | 170 +++
.../reef/wake/remote/impl/RemoteEventCodec.java | 65 +
.../wake/remote/impl/RemoteEventComparator.java | 37 +
.../wake/remote/impl/RemoteEventDecoder.java | 62 +
.../wake/remote/impl/RemoteEventEncoder.java | 68 +
.../remote/impl/RemoteReceiverEventHandler.java | 61 +
.../wake/remote/impl/RemoteReceiverStage.java | 99 ++
.../remote/impl/RemoteSenderEventHandler.java | 165 +++
.../wake/remote/impl/RemoteSenderStage.java | 91 ++
.../wake/remote/impl/RemoteSeqNumGenerator.java | 49 +
.../remote/impl/SocketRemoteIdentifier.java | 111 ++
.../reef/wake/remote/impl/StringCodec.java | 50 +
.../reef/wake/remote/impl/Subscription.java | 61 +
.../reef/wake/remote/impl/TransportEvent.java | 106 ++
.../apache/reef/wake/remote/impl/Tuple2.java | 59 +
.../reef/wake/remote/impl/package-info.java | 22 +
.../apache/reef/wake/remote/package-info.java | 22 +
.../apache/reef/wake/remote/transport/Link.java | 52 +
.../wake/remote/transport/LinkListener.java | 34 +
.../reef/wake/remote/transport/Transport.java | 77 +
.../exception/TransportRuntimeException.java | 54 +
.../transport/exception/package-info.java | 22 +
.../netty/AbstractNettyEventListener.java | 99 ++
.../remote/transport/netty/ByteEncoder.java | 36 +
.../netty/ChunkedReadWriteHandler.java | 191 +++
.../remote/transport/netty/LinkReference.java | 48 +
.../transport/netty/LoggingLinkListener.java | 46 +
.../transport/netty/NettyChannelHandler.java | 114 ++
.../netty/NettyChannelHandlerFactory.java | 35 +
.../netty/NettyChannelInitializer.java | 52 +
.../netty/NettyClientEventListener.java | 56 +
.../NettyDefaultChannelHandlerFactory.java | 49 +
.../transport/netty/NettyEventListener.java | 57 +
.../wake/remote/transport/netty/NettyLink.java | 117 ++
.../netty/NettyMessagingTransport.java | 329 +++++
.../netty/NettyServerEventListener.java | 65 +
.../remote/transport/netty/package-info.java | 22 +
.../wake/remote/transport/package-info.java | 22 +
.../apache/reef/wake/rx/AbstractObserver.java | 43 +
.../apache/reef/wake/rx/AbstractRxStage.java | 86 ++
.../apache/reef/wake/rx/DynamicObservable.java | 36 +
.../org/apache/reef/wake/rx/Observable.java | 25 +
.../java/org/apache/reef/wake/rx/Observer.java | 50 +
.../java/org/apache/reef/wake/rx/RxStage.java | 29 +
.../apache/reef/wake/rx/StaticObservable.java | 26 +
.../java/org/apache/reef/wake/rx/Subject.java | 29 +
.../exception/ObserverCompletedException.java | 38 +
.../reef/wake/rx/exception/package-info.java | 22 +
.../apache/reef/wake/rx/impl/RxSyncStage.java | 104 ++
.../reef/wake/rx/impl/RxThreadPoolStage.java | 198 +++
.../apache/reef/wake/rx/impl/SimpleSubject.java | 73 +
.../reef/wake/rx/impl/TimeoutSubject.java | 84 ++
.../apache/reef/wake/rx/impl/package-info.java | 22 +
.../org/apache/reef/wake/rx/package-info.java | 22 +
.../reef/wake/storage/FileHandlePool.java | 31 +
.../reef/wake/storage/FileIdentifier.java | 49 +
.../apache/reef/wake/storage/ReadRequest.java | 41 +
.../apache/reef/wake/storage/ReadResponse.java | 33 +
.../reef/wake/storage/SequentialFileReader.java | 61 +
.../reef/wake/storage/StorageIdentifier.java | 25 +
.../java/org/apache/reef/wake/time/Clock.java | 107 ++
.../java/org/apache/reef/wake/time/Time.java | 62 +
.../org/apache/reef/wake/time/event/Alarm.java | 40 +
.../apache/reef/wake/time/event/StartTime.java | 32 +
.../apache/reef/wake/time/event/StopTime.java | 32 +
.../reef/wake/time/event/package-info.java | 22 +
.../org/apache/reef/wake/time/package-info.java | 22 +
.../reef/wake/time/runtime/LogicalTimer.java | 48 +
.../reef/wake/time/runtime/RealTimer.java | 43 +
.../reef/wake/time/runtime/RuntimeClock.java | 244 ++++
.../apache/reef/wake/time/runtime/Timer.java | 30 +
.../wake/time/runtime/event/ClientAlarm.java | 29 +
.../reef/wake/time/runtime/event/IdleClock.java | 28 +
.../wake/time/runtime/event/RuntimeAlarm.java | 30 +
.../wake/time/runtime/event/RuntimeStart.java | 29 +
.../wake/time/runtime/event/RuntimeStop.java | 40 +
.../wake/time/runtime/event/package-info.java | 22 +
.../reef/wake/time/runtime/package-info.java | 22 +
.../wake/src/main/proto/RemoteProtocol.proto | 35 +
.../com/microsoft/wake/logging.properties | 81 ++
.../wake/test/BlockingEventHandlerTest.java | 196 +++
.../test/BlockingSignalEventHandlerTest.java | 166 +++
.../reef/wake/test/ForkPoolStageTest.java | 226 +++
...ndependentIterationsThreadPoolStageTest.java | 84 ++
.../reef/wake/test/MergingEventHandlerTest.java | 237 +++
.../org/apache/reef/wake/test/MetricsTest.java | 52 +
.../wake/test/PubSubThreadPoolStageTest.java | 115 ++
.../apache/reef/wake/test/StageManagerTest.java | 48 +
.../apache/reef/wake/test/SyncStageTest.java | 130 ++
.../reef/wake/test/ThreadPoolStageTest.java | 221 +++
.../apache/reef/wake/test/TimerStageTest.java | 82 ++
.../reef/wake/test/examples/SkipListTest.java | 378 +++++
.../wake/test/examples/TestBlockingJoin.java | 39 +
.../reef/wake/test/examples/TestCombiner.java | 129 ++
.../reef/wake/test/examples/TestJoin.java | 38 +
.../wake/test/examples/TestTupleSource.java | 34 +
.../org/apache/reef/wake/test/package-info.java | 22 +
.../reef/wake/test/remote/LargeMsgTest.java | 141 ++
.../remote/RemoteIdentifierFactoryTest.java | 86 ++
.../wake/test/remote/RemoteManagerTest.java | 462 ++++++
.../reef/wake/test/remote/RemoteTest.java | 211 +++
.../wake/test/remote/SmallMessagesTest.java | 161 +++
.../reef/wake/test/remote/StartEvent.java | 25 +
.../apache/reef/wake/test/remote/TestEvent.java | 47 +
.../reef/wake/test/remote/TestEvent1.java | 29 +
.../reef/wake/test/remote/TestEvent2.java | 30 +
.../reef/wake/test/remote/TestEventCodec.java | 52 +
.../reef/wake/test/remote/TestRemote.java | 68 +
.../wake/test/remote/TestRemoteIdentifier.java | 48 +
.../wake/test/remote/TransportRaceTest.java | 104 ++
.../reef/wake/test/remote/TransportTest.java | 144 ++
.../reef/wake/test/remote/package-info.java | 22 +
.../org/apache/reef/wake/test/rx/RxTest.java | 90 ++
.../wake/test/rx/RxThreadPoolStageTest.java | 194 +++
.../reef/wake/test/rx/TimeoutSubjectTest.java | 143 ++
.../apache/reef/wake/test/rx/package-info.java | 22 +
.../apache/reef/wake/test/time/ClockTest.java | 205 +++
.../reef/wake/test/time/package-info.java | 22 +
.../org/apache/reef/wake/test/util/Monitor.java | 41 +
.../reef/wake/test/util/PassThroughEncoder.java | 36 +
.../reef/wake/test/util/TimeoutHandler.java | 36 +
.../reef/wake/test/util/package-info.java | 22 +
.../wake/src/test/proto/TestEvent1.proto | 28 +
.../wake/src/test/proto/TestProtocol.proto | 28 +
lang/java/reef-webserver/pom.xml | 107 ++
.../src/main/avro/DriverInfo.avsc | 43 +
.../src/main/avro/EvaluatorInfo.avsc | 45 +
.../src/main/avro/EvaluatorList.avsc | 43 +
.../src/main/avro/webRequest.avsc | 29 +
.../webserver/AvroDriverInfoSerializer.java | 68 +
.../webserver/AvroEvaluatorInfoSerializer.java | 101 ++
.../webserver/AvroEvaluatorListSerializer.java | 85 ++
.../reef/webserver/AvroHttpSerializer.java | 108 ++
.../reef/webserver/DriverInfoSerializer.java | 46 +
.../reef/webserver/EvaluatorInfoSerializer.java | 40 +
.../reef/webserver/EvaluatorListSerializer.java | 48 +
.../reef/webserver/HttpEventHandlers.java | 31 +
.../org/apache/reef/webserver/HttpHandler.java | 50 +
.../webserver/HttpHandlerConfiguration.java | 43 +
.../webserver/HttpRuntimeConfiguration.java | 37 +
.../reef/webserver/HttpRuntimeStartHandler.java | 68 +
.../reef/webserver/HttpRuntimeStopHandler.java | 67 +
.../org/apache/reef/webserver/HttpServer.java | 55 +
.../apache/reef/webserver/HttpServerImpl.java | 149 ++
.../webserver/HttpServerReefEventHandler.java | 388 +++++
.../reef/webserver/HttpTrackingURLProvider.java | 67 +
.../org/apache/reef/webserver/JettyHandler.java | 159 ++
.../apache/reef/webserver/MaxPortNumber.java | 29 +
.../apache/reef/webserver/MaxRetryAttempts.java | 29 +
.../apache/reef/webserver/MinPortNumber.java | 29 +
.../reef/webserver/ParsedHttpRequest.java | 194 +++
.../org/apache/reef/webserver/PortNumber.java | 31 +
.../reef/webserver/ReefEventStateManager.java | 308 ++++
.../reef/webserver/TestAvroHttpSerializer.java | 153 ++
.../webserver/TestAvroSerializerForHttp.java | 179 +++
.../reef/webserver/TestHttpConfiguration.java | 204 +++
.../apache/reef/webserver/TestHttpServer.java | 169 +++
.../apache/reef/webserver/TestJettyHandler.java | 166 +++
.../reef/webserver/TestParsedHttpRequest.java | 101 ++
.../reef/webserver/TestReefEventHandler.java | 84 ++
.../webserver/TestReefEventStateManager.java | 146 ++
.../reef/webserver/TestRuntimeStartHandler.java | 104 ++
.../apache/reef/webserver/TestTrackingUri.java | 113 ++
pom.xml | 656 ---------
reef-annotations/pom.xml | 31 -
.../org/apache/reef/annotations/Optional.java | 26 -
.../org/apache/reef/annotations/Provided.java | 26 -
.../org/apache/reef/annotations/Unstable.java | 25 -
.../reef/annotations/audience/ClientSide.java | 26 -
.../reef/annotations/audience/DriverSide.java | 26 -
.../annotations/audience/EvaluatorSide.java | 25 -
.../reef/annotations/audience/Private.java | 26 -
.../reef/annotations/audience/Public.java | 26 -
.../annotations/audience/RuntimeAuthor.java | 26 -
.../reef/annotations/audience/TaskSide.java | 26 -
.../reef/annotations/audience/package-info.java | 22 -
.../apache/reef/annotations/package-info.java | 22 -
.../reef/annotations/semantics/Idempotent.java | 25 -
reef-bridge-project/.gitignore | 34 -
reef-bridge-project/pom.xml | 101 --
reef-bridge-project/reef-bridge-clr/pom.xml | 162 ---
.../CSharp/CSharp/ClrHandler/ClrHandler.csproj | 66 -
.../ClrHandler/Properties/AssemblyInfo.cs | 49 -
.../externals/Microsoft.Reef.Driver.dll | Bin 123392 -> 0 bytes
.../CSharp/ClrHandler/externals/msvcr110.dll | Bin 849360 -> 0 bytes
.../ClrHandler/interface/IInteropReturnInfo.cs | 30 -
.../CSharp/ClrHandler/interface/ILogger.cs | 37 -
.../JavaClrBridge/ActiveContextClr2Java.cpp | 106 --
.../AllocatedEvaluatorClr2Java.cpp | 164 ---
.../CppBridge/JavaClrBridge/AssemblyInfo.cpp | 50 -
.../CppBridge/JavaClrBridge/AssemblyUtil.cpp | 53 -
.../Cpp/CppBridge/JavaClrBridge/BinaryUtil.cpp | 102 --
.../Cpp/CppBridge/JavaClrBridge/BinaryUtil.h | 26 -
.../JavaClrBridge/ClosedContextClr2Java.cpp | 86 --
.../CppBridge/JavaClrBridge/Clr2JavaImpl.cpp | 44 -
.../Cpp/CppBridge/JavaClrBridge/Clr2JavaImpl.h | 220 ---
.../CppBridge/JavaClrBridge/CommonUtilities.cpp | 51 -
.../CompletedEvaluatorClr2Java.cpp | 58 -
.../JavaClrBridge/CompletedTaskClr2Java.cpp | 69 -
.../JavaClrBridge/ContextMessageClr2Java.cpp | 76 -
.../EvaluatorRequestorClr2Java.cpp | 69 -
.../JavaClrBridge/FailedContextClr2Java.cpp | 94 --
.../JavaClrBridge/FailedEvaluatorClr2Java.cpp | 72 -
.../JavaClrBridge/FailedTaskClr2Java.cpp | 79 -
.../JavaClrBridge/HttpServerClr2Java.cpp | 135 --
.../CppBridge/JavaClrBridge/InteropAssemblies.h | 40 -
.../CppBridge/JavaClrBridge/InteropLogger.cpp | 50 -
.../Cpp/CppBridge/JavaClrBridge/InteropLogger.h | 47 -
.../JavaClrBridge/InteropReturnInfo.cpp | 91 --
.../CppBridge/JavaClrBridge/InteropReturnInfo.h | 57 -
.../Cpp/CppBridge/JavaClrBridge/InteropUtil.cpp | 129 --
.../Cpp/CppBridge/JavaClrBridge/InteropUtil.h | 65 -
.../CppBridge/JavaClrBridge/JavaClrBridge.cpp | 492 -------
.../Cpp/CppBridge/JavaClrBridge/JavaClrBridge.h | 33 -
.../CppBridge/JavaClrBridge/JavaClrBridge.sln | 56 -
.../JavaClrBridge/JavaClrBridge.vcxproj | 173 ---
.../JavaClrBridge/JavaClrBridge.vcxproj.filters | 104 --
.../CppBridge/JavaClrBridge/ManagedLogger.cpp | 47 -
.../main/Cpp/CppBridge/JavaClrBridge/ReadMe.txt | 57 -
.../JavaClrBridge/RunningTaskClr2Java.cpp | 90 --
.../JavaClrBridge/SuspendedTaskClr2Java.cpp | 83 --
.../JavaClrBridge/TaskMessageClr2Java.cpp | 58 -
reef-bridge-project/reef-bridge-java/pom.xml | 116 --
.../reef/javabridge/ActiveContextBridge.java | 80 --
.../javabridge/AllocatedEvaluatorBridge.java | 141 --
.../reef/javabridge/ClosedContextBridge.java | 81 --
.../javabridge/CompletedEvaluatorBridge.java | 43 -
.../reef/javabridge/CompletedTaskBridge.java | 40 -
.../reef/javabridge/ContextMessageBridge.java | 56 -
.../javabridge/EvaluatorRequestorBridge.java | 76 -
.../reef/javabridge/FailedContextBridge.java | 83 --
.../reef/javabridge/FailedEvaluatorBridge.java | 47 -
.../reef/javabridge/FailedTaskBridge.java | 60 -
.../reef/javabridge/HttpServerEventBridge.java | 79 -
.../apache/reef/javabridge/InteropLogger.java | 55 -
.../reef/javabridge/InteropReturnInfo.java | 52 -
.../org/apache/reef/javabridge/JavaBridge.java | 31 -
.../org/apache/reef/javabridge/LibLoader.java | 154 --
.../apache/reef/javabridge/NativeBridge.java | 32 -
.../apache/reef/javabridge/NativeInterop.java | 166 ---
.../reef/javabridge/RunningTaskBridge.java | 49 -
.../reef/javabridge/SuspendedTaskBridge.java | 54 -
.../reef/javabridge/TaskMessageBridge.java | 36 -
.../org/apache/reef/javabridge/Utilities.java | 57 -
.../reef/javabridge/generic/JobClient.java | 322 -----
.../reef/javabridge/generic/JobDriver.java | 724 ----------
.../apache/reef/javabridge/generic/Launch.java | 236 ---
.../reef/javabridge/generic/LaunchHeadless.java | 100 --
.../reef/javabridge/generic/package-info.java | 22 -
.../util/logging/CLRBufferedLogHandler.java | 167 ---
.../reef/util/logging/CLRLoggingConfig.java | 31 -
.../apache/reef/util/logging/package-info.java | 22 -
.../org/apache/reef/clr.logging.properties | 82 --
reef-bridge-project/reef-bridge/pom.xml | 111 --
reef-checkpoint/maven-eclipse.xml | 28 -
reef-checkpoint/pom.xml | 68 -
.../apache/reef/io/checkpoint/CheckpointID.java | 31 -
.../io/checkpoint/CheckpointNamingService.java | 33 -
.../reef/io/checkpoint/CheckpointService.java | 100 --
.../reef/io/checkpoint/RandomNameCNS.java | 49 -
.../reef/io/checkpoint/SimpleNamingService.java | 55 -
.../fs/FSCheckPointServiceConfiguration.java | 110 --
.../reef/io/checkpoint/fs/FSCheckpointID.java | 74 -
.../io/checkpoint/fs/FSCheckpointService.java | 221 ---
reef-common/maven-eclipse.xml | 28 -
reef-common/pom.xml | 142 --
reef-common/src/main/conf/log4j.properties | 40 -
reef-common/src/main/conf/reef-site.xml | 21 -
.../apache/reef/client/ClientConfiguration.java | 83 --
.../org/apache/reef/client/CompletedJob.java | 39 -
.../apache/reef/client/DriverConfiguration.java | 253 ----
.../org/apache/reef/client/DriverLauncher.java | 220 ---
.../reef/client/DriverServiceConfiguration.java | 196 ---
.../java/org/apache/reef/client/FailedJob.java | 48 -
.../org/apache/reef/client/FailedRuntime.java | 82 --
.../java/org/apache/reef/client/JobMessage.java | 74 -
.../org/apache/reef/client/LauncherStatus.java | 123 --
.../main/java/org/apache/reef/client/REEF.java | 55 -
.../java/org/apache/reef/client/RunningJob.java | 62 -
.../org/apache/reef/client/package-info.java | 23 -
.../client/parameters/JobCompletedHandler.java | 35 -
.../client/parameters/JobFailedHandler.java | 35 -
.../client/parameters/JobMessageHandler.java | 35 -
.../client/parameters/JobRunningHandler.java | 35 -
.../parameters/ResourceManagerErrorHandler.java | 35 -
.../reef/client/parameters/package-info.java | 22 -
.../org/apache/reef/common/AbstractFailure.java | 151 --
.../java/org/apache/reef/common/Failure.java | 58 -
.../reef/driver/ContextAndTaskSubmittable.java | 64 -
.../apache/reef/driver/ContextSubmittable.java | 49 -
.../reef/driver/FlexiblePreemptionEvent.java | 47 -
.../org/apache/reef/driver/PreemptionEvent.java | 47 -
.../apache/reef/driver/PreemptionHandler.java | 36 -
.../reef/driver/StrictPreemptionEvent.java | 37 -
.../org/apache/reef/driver/TaskSubmittable.java | 40 -
.../reef/driver/catalog/NodeDescriptor.java | 42 -
.../reef/driver/catalog/RackDescriptor.java | 35 -
.../reef/driver/catalog/ResourceCatalog.java | 65 -
.../reef/driver/client/JobMessageObserver.java | 44 -
.../apache/reef/driver/client/package-info.java | 25 -
.../reef/driver/context/ActiveContext.java | 71 -
.../reef/driver/context/ClosedContext.java | 37 -
.../apache/reef/driver/context/ContextBase.java | 56 -
.../driver/context/ContextConfiguration.java | 109 --
.../reef/driver/context/ContextMessage.java | 52 -
.../reef/driver/context/FailedContext.java | 44 -
.../driver/context/ServiceConfiguration.java | 79 -
.../driver/evaluator/AllocatedEvaluator.java | 101 --
.../driver/evaluator/CompletedEvaluator.java | 33 -
.../driver/evaluator/EvaluatorDescriptor.java | 47 -
.../reef/driver/evaluator/EvaluatorRequest.java | 171 ---
.../driver/evaluator/EvaluatorRequestor.java | 38 -
.../reef/driver/evaluator/EvaluatorType.java | 38 -
.../reef/driver/evaluator/FailedEvaluator.java | 55 -
.../org/apache/reef/driver/package-info.java | 22 -
.../driver/parameters/ClientCloseHandlers.java | 35 -
.../ClientCloseWithMessageHandlers.java | 35 -
.../parameters/ClientMessageHandlers.java | 35 -
.../parameters/ContextActiveHandlers.java | 36 -
.../parameters/ContextClosedHandlers.java | 36 -
.../parameters/ContextFailedHandlers.java | 36 -
.../parameters/ContextMessageHandlers.java | 36 -
.../driver/parameters/DriverIdentifier.java | 35 -
.../driver/parameters/DriverIdleSources.java | 34 -
.../DriverJobSubmissionDirectory.java | 32 -
.../driver/parameters/DriverLocalFiles.java | 33 -
.../driver/parameters/DriverLocalLibraries.java | 33 -
.../reef/driver/parameters/DriverMemory.java | 31 -
.../DriverRestartCompletedHandlers.java | 36 -
.../DriverRestartContextActiveHandlers.java | 36 -
.../driver/parameters/DriverRestartHandler.java | 31 -
.../DriverRestartTaskRunningHandlers.java | 36 -
.../driver/parameters/DriverStartHandler.java | 33 -
.../parameters/EvaluatorAllocatedHandlers.java | 36 -
.../parameters/EvaluatorCompletedHandlers.java | 36 -
.../parameters/EvaluatorDispatcherThreads.java | 33 -
.../parameters/EvaluatorFailedHandlers.java | 36 -
.../reef/driver/parameters/JobGlobalFiles.java | 33 -
.../driver/parameters/JobGlobalLibraries.java | 33 -
.../ServiceContextActiveHandlers.java | 35 -
.../ServiceContextClosedHandlers.java | 35 -
.../ServiceContextFailedHandlers.java | 35 -
.../ServiceContextMessageHandlers.java | 35 -
.../ServiceDriverRestartCompletedHandlers.java | 35 -
...rviceDriverRestartContextActiveHandlers.java | 35 -
...ServiceDriverRestartTaskRunningHandlers.java | 35 -
.../ServiceEvaluatorAllocatedHandlers.java | 35 -
.../ServiceEvaluatorCompletedHandlers.java | 35 -
.../ServiceEvaluatorFailedHandlers.java | 35 -
.../ServiceTaskCompletedHandlers.java | 35 -
.../parameters/ServiceTaskFailedHandlers.java | 35 -
.../parameters/ServiceTaskMessageHandlers.java | 35 -
.../parameters/ServiceTaskRunningHandlers.java | 35 -
.../ServiceTaskSuspendedHandlers.java | 35 -
.../parameters/TaskCompletedHandlers.java | 36 -
.../driver/parameters/TaskFailedHandlers.java | 36 -
.../driver/parameters/TaskMessageHandlers.java | 36 -
.../driver/parameters/TaskRunningHandlers.java | 36 -
.../parameters/TaskSuspendedHandlers.java | 36 -
.../reef/driver/parameters/package-info.java | 22 -
.../apache/reef/driver/task/CompletedTask.java | 46 -
.../org/apache/reef/driver/task/FailedTask.java | 75 -
.../apache/reef/driver/task/RunningTask.java | 73 -
.../apache/reef/driver/task/SuspendedTask.java | 41 -
.../reef/driver/task/TaskConfiguration.java | 92 --
.../driver/task/TaskConfigurationOptions.java | 77 -
.../apache/reef/driver/task/TaskMessage.java | 56 -
.../reef/evaluator/context/ContextMessage.java | 69 -
.../context/ContextMessageHandler.java | 39 -
.../evaluator/context/ContextMessageSource.java | 39 -
.../evaluator/context/events/ContextStart.java | 39 -
.../evaluator/context/events/ContextStop.java | 39 -
.../context/parameters/ContextIdentifier.java | 29 -
.../parameters/ContextMessageHandlers.java | 34 -
.../parameters/ContextMessageSources.java | 34 -
.../parameters/ContextStartHandlers.java | 35 -
.../context/parameters/ContextStopHandlers.java | 35 -
.../evaluator/context/parameters/Services.java | 35 -
.../apache/reef/exception/DriverException.java | 65 -
.../reef/exception/EvaluatorException.java | 66 -
...aluatorKilledByResourceManagerException.java | 29 -
.../exception/EvaluatorTimeoutException.java | 44 -
.../exception/evaluator/NetworkException.java | 38 -
.../exception/evaluator/ServiceException.java | 53 -
.../evaluator/ServiceRuntimeException.java | 75 -
.../exception/evaluator/StorageException.java | 36 -
.../reef/exception/evaluator/package-info.java | 23 -
.../org/apache/reef/exception/package-info.java | 22 -
.../java/org/apache/reef/io/Accumulable.java | 39 -
.../java/org/apache/reef/io/Accumulator.java | 45 -
.../java/org/apache/reef/io/ExternalMap.java | 93 --
.../main/java/org/apache/reef/io/Message.java | 36 -
.../java/org/apache/reef/io/PartitionSpec.java | 49 -
.../src/main/java/org/apache/reef/io/Spool.java | 60 -
.../apache/reef/io/SystemTempFileCreator.java | 66 -
.../org/apache/reef/io/TempFileCreator.java | 65 -
.../src/main/java/org/apache/reef/io/Tuple.java | 67 -
.../io/WorkingDirectoryTempFileCreator.java | 76 -
.../org/apache/reef/io/naming/Identifiable.java | 33 -
.../apache/reef/io/naming/NameAssignment.java | 44 -
.../java/org/apache/reef/io/naming/Naming.java | 26 -
.../org/apache/reef/io/naming/NamingLookup.java | 43 -
.../apache/reef/io/naming/NamingRegistry.java | 46 -
.../java/org/apache/reef/io/package-info.java | 24 -
.../org/apache/reef/io/serialization/Codec.java | 45 -
.../reef/io/serialization/Deserializer.java | 37 -
.../io/serialization/SerializableCodec.java | 67 -
.../reef/io/serialization/Serializer.java | 38 -
.../runtime/common/DriverRestartCompleted.java | 28 -
.../apache/reef/runtime/common/Launcher.java | 156 --
.../runtime/common/client/ClientWireUp.java | 104 --
.../client/CommonClientConfigurationModule.java | 28 -
.../runtime/common/client/CompletedJobImpl.java | 46 -
.../common/client/JobStatusMessageHandler.java | 50 -
.../common/client/JobSubmissionHelper.java | 180 ---
.../common/client/REEFImplementation.java | 110 --
.../runtime/common/client/RunningJobImpl.java | 168 ---
.../reef/runtime/common/client/RunningJobs.java | 55 -
.../runtime/common/client/RunningJobsImpl.java | 148 --
.../common/client/RuntimeErrorProtoHandler.java | 51 -
.../client/api/ClientRuntimeParameters.java | 29 -
.../common/client/api/JobSubmissionHandler.java | 30 -
.../runtime/common/client/api/package-info.java | 22 -
.../defaults/DefaultCompletedJobHandler.java | 47 -
.../defaults/DefaultFailedJobHandler.java | 43 -
.../defaults/DefaultJobMessageHandler.java | 48 -
.../defaults/DefaultRunningJobHandler.java | 47 -
.../defaults/DefaultRuntimeErrorHandler.java | 52 -
.../common/client/defaults/package-info.java | 22 -
.../runtime/common/client/package-info.java | 22 -
.../common/client/parameters/ClientPresent.java | 33 -
.../common/driver/DriverExceptionHandler.java | 53 -
.../driver/DriverRuntimeConfiguration.java | 73 -
.../DriverRuntimeConfigurationOptions.java | 33 -
.../driver/DriverRuntimeStartHandler.java | 80 --
.../common/driver/DriverRuntimeStopHandler.java | 71 -
.../runtime/common/driver/DriverSingleton.java | 18 -
.../runtime/common/driver/DriverSingletons.java | 90 --
.../common/driver/DriverStartHandler.java | 93 --
.../runtime/common/driver/DriverStatus.java | 30 -
.../common/driver/DriverStatusManager.java | 330 -----
.../common/driver/EvaluatorRequestorImpl.java | 95 --
.../api/AbstractDriverRuntimeConfiguration.java | 124 --
.../api/DefaultResourceManagerLifeCycle.java | 18 -
.../driver/api/ResourceLaunchHandler.java | 30 -
.../driver/api/ResourceManagerLifeCycle.java | 18 -
.../driver/api/ResourceReleaseHandler.java | 30 -
.../driver/api/ResourceRequestHandler.java | 30 -
.../common/driver/api/RuntimeParameters.java | 50 -
.../runtime/common/driver/api/package-info.java | 22 -
.../driver/catalog/NodeDescriptorImpl.java | 78 -
.../driver/catalog/RackDescriptorImpl.java | 78 -
.../driver/catalog/ResourceCatalogImpl.java | 88 --
.../common/driver/client/ClientConnection.java | 82 --
.../common/driver/client/ClientManager.java | 148 --
.../driver/client/JobMessageObserverImpl.java | 44 -
.../driver/client/LoggingJobStatusHandler.java | 42 -
.../common/driver/client/package-info.java | 25 -
.../driver/context/ClosedContextImpl.java | 88 --
.../driver/context/ContextControlHandler.java | 62 -
.../common/driver/context/ContextFactory.java | 97 --
.../driver/context/ContextMessageImpl.java | 55 -
.../driver/context/ContextRepresenters.java | 247 ----
.../common/driver/context/EvaluatorContext.java | 280 ----
.../driver/context/FailedContextImpl.java | 95 --
.../common/driver/context/package-info.java | 26 -
.../defaults/DefaultClientCloseHandler.java | 46 -
.../DefaultClientCloseWithMessageHandler.java | 39 -
.../defaults/DefaultClientMessageHandler.java | 42 -
.../defaults/DefaultContextActiveHandler.java | 44 -
.../defaults/DefaultContextClosureHandler.java | 47 -
.../defaults/DefaultContextFailureHandler.java | 44 -
.../defaults/DefaultContextMessageHandler.java | 43 -
.../DefaultDriverRestartCompletedHandler.java | 44 -
...efaultDriverRestartContextActiveHandler.java | 44 -
.../DefaultDriverRestartTaskRunningHandler.java | 43 -
.../DefaultEvaluatorAllocationHandler.java | 44 -
.../DefaultEvaluatorCompletionHandler.java | 43 -
.../DefaultEvaluatorFailureHandler.java | 41 -
.../defaults/DefaultTaskCompletionHandler.java | 47 -
.../defaults/DefaultTaskFailureHandler.java | 39 -
.../defaults/DefaultTaskMessageHandler.java | 43 -
.../defaults/DefaultTaskRunningHandler.java | 43 -
.../defaults/DefaultTaskSuspensionHandler.java | 39 -
.../common/driver/defaults/package-info.java | 22 -
.../evaluator/AllocatedEvaluatorImpl.java | 224 ---
.../evaluator/CompletedEvaluatorImpl.java | 49 -
.../evaluator/EvaluatorControlHandler.java | 100 --
.../evaluator/EvaluatorDescriptorImpl.java | 75 -
.../EvaluatorHeartBeatSanityChecker.java | 57 -
.../evaluator/EvaluatorHeartbeatHandler.java | 74 -
.../driver/evaluator/EvaluatorManager.java | 529 -------
.../evaluator/EvaluatorManagerFactory.java | 105 --
.../evaluator/EvaluatorMessageDispatcher.java | 247 ----
.../EvaluatorResourceManagerErrorHandler.java | 67 -
.../common/driver/evaluator/EvaluatorState.java | 38 -
.../evaluator/EvaluatorStatusManager.java | 106 --
.../common/driver/evaluator/Evaluators.java | 128 --
.../driver/evaluator/FailedEvaluatorImpl.java | 73 -
.../common/driver/evaluator/package-info.java | 26 -
.../common/driver/idle/ClockIdlenessSource.java | 60 -
.../common/driver/idle/DriverIdleManager.java | 73 -
.../driver/idle/DriverIdlenessSource.java | 31 -
.../driver/idle/EventHandlerIdlenessSource.java | 59 -
.../runtime/common/driver/idle/IdleMessage.java | 61 -
.../common/driver/idle/package-info.java | 22 -
.../runtime/common/driver/package-info.java | 22 -
.../resourcemanager/NodeDescriptorHandler.java | 46 -
.../ResourceAllocationHandler.java | 63 -
.../ResourceManagerErrorHandler.java | 44 -
.../resourcemanager/ResourceManagerStatus.java | 156 --
.../resourcemanager/ResourceStatusHandler.java | 71 -
.../driver/resourcemanager/package-info.java | 22 -
.../common/driver/task/CompletedTaskImpl.java | 60 -
.../common/driver/task/RunningTaskImpl.java | 138 --
.../common/driver/task/SuspendedTaskImpl.java | 58 -
.../common/driver/task/TaskMessageImpl.java | 61 -
.../common/driver/task/TaskRepresenter.java | 202 ---
.../common/driver/task/package-info.java | 26 -
.../evaluator/DefaultDriverConnection.java | 48 -
.../common/evaluator/DriverConnection.java | 31 -
.../evaluator/EvaluatorConfiguration.java | 68 -
.../common/evaluator/EvaluatorRuntime.java | 207 ---
.../common/evaluator/HeartBeatManager.java | 173 ---
.../common/evaluator/PIDStoreStartHandler.java | 56 -
.../context/ContextClientCodeException.java | 78 -
.../evaluator/context/ContextLifeCycle.java | 97 --
.../evaluator/context/ContextManager.java | 374 -----
.../evaluator/context/ContextRuntime.java | 436 ------
.../evaluator/context/ContextStartImpl.java | 37 -
.../evaluator/context/ContextStopImpl.java | 35 -
.../evaluator/context/RootContextLauncher.java | 134 --
.../defaults/DefaultContextMessageHandler.java | 45 -
.../defaults/DefaultContextMessageSource.java | 44 -
.../defaults/DefaultContextStartHandler.java | 43 -
.../defaults/DefaultContextStopHandler.java | 43 -
.../context/defaults/package-info.java | 22 -
.../common/evaluator/context/package-info.java | 22 -
.../runtime/common/evaluator/package-info.java | 22 -
.../parameters/ApplicationIdentifier.java | 33 -
.../parameters/DriverRemoteIdentifier.java | 31 -
.../parameters/EvaluatorIdentifier.java | 31 -
.../evaluator/parameters/HeartbeatPeriod.java | 31 -
.../parameters/InitialTaskConfiguration.java | 31 -
.../parameters/RootContextConfiguration.java | 31 -
.../parameters/RootServiceConfiguration.java | 31 -
.../common/evaluator/task/CloseEventImpl.java | 45 -
.../evaluator/task/DriverMessageImpl.java | 44 -
.../common/evaluator/task/SuspendEventImpl.java | 45 -
.../evaluator/task/TaskClientCodeException.java | 77 -
.../evaluator/task/TaskLifeCycleHandlers.java | 90 --
.../common/evaluator/task/TaskRuntime.java | 313 ----
.../common/evaluator/task/TaskStartImpl.java | 43 -
.../common/evaluator/task/TaskStatus.java | 310 ----
.../common/evaluator/task/TaskStopImpl.java | 42 -
.../task/defaults/DefaultCloseHandler.java | 41 -
.../defaults/DefaultDriverMessageHandler.java | 41 -
.../task/defaults/DefaultSuspendHandler.java | 41 -
.../evaluator/task/defaults/package-info.java | 22 -
.../task/exceptions/TaskCallFailure.java | 37 -
.../exceptions/TaskCloseHandlerFailure.java | 37 -
.../exceptions/TaskMessageHandlerFailure.java | 37 -
.../exceptions/TaskStartHandlerFailure.java | 39 -
.../task/exceptions/TaskStopHandlerFailure.java | 39 -
.../exceptions/TaskSuspendHandlerFailure.java | 37 -
.../common/evaluator/task/package-info.java | 22 -
.../runtime/common/files/ClasspathProvider.java | 83 --
.../reef/runtime/common/files/JobJarMaker.java | 136 --
.../runtime/common/files/REEFFileNames.java | 216 ---
.../common/files/RuntimeClasspathProvider.java | 48 -
.../reef/runtime/common/files/package-info.java | 22 -
.../common/launch/CLRLaunchCommandBuilder.java | 99 --
.../common/launch/JavaLaunchCommandBuilder.java | 163 ---
.../reef/runtime/common/launch/LaunchClass.java | 191 ---
.../common/launch/LaunchCommandBuilder.java | 66 -
.../common/launch/LauncherSingletons.java | 18 -
.../common/launch/ProfilingStopHandler.java | 58 -
.../runtime/common/launch/REEFErrorHandler.java | 101 --
.../runtime/common/launch/REEFMessageCodec.java | 96 --
.../launch/REEFUncaughtExceptionHandler.java | 67 -
.../runtime/common/launch/package-info.java | 22 -
.../parameters/ClockConfigurationPath.java | 30 -
.../launch/parameters/ErrorHandlerRID.java | 37 -
.../common/launch/parameters/LaunchID.java | 27 -
.../common/launch/parameters/package-info.java | 22 -
.../reef/runtime/common/package-info.java | 26 -
.../common/parameters/DeleteTempFiles.java | 31 -
.../runtime/common/parameters/JVMHeapSlack.java | 29 -
.../common/utils/BroadCastEventHandler.java | 44 -
.../common/utils/DefaultExceptionCodec.java | 64 -
.../runtime/common/utils/DispatchingEStage.java | 143 --
.../runtime/common/utils/ExceptionCodec.java | 50 -
.../runtime/common/utils/RemoteManager.java | 76 -
.../reef/task/HeartBeatTriggerManager.java | 53 -
.../main/java/org/apache/reef/task/Task.java | 48 -
.../java/org/apache/reef/task/TaskMessage.java | 67 -
.../org/apache/reef/task/TaskMessageSource.java | 39 -
.../org/apache/reef/task/events/CloseEvent.java | 38 -
.../apache/reef/task/events/DriverMessage.java | 38 -
.../apache/reef/task/events/SuspendEvent.java | 38 -
.../org/apache/reef/task/events/TaskStart.java | 37 -
.../org/apache/reef/task/events/TaskStop.java | 36 -
.../main/java/org/apache/reef/util/Builder.java | 35 -
.../java/org/apache/reef/util/CommandUtils.java | 55 -
.../org/apache/reef/util/EnvironmentUtils.java | 153 --
.../util/ExceptionHandlingEventHandler.java | 50 -
.../java/org/apache/reef/util/Exceptions.java | 42 -
.../java/org/apache/reef/util/JARFileMaker.java | 114 --
.../java/org/apache/reef/util/MemoryUtils.java | 120 --
.../main/java/org/apache/reef/util/OSUtils.java | 105 --
.../reef/util/ObjectInstantiationLogger.java | 33 -
.../java/org/apache/reef/util/REEFVersion.java | 84 --
.../main/java/org/apache/reef/util/SetOnce.java | 51 -
.../org/apache/reef/util/SingletonAsserter.java | 41 -
.../java/org/apache/reef/util/ThreadLogger.java | 94 --
.../org/apache/reef/util/logging/Config.java | 31 -
.../apache/reef/util/logging/LogLevelName.java | 30 -
.../org/apache/reef/util/logging/LogParser.java | 164 ---
.../apache/reef/util/logging/LoggingScope.java | 29 -
.../reef/util/logging/LoggingScopeFactory.java | 343 -----
.../reef/util/logging/LoggingScopeImpl.java | 104 --
.../apache/reef/util/logging/LoggingSetup.java | 37 -
.../reef/util/logging/ThreadLogFormatter.java | 141 --
.../java/org/apache/reef/util/package-info.java | 22 -
reef-common/src/main/proto/client_runtime.proto | 54 -
reef-common/src/main/proto/driver_runtime.proto | 89 --
.../src/main/proto/evaluator_runtime.proto | 90 --
reef-common/src/main/proto/reef_protocol.proto | 42 -
.../src/main/proto/reef_service_protos.proto | 116 --
reef-common/src/main/resources/log4j.properties | 27 -
.../org/apache/reef/logging.properties | 85 --
.../src/main/resources/version.properties | 18 -
.../driver/EvaluatorRequestorImplTest.java | 110 --
.../common/driver/catalog/CatalogTest.java | 54 -
.../org/apache/reef/util/LoggingScopeTest.java | 100 --
.../apache/reef/util/SingletonAsserterTest.java | 34 -
reef-examples-clr/pom.xml | 182 ---
.../apache/reef/examples/helloCLR/HelloCLR.java | 93 --
.../reef/examples/helloCLR/HelloDriver.java | 183 ---
.../reef/examples/helloCLR/package-info.java | 22 -
.../examples/retained_evalCLR/JobClient.java | 317 ----
.../examples/retained_evalCLR/JobDriver.java | 489 -------
.../reef/examples/retained_evalCLR/Launch.java | 189 ---
.../examples/retained_evalCLR/package-info.java | 22 -
reef-examples-hdinsight/pom.xml | 128 --
.../reef/examples/hello/HelloHDInsight.java | 33 -
reef-examples/.gitignore | 1 -
reef-examples/pom.xml | 365 -----
.../examples/data/loading/DataLoadingREEF.java | 128 --
.../reef/examples/data/loading/LineCounter.java | 126 --
.../examples/data/loading/LineCountingTask.java | 59 -
.../apache/reef/examples/hello/HelloDriver.java | 84 --
.../apache/reef/examples/hello/HelloREEF.java | 77 -
.../reef/examples/hello/HelloREEFMesos.java | 55 -
.../reef/examples/hello/HelloREEFNoClient.java | 64 -
.../reef/examples/hello/HelloReefYarn.java | 70 -
.../apache/reef/examples/hello/HelloTask.java | 39 -
.../reef/examples/hello/package-info.java | 22 -
.../reef/examples/hellohttp/HelloREEFHttp.java | 112 --
.../examples/hellohttp/HelloREEFHttpYarn.java | 52 -
.../hellohttp/HttpServerShellCmdtHandler.java | 168 ---
.../examples/hellohttp/HttpShellJobDriver.java | 364 -----
.../apache/reef/examples/library/Command.java | 29 -
.../apache/reef/examples/library/ShellTask.java | 73 -
.../apache/reef/examples/pool/JobDriver.java | 306 ----
.../org/apache/reef/examples/pool/Launch.java | 216 ---
.../apache/reef/examples/pool/SleepTask.java | 73 -
.../apache/reef/examples/pool/package-info.java | 23 -
.../reef/examples/retained_eval/JobClient.java | 335 -----
.../reef/examples/retained_eval/JobDriver.java | 370 -----
.../reef/examples/retained_eval/Launch.java | 185 ---
.../examples/retained_eval/package-info.java | 22 -
.../reef/examples/scheduler/Scheduler.java | 226 ---
.../examples/scheduler/SchedulerDriver.java | 339 -----
.../scheduler/SchedulerHttpHandler.java | 107 --
.../reef/examples/scheduler/SchedulerREEF.java | 109 --
.../examples/scheduler/SchedulerREEFYarn.java | 46 -
.../examples/scheduler/SchedulerResponse.java | 114 --
.../reef/examples/scheduler/TaskEntity.java | 71 -
.../reef/examples/scheduler/package-info.java | 22 -
.../apache/reef/examples/suspend/Control.java | 103 --
.../apache/reef/examples/suspend/Launch.java | 174 ---
.../examples/suspend/ObjectWritableCodec.java | 93 --
.../reef/examples/suspend/SuspendClient.java | 172 ---
.../examples/suspend/SuspendClientControl.java | 92 --
.../reef/examples/suspend/SuspendDriver.java | 340 -----
.../reef/examples/suspend/SuspendTestTask.java | 179 ---
.../reef/examples/suspend/package-info.java | 22 -
.../utils/wake/BlockingEventHandler.java | 63 -
.../utils/wake/LoggingEventHandler.java | 58 -
.../reef/examples/hello/HelloHttpTest.java | 41 -
.../suspend/ObjectWritableCodecTest.java | 50 -
reef-io/pom.xml | 143 --
reef-io/src/main/avro/nameservice.avsc | 64 -
.../reef/io/data/loading/api/DataLoader.java | 236 ---
.../api/DataLoadingDriverConfiguration.java | 33 -
.../loading/api/DataLoadingRequestBuilder.java | 190 ---
.../io/data/loading/api/DataLoadingService.java | 68 -
.../reef/io/data/loading/api/DataSet.java | 43 -
.../loading/api/ResourceRequestHandler.java | 64 -
.../impl/EvaluatorRequestSerializer.java | 63 -
.../impl/EvaluatorToPartitionMapper.java | 154 --
.../impl/InMemoryInputFormatDataSet.java | 53 -
.../data/loading/impl/InputFormatDataSet.java | 156 --
.../impl/InputFormatExternalConstructor.java | 50 -
.../loading/impl/InputFormatLoadingService.java | 172 ---
.../impl/InputSplitExternalConstructor.java | 57 -
.../impl/JobConfExternalConstructor.java | 88 --
.../io/data/loading/impl/NumberedSplit.java | 65 -
.../data/loading/impl/WritableSerializer.java | 93 --
.../java/org/apache/reef/io/network/Cache.java | 53 -
.../org/apache/reef/io/network/Connection.java | 52 -
.../reef/io/network/ConnectionFactory.java | 37 -
.../org/apache/reef/io/network/Message.java | 50 -
.../reef/io/network/TransportFactory.java | 43 -
.../exception/NetworkRuntimeException.java | 54 -
.../network/exception/ParentDeadException.java | 48 -
.../reef/io/network/exception/package-info.java | 19 -
.../reef/io/network/impl/BindNSToTask.java | 45 -
.../network/impl/MessagingTransportFactory.java | 60 -
.../reef/io/network/impl/NSConnection.java | 134 --
.../apache/reef/io/network/impl/NSMessage.java | 90 --
.../reef/io/network/impl/NSMessageCodec.java | 134 --
.../network/impl/NameServiceCloseHandler.java | 49 -
.../reef/io/network/impl/NetworkService.java | 235 ---
.../impl/NetworkServiceClosingHandler.java | 43 -
.../network/impl/NetworkServiceParameters.java | 60 -
.../reef/io/network/impl/StreamingCodec.java | 35 -
.../reef/io/network/impl/UnbindNSFromTask.java | 45 -
.../reef/io/network/impl/package-info.java | 19 -
.../io/network/naming/NameAssignmentTuple.java | 65 -
.../reef/io/network/naming/NameCache.java | 72 -
.../reef/io/network/naming/NameClient.java | 212 ---
.../io/network/naming/NameLookupClient.java | 257 ----
.../io/network/naming/NameRegistryClient.java | 200 ---
.../reef/io/network/naming/NameServer.java | 88 --
.../network/naming/NameServerConfiguration.java | 51 -
.../reef/io/network/naming/NameServerImpl.java | 300 ----
.../io/network/naming/NameServerParameters.java | 40 -
.../io/network/naming/NamingCodecFactory.java | 82 --
.../naming/exception/NamingException.java | 56 -
.../exception/NamingRuntimeException.java | 56 -
.../network/naming/exception/package-info.java | 19 -
.../reef/io/network/naming/package-info.java | 19 -
.../network/naming/serialization/AvroUtils.java | 68 -
.../serialization/NamingLookupRequest.java | 46 -
.../serialization/NamingLookupRequestCodec.java | 79 -
.../serialization/NamingLookupResponse.java | 48 -
.../NamingLookupResponseCodec.java | 94 --
.../naming/serialization/NamingMessage.java | 46 -
.../serialization/NamingRegisterRequest.java | 46 -
.../NamingRegisterRequestCodec.java | 76 -
.../serialization/NamingRegisterResponse.java | 44 -
.../NamingRegisterResponseCodec.java | 60 -
.../serialization/NamingUnregisterRequest.java | 46 -
.../NamingUnregisterRequestCodec.java | 72 -
.../naming/serialization/package-info.java | 22 -
.../apache/reef/io/network/package-info.java | 19 -
.../apache/reef/io/network/util/ListCodec.java | 83 --
.../org/apache/reef/io/network/util/Pair.java | 42 -
.../reef/io/network/util/StringCodec.java | 42 -
.../reef/io/network/util/StringIdentifier.java | 80 --
.../network/util/StringIdentifierFactory.java | 46 -
.../reef/io/network/util/package-info.java | 19 -
.../reef/io/storage/FramingInputStream.java | 76 -
.../reef/io/storage/FramingOutputStream.java | 134 --
.../io/storage/FramingTupleDeserializer.java | 100 --
.../reef/io/storage/FramingTupleSerializer.java | 86 --
.../apache/reef/io/storage/MergingIterator.java | 62 -
.../apache/reef/io/storage/ScratchSpace.java | 27 -
.../apache/reef/io/storage/StorageService.java | 25 -
.../io/storage/local/CodecFileAccumulable.java | 52 -
.../io/storage/local/CodecFileAccumulator.java | 58 -
.../io/storage/local/CodecFileIterable.java | 53 -
.../io/storage/local/CodecFileIterator.java | 82 --
.../io/storage/local/LocalScratchSpace.java | 87 --
.../io/storage/local/LocalStorageService.java | 44 -
.../io/storage/local/SerializerFileSpool.java | 101 --
.../apache/reef/io/storage/ram/CodecRamMap.java | 84 --
.../org/apache/reef/io/storage/ram/RamMap.java | 74 -
.../apache/reef/io/storage/ram/RamSpool.java | 72 -
.../reef/io/storage/ram/RamStorageService.java | 38 -
.../reef/io/storage/ram/SortingRamSpool.java | 90 --
.../reef/io/storage/util/GetAllIterable.java | 95 --
.../reef/io/storage/util/IntegerCodec.java | 35 -
.../io/storage/util/IntegerDeserializer.java | 62 -
.../reef/io/storage/util/IntegerSerializer.java | 62 -
.../io/storage/util/StringDeserializer.java | 66 -
.../reef/io/storage/util/StringSerializer.java | 65 -
.../io/storage/util/TupleKeyComparator.java | 37 -
reef-io/src/main/proto/ns_protocol.proto | 32 -
.../reef/services/network/NameClientTest.java | 123 --
.../reef/services/network/NamingTest.java | 367 -----
.../services/network/NetworkServiceTest.java | 495 -------
.../apache/reef/services/network/TestEvent.java | 38 -
.../services/network/util/LoggingUtils.java | 43 -
.../reef/services/network/util/Monitor.java | 39 -
.../reef/services/network/util/StringCodec.java | 34 -
.../services/network/util/TimeoutHandler.java | 36 -
.../services/network/util/package-info.java | 19 -
.../reef/services/storage/ExternalMapTest.java | 94 --
.../reef/services/storage/FramingTest.java | 104 --
.../services/storage/MergingIteratorTest.java | 54 -
.../reef/services/storage/SortingSpoolTest.java | 117 --
.../reef/services/storage/SpoolFileTest.java | 206 ---
.../services/storage/TupleSerializerTest.java | 105 --
reef-poison/pom.xml | 52 -
.../org/apache/reef/poison/PoisonException.java | 28 -
.../reef/poison/PoisonedAlarmHandler.java | 33 -
.../reef/poison/PoisonedConfiguration.java | 57 -
.../context/PoisonedContextStartHandler.java | 77 -
.../PoissonPoisonedContextStartHandler.java | 57 -
.../reef/poison/context/package-info.java | 22 -
.../org/apache/reef/poison/package-info.java | 22 -
.../reef/poison/params/CrashProbability.java | 30 -
.../apache/reef/poison/params/CrashTimeout.java | 27 -
.../poison/task/PoisonedTaskStartHandler.java | 77 -
.../task/PoissonPoisonedTaskStartHandler.java | 57 -
.../apache/reef/poison/task/package-info.java | 22 -
reef-runtime-hdinsight/pom.xml | 82 --
.../hdinsight/HDInsightClasspathProvider.java | 73 -
.../reef/runtime/hdinsight/cli/HDICLI.java | 173 ---
.../reef/runtime/hdinsight/cli/LogFetcher.java | 134 --
.../runtime/hdinsight/cli/LogFileEntry.java | 113 --
.../reef/runtime/hdinsight/cli/TFileParser.java | 97 --
.../runtime/hdinsight/cli/package-info.java | 22 -
.../runtime/hdinsight/client/AzureUploader.java | 151 --
.../client/HDInsightDriverConfiguration.java | 95 --
.../client/HDInsightJobSubmissionHandler.java | 180 ---
.../client/HDInsightRuntimeConfiguration.java | 123 --
.../HDInsightRuntimeConfigurationStatic.java | 53 -
.../UnsafeHDInsightRuntimeConfiguration.java | 118 --
...safeHDInsightRuntimeConfigurationStatic.java | 50 -
.../runtime/hdinsight/client/package-info.java | 22 -
.../sslhacks/DefaultClientConstructor.java | 39 -
.../sslhacks/UnsafeClientConstructor.java | 72 -
.../client/sslhacks/UnsafeHostNameVerifier.java | 50 -
.../client/sslhacks/UnsafeTrustManager.java | 49 -
.../client/yarnrest/ApplicationID.java | 52 -
.../client/yarnrest/ApplicationResponse.java | 44 -
.../client/yarnrest/ApplicationState.java | 214 ---
.../client/yarnrest/ApplicationSubmission.java | 167 ---
.../client/yarnrest/ContainerInfo.java | 125 --
.../client/yarnrest/EnvironmentEntry.java | 76 -
.../hdinsight/client/yarnrest/FileResource.java | 89 --
.../client/yarnrest/HDInsightInstance.java | 211 ---
.../client/yarnrest/LocalResourcesEntry.java | 48 -
.../hdinsight/client/yarnrest/Resource.java | 54 -
.../hdinsight/client/yarnrest/package-info.java | 24 -
.../reef/runtime/hdinsight/package-info.java | 22 -
.../AzureStorageAccountContainerName.java | 29 -
.../parameters/AzureStorageAccountKey.java | 29 -
.../parameters/AzureStorageAccountName.java | 29 -
.../parameters/AzureStorageBaseFolder.java | 29 -
.../parameters/HDInsightInstanceURL.java | 29 -
.../hdinsight/parameters/HDInsightPassword.java | 29 -
.../hdinsight/parameters/HDInsightUsername.java | 29 -
reef-runtime-local/pom.xml | 62 -
.../runtime/local/LocalClasspathProvider.java | 134 --
.../reef/runtime/local/client/DriverFiles.java | 174 ---
.../client/ExecutorServiceConstructor.java | 44 -
.../reef/runtime/local/client/FileSet.java | 113 --
.../local/client/LocalJobSubmissionHandler.java | 166 ---
.../local/client/LocalRuntimeConfiguration.java | 82 --
.../reef/runtime/local/client/package-info.java | 22 -
.../client/parameters/DefaultMemorySize.java | 29 -
.../client/parameters/DefaultNumberOfCores.java | 29 -
.../client/parameters/NumberOfProcesses.java | 29 -
.../local/client/parameters/RootFolder.java | 30 -
.../local/client/parameters/package-info.java | 22 -
.../reef/runtime/local/driver/Container.java | 85 --
.../runtime/local/driver/ContainerManager.java | 202 ---
.../reef/runtime/local/driver/IDMaker.java | 47 -
.../local/driver/LocalDriverConfiguration.java | 81 --
.../driver/LocalDriverRuntimeConfiguration.java | 30 -
.../driver/LocalResourceLaunchHandler.java | 46 -
.../driver/LocalResourceReleaseHandler.java | 47 -
.../driver/LocalResourceRequestHandler.java | 46 -
.../runtime/local/driver/ProcessContainer.java | 178 ---
.../runtime/local/driver/ResourceManager.java | 270 ----
.../runtime/local/driver/ResourceRequest.java | 63 -
.../local/driver/ResourceRequestQueue.java | 70 -
.../reef/runtime/local/driver/package-info.java | 22 -
.../local/driver/parameters/GlobalFiles.java | 31 -
.../driver/parameters/GlobalLibraries.java | 31 -
.../local/driver/parameters/LocalFiles.java | 31 -
.../local/driver/parameters/LocalLibraries.java | 31 -
.../local/driver/parameters/package-info.java | 22 -
.../process/LoggingRunnableProcessObserver.java | 44 -
.../process/ReefRunnableProcessObserver.java | 125 --
.../runtime/local/process/RunnableProcess.java | 277 ----
.../local/process/RunnableProcessObserver.java | 39 -
.../runtime/local/process/package-info.java | 22 -
.../local/driver/ResourceRequestQueueTest.java | 63 -
.../local/driver/ResourceRequestTest.java | 61 -
reef-runtime-mesos/pom.xml | 95 --
.../src/main/avro/EvaluatorControl.avsc | 47 -
.../runtime/mesos/MesosClasspathProvider.java | 92 --
.../mesos/client/MesosClientConfiguration.java | 68 -
.../mesos/client/MesosJobSubmissionHandler.java | 141 --
.../mesos/client/parameters/MasterIp.java | 26 -
.../mesos/client/parameters/RootFolder.java | 26 -
.../mesos/driver/MesosDriverConfiguration.java | 98 --
.../driver/MesosResourceLaunchHandler.java | 129 --
.../driver/MesosResourceReleaseHandler.java | 42 -
.../driver/MesosResourceRequestHandler.java | 42 -
.../mesos/driver/MesosRuntimeStartHandler.java | 38 -
.../mesos/driver/MesosRuntimeStopHandler.java | 38 -
.../driver/MesosSchedulerDriverExecutor.java | 42 -
.../runtime/mesos/driver/REEFEventHandlers.java | 65 -
.../reef/runtime/mesos/driver/REEFExecutor.java | 50 -
.../runtime/mesos/driver/REEFExecutors.java | 64 -
.../runtime/mesos/driver/REEFScheduler.java | 506 -------
.../mesos/driver/parameters/MesosMasterIp.java | 26 -
.../evaluator/EvaluatorControlHandler.java | 55 -
.../runtime/mesos/evaluator/REEFExecutor.java | 249 ----
.../evaluator/parameters/MesosExecutorId.java | 26 -
.../util/HDFSConfigurationConstructor.java | 35 -
.../runtime/mesos/util/MesosErrorHandler.java | 43 -
.../runtime/mesos/util/MesosRemoteManager.java | 62 -
.../mesos/util/MesosRemoteManagerCodec.java | 68 -
reef-runtime-yarn/pom.xml | 80 --
.../reef/runtime/yarn/ClassPathBuilder.java | 109 --
.../runtime/yarn/YarnClasspathProvider.java | 140 --
.../yarn/client/YarnClientConfiguration.java | 73 -
.../yarn/client/YarnJobSubmissionHandler.java | 277 ----
.../yarn/client/parameters/JobPriority.java | 29 -
.../yarn/client/parameters/JobQueue.java | 29 -
.../driver/ApplicationMasterRegistration.java | 62 -
.../yarn/driver/ContainerRequestCounter.java | 71 -
.../reef/runtime/yarn/driver/Containers.java | 109 --
.../yarn/driver/DefaultTrackingURLProvider.java | 33 -
.../yarn/driver/EvaluatorSetupHelper.java | 147 --
.../runtime/yarn/driver/GlobalJarUploader.java | 92 --
.../runtime/yarn/driver/REEFEventHandlers.java | 91 --
.../yarn/driver/TrackingURLProvider.java | 29 -
.../yarn/driver/UploaderToJobfolder.java | 94 --
.../yarn/driver/YARNResourceLaunchHandler.java | 125 --
.../yarn/driver/YARNResourceReleaseHandler.java | 50 -
.../yarn/driver/YARNRuntimeStartHandler.java | 42 -
.../yarn/driver/YARNRuntimeStopHandler.java | 42 -
.../yarn/driver/YarnContainerManager.java | 680 ---------
.../driver/YarnContainerRequestHandler.java | 32 -
.../driver/YarnContainerRequestHandlerImpl.java | 47 -
.../yarn/driver/YarnDriverConfiguration.java | 95 --
.../yarn/driver/YarnResourceRequestHandler.java | 111 --
.../reef/runtime/yarn/driver/package-info.java | 22 -
.../parameters/JobSubmissionDirectory.java | 29 -
.../driver/parameters/YarnHeartbeatPeriod.java | 29 -
.../yarn/util/YarnConfigurationConstructor.java | 38 -
.../reef/runtime/yarn/util/YarnTypes.java | 59 -
.../driver/YarnResourceRequestHandlerTest.java | 127 --
reef-tang/.gitattributes | 3 -
reef-tang/.gitignore | 15 -
reef-tang/README.md | 562 --------
reef-tang/doc/tangdoc.png | Bin 32351 -> 0 bytes
reef-tang/doc/tooltip.png | Bin 9677 -> 0 bytes
reef-tang/pom.xml | 40 -
reef-tang/tang-test-jarA/pom.xml | 31 -
.../java/org/apache/reef/tang/examples/A.java | 23 -
reef-tang/tang-test-jarAB/pom.xml | 38 -
.../java/org/apache/reef/tang/examples/A.java | 25 -
.../java/org/apache/reef/tang/examples/B.java | 25 -
reef-tang/tang-test-jarB-conflictA/pom.xml | 31 -
reef-tang/tang-test-jarB/pom.xml | 39 -
.../java/org/apache/reef/tang/examples/B.java | 23 -
reef-tang/tang/.gitignore | 2 -
reef-tang/tang/maven-eclipse.xml | 28 -
reef-tang/tang/pom.xml | 171 ---
reef-tang/tang/src/main/avro/configuration.avsc | 37 -
.../main/java/org/apache/reef/tang/Aspect.java | 74 -
.../java/org/apache/reef/tang/BindLocation.java | 38 -
.../org/apache/reef/tang/ClassHierarchy.java | 86 --
.../org/apache/reef/tang/Configuration.java | 167 ---
.../apache/reef/tang/ConfigurationBuilder.java | 251 ----
.../org/apache/reef/tang/Configurations.java | 59 -
.../apache/reef/tang/ExternalConstructor.java | 40 -
.../org/apache/reef/tang/InjectionFuture.java | 136 --
.../java/org/apache/reef/tang/Injector.java | 133 --
.../apache/reef/tang/JavaClassHierarchy.java | 67 -
.../reef/tang/JavaConfigurationBuilder.java | 98 --
.../main/java/org/apache/reef/tang/Tang.java | 149 --
.../tang/annotations/DefaultImplementation.java | 42 -
.../org/apache/reef/tang/annotations/Name.java | 23 -
.../reef/tang/annotations/NamedParameter.java | 40 -
.../apache/reef/tang/annotations/Parameter.java | 31 -
.../org/apache/reef/tang/annotations/Unit.java | 47 -
.../reef/tang/annotations/package-info.java | 23 -
.../reef/tang/examples/PrintTypeHierarchy.java | 105 --
.../org/apache/reef/tang/examples/Timer.java | 73 -
.../org/apache/reef/tang/examples/TimerV1.java | 66 -
.../apache/reef/tang/examples/package-info.java | 22 -
.../apache/reef/tang/examples/timer/Timer.java | 33 -
.../reef/tang/examples/timer/TimerImpl.java | 42 -
.../reef/tang/examples/timer/TimerMock.java | 66 -
.../reef/tang/examples/timer/package-info.java | 23 -
.../reef/tang/exceptions/BindException.java | 43 -
.../exceptions/ClassHierarchyException.java | 40 -
.../tang/exceptions/InjectionException.java | 44 -
.../exceptions/NameResolutionException.java | 40 -
.../reef/tang/exceptions/ParseException.java | 36 -
.../reef/tang/exceptions/package-info.java | 28 -
.../formats/AvroConfigurationSerializer.java | 313 ----
.../apache/reef/tang/formats/CommandLine.java | 218 ---
.../reef/tang/formats/ConfigurationFile.java | 253 ----
.../reef/tang/formats/ConfigurationModule.java | 299 ----
.../formats/ConfigurationModuleBuilder.java | 385 -----
.../tang/formats/ConfigurationSerializer.java | 154 --
.../java/org/apache/reef/tang/formats/Impl.java | 22 -
.../apache/reef/tang/formats/OptionalImpl.java | 22 -
.../reef/tang/formats/OptionalParameter.java | 22 -
.../org/apache/reef/tang/formats/Param.java | 22 -
.../reef/tang/formats/ParameterParser.java | 150 --
.../org/apache/reef/tang/formats/Provides.java | 22 -
.../apache/reef/tang/formats/RequiredImpl.java | 22 -
.../reef/tang/formats/RequiredParameter.java | 22 -
.../apache/reef/tang/formats/package-info.java | 29 -
.../ConfigurationBuilderImpl.java | 378 -----
.../tang/implementation/ConfigurationImpl.java | 143 --
.../reef/tang/implementation/Constructor.java | 186 ---
.../implementation/InjectionFuturePlan.java | 64 -
.../reef/tang/implementation/InjectionPlan.java | 161 ---
.../tang/implementation/ListInjectionPlan.java | 106 --
.../tang/implementation/SetInjectionPlan.java | 106 --
.../tang/implementation/StackBindLocation.java | 46 -
.../reef/tang/implementation/Subplan.java | 188 ---
.../reef/tang/implementation/TangImpl.java | 161 ---
.../implementation/java/ClassHierarchyImpl.java | 448 ------
.../tang/implementation/java/InjectorImpl.java | 760 ----------
.../java/JavaConfigurationBuilderImpl.java | 238 ---
.../tang/implementation/java/JavaInstance.java | 75 -
.../implementation/java/JavaNodeFactory.java | 333 -----
.../tang/implementation/java/package-info.java | 29 -
.../reef/tang/implementation/package-info.java | 27 -
.../protobuf/ProtocolBufferClassHierarchy.java | 396 -----
.../protobuf/ProtocolBufferInjectionPlan.java | 148 --
.../implementation/protobuf/package-info.java | 25 -
.../tang/implementation/types/AbstractNode.java | 127 --
.../implementation/types/ClassNodeImpl.java | 141 --
.../types/ConstructorArgImpl.java | 77 -
.../types/ConstructorDefImpl.java | 150 --
.../types/NamedParameterNodeImpl.java | 86 --
.../implementation/types/PackageNodeImpl.java | 43 -
.../tang/implementation/types/package-info.java | 26 -
.../java/org/apache/reef/tang/package-info.java | 27 -
.../org/apache/reef/tang/types/ClassNode.java | 47 -
.../apache/reef/tang/types/ConstructorArg.java | 30 -
.../apache/reef/tang/types/ConstructorDef.java | 29 -
.../reef/tang/types/NamedParameterNode.java | 36 -
.../java/org/apache/reef/tang/types/Node.java | 42 -
.../org/apache/reef/tang/types/PackageNode.java | 23 -
.../org/apache/reef/tang/types/Traversable.java | 26 -
.../apache/reef/tang/types/package-info.java | 26 -
.../tang/util/AbstractMonotonicMultiMap.java | 206 ---
.../apache/reef/tang/util/MonotonicHashMap.java | 58 -
.../apache/reef/tang/util/MonotonicHashSet.java | 91 --
.../reef/tang/util/MonotonicMultiHashMap.java | 25 -
.../reef/tang/util/MonotonicMultiMap.java | 25 -
.../org/apache/reef/tang/util/MonotonicSet.java | 91 --
.../apache/reef/tang/util/MonotonicTreeMap.java | 119 --
.../reef/tang/util/ReflectionUtilities.java | 397 -----
.../java/org/apache/reef/tang/util/Tint.java | 735 ----------
.../reef/tang/util/TracingMonotonicMap.java | 25 -
.../reef/tang/util/TracingMonotonicTreeMap.java | 146 --
.../reef/tang/util/ValidateConfiguration.java | 150 --
.../org/apache/reef/tang/util/package-info.java | 24 -
.../walk/AbstractClassHierarchyNodeVisitor.java | 79 -
.../walk/AbstractInjectionPlanNodeVisitor.java | 80 --
.../apache/reef/tang/util/walk/EdgeVisitor.java | 35 -
.../apache/reef/tang/util/walk/NodeVisitor.java | 35 -
.../org/apache/reef/tang/util/walk/Walk.java | 66 -
.../walk/graphviz/GraphvizConfigVisitor.java | 244 ----
.../graphviz/GraphvizInjectionPlanVisitor.java | 168 ---
.../tang/util/walk/graphviz/package-info.java | 22 -
.../reef/tang/util/walk/package-info.java | 22 -
reef-tang/tang/src/main/proto/.gitignore | 1 -
.../tang/src/main/proto/class_hierarchy.proto | 167 ---
.../tang/src/main/proto/injection_plan.proto | 38 -
.../tang/ClassHierarchyDeserializationTest.java | 112 --
.../org/apache/reef/tang/TestBindSingleton.java | 420 ------
.../org/apache/reef/tang/TestClassLoaders.java | 118 --
.../apache/reef/tang/TestConfFileParser.java | 119 --
.../reef/tang/TestExternalConstructor.java | 89 --
.../reef/tang/TestImplicitConversions.java | 167 ---
.../apache/reef/tang/TestInjectionFuture.java | 195 ---
.../org/apache/reef/tang/TestListInjection.java | 344 -----
.../reef/tang/TestNamedParameterRoundTrip.java | 105 --
.../org/apache/reef/tang/TestSetInjection.java | 181 ---
.../java/org/apache/reef/tang/TestTang.java | 1356 ------------------
.../org/apache/reef/tang/TestTweetExample.java | 120 --
...onfigurationSerializerAvroRoundtripTest.java | 41 -
...urationSerializerByteArrayRoundtripTest.java | 42 -
...onfigurationSerializerFileRoundtripTest.java | 50 -
...figurationSerializerStringRoundtripTest.java | 40 -
...gurationSerializerTextFileRoundtripTest.java | 50 -
.../tang/formats/ConfigurationFileTest.java | 54 -
.../reef/tang/formats/NamedParameters.java | 38 -
.../reef/tang/formats/TestCommandLine.java | 79 -
.../tang/formats/TestConfigurationModule.java | 445 ------
.../tang/implementation/TestClassHierarchy.java | 642 ---------
.../java/TestConfigurationBuilder.java | 60 -
.../java/TestParameterParser.java | 245 ----
.../protobuf/TestClassHierarchyRoundTrip.java | 401 ------
.../org/apache/reef/tang/test/AnInterface.java | 29 -
.../tang/test/AnInterfaceImplementation.java | 52 -
.../apache/reef/tang/test/CyclicDependency.java | 56 -
.../tang/test/CyclicDependencyClassOne.java | 50 -
.../tang/test/CyclicDependencyClassTwo.java | 48 -
.../java/org/apache/reef/tang/test/Handler.java | 30 -
.../apache/reef/tang/test/InjectableClass.java | 47 -
.../apache/reef/tang/test/ListInterface.java | 23 -
.../reef/tang/test/ListInterfaceImplOne.java | 55 -
.../reef/tang/test/ListInterfaceImplTwo.java | 55 -
.../apache/reef/tang/test/ListOfBaseTypes.java | 82 --
.../reef/tang/test/ListOfImplementations.java | 55 -
.../apache/reef/tang/test/ObjectTreeTest.java | 61 -
.../reef/tang/test/RootImplementation.java | 166 ---
.../test/RootImplementationWithoutList.java | 155 --
.../apache/reef/tang/test/RootInterface.java | 31 -
.../apache/reef/tang/test/RoundTripTest.java | 56 -
.../org/apache/reef/tang/test/SetInterface.java | 27 -
.../reef/tang/test/SetInterfaceImplOne.java | 56 -
.../reef/tang/test/SetInterfaceImplTwo.java | 54 -
.../apache/reef/tang/test/SetOfBaseTypes.java | 85 --
.../reef/tang/test/SetOfImplementations.java | 55 -
.../reef/tang/test/TestConfiguration.java | 110 --
.../tang/test/TestConfigurationWithoutList.java | 92 --
.../org/apache/reef/tang/test/UnitClass.java | 119 --
.../org/apache/reef/tang/test/package-info.java | 22 -
reef-tang/tang/src/test/resources/Event.bin | Bin 24188 -> 0 bytes
reef-tang/tang/src/test/resources/Task.bin | Bin 128600 -> 0 bytes
reef-tests/pom.xml | 161 ---
.../assembly/test-jar-with-dependencies.xml | 38 -
.../apache/reef/tests/TestDriverLauncher.java | 132 --
.../tests/driver/DriverTestStartHandler.java | 43 -
.../apache/reef/tests/driver/package-info.java | 22 -
.../EvaluatorReuseTestDriver.java | 118 --
.../reef/tests/evaluatorreuse/package-info.java | 23 -
.../tests/fail/driver/DriverFailOnFail.java | 98 --
.../reef/tests/fail/driver/FailClient.java | 65 -
.../reef/tests/fail/driver/FailDriver.java | 371 -----
.../tests/fail/driver/FailDriverDelayedMsg.java | 128 --
.../apache/reef/tests/fail/driver/NoopTask.java | 117 --
.../org/apache/reef/tests/fail/task/Client.java | 57 -
.../org/apache/reef/tests/fail/task/Driver.java | 169 ---
.../apache/reef/tests/fail/task/FailTask.java | 49 -
.../reef/tests/fail/task/FailTaskCall.java | 46 -
.../reef/tests/fail/task/FailTaskClose.java | 65 -
.../reef/tests/fail/task/FailTaskMsg.java | 65 -
.../reef/tests/fail/task/FailTaskStart.java | 65 -
.../reef/tests/fail/task/FailTaskStop.java | 79 -
.../reef/tests/fail/task/FailTaskSuspend.java | 69 -
.../driver/ExpectedTaskFailureHandler.java | 59 -
.../driver/OnDriverStartedAllocateOne.java | 48 -
.../library/exceptions/ClientSideFailure.java | 40 -
.../library/exceptions/DriverSideFailure.java | 42 -
.../exceptions/ExpectedTaskException.java | 43 -
.../exceptions/SimulatedDriverFailure.java | 41 -
.../exceptions/SimulatedTaskFailure.java | 41 -
.../library/exceptions/TaskSideFailure.java | 41 -
.../exceptions/UnexpectedTaskReturnValue.java | 40 -
.../apache/reef/tests/library/package-info.java | 22 -
.../reef/tests/library/tasks/EchoTask.java | 38 -
.../reef/tests/library/tasks/NoopTask.java | 38 -
.../tests/messaging/driver/DriverMessaging.java | 173 ---
.../messaging/driver/DriverMessagingDriver.java | 87 --
.../messaging/task/TaskMessagingDriver.java | 98 --
.../tests/messaging/task/TaskMessagingTask.java | 83 --
.../apache/reef/tests/statepassing/Counter.java | 38 -
.../tests/statepassing/StatePassingDriver.java | 126 --
.../tests/statepassing/StatePassingTask.java | 50 -
.../reef/tests/yarn/failure/FailureDriver.java | 109 --
.../reef/tests/yarn/failure/FailureREEF.java | 120 --
.../org/apache/reef/tests/AllTestsSuite.java | 54 -
.../java/org/apache/reef/tests/FailureTest.java | 54 -
.../apache/reef/tests/LocalTestEnvironment.java | 68 -
.../apache/reef/tests/MesosTestEnvironment.java | 68 -
.../apache/reef/tests/ProbabilisticTests.java | 33 -
.../org/apache/reef/tests/TestEnvironment.java | 58 -
.../apache/reef/tests/TestEnvironmentBase.java | 39 -
.../reef/tests/TestEnvironmentFactory.java | 54 -
.../java/org/apache/reef/tests/TestUtils.java | 63 -
.../apache/reef/tests/YarnTestEnvironment.java | 60 -
.../tests/close_eval/CloseEvaluatorDriver.java | 65 -
.../tests/close_eval/CloseEvaluatorTest.java | 68 -
.../apache/reef/tests/driver/DriverTest.java | 68 -
.../tests/evaluatorexit/EvaluatorExitTest.java | 66 -
.../evaluatorexit/EvaluatorExitTestDriver.java | 79 -
.../evaluatorexit/EvaluatorExitTestTask.java | 39 -
.../reef/tests/evaluatorexit/package-info.java | 22 -
.../EvaluatorFailureDuringAlarmDriver.java | 106 --
.../evaluatorfailure/EvaluatorFailureTest.java | 75 -
.../evaluatorfailure/ExpectedException.java | 25 -
.../FailureSchedulingContextStartHandler.java | 52 -
.../tests/evaluatorfailure/package-info.java | 22 -
.../evaluatorreuse/EvaluatorReuseTest.java | 72 -
.../tests/evaluatorsize/EvaluatorSizeTest.java | 79 -
.../EvaluatorSizeTestConfiguration.java | 38 -
.../evaluatorsize/EvaluatorSizeTestDriver.java | 97 --
.../tests/evaluatorsize/MemorySizeTask.java | 49 -
.../reef/tests/evaluatorsize/package-info.java | 22 -
.../reef/tests/examples/ExamplesTestSuite.java | 33 -
.../reef/tests/examples/TestHelloREEF.java | 61 -
.../tests/examples/TestRetainedEvaluators.java | 81 --
.../reef/tests/examples/package-info.java | 22 -
.../reef/tests/fail/DriverFailOnFailTest.java | 71 -
.../tests/fail/FailDriverDelayedMsgTest.java | 73 -
.../apache/reef/tests/fail/FailDriverTest.java | 133 --
.../apache/reef/tests/fail/FailTaskTest.java | 93 --
.../apache/reef/tests/fail/FailTestSuite.java | 32 -
.../reef/tests/files/FileResourceTest.java | 144 --
.../tests/files/FileResourceTestDriver.java | 127 --
.../FileResourceTestDriverConfiguration.java | 40 -
.../reef/tests/files/FileResourceTestTask.java | 67 -
.../FileResourceTestTaskConfiguration.java | 44 -
.../apache/reef/tests/files/package-info.java | 22 -
.../messaging/driver/DriverMessagingTest.java | 51 -
.../tests/messaging/driver/package-info.java | 22 -
.../tests/messaging/task/TaskMessagingTest.java | 72 -
.../reef/tests/messaging/task/package-info.java | 22 -
.../ActiveContextHandler.java | 63 -
.../AllocatedEvaluatorHandler.java | 60 -
.../multipleEventHandlerInstances/Client.java | 76 -
.../ClosedContextHandler.java | 51 -
.../CompletedEvaluatorHandler.java | 52 -
.../CompletedTaskHandler.java | 51 -
.../EmptyTask.java | 39 -
.../RunningTaskHandler.java | 51 -
.../StartHandler.java | 62 -
.../tests/roguethread/RogueThreadDriver.java | 50 -
.../reef/tests/roguethread/RogueThreadTask.java | 44 -
.../reef/tests/roguethread/RogueThreadTest.java | 70 -
.../reef/tests/roguethread/package-info.java | 22 -
.../tests/statepassing/StatePassingTest.java | 71 -
.../reef/tests/statepassing/package-info.java | 22 -
.../tests/subcontexts/ContextStartHandler1.java | 39 -
.../tests/subcontexts/ContextStartHandler2.java | 38 -
.../tests/subcontexts/ContextStopHandler1.java | 38 -
.../tests/subcontexts/ContextStopHandler2.java | 38 -
.../tests/subcontexts/SubContextDriver.java | 143 --
.../reef/tests/subcontexts/SubContextTest.java | 93 --
.../reef/tests/subcontexts/package-info.java | 22 -
.../tests/taskcounting/TaskCountingDriver.java | 109 --
.../tests/taskcounting/TaskCountingTest.java | 70 -
.../reef/tests/taskcounting/package-info.java | 22 -
.../tests/taskresubmit/TaskResubmitDriver.java | 85 --
.../tests/taskresubmit/TaskResubmitTest.java | 72 -
.../reef/tests/taskresubmit/package-info.java | 22 -
reef-utils-hadoop/pom.xml | 45 -
.../org/apache/reef/util/HadoopEnvironment.java | 37 -
.../apache/reef/util/logging/DFSHandler.java | 146 --
reef-utils/pom.xml | 45 -
.../java/org/apache/reef/util/Optional.java | 128 --
.../java/org/apache/reef/util/package-info.java | 22 -
.../java/org/apache/reef/util/OptionalTest.java | 99 --
reef-wake/.gitattributes | 3 -
reef-wake/.gitignore | 16 -
reef-wake/README.md | 94 --
reef-wake/pom.xml | 38 -
reef-wake/wake/pom.xml | 123 --
.../org/apache/reef/wake/AbstractEStage.java | 91 --
.../apache/reef/wake/ComparableIdentifier.java | 27 -
.../main/java/org/apache/reef/wake/EStage.java | 27 -
.../java/org/apache/reef/wake/EventHandler.java | 34 -
.../java/org/apache/reef/wake/Identifiable.java | 30 -
.../java/org/apache/reef/wake/Identifier.java | 54 -
.../org/apache/reef/wake/IdentifierFactory.java | 31 -
.../org/apache/reef/wake/IdentifierParser.java | 55 -
.../main/java/org/apache/reef/wake/Stage.java | 25 -
.../apache/reef/wake/StageConfiguration.java | 68 -
.../org/apache/reef/wake/WakeConfiguration.java | 62 -
.../org/apache/reef/wake/WakeParameters.java | 46 -
.../wake/examples/accumulate/CombinerStage.java | 161 ---
.../reef/wake/examples/join/BlockingJoin.java | 95 --
.../reef/wake/examples/join/EventPrinter.java | 39 -
.../wake/examples/join/NonBlockingJoin.java | 121 --
.../reef/wake/examples/join/TupleEvent.java | 45 -
.../reef/wake/examples/join/TupleSource.java | 58 -
.../reef/wake/examples/join/package-info.java | 22 -
.../reef/wake/examples/p2p/EventSource.java | 33 -
.../reef/wake/examples/p2p/Pull2Push.java | 94 --
.../reef/wake/examples/p2p/package-info.java | 22 -
.../apache/reef/wake/examples/package-info.java | 22 -
.../wake/exception/WakeRuntimeException.java | 56 -
.../reef/wake/exception/package-info.java | 22 -
.../reef/wake/impl/BlockingEventHandler.java | 79 -
.../wake/impl/BlockingSignalEventHandler.java | 56 -
.../wake/impl/DefaultIdentifierFactory.java | 90 --
.../reef/wake/impl/DefaultThreadFactory.java | 85 --
.../apache/reef/wake/impl/ForkPoolStage.java | 103 --
.../IndependentIterationsThreadPoolStage.java | 80 --
.../reef/wake/impl/LoggingEventHandler.java | 49 -
.../org/apache/reef/wake/impl/LoggingUtils.java | 52 -
.../reef/wake/impl/LoggingVoidEventHandler.java | 47 -
.../reef/wake/impl/MergingEventHandler.java | 152 --
.../wake/impl/MissingStartHandlerHandler.java | 43 -
.../reef/wake/impl/MultiEventHandler.java | 60 -
.../reef/wake/impl/OpaqueLocalIdentifier.java | 28 -
.../apache/reef/wake/impl/PeriodicEvent.java | 25 -
.../reef/wake/impl/PubSubEventHandler.java | 105 --
.../reef/wake/impl/SingleThreadStage.java | 144 --
.../org/apache/reef/wake/impl/StageManager.java | 78 -
.../org/apache/reef/wake/impl/SyncStage.java | 113 --
.../apache/reef/wake/impl/ThreadPoolStage.java | 223 ---
.../org/apache/reef/wake/impl/TimerStage.java | 135 --
.../apache/reef/wake/impl/WakeSharedPool.java | 108 --
.../wake/impl/WakeUncaughtExceptionHandler.java | 46 -
.../org/apache/reef/wake/impl/package-info.java | 22 -
.../java/org/apache/reef/wake/metrics/EWMA.java | 79 -
.../reef/wake/metrics/EWMAParameters.java | 35 -
.../org/apache/reef/wake/metrics/Histogram.java | 55 -
.../org/apache/reef/wake/metrics/Meter.java | 147 --
.../reef/wake/metrics/UniformHistogram.java | 90 --
.../apache/reef/wake/metrics/package-info.java | 22 -
.../java/org/apache/reef/wake/package-info.java | 22 -
.../org/apache/reef/wake/profiler/Vertex.java | 100 --
.../apache/reef/wake/profiler/WakeProfiler.java | 321 -----
.../java/org/apache/reef/wake/remote/Codec.java | 28 -
.../org/apache/reef/wake/remote/Decoder.java | 36 -
.../reef/wake/remote/DefaultErrorHandler.java | 38 -
.../org/apache/reef/wake/remote/Encoder.java | 36 -
.../org/apache/reef/wake/remote/NetUtils.java | 106 --
.../reef/wake/remote/RemoteConfiguration.java | 71 -
.../reef/wake/remote/RemoteIdentifier.java | 27 -
.../wake/remote/RemoteIdentifierFactory.java | 41 -
.../apache/reef/wake/remote/RemoteManager.java | 91 --
.../apache/reef/wake/remote/RemoteMessage.java | 42 -
.../exception/RemoteRuntimeException.java | 54 -
.../wake/remote/exception/package-info.java | 22 -
.../apache/reef/wake/remote/impl/ByteCodec.java | 50 -
.../wake/remote/impl/ConnectFutureTask.java | 40 -
...ltRemoteIdentifierFactoryImplementation.java | 47 -
.../DefaultRemoteManagerImplementation.java | 229 ---
.../wake/remote/impl/DefaultRemoteMessage.java | 65 -
.../reef/wake/remote/impl/HandlerContainer.java | 154 --
.../reef/wake/remote/impl/MultiCodec.java | 75 -
.../reef/wake/remote/impl/MultiDecoder.java | 72 -
.../reef/wake/remote/impl/MultiEncoder.java | 64 -
.../remote/impl/ObjectSerializableCodec.java | 72 -
.../remote/impl/OrderedRemoteReceiverStage.java | 201 ---
.../wake/remote/impl/ProxyEventHandler.java | 89 --
.../reef/wake/remote/impl/RemoteEvent.java | 170 ---
.../reef/wake/remote/impl/RemoteEventCodec.java | 65 -
.../wake/remote/impl/RemoteEventComparator.java | 37 -
.../wake/remote/impl/RemoteEventDecoder.java | 62 -
.../wake/remote/impl/RemoteEventEncoder.java | 68 -
.../remote/impl/RemoteReceiverEventHandler.java | 61 -
.../wake/remote/impl/RemoteReceiverStage.java | 99 --
.../remote/impl/RemoteSenderEventHandler.java | 165 ---
.../wake/remote/impl/RemoteSenderStage.java | 91 --
.../wake/remote/impl/RemoteSeqNumGenerator.java | 49 -
.../remote/impl/SocketRemoteIdentifier.java | 111 --
.../reef/wake/remote/impl/StringCodec.java | 50 -
.../reef/wake/remote/impl/Subscription.java | 61 -
.../reef/wake/remote/impl/TransportEvent.java | 106 --
.../apache/reef/wake/remote/impl/Tuple2.java | 59 -
.../reef/wake/remote/impl/package-info.java | 22 -
.../apache/reef/wake/remote/package-info.java | 22 -
.../apache/reef/wake/remote/transport/Link.java | 52 -
.../wake/remote/transport/LinkListener.java | 34 -
.../reef/wake/remote/transport/Transport.java | 77 -
.../exception/TransportRuntimeException.java | 54 -
.../transport/exception/package-info.java | 22 -
.../netty/AbstractNettyEventListener.java | 99 --
.../remote/transport/netty/ByteEncoder.java | 36 -
.../netty/ChunkedReadWriteHandler.java | 191 ---
.../remote/transport/netty/LinkReference.java | 48 -
.../transport/netty/LoggingLinkListener.java | 46 -
.../transport/netty/NettyChannelHandler.java | 114 --
.../netty/NettyChannelHandlerFactory.java | 35 -
.../netty/NettyChannelInitializer.java | 52 -
.../netty/NettyClientEventListener.java | 56 -
.../NettyDefaultChannelHandlerFactory.java | 49 -
.../transport/netty/NettyEventListener.java | 57 -
.../wake/remote/transport/netty/NettyLink.java | 117 --
.../netty/NettyMessagingTransport.java | 329 -----
.../netty/NettyServerEventListener.java | 65 -
.../remote/transport/netty/package-info.java | 22 -
.../wake/remote/transport/package-info.java | 22 -
.../apache/reef/wake/rx/AbstractObserver.java | 43 -
.../apache/reef/wake/rx/AbstractRxStage.java | 86 --
.../apache/reef/wake/rx/DynamicObservable.java | 36 -
.../org/apache/reef/wake/rx/Observable.java | 25 -
.../java/org/apache/reef/wake/rx/Observer.java | 50 -
.../java/org/apache/reef/wake/rx/RxStage.java | 29 -
.../apache/reef/wake/rx/StaticObservable.java | 26 -
.../java/org/apache/reef/wake/rx/Subject.java | 29 -
.../exception/ObserverCompletedException.java | 38 -
.../reef/wake/rx/exception/package-info.java | 22 -
.../apache/reef/wake/rx/impl/RxSyncStage.java | 104 --
.../reef/wake/rx/impl/RxThreadPoolStage.java | 198 ---
.../apache/reef/wake/rx/impl/SimpleSubject.java | 73 -
.../reef/wake/rx/impl/TimeoutSubject.java | 84 --
.../apache/reef/wake/rx/impl/package-info.java | 22 -
.../org/apache/reef/wake/rx/package-info.java | 22 -
.../reef/wake/storage/FileHandlePool.java | 31 -
.../reef/wake/storage/FileIdentifier.java | 49 -
.../apache/reef/wake/storage/ReadRequest.java | 41 -
.../apache/reef/wake/storage/ReadResponse.java | 33 -
.../reef/wake/storage/SequentialFileReader.java | 61 -
.../reef/wake/storage/StorageIdentifier.java | 25 -
.../java/org/apache/reef/wake/time/Clock.java | 107 --
.../java/org/apache/reef/wake/time/Time.java | 62 -
.../org/apache/reef/wake/time/event/Alarm.java | 40 -
.../apache/reef/wake/time/event/StartTime.java | 32 -
.../apache/reef/wake/time/event/StopTime.java | 32 -
.../reef/wake/time/event/package-info.java | 22 -
.../org/apache/reef/wake/time/package-info.java | 22 -
.../reef/wake/time/runtime/LogicalTimer.java | 48 -
.../reef/wake/time/runtime/RealTimer.java | 43 -
.../reef/wake/time/runtime/RuntimeClock.java | 244 ----
.../apache/reef/wake/time/runtime/Timer.java | 30 -
.../wake/time/runtime/event/ClientAlarm.java | 29 -
.../reef/wake/time/runtime/event/IdleClock.java | 28 -
.../wake/time/runtime/event/RuntimeAlarm.java | 30 -
.../wake/time/runtime/event/RuntimeStart.java | 29 -
.../wake/time/runtime/event/RuntimeStop.java | 40 -
.../wake/time/runtime/event/package-info.java | 22 -
.../reef/wake/time/runtime/package-info.java | 22 -
.../wake/src/main/proto/RemoteProtocol.proto | 35 -
.../com/microsoft/wake/logging.properties | 81 --
.../wake/test/BlockingEventHandlerTest.java | 196 ---
.../test/BlockingSignalEventHandlerTest.java | 166 ---
.../reef/wake/test/ForkPoolStageTest.java | 226 ---
...ndependentIterationsThreadPoolStageTest.java | 84 --
.../reef/wake/test/MergingEventHandlerTest.java | 237 ---
.../org/apache/reef/wake/test/MetricsTest.java | 52 -
.../wake/test/PubSubThreadPoolStageTest.java | 115 --
.../apache/reef/wake/test/StageManagerTest.java | 48 -
.../apache/reef/wake/test/SyncStageTest.java | 130 --
.../reef/wake/test/ThreadPoolStageTest.java | 221 ---
.../apache/reef/wake/test/TimerStageTest.java | 82 --
.../reef/wake/test/examples/SkipListTest.java | 378 -----
.../wake/test/examples/TestBlockingJoin.java | 39 -
.../reef/wake/test/examples/TestCombiner.java | 129 --
.../reef/wake/test/examples/TestJoin.java | 38 -
.../wake/test/examples/TestTupleSource.java | 34 -
.../org/apache/reef/wake/test/package-info.java | 22 -
.../reef/wake/test/remote/LargeMsgTest.java | 141 --
.../remote/RemoteIdentifierFactoryTest.java | 86 --
.../wake/test/remote/RemoteManagerTest.java | 462 ------
.../reef/wake/test/remote/RemoteTest.java | 211 ---
.../wake/test/remote/SmallMessagesTest.java | 161 ---
.../reef/wake/test/remote/StartEvent.java | 25 -
.../apache/reef/wake/test/remote/TestEvent.java | 47 -
.../reef/wake/test/remote/TestEvent1.java | 29 -
.../reef/wake/test/remote/TestEvent2.java | 30 -
.../reef/wake/test/remote/TestEventCodec.java | 52 -
.../reef/wake/test/remote/TestRemote.java | 68 -
.../wake/test/remote/TestRemoteIdentifier.java | 48 -
.../wake/test/remote/TransportRaceTest.java | 104 --
.../reef/wake/test/remote/TransportTest.java | 144 --
.../reef/wake/test/remote/package-info.java | 22 -
.../org/apache/reef/wake/test/rx/RxTest.java | 90 --
.../wake/test/rx/RxThreadPoolStageTest.java | 194 ---
.../reef/wake/test/rx/TimeoutSubjectTest.java | 143 --
.../apache/reef/wake/test/rx/package-info.java | 22 -
.../apache/reef/wake/test/time/ClockTest.java | 205 ---
.../reef/wake/test/time/package-info.java | 22 -
.../org/apache/reef/wake/test/util/Monitor.java | 41 -
.../reef/wake/test/util/PassThroughEncoder.java | 36 -
.../reef/wake/test/util/TimeoutHandler.java | 36 -
.../reef/wake/test/util/package-info.java | 22 -
reef-wake/wake/src/test/proto/TestEvent1.proto | 28 -
.../wake/src/test/proto/TestProtocol.proto | 28 -
reef-webserver/pom.xml | 107 --
reef-webserver/src/main/avro/DriverInfo.avsc | 43 -
reef-webserver/src/main/avro/EvaluatorInfo.avsc | 45 -
reef-webserver/src/main/avro/EvaluatorList.avsc | 43 -
reef-webserver/src/main/avro/webRequest.avsc | 29 -
.../webserver/AvroDriverInfoSerializer.java | 68 -
.../webserver/AvroEvaluatorInfoSerializer.java | 101 --
.../webserver/AvroEvaluatorListSerializer.java | 85 --
.../reef/webserver/AvroHttpSerializer.java | 108 --
.../reef/webserver/DriverInfoSerializer.java | 46 -
.../reef/webserver/EvaluatorInfoSerializer.java | 40 -
.../reef/webserver/EvaluatorListSerializer.java | 48 -
.../reef/webserver/HttpEventHandlers.java | 31 -
.../org/apache/reef/webserver/HttpHandler.java | 50 -
.../webserver/HttpHandlerConfiguration.java | 43 -
.../webserver/HttpRuntimeConfiguration.java | 37 -
.../reef/webserver/HttpRuntimeStartHandler.java | 68 -
.../reef/webserver/HttpRuntimeStopHandler.java | 67 -
.../org/apache/reef/webserver/HttpServer.java | 55 -
.../apache/reef/webserver/HttpServerImpl.java | 149 --
.../webserver/HttpServerReefEventHandler.java | 388 -----
.../reef/webserver/HttpTrackingURLProvider.java | 67 -
.../org/apache/reef/webserver/JettyHandler.java | 159 --
.../apache/reef/webserver/MaxPortNumber.java | 29 -
.../apache/reef/webserver/MaxRetryAttempts.java | 29 -
.../apache/reef/webserver/MinPortNumber.java | 29 -
.../reef/webserver/ParsedHttpRequest.java | 194 ---
.../org/apache/reef/webserver/PortNumber.java | 31 -
.../reef/webserver/ReefEventStateManager.java | 308 ----
.../reef/webserver/TestAvroHttpSerializer.java | 153 --
.../webserver/TestAvroSerializerForHttp.java | 179 ---
.../reef/webserver/TestHttpConfiguration.java | 204 ---
.../apache/reef/webserver/TestHttpServer.java | 169 ---
.../apache/reef/webserver/TestJettyHandler.java | 166 ---
.../reef/webserver/TestParsedHttpRequest.java | 101 --
.../reef/webserver/TestReefEventHandler.java | 84 --
.../webserver/TestReefEventStateManager.java | 146 --
.../reef/webserver/TestRuntimeStartHandler.java | 104 --
.../apache/reef/webserver/TestTrackingUri.java | 113 --
2682 files changed, 110107 insertions(+), 110107 deletions(-)
----------------------------------------------------------------------