Hierarchy For All Packages

Package Hierarchies:

• org.apache.reef.annotations,
• org.apache.reef.annotations.audience,
• org.apache.reef.annotations.semantics,
• org.apache.reef.client,
• org.apache.reef.client.parameters,
• org.apache.reef.common,
• org.apache.reef.driver,
• org.apache.reef.driver.catalog,
• org.apache.reef.driver.client,
• org.apache.reef.driver.context,
• org.apache.reef.driver.evaluator,
• org.apache.reef.driver.parameters,
• org.apache.reef.driver.task,
• org.apache.reef.evaluator.context,
• org.apache.reef.evaluator.context.events,
• org.apache.reef.evaluator.context.parameters,
• org.apache.reef.examples.data.loading,
• org.apache.reef.examples.hello,
• org.apache.reef.examples.helloCLR,
• org.apache.reef.examples.hellohttp,
• org.apache.reef.examples.library,
• org.apache.reef.examples.pool,
• org.apache.reef.examples.retained_eval,
• org.apache.reef.examples.retained_evalCLR,
• org.apache.reef.examples.scheduler,
• org.apache.reef.examples.suspend,
• org.apache.reef.examples.utils.wake,
• org.apache.reef.exception,
• org.apache.reef.exception.evaluator,
• org.apache.reef.io,
• org.apache.reef.io.checkpoint,
• org.apache.reef.io.checkpoint.fs,
• org.apache.reef.io.data.loading.api,
• org.apache.reef.io.data.loading.impl,
• org.apache.reef.io.naming,
• org.apache.reef.io.network,
• org.apache.reef.io.network.exception,
• org.apache.reef.io.network.impl,
• org.apache.reef.io.network.naming,
• org.apache.reef.io.network.naming.avro,
• org.apache.reef.io.network.naming.exception,
• org.apache.reef.io.network.naming.serialization,
• org.apache.reef.io.network.proto,
• org.apache.reef.io.network.util,
• org.apache.reef.io.serialization,
• org.apache.reef.io.storage,
• org.apache.reef.io.storage.local,
• org.apache.reef.io.storage.ram,
• org.apache.reef.io.storage.util,
• org.apache.reef.poison,
• org.apache.reef.poison.context,
• org.apache.reef.poison.params,
• org.apache.reef.poison.task,
• org.apache.reef.proto,
• org.apache.reef.runtime.common,
• org.apache.reef.runtime.common.client,
• org.apache.reef.runtime.common.client.api,
• org.apache.reef.runtime.common.client.defaults,
• org.apache.reef.runtime.common.client.parameters,
• org.apache.reef.runtime.common.driver,
• org.apache.reef.runtime.common.driver.api,
• org.apache.reef.runtime.common.driver.catalog,
• org.apache.reef.runtime.common.driver.client,
• org.apache.reef.runtime.common.driver.context,
• org.apache.reef.runtime.common.driver.defaults,
• org.apache.reef.runtime.common.driver.evaluator,
• org.apache.reef.runtime.common.driver.idle,
• org.apache.reef.runtime.common.driver.resourcemanager,
• org.apache.reef.runtime.common.driver.task,
• org.apache.reef.runtime.common.evaluator,
• org.apache.reef.runtime.common.evaluator.context,
• org.apache.reef.runtime.common.evaluator.context.defaults,
• org.apache.reef.runtime.common.evaluator.parameters,
• org.apache.reef.runtime.common.evaluator.task,
• org.apache.reef.runtime.common.evaluator.task.defaults,
• org.apache.reef.runtime.common.evaluator.task.exceptions,
• org.apache.reef.runtime.common.files,
• org.apache.reef.runtime.common.launch,
• org.apache.reef.runtime.common.launch.parameters,
• org.apache.reef.runtime.common.parameters,
• org.apache.reef.runtime.common.utils,
• org.apache.reef.runtime.hdinsight,
• org.apache.reef.runtime.hdinsight.cli,
• org.apache.reef.runtime.hdinsight.client,
• org.apache.reef.runtime.hdinsight.client.sslhacks,
• org.apache.reef.runtime.hdinsight.client.yarnrest,
• org.apache.reef.runtime.hdinsight.parameters,
• org.apache.reef.runtime.local,
• org.apache.reef.runtime.local.client,
• org.apache.reef.runtime.local.client.parameters,
• org.apache.reef.runtime.local.driver,
• org.apache.reef.runtime.local.driver.parameters,
• org.apache.reef.runtime.local.process,
• org.apache.reef.runtime.yarn,
• org.apache.reef.runtime.yarn.client,
• org.apache.reef.runtime.yarn.client.parameters,
• org.apache.reef.runtime.yarn.driver,
• org.apache.reef.runtime.yarn.driver.parameters,
• org.apache.reef.runtime.yarn.util,
• org.apache.reef.tang,
• org.apache.reef.tang.annotations,
• org.apache.reef.tang.examples,
• org.apache.reef.tang.examples.timer,
• org.apache.reef.tang.exceptions,
• org.apache.reef.tang.formats,
• org.apache.reef.tang.formats.avro,
• org.apache.reef.tang.implementation,
• org.apache.reef.tang.implementation.java,
• org.apache.reef.tang.implementation.protobuf,
• org.apache.reef.tang.implementation.types,
• org.apache.reef.tang.proto,
• org.apache.reef.tang.types,
• org.apache.reef.tang.util,
• org.apache.reef.tang.util.walk,
• org.apache.reef.tang.util.walk.graphviz,
• org.apache.reef.task,
• org.apache.reef.task.events,
• org.apache.reef.tests,
• org.apache.reef.tests.driver,
• org.apache.reef.tests.evaluatorreuse,
• org.apache.reef.tests.fail.driver,
• org.apache.reef.tests.fail.task,
• org.apache.reef.tests.library,
• org.apache.reef.tests.library.driver,
• org.apache.reef.tests.library.exceptions,
• org.apache.reef.tests.library.tasks,
• org.apache.reef.tests.messaging.driver,
• org.apache.reef.tests.messaging.task,
• org.apache.reef.tests.statepassing,
• org.apache.reef.tests.yarn.failure,
• org.apache.reef.util,
• org.apache.reef.util.logging,
• org.apache.reef.wake,
• org.apache.reef.wake.examples,
• org.apache.reef.wake.examples.accumulate,
• org.apache.reef.wake.examples.join,
• org.apache.reef.wake.examples.p2p,
• org.apache.reef.wake.exception,
• org.apache.reef.wake.impl,
• org.apache.reef.wake.metrics,
• org.apache.reef.wake.profiler,
• org.apache.reef.wake.remote,
• org.apache.reef.wake.remote.exception,
• org.apache.reef.wake.remote.impl,
• org.apache.reef.wake.remote.proto,
• org.apache.reef.wake.remote.transport,
• org.apache.reef.wake.remote.transport.exception,
• org.apache.reef.wake.remote.transport.netty,
• org.apache.reef.wake.rx,
• org.apache.reef.wake.rx.exception,
• org.apache.reef.wake.rx.impl,
• org.apache.reef.wake.storage,
• org.apache.reef.wake.test.proto,
• org.apache.reef.wake.time,
• org.apache.reef.wake.time.event,
• org.apache.reef.wake.time.runtime,
• org.apache.reef.wake.time.runtime.event,
• org.apache.reef.webserver

Class Hierarchy

