Apache REEF
0.16.0
Retainable Evaluator Execution Framework
File List
Here is a list of all files with brief descriptions:
[detail level
1
2
3
4
5
6
7
]
▼
lang
▼
cs
►
Org.Apache.REEF.All
►
Properties
AssemblyInfo.cs
►
Org.Apache.REEF.Bridge.CLR
►
Message
Acknowledgement.cs
Protocol.cs
SystemOnStart.cs
►
Org.Apache.REEF.Client
►
API
►
Exceptions
ClasspathException.cs
JavaNotFoundException.cs
AppParameters.cs
AppParametersBuilder.cs
ClientFactory.cs
IREEFClient.cs
JobParameters.cs
JobParametersBuilder.cs
JobRequest.cs
JobRequestBuilder.cs
TcpPortConfigurationModule.cs
►
Avro
►
Local
AvroLocalAppSubmissionParameters.cs
AvroLocalJobSubmissionParameters.cs
►
YARN
AvroYarnAppSubmissionParameters.cs
AvroYarnClusterJobSubmissionParameters.cs
AvroYarnJobSubmissionParameters.cs
AvroAppSubmissionParameters.cs
AvroJobSubmissionParameters.cs
►
Common
ClientConstants.cs
DotNetFile.cs
DriverFolderPreparationHelper.cs
EnvironmentDriverConfigurationProviders.cs
FileSets.cs
IFile.cs
IJavaClientLauncher.cs
IJobSubmissionResult.cs
IResourceArchiveFileGenerator.cs
JavaClientLauncher.cs
JobSubmissionResult.cs
ResourceArchiveFileGenerator.cs
►
Local
►
Parameters
LocalRuntimeDirectory.cs
NumberOfEvaluators.cs
LocalClient.cs
LocalDriverConfigurationProvider.cs
LocalJobSubmissionResult.cs
LocalRuntimeClientConfiguration.cs
►
Properties
AssemblyInfo.cs
►
YARN
►
HDI
HDInsightClientConfiguration.cs
HDInsightCommandLineEnvironment.cs
HDInsightCredential.cs
HDInsightResourceFileRemoteUrlToClusterUrlConverter.cs
HDInsightUrlProvider.cs
NamedParameters.cs
►
Parameters
DriverMaxMemoryAllicationPoolSizeMB.cs
DriverMaxPermSizeMB.cs
DriverStderrFilePath.cs
DriverStdoutFilePath.cs
EnableDebugLogging.cs
FileSystemUrl.cs
JobSubmissionDirectoryPrefixParameter.cs
SecurityTokenParameters.cs
►
RESTClient
►
DataModel
Acls.cs
AmContainerSpec.cs
Application.cs
ApplicationFinalState.cs
Applications.cs
ApplicationState.cs
ApplicationTag.cs
ClusterHaState.cs
ClusterInfo.cs
ClusterMetrics.cs
ClusterState.cs
Commands.cs
Credentials.cs
Environment.cs
Error.cs
KeyValuePair.cs
LocalResources.cs
NewApplication.cs
Resouce.cs
Secrets.cs
ServiceData.cs
SubmitApplication.cs
Tokens.cs
FileSystemJobResourceUploader.cs
HttpClient.cs
HttpClientRetryHandler.cs
IDeserializer.cs
IHttpClient.cs
IRequestFactory.cs
IRestClient.cs
IRestRequestExecutor.cs
ISerializer.cs
IUrlProvider.cs
IYarnRestClientCredential.cs
IYarnRMClient.cs
Method.cs
MultipleRMUrlProvider.cs
NullYarnRestClientCredential.cs
RequestFactory.cs
RestClient.cs
RestJsonDeserializer.cs
RestJsonSerializer.cs
RestRequest.cs
RestRequestExecutor.cs
RestResponse.cs
YarnClient.cs
YarnClientNoCancellationToken.cs
YarnConfigurationUrlProvider.cs
YarnRestAPIException.cs
IdentityResourceFileRemoteUrlToClusterUrlConverter.cs
IJobResourceUploader.cs
IJobSubmissionDirectoryProvider.cs
IResourceFileRemoteUrlToClusterUrlConverter.cs
IYarnCommandLineEnvironment.cs
IYarnJobCommandProvider.cs
JobResource.cs
JobSubmissionDirectoryProvider.cs
LegacyJobResourceUploader.cs
WindowsYarnJobCommandProvider.cs
YARNClientConfiguration.cs
YarnCommandLineEnvironment.cs
YarnCommandProviderConfiguration.cs
YarnJobSubmissionResult.cs
YARNREEFClient.cs
YarnREEFDotNetClient.cs
YarnREEFDotNetParamSerializer.cs
YarnREEFParamSerializer.cs
►
Org.Apache.REEF.Common
►
Api
AbstractFailure.cs
IAbstractFailure.cs
IFailure.cs
►
Avro
AvroDriverInfo.cs
AvroFailedTask.cs
AvroHttpRequest.cs
AvroHttpSerializer.cs
AvroJsonSerializer.cs
AvroReefServiceInfo.cs
HeaderEntry.cs
►
Catalog
►
Capabilities
CPU.cs
ICapability.cs
RAM.cs
INodeDescriptor.cs
IRackDescriptor.cs
IResourceCatalog.cs
NodeDescriptorImpl.cs
RackDescriptorImpl.cs
ResourceCatalogImpl.cs
►
Client
►
Parameters
DriverConfigurationProviders.cs
►
Context
►
Defaults
DefaultContextMessageSource.cs
DefaultContextStartHandler.cs
DefaultContextStopHandler.cs
ContextConfiguration.cs
ContextConfigurationOptions.cs
ContextMessage.cs
IContextMessage.cs
IContextMessageHandler.cs
IContextMessageSource.cs
►
Evaluator
►
DriverConnectionConfigurationProviders
DefaultDriverReconnConfigProvider.cs
IDriverReconnConfigProvider.cs
LocalHttpDriverReconnConfigProvider.cs
YarnClusterHttpDriverReconnConfigProvider.cs
YarnOneBoxHttpDriverReconnConfigProvider.cs
►
Parameters
EvaluatorConfigurationProviders.cs
DefaultLocalHttpDriverConnection.cs
DefaultYarnClusterHttpDriverConnection.cs
DefaultYarnOneBoxHttpDriverConnection.cs
DriverInformation.cs
EvaluatorOperationState.cs
EvaluatorRuntimeState.cs
EvaluatorType.cs
IDriverConnection.cs
MissingDriverConnection.cs
►
Events
IContextStart.cs
IContextStop.cs
►
Exceptions
JobException.cs
NonSerializableEvaluatorException.cs
NonSerializableTaskException.cs
RecoverableNetworkException.cs
►
Files
PathUtilities.cs
REEFFileNames.cs
►
Io
INameClient.cs
NameAssignment.cs
NamingConfiguration.cs
NamingConfigurationOptions.cs
TcpPortConfigurationProvider.cs
►
Jar
ResourceHelper.cs
►
metrics
►
Api
IImmutableMetric.cs
IMetricsCollector.cs
IMetricsFilter.cs
IMetricsInfo.cs
IMetricsRecord.cs
IMetricsRecordBuilder.cs
IMetricsSource.cs
IMetricsSystem.cs
IMetricsVisitor.cs
ImmutableMetricImpl.cs
MetricsException.cs
MetricsInfoImpl.cs
MetricsTag.cs
MetricType.cs
SnapshotRequest.cs
►
MetricsSystem
DefaultMetricsFilter.cs
IMetricsCollectorMutable.cs
ImmutableCounter.cs
ImmutableDoubleGauge.cs
ImmutableLongGauge.cs
MetricsCollectorMutable.cs
MetricsRecord.cs
MetricsRecordBuilder.cs
MetricsSystemConstants.cs
►
MutableMetricsLayer
DefaultMetricsFactoryImpl.cs
DefaultMetricsSourceConfiguration.cs
DefaultMetricsSourceImpl.cs
DefaultMetricsSourceParameters.cs
ICounter.cs
IDoubleGauge.cs
IExtendedMutableMetric.cs
ILongGauge.cs
IMetricContainer.cs
IMetricsFactory.cs
IMutableMetric.cs
IRate.cs
IStat.cs
MutableCounter.cs
MutableDoubleGauge.cs
MutableLongGauge.cs
MutableMetricBase.cs
MutableMetricContainer.cs
MutableRate.cs
MutableStat.cs
StatsHelperClass.cs
►
Poison
PoisonedEventHandler.cs
►
Properties
AssemblyInfo.cs
AssemblyInfo.DotNet.cs
►
Protobuf
►
ReefProtocol
ClientRuntime.pb.cs
DriverRuntime.pb.cs
EvaluatorHeartbeatProtoCodec.cs
EvaluatorRunTime.pb.cs
REEFMessageCodec.cs
ReefProtocol.pb.cs
ReefService.pb.cs
Serializer.cs
►
Runtime
►
Evaluator
►
Context
ContextClientCodeException.cs
ContextException.cs
ContextLifeCycle.cs
ContextManager.cs
ContextRuntime.cs
ContextStartHandlerException.cs
ContextStartImpl.cs
ContextStopHandlerException.cs
ContextStopImpl.cs
RootContextLauncher.cs
►
Parameters
EvaluatorHeartbeatPeriodInMs.cs
HeartbeatMaxRetry.cs
HeartbeatMaxRetryForNonRecoveryMode.cs
►
Task
CloseEventImpl.cs
DriverMessageImpl.cs
SuspendEventImpl.cs
TaskClientCodeException.cs
TaskLifeCycle.cs
TaskRuntime.cs
TaskStartHandlerException.cs
TaskStartImpl.cs
TaskState.cs
TaskStatus.cs
TaskStopHandlerException.cs
TaskStopImpl.cs
►
Utils
NamedparameterAlias.cs
Constants.cs
EvaluatorExitLogger.cs
EvaluatorRuntime.cs
EvaluatorSettings.cs
HeartBeatManager.cs
IHeartBeatManager.cs
PIDStoreHandler.cs
ReefMessageProtoObserver.cs
MachineStatus.cs
RuntimeName.cs
►
Services
ServiceConfiguration.cs
►
Tasks
►
Defaults
DefaultDriverConnectionMessageHandler.cs
DefaultDriverMessageHandler.cs
DefaultSuspendHandler.cs
DefaultTaskCloseHandler.cs
DefaultTaskMessageSource.cs
►
Events
ICloseEvent.cs
IDriverMessage.cs
ISuspendEvent.cs
ITaskStart.cs
ITaskStop.cs
►
Exceptions
TaskCloseHandlerNotBoundException.cs
DriverConnectionMessageImpl.cs
DriverConnectionState.cs
IDriverConnectionMessage.cs
IDriverConnectionMessageHandler.cs
IDriverMessageHandler.cs
ITask.cs
ITaskMessageSource.cs
TaskConfiguration.cs
TaskConfigurationOptions.cs
TaskMessage.cs
►
Telemetry
Counter.cs
CounterData.cs
Counters.cs
CountersData.cs
CounterSinkThreshold.cs
DefaultMetricsSink.cs
EvaluatorMetrics.cs
ICounter.cs
ICounters.cs
IEvaluatorMetrics.cs
IMetricsSink.cs
MessageSenderConfigurationModule.cs
MetricSinks.cs
MetricsMessageSender.cs
MetricsService.cs
Constants.cs
IContextAndTaskSubmittable.cs
IContextSubmittable.cs
ITaskSubmittable.cs
►
Org.Apache.REEF.Driver
►
Bridge
►
Avro
DefinedRuntimes.cs
DefinedRuntimesSerializer.cs
►
Clr2java
IActiveContextClr2Java.cs
IAllocatedEvaluatorClr2Java.cs
IClosedContextClr2Java.cs
IClr2Java.cs
IClr2JavaTaskMessage.cs
ICompletedEvaluatorClr2Java.cs
ICompletedTaskClr2Java.cs
IContextMessageClr2Java.cs
IDriverRestartCompletedClr2Java.cs
IDriverRestartedClr2Java.cs
IEvaluatorRequestorClr2Java.cs
IFailedContextClr2Java.cs
IFailedEvaluatorClr2Java.cs
IFailedTaskClr2Java.cs
IHttpServerBridgeClr2Java.cs
IRunningTaskClr2Java.cs
ISuspendedTaskClr2Java.cs
ITaskMessageClr2Java.cs
►
Events
ActiveContext.cs
AllocatedEvaluator.cs
ClosedContext.cs
CompletedEvaluator.cs
CompletedTask.cs
ContextMessage.cs
DriverRestartCompleted.cs
DriverRestarted.cs
DriverStarted.cs
EvaluatorRequestor.cs
FailedContext.cs
FailedEvaluator.cs
FailedTask.cs
RunningTask.cs
SuspendedTask.cs
TaskMessage.cs
BridgeConfigurationProvider.cs
BridgeHandlerManager.cs
BridgeLogger.cs
ClrClientHelper.cs
ClrHandlerHelper.cs
ClrSystemHandler.cs
ClrSystemHandlerWrapper.cs
CommandLineArguments.cs
CustomTraceLevel.cs
CustomTraceListeners.cs
DriverBridge.cs
DriverBridgeConfigurationOptions.cs
EvaluatorLogLevelProvider.cs
HttpMessage.cs
HttpServerHandler.cs
HttpServerPort.cs
IHttpHandler.cs
IHttpMessage.cs
ILogger.cs
ReefHttpRequest.cs
ReefHttpResponse.cs
►
Context
IActiveContext.cs
IClosedContext.cs
IContext.cs
IFailedContext.cs
►
Defaults
DefaultClientCloseHandler.cs
DefaultClientCloseWithMessageHandler.cs
DefaultClientMessageHandler.cs
DefaultContextActiveHandler.cs
DefaultContextClosureHandler.cs
DefaultContextFailureHandler.cs
DefaultContextMessageHandler.cs
DefaultCustomTraceListener.cs
DefaultDriverRestartCompletedHandler.cs
DefaultDriverRestartContextActiveHandler.cs
DefaultDriverRestartedHandler.cs
DefaultDriverRestartHandler.cs
DefaultDriverRestartTaskRunningHandler.cs
DefaultEvaluatorAllocationHandler.cs
DefaultEvaluatorCompletionHandler.cs
DefaultEvaluatorFailureHandler.cs
DefaultHttpHandler.cs
DefaultProgressProvider.cs
DefaultTaskCompletionHandler.cs
DefaultTaskFailureHandler.cs
DefaultTaskMessageHandler.cs
DefaultTaskRunningHandler.cs
DefaultTaskSuspensionHandler.cs
►
Evaluator
EvaluatorDescriptorImpl.cs
EvaluatorException.cs
EvaluatorRequest.cs
EvaluatorRequestBuilder.cs
IAllocatedEvaluator.cs
ICompletedEvaluator.cs
IEvaluatorDescriptor.cs
IEvaluatorRequest.cs
IEvaluatorRequestor.cs
IFailedEvaluator.cs
►
Properties
AssemblyInfo.cs
AssemblyInfo.DotNet.cs
►
Task
ICompletedTask.cs
IFailedTask.cs
IRunningTask.cs
ISuspendedTask.cs
ITaskMessage.cs
JavaTaskException.cs
TaskExceptionMissingException.cs
Constants.cs
DriverConfigGenerator.cs
DriverConfiguration.cs
DriverConfigurationSettings.cs
IDriver.cs
IDriverRestartCompleted.cs
IDriverRestarted.cs
IDriverStarted.cs
IJobCancelled.cs
IProgressProvider.cs
MetricsServiceConfigurationModule.cs
►
Org.Apache.REEF.Evaluator
►
Exceptions
ClockInstantiationException.cs
EvaluatorConfigurationFileNotFoundException.cs
EvaluatorConfigurationParseException.cs
EvaluatorInjectorInstantiationException.cs
UnhandledException.cs
►
Properties
AssemblyInfo.cs
AssemblyInfo.DotNet.cs
Evaluator.cs
►
Org.Apache.REEF.FatNuGet
►
Properties
AssemblyInfo.cs
►
Org.Apache.REEF.IMRU
►
API
IIMRUClient.cs
IIMRUResultHandler.cs
IJobCancelledDetector.cs
IMapFunction.cs
IMRUCodecConfiguration.cs
IMRUJobDefinition.cs
IMRUJobDefinitionBuilder.cs
IMRUMapConfiguration.cs
IMRUPerMapperConfigGeneratorConfiguration.cs
IMRUPipelineDataConverterConfiguration.cs
IMRUReduceFunctionConfiguration.cs
IMRUUpdateConfiguration.cs
IPerMapperConfigGenerator.cs
IUpdateFunction.cs
PerMapConfigGeneratorSet.cs
UpdateResult.cs
►
InProcess
►
Parameters
NumberOfMappers.cs
IMRURunner.cs
InProcessIMRUClient.cs
InProcessIMRUConfiguration.cs
InputCodecWrapper.cs
MapFunctions.cs
OutputCodecWrapper.cs
►
OnREEF
►
Client
REEFIMRUClient.cs
REEFIMRUClientConfiguration.cs
►
Driver
►
StateMachine
StateTransition.cs
SystemState.cs
SystemStateEvent.cs
SystemStateMachine.cs
SystemStateTransitionException.cs
TaskState.cs
TaskStateEvent.cs
TaskStateMachine.cs
TaskStateTransitionException.cs
ActiveContextManager.cs
ConfigurationManager.cs
ContextAndServiceConfiguration.cs
DataLoadingContext.cs
EvaluatorManager.cs
EvaluatorSpecification.cs
IJobLifeCycleManager.cs
IMRUConstants.cs
IMRUDriver.cs
IMRUSystemException.cs
JobCancellationDetectorAlwaysFalse.cs
JobCancelled.cs
JobLifeCycleManager.cs
ServiceAndContextConfigurationProvider.cs
TaskInfo.cs
TaskManager.cs
TaskStateService.cs
►
IMRUTasks
IMRUTaskAppException.cs
IMRUTaskGroupCommunicationException.cs
IMRUTaskSystemException.cs
ITaskState.cs
MapTaskHost.cs
TaskCloseCoordinator.cs
TaskHostBase.cs
UpdateTaskHost.cs
►
MapInputWithControlMessage
MapControlMessage.cs
MapInputWithControlMessage.cs
MapInputWithControlMessageCodec.cs
MapInputwithControlMessagePipelineDataConverter.cs
►
Parameters
AllowedFailedEvaluatorsFraction.cs
CoresForUpdateTask.cs
CoresPerMapper.cs
InvokeGC .cs
MaxRetryNumberInRecovery.cs
MemoryForUpdateTask.cs
MemoryPerMapper.cs
MinTaskWaitingForCloseTimeout.cs
SerializedMapConfiguration.cs
SerializedMapInputCodecConfiguration.cs
SerializedMapInputPipelineDataConverterConfiguration.cs
SerializedMapOutputPipelineDataConverterConfiguration.cs
SerializedMapTaskStateConfiguration.cs
SerializedReduceConfiguration.cs
SerializedResultHandlerConfiguration.cs
SerializedUpdateConfiguration.cs
SerializedUpdateFunctionCodecsConfiguration.cs
SerializedUpdateTaskStateConfiguration.cs
SleepIntervalParameter.cs
TimeoutMonitoringInterval.cs
►
ResultHandler
DefaultResultHandler.cs
ResultOutputLocation.cs
WriteResultHandler.cs
►
Properties
AssemblyInfo.cs
►
Org.Apache.REEF.IO
►
Files
DefaultDirectoryInfo.cs
DefaultFileInfo.cs
FileSystemInfoFactory.cs
IDirectoryInfo.cs
IFileInfo.cs
IFIleSystemInfo.cs
►
FileSystem
►
AzureBlob
►
Parameters
AzureStorageConnectionString.cs
►
RetryPolicy
DefaultAzureBlobRetryPolicy.cs
IAzureBlobRetryPolicy.cs
AzureBlobType.cs
AzureBlockBlobFileSystem.cs
AzureBlockBlobFileSystemConfiguration.cs
AzureBlockBlobFileSystemConfigurationProvider.cs
AzureCloudBlobClient.cs
AzureCloudBlobContainer.cs
AzureCloudBlobDirectory.cs
AzureCloudBlockBlob.cs
ICloudBlobClient.cs
ICloudBlobContainer.cs
ICloudBlobDirectory.cs
ICloudBlockBlob.cs
►
Hadoop
►
Parameters
CommandTimeOut.cs
HadoopHome.cs
NumberOfRetries.cs
CommandResult.cs
HadoopFileSystem.cs
HadoopFileSystemConfiguration.cs
HadoopFileSystemConfigurationProvider.cs
HDFSCommandRunner.cs
HDFSConfigurationWithoutDriverBinding.cs
►
Local
LocalFileSystem.cs
LocalFileSystemConfiguration.cs
FileStatus.cs
IFileSystem.cs
►
PartitionedData
►
FileSystem
►
Parameters
CopyToLocal.cs
FileDeSerializerConfigString.cs
FilePathsForInputPartitions.cs
FilePathsInInputPartition.cs
FileInputPartitionDescriptor.cs
FileSystemInputPartition.cs
FileSystemInputPartitionConfiguration.cs
FileSystemPartitionInputDataSet.cs
IFileDeSerializer.cs
►
Random
►
Parameters
NumberOfDoublesPerPartition.cs
NumberOfPartitions.cs
PartitionId.cs
RandomInputDataConfiguration.cs
RandomInputDataSet.cs
RandomInputPartition.cs
RandomInputPartitionDescriptor.cs
IInputPartition.cs
IPartitionDescriptor.cs
IPartitionedInputDataSet.cs
►
Properties
AssemblyInfo.cs
AssemblyInfo.DotNet.cs
►
TempFileCreation
ITempFileCreator.cs
TempFileConfigurationModule.cs
TempFileConfigurationProvider.cs
TempFileCreator.cs
TempFileFolder.cs
►
Org.Apache.REEF.IO.TestClient
►
Properties
AssemblyInfo.cs
HadoopFileInputPartitionTest.cs
HadoopFileSystemTest.cs
Run.cs
►
Org.Apache.REEF.Network
►
Group
►
Config
CodecConfiguration.cs
CodecToStreamingCodecConfiguration.cs
GroupCommConfigurationOptions.cs
PipelineDataConverterConfiguration.cs
ReduceFunctionConfiguration.cs
StreamingCodecConfiguration.cs
StreamingCodecConfigurationMinusMessage.cs
►
Driver
►
Impl
CommunicationGroupDriver.cs
GeneralGroupCommunicationMessage.cs
GroupCommDriver.cs
GroupCommunicationMessage.cs
GroupCommunicationMessageStreamingCodec.cs
MessageType.cs
TaskStarter.cs
ICommunicationGroupDriver.cs
IGroupCommDriver.cs
►
Operators
►
Impl
BroadcastOperatorSpec.cs
BroadcastReceiver.cs
BroadcastSender.cs
PipelinedReduceFunction.cs
ReduceFunction.cs
ReduceOperatorSpec.cs
ReduceReceiver.cs
ReduceSender.cs
ScatterOperatorSpec.cs
ScatterReceiver.cs
ScatterSender.cs
Sender.cs
IBroadcastReceiver.cs
IBroadcastSender.cs
IGroupCommOperator.cs
IGroupCommOperatorInternal.cs
IOperatorSpec.cs
IReduceFunction.cs
IReduceReceiver.cs
IReduceSender.cs
IScatterReceiver.cs
IScatterSender.cs
►
Pipelining
►
Impl
ArrayPipelineDataConverter.cs
DefaultPipelineDataConverter.cs
IPipelineDataConverter.cs
PipelineMessage.cs
PipelineMessageCodec.cs
StreamingPipelineMessageCodec.cs
►
Task
►
Impl
ChildNodeContainer.cs
CommunicationGroupClient.cs
GroupCommClient.cs
GroupCommNetworkObserver.cs
NodeMessageObserver.cs
NodeObserverIdentifier.cs
NodeStruct.cs
OperatorTopology.cs
TaskMessageObserver.cs
ICommunicationGroupClient.cs
ICommunicationGroupClientInternal.cs
IGroupCommClient.cs
IOperatorTopology.cs
►
Topology
FlatTopology.cs
ITopology.cs
TaskNode.cs
TopologyTypes.cs
TreeTopology.cs
►
Naming
►
Codec
NamingLookupRequestCodec.cs
NamingLookupResponseCodec.cs
NamingRegisterRequestCodec.cs
NamingRegisterResponseCodec.cs
NamingUnregisterRequestCodec.cs
►
Contracts
AvroNamingAssignment.cs
AvroNamingLookupRequest.cs
AvroNamingLookupResponse.cs
AvroNamingRegisterRequest.cs
AvroNamingUnRegisterRequest.cs
►
Events
NamingEvent.cs
NamingGetAllRequest.cs
NamingGetAllResponse.cs
NamingLookupRequest.cs
NamingLookupResponse.cs
NamingRegisterRequest.cs
NamingRegisterResponse.cs
NamingUnregisterRequest.cs
NamingUnregisterResponse.cs
►
Observers
NamingGetAllRequestObserver.cs
NamingLookupRequestObserver.cs
NamingRegisterRequestObserver.cs
NamingUnregisterRequestObserver.cs
►
Parameters
NameCacheConfiguration.cs
INameServer.cs
NameCache.cs
NameClient.cs
NameLookupClient.cs
NameRegisterClient.cs
NameServer.cs
►
NetworkService
►
Codec
ControlMessageCodec.cs
NsMessageCodec.cs
NsMessageProto.cs
NsMessageStreamingCodec.cs
StreamingCodecFunctionCache.cs
ControlMessage.cs
IConnection.cs
INetworkService.cs
NetworkService.cs
NetworkServiceOptions.cs
NsConnection.cs
NsMessage.cs
StreamingNetworkService.cs
►
Properties
AssemblyInfo.cs
AssemblyInfo.DotNet.cs
►
Utilities
AvroUtils.cs
BlockingCollectionExtensions.cs
Utils.cs
TcpClientConfigurationModule.cs
TcpClientConfigurationProvider.cs
►
Org.Apache.REEF.Tang
►
Annotations
DefaultImplementation.cs
Inject.cs
Name.cs
NamedParameter.cs
Parameter.cs
Unit.cs
►
Exceptions
BindException.cs
ClassHierarchyException.cs
IllegalStateException.cs
InjectionException.cs
NameResolutionException.cs
ParseException.cs
ReefRuntimeException.cs
TangApplicationException.cs
►
Formats
►
AvroConfigurationDataContract
AvroConfiguration.cs
ConfigurationEntry.cs
AvroConfigurationSerializer.cs
ConfigurationFile.cs
ConfigurationModule.cs
ConfigurationModuleBuilder.cs
IConfigurationSerializer.cs
IImpl.cs
IParam.cs
OptionalImpl.cs
OptionalParameter.cs
Provides.cs
RequiredImpl.cs
RequiredParameter.cs
►
Implementations
►
ClassHierarchy
►
AvroDataContract
AvroClassNode.cs
AvroConstructorArg.cs
AvroConstructorDef.cs
AvroNamedParameterNode.cs
AvroNode.cs
AvroPackageNode.cs
AbstractNode.cs
AvroClassHierarchy.cs
AvroClassHierarchySerializer.cs
ClassHierarchyImpl.cs
ClassNodeImpl.cs
ConstructorArgImpl.cs
ConstructorDefImpl.cs
NamedParameterNodeImpl.cs
NodeFactory.cs
PackageNodeImpl.cs
ParameterParser.cs
►
Configuration
ConfigurationBuilderImpl.cs
ConfigurationImpl.cs
Configurations.cs
CsConfigurationBuilderImpl.cs
CsConfigurationImpl.cs
►
InjectionPlan
Constructor.cs
CsInstance.cs
InjectionFuture.cs
InjectionFuturePlan.cs
InjectionPlan.cs
InjectorImpl.cs
ListInjectionPlan.cs
SetInjectionPlan.cs
Subplan.cs
►
Tang
TangFactory.cs
TangImpl.cs
►
Interface
IAspect.cs
IClassHierarchy.cs
IClassHierarchySerializer.cs
IConfiguration.cs
IConfigurationBuilder.cs
IConfigurationProvider.cs
ICsClassHierarchy.cs
ICsConfigurationBuilder.cs
ICsInternalConfigurationBuilder.cs
IExternalConstructor.cs
IInjector.cs
ITang.cs
►
Properties
AssemblyInfo.cs
AssemblyInfo.DotNet.cs
►
Protobuf
class_hierarchy.cs
injection_plan.cs
ProtocolBufferClassHierarchy.cs
ProtocolBufferInjectionPlan.cs
►
Types
IClassNode.cs
IConstructorArg.cs
IConstructorDef.cs
INamedParameterNode.cs
INode.cs
IPackageNode.cs
ITraversable.cs
►
Util
AbstractMonotonicMultiMap.cs
AssemblyLoader.cs
GenericType.cs
Language.cs
MonotonicHashMap.cs
MonotonicHashSet.cs
MonotonicMultiHashMap.cs
MonotonicMultiMap.cs
MonotonicSet.cs
MonotonicTreeMap.cs
ReflectionUtilities.cs
SetValuedKey.cs
►
Org.Apache.REEF.Tang.Tools
►
Properties
AssemblyInfo.cs
ClassHierarchyBuilder.cs
►
Org.Apache.REEF.Utilities
►
AsyncUtils
LoggingHelper.cs
RemoveSynchronizationContextAwaiter.cs
VoidResult.cs
►
Attributes
ClientSideAttribute.cs
DriverSideAttribute.cs
EvaluatorSideAttribute.cs
InteropAttribute.cs
NotThreadSafeAttribute.cs
PrivateAttribute.cs
TaskSideAttribute.cs
TemporaryFixAttribute.cs
TestingAttribute.cs
ThreadSafeAttribute.cs
UnstableAttribute.cs
►
Collections
PriorityQueue.cs
ReadOnlySet.cs
►
Diagnostics
DefaultUnhandledExceptionHandler.cs
DiagnosticsMessages.cs
Exceptions.cs
►
Logging
JavaLoggingSetting.cs
Level.cs
Logger.cs
►
Properties
AssemblyInfo.cs
AssemblyInfo.DotNet.cs
►
Runtime
►
Yarn
HttpConfig.cs
YarnConfiguration.cs
ByteUtilities.cs
IIdentifiable.cs
IMessage.cs
NetUtilities.cs
Optional.cs
ValidationUtilities.cs
►
Org.Apache.REEF.Wake
►
Avro
►
Message
Header.cs
IMessageInstance.cs
MessageInstance.cs
ProtocolSerializer.cs
SeializationException.cs
►
Examples
►
P2p
IEventSource.cs
Pull2Push.cs
►
Impl
LoggingEventHandler.cs
MissingStartHandlerHandler.cs
MultiEventHandler.cs
PeriodicEvent.cs
PubSubEventHandler.cs
SingleThreadStage.cs
SyncStage.cs
ThreadPoolStage.cs
TimerStage.cs
►
Properties
AssemblyInfo.cs
AssemblyInfo.DotNet.cs
►
Remote
►
Impl
ByteCodec.cs
Channel.cs
DefaultLocalAddressProvider.cs
DefaultRemoteManager.cs
DefaultRemoteManagerFactory.cs
DefaultRemoteMessage.cs
IntCodec.cs
IPEndpointComparer.cs
Link.cs
LoopbackLocalAddressProvider.cs
MultiCodec.cs
MultiDecoder.cs
MultiEncoder.cs
ObserverContainer.cs
RemoteConnectionRetryHandler.cs
RemoteEvent.cs
RemoteEventCodec.cs
RemoteEventDecoder.cs
RemoteEventEncoder.cs
RemoteEventEndpoint.cs
RemoteEventStreamingCodec.cs
SocketRemoteIdentifier.cs
StreamDataReader.cs
StreamDataWriter.cs
StreamingLink.cs
StreamingRemoteManager.cs
StreamingRemoteManagerFactory.cs
StreamingTransportClient.cs
StreamingTransportServer.cs
StringCodec.cs
StringIdentifier.cs
StringIdentifierFactory.cs
TcpClientConnectionException.cs
TcpClientConnectionFactory.cs
TransportClient.cs
TransportEvent.cs
TransportServer.cs
►
Parameters
ConnectionRetryCount.cs
SleepTimeInMs.cs
TcpPortRangeCount.cs
TcpPortRangeSeed.cs
TcpPortRangeStart.cs
TcpPortRangeTryCount.cs
►
Proto
WakeRemoteProtos.cs
WakeRemoteProtosGen.cs
ICodec.cs
IConnectionRetryHandler.cs
IDataReader.cs
IDataWriter.cs
IDecoder.cs
IEncoder.cs
ILink.cs
ILocalAddressProvider.cs
IRemoteEvent.cs
IRemoteIdentifier.cs
IRemoteIdentifierFactory.cs
IRemoteManager.cs
IRemoteManagerFactory.cs
IRemoteMessage.cs
IRemoteObserver.cs
ISubscriptionManager.cs
ITcpClientConnectionFactory.cs
ITcpPortProvider.cs
RemoteConfiguration.cs
RemoteRuntimeException.cs
TcpPortProvider.cs
►
RX
►
Impl
PubSubSubject.cs
RxSyncStage.cs
RxThreadPoolStage.cs
RxTimerStage.cs
SimpleSubject.cs
AbstractObserver.cs
AbstractRxStage.cs
IRxStage.cs
IStaticObservable.cs
ISubject.cs
ObserverCompletedException.cs
►
StreamingCodec
►
CommonStreamingCodecs
DoubleArrayStreamingCodec.cs
DoubleStreamingCodec.cs
FloatArrayStreamingCodec.cs
FloatStreamingCodec.cs
IntArrayStreamingCodec.cs
IntStreamingCodec.cs
StringStreamingCodec.cs
CodecToStreamingCodec.cs
IStreamingCodec.cs
►
Time
►
Event
Alarm.cs
StartTime.cs
StopTime.cs
►
Parameters
IdleHandler.cs
RuntimeStartHandler.cs
RuntimeStopHandler.cs
StartHandler.cs
StopHandler.cs
►
Runtime
►
Event
ClientAlarm.cs
IdleClock.cs
RuntimeAlarm.cs
RuntimeStart.cs
RuntimeStop.cs
ITimer.cs
LogicalTimer.cs
RealTimer.cs
RuntimeClock.cs
IClock.cs
Time.cs
►
Util
Actionable.cs
Disposable.cs
FixedThreadPoolTaskService.cs
IStartable.cs
ITaskService.cs
LimitedConcurrencyLevelTaskScheduler.cs
NetworkUtils.cs
SerializationHelper.cs
TimeHelper.cs
AbstractEStage.cs
IEStage.cs
IEventHandler.cs
IIdentifier.cs
IIdentifierFactory.cs
IObserverFactory.cs
IStage.cs
WakeRuntimeException.cs
SharedAssemblyInfo.cs
Generated by
1.8.14