| COrg.Apache.REEF.Wake.RX.AbstractObserver< NamingGetAllRequest > | |
| COrg.Apache.REEF.Wake.RX.AbstractObserver< NamingLookupRequest > | |
| COrg.Apache.REEF.Wake.RX.AbstractObserver< NamingRegisterRequest > | |
| COrg.Apache.REEF.Wake.RX.AbstractObserver< NamingUnregisterRequest > | |
| ►CAttribute | |
| COrg.Apache.REEF.Tang.Annotations.DefaultImplementationAttribute | DefaultImplementationAttribute |
| COrg.Apache.REEF.Tang.Annotations.InjectAttribute | InjectAttribute |
| COrg.Apache.REEF.Tang.Annotations.NamedParameterAttribute | |
| COrg.Apache.REEF.Tang.Annotations.ParameterAttribute | ParameterAttribute |
| COrg.Apache.REEF.Tang.Annotations.UnitAttribute | UnitAttribute |
| COrg.Apache.REEF.Utilities.Attributes.ClientSideAttribute | Attribute target should be used by REEF Clients |
| COrg.Apache.REEF.Utilities.Attributes.DriverSideAttribute | Attribute target should be used at the Job Driver |
| COrg.Apache.REEF.Utilities.Attributes.EvaluatorSideAttribute | Attribute target should be used by Evaluators |
| COrg.Apache.REEF.Utilities.Attributes.InteropAttribute | Attribute target is used at the Interop layer |
| COrg.Apache.REEF.Utilities.Attributes.NotThreadSafeAttribute | Indicates that the attribute target is not thread safe |
| COrg.Apache.REEF.Utilities.Attributes.PrivateAttribute | Attribute target should not be used by users, and may change at any time without a deprecation phase |
| COrg.Apache.REEF.Utilities.Attributes.TaskSideAttribute | Attribute target should be used by Tasks |
| COrg.Apache.REEF.Utilities.Attributes.TestingAttribute | Attribute target should only be used in tests |
| COrg.Apache.REEF.Utilities.Attributes.ThreadSafeAttribute | Indicates that the attribute target is thread safe |
| COrg.Apache.REEF.Utilities.Attributes.UnstableAttribute | Signals that the API is NOT stabilized |
| ►CDictionary | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashMap< T, U > | |
| ►CException | |
| COrg.Apache.REEF.Client.API.Exceptions.ClasspathException | Thrown when the client fails to assemble the classpath for the Java part of the client |
| COrg.Apache.REEF.Common.Exceptions.JobException | |
| COrg.Apache.REEF.Common.Exceptions.NonSerializableEvaluatorException | Encapsulates Exception::ToString for an Exception from a REEF Evaluator that was not Serializable to the Job Driver |
| COrg.Apache.REEF.Common.Exceptions.NonSerializableTaskException | Encapsulates Exception::ToString for an Exception from a REEF Task that was not Serializable to the Job Driver |
| COrg.Apache.REEF.Common.Poison.PoisonException | Exception thrown by PoisonedEventHandler |
| COrg.Apache.REEF.Driver.Evaluator.EvaluatorException | |
| COrg.Apache.REEF.Driver.Task.JavaTaskException | A Task Exception from the Java side |
| COrg.Apache.REEF.IMRU.OnREEF.Driver.IMRUSystemException | Type of exception thrown when possible bugs are detected in IMRU code |
| COrg.Apache.REEF.IMRU.OnREEF.Driver.MaximumNumberOfEvaluatorFailuresExceededException | Type of exception thrown when number of failed evaluators reach the maximum allowed limit |
| COrg.Apache.REEF.IO.TestClient.AssertFailedException | |
| COrg.Apache.REEF.Tang.Exceptions.IllegalStateException | |
| COrg.Apache.REEF.Tang.Exceptions.InjectionException | |
| COrg.Apache.REEF.Wake.Remote.Impl.TcpClientConnectionException | Exception class for the case when Tcp Client connection fails after trying for some finite number of times |
| COrg.Apache.REEF.Wake.Remote.RemoteRuntimeException | Wake remote runtime exception |
| COrg.Apache.REEF.Wake.WakeRuntimeException | Wake runtime exception |
| ►CFileNotFoundException | |
| COrg.Apache.REEF.Client.API.Exceptions.JavaNotFoundException | Thrown when the java installation cannot be found on the client |
| ►CProtoBufIExtensible | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.AddContextProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.ContextControlProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.ContextMessageProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.ContextStatusProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.ContextStatusProto.ContextMessageProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.DoneEvaluatorProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.DriverProcessRegistrationProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.EvaluatorControlProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.EvaluatorHeartbeatProto | Add serializer/deserializer to EvaluatorHeartbeatProto |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.EvaluatorStatusProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.FileResourceProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.JobControlProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.JobStatusProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.JobSubmissionProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.KillEvaluatorProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.NodeDescriptorProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.REEFMessage | Add serializer/deserializer to REEFMessage |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.RemoveContextProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.ResourceAllocationProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.ResourceLaunchProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.ResourceReleaseProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.ResourceRequestProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.ResourceStatusProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.RuntimeErrorProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.RuntimeStatusProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.StartTaskProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.StopEvaluatorProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.StopTaskProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.SuspendTaskProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.TaskStatusProto | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.TaskStatusProto.TaskMessageProto | |
| COrg.Apache.REEF.Tang.Protobuf.ClassNode | |
| COrg.Apache.REEF.Tang.Protobuf.Constructor | |
| COrg.Apache.REEF.Tang.Protobuf.ConstructorArg | |
| COrg.Apache.REEF.Tang.Protobuf.ConstructorDef | |
| COrg.Apache.REEF.Tang.Protobuf.InjectionPlan | |
| COrg.Apache.REEF.Tang.Protobuf.Instance | |
| COrg.Apache.REEF.Tang.Protobuf.NamedParameterNode | |
| COrg.Apache.REEF.Tang.Protobuf.Node | |
| COrg.Apache.REEF.Tang.Protobuf.PackageNode | |
| COrg.Apache.REEF.Tang.Protobuf.Subplan | |
| COrg.Apache.REEF.Wake.Remote.Proto.WakeMessagePBuf | Message p buff |
| COrg.Apache.REEF.Wake.Remote.Proto.WakeTuplePBuf | Wake tuple buf |
| ►CHashSet | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashSet< T > | |
| COrg.Apache.REEF.Network.Group.Operators.IBroadcastReceiver< MapInputWithControlMessage< TMapInput > > | |
| COrg.Apache.REEF.Network.Group.Operators.IBroadcastSender< MapInputWithControlMessage< TMapInput > > | |
| ►COrg.Apache.REEF.Wake.Remote.ICodec< byte[]> | |
| COrg.Apache.REEF.Wake.Remote.Impl.ByteCodec | |
| ►COrg.Apache.REEF.Wake.Remote.ICodec< ControlMessage > | |
| COrg.Apache.REEF.Network.NetworkService.Codec.ControlMessageCodec | |
| ►COrg.Apache.REEF.Wake.Remote.ICodec< EvaluatorHeartbeatProto > | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.EvaluatorHeartbeatProtoCodec | |
| ►COrg.Apache.REEF.Wake.Remote.ICodec< int > | |
| COrg.Apache.REEF.Wake.Remote.Impl.IntCodec | |
| COrg.Apache.REEF.Wake.Remote.ICodec< NamingLookupRequest > | |
| COrg.Apache.REEF.Wake.Remote.ICodec< NamingLookupResponse > | |
| COrg.Apache.REEF.Wake.Remote.ICodec< NamingRegisterRequest > | |
| COrg.Apache.REEF.Wake.Remote.ICodec< NamingRegisterResponse > | |
| COrg.Apache.REEF.Wake.Remote.ICodec< NamingUnregisterRequest > | |
| ►CICodec< NsMessage< T >> | |
| COrg.Apache.REEF.Network.NetworkService.Codec.NsMessageCodec< T > | Codec to serialize NsMessages for NetworkService |
| COrg.Apache.REEF.Wake.Remote.ICodec< Org.Apache.REEF.Network.NetworkService.NsMessage< T > > | |
| COrg.Apache.REEF.Wake.Remote.ICodec< Org.Apache.REEF.Wake.Remote.IRemoteEvent< T > > | |
| ►CICodec< PipelineMessage< T >> | |
| COrg.Apache.REEF.Network.Group.Pipelining.PipelineMessageCodec< T > | The codec for PipelineMessage |
| ►COrg.Apache.REEF.Wake.Remote.ICodec< REEFMessage > | |
| COrg.Apache.REEF.Common.Protobuf.ReefProtocol.REEFMessageCodec | |
| ►COrg.Apache.REEF.Wake.Remote.ICodec< string > | |
| COrg.Apache.REEF.Wake.Remote.Impl.StringCodec | |
| ►CICollection | |
| COrg.Apache.REEF.Utilities.Collections.PriorityQueue< T > | A simple priority queue implementation, where the head of the queue is the smallest element in the priority queue |
| ►CICollection< KeyValuePair< K, V >> | |
| ►COrg.Apache.REEF.Tang.Util.AbstractMonotonicMultiMap< K, V > | |
| COrg.Apache.REEF.Tang.Util.MonotonicMultiHashMap< K, V > | |
| COrg.Apache.REEF.Tang.Util.MonotonicMultiMap< K, V > | |
| ►CIComparable | |
| COrg.Apache.REEF.Tang.Types.IConstructorDef | |
| ►COrg.Apache.REEF.Tang.Types.INode | |
| COrg.Apache.REEF.Tang.Types.IClassNode | |
| COrg.Apache.REEF.Tang.Types.INamedParameterNode | |
| COrg.Apache.REEF.Tang.Types.IPackageNode | |
| ►COrg.Apache.REEF.Wake.Time.Time | Time object |
| ►COrg.Apache.REEF.Wake.Time.Event.Alarm | Represents a timer event |
| COrg.Apache.REEF.Wake.Time.Runtime.Event.ClientAlarm | |
| COrg.Apache.REEF.Wake.Time.Runtime.Event.RuntimeAlarm | |
| COrg.Apache.REEF.Wake.Time.Event.StartTime | Represents the Time at which a component started |
| COrg.Apache.REEF.Wake.Time.Event.StopTime | Represents the Time at which a component stops |
| COrg.Apache.REEF.Wake.Time.Runtime.Event.IdleClock | |
| COrg.Apache.REEF.Wake.Time.Runtime.Event.RuntimeStart | |
| COrg.Apache.REEF.Wake.Time.Runtime.Event.RuntimeStop | |
| ►CIDecoder< IRemoteEvent< T >> | |
| COrg.Apache.REEF.Wake.Remote.Impl.RemoteEventDecoder< T > | |
| ►CIDisposable | |
| ►COrg.Apache.REEF.Common.Io.INameClient | Client for the Reef name service |
| COrg.Apache.REEF.Network.Naming.NameClient | Client for the Reef name service |
| COrg.Apache.REEF.Common.Tasks.ITask | |
| COrg.Apache.REEF.Driver.Context.IActiveContext | |
| COrg.Apache.REEF.Driver.Evaluator.IAllocatedEvaluator | Represents an Evaluator that is allocated, but is not running yet |
| COrg.Apache.REEF.Driver.Task.IRunningTask | Represents a running Task |
| COrg.Apache.REEF.IMRU.API.IIMRUResultHandler< in in T > | Interface defining how to handle the output of Update function in IMRU |
| ►COrg.Apache.REEF.Network.Group.Task.IGroupCommClient | Used by Tasks to fetch CommunicationGroupClients |
| COrg.Apache.REEF.Network.Group.Task.Impl.GroupCommClient | Used by Tasks to fetch CommunicationGroupClients |
| ►COrg.Apache.REEF.Network.Naming.INameServer | Service that manages names and IPEndpoints for well known hosts |
| COrg.Apache.REEF.Network.Naming.NameServer | Service that manages names and IPEndpoints for well known hosts |
| ►COrg.Apache.REEF.Network.NetworkService.IConnection< T > | Represents a connection between two endpoints named by identifiers |
| COrg.Apache.REEF.Network.NetworkService.NsConnection< T > | Represents a connection between two hosts using the NetworkService |
| ►COrg.Apache.REEF.Network.NetworkService.INetworkService< T > | Network service used for Reef Task communication |
| COrg.Apache.REEF.Network.NetworkService.NetworkService< T > | Network service used for Reef Task communication |
| COrg.Apache.REEF.Network.NetworkService.StreamingNetworkService< T > | Writable Network service used for Reef Task communication |
| COrg.Apache.REEF.Wake.Examples.P2p.Pull2Push< T > | Performs a Pull-to-Push conversion in Wake |
| ►COrg.Apache.REEF.Wake.IStage | Stage is an execution unit for events and provides a way to reclaim its resources |
| ►COrg.Apache.REEF.Wake.IEStage< T > | Stage that executes an event handler |
| ►COrg.Apache.REEF.Wake.AbstractEStage< T > | An estage that implements metering |
| COrg.Apache.REEF.Wake.Impl.SingleThreadStage< T > | Single thread stage that runs the event handler |
| COrg.Apache.REEF.Wake.Impl.SyncStage< T > | Stage that synchronously executes an event handler |
| COrg.Apache.REEF.Wake.Impl.ThreadPoolStage< T > | Stage that executes an event handler with a thread pool |
| COrg.Apache.REEF.Wake.Impl.TimerStage | Stage that triggers an event handler periodically |
| ►COrg.Apache.REEF.Wake.Remote.IRemoteManager< T > | |
| COrg.Apache.REEF.Wake.Remote.Impl.DefaultRemoteManager< T > | Manages incoming and outgoing messages between remote hosts |
| COrg.Apache.REEF.Wake.RX.Impl.RxTimerStage | Timer stage that provides events to the observer periodically |
| ►COrg.Apache.REEF.Wake.RX.IRxStage< T > | Stage that executes the observer |
| ►COrg.Apache.REEF.Wake.RX.AbstractRxStage< T > | An Rx stage that implements metering |
| COrg.Apache.REEF.Wake.RX.Impl.RxSyncStage< T > | Stage that executes the observer synchronously |
| COrg.Apache.REEF.Wake.RX.Impl.RxThreadPoolStage< T > | Stage that executes the observer with a thread pool |
| ►COrg.Apache.REEF.Wake.Remote.ILink< T > | Represents a link between two endpoints |
| COrg.Apache.REEF.Wake.Remote.Impl.Link< T > | Represents an open connection between remote hosts |
| COrg.Apache.REEF.Wake.Remote.Impl.TransportClient< T > | Establish connections to TransportServer for remote message passing |
| COrg.Apache.REEF.Wake.Remote.Impl.TransportServer< T > | Server to handle incoming remote messages |
| COrg.Apache.REEF.Wake.Remote.IRemoteObserver< T > | A disposable remote observer observer, that is not managed by the manager that creates it |
| ►COrg.Apache.REEF.Wake.Time.IClock | |
| COrg.Apache.REEF.Wake.Time.Runtime.RuntimeClock | |
| ►CIEncoder< IRemoteEvent< T >> | |
| COrg.Apache.REEF.Wake.Remote.Impl.RemoteEventEncoder< T > | |
| ►CIEnumerable | |
| COrg.Apache.REEF.IO.PartitionedData.IPartitionedInputDataSet | Driver-Side representation of a partitioned data set |
| ►COrg.Apache.REEF.Wake.Remote.ITcpPortProvider | Provides port numbers for tcp listeners |
| COrg.Apache.REEF.Wake.Remote.TcpPortProvider | |
| COrg.Apache.REEF.Wake.IEventHandler< Org.Apache.REEF.Wake.Impl.PeriodicEvent > | |
| ►COrg.Apache.REEF.IMRU.API.IIMRUResultHandler< TResult > | |
| COrg.Apache.REEF.IMRU.OnREEF.ResultHandler.WriteResultHandler< TResult > | Writes IMRU result from Update task to a file |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< ContextManager > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< EvaluatorRuntime > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< IDriverConnection > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< IObserver< ICloseEvent > > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< IObserver< ISuspendEvent > > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< ISet< IObserver< IdleClock > > > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< ISet< IObserver< RuntimeStart > > > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< ISet< IObserver< RuntimeStop > > > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< ISet< IObserver< StartTime > > > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< ISet< IObserver< StopTime > > > | |
| ►COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< T > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.InjectionFutureImpl< T > | |
| COrg.Apache.REEF.IO.PartitionedData.IInputPartition< Stream > | |
| COrg.Apache.REEF.IMRU.API.IMapFunction< TMapInput, TMapOutput > | |
| COrg.Apache.REEF.Network.NetworkService.INetworkService< GeneralGroupCommunicationMessage > | |
| ►CINotifyCompletion | |
| COrg.Apache.REEF.Utilities.AsyncUtils.RemoveSynchronizationContextAwaiter | This is to avoid deadlocks in clients that use synchronization context (WinForms/ASP.NET) Use at asynchronous entry points of all async REEF client APIs |
| ►CInvalidOperationException | |
| COrg.Apache.REEF.Wake.RX.ObserverCompletedException | It is illegal to call onError() or onCompleted() when a call to onNext() is still outstanding, or to call onNext(), onError() or onCompleted() after a call to onError() or onCompleted() has been dispatched |
| ►CIObserver | |
| COrg.Apache.REEF.Common.Context.Defaults.DefaultContextStartHandler | Default handler for ContextStart |
| COrg.Apache.REEF.Common.Context.Defaults.DefaultContextStopHandler | Default event handler for ContextStop |
| COrg.Apache.REEF.Common.Context.IContextMessageHandler | |
| COrg.Apache.REEF.Common.Poison.PoisonedEventHandler< T > | Handler to process an event in a way that has certain probability of failure within certain inverval of time |
| COrg.Apache.REEF.Common.Tasks.Defaults.DefaultTaskCloseHandler | A default handler for an event from the driver signaling the suspension of a task |
| ►COrg.Apache.REEF.Common.Tasks.IDriverConnectionMessageHandler | The handler implementable by users to handle IDriverConnectionMessages, which notifies the Task when there is a change in driver connection state |
| COrg.Apache.REEF.Common.Tasks.Defaults.DefaultDriverConnectionMessageHandler | |
| COrg.Apache.REEF.Driver.Defaults.DefaultClientCloseHandler | Default handler for close messages from the client: logging it |
| COrg.Apache.REEF.Driver.Defaults.DefaultClientCloseWithMessageHandler | Default handler for close messages from the client: Throw an Exception |
| COrg.Apache.REEF.Driver.Defaults.DefaultClientMessageHandler | DDefault event handler for Client messages: Logging it |
| COrg.Apache.REEF.Driver.Defaults.DefaultContextActiveHandler | Default handler for ActiveContext: Close it |
| COrg.Apache.REEF.Driver.Defaults.DefaultContextClosureHandler | Default event handler for ClosedContext: Logging it |
| COrg.Apache.REEF.Driver.Defaults.DefaultContextFailureHandler | Default event handler used for FailedContext: It crashes the driver |
| COrg.Apache.REEF.Driver.Defaults.DefaultContextMessageHandler | Default event handler for ContextMessage: Logging it |
| COrg.Apache.REEF.Driver.Defaults.DefaultDriverRestartCompletedHandler | The default driver restart completed handler |
| COrg.Apache.REEF.Driver.Defaults.DefaultDriverRestartContextActiveHandler | Default handler for ActiveContext received during driver restart: Close it |
| COrg.Apache.REEF.Driver.Defaults.DefaultDriverRestartHandler | Default event handler for driver restart: Logging it |
| COrg.Apache.REEF.Driver.Defaults.DefaultDriverRestartTaskRunningHandler | Default event handler for TaskRuntime received during driver restart: Logging it |
| COrg.Apache.REEF.Driver.Defaults.DefaultEvaluatorAllocationHandler | Default handler for AllocatedEvaluator: close it |
| COrg.Apache.REEF.Driver.Defaults.DefaultEvaluatorCompletionHandler | Default event handler for CompletedEvaluator: Logging it |
| COrg.Apache.REEF.Driver.Defaults.DefaultEvaluatorFailureHandler | Default event handler used for FailedEvaluator: It crashes the driver |
| COrg.Apache.REEF.Driver.Defaults.DefaultTaskCompletionHandler | Default event handler for CompletedTask: Log it and close the context |
| COrg.Apache.REEF.Driver.Defaults.DefaultTaskFailureHandler | Default event handler used for FailedTask: It crashes the driver |
| COrg.Apache.REEF.Driver.Defaults.DefaultTaskMessageHandler | Default event handler for TaskMessage: Logging it |
| COrg.Apache.REEF.Driver.Defaults.DefaultTaskRunningHandler | Default event handler for TaskRuntime: Logging it |
| COrg.Apache.REEF.Driver.Defaults.DefaultTaskSuspensionHandler | Default event handler used for SuspendedTask: It crashes the driver |
| COrg.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T > | Contains the Operator's topology graph |
| COrg.Apache.REEF.Wake.Impl.LoggingEventHandler< T > | A logging event handler |
| COrg.Apache.REEF.Wake.Impl.MissingStartHandlerHandler | |
| COrg.Apache.REEF.Wake.Remote.IRemoteObserver< T > | A disposable remote observer observer, that is not managed by the manager that creates it |
| COrg.Apache.REEF.Wake.RX.AbstractObserver< T > | An observer with logging-only onError and onCompleted() methods |
| COrg.Apache.REEF.Wake.RX.Impl.PubSubSubject< T > | Subject to provide publish/subscribe interface |
| COrg.Apache.REEF.Wake.RX.IRxStage< T > | Stage that executes the observer |
| COrg.Apache.REEF.Wake.RX.ISubject< In, Out > | A class implementing Observer> and StaticObservable |
| COrg.Apache.REEF.Network.Group.Task.IOperatorTopology< PipelineMessage< T > > | |
| COrg.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< TMapInput > | |
| ►CIReadOnlyCollection | |
| COrg.Apache.REEF.Utilities.Collections.ReadOnlySet< T > | An implementation of a set that is read only |
| ►CIReduceFunction< PipelineMessage< T >> | |
| COrg.Apache.REEF.Network.Group.Operators.Impl.PipelinedReduceFunction< T > | The class used to aggregate pipelined messages sent by ReduceSenders |
| COrg.Apache.REEF.Network.Group.Operators.IReduceFunction< TMapOutput > | |
| COrg.Apache.REEF.Network.Group.Operators.IReduceReceiver< TMapOutput > | |
| COrg.Apache.REEF.Network.Group.Operators.IReduceSender< TMapOutput > | |
| COrg.Apache.REEF.Wake.Remote.IRemoteManager< Org.Apache.REEF.Network.NetworkService.NsMessage< T > > | |
| COrg.Apache.REEF.Wake.Remote.IRemoteManager< REEFMessage > | |
| ►CIRetryPolicy | |
| COrg.Apache.REEF.IO.FileSystem.AzureBlob.RetryPolicy.IAzureBlobRetryPolicy | |
| ►CISet | |
| COrg.Apache.REEF.Utilities.Collections.ReadOnlySet< T > | An implementation of a set that is read only |
| ►COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< double > | |
| COrg.Apache.REEF.Wake.StreamingCodec.CommonStreamingCodecs.DoubleStreamingCodec | Streaming codec for double |
| ►COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< double[]> | |
| COrg.Apache.REEF.Wake.StreamingCodec.CommonStreamingCodecs.DoubleArrayStreamingCodec | Streaming codec for double array |
| ►COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< float > | |
| COrg.Apache.REEF.Wake.StreamingCodec.CommonStreamingCodecs.FloatStreamingCodec | Streaming codec for float |
| ►COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< float[]> | |
| COrg.Apache.REEF.Wake.StreamingCodec.CommonStreamingCodecs.FloatArrayStreamingCodec | Streaming codec for float array |
| ►COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< int > | |
| COrg.Apache.REEF.Wake.StreamingCodec.CommonStreamingCodecs.IntStreamingCodec | Streaming codec for integer |
| ►COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< int[]> | |
| COrg.Apache.REEF.Wake.StreamingCodec.CommonStreamingCodecs.IntArrayStreamingCodec | Streaming codec for integer array |
| COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< Org.Apache.REEF.Wake.Remote.IRemoteEvent< T > > | |
| ►CIStreamingCodec< PipelineMessage< T >> | |
| COrg.Apache.REEF.Network.Group.Pipelining.StreamingPipelineMessageCodec< T > | The streaming codec for PipelineMessage |
| ►COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< string > | |
| COrg.Apache.REEF.Wake.StreamingCodec.CommonStreamingCodecs.StringStreamingCodec | Streaming codec for string |
| COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< TMapInput > | |
| COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< TMapOutput > | |
| COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< TResult > | |
| ►COrg.Apache.REEF.Wake.RX.ISubject< T, T > | |
| COrg.Apache.REEF.Wake.RX.Impl.SimpleSubject< T > | A Subject that relays all messages to its subscribers. |
| ►COrg.Apache.REEF.Tang.Types.ITraversable< InjectionPlan > | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.InjectionPlan | |
| ►COrg.Apache.REEF.Tang.Types.ITraversable< INode > | |
| COrg.Apache.REEF.Tang.Types.INode | |
| COrg.Apache.REEF.IMRU.API.IUpdateFunction< TMapInput, TMapOutput, TResult > | |
| ►CAvroPublicMemberContractResolver | |
| COrg.Apache.REEF.Tang.Formats.AvroConfigurationResolver | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashMap< object, FieldInfo > | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashMap< object, IList< string > > | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashMap< object, IList< Type > > | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashMap< object, string > | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashMap< object, Type > | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashMap< Type, object > | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashMap< Type, string > | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashSet< FieldInfo > | |
| COrg.Apache.REEF.Tang.Util.MonotonicHashSet< object > | |
| COrg.Apache.REEF.Tang.Util.MonotonicMultiHashMap< object, string > | |
| COrg.Apache.REEF.Tang.Util.MonotonicMultiHashMap< object, Type > | |
| COrg.Apache.REEF.Tang.Util.MonotonicMultiMap< INamedParameterNode, object > | |
| COrg.Apache.REEF.Tang.Util.MonotonicSet< IClassNode > | |
| COrg.Apache.REEF.Tang.Util.MonotonicTreeMap< string, ConstructorInfo > | |
| COrg.Apache.REEF.Tang.Util.MonotonicTreeMap< string, INamedParameterNode > | |
| ►COrg.Apache.REEF.Tang.Annotations.Name< bool > | |
| COrg.Apache.REEF.Client.YARN.Parameters.EnableDebugLogging | |
| COrg.Apache.REEF.Client.Yarn.RestClient.YarnConfigurationUrlProvider.UseHttpsForYarnCommunication | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.Initialize | |
| COrg.Apache.REEF.Wake.Remote.RemoteConfiguration.OrderingGuarantee | |
| ►COrg.Apache.REEF.Tang.Annotations.Name< double > | |
| COrg.Apache.REEF.Common.Poison.CrashProbability | |
| COrg.Apache.REEF.Network.Naming.Parameters.NameCacheConfiguration.CacheEntryExpiryTime | |
| ►CName< ICodec< Type >> | |
| COrg.Apache.REEF.Wake.Remote.RemoteConfiguration.MessageCodec | |
| ►COrg.Apache.REEF.Tang.Annotations.Name< int > | |
| COrg.Apache.REEF.Client.Local.Parameters.NumberOfEvaluators | |
| COrg.Apache.REEF.Client.YARN.Parameters.DriverMaxMemoryAllicationPoolSizeMB | |
| COrg.Apache.REEF.Client.YARN.Parameters.DriverMaxPermSizeMB | |
| COrg.Apache.REEF.Common.Io.NamingConfigurationOptions.NameServerPort | |
| COrg.Apache.REEF.Common.Poison.CrashMinDelay | |
| COrg.Apache.REEF.Common.Poison.CrashTimeout | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.DriverRestartEvaluatorRecoverySeconds | |
| COrg.Apache.REEF.IMRU.InProcess.Parameters.NumberOfMappers | The number of mappers to instantiate |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.FanOut | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.NumberOfTasks | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.Timeout | |
| COrg.Apache.REEF.Network.Naming.NameServer.Port | |
| COrg.Apache.REEF.Network.NetworkService.NetworkServiceOptions.NetworkServicePort | |
| COrg.Apache.REEF.Wake.Remote.Parameters.ConnectionRetryCount | |
| COrg.Apache.REEF.Wake.Remote.Parameters.SleepTimeInMs | |
| COrg.Apache.REEF.Wake.Remote.Parameters.TcpPortRangeCount | |
| COrg.Apache.REEF.Wake.Remote.Parameters.TcpPortRangeSeed | |
| COrg.Apache.REEF.Wake.Remote.Parameters.TcpPortRangeStart | |
| COrg.Apache.REEF.Wake.Remote.Parameters.TcpPortRangeTryCount | |
| COrg.Apache.REEF.Wake.Remote.RemoteConfiguration.Port | |
| ►CName< IObserver< Exception >> | |
| COrg.Apache.REEF.Wake.Remote.RemoteConfiguration.ErrorHandler | |
| ►CName< IObserver< ICloseEvent >> | |
| COrg.Apache.REEF.Common.Tasks.TaskConfigurationOptions.CloseHandler | |
| ►CName< IObserver< IDriverMessage >> | |
| COrg.Apache.REEF.Common.Tasks.TaskConfigurationOptions.MessageHandler | |
| ►CName< IObserver< ISuspendEvent >> | |
| COrg.Apache.REEF.Common.Tasks.TaskConfigurationOptions.SuspendHandler | |
| ►CName< ISet< IConfigurationProvider >> | |
| COrg.Apache.REEF.Common.Client.Parameters.DriverConfigurationProviders | |
| COrg.Apache.REEF.Common.Evaluator.Parameters.EvaluatorConfigurationProviders | |
| ►CName< ISet< IContextMessageHandler >> | |
| COrg.Apache.REEF.Common.Context.ContextConfigurationOptions.ContextMessageHandlers | |
| ►CName< ISet< IContextMessageSource >> | |
| COrg.Apache.REEF.Common.Context.ContextConfigurationOptions.ContextMessageSources | |
| ►CName< ISet< IHttpHandler >> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.HttpEventHandlers | |
| ►CName< ISet< IObserver< IActiveContext >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.ActiveContextHandlers | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.DriverRestartActiveContextHandlers | |
| ►CName< ISet< IObserver< IAllocatedEvaluator >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.AllocatedEvaluatorHandlers | |
| ►CName< ISet< IObserver< IClosedContext >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.ClosedContextHandlers | |
| ►CName< ISet< IObserver< ICompletedEvaluator >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.CompletedEvaluatorHandlers | |
| ►CName< ISet< IObserver< ICompletedTask >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.CompletedTaskHandlers | |
| ►CName< ISet< IObserver< IContextMessage >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.ContextMessageHandlers | |
| ►CName< ISet< IObserver< IContextStart >>> | |
| COrg.Apache.REEF.Common.Context.ContextConfigurationOptions.StartHandlers | |
| ►CName< ISet< IObserver< IContextStop >>> | |
| COrg.Apache.REEF.Common.Context.ContextConfigurationOptions.StopHandlers | |
| ►CName< ISet< IObserver< IdleClock >>> | |
| COrg.Apache.REEF.Wake.Time.IClock.IdleHandler | Bind this to an event handler to statically subscribe to the IdleClock Event |
| COrg.Apache.REEF.Wake.Time.Parameters.IdleHandler | Bind this to an event handler to statically subscribe to the IdleClock Event |
| ►CName< ISet< IObserver< IDriverRestartCompleted >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.DriverRestartCompletedHandlers | |
| ►CName< ISet< IObserver< IDriverRestarted >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.DriverRestartedHandlers | |
| ►CName< ISet< IObserver< IDriverStarted >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.DriverStartedHandlers | |
| ►CName< ISet< IObserver< IEvaluatorRequestor >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.EvaluatorRequestHandlers | |
| ►CName< ISet< IObserver< IFailedContext >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.FailedContextHandlers | |
| ►CName< ISet< IObserver< IFailedEvaluator >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.DriverRestartFailedEvaluatorHandlers | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.FailedEvaluatorHandlers | |
| ►CName< ISet< IObserver< IFailedTask >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.FailedTaskHandlers | |
| ►CName< ISet< IObserver< IRunningTask >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.DriverRestartRunningTaskHandlers | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.RunningTaskHandlers | |
| ►CName< ISet< IObserver< ISuspendedTask >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.SuspendedTaskHandlers | |
| ►CName< ISet< IObserver< ITaskMessage >>> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.TaskMessageHandlers | |
| ►CName< ISet< IObserver< ITaskStart >>> | |
| COrg.Apache.REEF.Common.Tasks.TaskConfigurationOptions.StartHandlers | |
| ►CName< ISet< IObserver< ITaskStop >>> | |
| COrg.Apache.REEF.Common.Tasks.TaskConfigurationOptions.StopHandlers | |
| ►CName< ISet< IObserver< RuntimeStart >>> | |
| COrg.Apache.REEF.Wake.Time.IClock.RuntimeStartHandler | Bind this to an event handler to statically subscribe to the RuntimeStart Event |
| COrg.Apache.REEF.Wake.Time.Parameters.RuntimeStartHandler | Bind this to an event handler to statically subscribe to the RuntimeStart Event |
| ►CName< ISet< IObserver< RuntimeStop >>> | |
| COrg.Apache.REEF.Wake.Time.IClock.RuntimeStopHandler | Bind this to an event handler to statically subscribe to the RuntimeStop Event |
| COrg.Apache.REEF.Wake.Time.Parameters.RuntimeStopHandler | Bind this to an event handler to statically subscribe to the RuntimeStop Event |
| ►CName< ISet< IObserver< StartTime >>> | |
| COrg.Apache.REEF.Wake.Time.IClock.StartHandler | Bind this to an event handler to statically subscribe to the StartTime Event |
| COrg.Apache.REEF.Wake.Time.Parameters.StartHandler | Bind this to an event handler to statically subscribe to the StartTime Event |
| ►CName< ISet< IObserver< StopTime >>> | |
| COrg.Apache.REEF.Wake.Time.IClock.StopHandler | Bind this to an event handler to statically subscribe to the StopTime Event |
| COrg.Apache.REEF.Wake.Time.Parameters.StopHandler | Bind this to an event handler to statically subscribe to the StopTime Event |
| ►CName< ISet< IPerMapperConfigGenerator >> | |
| COrg.Apache.REEF.IMRU.API.PerMapConfigGeneratorSet | |
| ►CName< ISet< ITaskMessageSource >> | |
| COrg.Apache.REEF.Common.Tasks.TaskConfigurationOptions.TaskMessageSources | |
| ►CName< ISet< object >> | |
| COrg.Apache.REEF.Common.Services.ServicesSet | |
| ►CName< ISet< string >> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.ArgumentSets | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.SetOfAssemblies | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.SerializedGroupConfigs | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.SerializedOperatorConfigs | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.TopologyChildTaskIds | |
| ►CName< ISet< TraceListener >> | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.TraceListenersSet | |
| ►COrg.Apache.REEF.Tang.Annotations.Name< SecureString > | |
| COrg.Apache.REEF.Client.YARN.HDI.HDInsightPasswordSecureString | |
| ►COrg.Apache.REEF.Tang.Annotations.Name< string > | |
| COrg.Apache.REEF.Client.Local.Parameters.LocalRuntimeDirectory | |
| COrg.Apache.REEF.Client.YARN.HDI.HDInsightPasswordString | |
| COrg.Apache.REEF.Client.YARN.HDI.HDInsightUrl | |
| COrg.Apache.REEF.Client.YARN.HDI.HDInsightUserName | |
| COrg.Apache.REEF.Client.YARN.Parameters.JobSubmissionDirectoryPrefixParameter | |
| COrg.Apache.REEF.Client.YARN.Parameters.SecurityTokenKindParameter | |
| COrg.Apache.REEF.Client.YARN.Parameters.SecurityTokenServiceParameter | |
| COrg.Apache.REEF.Client.Yarn.RestClient.YarnConfigurationUrlProvider.HadoopConfigurationDirectory | |
| COrg.Apache.REEF.Common.Context.ContextConfigurationOptions.ContextIdentifier | |
| COrg.Apache.REEF.Common.Io.NamingConfigurationOptions.NameServerAddress | |
| COrg.Apache.REEF.Common.Tasks.TaskConfigurationOptions.Identifier | |
| COrg.Apache.REEF.Common.Tasks.TaskConfigurationOptions.Memento | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions.TraceLevel | |
| COrg.Apache.REEF.IMRU.OnREEF.ResultHandler.ResultOutputLocation | |
| COrg.Apache.REEF.IO.FileSystem.AzureBlob.Parameters.AzureStorageConnectionString | |
| COrg.Apache.REEF.IO.TempFileCreation.TempFileFolder | Folder for local temp file |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.CommunicationGroupName | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.DriverId | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.GroupName | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.MasterTaskId | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.MessageType | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.OperatorName | |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions.TopologyRootTaskId | |
| COrg.Apache.REEF.Network.Naming.Parameters.NameCacheConfiguration.CacheMemoryLimit | |
| COrg.Apache.REEF.Network.Naming.Parameters.NameCacheConfiguration.PollingInterval | |
| COrg.Apache.REEF.Wake.Remote.RemoteConfiguration.HostAddress | |
| COrg.Apache.REEF.Wake.Remote.RemoteConfiguration.ManagerName | |
| COrg.Apache.REEF.Utilities.Optional< byte[]> | |
| COrg.Apache.REEF.Utilities.Optional< ContextRuntime > | |
| COrg.Apache.REEF.Utilities.Optional< Exception > | |
| COrg.Apache.REEF.Utilities.Optional< IDriverConnectionMessageHandler > | |
| COrg.Apache.REEF.Utilities.Optional< IDriverMessageHandler > | |
| COrg.Apache.REEF.Utilities.Optional< ISet< ITaskMessageSource > > | |
| COrg.Apache.REEF.Utilities.Optional< ISet< string > > | |
| COrg.Apache.REEF.Utilities.Optional< ITaskStart > | |
| COrg.Apache.REEF.Utilities.Optional< ITaskStop > | |
| COrg.Apache.REEF.Utilities.Optional< string > | |
| COrg.Apache.REEF.Utilities.Optional< TaskRuntime > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IAzureBlobRetryPolicy > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IDriverConnection > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IDriverReconnConfigProvider > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IHttpHandler > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< IActiveContext > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< IAllocatedEvaluator > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< IClosedContext > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< ICloseEvent > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< ICompletedEvaluator > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< ICompletedTask > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< IContextMessage > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< IContextStart > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< IContextStop > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< IFailedContext > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< IFailedEvaluator > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< IFailedTask > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< IRunningTask > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< ISuspendedTask > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< ISuspendEvent > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< ITaskMessage > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< ITaskStart > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< ITaskStop > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< Org.Apache.REEF.Driver.IDriverRestartCompleted > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IObserver< Org.Apache.REEF.Driver.IDriverRestarted > > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< IYarnRestClientCredential > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< Org.Apache.REEF.Common.Context.IContextMessageHandler > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< Org.Apache.REEF.Common.Context.IContextMessageSource > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< Org.Apache.REEF.Common.Tasks.IDriverConnectionMessageHandler > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< Org.Apache.REEF.Common.Tasks.IDriverMessageHandler > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< Org.Apache.REEF.Common.Tasks.ITaskMessageSource > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< Org.Apache.REEF.Driver.IProgressProvider > | |
| COrg.Apache.REEF.Tang.Formats.OptionalParameter< bool > | |
| COrg.Apache.REEF.Tang.Formats.OptionalParameter< int > | |
| COrg.Apache.REEF.Tang.Formats.OptionalParameter< object > | |
| COrg.Apache.REEF.Tang.Formats.OptionalParameter< SecureString > | |
| COrg.Apache.REEF.Tang.Formats.OptionalParameter< string > | |
| COrg.Apache.REEF.Tang.Formats.OptionalParameter< TraceListener > | |
| COrg.Apache.REEF.Client.API.AppParameters | The parameters for a REEF application, used to specify application parameters for each REEF application |
| COrg.Apache.REEF.Client.API.AppParametersBuilder | A builder for AppParameters |
| COrg.Apache.REEF.Client.API.ClientFactory | Instantiates the client based on IConfiguration for the chosen runtime |
| ►COrg.Apache.REEF.Client.API.IREEFClient | Interface for job submission on a REEF cluster |
| COrg.Apache.REEF.Client.Local.LocalClient | An implementation of the REEF interface using an external Java program |
| COrg.Apache.REEF.Client.YARN.YarnREEFDotNetClient | Temporary client for developing and testing .NET job submission E2E |
| COrg.Apache.REEF.Client.API.JobParameters | The parameters for a REEF job, used to specify job parameters on each REEF submission |
| COrg.Apache.REEF.Client.API.JobParametersBuilder | A builder for JobParameters |
| COrg.Apache.REEF.Client.API.JobRequest | Describes parameters for a single job submission |
| COrg.Apache.REEF.Client.API.JobRequestBuilder | |
| COrg.Apache.REEF.Client.Avro.AvroAppSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters |
| COrg.Apache.REEF.Client.Avro.AvroJobSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroJobSubmissionParameters |
| COrg.Apache.REEF.Client.Avro.Local.AvroLocalAppSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroLocalAppSubmissionParameters |
| COrg.Apache.REEF.Client.Avro.Local.AvroLocalJobSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroLocalJobSubmissionParameters |
| COrg.Apache.REEF.Client.Avro.YARN.AvroYarnAppSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroYarnAppSubmissionParameters |
| COrg.Apache.REEF.Client.Avro.YARN.AvroYarnClusterJobSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters |
| COrg.Apache.REEF.Client.Avro.YARN.AvroYarnJobSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters |
| COrg.Apache.REEF.Client.Common.IJobSubmissionResult | |
| COrg.Apache.REEF.Client.YARN.HDI.HDInsightCommandLineEnvironment | Provides YARN classpath for HDInsight environment |
| COrg.Apache.REEF.Client.Yarn.IJobResourceUploader | |
| ►COrg.Apache.REEF.Client.Yarn.IJobSubmissionDirectoryProvider | Provides path to job submission directory |
| COrg.Apache.REEF.Client.Yarn.JobSubmissionDirectoryProvider | Provides path to job submission directory |
| COrg.Apache.REEF.Client.Yarn.JobResource | |
| ►COrg.Apache.REEF.Client.Yarn.RestClient.IUrlProvider | |
| COrg.Apache.REEF.Client.YARN.RestClient.MultipleRMUrlProvider | |
| COrg.Apache.REEF.Client.YARN.RestClient.IYarnRestClientCredential | Provides the credentials to be used by the REST client to connect to YARN RM |
| COrg.Apache.REEF.Common.Avro.AvroDriverInfo | Used to serialize and deserialize Avro record org.apache.reef.webserver.AvroDriverInfo |
| COrg.Apache.REEF.Common.Avro.AvroFailedTask | Used to serialize and deserialize Avro record org.apache.reef.javabridge.avro.AvroFailedTask |
| COrg.Apache.REEF.Common.Avro.AvroHttpRequest | Used to serialize and deserialize Avro record org.apache.reef.webserver.AvroHttpRequest |
| COrg.Apache.REEF.Common.Avro.AvroJsonSerializer< T > | Wrapper class for serialize/deserialize Avro json |
| COrg.Apache.REEF.Common.Avro.AvroReefServiceInfo | Used to serialize and deserialize Avro record org.apache.reef.webserver.AvroReefServiceInfo |
| COrg.Apache.REEF.Common.Avro.HeaderEntry | Used to serialize and deserialize Avro record org.apache.reef.webserver.HeaderEntry |
| ►COrg.Apache.REEF.Common.Catalog.Capabilities.ICapability | |
| COrg.Apache.REEF.Common.Catalog.Capabilities.CPU | |
| COrg.Apache.REEF.Common.Catalog.Capabilities.RAM | |
| COrg.Apache.REEF.Common.Catalog.INodeDescriptor | |
| ►COrg.Apache.REEF.Common.Catalog.IResourceCatalog | |
| COrg.Apache.REEF.Common.Catalog.IRackDescriptor | |
| COrg.Apache.REEF.Common.Constants | |
| COrg.Apache.REEF.Common.Context.ContextConfigurationOptions | Configuration parameters for ContextConfiguration module |
| COrg.Apache.REEF.Common.Context.ContextMessage | |
| ►COrg.Apache.REEF.Common.Context.IContextMessageSource | Implement (and bind) this interface to send messages from a context as part of a heartbeat from Evaluator to Driver |
| COrg.Apache.REEF.Common.Context.Defaults.DefaultContextMessageSource | Default ContextMessageSource: return nothing |
| COrg.Apache.REEF.Common.Evaluator.DriverInformation | |
| ►COrg.Apache.REEF.Common.Evaluator.IDriverConnection | |
| COrg.Apache.REEF.Common.Evaluator.DefaultLocalHttpDriverConnection | |
| COrg.Apache.REEF.Common.Evaluator.DefaultYarnClusterHttpDriverConnection | |
| COrg.Apache.REEF.Common.Evaluator.DefaultYarnOneBoxHttpDriverConnection | |
| COrg.Apache.REEF.Common.Events.IContextStart | |
| COrg.Apache.REEF.Common.Events.IContextStop | |
| COrg.Apache.REEF.Common.Files.REEFFileNames | Contains all file system constants used by REEF |
| ►COrg.Apache.REEF.Common.IContextAndTaskSubmittable | Base interface for classes that support the simultaneous submission of both Context and Task configurations |
| COrg.Apache.REEF.Driver.Evaluator.IAllocatedEvaluator | Represents an Evaluator that is allocated, but is not running yet |
| ►COrg.Apache.REEF.Common.IContextSubmittable | Base interface for classes that support Context submission |
| COrg.Apache.REEF.Driver.Context.IActiveContext | |
| COrg.Apache.REEF.Driver.Evaluator.IAllocatedEvaluator | Represents an Evaluator that is allocated, but is not running yet |
| COrg.Apache.REEF.Common.Io.NameAssignment | Tuple containing the string identifier and IPEndpoint |
| COrg.Apache.REEF.Common.Io.NamingConfigurationOptions | |
| ►COrg.Apache.REEF.Common.ITaskSubmittable | Base interface for classes that support Task submission |
| COrg.Apache.REEF.Driver.Context.IActiveContext | |
| COrg.Apache.REEF.Driver.Evaluator.IAllocatedEvaluator | Represents an Evaluator that is allocated, but is not running yet |
| COrg.Apache.REEF.Common.Jar.ResourceHelper | Helps with retrieval of embedded resources |
| COrg.Apache.REEF.Common.Runtime.MachineStatus | |
| COrg.Apache.REEF.Common.Tasks.Events.ICloseEvent | |
| COrg.Apache.REEF.Common.Tasks.Events.IDriverMessage | |
| COrg.Apache.REEF.Common.Tasks.Events.ISuspendEvent | An event from the driver signaling that a task should be suspended |
| COrg.Apache.REEF.Common.Tasks.Events.ITaskStart | |
| COrg.Apache.REEF.Common.Tasks.Events.ITaskStop | |
| COrg.Apache.REEF.Common.Tasks.IDriverConnectionMessage | The message triggered on a change of status in heartbeat to Driver |
| ►COrg.Apache.REEF.Common.Tasks.IDriverMessageHandler | |
| COrg.Apache.REEF.Common.Tasks.Defaults.DefaultDriverMessageHandler | |
| ►COrg.Apache.REEF.Common.Tasks.ITaskMessageSource | |
| COrg.Apache.REEF.Common.Tasks.Defaults.DefaultTaskMessageSource | |
| COrg.Apache.REEF.Common.Tasks.TaskConfigurationOptions | |
| COrg.Apache.REEF.Driver.Bridge.Avro.DefinedRuntimes | Used to serialize and deserialize Avro record org.apache.reef.javabridge.avro.DefinedRuntimes |
| COrg.Apache.REEF.Driver.Bridge.BridgeHandlerManager | A class that holds all .NET handles for Java InterOp calls |
| COrg.Apache.REEF.Driver.Bridge.BridgeLogger | A wrapper around the general Logger class used specifically for logging in CPP bridge code |
| ►COrg.Apache.REEF.Driver.Bridge.Clr2java.IClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IActiveContextClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IAllocatedEvaluatorClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IClosedContextClr2Java | A closed context event from Java |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.ICompletedEvaluatorClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.ICompletedTaskClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IContextMessageClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IDriverRestartedClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IEvaluatorRequestorClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IFailedContextClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IFailedTaskClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IHttpServerBridgeClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IRunningTaskClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.ISuspendedTaskClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.ITaskMessageClr2Java | |
| ►COrg.Apache.REEF.Driver.Bridge.Clr2java.IClr2JavaTaskMessage | An message sent from a Task to a Driver |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.ICompletedTaskClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.ISuspendedTaskClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IDriverRestartCompletedClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.Clr2java.IFailedEvaluatorClr2Java | |
| COrg.Apache.REEF.Driver.Bridge.ClrClientHelper | |
| COrg.Apache.REEF.Driver.Bridge.ClrHandlerHelper | |
| COrg.Apache.REEF.Driver.Bridge.ClrSystemHandlerWrapper | |
| COrg.Apache.REEF.Driver.Bridge.CommandLineArguments | |
| COrg.Apache.REEF.Driver.Bridge.CustomTraceLevel | |
| COrg.Apache.REEF.Driver.Bridge.CustomTraceListeners | |
| COrg.Apache.REEF.Driver.Bridge.DriverBridgeConfigurationOptions | Hosts all named parameters for Drivers, including bridge handlers |
| COrg.Apache.REEF.Driver.Bridge.HttpServerPort | |
| ►COrg.Apache.REEF.Driver.Bridge.IHttpHandler | |
| COrg.Apache.REEF.Driver.Defaults.DefaultHttpHandler | |
| COrg.Apache.REEF.Driver.Bridge.IHttpMessage | |
| COrg.Apache.REEF.Driver.Bridge.ILogger | |
| COrg.Apache.REEF.Driver.Bridge.ReefHttpRequest | |
| COrg.Apache.REEF.Driver.Bridge.ReefHttpResponse | |
| COrg.Apache.REEF.Driver.Constants | |
| COrg.Apache.REEF.Driver.DriverConfigGenerator | |
| COrg.Apache.REEF.Driver.DriverConfigurationSettings | |
| COrg.Apache.REEF.Driver.Evaluator.EvaluatorRequestBuilder | |
| ►COrg.Apache.REEF.Driver.Evaluator.IEvaluatorDescriptor | Metadata about an Evaluator |
| COrg.Apache.REEF.Driver.Evaluator.EvaluatorDescriptorImpl | |
| COrg.Apache.REEF.Driver.Evaluator.IEvaluatorRequest | A request for an Evaluator allocation |
| COrg.Apache.REEF.Driver.Evaluator.IEvaluatorRequestor | Interface through which Evaluators can be requested |
| COrg.Apache.REEF.Driver.IDriver | empty driver interface to facilitate referencing driver dll |
| COrg.Apache.REEF.Driver.IDriverRestartCompleted | Event fired on Driver restart completed |
| ►COrg.Apache.REEF.Driver.IDriverStarted | Event fired when the Driver started |
| COrg.Apache.REEF.Driver.IDriverRestarted | Event fired on Driver restarts instead of IDriverStarted |
| COrg.Apache.REEF.Driver.IProgressProvider | Provides the progress of the job to the Resource Manager |
| COrg.Apache.REEF.Driver.Task.ITaskMessage | Driver-side representation of a message sent from a Task to the Driver |
| COrg.Apache.REEF.Evaluator.Evaluator | |
| ►COrg.Apache.REEF.IMRU.API.IIMRUClient | |
| COrg.Apache.REEF.IMRU.InProcess.InProcessIMRUClient | Implements the IMRU client API for in-process execution |
| COrg.Apache.REEF.IMRU.API.IMapFunction< in in TMapInput, out out TMapOutput > | Interface to be implemented by Map functions in IMRU |
| COrg.Apache.REEF.IMRU.API.IMRUJobDefinition | Describes an IMRU Job |
| COrg.Apache.REEF.IMRU.API.IMRUJobDefinitionBuilder | Use this class to create an IMRU Job Definition |
| COrg.Apache.REEF.IMRU.API.IPerMapperConfigGenerator | Class returning mapper specific configuration |
| COrg.Apache.REEF.IMRU.API.IUpdateFunction< TMapInput, in in TMapOutput, TResult > | The interface for the Update function of IMRU |
| COrg.Apache.REEF.IMRU.API.UpdateResult< TMapInput, TResult > | Represents the output of an IUpdateFunction |
| COrg.Apache.REEF.IO.Files.FileSystemInfoFactory | A static factory class that creates an IFileSystemInfo object from a FileSystemInfo object |
| ►COrg.Apache.REEF.IO.Files.IFileSystemInfo | This is meant only as a proxy interface for FileSystemInfo and has no relation to classes in Org.Apache.REEF.IO.FileSystem |
| ►COrg.Apache.REEF.IO.Files.IDirectoryInfo | This is meant only as a proxy interface for DirectoryInfo and has no relation to classes in Org.Apache.REEF.IO.FileSystem |
| COrg.Apache.REEF.IO.Files.DefaultDirectoryInfo | This is meant only as a proxy class for DirectoryInfo and has no relation to classes in Org.Apache.REEF.IO.FileSystem |
| ►COrg.Apache.REEF.IO.Files.IFileInfo | This is meant only as a proxy interface for FileInfo and has no relation to classes in Org.Apache.REEF.IO.FileSystem |
| COrg.Apache.REEF.IO.Files.DefaultFileInfo | This is meant only as a proxy class for FileInfo and has no relation to classes in Org.Apache.REEF.IO.FileSystem |
| COrg.Apache.REEF.IO.FileSystem.FileStatus | Represents metadata about a file |
| COrg.Apache.REEF.IO.FileSystem.IFileSystem | A file system abstraction |
| COrg.Apache.REEF.IO.PartitionedData.FileSystem.IFileDeSerializer< T > | A interface for user to implement its deserializer |
| COrg.Apache.REEF.IO.PartitionedData.IInputPartition< T > | Evaluator-Side representation of a data set partition |
| COrg.Apache.REEF.IO.PartitionedData.IPartitionDescriptor | Driver-Side representation of a partition |
| COrg.Apache.REEF.IO.TempFileCreation.ITempFileCreator | Provide interface to wrap temp file folder and temp file folder creation |
| COrg.Apache.REEF.IO.TestClient.Assert | |
| COrg.Apache.REEF.IO.TestClient.HadoopFileSystemTest | |
| COrg.Apache.REEF.IO.TestClient.Run | This purpose of this test is to run tests in Yarn environment |
| COrg.Apache.REEF.Network.Group.Config.GroupCommConfigurationOptions | |
| COrg.Apache.REEF.Network.Group.Driver.ICommunicationGroupDriver | Used to configure Group Communication operators in Reef driver |
| ►COrg.Apache.REEF.Network.Group.Driver.IGroupCommDriver | Used to create Communication Groups for Group Communication Operators |
| COrg.Apache.REEF.Network.Group.Driver.Impl.GroupCommDriver | Used to create Communication Groups for Group Communication Operators on the Reef driver |
| COrg.Apache.REEF.Network.Group.Driver.Impl.GeneralGroupCommunicationMessage | Messages sent by MPI Operators |
| COrg.Apache.REEF.Network.Group.Driver.Impl.TaskStarter | Helper class to start Group Communication tasks |
| ►COrg.Apache.REEF.Network.Group.Operators.IGroupCommOperator< T > | An Group Communication Operator to be used in a Reef Task |
| ►COrg.Apache.REEF.Network.Group.Operators.IBroadcastReceiver< T > | Group Communication Operator used to receive broadcast messages |
| COrg.Apache.REEF.Network.Group.Operators.Impl.BroadcastReceiver< T > | Group Communication Operator used to receive broadcast messages in pipelined fashion |
| ►COrg.Apache.REEF.Network.Group.Operators.IBroadcastSender< T > | Group Communication Operator used to send messages to child Tasks |
| COrg.Apache.REEF.Network.Group.Operators.Impl.BroadcastSender< T > | Group Communication Operator used to send messages to child Tasks in pipelined fashion |
| ►COrg.Apache.REEF.Network.Group.Operators.IReduceReceiver< T > | Group Communication operator used to receive and reduce messages |
| COrg.Apache.REEF.Network.Group.Operators.Impl.ReduceReceiver< T > | Group Communication operator used to receive and reduce messages in pipelined fashion |
| ►COrg.Apache.REEF.Network.Group.Operators.IReduceSender< T > | Group Communication Operator used to send messages to be reduced by the ReduceReceiver |
| COrg.Apache.REEF.Network.Group.Operators.Impl.ReduceSender< T > | Group Communication Operator used to send messages to be reduced by the ReduceReceiver in pipelined fashion |
| ►COrg.Apache.REEF.Network.Group.Operators.IScatterReceiver< T > | Group Communication operator used to receive a sublist of messages sent from the IScatterSender |
| COrg.Apache.REEF.Network.Group.Operators.Impl.ScatterReceiver< T > | Group Communication operator used to receive a sublist of messages sent from the IScatterSender |
| ►COrg.Apache.REEF.Network.Group.Operators.IScatterSender< T > | Group Communication operator used to scatter a list of elements to all of the IScatterReceivers |
| COrg.Apache.REEF.Network.Group.Operators.Impl.ScatterSender< T > | Group Communication operator used to scatter a list of elements to all of the IScatterReceivers |
| ►COrg.Apache.REEF.Network.Group.Operators.IOperatorSpec | The specification used to define Broadcast Operators |
| COrg.Apache.REEF.Network.Group.Operators.Impl.BroadcastOperatorSpec | The specification used to define Broadcast Operators |
| COrg.Apache.REEF.Network.Group.Operators.Impl.ReduceOperatorSpec | The specification used to define Reduce Group Communication Operators |
| COrg.Apache.REEF.Network.Group.Operators.Impl.ScatterOperatorSpec | The specification used to define Scatter Group Communication Operators |
| ►COrg.Apache.REEF.Network.Group.Operators.IReduceFunction< T > | The class used to aggregate messages sent by ReduceSenders |
| COrg.Apache.REEF.Network.Group.Operators.Impl.ReduceFunction< T > | |
| ►COrg.Apache.REEF.Network.Group.Pipelining.IPipelineDataConverter< T > | User specified class to convert the message to be communicated in to pipelining amenable data and vice-versa |
| COrg.Apache.REEF.Network.Group.Pipelining.Impl.DefaultPipelineDataConverter< T > | Default IPipelineDataConverter implementation This basically is a non-pipelined implementation that just packs the whole message in one single PipelineMessage |
| COrg.Apache.REEF.Network.Group.Pipelining.PipelineMessage< T > | the message for pipelined communication |
| COrg.Apache.REEF.Network.Group.Task.ICommunicationGroupClient | Used by Tasks to fetch Group Communication Operators in the group configured by the driver |
| ►COrg.Apache.REEF.Network.Group.Task.IOperatorTopology< T > | Contains the Operator's topology graph |
| COrg.Apache.REEF.Network.Group.Task.Impl.OperatorTopology< T > | Contains the Operator's topology graph |
| COrg.Apache.REEF.Network.Group.Topology.ITopology< T > | Represents a topology graph for IGroupCommOperators |
| COrg.Apache.REEF.Network.Naming.Contracts.AvroNamingAssignment | Used to serialize and deserialize Avro record Org.Apache.REEF.Network.Naming.Contracts.AvroNamingAssignment |
| COrg.Apache.REEF.Network.Naming.Contracts.AvroNamingLookupRequest | Used to serialize and deserialize Avro record Org.Apache.REEF.Network.Naming.Contracts.AvroNamingLookupRequest |
| COrg.Apache.REEF.Network.Naming.Contracts.AvroNamingLookupResponse | Used to serialize and deserialize Avro record Org.Apache.REEF.Network.Naming.Contracts.AvroNamingLookupResponse |
| COrg.Apache.REEF.Network.Naming.Contracts.AvroNamingRegisterRequest | Used to serialize and deserialize Avro record Org.Apache.REEF.Network.Naming.Contracts.AvroNamingRegisterRequest |
| COrg.Apache.REEF.Network.Naming.Contracts.AvroNamingUnRegisterRequest | Used to serialize and deserialize Avro record Org.Apache.REEF.Network.Naming.Contracts.AvroNamingUnRegisterRequest |
| COrg.Apache.REEF.Network.Naming.Parameters.NameCacheConfiguration | |
| COrg.Apache.REEF.Network.NetworkService.Codec.NsMessageProto | |
| COrg.Apache.REEF.Network.NetworkService.NetworkServiceOptions | |
| COrg.Apache.REEF.Network.NetworkService.NsMessage< T > | Message sent between NetworkServices |
| COrg.Apache.REEF.Network.Utilities.BlockingCollectionExtensions | |
| COrg.Apache.REEF.Tang.Annotations.Name< T > | Base class for named parameters |
| COrg.Apache.REEF.Tang.Formats.AvroConfigurationDataContract.AvroConfiguration | |
| COrg.Apache.REEF.Tang.Formats.AvroConfigurationDataContract.ConfigurationEntry | |
| COrg.Apache.REEF.Tang.Formats.ConfigurationFile | |
| COrg.Apache.REEF.Tang.Formats.ConfigurationModule | Allows applications to bundle sets of configuration options together into discrete packages |
| ►COrg.Apache.REEF.Tang.Formats.ConfigurationModuleBuilder | |
| COrg.Apache.REEF.Client.API.TcpPortConfigurationModule | Configuration Module for the TCP port provider |
| COrg.Apache.REEF.Client.Local.LocalRuntimeClientConfiguration | |
| COrg.Apache.REEF.Client.YARN.HDI.HDInsightClientConfiguration | |
| COrg.Apache.REEF.Client.Yarn.YARNClientConfiguration | The Configuration for the YARN Client |
| COrg.Apache.REEF.Common.Context.ContextConfiguration | |
| COrg.Apache.REEF.Common.Io.NamingConfiguration | |
| COrg.Apache.REEF.Common.Services.ServiceConfiguration | Configuration module for services |
| COrg.Apache.REEF.Common.Tasks.TaskConfiguration | |
| COrg.Apache.REEF.Driver.DriverConfiguration | Fill this out to configure a Driver |
| COrg.Apache.REEF.IMRU.API.IMRUCodecConfiguration< T > | A configuration module for specifying codecs for IMRU |
| COrg.Apache.REEF.IMRU.API.IMRUMapConfiguration< TMapInput, TMapOutput > | A configuration module for IMRU IMapFunction |
| COrg.Apache.REEF.IMRU.API.IMRUPerMapperConfigGeneratorConfiguration | A configuration module for per mapper configuration |
| COrg.Apache.REEF.IMRU.API.IMRUPipelineDataConverterConfiguration< T > | A configuration module for The PipelineDataConverter used for chunking and dechunking TMapInput and TMapOutput |
| COrg.Apache.REEF.IMRU.API.IMRUReduceFunctionConfiguration< TMapOutput > | A configuration module for IMRU Reduce function |
| COrg.Apache.REEF.IMRU.API.IMRUUpdateConfiguration< TMapInput, TMapOutput, TResult > | A configuration module for IMRU Update function |
| COrg.Apache.REEF.IMRU.InProcess.InProcessIMRUConfiguration | Configuration module for the in-process IMRU |
| COrg.Apache.REEF.IMRU.OnREEF.Client.REEFIMRUClientConfiguration | A configuration module for specifying REEFIMRUClient |
| COrg.Apache.REEF.IO.FileSystem.AzureBlob.AzureBlockBlobFileSystemConfiguration | Configuration Module for the Azure Block Blob (WASB) file system implementation of IFileSystem |
| COrg.Apache.REEF.IO.FileSystem.Hadoop.HadoopFileSystemConfiguration | Configuration Module for the (command based) Hadoop file system implementation of IFileSystem |
| COrg.Apache.REEF.IO.FileSystem.Hadoop.HDFSConfigurationWithoutDriverBinding | Configuration Module for the (command based) Hadoop file system implementation of IFileSystem |
| COrg.Apache.REEF.IO.FileSystem.Local.LocalFileSystemConfiguration | ConfigurationModule for the local file system |
| COrg.Apache.REEF.IO.PartitionedData.FileSystem.FileSystemInputPartitionConfiguration< T > | This configuration module set FileSystemDataSet as IPartitionedDataSet |
| COrg.Apache.REEF.IO.PartitionedData.Random.RandomInputDataConfiguration | Configuration module for the random dataset generator |
| COrg.Apache.REEF.IO.TempFileCreation.TempFileConfigurationModule | Configuration Module for TempFileCreator |
| COrg.Apache.REEF.Network.Group.Config.CodecConfiguration< T > | |
| COrg.Apache.REEF.Network.Group.Config.CodecToStreamingCodecConfiguration< T > | |
| COrg.Apache.REEF.Network.Group.Config.PipelineDataConverterConfiguration< T > | |
| COrg.Apache.REEF.Network.Group.Config.ReduceFunctionConfiguration< T > | |
| COrg.Apache.REEF.Network.Group.Config.StreamingCodecConfiguration< T > | Defines configuration for streaming codecs and pipeline message streaming codecs by taking streaming codec as input |
| COrg.Apache.REEF.Network.Group.Config.StreamingCodecConfigurationMinusMessage< T > | Defines configuration for internal streaming codecs and internal pipeline message streaming codecs required for group communication |
| COrg.Apache.REEF.Network.TcpClientConfigurationModule | Configuration Module for the TCP Client provider |
| ►COrg.Apache.REEF.Tang.Formats.IConfigurationSerializer | |
| COrg.Apache.REEF.Tang.Formats.AvroConfigurationSerializer | |
| ►COrg.Apache.REEF.Tang.Formats.IImpl< T > | |
| COrg.Apache.REEF.Tang.Formats.OptionalImpl< T > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< T > | |
| ►COrg.Apache.REEF.Tang.Formats.IParam< T > | |
| COrg.Apache.REEF.Tang.Formats.OptionalParameter< T > | |
| COrg.Apache.REEF.Tang.Formats.RequiredParameter< T > | |
| COrg.Apache.REEF.Tang.Formats.Provides< T > | |
| COrg.Apache.REEF.Tang.Implementations.ClassHierarchy.AvroDataContract.AvroClassNode | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroClassNode |
| COrg.Apache.REEF.Tang.Implementations.ClassHierarchy.AvroDataContract.AvroConstructorArg | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroConstructorArg |
| COrg.Apache.REEF.Tang.Implementations.ClassHierarchy.AvroDataContract.AvroConstructorDef | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroConstructorDef |
| COrg.Apache.REEF.Tang.Implementations.ClassHierarchy.AvroDataContract.AvroNamedParameterNode | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroNamedParameterNode |
| COrg.Apache.REEF.Tang.Implementations.ClassHierarchy.AvroDataContract.AvroNode | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroNode |
| COrg.Apache.REEF.Tang.Implementations.ClassHierarchy.AvroDataContract.AvroPackageNode | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroPackageNode |
| COrg.Apache.REEF.Tang.Implementations.Configuration.Configurations | |
| COrg.Apache.REEF.Tang.Implementations.InjectionPlan.IInjectionFuture< out out T > | |
| COrg.Apache.REEF.Tang.Implementations.Tang.TangFactory | |
| COrg.Apache.REEF.Tang.Interface.Aspect | |
| ►COrg.Apache.REEF.Tang.Interface.IClassHierarchy | |
| COrg.Apache.REEF.Tang.Interface.ICsClassHierarchy | |
| COrg.Apache.REEF.Tang.Protobuf.ProtocolBufferClassHierarchy | |
| COrg.Apache.REEF.Tang.Interface.IClassHierarchySerializer | |
| COrg.Apache.REEF.Tang.Interface.IConfiguration | |
| ►COrg.Apache.REEF.Tang.Interface.IConfigurationBuilder | |
| COrg.Apache.REEF.Tang.Interface.ICsConfigurationBuilder | |
| ►COrg.Apache.REEF.Tang.Interface.IConfigurationProvider | Provides configurations |
| ►COrg.Apache.REEF.Common.Evaluator.DriverConnectionConfigurationProviders.IDriverReconnConfigProvider | A configuration provider for the Evaluator to create the appropriate reconnection object to reconnect to the Driver based on the environment |
| COrg.Apache.REEF.Common.Evaluator.DriverConnectionConfigurationProviders.LocalHttpDriverReconnConfigProvider | A driver reconnection configuration provider for the Local Driver based on HTTP connection |
| COrg.Apache.REEF.Common.Evaluator.DriverConnectionConfigurationProviders.YarnClusterHttpDriverReconnConfigProvider | A driver reconnection configuration provider for the YARN Driver based on HTTP connection |
| COrg.Apache.REEF.Common.Evaluator.DriverConnectionConfigurationProviders.YarnOneBoxHttpDriverReconnConfigProvider | A driver reconnection configuration provider for the YARN OneBox Driver based on HTTP connection |
| COrg.Apache.REEF.Common.Io.TcpPortConfigurationProvider | |
| COrg.Apache.REEF.Network.TcpClientConfigurationProvider | Configuration provider for TcpClient connection |
| COrg.Apache.REEF.Wake.Remote.Impl.LoopbackLocalAddressProvider | Provides the loopback address as the local address |
| COrg.Apache.REEF.Tang.Interface.IExternalConstructor< out out T > | |
| COrg.Apache.REEF.Tang.Interface.IInjector | |
| COrg.Apache.REEF.Tang.Interface.ITang | |
| COrg.Apache.REEF.Tang.Tools.ClassHierarchyBuilder | |
| COrg.Apache.REEF.Tang.Types.IConstructorArg | |
| COrg.Apache.REEF.Tang.Types.ITraversable< T > | |
| COrg.Apache.REEF.Tang.Util.AssemblyLoader | |
| COrg.Apache.REEF.Tang.Util.GenericType< T > | |
| COrg.Apache.REEF.Tang.Util.ReflectionUtilities | |
| COrg.Apache.REEF.Utilities.AsyncUtils.LoggingHelper | Logging helpers for TPL |
| COrg.Apache.REEF.Utilities.AsyncUtils.VoidResult | A type used to indicate that no meaningful value is returned |
| COrg.Apache.REEF.Utilities.AvroUtils | |
| COrg.Apache.REEF.Utilities.ByteUtilities | |
| COrg.Apache.REEF.Utilities.Diagnostics.Exceptions | |
| ►COrg.Apache.REEF.Utilities.IIdentifiable | Denotes an object that has a string identifier |
| ►COrg.Apache.REEF.Common.Api.IFailure | Common interface for all error messages in REEF |
| COrg.Apache.REEF.Common.Api.AbstractFailure | |
| ►COrg.Apache.REEF.Common.Api.IAbstractFailure | |
| COrg.Apache.REEF.Driver.Task.IFailedTask | |
| COrg.Apache.REEF.Common.Context.IContextMessage | |
| COrg.Apache.REEF.Common.Exceptions.JobException | |
| ►COrg.Apache.REEF.Driver.Context.IContext | A common base interface for Contexts, available or failed |
| COrg.Apache.REEF.Driver.Context.IActiveContext | |
| COrg.Apache.REEF.Driver.Context.IClosedContext | A closed context |
| COrg.Apache.REEF.Driver.Context.IFailedContext | |
| COrg.Apache.REEF.Driver.Evaluator.IAllocatedEvaluator | Represents an Evaluator that is allocated, but is not running yet |
| COrg.Apache.REEF.Driver.Evaluator.ICompletedEvaluator | Represents an Evaluator that has completed |
| COrg.Apache.REEF.Driver.Evaluator.IFailedEvaluator | Represents an Evaluator that became unavailable |
| COrg.Apache.REEF.Driver.Task.ICompletedTask | |
| COrg.Apache.REEF.Driver.Task.IRunningTask | Represents a running Task |
| COrg.Apache.REEF.Driver.Task.ISuspendedTask | Represents a suspended task |
| ►COrg.Apache.REEF.Utilities.IMessage | A message from a REEF component |
| COrg.Apache.REEF.Common.Context.IContextMessage | |
| COrg.Apache.REEF.Common.Tasks.TaskMessage | |
| COrg.Apache.REEF.Driver.Task.ICompletedTask | |
| COrg.Apache.REEF.Driver.Task.ISuspendedTask | Represents a suspended task |
| COrg.Apache.REEF.Utilities.Logging.Logger | |
| COrg.Apache.REEF.Utilities.NetUtilities | |
| COrg.Apache.REEF.Utilities.Optional< T > | A convenience class that indicates whether a variable is set or not |
| COrg.Apache.REEF.Utilities.ValidationUtilities | |
| COrg.Apache.REEF.Wake.Examples.P2p.IEventSource< T > | The pull side of the interface: Clients implement this and register it with the PullToPush class |
| ►COrg.Apache.REEF.Wake.IEventHandler< T > | Handler to process an event |
| COrg.Apache.REEF.Wake.IEStage< T > | Stage that executes an event handler |
| COrg.Apache.REEF.Wake.Impl.MultiEventHandler< T > | Event handler that dispatches an event to a specific handler based on an event class type |
| COrg.Apache.REEF.Wake.Impl.PubSubEventHandler< T > | Event handler to provide publish/subscribe interfaces |
| ►COrg.Apache.REEF.Wake.IIdentifier | Identifier class for REEF |
| COrg.Apache.REEF.Wake.Remote.Impl.StringIdentifier | |
| ►COrg.Apache.REEF.Wake.Remote.IRemoteIdentifier | An identifier that represents a remote source |
| COrg.Apache.REEF.Wake.Remote.Impl.SocketRemoteIdentifier | Remote identifier based on a socket address |
| ►COrg.Apache.REEF.Wake.IIdentifierFactory | |
| COrg.Apache.REEF.Wake.Remote.Impl.StringIdentifierFactory | |
| COrg.Apache.REEF.Wake.Remote.IRemoteIdentifierFactory | Factory that creates a RemoteIdentifier |
| COrg.Apache.REEF.Wake.Impl.PeriodicEvent | Periodic event for timers |
| COrg.Apache.REEF.Wake.IObserverFactory | |
| COrg.Apache.REEF.Wake.Remote.IConnectionRetryHandler | Interface for the retry logic to connect to remote endpoint |
| ►COrg.Apache.REEF.Wake.Remote.IDataReader | Interface for reading standard primitives |
| COrg.Apache.REEF.Wake.Remote.Impl.StreamDataReader | Class with functions to Read from stream |
| ►COrg.Apache.REEF.Wake.Remote.IDataWriter | Interface for writing standard primitives |
| COrg.Apache.REEF.Wake.Remote.Impl.StreamDataWriter | |
| ►COrg.Apache.REEF.Wake.Remote.IDecoder< T > | Interface for serialization routines that translate back and forth between byte arrays with low latency |
| ►COrg.Apache.REEF.Wake.Remote.ICodec< T > | Interface for serialization routines that translate back and forth between byte arrays with low latency |
| COrg.Apache.REEF.Wake.Remote.Impl.MultiCodec< T > | Codec that can encode and decode a class depending on the class type |
| COrg.Apache.REEF.Wake.Remote.Impl.MultiDecoder< T > | Decoder using the WakeTuple protocol buffer (class name and bytes) |
| ►COrg.Apache.REEF.Wake.Remote.IEncoder< T > | Interface for serialization routines that translate back and forth between byte arrays with low latency |
| COrg.Apache.REEF.Wake.Remote.ICodec< T > | Interface for serialization routines that translate back and forth between byte arrays with low latency |
| COrg.Apache.REEF.Wake.Remote.Impl.MultiEncoder< T > | Encoder using the WakeTuple protocol buffer (class name and bytes) |
| ►COrg.Apache.REEF.Wake.Remote.ILocalAddressProvider | Provides the local address |
| COrg.Apache.REEF.Wake.Remote.Impl.DefaultLocalAddressProvider | The local address provider that provides the local IP address using NetworkUtils.LocalIPAddress |
| COrg.Apache.REEF.Wake.Remote.Impl.LoopbackLocalAddressProvider | Provides the loopback address as the local address |
| COrg.Apache.REEF.Wake.Remote.Impl.Channel | Performs low level network IO operations between hosts |
| COrg.Apache.REEF.Wake.Remote.Impl.RemoteEventEndPoint< T > | |
| COrg.Apache.REEF.Wake.Remote.Impl.StreamingRemoteManagerFactory | StreamingRemoteManagerFactory for StreamingRemoteManager |
| COrg.Apache.REEF.Wake.Remote.Impl.TransportEvent< T > | |
| ►COrg.Apache.REEF.Wake.Remote.IRemoteEvent< T > | |
| COrg.Apache.REEF.Wake.Remote.Impl.RemoteEvent< T > | |
| COrg.Apache.REEF.Wake.Remote.IRemoteManagerFactory | Creates new instances of IRemoteManager |
| COrg.Apache.REEF.Wake.Remote.IRemoteMessage< T > | Message received from a remote handler |
| COrg.Apache.REEF.Wake.Remote.ISubscriptionManager | |
| ►COrg.Apache.REEF.Wake.Remote.ITcpClientConnectionFactory | Provides TcpClient for the remote endpoint |
| COrg.Apache.REEF.Wake.Remote.Impl.TcpClientConnectionFactory | Default implementation of ITcpClientFactory |
| COrg.Apache.REEF.Wake.Remote.RemoteConfiguration | |
| ►COrg.Apache.REEF.Wake.RX.IStaticObservable | |
| COrg.Apache.REEF.Wake.RX.Impl.RxTimerStage | Timer stage that provides events to the observer periodically |
| COrg.Apache.REEF.Wake.RX.ISubject< In, Out > | A class implementing Observer> and StaticObservable |
| ►COrg.Apache.REEF.Wake.StreamingCodec.IStreamingCodec< T > | Codec Interface that external users should implement to directly write to the stream |
| COrg.Apache.REEF.Wake.StreamingCodec.CodecToStreamingCodec< T > | Converts codec to streaming codec |
| ►COrg.Apache.REEF.Wake.Time.Runtime.ITimer | |
| COrg.Apache.REEF.Wake.Time.Runtime.LogicalTimer | LogicalTimer class used for testing purposes |
| COrg.Apache.REEF.Wake.Time.Runtime.RealTimer | |
| COrg.Apache.REEF.Wake.Util.Actionable | |
| ►COrg.Apache.REEF.Wake.Util.IStartable | |
| COrg.Apache.REEF.Wake.Examples.P2p.Pull2Push< T > | Performs a Pull-to-Push conversion in Wake |
| ►COrg.Apache.REEF.Wake.Util.ITaskService | |
| COrg.Apache.REEF.Wake.Util.FixedThreadPoolTaskService | |
| COrg.Apache.REEF.Wake.Util.NetworkUtils | |
| COrg.Apache.REEF.Wake.Util.SerializationHelper | |
| COrg.Apache.REEF.Wake.Util.TaskExtensions | |
| COrg.Apache.REEF.Wake.Util.TimeHelper | |
| COrg.Apache.REEF.Utilities.Collections.PriorityQueue< Org.Apache.REEF.Wake.Time.Time > | |
| COrg.Apache.REEF.Wake.RX.Impl.PubSubSubject< Org.Apache.REEF.Wake.Time.Time > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< ICodec< T > > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< IObserver< Org.Apache.REEF.Driver.IDriverStarted > > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< IPipelineDataConverter< T > > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< IReduceFunction< T > > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< IReduceFunction< TMapOutput > > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< IStreamingCodec< T > > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< Org.Apache.REEF.Common.Tasks.ITask > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< Org.Apache.REEF.IMRU.API.IMapFunction< TMapInput, TMapOutput > > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< Org.Apache.REEF.IMRU.API.IPerMapperConfigGenerator > | |
| COrg.Apache.REEF.Tang.Formats.RequiredImpl< Org.Apache.REEF.IMRU.API.IUpdateFunction< TMapInput, TMapOutput, TResult > > | |
| COrg.Apache.REEF.Tang.Formats.RequiredParameter< int > | |
| COrg.Apache.REEF.Tang.Formats.RequiredParameter< string > | |
| ►CSortedDictionary | |
| COrg.Apache.REEF.Tang.Util.MonotonicTreeMap< TKey, TVal > | |
| ►CSortedSet | |
| COrg.Apache.REEF.Tang.Util.MonotonicSet< T > | |
| ►CSystemException | |
| ►COrg.Apache.REEF.Tang.Exceptions.BindException | |
| COrg.Apache.REEF.Tang.Exceptions.NameResolutionException | |
| COrg.Apache.REEF.Tang.Exceptions.ParseException | |
| COrg.Apache.REEF.Tang.Exceptions.ClassHierarchyException | |
| ►CTraceListener | |
| COrg.Apache.REEF.Driver.Defaults.DefaultCustomTraceListener | |
| COrg.Apache.REEF.Wake.Remote.Impl.TransportClient< NamingEvent > | |
| COrg.Apache.REEF.Wake.Remote.Impl.TransportClient< Org.Apache.REEF.Wake.Remote.IRemoteEvent< T > > | |
| COrg.Apache.REEF.Wake.Remote.Impl.TransportServer< NamingEvent > | |
| COrg.Apache.REEF.Wake.Remote.Impl.TransportServer< Org.Apache.REEF.Wake.Remote.IRemoteEvent< T > > | |
1.8.11