• java.lang.Object
  • org.apache.reef.tang.examples.A
    • org.apache.reef.tang.examples.B
  • org.apache.reef.tang.util.walk.AbstractClassHierarchyNodeVisitor (implements org.apache.reef.tang.util.walk.NodeVisitor<T>)
    • org.apache.reef.tang.util.walk.graphviz.GraphvizConfigVisitor (implements org.apache.reef.tang.util.walk.EdgeVisitor<T>)
  • java.util.AbstractCollection<E> (implements java.util.Collection<E>)
    • java.util.AbstractSet<E> (implements java.util.Set<E>)
      • java.util.HashSet<E> (implements java.lang.Cloneable, java.io.Serializable, java.util.Set<E>)
        • org.apache.reef.tang.util.MonotonicHashSet<T>
      • java.util.TreeSet<E> (implements java.lang.Cloneable, java.util.NavigableSet<E>, java.io.Serializable)
        • org.apache.reef.tang.util.MonotonicSet<T>
  • org.apache.reef.runtime.common.driver.api.AbstractDriverRuntimeConfiguration (implements org.apache.reef.util.Builder<T>)
    • org.apache.reef.runtime.local.driver.LocalDriverRuntimeConfiguration
  • org.apache.reef.runtime.common.driver.api.AbstractDriverRuntimeConfiguration.ClientRemoteIdentifier (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.api.AbstractDriverRuntimeConfiguration.DriverProcessMemory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.api.AbstractDriverRuntimeConfiguration.EvaluatorTimeout (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.api.AbstractDriverRuntimeConfiguration.JobIdentifier (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.AbstractEStage<T> (implements org.apache.reef.wake.EStage<T>)
    • org.apache.reef.wake.impl.ForkPoolStage<T>
    • org.apache.reef.wake.impl.IndependentIterationsThreadPoolStage<T>
    • org.apache.reef.wake.impl.SingleThreadStage<T>
    • org.apache.reef.wake.impl.SyncStage<T>
    • org.apache.reef.wake.impl.ThreadPoolStage<T>
  • org.apache.reef.common.AbstractFailure (implements org.apache.reef.common.Failure)
    • org.apache.reef.runtime.common.driver.context.FailedContextImpl (implements org.apache.reef.driver.context.FailedContext)
    • org.apache.reef.client.FailedJob
    • org.apache.reef.client.FailedRuntime
    • org.apache.reef.driver.task.FailedTask
  • org.apache.reef.tang.util.walk.AbstractInjectionPlanNodeVisitor (implements org.apache.reef.tang.util.walk.NodeVisitor<T>)
    • org.apache.reef.tang.util.walk.graphviz.GraphvizInjectionPlanVisitor (implements org.apache.reef.tang.util.walk.EdgeVisitor<T>)
  • java.util.AbstractMap<K,V> (implements java.util.Map<K,V>)
    • java.util.HashMap<K,V> (implements java.lang.Cloneable, java.util.Map<K,V>, java.io.Serializable)
      • org.apache.reef.tang.util.MonotonicHashMap<T,U>
  • com.google.protobuf.AbstractMessageLite (implements com.google.protobuf.MessageLite)
    • com.google.protobuf.AbstractMessage (implements com.google.protobuf.Message)
      • com.google.protobuf.GeneratedMessage (implements java.io.Serializable)
        • org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode (implements org.apache.reef.tang.proto.ClassHierarchyProto.ClassNodeOrBuilder)
        • org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArg (implements org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArgOrBuilder)
        • org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef (implements org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDefOrBuilder)
        • org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode (implements org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNodeOrBuilder)
        • org.apache.reef.tang.proto.ClassHierarchyProto.Node (implements org.apache.reef.tang.proto.ClassHierarchyProto.NodeOrBuilder)
        • org.apache.reef.tang.proto.ClassHierarchyProto.PackageNode (implements org.apache.reef.tang.proto.ClassHierarchyProto.PackageNodeOrBuilder)
        • org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto (implements org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder)
        • org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto (implements org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.DriverProcessRegistrationProto (implements org.apache.reef.proto.DriverRuntimeProtocol.DriverProcessRegistrationProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.NodeDescriptorProto (implements org.apache.reef.proto.DriverRuntimeProtocol.NodeDescriptorProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.ResourceAllocationProto (implements org.apache.reef.proto.DriverRuntimeProtocol.ResourceAllocationProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.ResourceLaunchProto (implements org.apache.reef.proto.DriverRuntimeProtocol.ResourceLaunchProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.ResourceReleaseProto (implements org.apache.reef.proto.DriverRuntimeProtocol.ResourceReleaseProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.ResourceRequestProto (implements org.apache.reef.proto.DriverRuntimeProtocol.ResourceRequestProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.ResourceStatusProto (implements org.apache.reef.proto.DriverRuntimeProtocol.ResourceStatusProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.RuntimeStatusProto (implements org.apache.reef.proto.DriverRuntimeProtocol.RuntimeStatusProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProto (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProtoOrBuilder)
        • org.apache.reef.tang.proto.InjectionPlanProto.Constructor (implements org.apache.reef.tang.proto.InjectionPlanProto.ConstructorOrBuilder)
        • org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan (implements org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlanOrBuilder)
        • org.apache.reef.tang.proto.InjectionPlanProto.Instance (implements org.apache.reef.tang.proto.InjectionPlanProto.InstanceOrBuilder)
        • org.apache.reef.tang.proto.InjectionPlanProto.Subplan (implements org.apache.reef.tang.proto.InjectionPlanProto.SubplanOrBuilder)
        • org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf (implements org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBufOrBuilder)
        • org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf (implements org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder)
        • org.apache.reef.proto.REEFProtocol.REEFMessage (implements org.apache.reef.proto.REEFProtocol.REEFMessageOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.ContextStatusProto (implements org.apache.reef.proto.ReefServiceProtos.ContextStatusProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto (implements org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto (implements org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.FileResourceProto (implements org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.JobStatusProto (implements org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto (implements org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.TaskStatusProto (implements org.apache.reef.proto.ReefServiceProtos.TaskStatusProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto (implements org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder)
        • org.apache.reef.wake.test.proto.TestProtos.TestEventPBuf (implements org.apache.reef.wake.test.proto.TestProtos.TestEventPBufOrBuilder)
        • org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf (implements org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBufOrBuilder)
        • org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf (implements org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBufOrBuilder)
  • com.google.protobuf.AbstractMessageLite.Builder<BuilderType> (implements com.google.protobuf.MessageLite.Builder)
    • com.google.protobuf.AbstractMessage.Builder<BuilderType> (implements com.google.protobuf.Message.Builder)
      • com.google.protobuf.GeneratedMessage.Builder<BuilderType>
        • org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder (implements org.apache.reef.tang.proto.ClassHierarchyProto.ClassNodeOrBuilder)
        • org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArg.Builder (implements org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArgOrBuilder)
        • org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder (implements org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDefOrBuilder)
        • org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder (implements org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNodeOrBuilder)
        • org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder (implements org.apache.reef.tang.proto.ClassHierarchyProto.NodeOrBuilder)
        • org.apache.reef.tang.proto.ClassHierarchyProto.PackageNode.Builder (implements org.apache.reef.tang.proto.ClassHierarchyProto.PackageNodeOrBuilder)
        • org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder (implements org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder)
        • org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProto.Builder (implements org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.DriverProcessRegistrationProto.Builder (implements org.apache.reef.proto.DriverRuntimeProtocol.DriverProcessRegistrationProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.NodeDescriptorProto.Builder (implements org.apache.reef.proto.DriverRuntimeProtocol.NodeDescriptorProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.ResourceAllocationProto.Builder (implements org.apache.reef.proto.DriverRuntimeProtocol.ResourceAllocationProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.ResourceLaunchProto.Builder (implements org.apache.reef.proto.DriverRuntimeProtocol.ResourceLaunchProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.ResourceReleaseProto.Builder (implements org.apache.reef.proto.DriverRuntimeProtocol.ResourceReleaseProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.ResourceRequestProto.Builder (implements org.apache.reef.proto.DriverRuntimeProtocol.ResourceRequestProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.ResourceStatusProto.Builder (implements org.apache.reef.proto.DriverRuntimeProtocol.ResourceStatusProtoOrBuilder)
        • org.apache.reef.proto.DriverRuntimeProtocol.RuntimeStatusProto.Builder (implements org.apache.reef.proto.DriverRuntimeProtocol.RuntimeStatusProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProtoOrBuilder)
        • org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProto.Builder (implements org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProtoOrBuilder)
        • org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder (implements org.apache.reef.tang.proto.InjectionPlanProto.ConstructorOrBuilder)
        • org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan.Builder (implements org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlanOrBuilder)
        • org.apache.reef.tang.proto.InjectionPlanProto.Instance.Builder (implements org.apache.reef.tang.proto.InjectionPlanProto.InstanceOrBuilder)
        • org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder (implements org.apache.reef.tang.proto.InjectionPlanProto.SubplanOrBuilder)
        • org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder (implements org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBufOrBuilder)
        • org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder (implements org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder)
        • org.apache.reef.proto.REEFProtocol.REEFMessage.Builder (implements org.apache.reef.proto.REEFProtocol.REEFMessageOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder (implements org.apache.reef.proto.ReefServiceProtos.ContextStatusProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder (implements org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.Builder (implements org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.FileResourceProto.Builder (implements org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder (implements org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder (implements org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder (implements org.apache.reef.proto.ReefServiceProtos.TaskStatusProtoOrBuilder)
        • org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder (implements org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder)
        • org.apache.reef.wake.test.proto.TestProtos.TestEventPBuf.Builder (implements org.apache.reef.wake.test.proto.TestProtos.TestEventPBufOrBuilder)
        • org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.Builder (implements org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBufOrBuilder)
        • org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.Builder (implements org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBufOrBuilder)
  • org.apache.reef.tang.util.AbstractMonotonicMultiMap<K,V> (implements java.util.Collection<E>)
    • org.apache.reef.tang.util.MonotonicMultiHashMap<K,V>
    • org.apache.reef.tang.util.MonotonicMultiMap<K,V>
  • org.apache.reef.tang.implementation.types.AbstractNode (implements org.apache.reef.tang.types.Node)
    • org.apache.reef.tang.implementation.types.ClassNodeImpl<T> (implements org.apache.reef.tang.types.ClassNode<T>)
    • org.apache.reef.tang.implementation.types.NamedParameterNodeImpl<T> (implements org.apache.reef.tang.types.NamedParameterNode<T>)
    • org.apache.reef.tang.implementation.types.PackageNodeImpl (implements org.apache.reef.tang.types.PackageNode)
  • org.apache.reef.wake.rx.AbstractObserver<T> (implements org.apache.reef.wake.rx.Observer<T>)
  • org.apache.reef.wake.rx.AbstractRxStage<T> (implements org.apache.reef.wake.rx.RxStage<T>)
    • org.apache.reef.wake.rx.impl.RxSyncStage<T>
    • org.apache.reef.wake.rx.impl.RxThreadPoolStage<T>
  • org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationID
  • org.apache.reef.runtime.common.evaluator.parameters.ApplicationIdentifier (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationResponse
  • org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationState
  • org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationSubmission
  • org.apache.reef.tang.formats.AvroConfigurationSerializer (implements org.apache.reef.tang.formats.ConfigurationSerializer)
  • org.apache.reef.webserver.AvroDriverInfoSerializer (implements org.apache.reef.webserver.DriverInfoSerializer)
  • org.apache.reef.webserver.AvroEvaluatorInfoSerializer (implements org.apache.reef.webserver.EvaluatorInfoSerializer)
  • org.apache.reef.webserver.AvroEvaluatorListSerializer (implements org.apache.reef.webserver.EvaluatorListSerializer)
  • org.apache.reef.webserver.AvroHttpSerializer
  • org.apache.reef.runtime.hdinsight.parameters.AzureStorageAccountContainerName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.hdinsight.parameters.AzureStorageAccountKey (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.hdinsight.parameters.AzureStorageAccountName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.hdinsight.parameters.AzureStorageBaseFolder (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.impl.BindNSToTask (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.impl.BlockingEventHandler<T> (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.examples.utils.wake.BlockingEventHandler<T> (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.examples.join.BlockingJoin (implements org.apache.reef.wake.rx.StaticObservable)
  • org.apache.reef.wake.impl.BlockingSignalEventHandler<T> (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.utils.BroadCastEventHandler<E> (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.remote.impl.ByteCodec (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.wake.remote.transport.netty.ByteEncoder (implements org.apache.reef.wake.remote.Encoder<T>)
  • io.netty.channel.ChannelHandlerAdapter (implements io.netty.channel.ChannelHandler)
    • io.netty.channel.ChannelInboundHandlerAdapter (implements io.netty.channel.ChannelInboundHandler)
      • io.netty.channel.ChannelDuplexHandler (implements io.netty.channel.ChannelOutboundHandler)
        • io.netty.handler.stream.ChunkedWriteHandler
          • org.apache.reef.wake.remote.transport.netty.ChunkedReadWriteHandler
  • org.apache.reef.tang.implementation.java.ClassHierarchyImpl (implements org.apache.reef.tang.JavaClassHierarchy)
  • org.apache.reef.tang.proto.ClassHierarchyProto
  • org.apache.reef.runtime.common.files.ClasspathProvider
  • org.apache.reef.tests.fail.task.Client
  • org.apache.reef.driver.parameters.ClientCloseHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ClientCloseWithMessageHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.client.ClientConnection
  • org.apache.reef.runtime.common.driver.client.ClientManager (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.driver.parameters.ClientMessageHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.client.parameters.ClientPresent (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.client.api.ClientRuntimeParameters
  • org.apache.reef.runtime.common.client.api.ClientRuntimeParameters.RuntimeErrorHandlerRID (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.proto.ClientRuntimeProtocol
  • org.apache.reef.wake.time.Clock.IdleHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.time.Clock.RuntimeStartHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.time.Clock.RuntimeStopHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.time.Clock.StartHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.time.Clock.StopHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.launch.parameters.ClockConfigurationPath (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.idle.ClockIdlenessSource (implements org.apache.reef.runtime.common.driver.idle.DriverIdlenessSource, org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.context.ClosedContextImpl (implements org.apache.reef.driver.context.ClosedContext)
  • org.apache.reef.runtime.common.launch.CLRLaunchCommandBuilder (implements org.apache.reef.runtime.common.launch.LaunchCommandBuilder)
  • org.apache.reef.io.storage.local.CodecFileAccumulable<T,C> (implements org.apache.reef.io.Accumulable<T>)
  • org.apache.reef.io.storage.local.CodecFileIterable<T,C> (implements java.lang.Iterable<T>)
  • org.apache.reef.io.storage.ram.CodecRamMap<T> (implements org.apache.reef.io.ExternalMap<T>)
  • org.apache.reef.io.storage.ram.CodecRamMap.RamMapCodec (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.examples.accumulate.CombinerStage<K,V> (implements org.apache.reef.wake.Stage)
  • org.apache.reef.wake.examples.accumulate.CombinerStage.Pair<K,V> (implements java.lang.Comparable<T>, java.util.Map.Entry<K,V>)
  • org.apache.reef.examples.library.Command (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tang.formats.CommandLine
  • org.apache.reef.util.CommandUtils
  • org.apache.reef.runtime.common.driver.task.CompletedTaskImpl (implements org.apache.reef.driver.task.CompletedTask)
  • org.apache.reef.util.logging.Config
  • org.apache.reef.tang.implementation.ConfigurationBuilderImpl (implements org.apache.reef.tang.ConfigurationBuilder)
    • org.apache.reef.tang.implementation.java.JavaConfigurationBuilderImpl (implements org.apache.reef.tang.JavaConfigurationBuilder)
  • org.apache.reef.tang.formats.ConfigurationFile
  • org.apache.reef.tang.implementation.ConfigurationImpl (implements org.apache.reef.tang.Configuration)
  • org.apache.reef.tang.formats.ConfigurationModule
  • org.apache.reef.tang.formats.ConfigurationModuleBuilder
    • org.apache.reef.client.ClientConfiguration
    • org.apache.reef.runtime.common.client.CommonClientConfigurationModule
    • org.apache.reef.driver.context.ContextConfiguration
    • org.apache.reef.io.data.loading.api.DataLoadingDriverConfiguration
    • org.apache.reef.client.DriverConfiguration
    • org.apache.reef.runtime.common.driver.DriverRuntimeConfiguration
    • org.apache.reef.client.DriverServiceConfiguration
    • org.apache.reef.runtime.common.evaluator.EvaluatorConfiguration
    • org.apache.reef.io.checkpoint.fs.FSCheckPointServiceConfiguration
    • org.apache.reef.runtime.hdinsight.client.HDInsightDriverConfiguration
    • org.apache.reef.runtime.hdinsight.client.HDInsightRuntimeConfiguration
    • org.apache.reef.runtime.hdinsight.client.HDInsightRuntimeConfigurationStatic
    • org.apache.reef.webserver.HttpHandlerConfiguration
    • org.apache.reef.webserver.HttpRuntimeConfiguration
    • org.apache.reef.runtime.local.driver.LocalDriverConfiguration
    • org.apache.reef.runtime.local.client.LocalRuntimeConfiguration
    • org.apache.reef.io.network.naming.NameServerConfiguration
    • org.apache.reef.poison.PoisonedConfiguration
    • org.apache.reef.driver.context.ServiceConfiguration
    • org.apache.reef.driver.task.TaskConfiguration
    • org.apache.reef.tang.examples.timer.TimerMock.TimerMockConf
    • org.apache.reef.runtime.hdinsight.client.UnsafeHDInsightRuntimeConfiguration
    • org.apache.reef.runtime.hdinsight.client.UnsafeHDInsightRuntimeConfigurationStatic
    • org.apache.reef.runtime.yarn.client.YarnClientConfiguration
    • org.apache.reef.runtime.yarn.driver.YarnDriverConfiguration
  • org.apache.reef.tang.Configurations
  • org.apache.reef.tang.implementation.types.ConstructorArgImpl (implements org.apache.reef.tang.types.ConstructorArg)
  • org.apache.reef.tang.implementation.types.ConstructorDefImpl<T> (implements org.apache.reef.tang.types.ConstructorDef<T>)
  • org.apache.reef.runtime.hdinsight.client.yarnrest.ContainerInfo
  • org.apache.reef.driver.parameters.ContextActiveHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ContextClosedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.context.ContextConfiguration.DriverReconnect (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.context.ContextControlHandler
  • org.apache.reef.driver.parameters.ContextFailedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.evaluator.context.parameters.ContextIdentifier (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.evaluator.context.ContextManager (implements java.lang.AutoCloseable)
  • org.apache.reef.evaluator.context.ContextMessage (implements org.apache.reef.io.Message)
  • org.apache.reef.evaluator.context.parameters.ContextMessageHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ContextMessageHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.context.ContextMessageImpl (implements org.apache.reef.driver.context.ContextMessage)
  • org.apache.reef.evaluator.context.parameters.ContextMessageSources (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.context.ContextRepresenters
  • org.apache.reef.runtime.common.evaluator.context.ContextRuntime
  • org.apache.reef.evaluator.context.parameters.ContextStartHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.evaluator.context.parameters.ContextStopHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.suspend.Control
  • org.apache.reef.examples.suspend.Control.Command (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.suspend.Control.TaskId (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tests.statepassing.Counter
  • org.apache.reef.poison.params.CrashProbability (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.poison.params.CrashTimeout (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.data.loading.api.DataLoader
  • org.apache.reef.io.data.loading.api.DataLoader.EvaluatorAllocatedHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.io.data.loading.api.DataLoader.EvaluatorFailedHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.io.data.loading.api.DataLoader.StartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.examples.data.loading.DataLoadingREEF
  • org.apache.reef.examples.data.loading.DataLoadingREEF.InputDir (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.data.loading.DataLoadingREEF.Local (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.data.loading.DataLoadingREEF.TimeOut (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder (implements org.apache.reef.util.Builder<T>)
  • org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder.DataLoadingComputeRequest (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder.DataLoadingEvaluatorMemoryMB (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder.DataLoadingEvaluatorNumberOfCores (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder.LoadDataIntoMemory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder.NumberOfDesiredSplits (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultClientCloseHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultClientCloseWithMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.hdinsight.client.sslhacks.DefaultClientConstructor (implements org.apache.reef.tang.ExternalConstructor<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultClientMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.evaluator.task.defaults.DefaultCloseHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.client.defaults.DefaultCompletedJobHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultContextActiveHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultContextClosureHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultContextFailureHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.evaluator.context.defaults.DefaultContextMessageHandler (implements org.apache.reef.evaluator.context.ContextMessageHandler)
  • org.apache.reef.runtime.common.driver.defaults.DefaultContextMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.evaluator.context.defaults.DefaultContextMessageSource (implements org.apache.reef.evaluator.context.ContextMessageSource)
  • org.apache.reef.runtime.common.evaluator.context.defaults.DefaultContextStartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.evaluator.context.defaults.DefaultContextStopHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.evaluator.DefaultDriverConnection (implements org.apache.reef.runtime.common.evaluator.DriverConnection)
  • org.apache.reef.runtime.common.evaluator.task.defaults.DefaultDriverMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultDriverRestartCompletedHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultDriverRestartContextActiveHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultDriverRestartTaskRunningHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultEvaluatorAllocationHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultEvaluatorCompletionHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultEvaluatorFailureHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.client.defaults.DefaultFailedJobHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.impl.DefaultIdentifierFactory (implements org.apache.reef.wake.IdentifierFactory)
    • org.apache.reef.wake.remote.impl.DefaultRemoteIdentifierFactoryImplementation (implements org.apache.reef.wake.remote.RemoteIdentifierFactory)
  • org.apache.reef.runtime.common.client.defaults.DefaultJobMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.local.client.parameters.DefaultMemorySize (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.local.client.parameters.DefaultNumberOfCores (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.remote.impl.DefaultRemoteManagerImplementation (implements org.apache.reef.wake.remote.RemoteManager)
  • org.apache.reef.runtime.common.client.defaults.DefaultRunningJobHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.client.defaults.DefaultRuntimeErrorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.evaluator.task.defaults.DefaultSuspendHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultTaskCompletionHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultTaskFailureHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultTaskMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultTaskRunningHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.defaults.DefaultTaskSuspensionHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.impl.DefaultThreadFactory (implements java.util.concurrent.ThreadFactory)
  • org.apache.reef.runtime.common.parameters.DeleteTempFiles (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.utils.DispatchingEStage (implements java.lang.AutoCloseable)
  • org.apache.reef.tests.fail.task.Driver
  • org.apache.reef.tests.fail.task.Driver.FailTaskName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.DriverExceptionHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.DriverFailOnFail
  • org.apache.reef.tests.fail.driver.DriverFailOnFail.AllocatedEvaluatorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.DriverFailOnFail.FailedTaskHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.DriverFailOnFail.StartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.driver.parameters.DriverIdentifier (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.idle.DriverIdleManager
  • org.apache.reef.driver.parameters.DriverIdleSources (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.DriverJobSubmissionDirectory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.client.DriverLauncher
  • org.apache.reef.client.DriverLauncher.CompletedJobHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.client.DriverLauncher.FailedJobHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.client.DriverLauncher.RunningJobHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.client.DriverLauncher.RuntimeErrorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.driver.parameters.DriverLocalFiles (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.DriverLocalLibraries (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.DriverMemory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tests.messaging.driver.DriverMessaging
  • org.apache.reef.runtime.common.evaluator.parameters.DriverRemoteIdentifier (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.DriverRestartCompletedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.DriverRestartContextActiveHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.DriverRestartHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.DriverRestartTaskRunningHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.DriverRuntimeConfigurationOptions
  • org.apache.reef.runtime.common.driver.DriverRuntimeConfigurationOptions.JobControlHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.proto.DriverRuntimeProtocol
  • org.apache.reef.driver.parameters.DriverStartHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.DriverStartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.DriverStatusManager
  • org.apache.reef.tests.library.tasks.EchoTask (implements org.apache.reef.task.Task)
  • org.apache.reef.runtime.hdinsight.client.yarnrest.EnvironmentEntry
  • org.apache.reef.util.EnvironmentUtils
  • org.apache.reef.runtime.common.launch.parameters.ErrorHandlerRID (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.EvaluatorAllocatedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.EvaluatorCompletedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.context.EvaluatorContext (implements org.apache.reef.driver.context.ActiveContext)
  • org.apache.reef.runtime.common.driver.evaluator.EvaluatorControlHandler
  • org.apache.reef.driver.parameters.EvaluatorDispatcherThreads (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.EvaluatorFailedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.evaluator.EvaluatorHeartbeatHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.evaluator.parameters.EvaluatorIdentifier (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.evaluator.EvaluatorManager (implements java.lang.AutoCloseable, org.apache.reef.io.naming.Identifiable)
  • org.apache.reef.runtime.common.driver.evaluator.EvaluatorManager.EvaluatorDescriptorName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.evaluator.EvaluatorManager.EvaluatorIdentifier (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.evaluator.EvaluatorManagerFactory
  • org.apache.reef.runtime.common.driver.evaluator.EvaluatorMessageDispatcher
  • org.apache.reef.driver.evaluator.EvaluatorRequest
  • org.apache.reef.driver.evaluator.EvaluatorRequest.Builder (implements org.apache.reef.util.Builder<T>)
  • org.apache.reef.runtime.common.driver.EvaluatorRequestorImpl (implements org.apache.reef.driver.evaluator.EvaluatorRequestor)
  • org.apache.reef.io.data.loading.impl.EvaluatorRequestSerializer
  • org.apache.reef.runtime.common.driver.evaluator.EvaluatorResourceManagerErrorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.proto.EvaluatorRuntimeProtocol
  • org.apache.reef.runtime.common.driver.evaluator.Evaluators (implements java.lang.AutoCloseable)
  • org.apache.reef.io.data.loading.impl.EvaluatorToPartitionMapper<V>
  • org.apache.reef.runtime.common.driver.idle.EventHandlerIdlenessSource (implements org.apache.reef.runtime.common.driver.idle.DriverIdlenessSource)
  • org.apache.reef.wake.examples.join.EventPrinter<T> (implements org.apache.reef.wake.rx.Observer<T>)
  • org.apache.reef.wake.metrics.EWMA
  • org.apache.reef.wake.metrics.EWMAParameters
  • org.apache.reef.util.ExceptionHandlingEventHandler<T> (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.util.Exceptions
  • org.apache.reef.runtime.local.client.ExecutorServiceConstructor (implements org.apache.reef.tang.ExternalConstructor<T>)
  • org.apache.reef.tests.library.driver.ExpectedTaskFailureHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.FailClient
  • org.apache.reef.tests.fail.driver.FailDriver
  • org.apache.reef.tests.fail.driver.FailDriver.ExpectedMessage
  • org.apache.reef.tests.fail.driver.FailDriver.FailMsgClassName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tests.fail.driver.FailDriverDelayedMsg
  • org.apache.reef.tests.fail.driver.FailDriverDelayedMsg.ActiveContextHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.FailDriverDelayedMsg.AllocatedEvaluatorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.FailDriverDelayedMsg.RunningTaskHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.FailDriverDelayedMsg.StartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.FailDriverDelayedMsg.TaskMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.task.FailTask (implements org.apache.reef.task.Task)
  • org.apache.reef.tests.fail.task.FailTaskCall (implements org.apache.reef.task.Task)
  • org.apache.reef.tests.fail.task.FailTaskClose (implements org.apache.reef.wake.EventHandler<T>, org.apache.reef.task.Task)
  • org.apache.reef.tests.fail.task.FailTaskMsg (implements org.apache.reef.wake.EventHandler<T>, org.apache.reef.task.Task)
  • org.apache.reef.tests.fail.task.FailTaskStart (implements org.apache.reef.wake.EventHandler<T>, org.apache.reef.task.Task)
  • org.apache.reef.tests.fail.task.FailTaskStop (implements org.apache.reef.wake.EventHandler<T>, org.apache.reef.task.Task)
  • org.apache.reef.tests.fail.task.FailTaskStop.CloseEventHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.task.FailTaskSuspend (implements org.apache.reef.wake.EventHandler<T>, org.apache.reef.task.Task)
  • org.apache.reef.tests.yarn.failure.FailureDriver
  • org.apache.reef.tests.yarn.failure.FailureREEF
  • org.apache.reef.tests.yarn.failure.FailureREEF.Local (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tests.yarn.failure.FailureREEF.TimeOut (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.storage.FileHandlePool
  • org.apache.reef.wake.storage.FileIdentifier (implements org.apache.reef.wake.storage.StorageIdentifier)
  • org.apache.reef.runtime.hdinsight.client.yarnrest.FileResource
  • java.util.logging.Formatter
    • org.apache.reef.util.logging.ThreadLogFormatter
  • org.apache.reef.io.storage.FramingTupleDeserializer<K,V> (implements org.apache.reef.io.serialization.Deserializer<ObjectType,InType>)
  • org.apache.reef.io.storage.FramingTupleSerializer<K,V> (implements org.apache.reef.io.serialization.Serializer<ObjectType,OutType>)
  • org.apache.reef.io.checkpoint.fs.FSCheckpointID (implements org.apache.reef.io.checkpoint.CheckpointID)
  • org.apache.reef.io.checkpoint.fs.FSCheckpointService (implements org.apache.reef.io.checkpoint.CheckpointService)
  • org.apache.reef.io.checkpoint.fs.FSCheckPointServiceConfiguration.FileSystemConstructor (implements org.apache.reef.tang.ExternalConstructor<T>)
  • java.util.concurrent.FutureTask<V> (implements java.util.concurrent.RunnableFuture<V>)
    • org.apache.reef.wake.remote.impl.ConnectFutureTask<T>
  • org.apache.reef.io.storage.util.GetAllIterable<T> (implements java.lang.Iterable<T>)
  • org.apache.reef.runtime.local.driver.parameters.GlobalFiles (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.local.driver.parameters.GlobalLibraries (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.util.HadoopEnvironment
  • java.util.logging.Handler
    • org.apache.reef.util.logging.DFSHandler
  • org.apache.reef.runtime.hdinsight.cli.HDICLI
  • org.apache.reef.runtime.hdinsight.HDInsightClasspathProvider (implements org.apache.reef.runtime.common.files.RuntimeClasspathProvider)
  • org.apache.reef.runtime.hdinsight.client.yarnrest.HDInsightInstance
  • org.apache.reef.runtime.hdinsight.parameters.HDInsightInstanceURL (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.hdinsight.client.HDInsightJobSubmissionHandler (implements org.apache.reef.runtime.common.client.api.JobSubmissionHandler)
  • org.apache.reef.runtime.hdinsight.parameters.HDInsightPassword (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.hdinsight.parameters.HDInsightUsername (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.evaluator.HeartBeatManager
  • org.apache.reef.runtime.common.evaluator.parameters.HeartbeatPeriod (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.task.HeartBeatTriggerManager
  • org.apache.reef.examples.helloCLR.HelloCLR
  • org.apache.reef.examples.hello.HelloDriver
  • org.apache.reef.examples.helloCLR.HelloDriver
  • org.apache.reef.examples.hello.HelloDriver.EvaluatorAllocatedHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.examples.hello.HelloDriver.StartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.examples.hello.HelloHDInsight
  • org.apache.reef.examples.hello.HelloREEF
  • org.apache.reef.examples.hellohttp.HelloREEFHttp
  • org.apache.reef.examples.hellohttp.HelloREEFHttpYarn
  • org.apache.reef.examples.hello.HelloREEFNoClient
  • org.apache.reef.examples.hello.HelloReefYarn
  • org.apache.reef.examples.hello.HelloTask (implements org.apache.reef.task.Task)
  • org.apache.reef.webserver.HttpEventHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.webserver.HttpServerImpl (implements org.apache.reef.webserver.HttpServer)
  • org.apache.reef.webserver.HttpServerReefEventHandler (implements org.apache.reef.webserver.HttpHandler)
  • org.apache.reef.examples.hellohttp.HttpShellJobDriver
  • org.apache.reef.webserver.HttpTrackingURLProvider (implements org.apache.reef.runtime.yarn.driver.TrackingURLProvider)
  • org.apache.reef.wake.IdentifierParser (implements org.apache.reef.tang.ExternalConstructor<T>)
  • org.apache.reef.runtime.common.driver.idle.IdleMessage
  • org.apache.reef.runtime.local.driver.IDMaker
  • org.apache.reef.runtime.common.evaluator.parameters.InitialTaskConfiguration (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tang.InjectionFuture<T> (implements java.util.concurrent.Future<V>)
  • org.apache.reef.tang.implementation.InjectionPlan<T> (implements org.apache.reef.tang.types.Traversable<T>)
    • org.apache.reef.tang.implementation.Constructor<T>
    • org.apache.reef.tang.implementation.InjectionFuturePlan<T>
    • org.apache.reef.tang.implementation.java.JavaInstance<T>
    • org.apache.reef.tang.implementation.ListInjectionPlan<T>
    • org.apache.reef.tang.implementation.SetInjectionPlan<T>
    • org.apache.reef.tang.implementation.Subplan<T>
  • org.apache.reef.tang.proto.InjectionPlanProto
  • org.apache.reef.tang.implementation.java.InjectorImpl (implements org.apache.reef.tang.Injector)
  • org.apache.reef.io.data.loading.impl.InMemoryInputFormatDataSet<K,V> (implements org.apache.reef.io.data.loading.api.DataSet<K,V>)
  • org.apache.reef.io.data.loading.impl.InputFormatDataSet<K,V> (implements org.apache.reef.io.data.loading.api.DataSet<K,V>)
  • org.apache.reef.io.data.loading.impl.InputFormatExternalConstructor (implements org.apache.reef.tang.ExternalConstructor<T>)
  • org.apache.reef.io.data.loading.impl.InputFormatLoadingService<K,V> (implements org.apache.reef.io.data.loading.api.DataLoadingService)
  • org.apache.reef.io.data.loading.impl.InputSplitExternalConstructor (implements org.apache.reef.tang.ExternalConstructor<T>)
  • org.apache.reef.io.data.loading.impl.InputSplitExternalConstructor.SerializedInputSplit (implements org.apache.reef.tang.annotations.Name<T>)
  • java.io.InputStream (implements java.io.Closeable)
    • java.io.FilterInputStream
      • java.io.DataInputStream (implements java.io.DataInput)
        • org.apache.reef.io.storage.FramingInputStream (implements java.lang.Iterable<T>)
  • org.apache.reef.io.storage.util.IntegerCodec (implements org.apache.reef.io.serialization.Codec<T>)
  • org.apache.reef.io.storage.util.IntegerDeserializer (implements org.apache.reef.io.serialization.Deserializer<ObjectType,InType>)
  • org.apache.reef.io.storage.util.IntegerSerializer (implements org.apache.reef.io.serialization.Serializer<ObjectType,OutType>)
  • org.apache.reef.util.JARFileMaker (implements java.lang.AutoCloseable)
  • org.apache.reef.runtime.common.launch.JavaLaunchCommandBuilder (implements org.apache.reef.runtime.common.launch.LaunchCommandBuilder)
  • org.apache.reef.tang.implementation.java.JavaNodeFactory
  • org.apache.reef.examples.retained_eval.JobClient
  • org.apache.reef.examples.retained_evalCLR.JobClient
  • org.apache.reef.client.parameters.JobCompletedHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.data.loading.impl.JobConfExternalConstructor (implements org.apache.reef.tang.ExternalConstructor<T>)
  • org.apache.reef.io.data.loading.impl.JobConfExternalConstructor.InputFormatClass (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.data.loading.impl.JobConfExternalConstructor.InputPath (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.pool.JobDriver
  • org.apache.reef.examples.retained_eval.JobDriver
  • org.apache.reef.examples.retained_evalCLR.JobDriver
  • org.apache.reef.client.parameters.JobFailedHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.JobGlobalFiles (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.JobGlobalLibraries (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.files.JobJarMaker
  • org.apache.reef.client.JobMessage (implements org.apache.reef.io.naming.Identifiable, org.apache.reef.io.Message)
  • org.apache.reef.client.parameters.JobMessageHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.client.JobMessageObserverImpl (implements org.apache.reef.driver.client.JobMessageObserver)
  • org.apache.reef.runtime.yarn.client.parameters.JobPriority (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.yarn.client.parameters.JobQueue (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.client.parameters.JobRunningHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.yarn.driver.parameters.JobSubmissionDirectory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.parameters.JVMHeapSlack (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.pool.Launch
  • org.apache.reef.examples.retained_eval.Launch
  • org.apache.reef.examples.suspend.Launch
  • org.apache.reef.examples.retained_evalCLR.Launch
  • org.apache.reef.examples.retained_evalCLR.Launch.Command (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.pool.Launch.Delay (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.suspend.Launch.Delay (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.pool.Launch.JobId (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.pool.Launch.Local (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.retained_eval.Launch.Local (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.suspend.Launch.Local (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.retained_evalCLR.Launch.Local (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.suspend.Launch.NumCycles (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.retained_eval.Launch.NumEval (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.pool.Launch.NumEvaluators (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.retained_eval.Launch.NumRuns (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.retained_evalCLR.Launch.NumRuns (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.pool.Launch.NumTasks (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.pool.Launch.Piggyback (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.launch.LaunchClass (implements java.lang.AutoCloseable, java.lang.Runnable)
  • org.apache.reef.runtime.common.launch.LaunchClass.ProfilingEnabled (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.Launcher
  • org.apache.reef.client.LauncherStatus
  • org.apache.reef.runtime.common.launch.parameters.LaunchID (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.data.loading.LineCounter
  • org.apache.reef.examples.data.loading.LineCounter.ContextActiveHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.examples.data.loading.LineCounter.TaskCompletedHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.examples.data.loading.LineCountingTask (implements org.apache.reef.task.Task)
  • org.apache.reef.io.network.util.ListCodec<T> (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.runtime.local.LocalClasspathProvider (implements org.apache.reef.runtime.common.files.RuntimeClasspathProvider)
  • org.apache.reef.runtime.local.driver.parameters.LocalFiles (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.local.driver.parameters.LocalLibraries (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.local.driver.LocalResourceReleaseHandler (implements org.apache.reef.runtime.common.driver.api.ResourceReleaseHandler)
  • org.apache.reef.runtime.hdinsight.client.yarnrest.LocalResourcesEntry
  • org.apache.reef.io.storage.local.LocalScratchSpace (implements org.apache.reef.io.storage.ScratchSpace)
  • org.apache.reef.io.storage.local.LocalStorageService (implements org.apache.reef.io.storage.StorageService)
  • org.apache.reef.wake.impl.LoggingEventHandler<T> (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.examples.utils.wake.LoggingEventHandler<T> (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.remote.transport.netty.LoggingLinkListener<T> (implements org.apache.reef.wake.remote.transport.LinkListener<T>)
  • org.apache.reef.runtime.local.process.LoggingRunnableProcessObserver (implements org.apache.reef.runtime.local.process.RunnableProcessObserver)
  • org.apache.reef.util.logging.LoggingScopeFactory
  • org.apache.reef.util.logging.LoggingScopeImpl (implements org.apache.reef.util.logging.LoggingScope)
  • org.apache.reef.util.logging.LoggingSetup
  • org.apache.reef.wake.impl.LoggingUtils
  • org.apache.reef.wake.impl.LoggingVoidEventHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.time.runtime.LogicalTimer (implements org.apache.reef.wake.time.runtime.Timer)
  • org.apache.reef.util.logging.LogLevelName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.util.logging.LogParser
  • org.apache.reef.webserver.MaxPortNumber (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.webserver.MaxRetryAttempts (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.util.MemoryUtils
  • org.apache.reef.wake.impl.MergingEventHandler<L,R>
  • org.apache.reef.wake.impl.MergingEventHandler.Pair<S1,S2>
  • org.apache.reef.io.storage.MergingIterator<T> (implements java.util.Iterator<E>)
  • org.apache.reef.io.network.impl.MessagingTransportFactory (implements org.apache.reef.io.network.TransportFactory)
  • org.apache.reef.wake.metrics.Meter
  • org.apache.reef.webserver.MinPortNumber (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.impl.MissingStartHandlerHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tang.util.MonotonicTreeMap<T,U> (implements java.util.Map<K,V>)
  • org.apache.reef.wake.remote.impl.MultiCodec<T> (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.wake.remote.impl.MultiDecoder<T> (implements org.apache.reef.wake.remote.Decoder<T>)
  • org.apache.reef.wake.remote.impl.MultiEncoder<T> (implements org.apache.reef.wake.remote.Encoder<T>)
  • org.apache.reef.wake.impl.MultiEventHandler<T> (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.io.network.naming.NameAssignmentTuple (implements org.apache.reef.io.naming.NameAssignment)
  • org.apache.reef.io.network.naming.NameCache (implements org.apache.reef.io.network.Cache<K,V>)
  • org.apache.reef.io.network.naming.NameClient (implements org.apache.reef.io.naming.Naming, org.apache.reef.wake.Stage)
  • org.apache.reef.io.network.naming.NameLookupClient (implements org.apache.reef.io.naming.NamingLookup, org.apache.reef.wake.Stage)
  • org.apache.reef.io.network.naming.NameLookupClient.RetryCount (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.naming.NameLookupClient.RetryTimeout (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.naming.NameRegistryClient (implements org.apache.reef.io.naming.NamingRegistry, org.apache.reef.wake.Stage)
  • org.apache.reef.io.network.naming.NameServerImpl (implements org.apache.reef.io.network.naming.NameServer)
  • org.apache.reef.io.network.naming.NameServerParameters
  • org.apache.reef.io.network.naming.NameServerParameters.NameServerAddr (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.naming.NameServerParameters.NameServerIdentifierFactory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.naming.NameServerParameters.NameServerPort (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.impl.NameServiceCloseHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.io.network.naming.serialization.NamingLookupRequestCodec (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.io.network.naming.serialization.NamingLookupResponseCodec (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.io.network.naming.serialization.NamingMessage
    • org.apache.reef.io.network.naming.serialization.NamingLookupRequest
    • org.apache.reef.io.network.naming.serialization.NamingLookupResponse
    • org.apache.reef.io.network.naming.serialization.NamingRegisterRequest
    • org.apache.reef.io.network.naming.serialization.NamingRegisterResponse
    • org.apache.reef.io.network.naming.serialization.NamingUnregisterRequest
  • org.apache.reef.io.network.naming.serialization.NamingRegisterRequestCodec (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.io.network.naming.serialization.NamingRegisterResponseCodec (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.io.network.naming.serialization.NamingUnregisterRequestCodec (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.wake.remote.transport.netty.NettyLink<T> (implements org.apache.reef.wake.remote.transport.Link<T>)
  • org.apache.reef.wake.remote.transport.netty.NettyMessagingTransport (implements org.apache.reef.wake.remote.transport.Transport)
  • org.apache.reef.wake.remote.NetUtils
  • org.apache.reef.io.network.impl.NetworkService<T> (implements org.apache.reef.io.network.ConnectionFactory<T>, org.apache.reef.wake.Stage)
  • org.apache.reef.io.network.impl.NetworkServiceClosingHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.io.network.impl.NetworkServiceParameters
  • org.apache.reef.io.network.impl.NetworkServiceParameters.NetworkServiceCodec (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.impl.NetworkServiceParameters.NetworkServiceExceptionHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.impl.NetworkServiceParameters.NetworkServiceHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.impl.NetworkServiceParameters.NetworkServiceIdentifierFactory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.impl.NetworkServiceParameters.NetworkServicePort (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.impl.NetworkServiceParameters.NetworkServiceTransportFactory (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.io.network.impl.NetworkServiceParameters.TaskId (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.resourcemanager.NodeDescriptorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.catalog.NodeDescriptorImpl (implements org.apache.reef.driver.catalog.NodeDescriptor)
  • org.apache.reef.wake.examples.join.NonBlockingJoin (implements org.apache.reef.wake.rx.StaticObservable)
  • org.apache.reef.tests.fail.driver.NoopTask (implements org.apache.reef.task.Task, org.apache.reef.task.TaskMessageSource)
  • org.apache.reef.tests.library.tasks.NoopTask (implements org.apache.reef.task.Task)
  • org.apache.reef.tests.fail.driver.NoopTask.DriverMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.NoopTask.TaskCloseHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.NoopTask.TaskStopHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.fail.driver.NoopTask.TaskSuspendHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.io.network.impl.NSMessage<T> (implements org.apache.reef.io.network.Message<T>)
  • org.apache.reef.io.network.impl.NSMessageCodec<T> (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.runtime.local.client.parameters.NumberOfProcesses (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.util.ObjectInstantiationLogger
  • org.apache.reef.wake.remote.impl.ObjectSerializableCodec<T> (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.examples.suspend.ObjectWritableCodec<T> (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.tests.library.driver.OnDriverStartedAllocateOne (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.impl.OpaqueLocalIdentifier (implements org.apache.reef.wake.Identifier)
  • org.apache.reef.util.Optional<T> (implements java.io.Serializable)
  • org.apache.reef.tang.formats.OptionalImpl<T> (implements org.apache.reef.tang.formats.Impl<T>)
  • org.apache.reef.tang.formats.OptionalParameter<T> (implements org.apache.reef.tang.formats.Param<T>)
  • org.apache.reef.wake.remote.impl.OrderedRemoteReceiverStage (implements org.apache.reef.wake.EStage<T>)
  • org.apache.reef.util.OSUtils
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • org.apache.reef.io.storage.FramingOutputStream (implements org.apache.reef.io.Accumulable<T>)
  • org.apache.reef.io.network.util.Pair<T1,T2> (implements java.io.Serializable)
  • org.apache.reef.tang.formats.ParameterParser
  • org.apache.reef.webserver.ParsedHttpRequest
  • org.apache.reef.io.PartitionSpec
  • org.apache.reef.wake.impl.PeriodicEvent
  • org.apache.reef.runtime.common.evaluator.PIDStoreStartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.poison.PoisonedAlarmHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.poison.context.PoisonedContextStartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.poison.task.PoisonedTaskStartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.webserver.PortNumber (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tang.examples.PrintTypeHierarchy
  • org.apache.reef.tang.implementation.protobuf.ProtocolBufferClassHierarchy (implements org.apache.reef.tang.ClassHierarchy)
  • org.apache.reef.tang.implementation.protobuf.ProtocolBufferInjectionPlan
  • org.apache.reef.tang.formats.Provides<T>
  • org.apache.reef.wake.remote.impl.ProxyEventHandler<T> (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.impl.PubSubEventHandler<T> (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.examples.p2p.Pull2Push<T> (implements java.lang.AutoCloseable, java.lang.Runnable)
  • org.apache.reef.runtime.common.driver.catalog.RackDescriptorImpl (implements org.apache.reef.driver.catalog.RackDescriptor)
  • org.apache.reef.io.storage.ram.RamMap<T> (implements org.apache.reef.io.ExternalMap<T>)
  • org.apache.reef.io.storage.ram.RamSpool<T> (implements org.apache.reef.io.Spool<T>)
  • org.apache.reef.io.storage.ram.RamStorageService (implements org.apache.reef.io.storage.StorageService)
  • org.apache.reef.io.checkpoint.RandomNameCNS (implements org.apache.reef.io.checkpoint.CheckpointNamingService)
  • org.apache.reef.io.checkpoint.RandomNameCNS.PREFIX (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.storage.ReadRequest (implements org.apache.reef.wake.Identifiable)
  • org.apache.reef.wake.storage.ReadResponse
  • org.apache.reef.wake.time.runtime.RealTimer (implements org.apache.reef.wake.time.runtime.Timer)
  • org.apache.avro.data.RecordBuilderBase<T> (implements org.apache.avro.data.RecordBuilder<T>)
    • org.apache.avro.specific.SpecificRecordBuilderBase<T>
      • org.apache.reef.tang.formats.avro.AvroConfiguration.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.webserver.AvroDriverInfo.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.webserver.AvroEvaluatorEntry.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.webserver.AvroEvaluatorInfo.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.webserver.AvroEvaluatorList.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.webserver.AvroEvaluatorsInfo.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.webserver.AvroHttpRequest.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.io.network.naming.avro.AvroNamingAssignment.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.io.network.naming.avro.AvroNamingLookupRequest.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.io.network.naming.avro.AvroNamingLookupResponse.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.io.network.naming.avro.AvroNamingRegisterRequest.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.io.network.naming.avro.AvroNamingUnRegisterRequest.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.webserver.AvroReefServiceInfo.Builder (implements org.apache.avro.data.RecordBuilder<T>)
      • org.apache.reef.tang.formats.avro.ConfigurationEntry.Builder (implements org.apache.avro.data.RecordBuilder<T>)
  • org.apache.reef.runtime.common.launch.REEFErrorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.webserver.ReefEventStateManager
  • org.apache.reef.webserver.ReefEventStateManager.ActiveContextStateHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.webserver.ReefEventStateManager.AllocatedEvaluatorStateHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.webserver.ReefEventStateManager.ClientMessageStateHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.webserver.ReefEventStateManager.DriverRestartTaskRunningStateHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.webserver.ReefEventStateManager.DrivrRestartActiveContextStateHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.webserver.ReefEventStateManager.StartStateHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.webserver.ReefEventStateManager.StopStateHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.webserver.ReefEventStateManager.TaskRunningStateHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.files.REEFFileNames
  • org.apache.reef.runtime.common.client.REEFImplementation (implements org.apache.reef.client.REEF)
  • org.apache.reef.runtime.common.client.REEFImplementation.DriverRemoteIdentifier (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.launch.REEFMessageCodec (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.io.network.proto.ReefNetworkServiceProtos
  • org.apache.reef.proto.REEFProtocol
  • org.apache.reef.runtime.local.process.ReefRunnableProcessObserver (implements org.apache.reef.runtime.local.process.RunnableProcessObserver)
  • org.apache.reef.proto.ReefServiceProtos
  • org.apache.reef.util.REEFVersion
  • org.apache.reef.tang.util.ReflectionUtilities
  • org.apache.reef.wake.remote.RemoteConfiguration
  • org.apache.reef.wake.remote.RemoteConfiguration.ErrorHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.remote.RemoteConfiguration.HostAddress (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.remote.RemoteConfiguration.ManagerName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.remote.RemoteConfiguration.MessageCodec (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.remote.RemoteConfiguration.NumberOfTries (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.remote.RemoteConfiguration.OrderingGuarantee (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.remote.RemoteConfiguration.Port (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.remote.RemoteConfiguration.RetryTimeout (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.remote.impl.RemoteEvent<T>
  • org.apache.reef.wake.remote.impl.RemoteEventCodec<T> (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.wake.remote.impl.RemoteEventComparator<T> (implements java.util.Comparator<T>)
  • org.apache.reef.wake.remote.impl.RemoteEventDecoder<T> (implements org.apache.reef.wake.remote.Decoder<T>)
  • org.apache.reef.wake.remote.impl.RemoteEventEncoder<T> (implements org.apache.reef.wake.remote.Encoder<T>)
  • org.apache.reef.runtime.common.utils.RemoteManager
  • org.apache.reef.wake.remote.impl.RemoteReceiverStage (implements org.apache.reef.wake.EStage<T>)
  • org.apache.reef.wake.remote.impl.RemoteSenderStage (implements org.apache.reef.wake.Stage)
  • org.apache.reef.wake.remote.impl.RemoteSeqNumGenerator
  • org.apache.reef.tang.formats.RequiredImpl<T> (implements org.apache.reef.tang.formats.Impl<T>)
  • org.apache.reef.tang.formats.RequiredParameter<T> (implements org.apache.reef.tang.formats.Param<T>)
  • org.apache.reef.runtime.hdinsight.client.yarnrest.Resource
  • org.apache.reef.runtime.common.driver.resourcemanager.ResourceAllocationHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.catalog.ResourceCatalogImpl (implements org.apache.reef.driver.catalog.ResourceCatalog)
  • org.apache.reef.runtime.local.driver.ResourceManager
  • org.apache.reef.runtime.common.driver.resourcemanager.ResourceManagerErrorHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.client.parameters.ResourceManagerErrorHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.resourcemanager.ResourceManagerStatus (implements org.apache.reef.runtime.common.driver.idle.DriverIdlenessSource, org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.io.data.loading.api.ResourceRequestHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.resourcemanager.ResourceStatusHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.evaluator.parameters.RootContextConfiguration (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.local.client.parameters.RootFolder (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.evaluator.parameters.RootServiceConfiguration (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.local.process.RunnableProcess (implements java.lang.Runnable)
  • org.apache.reef.runtime.common.client.RunningJobImpl (implements org.apache.reef.wake.EventHandler<T>, org.apache.reef.client.RunningJob)
  • org.apache.reef.runtime.common.driver.task.RunningTaskImpl (implements org.apache.reef.driver.task.RunningTask)
  • org.apache.reef.wake.time.runtime.RuntimeClock (implements org.apache.reef.wake.time.Clock)
  • org.apache.reef.runtime.common.driver.api.RuntimeParameters
  • org.apache.reef.runtime.common.driver.api.RuntimeParameters.NodeDescriptorHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.api.RuntimeParameters.ResourceAllocationHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.api.RuntimeParameters.ResourceStatusHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.api.RuntimeParameters.RuntimeStatusHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.scheduler.SchedulerDriver
  • org.apache.reef.examples.scheduler.SchedulerREEF
  • org.apache.reef.examples.scheduler.SchedulerREEF.Retain (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.scheduler.SchedulerREEFYarn
  • org.apache.reef.wake.storage.SequentialFileReader (implements org.apache.reef.wake.EStage<T>)
  • org.apache.reef.io.serialization.SerializableCodec<T> (implements org.apache.reef.io.serialization.Codec<T>)
  • org.apache.reef.io.storage.local.SerializerFileSpool<T> (implements org.apache.reef.io.Spool<T>)
  • org.apache.reef.driver.parameters.ServiceContextActiveHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceContextClosedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceContextFailedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceContextMessageHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceDriverRestartCompletedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceDriverRestartContextActiveHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceDriverRestartTaskRunningHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceEvaluatorAllocatedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceEvaluatorCompletedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceEvaluatorFailedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.evaluator.context.parameters.Services (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceTaskCompletedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceTaskFailedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceTaskMessageHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceTaskRunningHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.ServiceTaskSuspendedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.util.SetOnce<T>
  • org.apache.reef.examples.library.ShellTask (implements org.apache.reef.task.Task)
  • org.apache.reef.io.checkpoint.SimpleNamingService (implements org.apache.reef.io.checkpoint.CheckpointNamingService)
  • org.apache.reef.io.checkpoint.SimpleNamingService.CheckpointName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.rx.impl.SimpleSubject<T> (implements org.apache.reef.wake.rx.Subject<InType,OutType>)
  • org.apache.reef.util.SingletonAsserter
  • org.apache.reef.examples.pool.SleepTask (implements org.apache.reef.task.Task)
  • org.apache.reef.wake.remote.impl.SocketRemoteIdentifier (implements org.apache.reef.wake.remote.RemoteIdentifier)
  • org.apache.reef.io.storage.ram.SortingRamSpool<T> (implements org.apache.reef.io.Spool<T>)
  • org.apache.avro.specific.SpecificRecordBase (implements java.lang.Comparable<T>, org.apache.avro.generic.GenericRecord, org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.tang.formats.avro.AvroConfiguration (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.webserver.AvroDriverInfo (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.webserver.AvroEvaluatorEntry (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.webserver.AvroEvaluatorInfo (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.webserver.AvroEvaluatorList (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.webserver.AvroEvaluatorsInfo (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.webserver.AvroHttpRequest (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.io.network.naming.avro.AvroNamingAssignment (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.io.network.naming.avro.AvroNamingLookupRequest (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.io.network.naming.avro.AvroNamingLookupResponse (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.io.network.naming.avro.AvroNamingRegisterRequest (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.io.network.naming.avro.AvroNamingUnRegisterRequest (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.webserver.AvroReefServiceInfo (implements org.apache.avro.specific.SpecificRecord)
    • org.apache.reef.tang.formats.avro.ConfigurationEntry (implements org.apache.avro.specific.SpecificRecord)
  • org.apache.reef.tang.implementation.StackBindLocation (implements org.apache.reef.tang.BindLocation)
  • org.apache.reef.wake.StageConfiguration
  • org.apache.reef.wake.StageConfiguration.Capacity (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.StageConfiguration.ErrorHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.StageConfiguration.NumberOfThreads (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.StageConfiguration.StageExecutorService (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.StageConfiguration.StageHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.StageConfiguration.StageName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.StageConfiguration.StageObserver (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.StageConfiguration.TimerInitialDelay (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.StageConfiguration.TimerPeriod (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.impl.StageManager (implements org.apache.reef.wake.Stage)
  • org.apache.reef.tests.statepassing.StatePassingDriver
  • org.apache.reef.tests.statepassing.StatePassingTask (implements org.apache.reef.task.Task)
  • org.apache.reef.wake.remote.impl.StringCodec (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.io.network.util.StringCodec (implements org.apache.reef.wake.remote.Codec<T>)
  • org.apache.reef.io.storage.util.StringDeserializer (implements org.apache.reef.io.serialization.Deserializer<ObjectType,InType>)
  • org.apache.reef.io.network.util.StringIdentifier (implements org.apache.reef.wake.ComparableIdentifier)
  • org.apache.reef.io.network.util.StringIdentifierFactory (implements org.apache.reef.wake.IdentifierFactory)
  • org.apache.reef.io.storage.util.StringSerializer (implements org.apache.reef.io.serialization.Serializer<ObjectType,OutType>)
  • org.apache.reef.wake.remote.impl.Subscription<T> (implements java.lang.AutoCloseable)
  • org.apache.reef.examples.suspend.SuspendClient
  • org.apache.reef.examples.suspend.SuspendClientControl (implements java.lang.AutoCloseable)
  • org.apache.reef.examples.suspend.SuspendClientControl.Port (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.examples.suspend.SuspendDriver
  • org.apache.reef.runtime.common.driver.task.SuspendedTaskImpl (implements org.apache.reef.driver.task.SuspendedTask)
  • org.apache.reef.examples.suspend.SuspendTestTask (implements org.apache.reef.task.Task, org.apache.reef.task.TaskMessageSource)
  • org.apache.reef.examples.suspend.SuspendTestTask.SuspendHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.io.SystemTempFileCreator (implements org.apache.reef.io.TempFileCreator)
  • org.apache.reef.tang.Tang.Factory
  • org.apache.reef.tang.implementation.TangImpl (implements org.apache.reef.tang.Tang)
  • org.apache.reef.driver.parameters.TaskCompletedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.task.TaskConfigurationOptions
  • org.apache.reef.driver.task.TaskConfigurationOptions.CloseHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.task.TaskConfigurationOptions.Identifier (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.task.TaskConfigurationOptions.Memento (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.task.TaskConfigurationOptions.MessageHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.task.TaskConfigurationOptions.StartHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.task.TaskConfigurationOptions.StopHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.task.TaskConfigurationOptions.SuspendHandler (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.task.TaskConfigurationOptions.TaskMessageSources (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.driver.parameters.TaskFailedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.task.TaskMessage (implements org.apache.reef.io.Message)
  • org.apache.reef.driver.parameters.TaskMessageHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.driver.task.TaskMessageImpl (implements org.apache.reef.driver.task.TaskMessage)
  • org.apache.reef.tests.messaging.task.TaskMessagingDriver
  • org.apache.reef.tests.messaging.task.TaskMessagingDriver.EvaluatorAllocatedHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.messaging.task.TaskMessagingDriver.TaskMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.messaging.task.TaskMessagingDriver.TaskRunningHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.tests.messaging.task.TaskMessagingTask (implements org.apache.reef.task.Task, org.apache.reef.task.TaskMessageSource)
  • org.apache.reef.tests.messaging.task.TaskMessagingTask.DriverMessageHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.common.driver.task.TaskRepresenter
  • org.apache.reef.driver.parameters.TaskRunningHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.common.evaluator.task.TaskRuntime (implements java.lang.Runnable)
  • org.apache.reef.runtime.common.evaluator.task.TaskStatus
  • org.apache.reef.driver.parameters.TaskSuspendedHandlers (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tests.TestDriverLauncher
  • org.apache.reef.wake.test.proto.TestProtos
  • org.apache.reef.util.ThreadLogger
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • org.apache.reef.runtime.common.evaluator.context.ContextClientCodeException
      • java.util.concurrent.ExecutionException
        • org.apache.reef.exception.DriverException
        • org.apache.reef.exception.EvaluatorException (implements org.apache.reef.io.naming.Identifiable)
          • org.apache.reef.exception.EvaluatorKilledByResourceManagerException
          • org.apache.reef.exception.EvaluatorTimeoutException
      • org.apache.reef.tang.exceptions.InjectionException
      • org.apache.reef.io.network.exception.ParentDeadException
      • java.lang.RuntimeException
        • org.apache.reef.tang.exceptions.BindException
          • org.apache.reef.tang.exceptions.NameResolutionException
          • org.apache.reef.tang.exceptions.ParseException
        • org.apache.reef.tang.exceptions.ClassHierarchyException
        • org.apache.reef.tests.library.exceptions.ClientSideFailure
        • org.apache.reef.tests.library.exceptions.DriverSideFailure
        • org.apache.reef.tests.library.exceptions.ExpectedTaskException
        • java.lang.IllegalStateException
          • org.apache.reef.wake.rx.exception.ObserverCompletedException
        • org.apache.reef.io.network.exception.NetworkRuntimeException
          • org.apache.reef.io.network.naming.exception.NamingRuntimeException
        • org.apache.reef.poison.PoisonException
        • org.apache.reef.wake.remote.exception.RemoteRuntimeException
        • org.apache.reef.exception.evaluator.ServiceRuntimeException
        • org.apache.reef.tests.library.exceptions.SimulatedDriverFailure
        • org.apache.reef.tests.library.exceptions.SimulatedTaskFailure
        • org.apache.reef.tests.library.exceptions.TaskSideFailure
        • org.apache.reef.wake.remote.transport.exception.TransportRuntimeException
        • org.apache.reef.tests.library.exceptions.UnexpectedTaskReturnValue
        • org.apache.reef.wake.exception.WakeRuntimeException
      • org.apache.reef.exception.evaluator.ServiceException
        • org.apache.reef.exception.evaluator.NetworkException
          • org.apache.reef.io.network.naming.exception.NamingException
        • org.apache.reef.exception.evaluator.StorageException
      • org.apache.reef.runtime.common.evaluator.task.exceptions.TaskCallFailure
      • org.apache.reef.runtime.common.evaluator.task.TaskClientCodeException
      • org.apache.reef.runtime.common.evaluator.task.exceptions.TaskCloseHandlerFailure
      • org.apache.reef.runtime.common.evaluator.task.exceptions.TaskMessageHandlerFailure
      • org.apache.reef.runtime.common.evaluator.task.exceptions.TaskStartHandlerFailure
      • org.apache.reef.runtime.common.evaluator.task.exceptions.TaskStopHandlerFailure
      • org.apache.reef.runtime.common.evaluator.task.exceptions.TaskSuspendHandlerFailure
  • org.apache.reef.wake.time.Time (implements java.lang.Comparable<T>)
    • org.apache.reef.wake.time.event.Alarm
      • org.apache.reef.wake.time.runtime.event.ClientAlarm
      • org.apache.reef.wake.time.runtime.event.RuntimeAlarm
    • org.apache.reef.runtime.common.DriverRestartCompleted
    • org.apache.reef.wake.time.runtime.event.IdleClock
    • org.apache.reef.wake.time.runtime.event.RuntimeStart
    • org.apache.reef.wake.time.runtime.event.RuntimeStop
    • org.apache.reef.wake.time.event.StartTime
    • org.apache.reef.wake.time.event.StopTime
  • org.apache.reef.wake.rx.impl.TimeoutSubject<T> (implements org.apache.reef.wake.rx.Subject<InType,OutType>)
  • org.apache.reef.tang.examples.Timer
  • org.apache.reef.tang.examples.timer.Timer.Seconds (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tang.examples.timer.TimerImpl (implements org.apache.reef.tang.examples.timer.Timer)
  • org.apache.reef.tang.examples.timer.TimerMock (implements org.apache.reef.tang.examples.timer.Timer)
  • org.apache.reef.wake.impl.TimerStage (implements org.apache.reef.wake.Stage)
  • org.apache.reef.tang.examples.TimerV1
  • org.apache.reef.tang.util.Tint
  • org.apache.reef.tang.util.TracingMonotonicTreeMap<K,V> (implements org.apache.reef.tang.util.TracingMonotonicMap<K,V>)
  • org.apache.reef.wake.remote.impl.TransportEvent
  • org.apache.reef.io.Tuple<K,V>
  • org.apache.reef.wake.remote.impl.Tuple2<T1,T2>
  • org.apache.reef.wake.examples.join.TupleEvent (implements java.lang.Comparable<T>)
  • org.apache.reef.io.storage.util.TupleKeyComparator<K,V> (implements java.util.Comparator<T>)
  • org.apache.reef.wake.examples.join.TupleSource (implements org.apache.reef.wake.Stage, org.apache.reef.wake.rx.StaticObservable)
  • org.apache.reef.io.network.impl.UnbindNSFromTask (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.wake.metrics.UniformHistogram (implements org.apache.reef.wake.metrics.Histogram)
  • org.apache.reef.runtime.hdinsight.client.sslhacks.UnsafeClientConstructor (implements org.apache.reef.tang.ExternalConstructor<T>)
  • org.apache.reef.tang.util.ValidateConfiguration
  • org.apache.reef.tang.util.ValidateConfiguration.ClassHierarchyIn (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tang.util.ValidateConfiguration.ConfigurationIn (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tang.util.ValidateConfiguration.ConfigurationOut (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.tang.util.ValidateConfiguration.FileParser (implements org.apache.reef.tang.ExternalConstructor<T>)
  • org.apache.reef.tang.util.ValidateConfiguration.Target (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.profiler.Vertex<T>
  • org.apache.reef.wake.WakeConfiguration
  • org.apache.reef.wake.WakeConfiguration.FileName (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.WakeParameters
  • org.apache.reef.wake.WakeParameters.ExecutorShutdownTimeout (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.WakeParameters.MaxFrameLength (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.WakeParameters.RemoteSendTimeout (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.wake.profiler.WakeProfiler (implements org.apache.reef.tang.Aspect)
  • org.apache.reef.wake.remote.proto.WakeRemoteProtos
  • org.apache.reef.wake.impl.WakeSharedPool (implements org.apache.reef.wake.Stage)
  • org.apache.reef.wake.impl.WakeUncaughtExceptionHandler (implements java.lang.Thread.UncaughtExceptionHandler)
  • org.apache.reef.tang.util.walk.Walk
  • org.apache.reef.io.WorkingDirectoryTempFileCreator (implements org.apache.reef.io.TempFileCreator)
  • org.apache.reef.io.data.loading.impl.WritableSerializer
  • org.apache.reef.runtime.yarn.YarnClasspathProvider (implements org.apache.reef.runtime.common.files.RuntimeClasspathProvider)
  • org.apache.reef.runtime.yarn.util.YarnConfigurationConstructor (implements org.apache.reef.tang.ExternalConstructor<T>)
  • org.apache.reef.runtime.yarn.driver.YarnContainerRequestHandlerImpl (implements org.apache.reef.runtime.yarn.driver.YarnContainerRequestHandler)
  • org.apache.reef.runtime.yarn.driver.parameters.YarnHeartbeatPeriod (implements org.apache.reef.tang.annotations.Name<T>)
  • org.apache.reef.runtime.yarn.driver.YARNResourceLaunchHandler (implements org.apache.reef.runtime.common.driver.api.ResourceLaunchHandler)
  • org.apache.reef.runtime.yarn.driver.YARNResourceReleaseHandler (implements org.apache.reef.runtime.common.driver.api.ResourceReleaseHandler)
  • org.apache.reef.runtime.yarn.driver.YarnResourceRequestHandler (implements org.apache.reef.runtime.common.driver.api.ResourceRequestHandler)
  • org.apache.reef.runtime.yarn.driver.YARNRuntimeStartHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.yarn.driver.YARNRuntimeStopHandler (implements org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.runtime.yarn.util.YarnTypes

Interface Hierarchy

• org.apache.reef.io.Accumulable<T>
  • org.apache.reef.io.Spool<T> (also extends java.lang.Iterable<T>)
• org.apache.reef.tang.Aspect
• java.lang.AutoCloseable
  • org.apache.reef.io.Accumulator<T>
  • org.apache.reef.driver.context.ActiveContext (also extends org.apache.reef.driver.context.ContextBase, org.apache.reef.driver.ContextSubmittable, org.apache.reef.io.naming.Identifiable, org.apache.reef.driver.TaskSubmittable)
  • org.apache.reef.driver.evaluator.AllocatedEvaluator (also extends org.apache.reef.driver.ContextAndTaskSubmittable, org.apache.reef.driver.ContextSubmittable, org.apache.reef.io.naming.Identifiable, org.apache.reef.driver.TaskSubmittable)
  • java.nio.channels.Channel
    • org.apache.reef.io.checkpoint.CheckpointService.CheckpointReadChannel
    • org.apache.reef.io.checkpoint.CheckpointService.CheckpointWriteChannel
    • java.nio.channels.ReadableByteChannel
      • org.apache.reef.io.checkpoint.CheckpointService.CheckpointReadChannel
    • java.nio.channels.WritableByteChannel
      • org.apache.reef.io.checkpoint.CheckpointService.CheckpointWriteChannel
  • org.apache.reef.io.checkpoint.CheckpointService.CheckpointReadChannel
  • org.apache.reef.io.checkpoint.CheckpointService.CheckpointWriteChannel
  • org.apache.reef.wake.time.Clock (also extends java.lang.Runnable)
  • java.io.Closeable
    • java.nio.channels.Channel
      • org.apache.reef.io.checkpoint.CheckpointService.CheckpointReadChannel
      • org.apache.reef.io.checkpoint.CheckpointService.CheckpointWriteChannel
      • java.nio.channels.ReadableByteChannel
        • org.apache.reef.io.checkpoint.CheckpointService.CheckpointReadChannel
      • java.nio.channels.WritableByteChannel
        • org.apache.reef.io.checkpoint.CheckpointService.CheckpointWriteChannel
    • org.apache.reef.io.checkpoint.CheckpointService.CheckpointReadChannel
    • org.apache.reef.io.checkpoint.CheckpointService.CheckpointWriteChannel
    • java.nio.channels.ReadableByteChannel
      • org.apache.reef.io.checkpoint.CheckpointService.CheckpointReadChannel
    • java.nio.channels.WritableByteChannel
      • org.apache.reef.io.checkpoint.CheckpointService.CheckpointWriteChannel
  • org.apache.reef.io.network.Connection<T>
  • org.apache.reef.runtime.common.evaluator.DriverConnection
  • org.apache.reef.wake.EStage<T> (also extends org.apache.reef.wake.EventHandler<T>, org.apache.reef.wake.Stage)
  • org.apache.reef.runtime.common.client.api.JobSubmissionHandler (also extends org.apache.reef.wake.EventHandler<T>)
  • org.apache.reef.util.logging.LoggingScope
  • org.apache.reef.io.network.naming.NameServer
  • java.nio.channels.ReadableByteChannel
    • org.apache.reef.io.checkpoint.CheckpointService.CheckpointReadChannel
  • org.apache.reef.client.REEF
  • org.apache.reef.wake.remote.RemoteManager
  • org.apache.reef.client.RunningJob (also extends org.apache.reef.io.naming.Identifiable)
  • org.apache.reef.driver.task.RunningTask (also extends org.apache.reef.io.naming.Identifiable)
  • org.apache.reef.wake.rx.RxStage<T> (also extends org.apache.reef.wake.rx.Observer<T>, org.apache.reef.wake.Stage)
  • org.apache.reef.wake.Stage
    • org.apache.reef.wake.EStage<T> (also extends org.apache.reef.wake.EventHandler<T>)
    • org.apache.reef.io.network.naming.NameServer
    • org.apache.reef.wake.remote.RemoteManager
    • org.apache.reef.wake.rx.RxStage<T> (also extends org.apache.reef.wake.rx.Observer<T>)
    • org.apache.reef.wake.remote.transport.Transport
  • org.apache.reef.wake.remote.transport.Transport
  • java.nio.channels.WritableByteChannel
    • org.apache.reef.io.checkpoint.CheckpointService.CheckpointWriteChannel
• org.apache.reef.tang.BindLocation
• org.apache.reef.util.Builder<T>
• org.apache.reef.io.network.Cache<K,V>
• org.apache.reef.io.checkpoint.CheckpointNamingService
• org.apache.reef.io.checkpoint.CheckpointService
• org.apache.reef.tang.ClassHierarchy
  • org.apache.reef.tang.JavaClassHierarchy
• org.apache.reef.task.events.CloseEvent
• org.apache.reef.io.serialization.Codec<T>
• org.apache.reef.wake.examples.accumulate.CombinerStage.Combiner<K,V>
• org.apache.reef.tang.formats.CommandLine.CommandLineCallback
• java.lang.Comparable<T>
  • org.apache.reef.tang.types.ClassNode<T>
  • org.apache.reef.wake.ComparableIdentifier (also extends org.apache.reef.wake.Identifier)
  • org.apache.reef.tang.types.ConstructorDef<T>
  • org.apache.reef.tang.types.NamedParameterNode<T>
  • org.apache.reef.tang.types.Node (also extends org.apache.reef.tang.types.Traversable<T>)
    • org.apache.reef.tang.types.ClassNode<T>
    • org.apache.reef.tang.types.NamedParameterNode<T>
    • org.apache.reef.tang.types.PackageNode
  • org.apache.reef.tang.types.PackageNode
• org.apache.reef.tang.Configuration
• org.apache.reef.tang.ConfigurationBuilder
  • org.apache.reef.tang.JavaConfigurationBuilder
• org.apache.reef.tang.formats.ConfigurationSerializer
• org.apache.reef.io.network.ConnectionFactory<T>
• org.apache.reef.tang.types.ConstructorArg
• org.apache.reef.driver.ContextAndTaskSubmittable
  • org.apache.reef.driver.evaluator.AllocatedEvaluator (also extends java.lang.AutoCloseable, org.apache.reef.driver.ContextSubmittable, org.apache.reef.io.naming.Identifiable, org.apache.reef.driver.TaskSubmittable)
• org.apache.reef.evaluator.context.ContextMessageSource
• org.apache.reef.driver.ContextSubmittable
  • org.apache.reef.driver.context.ActiveContext (also extends java.lang.AutoCloseable, org.apache.reef.driver.context.ContextBase, org.apache.reef.io.naming.Identifiable, org.apache.reef.driver.TaskSubmittable)
  • org.apache.reef.driver.evaluator.AllocatedEvaluator (also extends java.lang.AutoCloseable, org.apache.reef.driver.ContextAndTaskSubmittable, org.apache.reef.io.naming.Identifiable, org.apache.reef.driver.TaskSubmittable)
• org.apache.reef.io.data.loading.api.DataLoadingService
• org.apache.reef.wake.remote.Decoder<T>
  • org.apache.reef.wake.remote.Codec<T> (also extends org.apache.reef.wake.remote.Encoder<T>)
    • org.apache.reef.io.network.impl.StreamingCodec<T>
  • org.apache.reef.io.network.impl.StreamingCodec<T>
• org.apache.reef.io.serialization.Deserializer<ObjectType,InType>
• org.apache.reef.runtime.common.driver.idle.DriverIdlenessSource
• org.apache.reef.webserver.DriverInfoSerializer
• org.apache.reef.task.events.DriverMessage
• org.apache.reef.tang.util.walk.EdgeVisitor<T>
• org.apache.reef.wake.remote.Encoder<T>
  • org.apache.reef.wake.remote.Codec<T> (also extends org.apache.reef.wake.remote.Decoder<T>)
    • org.apache.reef.io.network.impl.StreamingCodec<T>
  • org.apache.reef.io.network.impl.StreamingCodec<T>
• org.apache.reef.driver.evaluator.EvaluatorDescriptor
• org.apache.reef.webserver.EvaluatorInfoSerializer
• org.apache.reef.webserver.EvaluatorListSerializer
• org.apache.reef.driver.evaluator.EvaluatorRequestor
• org.apache.reef.wake.EventHandler<T>
  • org.apache.reef.evaluator.context.ContextMessageHandler
  • org.apache.reef.wake.EStage<T> (also extends org.apache.reef.wake.Stage)
  • org.apache.reef.runtime.common.client.api.JobSubmissionHandler (also extends java.lang.AutoCloseable)
  • org.apache.reef.driver.PreemptionHandler
  • org.apache.reef.runtime.common.driver.api.ResourceLaunchHandler
  • org.apache.reef.runtime.common.driver.api.ResourceReleaseHandler
  • org.apache.reef.runtime.common.driver.api.ResourceRequestHandler
• org.apache.reef.wake.examples.p2p.EventSource<T>
• org.apache.reef.runtime.common.utils.ExceptionCodec
• org.apache.reef.tang.ExternalConstructor<T>
• org.apache.reef.io.ExternalMap<T>
• org.apache.reef.wake.metrics.Histogram
• org.apache.reef.webserver.HttpHandler
• org.apache.reef.webserver.HttpServer
• org.apache.reef.wake.Identifiable
• org.apache.reef.io.naming.Identifiable
  • org.apache.reef.driver.context.ActiveContext (also extends java.lang.AutoCloseable, org.apache.reef.driver.context.ContextBase, org.apache.reef.driver.ContextSubmittable, org.apache.reef.driver.TaskSubmittable)
  • org.apache.reef.driver.evaluator.AllocatedEvaluator (also extends java.lang.AutoCloseable, org.apache.reef.driver.ContextAndTaskSubmittable, org.apache.reef.driver.ContextSubmittable, org.apache.reef.driver.TaskSubmittable)
  • org.apache.reef.driver.context.ClosedContext
  • org.apache.reef.driver.evaluator.CompletedEvaluator
  • org.apache.reef.client.CompletedJob
  • org.apache.reef.driver.task.CompletedTask (also extends org.apache.reef.io.Message)
  • org.apache.reef.driver.context.ContextBase
    • org.apache.reef.driver.context.ActiveContext (also extends java.lang.AutoCloseable, org.apache.reef.driver.ContextSubmittable, org.apache.reef.io.naming.Identifiable, org.apache.reef.driver.TaskSubmittable)
    • org.apache.reef.driver.context.ClosedContext
    • org.apache.reef.driver.context.FailedContext (also extends org.apache.reef.common.Failure)
  • org.apache.reef.driver.context.ContextMessage (also extends org.apache.reef.io.Message)
  • org.apache.reef.evaluator.context.events.ContextStart
  • org.apache.reef.evaluator.context.events.ContextStop
  • org.apache.reef.driver.context.FailedContext (also extends org.apache.reef.driver.context.ContextBase, org.apache.reef.common.Failure)
  • org.apache.reef.driver.evaluator.FailedEvaluator
  • org.apache.reef.common.Failure
    • org.apache.reef.driver.context.FailedContext (also extends org.apache.reef.driver.context.ContextBase)
  • org.apache.reef.driver.catalog.NodeDescriptor (also extends org.apache.reef.driver.catalog.ResourceCatalog.Descriptor)
  • org.apache.reef.client.RunningJob (also extends java.lang.AutoCloseable)
  • org.apache.reef.driver.task.RunningTask (also extends java.lang.AutoCloseable)
  • org.apache.reef.driver.task.SuspendedTask (also extends org.apache.reef.io.Message)
  • org.apache.reef.driver.task.TaskMessage (also extends org.apache.reef.io.Message)
  • org.apache.reef.task.events.TaskStart
  • org.apache.reef.task.events.TaskStop
• org.apache.reef.wake.Identifier
  • org.apache.reef.wake.ComparableIdentifier (also extends java.lang.Comparable<T>)
  • org.apache.reef.wake.remote.RemoteIdentifier
  • org.apache.reef.wake.storage.StorageIdentifier
• org.apache.reef.wake.IdentifierFactory
  • org.apache.reef.wake.remote.RemoteIdentifierFactory
• org.apache.reef.tang.formats.Impl<T>
• org.apache.reef.tang.Injector
• java.lang.Iterable<T>
  • org.apache.reef.io.data.loading.api.DataSet<K,V>
  • org.apache.reef.io.Spool<T> (also extends org.apache.reef.io.Accumulable<T>)
• org.apache.reef.driver.client.JobMessageObserver
• org.apache.reef.runtime.common.launch.LaunchCommandBuilder
• org.apache.reef.wake.remote.transport.LinkListener<T>
  • org.apache.reef.wake.remote.transport.Link<T>
• java.util.Map<K,V>
  • org.apache.reef.tang.util.TracingMonotonicMap<K,V>
• org.apache.reef.io.Message
  • org.apache.reef.driver.task.CompletedTask (also extends org.apache.reef.io.naming.Identifiable)
  • org.apache.reef.driver.context.ContextMessage (also extends org.apache.reef.io.naming.Identifiable)
  • org.apache.reef.driver.task.SuspendedTask (also extends org.apache.reef.io.naming.Identifiable)
  • org.apache.reef.driver.task.TaskMessage (also extends org.apache.reef.io.naming.Identifiable)
• org.apache.reef.io.network.Message<T>
• com.google.protobuf.MessageLiteOrBuilder
  • org.apache.reef.tang.proto.ClassHierarchyProto.ClassNodeOrBuilder
  • org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArgOrBuilder
  • org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDefOrBuilder
  • org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNodeOrBuilder
  • org.apache.reef.tang.proto.ClassHierarchyProto.NodeOrBuilder
  • org.apache.reef.tang.proto.ClassHierarchyProto.PackageNodeOrBuilder
  • org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder
  • org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder
  • org.apache.reef.proto.DriverRuntimeProtocol.DriverProcessRegistrationProtoOrBuilder
  • org.apache.reef.proto.DriverRuntimeProtocol.NodeDescriptorProtoOrBuilder
  • org.apache.reef.proto.DriverRuntimeProtocol.ResourceAllocationProtoOrBuilder
  • org.apache.reef.proto.DriverRuntimeProtocol.ResourceLaunchProtoOrBuilder
  • org.apache.reef.proto.DriverRuntimeProtocol.ResourceReleaseProtoOrBuilder
  • org.apache.reef.proto.DriverRuntimeProtocol.ResourceRequestProtoOrBuilder
  • org.apache.reef.proto.DriverRuntimeProtocol.ResourceStatusProtoOrBuilder
  • org.apache.reef.proto.DriverRuntimeProtocol.RuntimeStatusProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProtoOrBuilder
  • org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProtoOrBuilder
  • org.apache.reef.tang.proto.InjectionPlanProto.ConstructorOrBuilder
  • org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlanOrBuilder
  • org.apache.reef.tang.proto.InjectionPlanProto.InstanceOrBuilder
  • org.apache.reef.tang.proto.InjectionPlanProto.SubplanOrBuilder
  • com.google.protobuf.MessageOrBuilder
    • org.apache.reef.tang.proto.ClassHierarchyProto.ClassNodeOrBuilder
    • org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArgOrBuilder
    • org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDefOrBuilder
    • org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNodeOrBuilder
    • org.apache.reef.tang.proto.ClassHierarchyProto.NodeOrBuilder
    • org.apache.reef.tang.proto.ClassHierarchyProto.PackageNodeOrBuilder
    • org.apache.reef.proto.ClientRuntimeProtocol.JobControlProtoOrBuilder
    • org.apache.reef.proto.ClientRuntimeProtocol.JobSubmissionProtoOrBuilder
    • org.apache.reef.proto.DriverRuntimeProtocol.DriverProcessRegistrationProtoOrBuilder
    • org.apache.reef.proto.DriverRuntimeProtocol.NodeDescriptorProtoOrBuilder
    • org.apache.reef.proto.DriverRuntimeProtocol.ResourceAllocationProtoOrBuilder
    • org.apache.reef.proto.DriverRuntimeProtocol.ResourceLaunchProtoOrBuilder
    • org.apache.reef.proto.DriverRuntimeProtocol.ResourceReleaseProtoOrBuilder
    • org.apache.reef.proto.DriverRuntimeProtocol.ResourceRequestProtoOrBuilder
    • org.apache.reef.proto.DriverRuntimeProtocol.ResourceStatusProtoOrBuilder
    • org.apache.reef.proto.DriverRuntimeProtocol.RuntimeStatusProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProtoOrBuilder
    • org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProtoOrBuilder
    • org.apache.reef.tang.proto.InjectionPlanProto.ConstructorOrBuilder
    • org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlanOrBuilder
    • org.apache.reef.tang.proto.InjectionPlanProto.InstanceOrBuilder
    • org.apache.reef.tang.proto.InjectionPlanProto.SubplanOrBuilder
    • org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBufOrBuilder
    • org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder
    • org.apache.reef.proto.REEFProtocol.REEFMessageOrBuilder
    • org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder
    • org.apache.reef.proto.ReefServiceProtos.ContextStatusProtoOrBuilder
    • org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProtoOrBuilder
    • org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder
    • org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder
    • org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder
    • org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder
    • org.apache.reef.proto.ReefServiceProtos.TaskStatusProtoOrBuilder
    • org.apache.reef.wake.test.proto.TestProtos.TestEventPBufOrBuilder
    • org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBufOrBuilder
    • org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBufOrBuilder
  • org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBufOrBuilder
  • org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBufOrBuilder
  • org.apache.reef.proto.REEFProtocol.REEFMessageOrBuilder
  • org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProtoOrBuilder
  • org.apache.reef.proto.ReefServiceProtos.ContextStatusProtoOrBuilder
  • org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProtoOrBuilder
  • org.apache.reef.proto.ReefServiceProtos.FileResourceProtoOrBuilder
  • org.apache.reef.proto.ReefServiceProtos.JobStatusProtoOrBuilder
  • org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProtoOrBuilder
  • org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProtoOrBuilder
  • org.apache.reef.proto.ReefServiceProtos.TaskStatusProtoOrBuilder
  • org.apache.reef.wake.test.proto.TestProtos.TestEventPBufOrBuilder
  • org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBufOrBuilder
  • org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBufOrBuilder
• org.apache.reef.tang.annotations.Name<T>
• org.apache.reef.io.naming.NameAssignment
• org.apache.reef.io.naming.NamingLookup
  • org.apache.reef.io.naming.Naming (also extends org.apache.reef.io.naming.NamingRegistry)
• org.apache.reef.io.naming.NamingRegistry
  • org.apache.reef.io.naming.Naming (also extends org.apache.reef.io.naming.NamingLookup)
• org.apache.reef.tang.util.walk.NodeVisitor<T>
• org.apache.reef.wake.rx.Observable
  • org.apache.reef.wake.rx.DynamicObservable<T>
  • org.apache.reef.wake.rx.StaticObservable
    • org.apache.reef.wake.rx.Subject<InType,OutType> (also extends org.apache.reef.wake.rx.Observer<T>)
  • org.apache.reef.wake.rx.Subject<InType,OutType> (also extends org.apache.reef.wake.rx.Observer<T>, org.apache.reef.wake.rx.StaticObservable)
• org.apache.reef.wake.rx.Observer<T>
  • org.apache.reef.wake.rx.RxStage<T> (also extends org.apache.reef.wake.Stage)
  • org.apache.reef.wake.rx.Subject<InType,OutType> (also extends org.apache.reef.wake.rx.StaticObservable)
• org.apache.reef.tang.formats.Param<T>
• org.apache.reef.driver.PreemptionEvent
  • org.apache.reef.driver.FlexiblePreemptionEvent
  • org.apache.reef.driver.StrictPreemptionEvent
• org.apache.reef.wake.remote.RemoteMessage<T>
• org.apache.reef.driver.catalog.ResourceCatalog
• org.apache.reef.driver.catalog.ResourceCatalog.Descriptor
  • org.apache.reef.driver.catalog.NodeDescriptor (also extends org.apache.reef.io.naming.Identifiable)
  • org.apache.reef.driver.catalog.RackDescriptor
• java.lang.Runnable
  • org.apache.reef.wake.time.Clock (also extends java.lang.AutoCloseable)
• org.apache.reef.runtime.local.process.RunnableProcessObserver
• org.apache.reef.runtime.common.files.RuntimeClasspathProvider
• org.apache.reef.io.storage.ScratchSpace
• org.apache.reef.io.serialization.Serializer<ObjectType,OutType>
• org.apache.reef.io.storage.StorageService
• org.apache.reef.task.events.SuspendEvent
• org.apache.reef.tang.Tang
• org.apache.reef.task.Task
• org.apache.reef.task.TaskMessageSource
• org.apache.reef.driver.TaskSubmittable
  • org.apache.reef.driver.context.ActiveContext (also extends java.lang.AutoCloseable, org.apache.reef.driver.context.ContextBase, org.apache.reef.driver.ContextSubmittable, org.apache.reef.io.naming.Identifiable)
  • org.apache.reef.driver.evaluator.AllocatedEvaluator (also extends java.lang.AutoCloseable, org.apache.reef.driver.ContextAndTaskSubmittable, org.apache.reef.driver.ContextSubmittable, org.apache.reef.io.naming.Identifiable)
• org.apache.reef.io.TempFileCreator
• org.apache.reef.tang.examples.timer.Timer
• org.apache.reef.wake.time.runtime.Timer
• org.apache.reef.runtime.yarn.driver.TrackingURLProvider
• org.apache.reef.io.network.TransportFactory
• org.apache.reef.tang.types.Traversable<T>
  • org.apache.reef.tang.types.ClassNode<T>
  • org.apache.reef.tang.types.NamedParameterNode<T>
  • org.apache.reef.tang.types.Node (also extends java.lang.Comparable<T>)
    • org.apache.reef.tang.types.ClassNode<T>
    • org.apache.reef.tang.types.NamedParameterNode<T>
    • org.apache.reef.tang.types.PackageNode
  • org.apache.reef.tang.types.PackageNode
• org.apache.hadoop.io.Writable
  • org.apache.reef.io.checkpoint.CheckpointID
• org.apache.reef.runtime.yarn.driver.YarnContainerRequestHandler

Annotation Type Hierarchy

• org.apache.reef.annotations.Provided (implements java.lang.annotation.Annotation)
• org.apache.reef.annotations.Unstable (implements java.lang.annotation.Annotation)
• org.apache.reef.annotations.Optional (implements java.lang.annotation.Annotation)
• org.apache.reef.annotations.semantics.Idempotent (implements java.lang.annotation.Annotation)
• org.apache.reef.annotations.audience.TaskSide (implements java.lang.annotation.Annotation)
• org.apache.reef.annotations.audience.Public (implements java.lang.annotation.Annotation)
• org.apache.reef.annotations.audience.DriverSide (implements java.lang.annotation.Annotation)
• org.apache.reef.annotations.audience.Private (implements java.lang.annotation.Annotation)
• org.apache.reef.annotations.audience.EvaluatorSide (implements java.lang.annotation.Annotation)
• org.apache.reef.annotations.audience.ClientSide (implements java.lang.annotation.Annotation)
• org.apache.reef.annotations.audience.RuntimeAuthor (implements java.lang.annotation.Annotation)
• org.apache.reef.tang.annotations.Unit (implements java.lang.annotation.Annotation)
• org.apache.reef.tang.annotations.NamedParameter (implements java.lang.annotation.Annotation)
• org.apache.reef.tang.annotations.DefaultImplementation (implements java.lang.annotation.Annotation)
• org.apache.reef.tang.annotations.Parameter (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.reef.driver.evaluator.EvaluatorType
    • org.apache.reef.io.PartitionSpec.Type
    • org.apache.reef.runtime.common.driver.DriverStatus
    • org.apache.reef.proto.ReefServiceProtos.State (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.reef.proto.ReefServiceProtos.FileType (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.reef.proto.ReefServiceProtos.ProcessType (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.reef.proto.ClientRuntimeProtocol.Signal (implements com.google.protobuf.ProtocolMessageEnum)
    • org.apache.reef.tests.fail.driver.FailDriver.ExpectedMessage.RequiredFlag