A B C D E F G H I J K L M N O P Q R S T U V W Y 

A

A - Class in org.apache.reef.tang.examples
 
A() - Constructor for class org.apache.reef.tang.examples.A
 
abort(CheckpointService.CheckpointWriteChannel) - Method in interface org.apache.reef.io.checkpoint.CheckpointService
Aborts the current checkpoint.
abort(CheckpointService.CheckpointWriteChannel) - Method in class org.apache.reef.io.checkpoint.fs.FSCheckpointService
 
AbstractClassHierarchyNodeVisitor - Class in org.apache.reef.tang.util.walk
Generic interface to traverse nodes of the class hierarchy.
AbstractClassHierarchyNodeVisitor() - Constructor for class org.apache.reef.tang.util.walk.AbstractClassHierarchyNodeVisitor
 
AbstractEStage<T> - Class in org.apache.reef.wake
An EStage that implements metering.
AbstractEStage(String) - Constructor for class org.apache.reef.wake.AbstractEStage
Constructs an abstract estage.
AbstractEvaluatorToPartitionStrategy - Class in org.apache.reef.io.data.loading.impl
This is an abstract class useful for EvaluatorToPartitionStrategy implementations.
AbstractFailure - Class in org.apache.reef.common
Common data and functionality for all error messages in REEF.
AbstractGroupCommOperator - Class in org.apache.reef.io.network.group.api.operators
 
AbstractGroupCommOperator() - Constructor for class org.apache.reef.io.network.group.api.operators.AbstractGroupCommOperator
 
AbstractInjectionPlanNodeVisitor - Class in org.apache.reef.tang.util.walk
Generic interface to traverse nodes of the injection plan.
AbstractInjectionPlanNodeVisitor() - Constructor for class org.apache.reef.tang.util.walk.AbstractInjectionPlanNodeVisitor
 
AbstractMonotonicMultiMap<K,V> - Class in org.apache.reef.tang.util
 
AbstractMonotonicMultiMap(Map<K, Set<V>>) - Constructor for class org.apache.reef.tang.util.AbstractMonotonicMultiMap
 
AbstractNode - Class in org.apache.reef.tang.implementation.types
 
AbstractNode(Node, String, String) - Constructor for class org.apache.reef.tang.implementation.types.AbstractNode
 
AbstractObserver<T> - Class in org.apache.reef.wake.rx
An Observer with logging-only onError and onCompleted() methods.
AbstractObserver() - Constructor for class org.apache.reef.wake.rx.AbstractObserver
 
AbstractRxStage<T> - Class in org.apache.reef.wake.rx
An RxStage that implements metering.
AbstractRxStage(String) - Constructor for class org.apache.reef.wake.rx.AbstractRxStage
Constructs an abstact rxstage.
AbstractVector - Class in org.apache.reef.examples.group.utils.math
Abstract base class for Vector implementations.
AbstractVector() - Constructor for class org.apache.reef.examples.group.utils.math.AbstractVector
 
Accumulable<T> - Interface in org.apache.reef.io
Similar to Iterable, this is an interface for objects that can return Accumulators.
accumulator() - Method in interface org.apache.reef.io.Accumulable
Returns a new Accumulator.
Accumulator<T> - Interface in org.apache.reef.io
A basic Accumulator interface.
accumulator() - Method in interface org.apache.reef.io.Spool
Returns an Accumulator for the spool file.
accumulator() - Method in class org.apache.reef.io.storage.FramingOutputStream
 
accumulator() - Method in class org.apache.reef.io.storage.local.CodecFileAccumulable
 
accumulator() - Method in class org.apache.reef.io.storage.local.SerializerFileSpool
 
accumulator() - Method in class org.apache.reef.io.storage.ram.RamSpool
 
accumulator() - Method in class org.apache.reef.io.storage.ram.SortingRamSpool
 
Acknowledgement - Class in org.apache.reef.bridge.message
 
Acknowledgement() - Constructor for class org.apache.reef.bridge.message.Acknowledgement
Default constructor.
Acknowledgement(Long) - Constructor for class org.apache.reef.bridge.message.Acknowledgement
All-args constructor.
Acknowledgement.Builder - Class in org.apache.reef.bridge.message
RecordBuilder for Acknowledgement instances.
ACLS_MODIFY_APP - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.AmContainerSpec
 
ACLS_VIEW_APP - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.AmContainerSpec
 
ACTIVE_CONTEXT - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
ActiveContext - Interface in org.apache.reef.driver.context
Represents an active context on an Evaluator.
activeContext - Variable in class org.apache.reef.io.watcher.driver.task.AvroCompletedTask
Deprecated.
activeContext - Variable in class org.apache.reef.io.watcher.driver.task.AvroFailedTask
Deprecated.
activeContext - Variable in class org.apache.reef.io.watcher.driver.task.AvroRunningTask
Deprecated.
activeContext - Variable in class org.apache.reef.io.watcher.driver.task.AvroSuspendedTask
Deprecated.
ActiveContextBridge - Class in org.apache.reef.javabridge
The Java-CLR bridge object for ActiveContext.
ActiveContextBridgeFactory - Class in org.apache.reef.javabridge
Factory for ActiveContextBridge instances.
activeContextReceived(String) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time in calling activeContext handler.
add(Vector) - Method in class org.apache.reef.examples.group.utils.math.AbstractVector
 
add(Vector) - Method in interface org.apache.reef.examples.group.utils.math.Vector
Adds the Vector that to this one in place: this += that.
add(double) - Method in class org.apache.reef.examples.group.utils.math.Window
 
add(T) - Method in interface org.apache.reef.io.Accumulator
Add the given datum to this.
add(K, V) - Method in class org.apache.reef.io.network.group.impl.utils.ConcurrentCountingMap
 
add(L) - Method in class org.apache.reef.io.network.group.impl.utils.CountingMap
 
add(K, V) - Method in class org.apache.reef.io.network.group.impl.utils.SetMap
 
add(Map.Entry<K, V>) - Method in class org.apache.reef.tang.util.AbstractMonotonicMultiMap
 
add(T) - Method in class org.apache.reef.tang.util.MonotonicHashSet
 
add(T) - Method in class org.apache.reef.tang.util.MonotonicSet
 
add(File) - Method in class org.apache.reef.util.JARFileMaker
Adds a file to the JAR.
ADD_CONTEXT_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto
 
addAll(Collection<? extends Map.Entry<K, V>>) - Method in class org.apache.reef.tang.util.AbstractMonotonicMultiMap
 
addAll(Collection<? extends T>) - Method in class org.apache.reef.tang.util.MonotonicHashSet
 
addAll(Collection<? extends T>) - Method in class org.apache.reef.tang.util.MonotonicSet
 
addAllArgs(Iterable<? extends ClassHierarchyProto.ConstructorArg>) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
repeated .ConstructorArg args = 2;
addAllArgs(Iterable<? extends InjectionPlanProto.InjectionPlan>) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
repeated .InjectionPlan args = 1;
addAllChildren(Iterable<? extends ClassHierarchyProto.Node>) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
repeated .Node children = 6;
addAllContextMessage(Iterable<? extends ReefServiceProtos.ContextStatusProto.ContextMessageProto>) - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
repeated .ContextStatusProto.ContextMessageProto context_message = 7;
addAllContextStatus(Iterable<? extends ReefServiceProtos.ContextStatusProto>) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
repeated .ContextStatusProto context_status = 3;
addAllIgnoreDuplicates(Collection<? extends T>) - Method in class org.apache.reef.tang.util.MonotonicHashSet
 
addAllIgnoreDuplicates(Collection<? extends T>) - Method in class org.apache.reef.tang.util.MonotonicSet
 
addAllImplFullNames(Iterable<String>) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated string impl_full_names = 6;
addAllInjectableConstructors(Iterable<? extends ClassHierarchyProto.ConstructorDef>) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef InjectableConstructors = 4;
addAllInstanceDefault(Iterable<String>) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
repeated string instance_default = 7;
addAllMsgs(Iterable<? extends ReefNetworkGroupCommProtos.GroupMessageBody>) - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
repeated .GroupMessageBody msgs = 8;
addAllMsgs(Iterable<? extends ReefNetworkServiceProtos.NSRecordPBuf>) - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
repeated .NSRecordPBuf msgs = 4;
addAllOtherConstructors(Iterable<? extends ClassHierarchyProto.ConstructorDef>) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef OtherConstructors = 5;
addAllPlans(Iterable<? extends InjectionPlanProto.InjectionPlan>) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
repeated .InjectionPlan plans = 2;
addAllTaskMessage(Iterable<? extends ReefServiceProtos.TaskStatusProto.TaskMessageProto>) - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
repeated .TaskStatusProto.TaskMessageProto task_message = 6;
addApplicationAcl(String, String) - Method in class org.apache.reef.runtime.hdinsight.client.yarnrest.AmContainerSpec
 
addApplicationTag(String) - Method in class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationSubmission
 
addArgs(ClassHierarchyProto.ConstructorArg) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
repeated .ConstructorArg args = 2;
addArgs(int, ClassHierarchyProto.ConstructorArg) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
repeated .ConstructorArg args = 2;
addArgs(ClassHierarchyProto.ConstructorArg.Builder) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
repeated .ConstructorArg args = 2;
addArgs(int, ClassHierarchyProto.ConstructorArg.Builder) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
repeated .ConstructorArg args = 2;
addArgs(InjectionPlanProto.InjectionPlan) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
repeated .InjectionPlan args = 1;
addArgs(int, InjectionPlanProto.InjectionPlan) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
repeated .InjectionPlan args = 1;
addArgs(InjectionPlanProto.InjectionPlan.Builder) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
repeated .InjectionPlan args = 1;
addArgs(int, InjectionPlanProto.InjectionPlan.Builder) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
repeated .InjectionPlan args = 1;
addArgsBuilder() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
repeated .ConstructorArg args = 2;
addArgsBuilder(int) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
repeated .ConstructorArg args = 2;
addArgsBuilder() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
repeated .InjectionPlan args = 1;
addArgsBuilder(int) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
repeated .InjectionPlan args = 1;
addAsData(GroupCommunicationMessage) - Method in interface org.apache.reef.io.network.group.api.task.OperatorTopologyStruct
 
addAsData(GroupCommunicationMessage) - Method in class org.apache.reef.io.network.group.impl.task.OperatorTopologyStructImpl
 
addBroadcast(Class<? extends Name<String>>, BroadcastOperatorSpec) - Method in interface org.apache.reef.io.network.group.api.driver.CommunicationGroupDriver
Add the broadcast operator specified by the.
addBroadcast(Class<? extends Name<String>>, BroadcastOperatorSpec) - Method in class org.apache.reef.io.network.group.impl.driver.CommunicationGroupDriverImpl
 
addChild(TaskNode) - Method in interface org.apache.reef.io.network.group.api.driver.TaskNode
 
addChild(TaskNode) - Method in class org.apache.reef.io.network.group.impl.driver.TaskNodeImpl
 
addChild(TopologySimpleNode) - Method in class org.apache.reef.io.network.group.impl.driver.TopologySimpleNode
 
addChildren(ClassHierarchyProto.Node) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
repeated .Node children = 6;
addChildren(int, ClassHierarchyProto.Node) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
repeated .Node children = 6;
addChildren(ClassHierarchyProto.Node.Builder) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
repeated .Node children = 6;
addChildren(int, ClassHierarchyProto.Node.Builder) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
repeated .Node children = 6;
addChildren(File) - Method in class org.apache.reef.util.JARFileMaker
 
addChildrenBuilder() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
repeated .Node children = 6;
addChildrenBuilder(int) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
repeated .Node children = 6;
addCLRFiles(File) - Method in class org.apache.reef.javabridge.generic.JobClient
 
addCommandLineOption(Option, CommandLine.CommandLineCallback) - Method in class org.apache.reef.tang.formats.CommandLine
 
addComputeRequest(EvaluatorRequest) - Method in class org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder
Adds a single request to the compute requests list.
addComputeRequests(List<EvaluatorRequest>) - Method in class org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder
Adds the requests to the compute requests list.
addConfiguration(Configuration) - Method in interface org.apache.reef.tang.ConfigurationBuilder
Add all configuration parameters from the given Configuration object.
addConfiguration(Configuration) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
addContainerAllocation(String) - Method in class org.apache.reef.runtime.common.driver.resourcemanager.RuntimeStatusEventImpl.Builder
Add an entry to containerAllocationList.
addContextMessage(ReefServiceProtos.ContextStatusProto.ContextMessageProto) - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
repeated .ContextStatusProto.ContextMessageProto context_message = 7;
addContextMessage(int, ReefServiceProtos.ContextStatusProto.ContextMessageProto) - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
repeated .ContextStatusProto.ContextMessageProto context_message = 7;
addContextMessage(ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder) - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
repeated .ContextStatusProto.ContextMessageProto context_message = 7;
addContextMessage(int, ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder) - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
repeated .ContextStatusProto.ContextMessageProto context_message = 7;
addContextMessageBuilder() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
repeated .ContextStatusProto.ContextMessageProto context_message = 7;
addContextMessageBuilder(int) - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
repeated .ContextStatusProto.ContextMessageProto context_message = 7;
addContextStatus(ReefServiceProtos.ContextStatusProto) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
repeated .ContextStatusProto context_status = 3;
addContextStatus(int, ReefServiceProtos.ContextStatusProto) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
repeated .ContextStatusProto context_status = 3;
addContextStatus(ReefServiceProtos.ContextStatusProto.Builder) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
repeated .ContextStatusProto context_status = 3;
addContextStatus(int, ReefServiceProtos.ContextStatusProto.Builder) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
repeated .ContextStatusProto context_status = 3;
addContextStatusBuilder() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
repeated .ContextStatusProto context_status = 3;
addContextStatusBuilder(int) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
repeated .ContextStatusProto context_status = 3;
addData(GroupCommunicationMessage) - Method in interface org.apache.reef.io.network.group.api.task.NodeStruct
 
addData(GroupCommunicationMessage) - Method in class org.apache.reef.io.network.group.impl.task.NodeStructImpl
 
addDataRequest(EvaluatorRequest) - Method in class org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder
Adds a single request to the data requests list.
addDataRequests(List<EvaluatorRequest>) - Method in class org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder
Adds the requests to the data requests list.
addEnvironment(String, String) - Method in class org.apache.reef.runtime.hdinsight.client.yarnrest.AmContainerSpec
 
addEventHandler(EventHandler<E>) - Method in class org.apache.reef.runtime.common.utils.BroadCastEventHandler
 
addFile(File) - Method in interface org.apache.reef.driver.evaluator.AllocatedEvaluator
Puts the given file into the working directory of the Evaluator.
addFile(FileResource) - Method in class org.apache.reef.runtime.common.driver.api.ResourceLaunchEventImpl.Builder
Add an entry to the fileSet.
addFile(File) - Method in class org.apache.reef.runtime.common.driver.evaluator.AllocatedEvaluatorImpl
 
addFiles(Iterable<File>) - Method in class org.apache.reef.runtime.common.driver.api.ResourceLaunchEventImpl.Builder
Utility method that adds files to the fileSet.
addGather(Class<? extends Name<String>>, GatherOperatorSpec) - Method in interface org.apache.reef.io.network.group.api.driver.CommunicationGroupDriver
Add the gather operator specified by operatorName and spec.
addGather(Class<? extends Name<String>>, GatherOperatorSpec) - Method in class org.apache.reef.io.network.group.impl.driver.CommunicationGroupDriverImpl
 
addGlobalFile(FileResource) - Method in class org.apache.reef.runtime.common.client.api.JobSubmissionEventImpl.Builder
Add an entry to the globalFileSet.
addGlobalFiles(File) - Method in interface org.apache.reef.runtime.local.driver.Container
 
addGlobalFiles(File) - Method in class org.apache.reef.runtime.local.driver.ProcessContainer
 
addGradient(Vector, double) - Method in interface org.apache.reef.examples.group.bgd.data.Example
Adds the current example's gradient to the gradientVector, assuming that the gradient with respect to the prediction is gradient.
addGradient(Vector, double) - Method in class org.apache.reef.examples.group.bgd.data.SparseExample
 
addHandler(Class<? extends Name<String>>, SingleThreadStage<GroupCommunicationMessage>) - Method in class org.apache.reef.io.network.group.impl.driver.GroupCommMessageHandler
 
addHandler(EventHandler<T>) - Method in class org.apache.reef.io.network.group.impl.utils.BroadcastingEventHandler
 
addHttpHandler(HttpHandler) - Method in interface org.apache.reef.webserver.HttpServer
Add a httpHandler to the server.
addHttpHandler(HttpHandler) - Method in class org.apache.reef.webserver.HttpServerImpl
Add a HttpHandler to Jetty Handler.
addHttpHandler(HttpHandler) - Method in class org.apache.reef.webserver.NoOpHttpServerImpl
 
addImplFullNames(String) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated string impl_full_names = 6;
addImplFullNamesBytes(ByteString) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated string impl_full_names = 6;
addInjectableConstructors(ClassHierarchyProto.ConstructorDef) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef InjectableConstructors = 4;
addInjectableConstructors(int, ClassHierarchyProto.ConstructorDef) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef InjectableConstructors = 4;
addInjectableConstructors(ClassHierarchyProto.ConstructorDef.Builder) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef InjectableConstructors = 4;
addInjectableConstructors(int, ClassHierarchyProto.ConstructorDef.Builder) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef InjectableConstructors = 4;
addInjectableConstructorsBuilder() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef InjectableConstructors = 4;
addInjectableConstructorsBuilder(int) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef InjectableConstructors = 4;
addInstanceDefault(String) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
repeated string instance_default = 7;
addInstanceDefaultBytes(ByteString) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
repeated string instance_default = 7;
AdditionAggregateFunction - Class in org.apache.reef.vortex.examples.sumones
Aggregates and sums the outputs.
AdditionAggregateFunction() - Constructor for class org.apache.reef.vortex.examples.sumones.AdditionAggregateFunction
 
addLibraries(Iterable<File>) - Method in class org.apache.reef.runtime.common.driver.api.ResourceLaunchEventImpl.Builder
Utility method that adds Libraries to the fileSet.
addLibrary(File) - Method in interface org.apache.reef.driver.evaluator.AllocatedEvaluator
Puts the given file into the working directory of the Evaluator and adds it to its classpath.
addLibrary(File) - Method in class org.apache.reef.runtime.common.driver.evaluator.AllocatedEvaluatorImpl
 
addLocalFile(FileResource) - Method in class org.apache.reef.runtime.common.client.api.JobSubmissionEventImpl.Builder
Add an entry to the localFileSet.
addLocalFiles(Iterable<File>) - Method in interface org.apache.reef.runtime.local.driver.Container
Copies the files to the working directory of the container.
addLocalFiles(Iterable<File>) - Method in class org.apache.reef.runtime.local.driver.ProcessContainer
 
addLocalResource(String, LocalResource) - Method in class org.apache.reef.runtime.hdinsight.client.yarnrest.AmContainerSpec
 
addLocalResource(String, LocalResource) - Method in class org.apache.reef.runtime.yarn.client.YarnSubmissionHelper
Add a file to be localized on the driver.
addMsgs(ReefNetworkGroupCommProtos.GroupMessageBody) - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
repeated .GroupMessageBody msgs = 8;
addMsgs(int, ReefNetworkGroupCommProtos.GroupMessageBody) - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
repeated .GroupMessageBody msgs = 8;
addMsgs(ReefNetworkGroupCommProtos.GroupMessageBody.Builder) - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
repeated .GroupMessageBody msgs = 8;
addMsgs(int, ReefNetworkGroupCommProtos.GroupMessageBody.Builder) - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
repeated .GroupMessageBody msgs = 8;
addMsgs(ReefNetworkServiceProtos.NSRecordPBuf) - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
repeated .NSRecordPBuf msgs = 4;
addMsgs(int, ReefNetworkServiceProtos.NSRecordPBuf) - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
repeated .NSRecordPBuf msgs = 4;
addMsgs(ReefNetworkServiceProtos.NSRecordPBuf.Builder) - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
repeated .NSRecordPBuf msgs = 4;
addMsgs(int, ReefNetworkServiceProtos.NSRecordPBuf.Builder) - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
repeated .NSRecordPBuf msgs = 4;
addMsgsBuilder() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
repeated .GroupMessageBody msgs = 8;
addMsgsBuilder(int) - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
repeated .GroupMessageBody msgs = 8;
addMsgsBuilder() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
repeated .NSRecordPBuf msgs = 4;
addMsgsBuilder(int) - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
repeated .NSRecordPBuf msgs = 4;
addNodeName(String) - Method in class org.apache.reef.driver.evaluator.EvaluatorRequest.Builder
Adds a node name.It is the preferred location where the evaluator should run on.
addNodeName(String) - Method in class org.apache.reef.runtime.common.driver.api.ResourceRequestEventImpl.Builder
Add an entry to the nodeNameList.
addNodeNames(List<String>) - Method in class org.apache.reef.runtime.common.driver.api.ResourceRequestEventImpl.Builder
Add a list of node names.
addOption(String) - Method in class org.apache.reef.driver.evaluator.JVMProcess
Add a JVM option.
addOption(String) - Method in class org.apache.reef.runtime.common.launch.JavaLaunchCommandBuilder
Add a JVM option.
addOtherConstructors(ClassHierarchyProto.ConstructorDef) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef OtherConstructors = 5;
addOtherConstructors(int, ClassHierarchyProto.ConstructorDef) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef OtherConstructors = 5;
addOtherConstructors(ClassHierarchyProto.ConstructorDef.Builder) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef OtherConstructors = 5;
addOtherConstructors(int, ClassHierarchyProto.ConstructorDef.Builder) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef OtherConstructors = 5;
addOtherConstructorsBuilder() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef OtherConstructors = 5;
addOtherConstructorsBuilder(int) - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef OtherConstructors = 5;
addParser(Class<? extends ExternalConstructor<?>>) - Method in class org.apache.reef.tang.formats.ParameterParser
 
addParser(Class<U>, Class<? extends ExternalConstructor<T>>) - Method in class org.apache.reef.tang.formats.ParameterParser
 
addPartition(DistributedDataSetPartition) - Method in class org.apache.reef.io.data.loading.api.DistributedDataSet
Adds the given partition to the set.
addPartitions(Collection<DistributedDataSetPartition>) - Method in class org.apache.reef.io.data.loading.api.DistributedDataSet
Adds the given partitions to the set.
addPlans(InjectionPlanProto.InjectionPlan) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
repeated .InjectionPlan plans = 2;
addPlans(int, InjectionPlanProto.InjectionPlan) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
repeated .InjectionPlan plans = 2;
addPlans(InjectionPlanProto.InjectionPlan.Builder) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
repeated .InjectionPlan plans = 2;
addPlans(int, InjectionPlanProto.InjectionPlan.Builder) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
repeated .InjectionPlan plans = 2;
addPlansBuilder() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
repeated .InjectionPlan plans = 2;
addPlansBuilder(int) - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
repeated .InjectionPlan plans = 2;
addRackName(String) - Method in class org.apache.reef.driver.evaluator.EvaluatorRequest.Builder
Adds a rack name.
addRackName(String) - Method in class org.apache.reef.runtime.common.driver.api.ResourceRequestEventImpl.Builder
Add a list of rack names.
addRackNames(List<String>) - Method in class org.apache.reef.runtime.common.driver.api.ResourceRequestEventImpl.Builder
Add an entry to rackNameList.
addReduce(Class<? extends Name<String>>, ReduceOperatorSpec) - Method in interface org.apache.reef.io.network.group.api.driver.CommunicationGroupDriver
Add the reduce operator specified by the.
addReduce(Class<? extends Name<String>>, ReduceOperatorSpec) - Method in class org.apache.reef.io.network.group.impl.driver.CommunicationGroupDriverImpl
 
addRestartEvaluator(EvaluatorRestartInfo) - Method in class org.apache.reef.driver.restart.RestartEvaluators.Builder
 
addRuntime(String) - Method in class org.apache.reef.runtime.multi.client.MultiRuntimeConfigurationBuilder
Adds runtime name to the builder.
addRuntime(Configuration, String) - Method in class org.apache.reef.runtime.multi.client.MultiRuntimeDefinitionBuilder
Adds runtime configuration module to the builder.
addScatter(Class<? extends Name<String>>, ScatterOperatorSpec) - Method in interface org.apache.reef.io.network.group.api.driver.CommunicationGroupDriver
Add the scatter operator specified by operatorName and spec.
addScatter(Class<? extends Name<String>>, ScatterOperatorSpec) - Method in class org.apache.reef.io.network.group.impl.driver.CommunicationGroupDriverImpl
 
addSecret(String, String) - Method in class org.apache.reef.runtime.hdinsight.client.yarnrest.Credentials
 
addServiceData(String, String) - Method in class org.apache.reef.runtime.hdinsight.client.yarnrest.AmContainerSpec
 
addTask(Configuration) - Method in interface org.apache.reef.io.network.group.api.driver.CommunicationGroupDriver
Add the task represented by this configuration to this communication group.
addTask(String) - Method in interface org.apache.reef.io.network.group.api.driver.Topology
Add task with id 'taskId' to.
addTask(Configuration) - Method in class org.apache.reef.io.network.group.impl.driver.CommunicationGroupDriverImpl
 
addTask(String) - Method in class org.apache.reef.io.network.group.impl.driver.FlatTopology
 
addTask(String) - Method in class org.apache.reef.io.network.group.impl.driver.TreeTopology
 
addTaskMessage(ReefServiceProtos.TaskStatusProto.TaskMessageProto) - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
repeated .TaskStatusProto.TaskMessageProto task_message = 6;
addTaskMessage(int, ReefServiceProtos.TaskStatusProto.TaskMessageProto) - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
repeated .TaskStatusProto.TaskMessageProto task_message = 6;
addTaskMessage(ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder) - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
repeated .TaskStatusProto.TaskMessageProto task_message = 6;
addTaskMessage(int, ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder) - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
repeated .TaskStatusProto.TaskMessageProto task_message = 6;
addTaskMessageBuilder() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
repeated .TaskStatusProto.TaskMessageProto task_message = 6;
addTaskMessageBuilder(int) - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
repeated .TaskStatusProto.TaskMessageProto task_message = 6;
addToken(String, String) - Method in class org.apache.reef.runtime.hdinsight.client.yarnrest.Credentials
 
addTokens(byte[]) - Method in interface org.apache.reef.runtime.yarn.client.SecurityTokenProvider
Add serialized tokens to the credentials.
addTokens(byte[]) - Method in class org.apache.reef.runtime.yarn.client.UserCredentialSecurityTokenProvider
Add serialized token to teh credentials.
addTopologyElement(Class<? extends Name<String>>) - Method in interface org.apache.reef.io.network.group.api.task.CommGroupNetworkHandler
 
addTopologyElement(Class<? extends Name<String>>) - Method in class org.apache.reef.io.network.group.impl.task.CommGroupNetworkHandlerImpl
 
AggregateResult<TInput,TOutput> - Class in org.apache.reef.vortex.api
The result of an aggregate.
AggregateResultSynchronous<TInput,TOutput> - Class in org.apache.reef.vortex.api
The synchronous result of an aggregate, returned by VortexAggregateFuture.get().
aggregationCompleted(List<Integer>, TOutput) - Method in class org.apache.reef.vortex.api.VortexAggregateFuture
Aggregation has completed for a list of Tasklets, with an aggregated result.
aggregationCompleted(List<Integer>, TOutput) - Method in class org.apache.reef.vortex.api.VortexFuture
VortexMaster should never call this.
aggregationCompleted(List<Integer>, TOutput) - Method in interface org.apache.reef.vortex.driver.VortexFutureDelegate
The list of aggregated Tasklets associated with the Future that have completed with a result.
aggregationThrewException(List<Integer>, Exception) - Method in class org.apache.reef.vortex.api.VortexAggregateFuture
A list of Tasklets has failed during aggregation phase.
aggregationThrewException(List<Integer>, Exception) - Method in class org.apache.reef.vortex.api.VortexFuture
VortexMaster should never call this.
aggregationThrewException(List<Integer>, Exception) - Method in interface org.apache.reef.vortex.driver.VortexFutureDelegate
The list of Tasklets associated with the Future that have thrown an Exception.
Alarm - Class in org.apache.reef.wake.time.event
An alarm is a timer event to be invoked at a given time.
Alarm(long, EventHandler<Alarm>) - Constructor for class org.apache.reef.wake.time.event.Alarm
 
ALIAS_LANGUAGE_FIELD_NUMBER - Static variable in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode
 
ALIAS_NAME_FIELD_NUMBER - Static variable in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode
 
AllCommunicationGroup - Class in org.apache.reef.examples.group.bgd.parameters
Communication group name.
AllCommunicationGroup() - Constructor for class org.apache.reef.examples.group.bgd.parameters.AllCommunicationGroup
 
AllCommunicationGroup - Class in org.apache.reef.examples.group.broadcast.parameters
Communication group name.
AllCommunicationGroup() - Constructor for class org.apache.reef.examples.group.broadcast.parameters.AllCommunicationGroup
 
allEvaluatorsAreClosed() - Method in class org.apache.reef.runtime.common.driver.evaluator.Evaluators
Return true if all evaluators are in closed state (and their processing queues are empty).
AllGather<T> - Interface in org.apache.reef.io.network.group.api.operators
MPI AllGather Operator.
AllGather_VALUE - Static variable in enum org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Type
AllGather = 5;
ALLOCATED_MB - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
ALLOCATED_VCORES - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
AllocatedEvaluator - Interface in org.apache.reef.driver.evaluator
Represents an Evaluator that is allocated, but is not running yet.
AllocatedEvaluatorBridge - Class in org.apache.reef.javabridge
The AllocatedEvaluatorBridge object to bridge operations between REEF .NET and Java allocated evaluator operations.
AllocatedEvaluatorBridgeFactory - Class in org.apache.reef.javabridge
The Factory object used to create AllocatedEvaluatorBridge objects.
AllocatedEvaluatorImpl - Class in org.apache.reef.runtime.common.driver.evaluator
Driver-Side representation of an allocated evaluator.
AllReduce<T> - Interface in org.apache.reef.io.network.group.api.operators
MPI All Reduce Operator.
AllReduce_VALUE - Static variable in enum org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Type
AllReduce = 6;
AM_CONTAINER_LOGS - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
AM_CONTAINER_SPEC - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
AM_HOST_HTTP_ADDRESS - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
AmContainerSpec - Class in org.apache.reef.runtime.hdinsight.client.yarnrest
Represents the specifications for an application master container.
AmContainerSpec() - Constructor for class org.apache.reef.runtime.hdinsight.client.yarnrest.AmContainerSpec
 
ANY_RACK - Static variable in class org.apache.reef.runtime.common.utils.Constants
Any modifier.
APP - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
APPLICATION_ACLS - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
APPLICATION_ID - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
APPLICATION_IDENTIFIER - Static variable in class org.apache.reef.runtime.common.evaluator.EvaluatorConfiguration
 
APPLICATION_NAME - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
APPLICATION_TAGS - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
APPLICATION_TYPE - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
ApplicationID - Class in org.apache.reef.runtime.hdinsight.client.yarnrest
Represents the response to an application ID request to the YARN Resource Manager via the YARN REST API.
ApplicationID() - Constructor for class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationID
 
ApplicationIdentifier - Class in org.apache.reef.runtime.common.evaluator.parameters
The RM application/job identifier.
ApplicationResponse - Class in org.apache.reef.runtime.hdinsight.client.yarnrest
A response object used in deserialization when querying the Resource Manager for an application via the YARN REST API.
ApplicationResponse() - Constructor for class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationResponse
 
ApplicationState - Class in org.apache.reef.runtime.hdinsight.client.yarnrest
An object representing the state of an application, used to deserialize queries for an application/list of applications to the Resource Manager on HDInsight via the YARN REST API.
ApplicationState() - Constructor for class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationState
 
ApplicationSubmission - Class in org.apache.reef.runtime.hdinsight.client.yarnrest
Represents an Application Submission object to the YARN REST API.
ApplicationSubmission() - Constructor for class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationSubmission
 
apply(Iterable<Pair<Vector, Integer>>) - Method in class org.apache.reef.examples.group.bgd.LineSearchReduceFunction
 
apply(Iterable<Pair<Pair<Double, Integer>, Vector>>) - Method in class org.apache.reef.examples.group.bgd.LossAndGradientReduceFunction
 
apply(Iterable<Boolean>) - Method in class org.apache.reef.examples.group.broadcast.ModelReceiveAckReduceFunction
 
apply(T) - Method in interface org.apache.reef.io.network.group.api.operators.AllGather
Apply the operation on element.
apply(T, List<? extends Identifier>) - Method in interface org.apache.reef.io.network.group.api.operators.AllGather
Apply the operation on element.
apply(T) - Method in interface org.apache.reef.io.network.group.api.operators.AllReduce
Apply the operation on element.
apply(T, List<? extends Identifier>) - Method in interface org.apache.reef.io.network.group.api.operators.AllReduce
Apply the operation on element.
apply(Iterable<T>) - Method in interface org.apache.reef.io.network.group.api.operators.Reduce.ReduceFunction
Apply the function on elements.
apply(List<T>, List<Integer>) - Method in interface org.apache.reef.io.network.group.api.operators.ReduceScatter
Apply this operation on elements where counts specify the distribution of elements to each task.
apply(List<T>, List<Integer>, List<? extends Identifier>) - Method in interface org.apache.reef.io.network.group.api.operators.ReduceScatter
Apply this operation on elements where counts specify the distribution of elements to each task.
APPS - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
areAssertionsEnabled() - Static method in class org.apache.reef.util.EnvironmentUtils
Check whether assert() statements are evaluated.
ARGS_FIELD_NUMBER - Static variable in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef
 
ARGS_FIELD_NUMBER - Static variable in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor
 
asError() - Method in class org.apache.reef.common.AbstractFailure
Return the original Java Exception, or generate a new one if it does not exists.
asError() - Method in interface org.apache.reef.common.Failure
Return the original Java Exception, or generate a new one if it does not exists.
asError - Variable in class org.apache.reef.io.watcher.common.AvroFailure
Deprecated.
Aspect - Interface in org.apache.reef.tang
A simple interface that allows external code to interpose on Tang object injections.
assertSingleton(Class) - Static method in class org.apache.reef.util.SingletonAsserter
Check if a given class is instantiated only once.
assertSingleton(String, Class) - Static method in class org.apache.reef.util.SingletonAsserter
Check if given class is singleton within a particular environment or scope.
assertStaticClean() - Method in class org.apache.reef.tang.formats.ConfigurationModule
 
availableSpace() - Method in class org.apache.reef.io.storage.local.LocalScratchSpace
 
availableSpace() - Method in interface org.apache.reef.io.storage.ScratchSpace
 
avg() - Method in class org.apache.reef.examples.group.utils.math.Window
 
avgIfAdded(double) - Method in class org.apache.reef.examples.group.utils.math.Window
 
AvroActiveContext - Class in org.apache.reef.io.watcher.driver.context
 
AvroActiveContext() - Constructor for class org.apache.reef.io.watcher.driver.context.AvroActiveContext
Default constructor.
AvroActiveContext(AvroContextBase) - Constructor for class org.apache.reef.io.watcher.driver.context.AvroActiveContext
All-args constructor.
AvroActiveContext.Builder - Class in org.apache.reef.io.watcher.driver.context
RecordBuilder for AvroActiveContext instances.
AvroAllocatedEvaluator - Class in org.apache.reef.io.watcher.driver.evaluator
 
AvroAllocatedEvaluator() - Constructor for class org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator
Default constructor.
AvroAllocatedEvaluator(CharSequence, AvroEvaluatorDescriptor) - Constructor for class org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator
All-args constructor.
AvroAllocatedEvaluator.Builder - Class in org.apache.reef.io.watcher.driver.evaluator
RecordBuilder for AvroAllocatedEvaluator instances.
AvroAppSubmissionParameters - Class in org.apache.reef.reef.bridge.client.avro
 
AvroAppSubmissionParameters() - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters
Default constructor.
AvroAppSubmissionParameters(Integer, Integer, Integer) - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters
All-args constructor.
AvroAppSubmissionParameters.Builder - Class in org.apache.reef.reef.bridge.client.avro
RecordBuilder for AvroAppSubmissionParameters instances.
AvroClassHierarchySerializer - Class in org.apache.reef.tang.implementation.avro
Serialize and Deserialize ClassHierarchy to and from AvroClassHierarchy.
AvroClassHierarchySerializer() - Constructor for class org.apache.reef.tang.implementation.avro.AvroClassHierarchySerializer
 
AvroClassNode - Class in org.apache.reef.tang.implementation.avro
 
AvroClassNode() - Constructor for class org.apache.reef.tang.implementation.avro.AvroClassNode
Default constructor.
AvroClassNode(Boolean, Boolean, Boolean, List<AvroConstructorDef>, List<AvroConstructorDef>, List<CharSequence>, CharSequence) - Constructor for class org.apache.reef.tang.implementation.avro.AvroClassNode
All-args constructor.
AvroClassNode.Builder - Class in org.apache.reef.tang.implementation.avro
RecordBuilder for AvroClassNode instances.
AvroClosedContext - Class in org.apache.reef.io.watcher.driver.context
 
AvroClosedContext() - Constructor for class org.apache.reef.io.watcher.driver.context.AvroClosedContext
Default constructor.
AvroClosedContext(AvroContextBase, AvroActiveContext) - Constructor for class org.apache.reef.io.watcher.driver.context.AvroClosedContext
All-args constructor.
AvroClosedContext.Builder - Class in org.apache.reef.io.watcher.driver.context
RecordBuilder for AvroClosedContext instances.
AvroCompletedEvaluator - Class in org.apache.reef.io.watcher.driver.evaluator
 
AvroCompletedEvaluator() - Constructor for class org.apache.reef.io.watcher.driver.evaluator.AvroCompletedEvaluator
Default constructor.
AvroCompletedEvaluator(CharSequence) - Constructor for class org.apache.reef.io.watcher.driver.evaluator.AvroCompletedEvaluator
All-args constructor.
AvroCompletedEvaluator.Builder - Class in org.apache.reef.io.watcher.driver.evaluator
RecordBuilder for AvroCompletedEvaluator instances.
AvroCompletedTask - Class in org.apache.reef.io.watcher.driver.task
 
AvroCompletedTask() - Constructor for class org.apache.reef.io.watcher.driver.task.AvroCompletedTask
Default constructor.
AvroCompletedTask(CharSequence, AvroActiveContext, ByteBuffer) - Constructor for class org.apache.reef.io.watcher.driver.task.AvroCompletedTask
All-args constructor.
AvroCompletedTask.Builder - Class in org.apache.reef.io.watcher.driver.task
RecordBuilder for AvroCompletedTask instances.
AvroConfiguration - Class in org.apache.reef.tang.formats.avro
 
AvroConfiguration() - Constructor for class org.apache.reef.tang.formats.avro.AvroConfiguration
Default constructor.
AvroConfiguration(CharSequence, List<ConfigurationEntry>) - Constructor for class org.apache.reef.tang.formats.avro.AvroConfiguration
All-args constructor.
AvroConfiguration.Builder - Class in org.apache.reef.tang.formats.avro
RecordBuilder for AvroConfiguration instances.
AvroConfigurationSerializer - Class in org.apache.reef.tang.formats
(De-)Serializing Configuration to and from AvroConfiguration.
AvroConfigurationSerializer() - Constructor for class org.apache.reef.tang.formats.AvroConfigurationSerializer
 
AvroConstructorArg - Class in org.apache.reef.tang.implementation.avro
 
AvroConstructorArg() - Constructor for class org.apache.reef.tang.implementation.avro.AvroConstructorArg
Default constructor.
AvroConstructorArg(CharSequence, CharSequence, Boolean) - Constructor for class org.apache.reef.tang.implementation.avro.AvroConstructorArg
All-args constructor.
AvroConstructorArg.Builder - Class in org.apache.reef.tang.implementation.avro
RecordBuilder for AvroConstructorArg instances.
AvroConstructorDef - Class in org.apache.reef.tang.implementation.avro
 
AvroConstructorDef() - Constructor for class org.apache.reef.tang.implementation.avro.AvroConstructorDef
Default constructor.
AvroConstructorDef(CharSequence, List<AvroConstructorArg>) - Constructor for class org.apache.reef.tang.implementation.avro.AvroConstructorDef
All-args constructor.
AvroConstructorDef.Builder - Class in org.apache.reef.tang.implementation.avro
RecordBuilder for AvroConstructorDef instances.
AvroContextBase - Class in org.apache.reef.io.watcher.driver.context
 
AvroContextBase() - Constructor for class org.apache.reef.io.watcher.driver.context.AvroContextBase
Default constructor.
AvroContextBase(CharSequence, CharSequence, CharSequence, AvroEvaluatorDescriptor) - Constructor for class org.apache.reef.io.watcher.driver.context.AvroContextBase
All-args constructor.
AvroContextBase.Builder - Class in org.apache.reef.io.watcher.driver.context
RecordBuilder for AvroContextBase instances.
AvroContextMessage - Class in org.apache.reef.io.watcher.driver.context
 
AvroContextMessage() - Constructor for class org.apache.reef.io.watcher.driver.context.AvroContextMessage
Default constructor.
AvroContextMessage(CharSequence, CharSequence, ByteBuffer) - Constructor for class org.apache.reef.io.watcher.driver.context.AvroContextMessage
All-args constructor.
AvroContextMessage.Builder - Class in org.apache.reef.io.watcher.driver.context
RecordBuilder for AvroContextMessage instances.
AvroDriverInfo - Class in org.apache.reef.webserver
 
AvroDriverInfo() - Constructor for class org.apache.reef.webserver.AvroDriverInfo
Default constructor.
AvroDriverInfo(CharSequence, CharSequence, List<AvroReefServiceInfo>) - Constructor for class org.apache.reef.webserver.AvroDriverInfo
All-args constructor.
AvroDriverInfo.Builder - Class in org.apache.reef.webserver
RecordBuilder for AvroDriverInfo instances.
AvroDriverInfoSerializer - Class in org.apache.reef.webserver
Serialize Drive information.
AvroEvaluatorDescriptor - Class in org.apache.reef.io.watcher.driver.evaluator
 
AvroEvaluatorDescriptor() - Constructor for class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor
Default constructor.
AvroEvaluatorDescriptor(AvroNodeDescriptor, AvroEvaluatorProcess, Integer, Integer) - Constructor for class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor
All-args constructor.
AvroEvaluatorDescriptor.Builder - Class in org.apache.reef.io.watcher.driver.evaluator
RecordBuilder for AvroEvaluatorDescriptor instances.
AvroEvaluatorEntry - Class in org.apache.reef.webserver
 
AvroEvaluatorEntry() - Constructor for class org.apache.reef.webserver.AvroEvaluatorEntry
Default constructor.
AvroEvaluatorEntry(CharSequence, CharSequence) - Constructor for class org.apache.reef.webserver.AvroEvaluatorEntry
All-args constructor.
AvroEvaluatorEntry.Builder - Class in org.apache.reef.webserver
RecordBuilder for AvroEvaluatorEntry instances.
AvroEvaluatorInfo - Class in org.apache.reef.webserver
 
AvroEvaluatorInfo() - Constructor for class org.apache.reef.webserver.AvroEvaluatorInfo
Default constructor.
AvroEvaluatorInfo(CharSequence, CharSequence, CharSequence, Integer, CharSequence, CharSequence, CharSequence) - Constructor for class org.apache.reef.webserver.AvroEvaluatorInfo
All-args constructor.
AvroEvaluatorInfo.Builder - Class in org.apache.reef.webserver
RecordBuilder for AvroEvaluatorInfo instances.
AvroEvaluatorInfoSerializer - Class in org.apache.reef.webserver
Serialize Evaluator Info.
AvroEvaluatorList - Class in org.apache.reef.webserver
 
AvroEvaluatorList() - Constructor for class org.apache.reef.webserver.AvroEvaluatorList
Default constructor.
AvroEvaluatorList(List<AvroEvaluatorEntry>, Integer, CharSequence) - Constructor for class org.apache.reef.webserver.AvroEvaluatorList
All-args constructor.
AvroEvaluatorList.Builder - Class in org.apache.reef.webserver
RecordBuilder for AvroEvaluatorList instances.
AvroEvaluatorListSerializer - Class in org.apache.reef.webserver
Serializer for Evaluator list.
AvroEvaluatorProcess - Class in org.apache.reef.io.watcher.driver.evaluator
 
AvroEvaluatorProcess() - Constructor for class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorProcess
Default constructor.
AvroEvaluatorProcess(List<CharSequence>, AvroEvaluatorType, Boolean) - Constructor for class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorProcess
All-args constructor.
AvroEvaluatorProcess.Builder - Class in org.apache.reef.io.watcher.driver.evaluator
RecordBuilder for AvroEvaluatorProcess instances.
AvroEvaluatorRequest - Class in org.apache.reef.io.data.loading.avro
 
AvroEvaluatorRequest() - Constructor for class org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest
Default constructor.
AvroEvaluatorRequest(Integer, Integer, Integer, List<CharSequence>, List<CharSequence>) - Constructor for class org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest
All-args constructor.
AvroEvaluatorRequest.Builder - Class in org.apache.reef.io.data.loading.avro
RecordBuilder for AvroEvaluatorRequest instances.
AvroEvaluatorRequestSerializer - Class in org.apache.reef.io.data.loading.impl
Serialize and deserialize EvaluatorRequest objects using Avro.
AvroEvaluatorsInfo - Class in org.apache.reef.webserver
 
AvroEvaluatorsInfo() - Constructor for class org.apache.reef.webserver.AvroEvaluatorsInfo
Default constructor.
AvroEvaluatorsInfo(List<AvroEvaluatorInfo>) - Constructor for class org.apache.reef.webserver.AvroEvaluatorsInfo
All-args constructor.
AvroEvaluatorsInfo.Builder - Class in org.apache.reef.webserver
RecordBuilder for AvroEvaluatorsInfo instances.
AvroEvaluatorType - Enum in org.apache.reef.io.watcher.driver.evaluator
 
AvroFailedContext - Class in org.apache.reef.io.watcher.driver.context
 
AvroFailedContext() - Constructor for class org.apache.reef.io.watcher.driver.context.AvroFailedContext
Default constructor.
AvroFailedContext(AvroContextBase, AvroActiveContext, AvroFailure) - Constructor for class org.apache.reef.io.watcher.driver.context.AvroFailedContext
All-args constructor.
AvroFailedContext.Builder - Class in org.apache.reef.io.watcher.driver.context
RecordBuilder for AvroFailedContext instances.
AvroFailedEvaluator - Class in org.apache.reef.io.watcher.driver.evaluator
 
AvroFailedEvaluator() - Constructor for class org.apache.reef.io.watcher.driver.evaluator.AvroFailedEvaluator
Default constructor.
AvroFailedEvaluator(CharSequence, CharSequence, List<AvroFailedContext>, AvroFailedTask) - Constructor for class org.apache.reef.io.watcher.driver.evaluator.AvroFailedEvaluator
All-args constructor.
AvroFailedEvaluator.Builder - Class in org.apache.reef.io.watcher.driver.evaluator
RecordBuilder for AvroFailedEvaluator instances.
AvroFailedTask - Class in org.apache.reef.io.watcher.driver.task
 
AvroFailedTask() - Constructor for class org.apache.reef.io.watcher.driver.task.AvroFailedTask
Default constructor.
AvroFailedTask(AvroFailure, AvroActiveContext) - Constructor for class org.apache.reef.io.watcher.driver.task.AvroFailedTask
All-args constructor.
AvroFailedTask - Class in org.apache.reef.javabridge.avro
 
AvroFailedTask() - Constructor for class org.apache.reef.javabridge.avro.AvroFailedTask
Default constructor.
AvroFailedTask(CharSequence, ByteBuffer, ByteBuffer, CharSequence) - Constructor for class org.apache.reef.javabridge.avro.AvroFailedTask
All-args constructor.
AvroFailedTask.Builder - Class in org.apache.reef.io.watcher.driver.task
RecordBuilder for AvroFailedTask instances.
AvroFailedTask.Builder - Class in org.apache.reef.javabridge.avro
RecordBuilder for AvroFailedTask instances.
AvroFailure - Class in org.apache.reef.io.watcher.common
 
AvroFailure() - Constructor for class org.apache.reef.io.watcher.common.AvroFailure
Default constructor.
AvroFailure(CharSequence, CharSequence, CharSequence, CharSequence, ByteBuffer, CharSequence) - Constructor for class org.apache.reef.io.watcher.common.AvroFailure
All-args constructor.
AvroFailure.Builder - Class in org.apache.reef.io.watcher.common
RecordBuilder for AvroFailure instances.
AvroHttpRequest - Class in org.apache.reef.webserver
 
AvroHttpRequest() - Constructor for class org.apache.reef.webserver.AvroHttpRequest
Default constructor.
AvroHttpRequest(List<HeaderEntry>, CharSequence, CharSequence, CharSequence, CharSequence, ByteBuffer) - Constructor for class org.apache.reef.webserver.AvroHttpRequest
All-args constructor.
AvroHttpRequest.Builder - Class in org.apache.reef.webserver
RecordBuilder for AvroHttpRequest instances.
AvroHttpSerializer - Class in org.apache.reef.webserver
Serialize Http Request Response data with Avro.
AvroHttpSerializer() - Constructor for class org.apache.reef.webserver.AvroHttpSerializer
 
AvroJobSubmissionParameters - Class in org.apache.reef.reef.bridge.client.avro
 
AvroJobSubmissionParameters() - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroJobSubmissionParameters
Default constructor.
AvroJobSubmissionParameters(CharSequence, CharSequence) - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroJobSubmissionParameters
All-args constructor.
AvroJobSubmissionParameters.Builder - Class in org.apache.reef.reef.bridge.client.avro
RecordBuilder for AvroJobSubmissionParameters instances.
AvroLocalAppSubmissionParameters - Class in org.apache.reef.reef.bridge.client.avro
 
AvroLocalAppSubmissionParameters() - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroLocalAppSubmissionParameters
Default constructor.
AvroLocalAppSubmissionParameters(AvroAppSubmissionParameters, Integer) - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroLocalAppSubmissionParameters
All-args constructor.
AvroLocalAppSubmissionParameters.Builder - Class in org.apache.reef.reef.bridge.client.avro
RecordBuilder for AvroLocalAppSubmissionParameters instances.
AvroLocalJobSubmissionParameters - Class in org.apache.reef.reef.bridge.client.avro
 
AvroLocalJobSubmissionParameters() - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroLocalJobSubmissionParameters
Default constructor.
AvroLocalJobSubmissionParameters(AvroJobSubmissionParameters, CharSequence, CharSequence) - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroLocalJobSubmissionParameters
All-args constructor.
AvroLocalJobSubmissionParameters.Builder - Class in org.apache.reef.reef.bridge.client.avro
RecordBuilder for AvroLocalJobSubmissionParameters instances.
AvroMultiRuntimeAppSubmissionParameters - Class in org.apache.reef.reef.bridge.client.avro
 
AvroMultiRuntimeAppSubmissionParameters() - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroMultiRuntimeAppSubmissionParameters
Default constructor.
AvroMultiRuntimeAppSubmissionParameters(AvroAppSubmissionParameters, AvroLocalAppSubmissionParameters, AvroYarnAppSubmissionParameters, CharSequence, List<CharSequence>) - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroMultiRuntimeAppSubmissionParameters
All-args constructor.
AvroMultiRuntimeAppSubmissionParameters.Builder - Class in org.apache.reef.reef.bridge.client.avro
RecordBuilder for AvroMultiRuntimeAppSubmissionParameters instances.
AvroMultiRuntimeDefinition - Class in org.apache.reef.runtime.multi.utils.avro
 
AvroMultiRuntimeDefinition() - Constructor for class org.apache.reef.runtime.multi.utils.avro.AvroMultiRuntimeDefinition
Default constructor.
AvroMultiRuntimeDefinition(CharSequence, List<AvroRuntimeDefinition>) - Constructor for class org.apache.reef.runtime.multi.utils.avro.AvroMultiRuntimeDefinition
All-args constructor.
AvroMultiRuntimeDefinition.Builder - Class in org.apache.reef.runtime.multi.utils.avro
RecordBuilder for AvroMultiRuntimeDefinition instances.
AvroNamedParameterNode - Class in org.apache.reef.tang.implementation.avro
 
AvroNamedParameterNode() - Constructor for class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode
Default constructor.
AvroNamedParameterNode(CharSequence, CharSequence, Boolean, Boolean, CharSequence, CharSequence, List<CharSequence>) - Constructor for class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode
All-args constructor.
AvroNamedParameterNode.Builder - Class in org.apache.reef.tang.implementation.avro
RecordBuilder for AvroNamedParameterNode instances.
AvroNamingAssignment - Class in org.apache.reef.io.network.naming.avro
 
AvroNamingAssignment() - Constructor for class org.apache.reef.io.network.naming.avro.AvroNamingAssignment
Default constructor.
AvroNamingAssignment(CharSequence, CharSequence, Integer) - Constructor for class org.apache.reef.io.network.naming.avro.AvroNamingAssignment
All-args constructor.
AvroNamingAssignment.Builder - Class in org.apache.reef.io.network.naming.avro
RecordBuilder for AvroNamingAssignment instances.
AvroNamingLookupRequest - Class in org.apache.reef.io.network.naming.avro
 
AvroNamingLookupRequest() - Constructor for class org.apache.reef.io.network.naming.avro.AvroNamingLookupRequest
Default constructor.
AvroNamingLookupRequest(List<CharSequence>) - Constructor for class org.apache.reef.io.network.naming.avro.AvroNamingLookupRequest
All-args constructor.
AvroNamingLookupRequest.Builder - Class in org.apache.reef.io.network.naming.avro
RecordBuilder for AvroNamingLookupRequest instances.
AvroNamingLookupResponse - Class in org.apache.reef.io.network.naming.avro
 
AvroNamingLookupResponse() - Constructor for class org.apache.reef.io.network.naming.avro.AvroNamingLookupResponse
Default constructor.
AvroNamingLookupResponse(List<AvroNamingAssignment>) - Constructor for class org.apache.reef.io.network.naming.avro.AvroNamingLookupResponse
All-args constructor.
AvroNamingLookupResponse.Builder - Class in org.apache.reef.io.network.naming.avro
RecordBuilder for AvroNamingLookupResponse instances.
AvroNamingRegisterRequest - Class in org.apache.reef.io.network.naming.avro
 
AvroNamingRegisterRequest() - Constructor for class org.apache.reef.io.network.naming.avro.AvroNamingRegisterRequest
Default constructor.
AvroNamingRegisterRequest(CharSequence, CharSequence, Integer) - Constructor for class org.apache.reef.io.network.naming.avro.AvroNamingRegisterRequest
All-args constructor.
AvroNamingRegisterRequest.Builder - Class in org.apache.reef.io.network.naming.avro
RecordBuilder for AvroNamingRegisterRequest instances.
AvroNamingUnRegisterRequest - Class in org.apache.reef.io.network.naming.avro
 
AvroNamingUnRegisterRequest() - Constructor for class org.apache.reef.io.network.naming.avro.AvroNamingUnRegisterRequest
Default constructor.
AvroNamingUnRegisterRequest(CharSequence) - Constructor for class org.apache.reef.io.network.naming.avro.AvroNamingUnRegisterRequest
All-args constructor.
AvroNamingUnRegisterRequest.Builder - Class in org.apache.reef.io.network.naming.avro
RecordBuilder for AvroNamingUnRegisterRequest instances.
AvroNode - Class in org.apache.reef.tang.implementation.avro
 
AvroNode() - Constructor for class org.apache.reef.tang.implementation.avro.AvroNode
Default constructor.
AvroNode(CharSequence, CharSequence, AvroClassNode, AvroNamedParameterNode, AvroPackageNode, List<AvroNode>) - Constructor for class org.apache.reef.tang.implementation.avro.AvroNode
All-args constructor.
AvroNode.Builder - Class in org.apache.reef.tang.implementation.avro
RecordBuilder for AvroNode instances.
AvroNodeDescriptor - Class in org.apache.reef.io.watcher.driver.catalog
 
AvroNodeDescriptor() - Constructor for class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptor
Default constructor.
AvroNodeDescriptor(CharSequence, CharSequence, CharSequence, AvroRackDescriptor) - Constructor for class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptor
All-args constructor.
AvroNodeDescriptor.Builder - Class in org.apache.reef.io.watcher.driver.catalog
RecordBuilder for AvroNodeDescriptor instances.
AvroNodeDescriptorInRackDescriptor - Class in org.apache.reef.io.watcher.driver.catalog
 
AvroNodeDescriptorInRackDescriptor() - Constructor for class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptorInRackDescriptor
Default constructor.
AvroNodeDescriptorInRackDescriptor(CharSequence, CharSequence, CharSequence) - Constructor for class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptorInRackDescriptor
All-args constructor.
AvroNodeDescriptorInRackDescriptor.Builder - Class in org.apache.reef.io.watcher.driver.catalog
RecordBuilder for AvroNodeDescriptorInRackDescriptor instances.
AvroPackageNode - Class in org.apache.reef.tang.implementation.avro
 
AvroPackageNode() - Constructor for class org.apache.reef.tang.implementation.avro.AvroPackageNode
 
AvroPackageNode.Builder - Class in org.apache.reef.tang.implementation.avro
RecordBuilder for AvroPackageNode instances.
AvroRackDescriptor - Class in org.apache.reef.io.watcher.driver.catalog
 
AvroRackDescriptor() - Constructor for class org.apache.reef.io.watcher.driver.catalog.AvroRackDescriptor
Default constructor.
AvroRackDescriptor(CharSequence, List<AvroNodeDescriptorInRackDescriptor>) - Constructor for class org.apache.reef.io.watcher.driver.catalog.AvroRackDescriptor
All-args constructor.
AvroRackDescriptor.Builder - Class in org.apache.reef.io.watcher.driver.catalog
RecordBuilder for AvroRackDescriptor instances.
AvroReefServiceInfo - Class in org.apache.reef.webserver
 
AvroReefServiceInfo() - Constructor for class org.apache.reef.webserver.AvroReefServiceInfo
Default constructor.
AvroReefServiceInfo(CharSequence, CharSequence) - Constructor for class org.apache.reef.webserver.AvroReefServiceInfo
All-args constructor.
AvroReefServiceInfo.Builder - Class in org.apache.reef.webserver
RecordBuilder for AvroReefServiceInfo instances.
AvroRunningTask - Class in org.apache.reef.io.watcher.driver.task
 
AvroRunningTask() - Constructor for class org.apache.reef.io.watcher.driver.task.AvroRunningTask
Default constructor.
AvroRunningTask(CharSequence, AvroActiveContext) - Constructor for class org.apache.reef.io.watcher.driver.task.AvroRunningTask
All-args constructor.
AvroRunningTask.Builder - Class in org.apache.reef.io.watcher.driver.task
RecordBuilder for AvroRunningTask instances.
AvroRuntimeDefinition - Class in org.apache.reef.runtime.multi.utils.avro
 
AvroRuntimeDefinition() - Constructor for class org.apache.reef.runtime.multi.utils.avro.AvroRuntimeDefinition
Default constructor.
AvroRuntimeDefinition(CharSequence, CharSequence) - Constructor for class org.apache.reef.runtime.multi.utils.avro.AvroRuntimeDefinition
All-args constructor.
AvroRuntimeDefinition.Builder - Class in org.apache.reef.runtime.multi.utils.avro
RecordBuilder for AvroRuntimeDefinition instances.
AvroRuntimeStart - Class in org.apache.reef.io.watcher.wake.time.runtime.event
 
AvroRuntimeStart() - Constructor for class org.apache.reef.io.watcher.wake.time.runtime.event.AvroRuntimeStart
Default constructor.
AvroRuntimeStart(Long) - Constructor for class org.apache.reef.io.watcher.wake.time.runtime.event.AvroRuntimeStart
All-args constructor.
AvroRuntimeStart.Builder - Class in org.apache.reef.io.watcher.wake.time.runtime.event
RecordBuilder for AvroRuntimeStart instances.
AvroRuntimeStop - Class in org.apache.reef.io.watcher.wake.time.runtime.event
 
AvroRuntimeStop() - Constructor for class org.apache.reef.io.watcher.wake.time.runtime.event.AvroRuntimeStop
Default constructor.
AvroRuntimeStop(Long, CharSequence) - Constructor for class org.apache.reef.io.watcher.wake.time.runtime.event.AvroRuntimeStop
All-args constructor.
AvroRuntimeStop.Builder - Class in org.apache.reef.io.watcher.wake.time.runtime.event
RecordBuilder for AvroRuntimeStop instances.
AvroStartTime - Class in org.apache.reef.io.watcher.wake.time.event
 
AvroStartTime() - Constructor for class org.apache.reef.io.watcher.wake.time.event.AvroStartTime
Default constructor.
AvroStartTime(Long) - Constructor for class org.apache.reef.io.watcher.wake.time.event.AvroStartTime
All-args constructor.
AvroStartTime.Builder - Class in org.apache.reef.io.watcher.wake.time.event
RecordBuilder for AvroStartTime instances.
AvroStopTime - Class in org.apache.reef.io.watcher.wake.time.event
 
AvroStopTime() - Constructor for class org.apache.reef.io.watcher.wake.time.event.AvroStopTime
Default constructor.
AvroStopTime(Long) - Constructor for class org.apache.reef.io.watcher.wake.time.event.AvroStopTime
All-args constructor.
AvroStopTime.Builder - Class in org.apache.reef.io.watcher.wake.time.event
RecordBuilder for AvroStopTime instances.
AvroSuspendedTask - Class in org.apache.reef.io.watcher.driver.task
 
AvroSuspendedTask() - Constructor for class org.apache.reef.io.watcher.driver.task.AvroSuspendedTask
Default constructor.
AvroSuspendedTask(CharSequence, AvroActiveContext, ByteBuffer) - Constructor for class org.apache.reef.io.watcher.driver.task.AvroSuspendedTask
All-args constructor.
AvroSuspendedTask.Builder - Class in org.apache.reef.io.watcher.driver.task
RecordBuilder for AvroSuspendedTask instances.
AvroTaskMessage - Class in org.apache.reef.io.watcher.driver.task
 
AvroTaskMessage() - Constructor for class org.apache.reef.io.watcher.driver.task.AvroTaskMessage
Default constructor.
AvroTaskMessage(CharSequence, CharSequence, CharSequence, ByteBuffer) - Constructor for class org.apache.reef.io.watcher.driver.task.AvroTaskMessage
All-args constructor.
AvroTaskMessage.Builder - Class in org.apache.reef.io.watcher.driver.task
RecordBuilder for AvroTaskMessage instances.
AvroYarnAppSubmissionParameters - Class in org.apache.reef.reef.bridge.client.avro
 
AvroYarnAppSubmissionParameters() - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroYarnAppSubmissionParameters
Default constructor.
AvroYarnAppSubmissionParameters(AvroAppSubmissionParameters, Integer) - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroYarnAppSubmissionParameters
All-args constructor.
AvroYarnAppSubmissionParameters.Builder - Class in org.apache.reef.reef.bridge.client.avro
RecordBuilder for AvroYarnAppSubmissionParameters instances.
AvroYarnClusterJobSubmissionParameters - Class in org.apache.reef.reef.bridge.client.avro
 
AvroYarnClusterJobSubmissionParameters() - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters
Default constructor.
AvroYarnClusterJobSubmissionParameters(AvroYarnJobSubmissionParameters, CharSequence, CharSequence, Integer, Integer, CharSequence, CharSequence) - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters
All-args constructor.
AvroYarnClusterJobSubmissionParameters.Builder - Class in org.apache.reef.reef.bridge.client.avro
RecordBuilder for AvroYarnClusterJobSubmissionParameters instances.
AvroYarnJobSubmissionParameters - Class in org.apache.reef.reef.bridge.client.avro
 
AvroYarnJobSubmissionParameters() - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters
Default constructor.
AvroYarnJobSubmissionParameters(AvroJobSubmissionParameters, CharSequence, CharSequence, CharSequence) - Constructor for class org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters
All-args constructor.
AvroYarnJobSubmissionParameters.Builder - Class in org.apache.reef.reef.bridge.client.avro
RecordBuilder for AvroYarnJobSubmissionParameters instances.
await() - Method in class org.apache.reef.io.network.group.impl.utils.CountingSemaphore
 
await() - Method in class org.apache.reef.io.network.group.impl.utils.ResettingCountDownLatch
 
awaitAndReset(int) - Method in class org.apache.reef.io.network.group.impl.utils.ResettingCountDownLatch
 
AzureStorageAccountContainerName - Class in org.apache.reef.runtime.hdinsight.parameters
The Storage account container name to be used by Azure.
AzureStorageAccountContainerName() - Constructor for class org.apache.reef.runtime.hdinsight.parameters.AzureStorageAccountContainerName
 
AzureStorageAccountKey - Class in org.apache.reef.runtime.hdinsight.parameters
The Storage account key to be used by Azure.
AzureStorageAccountKey() - Constructor for class org.apache.reef.runtime.hdinsight.parameters.AzureStorageAccountKey
 
AzureStorageAccountName - Class in org.apache.reef.runtime.hdinsight.parameters
The Storage account to be used by Azure.
AzureStorageAccountName() - Constructor for class org.apache.reef.runtime.hdinsight.parameters.AzureStorageAccountName
 
AzureStorageBaseFolder - Class in org.apache.reef.runtime.hdinsight.parameters
The folder to use as the base folder for storing the JARs.
AzureStorageBaseFolder() - Constructor for class org.apache.reef.runtime.hdinsight.parameters.AzureStorageBaseFolder
 

B

B - Class in org.apache.reef.tang.examples
 
B() - Constructor for class org.apache.reef.tang.examples.B
 
base - Variable in class org.apache.reef.io.watcher.driver.context.AvroActiveContext
Deprecated.
base - Variable in class org.apache.reef.io.watcher.driver.context.AvroClosedContext
Deprecated.
base - Variable in class org.apache.reef.io.watcher.driver.context.AvroFailedContext
Deprecated.
BGDClient - Class in org.apache.reef.examples.group.bgd
A client to submit BGD Jobs.
BGDClient(String, int, int, int, BGDControlParameters) - Constructor for class org.apache.reef.examples.group.bgd.BGDClient
 
BGDControlParameters - Class in org.apache.reef.examples.group.bgd.parameters
Control parameters for BGD example.
BGDControlParameters(int, double, double, double, double, int, boolean, int, BGDLossType) - Constructor for class org.apache.reef.examples.group.bgd.parameters.BGDControlParameters
 
BGDDriver - Class in org.apache.reef.examples.group.bgd
Driver for BGD example.
BGDDriver(DataLoadingService, GroupCommDriver, ConfigurationSerializer, BGDControlParameters) - Constructor for class org.apache.reef.examples.group.bgd.BGDDriver
 
BGDLocal - Class in org.apache.reef.examples.group.bgd
Runs BGD on the local runtime.
BGDLossType - Class in org.apache.reef.examples.group.bgd.parameters
Type of loss function used in example.
BGDLossType(String) - Constructor for class org.apache.reef.examples.group.bgd.parameters.BGDLossType
 
BGDYarn - Class in org.apache.reef.examples.group.bgd
Runs BGD on the YARN runtime.
bind(String, String) - Method in interface org.apache.reef.tang.ConfigurationBuilder
Bind classes to each other, based on their full class names; alternatively, bound a NamedParameter configuration option to a configuration value.
bind(Node, Node) - Method in interface org.apache.reef.tang.ConfigurationBuilder
Bind classes to each other, based on their full class names; alternatively, bound a NamedParameter configuration option to a configuration value.
bind(Class<?>, Impl<?>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bind(String, String) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bind(Node, Node) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bind(Class<T>, Class<?>) - Method in class org.apache.reef.tang.implementation.java.JavaConfigurationBuilderImpl
 
bind(Class<T>, Class<?>) - Method in interface org.apache.reef.tang.JavaConfigurationBuilder
Bind named parameters, implementations or external constructors, depending on the types of the classes passed in.
bindAspect(Aspect) - Method in class org.apache.reef.tang.implementation.java.InjectorImpl
 
bindAspect(Aspect) - Method in interface org.apache.reef.tang.Injector
Binds a TANG Aspect to this injector.
bindConstructor(ClassNode<T>, ClassNode<? extends ExternalConstructor<? extends T>>) - Method in interface org.apache.reef.tang.ConfigurationBuilder
Register an ExternalConstructor implementation with Tang.
bindConstructor(Class<T>, Class<? extends ExternalConstructor<? extends T>>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindConstructor(Class<T>, Impl<? extends ExternalConstructor<? extends T>>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindConstructor(ClassNode<T>, ClassNode<? extends ExternalConstructor<? extends T>>) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bindConstructor(Class<T>, Class<? extends ExternalConstructor<? extends T>>) - Method in class org.apache.reef.tang.implementation.java.JavaConfigurationBuilderImpl
 
bindConstructor(Class<T>, Class<? extends ExternalConstructor<? extends T>>) - Method in interface org.apache.reef.tang.JavaConfigurationBuilder
 
BindException - Exception in org.apache.reef.tang.exceptions
Thrown when an illegal or contradictory configuration option is encountered.
BindException(String, Throwable) - Constructor for exception org.apache.reef.tang.exceptions.BindException
 
BindException(String) - Constructor for exception org.apache.reef.tang.exceptions.BindException
 
bindImplementation(Class<T>, Class<? extends T>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindImplementation(Class<T>, String) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindImplementation(Class<T>, Impl<? extends T>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindImplementation(ClassNode<T>, ClassNode<? extends T>) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bindImplementation(Class<T>, Class<? extends T>) - Method in class org.apache.reef.tang.implementation.java.JavaConfigurationBuilderImpl
 
bindImplementation(Class<T>, Class<? extends T>) - Method in interface org.apache.reef.tang.JavaConfigurationBuilder
Binds the Class impl as the implementation of the interface iface.
Bindings - Variable in class org.apache.reef.tang.formats.avro.AvroConfiguration
Deprecated.
bindList(NamedParameterNode<List<T>>, List) - Method in interface org.apache.reef.tang.ConfigurationBuilder
Bind an list of implementations(Class or String) to an given NamedParameter.
bindList(String, List) - Method in interface org.apache.reef.tang.ConfigurationBuilder
 
bindList(Class<? extends Name<List<T>>>, Impl<List>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindList(Class<? extends Name<List<T>>>, Param<List>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindList(Class<? extends Name<List<T>>>, List) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindList(NamedParameterNode<List<T>>, List) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bindList(String, List) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bindList(Class<? extends Name<List<T>>>, List) - Method in class org.apache.reef.tang.implementation.java.JavaConfigurationBuilderImpl
Binding list method for JavaConfigurationBuilder.
bindList(Class<? extends Name<List<T>>>, List) - Method in interface org.apache.reef.tang.JavaConfigurationBuilder
Binds a specific list to a named parameter.
BindLocation - Interface in org.apache.reef.tang
This interface is used to track the source of configuration bindings.
bindNamedParameter(Class<? extends Name<T>>, String) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindNamedParameter(Class<? extends Name<T>>, Param<T>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindNamedParameter(Class<? extends Name<T>>, Class<? extends T>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindNamedParameter(Class<? extends Name<T>>, Impl<? extends T>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindNamedParameter(Class<? extends Name<?>>, String) - Method in class org.apache.reef.tang.implementation.java.JavaConfigurationBuilderImpl
 
bindNamedParameter(Class<? extends Name<T>>, Class<? extends T>) - Method in class org.apache.reef.tang.implementation.java.JavaConfigurationBuilderImpl
 
bindNamedParameter(Class<? extends Name<?>>, String) - Method in interface org.apache.reef.tang.JavaConfigurationBuilder
Set the value of a named parameter.
bindNamedParameter(Class<? extends Name<T>>, Class<? extends T>) - Method in interface org.apache.reef.tang.JavaConfigurationBuilder
 
BindNSToTask - Class in org.apache.reef.io.network.impl
 
BindNSToTask(NetworkService<?>, IdentifierFactory) - Constructor for class org.apache.reef.io.network.impl.BindNSToTask
 
bindParameter(NamedParameterNode<T>, String) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bindSetEntry(NamedParameterNode<Set<T>>, Node) - Method in interface org.apache.reef.tang.ConfigurationBuilder
 
bindSetEntry(NamedParameterNode<Set<T>>, String) - Method in interface org.apache.reef.tang.ConfigurationBuilder
 
bindSetEntry(String, String) - Method in interface org.apache.reef.tang.ConfigurationBuilder
 
bindSetEntry(String, Node) - Method in interface org.apache.reef.tang.ConfigurationBuilder
 
bindSetEntry(Class<? extends Name<Set<T>>>, String) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindSetEntry(Class<? extends Name<Set<T>>>, Class<? extends T>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindSetEntry(Class<? extends Name<Set<T>>>, Impl<? extends T>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindSetEntry(Class<? extends Name<Set<T>>>, Param<? extends T>) - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
bindSetEntry(String, String) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bindSetEntry(String, Node) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bindSetEntry(NamedParameterNode<Set<T>>, String) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bindSetEntry(NamedParameterNode<Set<T>>, Node) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
bindSetEntry(Class<? extends Name<Set<T>>>, String) - Method in class org.apache.reef.tang.implementation.java.JavaConfigurationBuilderImpl
 
bindSetEntry(Class<? extends Name<Set<T>>>, Class<? extends T>) - Method in class org.apache.reef.tang.implementation.java.JavaConfigurationBuilderImpl
 
bindSetEntry(Class<? extends Name<Set<T>>>, String) - Method in interface org.apache.reef.tang.JavaConfigurationBuilder
 
bindSetEntry(Class<? extends Name<Set<T>>>, Class<? extends T>) - Method in interface org.apache.reef.tang.JavaConfigurationBuilder
 
bindVolatileInstance(Class<T>, T) - Method in class org.apache.reef.tang.implementation.java.InjectorImpl
 
bindVolatileInstance(Class<T>, T) - Method in interface org.apache.reef.tang.Injector
Binds the given object to the class.
bindVolatileParameter(Class<? extends Name<T>>, T) - Method in class org.apache.reef.tang.implementation.java.InjectorImpl
 
bindVolatileParameter(Class<? extends Name<T>>, T) - Method in interface org.apache.reef.tang.Injector
 
bldGCM(ReefNetworkGroupCommProtos.GroupCommMessage.Type, Identifier, Identifier, byte[]...) - Static method in class org.apache.reef.io.network.util.Utils
 
bldVersionedGCM(Class<? extends Name<String>>, Class<? extends Name<String>>, ReefNetworkGroupCommProtos.GroupCommMessage.Type, String, int, String, int, byte[]...) - Static method in class org.apache.reef.io.network.group.impl.utils.Utils
 
BlockingEventHandler<T> - Class in org.apache.reef.examples.utils.wake
An EventHandler that blocks until a set number of Events has been received.
BlockingEventHandler(int, EventHandler<Iterable<T>>) - Constructor for class org.apache.reef.examples.utils.wake.BlockingEventHandler
 
BlockingEventHandler<T> - Class in org.apache.reef.wake.impl
An EventHandler that blocks until a set number of Events has been received.
BlockingEventHandler(int, EventHandler<Iterable<T>>) - Constructor for class org.apache.reef.wake.impl.BlockingEventHandler
 
BlockingJoin - Class in org.apache.reef.wake.examples.join
Blocking join.
BlockingJoin(Observer<TupleEvent>) - Constructor for class org.apache.reef.wake.examples.join.BlockingJoin
 
BlockingSignalEventHandler<T> - Class in org.apache.reef.wake.impl
An EventHandler that blocks until a set number of Events has been received.
BlockingSignalEventHandler(int, EventHandler<T>) - Constructor for class org.apache.reef.wake.impl.BlockingSignalEventHandler
 
boxClass(Class<?>) - Static method in class org.apache.reef.tang.util.ReflectionUtilities
Given a primitive type, return its boxed representation.
BRIDGE_SETUP - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
BridgeHandlerManager - Class in org.apache.reef.javabridge
A class that holds all handles to the .NET side.
BridgeHandlerManager() - Constructor for class org.apache.reef.javabridge.BridgeHandlerManager
 
BridgeInterop - Class in org.apache.reef.bridge.message
 
BridgeInterop() - Constructor for class org.apache.reef.bridge.message.BridgeInterop
Default constructor.
BridgeInterop(Long, MessageType, Object) - Constructor for class org.apache.reef.bridge.message.BridgeInterop
All-args constructor.
BridgeInterop.Builder - Class in org.apache.reef.bridge.message
RecordBuilder for BridgeInterop instances.
Broadcast - Interface in org.apache.reef.io.network.group.api.operators
MPI Broadcast operator.
Broadcast.Receiver<T> - Interface in org.apache.reef.io.network.group.api.operators
Receivers or Non-roots.
Broadcast.Sender<T> - Interface in org.apache.reef.io.network.group.api.operators
Sender or Root.
Broadcast_VALUE - Static variable in enum org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Type
Broadcast = 3;
BroadcastDriver - Class in org.apache.reef.examples.group.broadcast
Driver for broadcast example.
BroadcastDriver(EvaluatorRequestor, GroupCommDriver, ConfigurationSerializer, int, int) - Constructor for class org.apache.reef.examples.group.broadcast.BroadcastDriver
 
BroadcastDriver.ContextActiveHandler - Class in org.apache.reef.examples.group.broadcast
ActiveContext handler.
BroadcastDriver.ContextActiveHandler() - Constructor for class org.apache.reef.examples.group.broadcast.BroadcastDriver.ContextActiveHandler
 
BroadcastDriver.ContextCloseHandler - Class in org.apache.reef.examples.group.broadcast
ClosedContext handler.
BroadcastDriver.ContextCloseHandler() - Constructor for class org.apache.reef.examples.group.broadcast.BroadcastDriver.ContextCloseHandler
 
BroadcastDriver.FailedTaskHandler - Class in org.apache.reef.examples.group.broadcast
FailedTask handler.
BroadcastDriver.FailedTaskHandler() - Constructor for class org.apache.reef.examples.group.broadcast.BroadcastDriver.FailedTaskHandler
 
BroadCastEventHandler<E> - Class in org.apache.reef.runtime.common.utils
Handler for BroadCastEvent which sends event to all handlers in the list.
BroadCastEventHandler(Collection<EventHandler<E>>) - Constructor for class org.apache.reef.runtime.common.utils.BroadCastEventHandler
 
BroadcastingEventHandler<T> - Class in org.apache.reef.io.network.group.impl.utils
 
BroadcastingEventHandler() - Constructor for class org.apache.reef.io.network.group.impl.utils.BroadcastingEventHandler
 
BroadcastOperatorSpec - Class in org.apache.reef.io.network.group.impl.config
The specification for the broadcast operator.
BroadcastOperatorSpec(String, Class<? extends Codec>) - Constructor for class org.apache.reef.io.network.group.impl.config.BroadcastOperatorSpec
 
BroadcastOperatorSpec.Builder - Class in org.apache.reef.io.network.group.impl.config
 
BroadcastOperatorSpec.Builder() - Constructor for class org.apache.reef.io.network.group.impl.config.BroadcastOperatorSpec.Builder
 
BroadcastReceiver<T> - Class in org.apache.reef.io.network.group.impl.operators
 
BroadcastReceiver(String, String, String, Codec<T>, String, int, CommGroupNetworkHandler, NetworkService<GroupCommunicationMessage>, CommunicationGroupServiceClient) - Constructor for class org.apache.reef.io.network.group.impl.operators.BroadcastReceiver
 
BroadcastREEF - Class in org.apache.reef.examples.group.broadcast
Client for broadcast example.
BroadcastREEF.InputDir - Class in org.apache.reef.examples.group.broadcast
Input path.
BroadcastREEF.InputDir() - Constructor for class org.apache.reef.examples.group.broadcast.BroadcastREEF.InputDir
 
BroadcastREEF.Local - Class in org.apache.reef.examples.group.broadcast
Command line parameter = true to run locally, or false to run on YARN.
BroadcastREEF.Local() - Constructor for class org.apache.reef.examples.group.broadcast.BroadcastREEF.Local
 
BroadcastSender<T> - Class in org.apache.reef.io.network.group.impl.operators
 
BroadcastSender(String, String, String, Codec<T>, String, int, CommGroupNetworkHandler, NetworkService<GroupCommunicationMessage>, CommunicationGroupServiceClient) - Constructor for class org.apache.reef.io.network.group.impl.operators.BroadcastSender
 
build() - Method in class org.apache.reef.bridge.message.Acknowledgement.Builder
 
build() - Method in class org.apache.reef.bridge.message.BridgeInterop.Builder
 
build() - Method in class org.apache.reef.bridge.message.Header.Builder
 
build() - Method in class org.apache.reef.bridge.message.Protocol.Builder
 
build() - Method in class org.apache.reef.bridge.message.SetupBridge.Builder
 
build() - Method in class org.apache.reef.bridge.message.SystemOnStart.Builder
 
build() - Method in class org.apache.reef.driver.evaluator.EvaluatorRequest.Builder
Builds the EvaluatorRequest.
build() - Method in class org.apache.reef.driver.restart.RestartEvaluators.Builder
 
build() - Method in class org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder
 
build() - Method in class org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder
 
build() - Method in class org.apache.reef.io.data.loading.impl.DistributedDataSetPartition.Builder
build() - Method in class org.apache.reef.io.network.group.impl.config.BroadcastOperatorSpec.Builder
 
build() - Method in class org.apache.reef.io.network.group.impl.config.GatherOperatorSpec.Builder
 
build() - Method in class org.apache.reef.io.network.group.impl.config.ReduceOperatorSpec.Builder
 
build() - Method in class org.apache.reef.io.network.group.impl.config.ScatterOperatorSpec.Builder
 
build() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingAssignment.Builder
 
build() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingLookupRequest.Builder
 
build() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingLookupResponse.Builder
 
build() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingRegisterRequest.Builder
 
build() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingUnRegisterRequest.Builder
 
build() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
 
build() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupMessageBody.Builder
 
build() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
 
build() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder
 
build() - Method in class org.apache.reef.io.watcher.common.AvroFailure.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptor.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptorInRackDescriptor.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroRackDescriptor.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.context.AvroActiveContext.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.context.AvroContextBase.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.context.AvroContextMessage.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.context.AvroFailedContext.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroCompletedEvaluator.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorProcess.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroFailedEvaluator.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.task.AvroCompletedTask.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.task.AvroFailedTask.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.task.AvroSuspendedTask.Builder
 
build() - Method in class org.apache.reef.io.watcher.driver.task.AvroTaskMessage.Builder
 
build() - Method in class org.apache.reef.io.watcher.wake.time.event.AvroStartTime.Builder
 
build() - Method in class org.apache.reef.io.watcher.wake.time.event.AvroStopTime.Builder
 
build() - Method in class org.apache.reef.io.watcher.wake.time.runtime.event.AvroRuntimeStart.Builder
 
build() - Method in class org.apache.reef.io.watcher.wake.time.runtime.event.AvroRuntimeStop.Builder
 
build() - Method in class org.apache.reef.javabridge.avro.AvroFailedTask.Builder
 
build() - Method in class org.apache.reef.javabridge.avro.DefinedRuntimes.Builder
 
build() - Method in class org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.DoneEvaluatorProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProto.Builder
 
build() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProto.Builder
 
build() - Method in class org.apache.reef.proto.REEFProtocol.REEFMessage.Builder
 
build() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
 
build() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder
 
build() - Method in class org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.Builder
 
build() - Method in class org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder
 
build() - Method in class org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder
 
build() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
 
build() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder
 
build() - Method in class org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder
 
build() - Method in class org.apache.reef.reef.bridge.client.avro.AvroJobSubmissionParameters.Builder
 
build() - Method in class org.apache.reef.reef.bridge.client.avro.AvroLocalAppSubmissionParameters.Builder
 
build() - Method in class org.apache.reef.reef.bridge.client.avro.AvroLocalJobSubmissionParameters.Builder
 
build() - Method in class org.apache.reef.reef.bridge.client.avro.AvroMultiRuntimeAppSubmissionParameters.Builder
 
build() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnAppSubmissionParameters.Builder
 
build() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder
 
build() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.Builder
 
build() - Method in class org.apache.reef.runtime.common.client.api.JobSubmissionEventImpl.Builder
 
build() - Method in class org.apache.reef.runtime.common.driver.api.ResourceLaunchEventImpl.Builder
 
build() - Method in class org.apache.reef.runtime.common.driver.api.ResourceReleaseEventImpl.Builder
 
build() - Method in class org.apache.reef.runtime.common.driver.api.ResourceRequestEventImpl.Builder
 
build() - Method in class org.apache.reef.runtime.common.driver.resourcemanager.NodeDescriptorEventImpl.Builder
 
build() - Method in class org.apache.reef.runtime.common.driver.resourcemanager.ResourceEventImpl.Builder
 
build() - Method in class org.apache.reef.runtime.common.driver.resourcemanager.ResourceStatusEventImpl.Builder
 
build() - Method in class org.apache.reef.runtime.common.driver.resourcemanager.RuntimeStatusEventImpl.Builder
 
build() - Method in class org.apache.reef.runtime.common.files.FileResourceImpl.Builder
 
build() - Method in class org.apache.reef.runtime.common.launch.CLRLaunchCommandBuilder
 
build() - Method in class org.apache.reef.runtime.common.launch.JavaLaunchCommandBuilder
 
build() - Method in interface org.apache.reef.runtime.common.launch.LaunchCommandBuilder
 
build() - Method in class org.apache.reef.runtime.mesos.util.EvaluatorControl.Builder
 
build() - Method in class org.apache.reef.runtime.mesos.util.EvaluatorLaunch.Builder
 
build() - Method in class org.apache.reef.runtime.mesos.util.EvaluatorRelease.Builder
 
build() - Method in class org.apache.reef.runtime.multi.client.MultiRuntimeConfigurationBuilder
Builds the configuration.
build() - Method in class org.apache.reef.runtime.multi.client.MultiRuntimeDefinitionBuilder
Builds multi runtime definition.
build() - Method in class org.apache.reef.runtime.multi.utils.avro.AvroMultiRuntimeDefinition.Builder
 
build() - Method in class org.apache.reef.runtime.multi.utils.avro.AvroRuntimeDefinition.Builder
 
build() - Method in interface org.apache.reef.tang.ConfigurationBuilder
Produce an immutable Configuration object that contains the current bindings and ClassHierarchy of this ConfigurationBuilder.
build() - Method in class org.apache.reef.tang.formats.avro.AvroConfiguration.Builder
 
build() - Method in class org.apache.reef.tang.formats.avro.ConfigurationEntry.Builder
 
build() - Method in class org.apache.reef.tang.formats.ConfigurationModule
 
build() - Method in class org.apache.reef.tang.formats.ConfigurationModuleBuilder
 
build() - Method in class org.apache.reef.tang.implementation.avro.AvroClassNode.Builder
 
build() - Method in class org.apache.reef.tang.implementation.avro.AvroConstructorArg.Builder
 
build() - Method in class org.apache.reef.tang.implementation.avro.AvroConstructorDef.Builder
 
build() - Method in class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode.Builder
 
build() - Method in class org.apache.reef.tang.implementation.avro.AvroNode.Builder
 
build() - Method in class org.apache.reef.tang.implementation.avro.AvroPackageNode.Builder
 
build() - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
build() - Method in class org.apache.reef.tang.implementation.java.JavaConfigurationBuilderImpl
 
build() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
 
build() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArg.Builder
 
build() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
 
build() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
 
build() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
 
build() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.PackageNode.Builder
 
build() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
 
build() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan.Builder
 
build() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Instance.Builder
 
build() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
 
build() - Method in interface org.apache.reef.util.Builder
Builds a fresh instance of the object.
build() - Method in class org.apache.reef.vortex.api.VortexAggregatePolicy.AggregatePolicyBuilder
Builds and returns a new VortexAggregatePolicy based on user's specification.
build() - Method in class org.apache.reef.vortex.driver.VortexJobConf.Builder
Instantiate a VortexJobConf object, where a Configuration is built by Tang internally.
build() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.Builder
 
build() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.Builder
 
build() - Method in class org.apache.reef.wake.test.proto.TestProtos.TestEventPBuf.Builder
 
build() - Method in class org.apache.reef.webserver.AvroDriverInfo.Builder
 
build() - Method in class org.apache.reef.webserver.AvroEvaluatorEntry.Builder
 
build() - Method in class org.apache.reef.webserver.AvroEvaluatorInfo.Builder
 
build() - Method in class org.apache.reef.webserver.AvroEvaluatorList.Builder
 
build() - Method in class org.apache.reef.webserver.AvroEvaluatorsInfo.Builder
 
build() - Method in class org.apache.reef.webserver.AvroHttpRequest.Builder
 
build() - Method in class org.apache.reef.webserver.AvroReefServiceInfo.Builder
 
build() - Method in class org.apache.reef.webserver.HeaderEntry.Builder
 
Builder<T> - Interface in org.apache.reef.util
A basic Builder pattern interface.
BuilderUtils - Class in org.apache.reef.util
Utilities for creating Builders.
buildPartial() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
 
buildPartial() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupMessageBody.Builder
 
buildPartial() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
 
buildPartial() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder
 
buildPartial() - Method in class org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.DoneEvaluatorProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.REEFProtocol.REEFMessage.Builder
 
buildPartial() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
 
buildPartial() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder
 
buildPartial() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
 
buildPartial() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArg.Builder
 
buildPartial() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
 
buildPartial() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
 
buildPartial() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
 
buildPartial() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.PackageNode.Builder
 
buildPartial() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
 
buildPartial() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan.Builder
 
buildPartial() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Instance.Builder
 
buildPartial() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
 
buildPartial() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.Builder
 
buildPartial() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.Builder
 
buildPartial() - Method in class org.apache.reef.wake.test.proto.TestProtos.TestEventPBuf.Builder
 
ByteCodec - Class in org.apache.reef.wake.remote.impl
Codec that performs identity transformation on bytes.
ByteCodec() - Constructor for class org.apache.reef.wake.remote.impl.ByteCodec
 
ByteEncoder - Class in org.apache.reef.wake.remote.transport.netty
Wrapping encoder for byte[].
ByteEncoder() - Constructor for class org.apache.reef.wake.remote.transport.netty.ByteEncoder
 

C

Cache<K,V> - Interface in org.apache.reef.util.cache
Cache with get-if-absent-compute semantics.
CACHE_TIMEOUT - Static variable in class org.apache.reef.io.network.naming.LocalNameResolverConfiguration
The timeout of caching lookup.
CACHE_TIMEOUT - Static variable in class org.apache.reef.io.network.naming.NameResolverConfiguration
The timeout of caching lookup.
CacheImpl<K,V> - Class in org.apache.reef.util.cache
Implementation that supports expire-after-write.
CacheImpl(CurrentTime, long) - Constructor for class org.apache.reef.util.cache.CacheImpl
Construct an expire-after-write cache.
call(byte[]) - Method in class org.apache.reef.examples.data.loading.LineCountingTask
 
call(byte[]) - Method in class org.apache.reef.examples.data.output.OutputServiceTask
Receives an output stream from the output service and writes "Hello REEF!" on it.
call(byte[]) - Method in class org.apache.reef.examples.group.bgd.MasterTask
 
call(byte[]) - Method in class org.apache.reef.examples.group.bgd.SlaveTask
 
call(byte[]) - Method in class org.apache.reef.examples.group.broadcast.MasterTask
 
call(byte[]) - Method in class org.apache.reef.examples.group.broadcast.SlaveTask
 
call(byte[]) - Method in class org.apache.reef.examples.hello.HelloTask
 
call(byte[]) - Method in class org.apache.reef.examples.library.ShellTask
Execute the shell command and return the result, which is sent back to the JobDriver and surfaced in the CompletedTask object.
call(byte[]) - Method in class org.apache.reef.examples.pool.SleepTask
Sleep for delay milliseconds and return.
call(byte[]) - Method in class org.apache.reef.examples.suspend.SuspendTestTask
Main method of the task: run cycle from 0 to numCycles, and sleep for delay seconds on each cycle.
call(byte[]) - Method in interface org.apache.reef.task.Task
Called by the resourcemanager harness to execute the task.
call(byte[]) - Method in class org.apache.reef.tests.fail.driver.NoopTask
 
call(byte[]) - Method in class org.apache.reef.tests.fail.task.FailTask
 
call(byte[]) - Method in class org.apache.reef.tests.fail.task.FailTaskCall
 
call(byte[]) - Method in class org.apache.reef.tests.fail.task.FailTaskClose
 
call(byte[]) - Method in class org.apache.reef.tests.fail.task.FailTaskMsg
 
call(byte[]) - Method in class org.apache.reef.tests.fail.task.FailTaskStart
 
call(byte[]) - Method in class org.apache.reef.tests.fail.task.FailTaskStop
 
call(byte[]) - Method in class org.apache.reef.tests.fail.task.FailTaskSuspend
 
call(byte[]) - Method in class org.apache.reef.tests.group.MasterTask
 
call(byte[]) - Method in class org.apache.reef.tests.group.SlaveTask
 
call(byte[]) - Method in class org.apache.reef.tests.library.tasks.EchoTask
 
call(byte[]) - Method in class org.apache.reef.tests.library.tasks.NoopTask
 
call(byte[]) - Method in class org.apache.reef.tests.messaging.task.TaskMessagingTask
 
call(byte[]) - Method in class org.apache.reef.tests.statepassing.StatePassingTask
 
call(byte[]) - Method in class org.apache.reef.tests.watcher.WatcherTestTask
 
call(List<TOutput>) - Method in interface org.apache.reef.vortex.api.VortexAggregateFunction
Runs a custom local aggregation function on Tasklets assigned to a VortexWorker.
call(TInput) - Method in interface org.apache.reef.vortex.api.VortexFunction
 
call(byte[]) - Method in class org.apache.reef.vortex.evaluator.VortexWorker
Starts the scheduler and executor and waits until termination.
call(List<Integer>) - Method in class org.apache.reef.vortex.examples.sumones.AdditionAggregateFunction
 
call(Integer) - Method in class org.apache.reef.vortex.examples.sumones.IdentityFunction
Outputs input.
callClrSystemOnRestartHandler(DriverRestartedBridge) - Static method in class org.apache.reef.javabridge.NativeInterop
 
callClrSystemOnStartHandler() - Static method in class org.apache.reef.javabridge.NativeInterop
 
cancel() - Method in class org.apache.reef.runtime.local.process.RunnableProcess
Cancels the running process if it is running.
cancel(boolean) - Method in class org.apache.reef.tang.InjectionFuture
 
cancel(boolean) - Method in class org.apache.reef.vortex.api.VortexFuture
Sends a cancel signal and blocks and waits until the task is cancelled, completed, or failed.
cancel(boolean, long, TimeUnit) - Method in class org.apache.reef.vortex.api.VortexFuture
Sends a cancel signal and blocks and waits until the task is cancelled, completed, or failed, or if the timeout has expired.
cancelled(int) - Method in class org.apache.reef.vortex.api.VortexAggregateFuture
Not implemented for local aggregation.
cancelled(int) - Method in class org.apache.reef.vortex.api.VortexFuture
Called by VortexMaster to let the user know that the Tasklet was cancelled.
cancelled(int) - Method in interface org.apache.reef.vortex.driver.VortexFutureDelegate
A Tasklet associated with the Future has been cancelled.
cancelTask(int) - Method in class org.apache.reef.examples.scheduler.driver.SchedulerDriver
Cancel a Task waiting on the queue.
cancelTasklet(boolean, int) - Method in interface org.apache.reef.vortex.driver.VortexMaster
Call this when a Tasklet is to be cancelled.
canParse(String) - Method in class org.apache.reef.tang.formats.ParameterParser
 
cause - Variable in class org.apache.reef.javabridge.avro.AvroFailedTask
Deprecated.
cell(String, String) - Method in class org.apache.reef.tang.util.Tint
 
cell(StringBuffer, String) - Method in class org.apache.reef.tang.util.Tint
 
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.reef.wake.remote.transport.netty.ChunkedReadWriteHandler
 
check() - Method in class org.apache.reef.runtime.common.driver.idle.EventHandlerIdlenessSource
 
checkAndSendTopologySetupMessage() - Method in interface org.apache.reef.io.network.group.api.driver.TaskNode
Check if this node is ready for sending.
checkAndSendTopologySetupMessage() - Method in class org.apache.reef.io.network.group.impl.driver.TaskNodeImpl
 
checkAndSendTopologySetupMessageFor(String) - Method in interface org.apache.reef.io.network.group.api.driver.TaskNode
Check if the neighbor node with id source.
checkAndSendTopologySetupMessageFor(String) - Method in class org.apache.reef.io.network.group.impl.driver.TaskNodeImpl
 
checkDead(GroupCommunicationMessage) - Method in class org.apache.reef.io.network.group.impl.task.ChildNodeStruct
 
checkDead(GroupCommunicationMessage) - Method in class org.apache.reef.io.network.group.impl.task.NodeStructImpl
 
checkDead(GroupCommunicationMessage) - Method in class org.apache.reef.io.network.group.impl.task.ParentNodeStruct
 
CheckpointID - Interface in org.apache.reef.io.checkpoint
This class represent an identifier of a checkpoint.
CheckpointNamingService - Interface in org.apache.reef.io.checkpoint
This class represent a naming service for checkpoints.
CheckpointService - Interface in org.apache.reef.io.checkpoint
The CheckpointService provides a simple API to store and retrieve the state of a task.
CheckpointService.CheckpointReadChannel - Interface in org.apache.reef.io.checkpoint
A channel to read from a checkpoint.
CheckpointService.CheckpointWriteChannel - Interface in org.apache.reef.io.checkpoint
A channel to write to a checkpoint.
ChildAdd_VALUE - Static variable in enum org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Type
ChildAdd = 11;
ChildAdded_VALUE - Static variable in enum org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Type
ChildAdded = 15;
ChildDead_VALUE - Static variable in enum org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Type
ChildDead = 13;
ChildNodeStruct - Class in org.apache.reef.io.network.group.impl.task
 
ChildNodeStruct(String, int) - Constructor for class org.apache.reef.io.network.group.impl.task.ChildNodeStruct
 
ChildRemoved_VALUE - Static variable in enum org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Type
ChildRemoved = 17;
children - Variable in class org.apache.reef.tang.implementation.avro.AvroNode
Deprecated.
CHILDREN_FIELD_NUMBER - Static variable in class org.apache.reef.tang.proto.ClassHierarchyProto.Node
 
ChunkedReadWriteHandler - Class in org.apache.reef.wake.remote.transport.netty
Thin wrapper around ChunkedWriteHandler.
ChunkedReadWriteHandler() - Constructor for class org.apache.reef.wake.remote.transport.netty.ChunkedReadWriteHandler
 
CLASS_HIERARCHY_FILENAME - Static variable in class org.apache.reef.examples.helloCLR.HelloCLR
The name of the class hierarchy file.
CLASS_NODE_FIELD_NUMBER - Static variable in class org.apache.reef.tang.proto.ClassHierarchyProto.Node
 
classAndAncestors(Type) - Static method in class org.apache.reef.tang.util.ReflectionUtilities
Given a Type, return all of the classes it extends and interfaces it implements (including the class itself).
classForName(String) - Method in class org.apache.reef.tang.implementation.java.ClassHierarchyImpl
Helper method that converts a String to a Class using this ClassHierarchy's classloader.
classForName(String) - Method in interface org.apache.reef.tang.JavaClassHierarchy
 
classForName(String, ClassLoader) - Static method in class org.apache.reef.tang.util.ReflectionUtilities
Lookup the provided name using the provided classloader.
ClassHierarchy - Interface in org.apache.reef.tang
ClassHierarchy objects store information about the interfaces and implementations that are available in a particular runtime environment.
ClassHierarchyException - Exception in org.apache.reef.tang.exceptions
This exception is thrown when Tang detects improper or inconsistent class annotations.
ClassHierarchyException(Throwable) - Constructor for exception org.apache.reef.tang.exceptions.ClassHierarchyException
 
ClassHierarchyException(String) - Constructor for exception org.apache.reef.tang.exceptions.ClassHierarchyException
 
ClassHierarchyException(String, Throwable) - Constructor for exception org.apache.reef.tang.exceptions.ClassHierarchyException
 
ClassHierarchyImpl - Class in org.apache.reef.tang.implementation.java
 
ClassHierarchyImpl() - Constructor for class org.apache.reef.tang.implementation.java.ClassHierarchyImpl
 
ClassHierarchyImpl(URL...) - Constructor for class org.apache.reef.tang.implementation.java.ClassHierarchyImpl
 
ClassHierarchyImpl(URL[], Class<? extends ExternalConstructor<?>>[]) - Constructor for class org.apache.reef.tang.implementation.java.ClassHierarchyImpl
 
ClassHierarchyProto - Class in org.apache.reef.tang.proto
 
ClassHierarchyProto.ClassNode - Class in org.apache.reef.tang.proto
Protobuf type ClassNode
ClassHierarchyProto.ClassNode.Builder - Class in org.apache.reef.tang.proto
Protobuf type ClassNode
ClassHierarchyProto.ClassNodeOrBuilder - Interface in org.apache.reef.tang.proto
 
ClassHierarchyProto.ConstructorArg - Class in org.apache.reef.tang.proto
Protobuf type ConstructorArg
ClassHierarchyProto.ConstructorArg.Builder - Class in org.apache.reef.tang.proto
Protobuf type ConstructorArg
ClassHierarchyProto.ConstructorArgOrBuilder - Interface in org.apache.reef.tang.proto
 
ClassHierarchyProto.ConstructorDef - Class in org.apache.reef.tang.proto
Protobuf type ConstructorDef
ClassHierarchyProto.ConstructorDef.Builder - Class in org.apache.reef.tang.proto
Protobuf type ConstructorDef
ClassHierarchyProto.ConstructorDefOrBuilder - Interface in org.apache.reef.tang.proto
 
ClassHierarchyProto.NamedParameterNode - Class in org.apache.reef.tang.proto
Protobuf type NamedParameterNode
ClassHierarchyProto.NamedParameterNode.Builder - Class in org.apache.reef.tang.proto
Protobuf type NamedParameterNode
ClassHierarchyProto.NamedParameterNodeOrBuilder - Interface in org.apache.reef.tang.proto
 
ClassHierarchyProto.Node - Class in org.apache.reef.tang.proto
Protobuf type Node
ClassHierarchyProto.Node.Builder - Class in org.apache.reef.tang.proto
Protobuf type Node
ClassHierarchyProto.NodeOrBuilder - Interface in org.apache.reef.tang.proto
 
ClassHierarchyProto.PackageNode - Class in org.apache.reef.tang.proto
Protobuf type PackageNode
ClassHierarchyProto.PackageNode.Builder - Class in org.apache.reef.tang.proto
Protobuf type PackageNode
ClassHierarchyProto.PackageNodeOrBuilder - Interface in org.apache.reef.tang.proto
 
ClassHierarchySerializer - Interface in org.apache.reef.tang
A base interface for ClassHierarchy serializers.
className - Variable in class org.apache.reef.bridge.message.Header
Deprecated.
CLASSNAME_FIELD_NUMBER - Static variable in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf
 
classNode - Variable in class org.apache.reef.tang.implementation.avro.AvroNode
Deprecated.
ClassNode<T> - Interface in org.apache.reef.tang.types
 
ClassNodeImpl<T> - Class in org.apache.reef.tang.implementation.types
 
ClassNodeImpl(Node, String, String, boolean, boolean, boolean, ConstructorDef<T>[], ConstructorDef<T>[], String) - Constructor for class org.apache.reef.tang.implementation.types.ClassNodeImpl
 
ClasspathProvider - Class in org.apache.reef.runtime.common.files
Supplies the classpath to REEF for process (Driver, Evaluator) launches.
classPrettyDefaultString(String) - Method in interface org.apache.reef.tang.ConfigurationBuilder
Pretty print the default implementation / value of the provided class / NamedParameter.
classPrettyDefaultString(String) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
classPrettyDescriptionString(String) - Method in interface org.apache.reef.tang.ConfigurationBuilder
Pretty print the human readable documentation of the provided class / NamedParameter.
classPrettyDescriptionString(String) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
clear() - Method in class org.apache.reef.io.network.group.impl.utils.ConcurrentCountingMap
 
clear() - Method in class org.apache.reef.io.network.group.impl.utils.CountingMap
 
clear() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
 
clear() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupMessageBody.Builder
 
clear() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
 
clear() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder
 
clear() - Method in class org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.DoneEvaluatorProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProto.Builder
 
clear() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProto.Builder
 
clear() - Method in class org.apache.reef.proto.REEFProtocol.REEFMessage.Builder
 
clear() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
 
clear() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder
 
clear() - Method in class org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.Builder
 
clear() - Method in class org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder
 
clear() - Method in class org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder
 
clear() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
 
clear() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder
 
clear() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
 
clear() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArg.Builder
 
clear() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
 
clear() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
 
clear() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
 
clear() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.PackageNode.Builder
 
clear() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
 
clear() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan.Builder
 
clear() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Instance.Builder
 
clear() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
 
clear() - Method in class org.apache.reef.tang.util.AbstractMonotonicMultiMap
 
clear() - Method in class org.apache.reef.tang.util.MonotonicHashMap
 
clear() - Method in class org.apache.reef.tang.util.MonotonicHashSet
 
clear() - Method in class org.apache.reef.tang.util.MonotonicSet
 
clear() - Method in class org.apache.reef.tang.util.MonotonicTreeMap
 
clear() - Method in class org.apache.reef.tang.util.TracingMonotonicTreeMap
 
clear() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.Builder
 
clear() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.Builder
 
clear() - Method in class org.apache.reef.wake.test.proto.TestProtos.TestEventPBuf.Builder
 
clearActiveContext() - Method in class org.apache.reef.io.watcher.driver.task.AvroCompletedTask.Builder
Clears the value of the 'activeContext' field.
clearActiveContext() - Method in class org.apache.reef.io.watcher.driver.task.AvroFailedTask.Builder
Clears the value of the 'activeContext' field.
clearActiveContext() - Method in class org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder
Clears the value of the 'activeContext' field.
clearActiveContext() - Method in class org.apache.reef.io.watcher.driver.task.AvroSuspendedTask.Builder
Clears the value of the 'activeContext' field.
clearAddContext() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
optional .AddContextProto add_context = 5;
clearAliasLanguage() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
optional string alias_language = 9;
clearAliasName() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
optional string alias_name = 8;
clearArgs() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
repeated .ConstructorArg args = 2;
clearArgs() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
repeated .InjectionPlan args = 1;
clearAsError() - Method in class org.apache.reef.io.watcher.common.AvroFailure.Builder
Clears the value of the 'asError' field.
clearBase() - Method in class org.apache.reef.io.watcher.driver.context.AvroActiveContext.Builder
Clears the value of the 'base' field.
clearBase() - Method in class org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder
Clears the value of the 'base' field.
clearBase() - Method in class org.apache.reef.io.watcher.driver.context.AvroFailedContext.Builder
Clears the value of the 'base' field.
clearBindings() - Method in class org.apache.reef.tang.formats.avro.AvroConfiguration.Builder
Clears the value of the 'Bindings' field.
clearCause() - Method in class org.apache.reef.javabridge.avro.AvroFailedTask.Builder
Clears the value of the 'cause' field.
clearChildren() - Method in class org.apache.reef.tang.implementation.avro.AvroNode.Builder
Clears the value of the 'children' field.
clearChildren() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
repeated .Node children = 6;
clearClassName() - Method in class org.apache.reef.bridge.message.Header.Builder
Clears the value of the 'className' field.
clearClassName() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.Builder
required string className = 1;
clearClassNode() - Method in class org.apache.reef.tang.implementation.avro.AvroNode.Builder
Clears the value of the 'classNode' field.
clearClassNode() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
optional .ClassNode class_node = 3;
clearCommand() - Method in class org.apache.reef.runtime.mesos.util.EvaluatorLaunch.Builder
Clears the value of the 'command' field.
clearCommandLines() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorProcess.Builder
Clears the value of the 'commandLines' field.
clearConfiguration() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto.Builder
required string configuration = 2;
clearConstructor() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan.Builder
optional .Constructor constructor = 2;
clearConstructorArgs() - Method in class org.apache.reef.tang.implementation.avro.AvroConstructorDef.Builder
Clears the value of the 'constructorArgs' field.
clearContextConfiguration() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto.Builder
required string context_configuration = 2;
clearContextControl() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder
optional .ContextControlProto context_control = 3;
clearContextId() - Method in class org.apache.reef.io.watcher.driver.task.AvroTaskMessage.Builder
Clears the value of the 'contextId' field.
clearContextId() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProto.Builder
required string context_id = 1;
clearContextId() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProto.Builder
required string context_id = 1;
clearContextId() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto.Builder
required string context_id = 1;
clearContextId() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
required string context_id = 2;
clearContextId() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
required string context_id = 2;
clearContextMessage() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
optional .ContextMessageProto context_message = 2;
clearContextMessage() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
repeated .ContextStatusProto.ContextMessageProto context_message = 7;
clearContextState() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
required .ContextStatusProto.State context_state = 1;
clearContextStatus() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
repeated .ContextStatusProto context_status = 3;
clearCores() - Method in class org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder
Clears the value of the 'cores' field.
clearData() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupMessageBody.Builder
required bytes data = 1;
clearData() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder
required bytes data = 1;
clearData() - Method in class org.apache.reef.io.watcher.common.AvroFailure.Builder
Clears the value of the 'data' field.
clearData() - Method in class org.apache.reef.javabridge.avro.AvroFailedTask.Builder
Clears the value of the 'data' field.
clearData() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.Builder
required bytes data = 1;
clearData() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.Builder
required bytes data = 2;
clearDateTime() - Method in class org.apache.reef.bridge.message.SystemOnStart.Builder
Clears the value of the 'dateTime' field.
clearDefaultImplementation() - Method in class org.apache.reef.tang.implementation.avro.AvroClassNode.Builder
Clears the value of the 'defaultImplementation' field.
clearDefaultImplementation() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
optional string default_implementation = 7;
clearDefaultRuntimeName() - Method in class org.apache.reef.reef.bridge.client.avro.AvroMultiRuntimeAppSubmissionParameters.Builder
Clears the value of the 'defaultRuntimeName' field.
clearDefaultRuntimeName() - Method in class org.apache.reef.runtime.multi.utils.avro.AvroMultiRuntimeDefinition.Builder
Clears the value of the 'defaultRuntimeName' field.
clearDescription() - Method in class org.apache.reef.io.watcher.common.AvroFailure.Builder
Clears the value of the 'description' field.
clearDestid() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
required string destid = 3;
clearDestid() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
required string destid = 3;
clearDfsJobSubmissionFolder() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.Builder
Clears the value of the 'dfsJobSubmissionFolder' field.
clearDocumentation() - Method in class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode.Builder
Clears the value of the 'documentation' field.
clearDocumentation() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
optional string documentation = 5;
clearDoneEvaluator() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder
optional .DoneEvaluatorProto done_evaluator = 6;
clearDriverMemory() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder
Clears the value of the 'driverMemory' field.
clearDriverRecoveryTimeout() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnAppSubmissionParameters.Builder
Clears the value of the 'driverRecoveryTimeout' field.
clearDriverStderrFilePath() - Method in class org.apache.reef.reef.bridge.client.avro.AvroLocalJobSubmissionParameters.Builder
Clears the value of the 'driverStderrFilePath' field.
clearDriverStderrFilePath() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder
Clears the value of the 'driverStderrFilePath' field.
clearDriverStdoutFilePath() - Method in class org.apache.reef.reef.bridge.client.avro.AvroLocalJobSubmissionParameters.Builder
Clears the value of the 'driverStdoutFilePath' field.
clearDriverStdoutFilePath() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder
Clears the value of the 'driverStdoutFilePath' field.
clearError() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
optional bytes error = 5;
clearError() - Method in class org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.Builder
optional bytes error = 3;
clearEvaluatorControl() - Method in class org.apache.reef.proto.REEFProtocol.REEFMessage.Builder
optional .EvaluatorControlProto evaluatorControl = 5;
clearEvaluatorDescriptor() - Method in class org.apache.reef.io.watcher.driver.context.AvroContextBase.Builder
Clears the value of the 'evaluatorDescriptor' field.
clearEvaluatorDescriptor() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder
Clears the value of the 'evaluatorDescriptor' field.
clearEvaluatorException() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroFailedEvaluator.Builder
Clears the value of the 'evaluatorException' field.
clearEvaluatorHeartBeat() - Method in class org.apache.reef.proto.REEFProtocol.REEFMessage.Builder
optional .EvaluatorHeartbeatProto evaluatorHeartBeat = 6;
clearEvaluatorId() - Method in class org.apache.reef.io.watcher.driver.context.AvroContextBase.Builder
Clears the value of the 'evaluatorId' field.
clearEvaluatorId() - Method in class org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.Builder
required string evaluator_id = 1;
clearEvaluatorId() - Method in class org.apache.reef.webserver.AvroEvaluatorInfo.Builder
Clears the value of the 'evaluatorId' field.
clearEvaluatorLaunch() - Method in class org.apache.reef.runtime.mesos.util.EvaluatorControl.Builder
Clears the value of the 'evaluator_launch' field.
clearEvaluatorRelease() - Method in class org.apache.reef.runtime.mesos.util.EvaluatorControl.Builder
Clears the value of the 'evaluator_release' field.
clearEvaluators() - Method in class org.apache.reef.webserver.AvroEvaluatorList.Builder
Clears the value of the 'evaluators' field.
clearEvaluatorsInfo() - Method in class org.apache.reef.webserver.AvroEvaluatorsInfo.Builder
Clears the value of the 'evaluatorsInfo' field.
clearEvaluatorStatus() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
required .EvaluatorStatusProto evaluator_status = 2;
clearEvaluatorType() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorProcess.Builder
Clears the value of the 'evaluatorType' field.
clearException() - Method in class org.apache.reef.io.watcher.wake.time.runtime.event.AvroRuntimeStop.Builder
Clears the value of the 'exception' field.
clearException() - Method in class org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder
optional bytes exception = 4;
clearException() - Method in class org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder
optional bytes exception = 3;
clearFailedContextList() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroFailedEvaluator.Builder
Clears the value of the 'failedContextList' field.
clearFailedTask() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroFailedEvaluator.Builder
Clears the value of the 'failedTask' field.
clearFailure() - Method in class org.apache.reef.io.watcher.driver.context.AvroFailedContext.Builder
Clears the value of the 'failure' field.
clearFailure() - Method in class org.apache.reef.io.watcher.driver.task.AvroFailedTask.Builder
Clears the value of the 'failure' field.
clearFileSystemUrl() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.Builder
Clears the value of the 'fileSystemUrl' field.
clearFullArgClassName() - Method in class org.apache.reef.tang.implementation.avro.AvroConstructorArg.Builder
Clears the value of the 'fullArgClassName' field.
clearFullArgClassName() - Method in class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode.Builder
Clears the value of the 'fullArgClassName' field.
clearFullArgClassName() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArg.Builder
required string full_arg_class_name = 1;
clearFullArgClassName() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
required string full_arg_class_name = 2;
clearFullClassName() - Method in class org.apache.reef.tang.implementation.avro.AvroConstructorDef.Builder
Clears the value of the 'fullClassName' field.
clearFullClassName() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
required string full_class_name = 1;
clearFullName() - Method in class org.apache.reef.tang.implementation.avro.AvroNode.Builder
Clears the value of the 'fullName' field.
clearFullName() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
required string full_name = 2;
clearGet() - Method in class org.apache.reef.io.watcher.driver.context.AvroContextMessage.Builder
Clears the value of the 'get' field.
clearGet() - Method in class org.apache.reef.io.watcher.driver.task.AvroCompletedTask.Builder
Clears the value of the 'get' field.
clearGet() - Method in class org.apache.reef.io.watcher.driver.task.AvroSuspendedTask.Builder
Clears the value of the 'get' field.
clearGet() - Method in class org.apache.reef.io.watcher.driver.task.AvroTaskMessage.Builder
Clears the value of the 'get' field.
clearGroupname() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
optional string groupname = 4;
clearHeader() - Method in class org.apache.reef.webserver.AvroHttpRequest.Builder
Clears the value of the 'header' field.
clearHost() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingAssignment.Builder
Clears the value of the 'host' field.
clearHost() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingRegisterRequest.Builder
Clears the value of the 'host' field.
clearHttpMethod() - Method in class org.apache.reef.webserver.AvroHttpRequest.Builder
Clears the value of the 'httpMethod' field.
clearHttpServerPortNumber() - Method in class org.apache.reef.bridge.message.SetupBridge.Builder
Clears the value of the 'httpServerPortNumber' field.
clearId() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingAssignment.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingRegisterRequest.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingUnRegisterRequest.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.common.AvroFailure.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptor.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptorInRackDescriptor.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.context.AvroContextBase.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.context.AvroContextMessage.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroCompletedEvaluator.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroFailedEvaluator.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.task.AvroCompletedTask.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.task.AvroRunningTask.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.task.AvroSuspendedTask.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.io.watcher.driver.task.AvroTaskMessage.Builder
Clears the value of the 'id' field.
clearId() - Method in class org.apache.reef.webserver.AvroEvaluatorEntry.Builder
Clears the value of the 'id' field.
clearIdentifier() - Method in class org.apache.reef.bridge.message.Header.Builder
Clears the value of the 'identifier' field.
clearIdentifier() - Method in class org.apache.reef.javabridge.avro.AvroFailedTask.Builder
Clears the value of the 'identifier' field.
clearIdentifier() - Method in class org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder
required string identifier = 1;
clearIdentifier() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder
required string identifier = 2;
clearIdentifier() - Method in class org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder
required string identifier = 1;
clearIdentifier() - Method in class org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder
optional string identifier = 5;
clearIdentifier() - Method in class org.apache.reef.runtime.mesos.util.EvaluatorLaunch.Builder
Clears the value of the 'identifier' field.
clearIdentifier() - Method in class org.apache.reef.runtime.mesos.util.EvaluatorRelease.Builder
Clears the value of the 'identifier' field.
clearIds() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingLookupRequest.Builder
Clears the value of the 'ids' field.
clearImplFullNames() - Method in class org.apache.reef.tang.implementation.avro.AvroClassNode.Builder
Clears the value of the 'implFullNames' field.
clearImplFullNames() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated string impl_full_names = 6;
clearInetSocketAddress() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptor.Builder
Clears the value of the 'inetSocketAddress' field.
clearInetSocketAddress() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptorInRackDescriptor.Builder
Clears the value of the 'inetSocketAddress' field.
clearInjectableConstructors() - Method in class org.apache.reef.tang.implementation.avro.AvroClassNode.Builder
Clears the value of the 'injectableConstructors' field.
clearInjectableConstructors() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef InjectableConstructors = 4;
clearInputStream() - Method in class org.apache.reef.webserver.AvroHttpRequest.Builder
Clears the value of the 'inputStream' field.
clearInstance() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan.Builder
optional .Instance instance = 3;
clearInstanceDefault() - Method in class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode.Builder
Clears the value of the 'instanceDefault' field.
clearInstanceDefault() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
repeated string instance_default = 7;
clearInternetAddress() - Method in class org.apache.reef.webserver.AvroEvaluatorInfo.Builder
Clears the value of the 'internetAddress' field.
clearIsExternalConstructor() - Method in class org.apache.reef.tang.implementation.avro.AvroClassNode.Builder
Clears the value of the 'isExternalConstructor' field.
clearIsExternalConstructor() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
required bool is_external_constructor = 2;
clearIsInjectionCandidate() - Method in class org.apache.reef.tang.implementation.avro.AvroClassNode.Builder
Clears the value of the 'isInjectionCandidate' field.
clearIsInjectionCandidate() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
required bool is_injection_candidate = 1;
clearIsInjectionFuture() - Method in class org.apache.reef.tang.implementation.avro.AvroConstructorArg.Builder
Clears the value of the 'isInjectionFuture' field.
clearIsInjectionFuture() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArg.Builder
required bool is_injection_future = 3;
clearIsList() - Method in class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode.Builder
Clears the value of the 'isList' field.
clearIsList() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
required bool is_list = 4;
clearIsOptionSet() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorProcess.Builder
Clears the value of the 'isOptionSet' field.
clearIsSet() - Method in class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode.Builder
Clears the value of the 'isSet' field.
clearIsSet() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
required bool is_set = 3;
clearIsUnit() - Method in class org.apache.reef.tang.implementation.avro.AvroClassNode.Builder
Clears the value of the 'isUnit' field.
clearIsUnit() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
required bool is_unit = 3;
clearJobControl() - Method in class org.apache.reef.proto.REEFProtocol.REEFMessage.Builder
optional .JobControlProto jobControl = 2;
clearJobId() - Method in class org.apache.reef.reef.bridge.client.avro.AvroJobSubmissionParameters.Builder
Clears the value of the 'jobId' field.
clearJobStatus() - Method in class org.apache.reef.proto.REEFProtocol.REEFMessage.Builder
optional .JobStatusProto jobStatus = 4;
clearJobSubmissionDirectoryPrefix() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.Builder
Clears the value of the 'jobSubmissionDirectoryPrefix' field.
clearJobSubmissionFolder() - Method in class org.apache.reef.reef.bridge.client.avro.AvroJobSubmissionParameters.Builder
Clears the value of the 'jobSubmissionFolder' field.
clearKey() - Method in class org.apache.reef.tang.formats.avro.ConfigurationEntry.Builder
Clears the value of the 'key' field.
clearKey() - Method in class org.apache.reef.webserver.HeaderEntry.Builder
Clears the value of the 'key' field.
clearKillEvaluator() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder
optional .KillEvaluatorProto kill_evaluator = 4;
clearLanguage() - Method in class org.apache.reef.tang.formats.avro.AvroConfiguration.Builder
Clears the value of the 'language' field.
clearList() - Method in class org.apache.reef.examples.scheduler.driver.SchedulerDriver
Clear all the Tasks from the waiting queue.
clearLoad() - Method in class org.apache.reef.wake.test.proto.TestProtos.TestEventPBuf.Builder
required double load = 2;
clearLocalRuntimeAppParameters() - Method in class org.apache.reef.reef.bridge.client.avro.AvroMultiRuntimeAppSubmissionParameters.Builder
Clears the value of the 'localRuntimeAppParameters' field.
clearMaxApplicationSubmissions() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder
Clears the value of the 'maxApplicationSubmissions' field.
clearMaxNumberOfConcurrentEvaluators() - Method in class org.apache.reef.reef.bridge.client.avro.AvroLocalAppSubmissionParameters.Builder
Clears the value of the 'maxNumberOfConcurrentEvaluators' field.
clearMegaBytes() - Method in class org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder
Clears the value of the 'megaBytes' field.
clearMemory() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor.Builder
Clears the value of the 'memory' field.
clearMemory() - Method in class org.apache.reef.webserver.AvroEvaluatorInfo.Builder
Clears the value of the 'memory' field.
clearMessage() - Method in class org.apache.reef.bridge.message.BridgeInterop.Builder
Clears the value of the 'message' field.
clearMessage() - Method in class org.apache.reef.io.watcher.common.AvroFailure.Builder
Clears the value of the 'message' field.
clearMessage() - Method in class org.apache.reef.javabridge.avro.AvroFailedTask.Builder
Clears the value of the 'message' field.
clearMessage() - Method in class org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder
optional bytes message = 3;
clearMessage() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProto.Builder
required bytes message = 2;
clearMessage() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder
required bytes message = 2;
clearMessage() - Method in class org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder
optional bytes message = 3;
clearMessage() - Method in class org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder
required string message = 2;
clearMessage() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder
required bytes message = 2;
clearMessage() - Method in class org.apache.reef.wake.test.proto.TestProtos.TestEventPBuf.Builder
required string message = 1;
clearMessageIdentifier() - Method in class org.apache.reef.bridge.message.Acknowledgement.Builder
Clears the value of the 'messageIdentifier' field.
clearMessageSourceId() - Method in class org.apache.reef.io.watcher.driver.context.AvroContextMessage.Builder
Clears the value of the 'messageSourceId' field.
clearMessageSourceId() - Method in class org.apache.reef.io.watcher.driver.task.AvroTaskMessage.Builder
Clears the value of the 'messageSourceId' field.
clearMessageType() - Method in class org.apache.reef.bridge.message.BridgeInterop.Builder
Clears the value of the 'messageType' field.
clearMsgs() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
repeated .GroupMessageBody msgs = 8;
clearMsgs() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
repeated .NSRecordPBuf msgs = 4;
clearName() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptor.Builder
Clears the value of the 'name' field.
clearName() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptorInRackDescriptor.Builder
Clears the value of the 'name' field.
clearName() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroRackDescriptor.Builder
Clears the value of the 'name' field.
clearName() - Method in class org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder
required string name = 1;
clearName() - Method in class org.apache.reef.tang.implementation.avro.AvroNode.Builder
Clears the value of the 'name' field.
clearName() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
required string name = 1;
clearName() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan.Builder
required string name = 1;
clearName() - Method in class org.apache.reef.webserver.AvroEvaluatorEntry.Builder
Clears the value of the 'name' field.
clearNamedParameterName() - Method in class org.apache.reef.tang.implementation.avro.AvroConstructorArg.Builder
Clears the value of the 'namedParameterName' field.
clearNamedParameterName() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArg.Builder
optional string named_parameter_name = 2;
clearNamedParameterNode() - Method in class org.apache.reef.tang.implementation.avro.AvroNode.Builder
Clears the value of the 'namedParameterNode' field.
clearNamedParameterNode() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
optional .NamedParameterNode named_parameter_node = 4;
clearNodeDescriptor() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor.Builder
Clears the value of the 'nodeDescriptor' field.
clearNodeId() - Method in class org.apache.reef.webserver.AvroEvaluatorInfo.Builder
Clears the value of the 'nodeId' field.
clearNodeName() - Method in class org.apache.reef.webserver.AvroEvaluatorInfo.Builder
Clears the value of the 'nodeName' field.
clearNodeNames() - Method in class org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder
Clears the value of the 'nodeNames' field.
clearNodes() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroRackDescriptor.Builder
Clears the value of the 'nodes' field.
clearNumber() - Method in class org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder
Clears the value of the 'number' field.
clearNumberOfCores() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor.Builder
Clears the value of the 'numberOfCores' field.
clearOffset() - Method in class org.apache.reef.bridge.message.Protocol.Builder
Clears the value of the 'offset' field.
clearOperatorname() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
optional string operatorname = 5;
clearOtherConstructors() - Method in class org.apache.reef.tang.implementation.avro.AvroClassNode.Builder
Clears the value of the 'otherConstructors' field.
clearOtherConstructors() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
repeated .ConstructorDef OtherConstructors = 5;
clearPackageNode() - Method in class org.apache.reef.tang.implementation.avro.AvroNode.Builder
Clears the value of the 'packageNode' field.
clearPackageNode() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
optional .PackageNode package_node = 5;
clearParentContext() - Method in class org.apache.reef.io.watcher.driver.context.AvroClosedContext.Builder
Clears the value of the 'parentContext' field.
clearParentContext() - Method in class org.apache.reef.io.watcher.driver.context.AvroFailedContext.Builder
Clears the value of the 'parentContext' field.
clearParentContextId() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto.Builder
required string parent_context_id = 1;
clearParentId() - Method in class org.apache.reef.io.watcher.driver.context.AvroContextBase.Builder
Clears the value of the 'parentId' field.
clearParentId() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
optional string parent_id = 3;
clearPathInfo() - Method in class org.apache.reef.webserver.AvroHttpRequest.Builder
Clears the value of the 'pathInfo' field.
clearPlans() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
repeated .InjectionPlan plans = 2;
clearPort() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingAssignment.Builder
Clears the value of the 'port' field.
clearPort() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingRegisterRequest.Builder
Clears the value of the 'port' field.
clearProcess() - Method in class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorDescriptor.Builder
Clears the value of the 'process' field.
clearQueryString() - Method in class org.apache.reef.webserver.AvroHttpRequest.Builder
Clears the value of the 'queryString' field.
clearRackDescriptor() - Method in class org.apache.reef.io.watcher.driver.catalog.AvroNodeDescriptor.Builder
Clears the value of the 'rackDescriptor' field.
clearRackNames() - Method in class org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest.Builder
Clears the value of the 'rackNames' field.
clearReason() - Method in class org.apache.reef.io.watcher.common.AvroFailure.Builder
Clears the value of the 'reason' field.
clearRecovery() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
optional bool recovery = 5;
clearRecovery() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
optional bool recovery = 6;
clearRecovery() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
optional bool recovery = 5;
clearRemoteId() - Method in class org.apache.reef.webserver.AvroDriverInfo.Builder
Clears the value of the 'remoteId' field.
clearRemoveContext() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
optional .RemoveContextProto remove_context = 6;
clearRequestUrl() - Method in class org.apache.reef.webserver.AvroHttpRequest.Builder
Clears the value of the 'requestUrl' field.
clearResult() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
optional bytes result = 4;
clearRuntimeError() - Method in class org.apache.reef.proto.REEFProtocol.REEFMessage.Builder
optional .RuntimeErrorProto runtimeError = 3;
clearRuntimeName() - Method in class org.apache.reef.runtime.multi.utils.avro.AvroRuntimeDefinition.Builder
Clears the value of the 'runtimeName' field.
clearRuntimeName() - Method in class org.apache.reef.webserver.AvroEvaluatorInfo.Builder
Clears the value of the 'runtimeName' field.
clearRuntimeNames() - Method in class org.apache.reef.javabridge.avro.DefinedRuntimes.Builder
Clears the value of the 'runtimeNames' field.
clearRuntimes() - Method in class org.apache.reef.reef.bridge.client.avro.AvroMultiRuntimeAppSubmissionParameters.Builder
Clears the value of the 'runtimes' field.
clearRuntimes() - Method in class org.apache.reef.runtime.multi.utils.avro.AvroMultiRuntimeDefinition.Builder
Clears the value of the 'runtimes' field.
clearSecurityTokenKind() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder
Clears the value of the 'securityTokenKind' field.
clearSecurityTokenService() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder
Clears the value of the 'securityTokenService' field.
clearSelectedPlan() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
optional sint32 selected_plan = 1;
clearSeq() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.Builder
required int64 seq = 2;
clearSequence() - Method in class org.apache.reef.bridge.message.BridgeInterop.Builder
Clears the value of the 'sequence' field.
clearSerializedConfiguration() - Method in class org.apache.reef.runtime.multi.utils.avro.AvroRuntimeDefinition.Builder
Clears the value of the 'serializedConfiguration' field.
clearServiceConfiguration() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto.Builder
optional string service_configuration = 3;
clearServiceInfo() - Method in class org.apache.reef.webserver.AvroReefServiceInfo.Builder
Clears the value of the 'serviceInfo' field.
clearServiceName() - Method in class org.apache.reef.webserver.AvroReefServiceInfo.Builder
Clears the value of the 'serviceName' field.
clearServices() - Method in class org.apache.reef.webserver.AvroDriverInfo.Builder
Clears the value of the 'services' field.
clearSharedAppSubmissionParameters() - Method in class org.apache.reef.reef.bridge.client.avro.AvroLocalAppSubmissionParameters.Builder
Clears the value of the 'sharedAppSubmissionParameters' field.
clearSharedAppSubmissionParameters() - Method in class org.apache.reef.reef.bridge.client.avro.AvroMultiRuntimeAppSubmissionParameters.Builder
Clears the value of the 'sharedAppSubmissionParameters' field.
clearSharedAppSubmissionParameters() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnAppSubmissionParameters.Builder
Clears the value of the 'sharedAppSubmissionParameters' field.
clearSharedJobSubmissionParameters() - Method in class org.apache.reef.reef.bridge.client.avro.AvroLocalJobSubmissionParameters.Builder
Clears the value of the 'sharedJobSubmissionParameters' field.
clearSharedJobSubmissionParameters() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters.Builder
Clears the value of the 'sharedJobSubmissionParameters' field.
clearShortName() - Method in class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode.Builder
Clears the value of the 'shortName' field.
clearShortName() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
optional string short_name = 6;
clearSignal() - Method in class org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder
optional .Signal signal = 2;
clearSimpleArgClassName() - Method in class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode.Builder
Clears the value of the 'simpleArgClassName' field.
clearSimpleArgClassName() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
required string simple_arg_class_name = 1;
clearSourceId() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder
required string source_id = 1;
clearSourceId() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder
required string source_id = 1;
clearSrcid() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
required string srcid = 2;
clearSrcid() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
required string srcid = 2;
clearSrcVersion() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
optional int32 srcVersion = 7;
clearStartTask() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
optional .StartTaskProto start_task = 7;
clearStartTime() - Method in class org.apache.reef.webserver.AvroDriverInfo.Builder
Clears the value of the 'startTime' field.
clearStartTime() - Method in class org.apache.reef.webserver.AvroEvaluatorList.Builder
Clears the value of the 'startTime' field.
clearState() - Method in class org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.Builder
required .State state = 2;
clearState() - Method in class org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder
required .State state = 2;
clearState() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
required .State state = 3;
clearStateAndReleaseLocks() - Method in interface org.apache.reef.io.network.group.api.driver.TaskNodeStatus
Used when the task has failed to clear all.
clearStateAndReleaseLocks() - Method in class org.apache.reef.io.network.group.impl.driver.TaskNodeStatusImpl
 
clearStopEvaluator() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder
optional .StopEvaluatorProto stop_evaluator = 5;
clearStopTask() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
optional .StopTaskProto stop_task = 8;
clearSubplan() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan.Builder
optional .Subplan subplan = 4;
clearSuspendTask() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
optional .SuspendTaskProto suspend_task = 9;
clearTaskId() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
required string task_id = 1;
clearTaskMessage() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
optional bytes task_message = 1;
clearTaskMessage() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
repeated .TaskStatusProto.TaskMessageProto task_message = 6;
clearTaskStatus() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
optional .TaskStatusProto task_status = 4;
clearTcpBeginPort() - Method in class org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder
Clears the value of the 'tcpBeginPort' field.
clearTcpRangeCount() - Method in class org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder
Clears the value of the 'tcpRangeCount' field.
clearTcpTryCount() - Method in class org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters.Builder
Clears the value of the 'tcpTryCount' field.
clearTimestamp() - Method in class org.apache.reef.io.watcher.wake.time.event.AvroStartTime.Builder
Clears the value of the 'timestamp' field.
clearTimestamp() - Method in class org.apache.reef.io.watcher.wake.time.event.AvroStopTime.Builder
Clears the value of the 'timestamp' field.
clearTimestamp() - Method in class org.apache.reef.io.watcher.wake.time.runtime.event.AvroRuntimeStart.Builder
Clears the value of the 'timestamp' field.
clearTimestamp() - Method in class org.apache.reef.io.watcher.wake.time.runtime.event.AvroRuntimeStop.Builder
Clears the value of the 'timestamp' field.
clearTimestamp() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder
required int64 timestamp = 1;
clearTimestamp() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
required int64 timestamp = 1;
clearTotal() - Method in class org.apache.reef.webserver.AvroEvaluatorList.Builder
Clears the value of the 'total' field.
clearTuples() - Method in class org.apache.reef.io.network.naming.avro.AvroNamingLookupResponse.Builder
Clears the value of the 'tuples' field.
clearType() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
required .GroupCommMessage.Type type = 1;
clearType() - Method in class org.apache.reef.webserver.AvroEvaluatorInfo.Builder
Clears the value of the 'type' field.
clearValue() - Method in class org.apache.reef.tang.formats.avro.ConfigurationEntry.Builder
Clears the value of the 'value' field.
clearValue() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Instance.Builder
required string value = 1;
clearValue() - Method in class org.apache.reef.webserver.HeaderEntry.Builder
Clears the value of the 'value' field.
clearVersion() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
optional int32 version = 6;
clearYarnJobSubmissionParameters() - Method in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters.Builder
Clears the value of the 'yarnJobSubmissionParameters' field.
clearYarnRuntimeAppParameters() - Method in class org.apache.reef.reef.bridge.client.avro.AvroMultiRuntimeAppSubmissionParameters.Builder
Clears the value of the 'yarnRuntimeAppParameters' field.
Client - Class in org.apache.reef.tests.fail.task
Client for the test REEF job that fails on different stages of execution.
CLIENT_REMOTE_IDENTIFIER - Static variable in class org.apache.reef.runtime.hdinsight.client.HDInsightDriverConfiguration
The client remote identifier.
CLIENT_REMOTE_IDENTIFIER - Static variable in class org.apache.reef.runtime.local.driver.LocalDriverConfiguration
The remote identifier to use for communications back to the client.
CLIENT_REMOTE_IDENTIFIER - Static variable in class org.apache.reef.runtime.mesos.driver.MesosDriverConfiguration
The client remote identifier.
CLIENT_REMOTE_IDENTIFIER - Static variable in class org.apache.reef.runtime.multi.driver.MultiRuntimeDriverConfiguration
The identifier of the Job submitted.
CLIENT_REMOTE_IDENTIFIER - Static variable in class org.apache.reef.runtime.standalone.driver.StandaloneDriverConfiguration
The remote identifier to use for communications back to the client.
CLIENT_REMOTE_IDENTIFIER - Static variable in class org.apache.reef.runtime.yarn.client.unmanaged.UnmanagedAmYarnDriverConfiguration
 
CLIENT_REMOTE_IDENTIFIER - Static variable in class org.apache.reef.runtime.yarn.driver.YarnDriverConfiguration
The client remote identifier.
ClientAlarm - Class in org.apache.reef.wake.time.runtime.event
An event for client-created alarm.
ClientAlarm(long, EventHandler<Alarm>) - Constructor for class org.apache.reef.wake.time.runtime.event.ClientAlarm
 
ClientCloseHandlers - Class in org.apache.reef.driver.parameters
Handles close requests from the client.
ClientCloseWithMessageHandlers - Class in org.apache.reef.driver.parameters
Handles client close requests.
ClientConfiguration - Class in org.apache.reef.client
A ConfigurationModule to fill out for the client configuration.
ClientConfiguration() - Constructor for class org.apache.reef.client.ClientConfiguration
 
ClientConnection - Class in org.apache.reef.runtime.common.driver.client
Represents the communication channel to the client.
ClientConnection(String, JobStatusHandler) - Constructor for class org.apache.reef.runtime.common.driver.client.ClientConnection
 
ClientManager - Class in org.apache.reef.runtime.common.driver.client
Represents the Client in the Driver.
ClientMessageHandlers - Class in org.apache.reef.driver.parameters
Handles message from the Client.
ClientPresent - Class in org.apache.reef.runtime.common.client.parameters
A Tang named parameter that indicates whether or not a client (handler for the various Job events) is present.
ClientRemoteIdentifier - Class in org.apache.reef.runtime.common.driver.parameters
The client remote identifier.
ClientRuntimeParameters - Class in org.apache.reef.runtime.common.client.api
Parameters used by client runtime.
ClientRuntimeParameters() - Constructor for class org.apache.reef.runtime.common.client.api.ClientRuntimeParameters
 
ClientRuntimeParameters.RuntimeErrorHandlerRID - Class in org.apache.reef.runtime.common.client.api
The runtime error handler RID.
ClientRuntimeParameters.RuntimeErrorHandlerRID() - Constructor for class org.apache.reef.runtime.common.client.api.ClientRuntimeParameters.RuntimeErrorHandlerRID
 
ClientRuntimeProtocol - Class in org.apache.reef.proto
 
ClientRuntimeProtocol.JobControlProto - Class in org.apache.reef.proto
Protobuf type JobControlProto
ClientRuntimeProtocol.JobControlProto.Builder - Class in org.apache.reef.proto
Protobuf type JobControlProto
ClientRuntimeProtocol.JobControlProtoOrBuilder - Interface in org.apache.reef.proto
 
ClientRuntimeProtocol.Signal - Enum in org.apache.reef.proto
Protobuf enum Signal
ClientSide - Annotation Type in org.apache.reef.annotations.audience
Annotates interface meant to be used by REEF clients.
ClientSideFailure - Exception in org.apache.reef.tests.library.exceptions
Thrown when a test fails on the client side.
ClientSideFailure() - Constructor for exception org.apache.reef.tests.library.exceptions.ClientSideFailure
 
ClientSideFailure(String) - Constructor for exception org.apache.reef.tests.library.exceptions.ClientSideFailure
 
ClientSideFailure(String, Throwable) - Constructor for exception org.apache.reef.tests.library.exceptions.ClientSideFailure
 
ClientSideFailure(Throwable) - Constructor for exception org.apache.reef.tests.library.exceptions.ClientSideFailure
 
Clock - Interface in org.apache.reef.wake.time
Represents a clock.
Clock.IdleHandler - Class in org.apache.reef.wake.time
Bind this to an event handler to statically subscribe to the IdleClock Event.
Clock.IdleHandler() - Constructor for class org.apache.reef.wake.time.Clock.IdleHandler
 
Clock.RuntimeStartHandler - Class in org.apache.reef.wake.time
Bind this to an event handler to statically subscribe to the RuntimeStart Event.
Clock.RuntimeStartHandler() - Constructor for class org.apache.reef.wake.time.Clock.RuntimeStartHandler
 
Clock.RuntimeStopHandler - Class in org.apache.reef.wake.time
Bind this to an event handler to statically subscribe to the RuntimeStart Event.
Clock.RuntimeStopHandler() - Constructor for class org.apache.reef.wake.time.Clock.RuntimeStopHandler
 
Clock.StartHandler - Class in org.apache.reef.wake.time
Bind this to an event handler to statically subscribe to the StartTime Event.
Clock.StartHandler() - Constructor for class org.apache.reef.wake.time.Clock.StartHandler
 
Clock.StopHandler - Class in org.apache.reef.wake.time
Bind this to an event handler to statically subscribe to the StopTime Event.
Clock.StopHandler() - Constructor for class org.apache.reef.wake.time.Clock.StopHandler
 
ClockConfigurationPath - Class in org.apache.reef.runtime.common.launch.parameters
The path to the clock configuration.
ClockIdlenessSource - Class in org.apache.reef.runtime.common.driver.idle
Informs the DriverIdleManager of clock idleness.
clone() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage.Builder
 
clone() - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupMessageBody.Builder
 
clone() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf.Builder
 
clone() - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf.Builder
 
clone() - Method in class org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.DoneEvaluatorProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProto.Builder
 
clone() - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProto.Builder
 
clone() - Method in class org.apache.reef.proto.REEFProtocol.REEFMessage.Builder
 
clone() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.Builder
 
clone() - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto.Builder
 
clone() - Method in class org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto.Builder
 
clone() - Method in class org.apache.reef.proto.ReefServiceProtos.JobStatusProto.Builder
 
clone() - Method in class org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto.Builder
 
clone() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.Builder
 
clone() - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto.Builder
 
clone() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode.Builder
 
clone() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorArg.Builder
 
clone() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.ConstructorDef.Builder
 
clone() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode.Builder
 
clone() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.Node.Builder
 
clone() - Method in class org.apache.reef.tang.proto.ClassHierarchyProto.PackageNode.Builder
 
clone() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Constructor.Builder
 
clone() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan.Builder
 
clone() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Instance.Builder
 
clone() - Method in class org.apache.reef.tang.proto.InjectionPlanProto.Subplan.Builder
 
clone() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf.Builder
 
clone() - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf.Builder
 
clone() - Method in class org.apache.reef.wake.test.proto.TestProtos.TestEventPBuf.Builder
 
close() - Method in class org.apache.reef.client.DriverLauncher
Kills the running job.
close() - Method in interface org.apache.reef.client.REEF
Close the resourcemanager connection.
close() - Method in interface org.apache.reef.client.RunningJob
Cancels the running Job.
close(byte[]) - Method in interface org.apache.reef.client.RunningJob
Cancels the running Job.
close() - Method in interface org.apache.reef.driver.context.ActiveContext
 
close() - Method in interface org.apache.reef.driver.evaluator.AllocatedEvaluator
Releases the allocated evaluator back to the resource manager.
close() - Method in class org.apache.reef.driver.restart.DriverRestartManager
Close the restart timer.
close(byte[]) - Method in interface org.apache.reef.driver.task.RunningTask
Signal the task to shut down.
close() - Method in interface org.apache.reef.driver.task.RunningTask
Signal the task to shut down.
close() - Method in class org.apache.reef.examples.group.utils.timer.Timer
 
close() - Method in class org.apache.reef.examples.suspend.SuspendClientControl
 
close() - Method in interface org.apache.reef.io.Accumulator
 
close() - Method in interface org.apache.reef.io.data.output.OutputStreamProvider
release resources.
close() - Method in class org.apache.reef.io.data.output.TaskOutputStreamProviderHDFS
 
close() - Method in class org.apache.reef.io.data.output.TaskOutputStreamProviderLocal
 
close() - Method in interface org.apache.reef.io.network.Connection
Closes the connection.
close() - Method in class org.apache.reef.io.network.impl.NetworkConnectionServiceImpl
 
close() - Method in class org.apache.reef.io.network.impl.NetworkService
 
close() - Method in class org.apache.reef.io.network.naming.LocalNameResolverImpl
 
close() - Method in class org.apache.reef.io.network.naming.NameClient
Closes resources.
close() - Method in class org.apache.reef.io.network.naming.NameLookupClient
Closes resources.
close() - Method in class org.apache.reef.io.network.naming.NameRegistryClient
Closes resources.
close() - Method in class org.apache.reef.io.network.naming.NameServerImpl
Closes resources.
close() - Method in interface org.apache.reef.io.network.NetworkConnectionService
Closes all resources and unregisters all registered connection factories.
close() - Method in class org.apache.reef.io.storage.FramingOutputStream
 
close() - Method in class org.apache.reef.javabridge.ActiveContextBridge
 
close() - Method in class org.apache.reef.javabridge.AllocatedEvaluatorBridge
Closes the Java AllocatedEvaluator.
close() - Method in class org.apache.reef.javabridge.ClosedContextBridge
 
close() - Method in class org.apache.reef.javabridge.CompletedEvaluatorBridge
 
close() - Method in class org.apache.reef.javabridge.CompletedTaskBridge
 
close() - Method in class org.apache.reef.javabridge.ContextMessageBridge
 
close() - Method in class org.apache.reef.javabridge.DriverRestartedBridge
 
close() - Method in class org.apache.reef.javabridge.EvaluatorRequestorBridge
 
close() - Method in class org.apache.reef.javabridge.FailedContextBridge
 
close() - Method in class org.apache.reef.javabridge.FailedEvaluatorBridge
 
close() - Method in class org.apache.reef.javabridge.FailedTaskBridge
 
close() - Method in class org.apache.reef.javabridge.generic.DriverRestartCompletedBridge
 
close(long) - Method in class org.apache.reef.javabridge.generic.JobClient
 
close() - Method in class org.apache.reef.javabridge.HttpServerEventBridge
 
close(byte[]) - Method in class org.apache.reef.javabridge.RunningTaskBridge
 
close() - Method in class org.apache.reef.javabridge.RunningTaskBridge
 
close() - Method in class org.apache.reef.javabridge.SuspendedTaskBridge
 
close() - Method in class org.apache.reef.javabridge.TaskMessageBridge
 
close() - Method in class org.apache.reef.runtime.common.client.REEFImplementation
 
close() - Method in class org.apache.reef.runtime.common.client.RunningJobImpl
 
close(byte[]) - Method in class org.apache.reef.runtime.common.client.RunningJobImpl
 
close() - Method in class org.apache.reef.runtime.common.driver.context.EvaluatorContext
 
close() - Method in class org.apache.reef.runtime.common.driver.evaluator.AllocatedEvaluatorImpl
 
close() - Method in class org.apache.reef.runtime.common.driver.evaluator.EvaluatorIdlenessThreadPool
Shutdown the thread pool of idleness checkers.
close() - Method in class org.apache.reef.runtime.common.driver.evaluator.EvaluatorManager
 
close() - Method in class org.apache.reef.runtime.common.driver.evaluator.EvaluatorMessageDispatcher
 
close() - Method in class org.apache.reef.runtime.common.driver.evaluator.Evaluators
Closes all EvaluatorManager instances managed.
close() - Method in class org.apache.reef.runtime.common.driver.task.RunningTaskImpl
 
close(byte[]) - Method in class org.apache.reef.runtime.common.driver.task.RunningTaskImpl
 
close() - Method in class org.apache.reef.runtime.common.evaluator.context.ContextManager
Shuts down.
close() - Method in class org.apache.reef.runtime.common.evaluator.DefaultDriverConnection
 
close(byte[]) - Method in class org.apache.reef.runtime.common.evaluator.task.TaskRuntime
Close the Task.
close() - Method in class org.apache.reef.runtime.common.launch.REEFErrorHandler
 
close() - Method in class org.apache.reef.runtime.common.REEFEnvironment
Close and cleanup the environment.
close() - Method in class org.apache.reef.runtime.common.utils.DispatchingEStage
Close the stage adn stop accepting new messages.
close() - Method in class org.apache.reef.runtime.common.utils.RemoteManager
 
close() - Method in class org.apache.reef.runtime.hdinsight.client.HDInsightJobSubmissionHandler
 
close() - Method in class org.apache.reef.runtime.local.client.LocalJobSubmissionHandler
 
close() - Method in interface org.apache.reef.runtime.local.driver.Container
Kills the Container.
close() - Method in class org.apache.reef.runtime.local.driver.ProcessContainer
 
close() - Method in class org.apache.reef.runtime.standalone.driver.RemoteNodeManager
 
close() - Method in class org.apache.reef.runtime.yarn.client.YarnSubmissionHelper
 
close() - Method in class org.apache.reef.runtime.yarn.driver.REEFEventHandlers
 
close() - Method in class org.apache.reef.runtime.yarn.driver.restart.DFSEvaluatorLogAppendReaderWriter
Closes the FileSystem.
close() - Method in class org.apache.reef.runtime.yarn.driver.restart.DFSEvaluatorLogOverwriteReaderWriter
Closes the FileSystem.
close() - Method in class org.apache.reef.runtime.yarn.driver.restart.DFSEvaluatorPreserver
Closes the readerWriter, which in turn closes the FileSystem.
close() - Method in class org.apache.reef.tests.messaging.driver.DriverMessaging
 
close() - Method in class org.apache.reef.tests.TestDriverLauncher
 
close() - Method in class org.apache.reef.util.JARFileMaker
 
close() - Method in class org.apache.reef.util.logging.CLRBufferedLogHandler
Flushes the remaining buffered logs and shuts down the log scheduler thread.
close() - Method in class org.apache.reef.util.logging.DFSHandler
 
close() - Method in interface org.apache.reef.util.logging.LoggingScope
 
close() - Method in class org.apache.reef.util.logging.LoggingScopeImpl
The close() will be called when the object is to deleted.
close() - Method in class org.apache.reef.wake.examples.accumulate.CombinerStage
 
close() - Method in class org.apache.reef.wake.examples.join.TupleSource
 
close() - Method in class org.apache.reef.wake.examples.p2p.Pull2Push
 
close() - Method in class org.apache.reef.wake.impl.ForkPoolStage
 
close() - Method in class org.apache.reef.wake.impl.IndependentIterationsThreadPoolStage
 
close() - Method in class org.apache.reef.wake.impl.SingleThreadStage
Closes the stage.
close() - Method in class org.apache.reef.wake.impl.StageManager
 
close() - Method in class org.apache.reef.wake.impl.SyncStage
Closes resources.
close() - Method in class org.apache.reef.wake.impl.ThreadPoolStage
Closes resources.
close() - Method in class org.apache.reef.wake.impl.TimerStage
Closes resources.
close() - Method in class org.apache.reef.wake.impl.WakeSharedPool
 
close() - Method in class org.apache.reef.wake.remote.impl.DefaultRemoteManagerImplementation
 
close() - Method in class org.apache.reef.wake.remote.impl.DefaultTransportEStage
 
close() - Method in class org.apache.reef.wake.remote.impl.OrderedRemoteReceiverStage
 
close() - Method in class org.apache.reef.wake.remote.impl.RemoteReceiverStage
Closes the stage.
close() - Method in class org.apache.reef.wake.remote.impl.RemoteSenderStage
Closes the stage.
close() - Method in class org.apache.reef.wake.remote.impl.Subscription
Deprecated.
Unsubscribes this subscription.
close() - Method in class org.apache.reef.wake.remote.transport.netty.NettyMessagingTransport
Closes all channels and releases all resources.
close() - Method in class org.apache.reef.wake.rx.impl.RxSyncStage
Closes the stage.
close() - Method in class org.apache.reef.wake.rx.impl.RxThreadPoolStage
Closes the stage.
close() - Method in interface org.apache.reef.wake.time.Clock
This will stop the clock after all client alarms finish executing.
close() - Method in class org.apache.reef.wake.time.runtime.RuntimeClock
Wait for all client alarms to finish executing and gracefully shutdown the clock.
CloseableIterable<T> - Interface in org.apache.reef.util
An iterable that is closeable.
ClosedContext - Interface in org.apache.reef.driver.context
Represents a Context that has been closed successfully.
closedContext(String) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time in calling closedContext handler.
ClosedContextBridge - Class in org.apache.reef.javabridge
The Java-CLR bridge object for ClosedContext.
ClosedContextBridge(ClosedContext, ActiveContextBridgeFactory) - Constructor for class org.apache.reef.javabridge.ClosedContextBridge
 
ClosedContextImpl - Class in org.apache.reef.runtime.common.driver.context
Driver side representation of a closed context.
ClosedContextImpl(ActiveContext, String, String, EvaluatorDescriptor) - Constructor for class org.apache.reef.runtime.common.driver.context.ClosedContextImpl
 
CloseEvent - Interface in org.apache.reef.task.events
Indicates that the driver called .close() on this Task.
clrBufferedLog(int, String) - Static method in class org.apache.reef.javabridge.NativeInterop
 
CLRBufferedLogHandler - Class in org.apache.reef.util.logging
Logging Handler to intercept java logs and transfer them to the CLR side via the reef-bridge.
CLRBufferedLogHandler() - Constructor for class org.apache.reef.util.logging.CLRBufferedLogHandler
 
CLRLaunchCommandBuilder - Class in org.apache.reef.runtime.common.launch
A builder for the command line to launch a CLR Evaluator.
CLRLaunchCommandBuilder() - Constructor for class org.apache.reef.runtime.common.launch.CLRLaunchCommandBuilder
 
CLRLoggingConfig - Class in org.apache.reef.util.logging
Loader for CLR logging configuration.
CLRLoggingConfig() - Constructor for class org.apache.reef.util.logging.CLRLoggingConfig
 
CLRProcess - Class in org.apache.reef.driver.evaluator
Defines the setup of a CLR process.
CLRProcessFactory - Class in org.apache.reef.driver.evaluator
Factory to setup new CLR processes.
clrSystemActiveContextHandlerOnNext(long, ActiveContextBridge, InteropLogger) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemAllocatedEvaluatorHandlerOnNext(long, AllocatedEvaluatorBridge, InteropLogger) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemClosedContextHandlerOnNext(long, ClosedContextBridge) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemCompletedEvaluatorHandlerOnNext(long, CompletedEvaluatorBridge) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemCompletedTaskHandlerOnNext(long, CompletedTaskBridge, InteropLogger) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemContextMessageHandlerOnNext(long, ContextMessageBridge) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemDriverRestartActiveContextHandlerOnNext(long, ActiveContextBridge) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemDriverRestartCompletedHandlerOnNext(long, DriverRestartCompletedBridge) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemDriverRestartFailedEvaluatorHandlerOnNext(long, FailedEvaluatorBridge, InteropLogger) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemDriverRestartRunningTaskHandlerOnNext(long, RunningTaskBridge) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemFailedContextHandlerOnNext(long, FailedContextBridge) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemFailedEvaluatorHandlerOnNext(long, FailedEvaluatorBridge, InteropLogger) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemFailedTaskHandlerOnNext(long, FailedTaskBridge, InteropLogger) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemHttpServerHandlerOnNext(long, HttpServerEventBridge, InteropLogger) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemProgressProviderGetProgress(long) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemRunningTaskHandlerOnNext(long, RunningTaskBridge, InteropLogger) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemSetupBridgeHandlerManager(String, BridgeHandlerManager, EvaluatorRequestorBridge) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemSuspendedTaskHandlerOnNext(long, SuspendedTaskBridge) - Static method in class org.apache.reef.javabridge.NativeInterop
 
clrSystemTaskMessageHandlerOnNext(long, byte[], TaskMessageBridge, InteropLogger) - Static method in class org.apache.reef.javabridge.NativeInterop
 
CLUSTER_ID - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
CODEC - Static variable in class org.apache.reef.examples.hellohttp.HttpShellJobDriver
String codec is used to encode the results before passing them back to the client.
CODEC - Static variable in class org.apache.reef.examples.scheduler.driver.SchedulerDriver
 
Codec<T> - Interface in org.apache.reef.io.serialization
Interface for serialization routines that translate back and forth between byte arrays with low latency.
Codec<T> - Interface in org.apache.reef.wake.remote
Interface for serialization routines that translate back and forth between byte arrays with low latency.
CodecFileAccumulable<T,C extends Codec<T>> - Class in org.apache.reef.io.storage.local
 
CodecFileAccumulable(LocalStorageService, C) - Constructor for class org.apache.reef.io.storage.local.CodecFileAccumulable
 
CodecFileIterable<T,C extends Codec<T>> - Class in org.apache.reef.io.storage.local
A read-only spool implementation, based on files.
CodecFileIterable(File, C) - Constructor for class org.apache.reef.io.storage.local.CodecFileIterable
 
CodecRamMap<T> - Class in org.apache.reef.io.storage.ram
 
CodecRamMap(RamStorageService, Codec<T>) - Constructor for class org.apache.reef.io.storage.ram.CodecRamMap
 
CodecRamMap.RamMapCodec - Class in org.apache.reef.io.storage.ram
 
CodecRamMap.RamMapCodec() - Constructor for class org.apache.reef.io.storage.ram.CodecRamMap.RamMapCodec
 
CollectionUtils - Class in org.apache.reef.util
Utility functions for arrays and collection classes.
combine(K, V, V) - Method in interface org.apache.reef.wake.examples.accumulate.CombinerStage.Combiner
 
CombinerStage<K extends Comparable<K>,V> - Class in org.apache.reef.wake.examples.accumulate
key-value pair Combiner stage.
CombinerStage(CombinerStage.Combiner<K, V>, Observer<Map.Entry<K, V>>) - Constructor for class org.apache.reef.wake.examples.accumulate.CombinerStage
 
CombinerStage.Combiner<K extends Comparable<K>,V> - Interface in org.apache.reef.wake.examples.accumulate
key-value pair Combiner Interface.
CombinerStage.Pair<K extends Comparable<K>,V> - Class in org.apache.reef.wake.examples.accumulate
A comparable key-value pair.
CombinerStage.Pair(K, V) - Constructor for class org.apache.reef.wake.examples.accumulate.CombinerStage.Pair
 
Command - Class in org.apache.reef.examples.library
Command line parameter: a command to run, e.g.
Command() - Constructor for class org.apache.reef.examples.library.Command
 
COMMAND - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
command - Variable in class org.apache.reef.runtime.mesos.util.EvaluatorLaunch
Deprecated.
CommandLine - Class in org.apache.reef.tang.formats
 
CommandLine() - Constructor for class org.apache.reef.tang.formats.CommandLine
 
CommandLine(ConfigurationBuilder) - Constructor for class org.apache.reef.tang.formats.CommandLine
 
CommandLine.CommandLineCallback - Interface in org.apache.reef.tang.formats
 
commandLines - Variable in class org.apache.reef.io.watcher.driver.evaluator.AvroEvaluatorProcess
Deprecated.
Commands - Class in org.apache.reef.runtime.hdinsight.client.yarnrest
Commands used to start an Application Master via the YARN Resource Manger REST API.
Commands() - Constructor for class org.apache.reef.runtime.hdinsight.client.yarnrest.Commands
 
COMMANDS - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
CommandUtils - Class in org.apache.reef.util
run given command and return the result as string.
CommGroupMessageHandler - Class in org.apache.reef.io.network.group.impl.config.parameters
Name class of the comm group message handler.
CommGroupNameClass - Class in org.apache.reef.io.network.group.impl.config.parameters
NamedParameter wrapper for the name class of the comm group.
CommGroupNetworkHandler - Interface in org.apache.reef.io.network.group.api.task
The EventHandler that receives the GroupCommunicationMsg.
CommGroupNetworkHandlerImpl - Class in org.apache.reef.io.network.group.impl.task
 
CommGroupNetworkHandlerImpl() - Constructor for class org.apache.reef.io.network.group.impl.task.CommGroupNetworkHandlerImpl
 
CommGroupNumTask - Class in org.apache.reef.io.network.group.impl.config.parameters
Name class of the number of tasks in the comm group.
commit(CheckpointService.CheckpointWriteChannel) - Method in interface org.apache.reef.io.checkpoint.CheckpointService
Closes an existing checkpoint for writes and returns the CheckpointID that can be later used to get the read-only access to this checkpoint.
commit(CheckpointService.CheckpointWriteChannel) - Method in class org.apache.reef.io.checkpoint.fs.FSCheckpointService
 
CommonRuntimeConfiguration - Class in org.apache.reef.runtime.common.client
A ConfigurationModule to be merged in by all runtimes into their client configuration.
CommonRuntimeConfiguration() - Constructor for class org.apache.reef.runtime.common.client.CommonRuntimeConfiguration
 
CommunicationGroupClient - Interface in org.apache.reef.io.network.group.api.task
The Task side interface of a communication group.
CommunicationGroupClientImpl - Class in org.apache.reef.io.network.group.impl.task
 
CommunicationGroupDriver - Interface in org.apache.reef.io.network.group.api.driver
The driver side interface of a Communication Group Lets one add operators and tasks.
CommunicationGroupDriverFactory - Class in org.apache.reef.io.network.group.impl.driver
A factory used to create CommunicationGroupDriver instance.
CommunicationGroupDriverImpl - Class in org.apache.reef.io.network.group.impl.driver
 
CommunicationGroupDriverImpl(Class<? extends Name<String>>, ConfigurationSerializer, EStage<GroupCommunicationMessage>, BroadcastingEventHandler<RunningTask>, BroadcastingEventHandler<FailedTask>, BroadcastingEventHandler<FailedEvaluator>, BroadcastingEventHandler<GroupCommunicationMessage>, String, int, int) - Constructor for class org.apache.reef.io.network.group.impl.driver.CommunicationGroupDriverImpl
Deprecated.
in 0.14. Use Tang to obtain an instance of this instead.
CommunicationGroupName - Class in org.apache.reef.io.network.group.impl.config.parameters
 
CommunicationGroupServiceClient - Interface in org.apache.reef.io.network.group.api.task
 
ComparableIdentifier - Interface in org.apache.reef.wake
Identifier that can be totally ordered.
compare(Tuple<K, V>, Tuple<K, V>) - Method in class org.apache.reef.io.storage.util.TupleKeyComparator
 
compare(RemoteEvent<T>, RemoteEvent<T>) - Method in class org.apache.reef.wake.remote.impl.RemoteEventComparator
 
compareTo(NumberedSplit<E>) - Method in class org.apache.reef.io.data.loading.impl.NumberedSplit
 
compareTo(Identifier) - Method in class org.apache.reef.io.network.util.StringIdentifier
 
compareTo(Node) - Method in class org.apache.reef.tang.implementation.types.AbstractNode
 
compareTo(ConstructorDef<?>) - Method in class org.apache.reef.tang.implementation.types.ConstructorDefImpl
 
compareTo(Map.Entry<K, V>) - Method in class org.apache.reef.wake.examples.accumulate.CombinerStage.Pair
 
compareTo(TupleEvent) - Method in class org.apache.reef.wake.examples.join.TupleEvent
 
compareTo(Time) - Method in class org.apache.reef.wake.time.Time
 
COMPLETED - Static variable in class org.apache.reef.client.LauncherStatus
 
completed(int, TOutput) - Method in class org.apache.reef.vortex.api.VortexAggregateFuture
A Tasklet associated with the aggregation has completed.
completed(int, TOutput) - Method in class org.apache.reef.vortex.api.VortexFuture
Called by VortexMaster to let the user know that the Tasklet completed.
completed(int, TOutput) - Method in interface org.apache.reef.vortex.driver.VortexFutureDelegate
A Tasklet associated with the future has completed with a result.
CompletedEvaluator - Interface in org.apache.reef.driver.evaluator
Represents a successfully closed Evaluator.
CompletedEvaluatorBridge - Class in org.apache.reef.javabridge
The Java-CLR bridge object for CompletedEvaluator.
CompletedEvaluatorBridge(CompletedEvaluator) - Constructor for class org.apache.reef.javabridge.CompletedEvaluatorBridge
 
CompletedJob - Interface in org.apache.reef.client
Represents a completed REEF job.
CompletedTask - Interface in org.apache.reef.driver.task
Represents a completed Task.
CompletedTaskBridge - Class in org.apache.reef.javabridge
The Java-CLR bridge object for CompletedTask.
CompletedTaskBridge(CompletedTask, ActiveContextBridgeFactory) - Constructor for class org.apache.reef.javabridge.CompletedTaskBridge
 
CompletedTaskImpl - Class in org.apache.reef.runtime.common.driver.task
Implementation of CompletedTask.
CompletedTaskImpl(ActiveContext, byte[], String) - Constructor for class org.apache.reef.runtime.common.driver.task.CompletedTaskImpl
 
computeGradient(double, double) - Method in class org.apache.reef.examples.group.bgd.loss.LogisticLossFunction
 
computeGradient(double, double) - Method in interface org.apache.reef.examples.group.bgd.loss.LossFunction
Computes the gradient with respect to f, if y is the true label.
computeGradient(double, double) - Method in class org.apache.reef.examples.group.bgd.loss.SquaredErrorLossFunction
 
computeGradient(double, double) - Method in class org.apache.reef.examples.group.bgd.loss.WeightedLogisticLossFunction
 
computeLoss(double, double) - Method in class org.apache.reef.examples.group.bgd.loss.LogisticLossFunction
 
computeLoss(double, double) - Method in interface org.apache.reef.examples.group.bgd.loss.LossFunction
Computes the loss incurred by predicting f, if y is the true label.
computeLoss(double, double) - Method in class org.apache.reef.examples.group.bgd.loss.SquaredErrorLossFunction
 
computeLoss(double, double) - Method in class org.apache.reef.examples.group.bgd.loss.WeightedLogisticLossFunction
 
ConcurrentCountingMap<K,V> - Class in org.apache.reef.io.network.group.impl.utils
Utility map class that wraps a CountingMap.
ConcurrentCountingMap() - Constructor for class org.apache.reef.io.network.group.impl.utils.ConcurrentCountingMap
 
CONF - Static variable in class org.apache.reef.client.ClientConfiguration
 
CONF - Static variable in class org.apache.reef.client.DriverConfiguration
ConfigurationModule to fill out to get a legal Driver Configuration.
CONF - Static variable in class org.apache.reef.client.DriverRestartConfiguration
 
CONF - Static variable in class org.apache.reef.client.DriverServiceConfiguration
ConfigurationModule to fill out to get a legal Driver Configuration.
CONF - Static variable in class org.apache.reef.driver.context.ContextConfiguration
A ConfigurationModule for context.
CONF - Static variable in class org.apache.reef.driver.context.ServiceConfiguration
ConfigurationModule for services.
CONF - Static variable in class org.apache.reef.driver.task.TaskConfiguration
ConfigurationModule to fill out for a Task configuration.
CONF - Static variable in class org.apache.reef.io.checkpoint.fs.FSCheckPointServiceConfiguration
 
CONF - Static variable in class org.apache.reef.io.data.loading.api.DataLoadingDriverConfiguration
 
CONF - Static variable in class org.apache.reef.io.data.output.TaskOutputServiceBuilder
 
CONF - Static variable in class org.apache.reef.io.network.naming.LocalNameResolverConfiguration
 
CONF - Static variable in class org.apache.reef.io.network.naming.NameResolverConfiguration
 
CONF - Static variable in class org.apache.reef.io.network.naming.NameServerConfiguration
 
CONF - Static variable in class org.apache.reef.io.watcher.WatcherConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.common.client.CommonRuntimeConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.common.driver.DriverRuntimeConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.common.driver.DriverRuntimeRestartConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.common.evaluator.EvaluatorConfiguration
This is ConfigurationModule for Java Evaluator.
CONF - Static variable in class org.apache.reef.runtime.hdinsight.client.HDInsightDriverConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.hdinsight.client.HDInsightRuntimeConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.hdinsight.client.HDInsightRuntimeConfigurationStatic
 
CONF - Static variable in class org.apache.reef.runtime.hdinsight.client.UnsafeHDInsightRuntimeConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.hdinsight.client.UnsafeHDInsightRuntimeConfigurationStatic
 
CONF - Static variable in class org.apache.reef.runtime.local.client.ExtensibleLocalRuntimeConfiguration
The ConfigurationModule for the local resourcemanager.
CONF - Static variable in class org.apache.reef.runtime.local.client.LocalRuntimeConfiguration
The ConfigurationModule for the local resourcemanager.
CONF - Static variable in class org.apache.reef.runtime.local.driver.LocalDriverConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.mesos.client.MesosClientConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.mesos.driver.MesosDriverConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.multi.driver.MultiRuntimeDriverConfiguration
Hybrid driver configuration.
CONF - Static variable in class org.apache.reef.runtime.standalone.client.StandaloneRuntimeConfiguration
The ConfigurationModule for the standalone resourcemanager.
CONF - Static variable in class org.apache.reef.runtime.standalone.driver.StandaloneDriverConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.yarn.client.ExtensibleYarnClientConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.yarn.client.unmanaged.UnmanagedAmYarnClientConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.yarn.client.unmanaged.UnmanagedAmYarnDriverConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.yarn.client.YarnClientConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.yarn.client.YarnDriverConfiguration
ConfigurationModule to set YARN-Specific configuration options to be merged with DriverConfiguration.
CONF - Static variable in class org.apache.reef.runtime.yarn.driver.YarnDriverConfiguration
 
CONF - Static variable in class org.apache.reef.runtime.yarn.driver.YarnDriverRestartConfiguration
This event is fired in place of the ON_DRIVER_STARTED when the Driver is in fact restarted after failure.
CONF - Static variable in class org.apache.reef.tang.examples.timer.TimerMock
 
CONF - Static variable in class org.apache.reef.tests.driver.RuntimeNameTestConfiguration
 
CONF - Static variable in class org.apache.reef.vortex.driver.VortexMasterConf
Vortex Master configuration.
CONF - Static variable in class org.apache.reef.vortex.driver.VortexWorkerConf
Vortex Worker configuration.
CONF - Static variable in class org.apache.reef.webserver.HttpHandlerConfiguration
HttpHandlerConfiguration merged with HttpRuntimeConfiguration.
CONF - Static variable in class org.apache.reef.webserver.HttpRuntimeConfiguration
HttpRuntimeConfiguration.
CONFCLR - Static variable in class org.apache.reef.runtime.common.evaluator.EvaluatorConfiguration
This is ConfigurationModule for CLR Evaluator.
Config - Class in org.apache.reef.util.logging
Wrapper for logging config.
Config() - Constructor for class org.apache.reef.util.logging.Config
 
ConfigurableDirectoryTempFileCreator - Class in org.apache.reef.io
Creates temp files in a directory named "temp" within the configured directory.
Configuration - Interface in org.apache.reef.tang
Immutable, type-checked configuration data.
CONFIGURATION_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto
 
ConfigurationBuilder - Interface in org.apache.reef.tang
This class allows applications to register bindings with Tang.
configurationBuilderFromString(String, ConfigurationBuilder) - Method in class org.apache.reef.tang.formats.AvroConfigurationSerializer
Converts a given serialized string to ConfigurationBuilder from which Configuration can be produced.
ConfigurationBuilderImpl - Class in org.apache.reef.tang.implementation
 
ConfigurationEntry - Class in org.apache.reef.tang.formats.avro
 
ConfigurationEntry() - Constructor for class org.apache.reef.tang.formats.avro.ConfigurationEntry
Default constructor.
ConfigurationEntry(CharSequence, CharSequence) - Constructor for class org.apache.reef.tang.formats.avro.ConfigurationEntry
All-args constructor.
ConfigurationEntry.Builder - Class in org.apache.reef.tang.formats.avro
RecordBuilder for ConfigurationEntry instances.
ConfigurationImpl - Class in org.apache.reef.tang.implementation
 
ConfigurationModule - Class in org.apache.reef.tang.formats
Allows applications to bundle sets of configuration options together into discrete packages.
ConfigurationModuleBuilder - Class in org.apache.reef.tang.formats
 
ConfigurationProvider - Interface in org.apache.reef.tang
Objects that can provide a Configuration implement this interface.
Configurations - Class in org.apache.reef.tang
Helper class for Configurations.
ConfigurationSerializer - Interface in org.apache.reef.tang.formats
A base interface for Configuration serializers.
ConnectFutureTask<T> - Class in org.apache.reef.wake.remote.impl
FutureTask for network connection.
ConnectFutureTask(Callable<T>, EventHandler<ConnectFutureTask<T>>) - Constructor for class org.apache.reef.wake.remote.impl.ConnectFutureTask
 
Connection<T> - Interface in org.apache.reef.io.network
Connection between two end-points named by identifiers.
ConnectionFactory<T> - Interface in org.apache.reef.io.network
Factory that creates a new connection.
Constants - Class in org.apache.reef.bridge.client
Constant Configuration instances used by the bridge.
Constants - Class in org.apache.reef.runtime.common.utils
Constants used by different REEF modules.
Constants - Class in org.apache.reef.runtime.hdinsight.client.yarnrest
Constants used in serializing/deserializing REST calls to HDInsight's Resource Manager.
Constructor<T> - Class in org.apache.reef.tang.implementation
 
Constructor(ClassNode<T>, ConstructorDef<T>, InjectionPlan<?>[]) - Constructor for class org.apache.reef.tang.implementation.Constructor
 
CONSTRUCTOR_FIELD_NUMBER - Static variable in class org.apache.reef.tang.proto.InjectionPlanProto.InjectionPlan
 
ConstructorArg - Interface in org.apache.reef.tang.types
 
ConstructorArgImpl - Class in org.apache.reef.tang.implementation.types
 
ConstructorArgImpl(String, String, boolean) - Constructor for class org.apache.reef.tang.implementation.types.ConstructorArgImpl
 
constructorArgs - Variable in class org.apache.reef.tang.implementation.avro.AvroConstructorDef
Deprecated.
ConstructorDef<T> - Interface in org.apache.reef.tang.types
 
ConstructorDefImpl<T> - Class in org.apache.reef.tang.implementation.types
 
ConstructorDefImpl(String, ConstructorArg[], boolean) - Constructor for class org.apache.reef.tang.implementation.types.ConstructorDefImpl
 
Container - Interface in org.apache.reef.runtime.local.driver
Represents a Container: A slice of a machine.
CONTAINER_NAME - Static variable in class org.apache.reef.runtime.hdinsight.client.HDInsightRuntimeConfiguration
The Container name to be used by Azure.
CONTAINER_NAME - Static variable in class org.apache.reef.runtime.hdinsight.client.UnsafeHDInsightRuntimeConfiguration
The Container name to be used by Azure.
contains(K, V) - Method in class org.apache.reef.io.network.group.impl.utils.ConcurrentCountingMap
 
contains(K, V) - Method in class org.apache.reef.io.network.group.impl.utils.SetMap
 
contains(String) - Method in class org.apache.reef.tang.implementation.types.AbstractNode
 
contains(String) - Method in interface org.apache.reef.tang.types.Node
 
contains(K, V) - Method in class org.apache.reef.tang.util.AbstractMonotonicMultiMap
 
contains(Object) - Method in class org.apache.reef.tang.util.AbstractMonotonicMultiMap
 
containsAll(Collection<?>) - Method in class org.apache.reef.tang.util.AbstractMonotonicMultiMap
 
containsKey(CharSequence) - Method in interface org.apache.reef.io.ExternalMap
 
containsKey(K) - Method in class org.apache.reef.io.network.group.impl.utils.ConcurrentCountingMap
 
containsKey(L) - Method in class org.apache.reef.io.network.group.impl.utils.CountingMap
 
containsKey(K) - Method in class org.apache.reef.io.network.group.impl.utils.SetMap
 
containsKey(CharSequence) - Method in class org.apache.reef.io.storage.ram.CodecRamMap
 
containsKey(CharSequence) - Method in class org.apache.reef.io.storage.ram.RamMap
 
containsKey(K) - Method in class org.apache.reef.tang.util.AbstractMonotonicMultiMap
 
containsKey(Object) - Method in class org.apache.reef.tang.util.MonotonicTreeMap
 
containsKey(Object) - Method in class org.apache.reef.tang.util.TracingMonotonicTreeMap
 
containsValue(Object) - Method in class org.apache.reef.tang.util.MonotonicTreeMap
 
containsValue(Object) - Method in class org.apache.reef.tang.util.TracingMonotonicTreeMap
 
CONTEXT_CLOSE - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
CONTEXT_CONF - Static variable in class org.apache.reef.poison.PoisonedConfiguration
 
CONTEXT_CONFIGURATION_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto
 
CONTEXT_CONTROL_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto
 
CONTEXT_ID_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProto
 
CONTEXT_ID_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProto
 
CONTEXT_ID_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto
 
CONTEXT_ID_FIELD_NUMBER - Static variable in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto
 
CONTEXT_ID_FIELD_NUMBER - Static variable in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto
 
CONTEXT_MESSAGE - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
CONTEXT_MESSAGE_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto
 
CONTEXT_MESSAGE_FIELD_NUMBER - Static variable in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto
 
CONTEXT_STATE_FIELD_NUMBER - Static variable in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto
 
CONTEXT_STATUS_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto
 
ContextActiveHandlers - Class in org.apache.reef.driver.parameters
Handler for ActiveContext.
ContextAndTaskSubmittable - Interface in org.apache.reef.driver
Base interface for classes that support the simultaneous submission of both Context and Task configurations.
ContextBase - Interface in org.apache.reef.driver.context
A common base interface for all Driver-side representations of Contexts.
ContextClientCodeException - Exception in org.apache.reef.runtime.common.evaluator.context
Thrown when we encounter a problem with client code in a context.
ContextClientCodeException(String, Optional<String>, String, Throwable) - Constructor for exception org.apache.reef.runtime.common.evaluator.context.ContextClientCodeException
 
ContextClosedHandlers - Class in org.apache.reef.driver.parameters
Handler for ClosedContext.
ContextConfiguration - Class in org.apache.reef.driver.context
A ConfigurationModule for Context Configuration.
ContextConfiguration() - Constructor for class org.apache.reef.driver.context.ContextConfiguration
 
ContextConfiguration.DriverReconnect - Class in org.apache.reef.driver.context
Implementation for re-connecting to driver after driver restart.
ContextConfiguration.DriverReconnect() - Constructor for class org.apache.reef.driver.context.ContextConfiguration.DriverReconnect
 
ContextControlHandler - Class in org.apache.reef.runtime.common.driver.context
Handles context control messages.
ContextFailedHandlers - Class in org.apache.reef.driver.parameters
Handler for FailedContext.
contextId - Variable in class org.apache.reef.io.watcher.driver.task.AvroTaskMessage
Deprecated.
ContextIdentifier - Class in org.apache.reef.evaluator.context.parameters
Context identifier.
ContextIdentifier() - Constructor for class org.apache.reef.evaluator.context.parameters.ContextIdentifier
 
ContextManager - Class in org.apache.reef.runtime.common.evaluator.context
Manages the stack of context in the Evaluator.
ContextMessage - Interface in org.apache.reef.driver.context
Driver-side representation of a message sent by a Context to the Driver.
ContextMessage - Class in org.apache.reef.evaluator.context
Evaluator-side representation of a message sent from an Evaluator to a Driver.
ContextMessageBridge - Class in org.apache.reef.javabridge
The Java-CLR bridge object for ContextMessage.
ContextMessageBridge(ContextMessage) - Constructor for class org.apache.reef.javabridge.ContextMessageBridge
 
ContextMessageHandler - Interface in org.apache.reef.evaluator.context
Implement this interface to receive messages from the driver in a context.
ContextMessageHandlers - Class in org.apache.reef.driver.parameters
Context message handler.
ContextMessageHandlers - Class in org.apache.reef.evaluator.context.parameters
The set of Context message handlers.
ContextMessageHandlers() - Constructor for class org.apache.reef.evaluator.context.parameters.ContextMessageHandlers
 
ContextMessageImpl - Class in org.apache.reef.runtime.common.driver.context
Driver-side representation of a context message.
ContextMessageImpl(byte[], String, String, long) - Constructor for class org.apache.reef.runtime.common.driver.context.ContextMessageImpl
 
ContextMessagePOJO - Class in org.apache.reef.runtime.common.driver.evaluator.pojos
DriverSide representation of ContextMessageProto.
contextMessageReceived(String) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time in calling contextMessageReceivedHandler.
ContextMessageSource - Interface in org.apache.reef.evaluator.context
Message source for control flow messages from a context to the Driver.
ContextMessageSources - Class in org.apache.reef.evaluator.context.parameters
The set of ContextMessageSource implementations called during heartbeats.
ContextMessageSources() - Constructor for class org.apache.reef.evaluator.context.parameters.ContextMessageSources
 
ContextRepresenters - Class in org.apache.reef.runtime.common.driver.context
Driver-Side representation of all contexts on an Evaluator.
ContextRuntime - Class in org.apache.reef.runtime.common.evaluator.context
The evaluator side resourcemanager for Contexts.
contextStackIsEmpty() - Method in class org.apache.reef.runtime.common.evaluator.context.ContextManager
 
ContextStart - Interface in org.apache.reef.evaluator.context.events
This Event is fired when a Context is started.
ContextStartHandlers - Class in org.apache.reef.evaluator.context.parameters
The set of event handlers for the ContextStart event.
ContextStartHandlers() - Constructor for class org.apache.reef.evaluator.context.parameters.ContextStartHandlers
 
ContextState - Enum in org.apache.reef.runtime.common.driver.evaluator.pojos
DriverSide representation of ContextStatusProto.State.
ContextStatusPOJO - Class in org.apache.reef.runtime.common.driver.evaluator.pojos
DriverSide representation of ContextStatusProto.
ContextStatusPOJO(ReefServiceProtos.ContextStatusProto, long) - Constructor for class org.apache.reef.runtime.common.driver.evaluator.pojos.ContextStatusPOJO
 
ContextStop - Interface in org.apache.reef.evaluator.context.events
This event is fired when a Context is about to be closed.
ContextStopHandlers - Class in org.apache.reef.evaluator.context.parameters
The set of event handlers for the ContextStop event.
ContextStopHandlers() - Constructor for class org.apache.reef.evaluator.context.parameters.ContextStopHandlers
 
ContextSubmittable - Interface in org.apache.reef.driver
Base interface for classes that support Context submission.
Control - Class in org.apache.reef.examples.suspend
Control process which sends suspend/resume commands.
Control(int, String, String, TransportFactory) - Constructor for class org.apache.reef.examples.suspend.Control
 
Control.Command - Class in org.apache.reef.examples.suspend
Command: 'suspend' or 'resume'.
Control.Command() - Constructor for class org.apache.reef.examples.suspend.Control.Command
 
Control.TaskId - Class in org.apache.reef.examples.suspend
Task id.
Control.TaskId() - Constructor for class org.apache.reef.examples.suspend.Control.TaskId
 
ControlMessageBroadcaster - Class in org.apache.reef.examples.group.bgd.operatornames
Used to identify the broadcast operator for control flow messages.
ControlMessageBroadcaster() - Constructor for class org.apache.reef.examples.group.bgd.operatornames.ControlMessageBroadcaster
 
ControlMessageBroadcaster - Class in org.apache.reef.examples.group.broadcast.parameters
Control messages broadcaster.
ControlMessageBroadcaster() - Constructor for class org.apache.reef.examples.group.broadcast.parameters.ControlMessageBroadcaster
 
ControlMessages - Enum in org.apache.reef.examples.group.bgd
Control messages used in BGD example.
ControlMessages - Enum in org.apache.reef.examples.group.broadcast
Control messages used in broadcast example.
copy(Iterable<FileResource>, File) - Static method in class org.apache.reef.runtime.common.files.JobJarMaker
 
cores - Variable in class org.apache.reef.io.data.loading.avro.AvroEvaluatorRequest
Deprecated.
count(K) - Method in class org.apache.reef.io.network.group.impl.utils.SetMap
 
countDown() - Method in class org.apache.reef.io.network.group.impl.utils.ResettingCountDownLatch
 
Counter - Class in org.apache.reef.tests.statepassing
Simple counter.
Counter() - Constructor for class org.apache.reef.tests.statepassing.Counter
 
CountingMap<L> - Class in org.apache.reef.io.network.group.impl.utils
Utility class to provide a map that allows to add multiple keys and automatically incrementing the count on each add decrementing the count on each remove and removing key on count==0.
CountingMap() - Constructor for class org.apache.reef.io.network.group.impl.utils.CountingMap
 
CountingSemaphore - Class in org.apache.reef.io.network.group.impl.utils
 
CountingSemaphore(int, String, Object) - Constructor for class org.apache.reef.io.network.group.impl.utils.CountingSemaphore
 
CRASH_PROBABILITY - Static variable in class org.apache.reef.poison.PoisonedConfiguration
The probability with which a crash is to occur.
CRASH_TIMEOUT - Static variable in class org.apache.reef.poison.PoisonedConfiguration
The time window in seconds beginning at ContextStart during which the crash is to occur.
CrashProbability - Class in org.apache.reef.poison.params
The probability with which a crash will occur.
CrashTimeout - Class in org.apache.reef.poison.params
The time window after ContextStart in which the crash will occur.
create() - Method in interface org.apache.reef.io.checkpoint.CheckpointService
Creates a checkpoint and provides a channel to write to it.
create() - Method in class org.apache.reef.io.checkpoint.fs.FSCheckpointService
 
create(String) - Method in interface org.apache.reef.io.data.output.OutputStreamProvider
create an output stream using the given name.
create(String) - Method in class org.apache.reef.io.data.output.TaskOutputStreamProviderHDFS
create a file output stream using the given name.
create(String) - Method in class org.apache.reef.io.data.output.TaskOutputStreamProviderLocal
create a file output stream using the given name.
create(InType) - Method in interface org.apache.reef.io.serialization.Deserializer
Deserialize a stream of input.
create(OutType) - Method in interface org.apache.reef.io.serialization.Serializer
Serialize a stream of objects.
create(InputStream) - Method in class org.apache.reef.io.storage.FramingTupleDeserializer
 
create(OutputStream) - Method in class org.apache.reef.io.storage.FramingTupleSerializer
 
create(InputStream) - Method in class org.apache.reef.io.storage.util.IntegerDeserializer
 
create(OutputStream) - Method in class org.apache.reef.io.storage.util.IntegerSerializer
 
create(InputStream) - Method in class org.apache.reef.io.storage.util.StringDeserializer
 
create(OutputStream) - Method in class org.apache.reef.io.storage.util.StringSerializer
 
createAvroSchema() - Method in class org.apache.reef.experimental.parquet.ParquetReader
Retrieve avro schema from parquet file.
createChildAspect() - Method in interface org.apache.reef.tang.Aspect
This method creates a child aspect, and returns it.
createChildAspect() - Method in class org.apache.reef.wake.profiler.WakeProfiler
 
createExpectedEvaluatorInfo(ResourceRecoverEvent) - Static method in class org.apache.reef.driver.restart.EvaluatorRestartInfo
Creates an EvaluatorRestartInfo object that represents the information of an evaluator that is expected to recover.
createFailedEvaluatorInfo(String) - Static method in class org.apache.reef.driver.restart.EvaluatorRestartInfo
Creates an EvaluatorRestartInfo object that represents the information of an evaluator that has failed on driver restart.
createJobFolder(String) - Method in class org.apache.reef.runtime.yarn.client.uploader.JobUploader
Convenience override for int ids.
createJobFolder(int) - Method in class org.apache.reef.runtime.yarn.client.uploader.JobUploader
Convenience override for int ids.
createJobFolderWithApplicationId(String) - Method in class org.apache.reef.runtime.yarn.client.uploader.JobUploader
Creates the Job folder on the DFS.
createJobSubmissionJAR(JobSubmissionEvent, Configuration) - Method in class org.apache.reef.runtime.common.files.JobJarMaker
 
createNamedParameterNode(Node, Class<? extends Name<T>>, Type) - Static method in class org.apache.reef.tang.implementation.java.JavaNodeFactory
XXX: This method assumes that all generic types have exactly one type parameter.
createRootPackageNode() - Static method in class org.apache.reef.tang.implementation.java.JavaNodeFactory
 
createTempDirectory(String, FileAttribute<?>) - Method in class org.apache.reef.io.ConfigurableDirectoryTempFileCreator
 
createTempDirectory(String) - Method in class org.apache.reef.io.ConfigurableDirectoryTempFileCreator
 
createTempDirectory(String, FileAttribute<?>) - Method in class org.apache.reef.io.SystemTempFileCreator
 
createTempDirectory(String) - Method in class org.apache.reef.io.SystemTempFileCreator
 
createTempDirectory(String, FileAttribute<?>) - Method in interface org.apache.reef.io.TempFileCreator
Creates a temporary folder.
createTempDirectory(String) - Method in interface org.apache.reef.io.TempFileCreator
Create a temporary folder.
createTempDirectory(String, FileAttribute<?>) - Method in class org.apache.reef.io.WorkingDirectoryTempFileCreator
 
createTempDirectory(String) - Method in class org.apache.reef.io.WorkingDirectoryTempFileCreator
 
createTempFile(String, String) - Method in class org.apache.reef.io.ConfigurableDirectoryTempFileCreator
 
createTempFile(String, String) - Method in class org.apache.reef.io.SystemTempFileCreator
 
createTempFile(String, String) - Method in interface org.apache.reef.io.TempFileCreator
Creates a temporary file.
createTempFile(String, String) - Method in class org.apache.reef.io.WorkingDirectoryTempFileCreator
 
createUniformCounts(int, int) - Static method in class org.apache.reef.io.network.util.Utils
 
CREDENTIALS - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
Credentials - Class in org.apache.reef.runtime.hdinsight.client.yarnrest
Represents credentials for an application in the YARN REST API.
Credentials() - Constructor for class org.apache.reef.runtime.hdinsight.client.yarnrest.Credentials
 
CS - Static variable in class org.apache.reef.tang.formats.AvroConfigurationSerializer
 
CtrlMsgSender - Class in org.apache.reef.io.network.group.impl.driver
Event handler that receives ctrl msgs and.
CtrlMsgSender(IdentifierFactory, NetworkService<GroupCommunicationMessage>) - Constructor for class org.apache.reef.io.network.group.impl.driver.CtrlMsgSender
 
currentEdenMemoryUsageMB() - Static method in class org.apache.reef.util.MemoryUtils
 
currentOldMemoryUsageMB() - Static method in class org.apache.reef.util.MemoryUtils
 
currentPermMemoryUsageMB() - Static method in class org.apache.reef.util.MemoryUtils
 
CurrentTime - Interface in org.apache.reef.util.cache
Return the current time.

D

data - Variable in class org.apache.reef.io.watcher.common.AvroFailure
Deprecated.
data - Variable in class org.apache.reef.javabridge.avro.AvroFailedTask
Deprecated.
DATA_FIELD_NUMBER - Static variable in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupMessageBody
 
DATA_FIELD_NUMBER - Static variable in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf
 
DATA_FIELD_NUMBER - Static variable in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf
 
DATA_FIELD_NUMBER - Static variable in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf
 
DataCodec - Class in org.apache.reef.io.network.group.impl.config.parameters
 
DataLoader - Class in org.apache.reef.io.data.loading.api
The driver component for the DataLoadingService Also acts as the central point for resource requests All the allocated evaluators pass through this and the ones that need data loading have a context stacked that enables a task to get access to Data via the DataSet.
DataLoader(Clock, EvaluatorRequestor, DataLoadingService, Set<String>, Set<String>) - Constructor for class org.apache.reef.io.data.loading.api.DataLoader
Allows to specify compute and data evaluator requests in particular locations.
DataLoader.EvaluatorAllocatedHandler - Class in org.apache.reef.io.data.loading.api
 
DataLoader.EvaluatorAllocatedHandler() - Constructor for class org.apache.reef.io.data.loading.api.DataLoader.EvaluatorAllocatedHandler
 
DataLoader.EvaluatorFailedHandler - Class in org.apache.reef.io.data.loading.api
 
DataLoader.EvaluatorFailedHandler() - Constructor for class org.apache.reef.io.data.loading.api.DataLoader.EvaluatorFailedHandler
 
DataLoader.StartHandler - Class in org.apache.reef.io.data.loading.api
 
DataLoader.StartHandler() - Constructor for class org.apache.reef.io.data.loading.api.DataLoader.StartHandler
 
DataLoadingDriverConfiguration - Class in org.apache.reef.io.data.loading.api
 
DataLoadingDriverConfiguration() - Constructor for class org.apache.reef.io.data.loading.api.DataLoadingDriverConfiguration
 
DataLoadingREEF - Class in org.apache.reef.examples.data.loading
Client for the data loading demo app.
DataLoadingREEF.InputDir - Class in org.apache.reef.examples.data.loading
Input path.
DataLoadingREEF.InputDir() - Constructor for class org.apache.reef.examples.data.loading.DataLoadingREEF.InputDir
 
DataLoadingREEF.Local - Class in org.apache.reef.examples.data.loading
Command line parameter = true to run locally, or false to run on YARN.
DataLoadingREEF.Local() - Constructor for class org.apache.reef.examples.data.loading.DataLoadingREEF.Local
 
DataLoadingREEF.TimeOut - Class in org.apache.reef.examples.data.loading
Number of minutes before timeout.
DataLoadingREEF.TimeOut() - Constructor for class org.apache.reef.examples.data.loading.DataLoadingREEF.TimeOut
 
DataLoadingRequestBuilder - Class in org.apache.reef.io.data.loading.api
Builder to create a request to the DataLoadingService.
DataLoadingRequestBuilder() - Constructor for class org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder
 
DataLoadingRequestBuilder.LoadDataIntoMemory - Class in org.apache.reef.io.data.loading.api
 
DataLoadingRequestBuilder.LoadDataIntoMemory() - Constructor for class org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder.LoadDataIntoMemory
 
DataLoadingRequestBuilder.NumberOfDesiredSplits - Class in org.apache.reef.io.data.loading.api
 
DataLoadingRequestBuilder.NumberOfDesiredSplits() - Constructor for class org.apache.reef.io.data.loading.api.DataLoadingRequestBuilder.NumberOfDesiredSplits
 
DataLoadingService - Interface in org.apache.reef.io.data.loading.api
All data loading services should implement this interface.
DataSet<K,V> - Interface in org.apache.reef.io.data.loading.api
A view of the data set to be loaded at an evaluator as an iterable of key value pairs.
dateTime - Variable in class org.apache.reef.bridge.message.SystemOnStart
Deprecated.
decode(byte[]) - Method in class org.apache.reef.examples.group.utils.math.VectorCodec
 
decode(byte[]) - Method in class org.apache.reef.examples.suspend.ObjectWritableCodec
Decode Hadoop Writable object from a byte array.
decode(byte[], IdentifierFactory) - Static method in class org.apache.reef.io.network.group.impl.driver.TopologySerializer
Recursively translate a byte array into a TopologySimpleNode and a list of task Identifiers.
decode(byte[]) - Method in class org.apache.reef.io.network.group.impl.GroupChangesCodec
 
decode(byte[]) - Method in class org.apache.reef.io.network.group.impl.GroupCommunicationMessageCodec
 
decode(byte[]) - Method in class org.apache.reef.io.network.group.impl.utils.ScatterDecoder
 
decode(byte[]) - Method in class org.apache.reef.io.network.impl.NSMessageCodec
Decodes a network service message from bytes.
decode(byte[]) - Method in class org.apache.reef.io.network.naming.serialization.NamingLookupRequestCodec
Decodes the bytes to a naming lookup request.
decode(byte[]) - Method in class org.apache.reef.io.network.naming.serialization.NamingLookupResponseCodec
Decodes bytes to an iterable of name assignments.
decode(byte[]) - Method in class org.apache.reef.io.network.naming.serialization.NamingRegisterRequestCodec
Decodes the bytes to a name assignment.
decode(byte[]) - Method in class org.apache.reef.io.network.naming.serialization.NamingRegisterResponseCodec
Decodes a naming register response from the bytes.
decode(byte[]) - Method in class org.apache.reef.io.network.naming.serialization.NamingUnregisterRequestCodec
Decodes the bytes to a naming un-registration request.
decode(byte[]) - Method in class org.apache.reef.io.network.util.ListCodec
 
decode(byte[]) - Method in class org.apache.reef.io.network.util.StringCodec
 
decode(byte[]) - Method in interface org.apache.reef.io.serialization.Codec
Decodes the given byte array into an object.
decode(byte[]) - Method in class org.apache.reef.io.serialization.SerializableCodec
 
decode(byte[]) - Method in class org.apache.reef.io.storage.util.IntegerCodec
 
decode(byte[]) - Method in class org.apache.reef.runtime.common.launch.REEFMessageCodec
 
decode(byte[]) - Method in class org.apache.reef.runtime.mesos.util.MesosRemoteManagerCodec
 
decode(byte[]) - Method in interface org.apache.reef.wake.remote.Decoder
Decodes the given byte array into an object.
decode(byte[]) - Method in class org.apache.reef.wake.remote.impl.ByteCodec
Returns the byte array argument.
decode(byte[]) - Method in class org.apache.reef.wake.remote.impl.MultiCodec
Decodes byte array.
decode(byte[]) - Method in class org.apache.reef.wake.remote.impl.MultiDecoder
Decodes byte array.
decode(byte[]) - Method in class org.apache.reef.wake.remote.impl.ObjectSerializableCodec
Decodes an object from the bytes.
decode(byte[]) - Method in class org.apache.reef.wake.remote.impl.RemoteEventCodec
Decodes a remote event object from the bytes.
decode(byte[]) - Method in class org.apache.reef.wake.remote.impl.RemoteEventDecoder
Decodes a remote event from the byte array data.
decode(byte[]) - Method in class org.apache.reef.wake.remote.impl.StringCodec
Returns a string decoded from the byte array.
decodeFromStream(DataInputStream) - Method in class org.apache.reef.io.network.group.impl.GroupCommunicationMessageCodec
 
decodeFromStream(DataInputStream) - Method in interface org.apache.reef.io.network.impl.StreamingCodec
 
Decoder<T> - Interface in org.apache.reef.wake.remote
Interface for serialization routines that translate back and forth between byte arrays with low latency.
decrement() - Method in class org.apache.reef.io.network.group.impl.utils.CountingSemaphore
 
DEFAULT - Static variable in class org.apache.reef.driver.parameters.DriverRestartEvaluatorRecoverySeconds
Default restart wait for the driver is 3 minutes.
DEFAULT_APPLICATION_TYPE - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationSubmission
 
DEFAULT_COMMAND - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Commands
 
DEFAULT_IMPLEMENTATION_FIELD_NUMBER - Static variable in class org.apache.reef.tang.proto.ClassHierarchyProto.ClassNode
 
DEFAULT_KEEP_CONTAINERS_ACROSS_APPLICATION_ATTEMPTS - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationSubmission
 
DEFAULT_MAX_APP_ATTEMPTS - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationSubmission
 
DEFAULT_PRIORITY - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationSubmission
 
DEFAULT_QUEUE - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationSubmission
 
DEFAULT_RACK - Static variable in class org.apache.reef.runtime.common.driver.catalog.ResourceCatalogImpl
 
DEFAULT_RACK_NAME - Static variable in class org.apache.reef.runtime.local.client.parameters.RackNames
 
DEFAULT_UNMANAGED_AM - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.ApplicationSubmission
 
DEFAULT_VALUE - Static variable in class org.apache.reef.driver.parameters.DriverIdentifier
 
DEFAULT_VALUE - Static variable in class org.apache.reef.poison.params.CrashProbability
 
DEFAULT_VALUE - Static variable in class org.apache.reef.poison.params.CrashTimeout
 
DEFAULT_VALUE - Static variable in class org.apache.reef.runtime.local.client.parameters.RootFolder
 
DEFAULT_VALUE - Static variable in class org.apache.reef.runtime.standalone.client.parameters.NodeFolder
 
DEFAULT_VALUE - Static variable in class org.apache.reef.runtime.standalone.client.parameters.RootFolder
 
DEFAULT_VALUE - Static variable in class org.apache.reef.runtime.yarn.client.parameters.RootFolder
 
DEFAULT_VALUE - Static variable in class org.apache.reef.runtime.yarn.driver.parameters.FileSystemUrl
 
DEFAULT_VALUE - Static variable in class org.apache.reef.wake.remote.ports.parameters.TcpPortRangeBegin
 
DEFAULT_VALUE - Static variable in class org.apache.reef.wake.remote.ports.parameters.TcpPortRangeCount
 
DEFAULT_VALUE - Static variable in class org.apache.reef.wake.remote.ports.parameters.TcpPortRangeTryCount
 
DefaultClientCloseHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default handler for close messages from the client: Throw an Exception.
DefaultClientCloseWithMessageHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default handler for close messages from the client: Throw an Exception.
DefaultClientCloseWithMessageHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultClientCloseWithMessageHandler
 
DefaultClientConstructor - Class in org.apache.reef.runtime.hdinsight.client.sslhacks
Default Client constructor with default SSL checks.
DefaultClientMessageHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler for Client messages: Logging it.
DefaultClientMessageHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultClientMessageHandler
 
DefaultCloseHandler - Class in org.apache.reef.runtime.common.evaluator.task.defaults
Default implementation for EventHandler<CloseEvent>.
DefaultCloseHandler() - Constructor for class org.apache.reef.runtime.common.evaluator.task.defaults.DefaultCloseHandler
 
DefaultCompletedJobHandler - Class in org.apache.reef.runtime.common.client.defaults
Default event handler for CompletedJob: Logging it.
DefaultContextActiveHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default handler for ActiveContext: Close it.
DefaultContextClosureHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler for ClosedContext: Logging it.
DefaultContextClosureHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultContextClosureHandler
 
DefaultContextFailureHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler used for FailedContext: It crashes the driver.
DefaultContextFailureHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultContextFailureHandler
 
DefaultContextMessageHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler for ContextMessage: Logging it.
DefaultContextMessageHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultContextMessageHandler
 
DefaultContextMessageHandler - Class in org.apache.reef.runtime.common.evaluator.context.defaults
Default handler for messages sent by the driver: Crash the context.
DefaultContextMessageSource - Class in org.apache.reef.runtime.common.evaluator.context.defaults
Default ContextMessageSource: return nothing.
DefaultContextMessageSource() - Constructor for class org.apache.reef.runtime.common.evaluator.context.defaults.DefaultContextMessageSource
 
DefaultContextStartHandler - Class in org.apache.reef.runtime.common.evaluator.context.defaults
Default handler for ContextStart.
DefaultContextStopHandler - Class in org.apache.reef.runtime.common.evaluator.context.defaults
Default event handler for ContextStop.
DefaultDriverConnection - Class in org.apache.reef.runtime.common.evaluator
Default implementation for re-establishing connection to driver after driver restart.
DefaultDriverConnection() - Constructor for class org.apache.reef.runtime.common.evaluator.DefaultDriverConnection
 
DefaultDriverMessageHandler - Class in org.apache.reef.runtime.common.evaluator.task.defaults
A default implementation of EventHandler<DriverMessage>.
DefaultDriverMessageHandler() - Constructor for class org.apache.reef.runtime.common.evaluator.task.defaults.DefaultDriverMessageHandler
 
DefaultDriverRestartCompletedHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default handler for driver restart completed event: log it.
DefaultDriverRestartContextActiveHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default handler for ActiveContext from previous evaluator during driver restart: Close it.
DefaultDriverRestartTaskRunningHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler for Task Restart TaskRuntime: Logging it.
DefaultDriverRestartTaskRunningHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultDriverRestartTaskRunningHandler
 
DefaultEvaluatorAllocationHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default handler for AllocatedEvaluator: close it.
DefaultEvaluatorAllocationHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultEvaluatorAllocationHandler
 
DefaultEvaluatorCompletionHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler for CompletedEvaluator: Logging it.
DefaultEvaluatorCompletionHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultEvaluatorCompletionHandler
 
DefaultEvaluatorFailureHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler used for FailedEvaluator: It crashes the driver.
DefaultEvaluatorFailureHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultEvaluatorFailureHandler
 
DefaultFailedJobHandler - Class in org.apache.reef.runtime.common.client.defaults
Default event handler for FailedJob: rethrow the exception.
DefaultIdentifierFactory - Class in org.apache.reef.wake.impl
Default remote identifier factory that creates a specific remote identifier from a string representation.
DefaultIdentifierFactory() - Constructor for class org.apache.reef.wake.impl.DefaultIdentifierFactory
Constructs a default remote identifier factory.
DefaultIdentifierFactory(Map<String, Class<? extends Identifier>>) - Constructor for class org.apache.reef.wake.impl.DefaultIdentifierFactory
Constructs a default remote identifier factory.
DefaultImplementation - Annotation Type in org.apache.reef.tang.annotations
Allows interfaces to specify a default implementation.
defaultImplementation - Variable in class org.apache.reef.tang.implementation.avro.AvroClassNode
Deprecated.
DefaultJobMessageHandler - Class in org.apache.reef.runtime.common.client.defaults
Default event handler for job message: Logging it.
DefaultMemorySize - Class in org.apache.reef.runtime.local.client.parameters
The size of the default container returned in MB.
DefaultMemorySize() - Constructor for class org.apache.reef.runtime.local.client.parameters.DefaultMemorySize
 
DefaultNumberOfCores - Class in org.apache.reef.runtime.local.client.parameters
The number of the default core.
DefaultNumberOfCores() - Constructor for class org.apache.reef.runtime.local.client.parameters.DefaultNumberOfCores
 
DefaultProgressProvider - Class in org.apache.reef.driver
The default implementation of ProgressProvider.
DefaultRackNameFormatter - Class in org.apache.reef.runtime.yarn.driver
Default implementation of rack names formatter.
DefaultRemoteIdentifierFactoryImplementation - Class in org.apache.reef.wake.remote.impl
A default implementation for RemoteIdentifierFactory interface.
DefaultRemoteIdentifierFactoryImplementation() - Constructor for class org.apache.reef.wake.remote.impl.DefaultRemoteIdentifierFactoryImplementation
 
DefaultRemoteIdentifierFactoryImplementation(Map<String, Class<? extends RemoteIdentifier>>) - Constructor for class org.apache.reef.wake.remote.impl.DefaultRemoteIdentifierFactoryImplementation
 
DefaultRemoteManagerImplementation - Class in org.apache.reef.wake.remote.impl
Default remote manager implementation.
DefaultRunningJobHandler - Class in org.apache.reef.runtime.common.client.defaults
Default event handler for RunningJob: Logging it.
DefaultRuntimeErrorHandler - Class in org.apache.reef.runtime.common.client.defaults
Default event handler for REEF FailedRuntime: rethrow the exception.
defaultRuntimeName - Variable in class org.apache.reef.reef.bridge.client.avro.AvroMultiRuntimeAppSubmissionParameters
Deprecated.
DefaultRuntimeName - Class in org.apache.reef.runtime.multi.client.parameters
Serialized tang configuration for a runtime.
DefaultRuntimeName() - Constructor for class org.apache.reef.runtime.multi.client.parameters.DefaultRuntimeName
 
defaultRuntimeName - Variable in class org.apache.reef.runtime.multi.utils.avro.AvroMultiRuntimeDefinition
Deprecated.
DefaultSubmittedJobHandler - Class in org.apache.reef.runtime.common.client.defaults
Default event handler for SubmittedJob: Log the new job ID.
DefaultSuspendHandler - Class in org.apache.reef.runtime.common.evaluator.task.defaults
Default handler for SuspendEvent.
DefaultSuspendHandler() - Constructor for class org.apache.reef.runtime.common.evaluator.task.defaults.DefaultSuspendHandler
 
DefaultTaskCompletionHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler for CompletedTask: Log it and close the context.
DefaultTaskCompletionHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultTaskCompletionHandler
 
DefaultTaskFailureHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler used for FailedTask: It crashes the driver.
DefaultTaskFailureHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultTaskFailureHandler
 
DefaultTaskMessageHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler for TaskMessage: Logging it.
DefaultTaskMessageHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultTaskMessageHandler
 
DefaultTaskRunningHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler for TaskRuntime: Logging it.
DefaultTaskRunningHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultTaskRunningHandler
 
DefaultTaskSuspensionHandler - Class in org.apache.reef.runtime.common.driver.defaults
Default event handler used for SuspendedTask: It crashes the driver.
DefaultTaskSuspensionHandler() - Constructor for class org.apache.reef.runtime.common.driver.defaults.DefaultTaskSuspensionHandler
 
DefaultThreadFactory - Class in org.apache.reef.wake.impl
A default thread factory implementation that names created threads.
DefaultThreadFactory(String) - Constructor for class org.apache.reef.wake.impl.DefaultThreadFactory
Constructs a default thread factory.
DefaultThreadFactory(String, Thread.UncaughtExceptionHandler) - Constructor for class org.apache.reef.wake.impl.DefaultThreadFactory
Constructs a default thread factory.
DefaultTransportEStage - Class in org.apache.reef.wake.remote.impl
A default event-based message transporting stage for both client and server.
DefaultTransportEStage() - Constructor for class org.apache.reef.wake.remote.impl.DefaultTransportEStage
 
DefaultUserCredentials - Class in org.apache.reef.runtime.common.client.defaults
A holder object for REEF user credentials.
DefinedRuntimes - Class in org.apache.reef.javabridge.avro
 
DefinedRuntimes() - Constructor for class org.apache.reef.javabridge.avro.DefinedRuntimes
Default constructor.
DefinedRuntimes(List<CharSequence>) - Constructor for class org.apache.reef.javabridge.avro.DefinedRuntimes
All-args constructor.
DefinedRuntimes - Class in org.apache.reef.runtime.common.driver.parameters
The defined runtimes for the job driver.
DefinedRuntimes() - Constructor for class org.apache.reef.runtime.common.driver.parameters.DefinedRuntimes
 
DefinedRuntimes.Builder - Class in org.apache.reef.javabridge.avro
RecordBuilder for DefinedRuntimes instances.
DefinedRuntimesSerializer - Class in org.apache.reef.javabridge.utils
Serializer for MultiRuntimeDefinition.
DefinedRuntimesSerializer() - Constructor for class org.apache.reef.javabridge.utils.DefinedRuntimesSerializer
 
delete(CheckpointID) - Method in interface org.apache.reef.io.checkpoint.CheckpointService
Discards an existing checkpoint identified by its CheckpointID.
delete(CheckpointID) - Method in class org.apache.reef.io.checkpoint.fs.FSCheckpointService
 
delete() - Method in class org.apache.reef.io.storage.local.LocalScratchSpace
 
delete() - Method in interface org.apache.reef.io.storage.ScratchSpace
 
DeleteTempFiles - Class in org.apache.reef.runtime.common.parameters
Whether or not to delete the temporary files created during Driver and Evaluator submission.
deliver(byte[]) - Method in class org.apache.reef.runtime.common.evaluator.task.TaskRuntime
Deliver a message to the Task.
DenseVector - Class in org.apache.reef.examples.group.utils.math
A dense Vector implementation backed by a double[].
DenseVector(int) - Constructor for class org.apache.reef.examples.group.utils.math.DenseVector
Creates a dense vector of the given size.
DenseVector(double[]) - Constructor for class org.apache.reef.examples.group.utils.math.DenseVector
 
DenseVector(ImmutableVector) - Constructor for class org.apache.reef.examples.group.utils.math.DenseVector
Instantiates a new DenseVector by copying the given other vector.
DenseVector(DenseVector) - Constructor for class org.apache.reef.examples.group.utils.math.DenseVector
 
DescentDirectionBroadcaster - Class in org.apache.reef.examples.group.bgd.operatornames
Name of the broadcast operator used to send descent directions during linesearch.
DescentDirectionBroadcaster() - Constructor for class org.apache.reef.examples.group.bgd.operatornames.DescentDirectionBroadcaster
 
description - Variable in class org.apache.reef.io.watcher.common.AvroFailure
Deprecated.
deserialize(String) - Static method in class org.apache.reef.io.data.loading.impl.DistributedDataSetPartitionSerializer
 
deserialize(String) - Static method in class org.apache.reef.io.data.loading.impl.WritableSerializer
 
deserialize(String, JobConf) - Static method in class org.apache.reef.io.data.loading.impl.WritableSerializer
 
deserialize(File) - Static method in class org.apache.reef.tang.implementation.protobuf.ProtocolBufferClassHierarchy
Deprecated.
in 0.12. Use AvroClassHierarchySerializer instead
deserialize(ClassHierarchy, InjectionPlanProto.InjectionPlan) - Method in class org.apache.reef.tang.implementation.protobuf.ProtocolBufferInjectionPlan
 
deserialize(byte[]) - Method in class org.apache.reef.vortex.common.KryoUtils
 
Deserializer<ObjectType,InType> - Interface in org.apache.reef.io.serialization
Stream-based multi-object deserialization interface.
DESTID_FIELD_NUMBER - Static variable in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage
 
DESTID_FIELD_NUMBER - Static variable in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf
 
detectRestart() - Method in class org.apache.reef.driver.restart.DriverRestartManager
Triggers the state machine if the application is a restart instance.
DFS_PATH_OPTION - Static variable in class org.apache.reef.util.logging.DFSHandler
 
DFSEvaluatorLogAppendReaderWriter - Class in org.apache.reef.runtime.yarn.driver.restart
The DFS evaluator logger that performs regular append.
DFSEvaluatorLogOverwriteReaderWriter - Class in org.apache.reef.runtime.yarn.driver.restart
The DFS evaluator logger that does not support append and does append by overwrite.
DFSEvaluatorLogReaderWriter - Interface in org.apache.reef.runtime.yarn.driver.restart
The Evaluator log reader/writer that reads from and writes to the Hadoop DFS.
DFSEvaluatorPreserver - Class in org.apache.reef.runtime.yarn.driver.restart
An Evaluator Preserver that uses the DFS on YARN.
DFSHandler - Class in org.apache.reef.util.logging
A java.util.logging.Handler that logs to (H)DFS.
DFSHandler() - Constructor for class org.apache.reef.util.logging.DFSHandler
 
dfsJobSubmissionFolder - Variable in class org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters
Deprecated.
DIAGNOSTICS - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
Dimensions - Class in org.apache.reef.examples.group.broadcast.parameters
 
Dimensions() - Constructor for class org.apache.reef.examples.group.broadcast.parameters.Dimensions
 
disconnected(ExecutorDriver) - Method in class org.apache.reef.runtime.mesos.evaluator.REEFExecutor
 
DispatchingEStage - Class in org.apache.reef.runtime.common.utils
Delayed event router that dispatches messages to the proper event handler by type.
DispatchingEStage(EventHandler<Throwable>, int, String) - Constructor for class org.apache.reef.runtime.common.utils.DispatchingEStage
 
DispatchingEStage(DispatchingEStage) - Constructor for class org.apache.reef.runtime.common.utils.DispatchingEStage
Constructs a DispatchingEStage that uses the Thread pool and ErrorHandler of another one.
DistributedDataSet - Class in org.apache.reef.io.data.loading.api
Represents a distributed data set that is split across data centers.
DistributedDataSet() - Constructor for class org.apache.reef.io.data.loading.api.DistributedDataSet
 
DistributedDataSetPartition - Class in org.apache.reef.io.data.loading.impl
POJO that represents a distributed data set partition.
DistributedDataSetPartition.Builder - Class in org.apache.reef.io.data.loading.impl
DistributedDataSetPartitions are build using this Builder.
DistributedDataSetPartitionSerializer - Class in org.apache.reef.io.data.loading.impl
Serialize and deserialize DistributedDataSetPartition objects.
DistributedDataSetPartitionSerializer.DistributedDataSetPartitions - Class in org.apache.reef.io.data.loading.impl
Allows to specify a set of distributed data set partitions.
DistributedDataSetPartitionSerializer.DistributedDataSetPartitions() - Constructor for class org.apache.reef.io.data.loading.impl.DistributedDataSetPartitionSerializer.DistributedDataSetPartitions
 
doAs(PrivilegedExceptionAction<T>) - Method in class org.apache.reef.runtime.common.client.defaults.DefaultUserCredentials
Execute the privileged action as a given user.
doAs(PrivilegedExceptionAction<T>) - Method in interface org.apache.reef.runtime.common.UserCredentials
Execute the privileged action as a given user.
doAs(PrivilegedExceptionAction<T>) - Method in class org.apache.reef.runtime.yarn.client.unmanaged.YarnProxyUser
Execute the privileged action as a given user.
documentation - Variable in class org.apache.reef.tang.implementation.avro.AvroNamedParameterNode
Deprecated.
DOCUMENTATION_FIELD_NUMBER - Static variable in class org.apache.reef.tang.proto.ClassHierarchyProto.NamedParameterNode
 
DONE_EVALUATOR_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto
 
DONE_VALUE - Static variable in enum org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.State
DONE = 1;
DONE_VALUE - Static variable in enum org.apache.reef.proto.ReefServiceProtos.State
DONE = 2;
dot(Vector) - Method in interface org.apache.reef.examples.group.utils.math.ImmutableVector
Computes the inner product with another Vector.
Driver - Class in org.apache.reef.tests.fail.task
Universal driver for the test REEF job that fails on different stages of execution.
Driver(String, EvaluatorRequestor) - Constructor for class org.apache.reef.tests.fail.task.Driver
 
Driver.FailTaskName - Class in org.apache.reef.tests.fail.task
Name of the message class to specify the failing message handler.
Driver.FailTaskName() - Constructor for class org.apache.reef.tests.fail.task.Driver.FailTaskName
 
DRIVER_CONFIGURATION - Static variable in class org.apache.reef.bridge.client.Constants
Contains all bindings of event handlers to the bridge.
DRIVER_CONFIGURATION_PROVIDER - Static variable in class org.apache.reef.runtime.local.client.ExtensibleLocalRuntimeConfiguration
Driver configuration provider for the client.
DRIVER_CONFIGURATION_PROVIDER - Static variable in class org.apache.reef.runtime.yarn.client.ExtensibleYarnClientConfiguration
Driver configuration provider for the client.
DRIVER_CONFIGURATION_PROVIDERS - Static variable in class org.apache.reef.runtime.local.client.ExtensibleLocalRuntimeConfiguration
Configuration provides whose Configuration will be merged into all Driver Configuration.
DRIVER_CONFIGURATION_PROVIDERS - Static variable in class org.apache.reef.runtime.local.client.LocalRuntimeConfiguration
Configuration provides whose Configuration will be merged into all Driver Configuration.
DRIVER_CONFIGURATION_PROVIDERS - Static variable in class org.apache.reef.runtime.standalone.client.StandaloneRuntimeConfiguration
Configuration provides whose Configuration will be merged into all Driver Configuration.
DRIVER_CONFIGURATION_PROVIDERS - Static variable in class org.apache.reef.runtime.yarn.client.ExtensibleYarnClientConfiguration
Configuration provides whose Configuration will be merged into all Driver Configuration.
DRIVER_CONFIGURATION_PROVIDERS - Static variable in class org.apache.reef.runtime.yarn.client.unmanaged.UnmanagedAmYarnClientConfiguration
Configuration provides whose Configuration will be merged into all Driver Configuration.
DRIVER_CONFIGURATION_PROVIDERS - Static variable in class org.apache.reef.runtime.yarn.client.YarnClientConfiguration
Configuration provides whose Configuration will be merged into all Driver Configuration.
DRIVER_CONFIGURATION_WITH_HTTP_AND_NAMESERVER - Static variable in class org.apache.reef.bridge.client.Constants
The driver configuration assumed by the the bridge.
DRIVER_FOLDER_NAME - Static variable in class org.apache.reef.runtime.local.client.PreparedDriverFolderLauncher
The name of the folder for the driver within the Job folder.
DRIVER_IDENTIFIER - Static variable in class org.apache.reef.client.DriverConfiguration
Identifies the driver and therefore the JOB.
DRIVER_JOB_SUBMISSION_DIRECTORY - Static variable in class org.apache.reef.client.DriverConfiguration
Job submission directory to be used by driver.
DRIVER_MEMORY - Static variable in class org.apache.reef.client.DriverConfiguration
The amount of memory to be allocated for the Driver.
DRIVER_MEMORY - Static variable in class org.apache.reef.runtime.local.client.PreparedDriverFolderLauncher
The (hard-coded) amount of memory to be used for the driver.
DRIVER_REMOTE_IDENTIFIER - Static variable in class org.apache.reef.runtime.common.evaluator.EvaluatorConfiguration
 
DRIVER_RESTART - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
DRIVER_RESTART_ACTIVE_CONTEXT - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
DRIVER_RESTART_COMPLETE - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
DRIVER_RESTART_EVALUATOR_RECOVERY_SECONDS - Static variable in class org.apache.reef.client.DriverRestartConfiguration
The amount of time in seconds the driver waits for evaluators to report back on restart.
DRIVER_RESTART_RUNNING_TASK - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
DRIVER_START - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
DRIVER_STOP - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
DRIVER_SUBMIT - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
DriverConfiguration - Class in org.apache.reef.client
A ConfigurationModule for Drivers.
DriverConfiguration() - Constructor for class org.apache.reef.client.DriverConfiguration
 
DriverConfigurationProvider - Interface in org.apache.reef.runtime.common.client
A contract for driver configuration provider.
DriverConfigurationProviders - Class in org.apache.reef.client.parameters
Configuration provides whose Configurations will be mixed into the Driver Configuration.
DriverConfigurationProviders() - Constructor for class org.apache.reef.client.parameters.DriverConfigurationProviders
 
DriverConnection - Interface in org.apache.reef.runtime.common.evaluator
Interface used for reconnecting to driver after driver restart.
DriverException - Exception in org.apache.reef.exception
Thrown by the Driver and to the clients of REEF.
DriverException() - Constructor for exception org.apache.reef.exception.DriverException
Standard Exception constructor.
DriverException(String, Throwable) - Constructor for exception org.apache.reef.exception.DriverException
Standard Exception constructor.
DriverException(String) - Constructor for exception org.apache.reef.exception.DriverException
Standard Exception constructor.
DriverException(Throwable) - Constructor for exception org.apache.reef.exception.DriverException
Standard Exception constructor.
DriverExceptionHandler - Class in org.apache.reef.runtime.common.driver
Exception handler for exceptions thrown by client code in the Driver.
DriverExceptionHandler(DriverStatusManager) - Constructor for class org.apache.reef.runtime.common.driver.DriverExceptionHandler
 
DriverFailOnFail - Class in org.apache.reef.tests.fail.driver
Driver which fails on FailedTask event.
DriverFailOnFail(JobMessageObserver, EvaluatorRequestor) - Constructor for class org.apache.reef.tests.fail.driver.DriverFailOnFail
 
DriverFailOnFail.AllocatedEvaluatorHandler - Class in org.apache.reef.tests.fail.driver
Handler for AllocatedEvaluator.
DriverFailOnFail.AllocatedEvaluatorHandler() - Constructor for class org.apache.reef.tests.fail.driver.DriverFailOnFail.AllocatedEvaluatorHandler
 
DriverFailOnFail.FailedTaskHandler - Class in org.apache.reef.tests.fail.driver
Handler for FailedTask.
DriverFailOnFail.FailedTaskHandler() - Constructor for class org.apache.reef.tests.fail.driver.DriverFailOnFail.FailedTaskHandler
 
DriverFailOnFail.StartHandler - Class in org.apache.reef.tests.fail.driver
Handler for StartTime.
DriverFailOnFail.StartHandler() - Constructor for class org.apache.reef.tests.fail.driver.DriverFailOnFail.StartHandler
 
DriverFatalRuntimeException - Exception in org.apache.reef.exception
A special RuntimeException we throw to indicate to the resource manager to never attempt to restart us if this exception is thrown.
DriverFatalRuntimeException(String, Throwable) - Constructor for exception org.apache.reef.exception.DriverFatalRuntimeException
 
DriverFatalRuntimeException(String) - Constructor for exception org.apache.reef.exception.DriverFatalRuntimeException
 
DriverIdentifier - Class in org.apache.reef.driver.parameters
Driver Identifier.
DriverIdentifierGroupComm - Class in org.apache.reef.io.network.group.impl.config.parameters
 
DriverIdentifierGroupComm() - Constructor for class org.apache.reef.io.network.group.impl.config.parameters.DriverIdentifierGroupComm
 
DriverIdleManager - Class in org.apache.reef.runtime.common.driver.idle
Handles the various sources for driver idleness and forwards decisions to DriverStatusManager.
DriverIdlenessSource - Interface in org.apache.reef.runtime.common.driver.idle
Implementations of this interface are used to determine driver idleness.
DriverIdleSources - Class in org.apache.reef.driver.parameters
Sources considered when making an idleness decision.
DriverInfoSerializer - Interface in org.apache.reef.webserver
Interface for DriverInfoSerializer.
DriverIsUnmanaged - Class in org.apache.reef.driver.parameters
If true, run Driver in unmanaged mode.
DriverJobSubmissionDirectory - Class in org.apache.reef.driver.parameters
Job submission directory.
DriverLaunchCommandPrefix - Class in org.apache.reef.runtime.common.launch.parameters
List of strings to be prepended to driver launch command (I.E.
DriverLaunchCommandPrefix() - Constructor for class org.apache.reef.runtime.common.launch.parameters.DriverLaunchCommandPrefix
 
DriverLauncher - Class in org.apache.reef.client
A launcher for REEF Drivers.
DriverLauncher.CompletedJobHandler - Class in org.apache.reef.client
Job driver notifies us that the job had completed successfully.
DriverLauncher.CompletedJobHandler() - Constructor for class org.apache.reef.client.DriverLauncher.CompletedJobHandler
 
DriverLauncher.FailedJobHandler - Class in org.apache.reef.client
Job driver notifies us that the job had failed.
DriverLauncher.FailedJobHandler() - Constructor for class org.apache.reef.client.DriverLauncher.FailedJobHandler
 
DriverLauncher.RunningJobHandler - Class in org.apache.reef.client
Job driver notifies us that the job is running.
DriverLauncher.RunningJobHandler() - Constructor for class org.apache.reef.client.DriverLauncher.RunningJobHandler
 
DriverLauncher.RuntimeErrorHandler - Class in org.apache.reef.client
Handler an error in the job driver.
DriverLauncher.RuntimeErrorHandler() - Constructor for class org.apache.reef.client.DriverLauncher.RuntimeErrorHandler
 
DriverLauncher.SubmittedJobHandler - Class in org.apache.reef.client
Job driver notifies us that the job has been submitted to the Resource Manager.
DriverLauncher.SubmittedJobHandler() - Constructor for class org.apache.reef.client.DriverLauncher.SubmittedJobHandler
 
DriverLocalFiles - Class in org.apache.reef.driver.parameters
Files to be made accessible on the Driver only.
DriverLocalLibraries - Class in org.apache.reef.driver.parameters
Libraries to be made accessible on the Driver only.
DriverMemory - Class in org.apache.reef.driver.parameters
Driver RAM allocation in MB.
driverMemory - Variable in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters
Deprecated.
DriverMessage - Interface in org.apache.reef.task.events
Represents a message sent by the driver.
DriverMessaging - Class in org.apache.reef.tests.messaging.driver
Runner for DriverMessagingTest.
DriverProcessMemory - Class in org.apache.reef.runtime.common.driver.parameters
The driver process memory.
DriverProcessMemory() - Constructor for class org.apache.reef.runtime.common.driver.parameters.DriverProcessMemory
 
driverRecoveryTimeout - Variable in class org.apache.reef.reef.bridge.client.avro.AvroYarnAppSubmissionParameters
Deprecated.
DriverRemoteIdentifier - Class in org.apache.reef.runtime.common.evaluator.parameters
The identifier used by the Evaluator to connect back to the Driver.
driverRestart(StartTime) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time in calling driverRestartHandler.
driverRestartActiveContextReceived(String) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time in calling driverRestartActiveContextReceivedHandler.
DriverRestartCompleted - Interface in org.apache.reef.driver.restart
The object used to notify the user that the Driver Restart process has been completed.
driverRestartCompleted(long) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time in calling driverRestartCompletedHandler.
DriverRestartCompletedBridge - Class in org.apache.reef.javabridge.generic
The Java-CLR bridge object for DriverRestartCompleted events.
DriverRestartCompletedHandlers - Class in org.apache.reef.driver.parameters
Handler for event that all evaluators have checked back in after driver restart and that the restart is completed.
DriverRestartConfiguration - Class in org.apache.reef.client
EventHandlers specific to Driver Restart.
DriverRestartContextActiveHandlers - Class in org.apache.reef.driver.parameters
Handler for ActiveContext during a driver restart.
DriverRestarted - Interface in org.apache.reef.driver.restart
Am event encapsulating the time of Driver restart as well as the set of Evaluator IDs of Evaluators that are expected to report back to the Driver after restart.
DriverRestartedBridge - Class in org.apache.reef.javabridge
The Java-CLR bridge object for DriverRestarted events.
DriverRestartedBridge(DriverRestarted) - Constructor for class org.apache.reef.javabridge.DriverRestartedBridge
 
DriverRestartedImpl - Class in org.apache.reef.driver.restart
 
DriverRestartEvaluatorRecoverySeconds - Class in org.apache.reef.driver.parameters
Represents the amount of time in seconds that the driver restart waits for evaluators to report back.
DriverRestartFailedEvaluatorHandlers - Class in org.apache.reef.driver.parameters
The NamedParameter for Evaluators that have failed on Driver Restart.
DriverRestartHandler - Class in org.apache.reef.driver.parameters
The EventHandler invoked on Driver restart.
DriverRestartHandler() - Constructor for class org.apache.reef.driver.parameters.DriverRestartHandler
 
DriverRestartManager - Class in org.apache.reef.driver.restart
The manager that handles aspects of driver restart such as determining whether the driver is in restart mode, what to do on restart, whether restart is completed, and others.
driverRestartRunningTask(String) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time in calling driverRestartRunningTaskHandler.
DriverRestartState - Enum in org.apache.reef.driver.restart
Represents the current driver restart progress.
DriverRestartTaskRunningHandlers - Class in org.apache.reef.driver.parameters
Handler for RunningTask events during a Driver restart.
DriverRuntimeConfiguration - Class in org.apache.reef.runtime.common.driver
ConfigurationModule for driver runtime.
DriverRuntimeConfiguration() - Constructor for class org.apache.reef.runtime.common.driver.DriverRuntimeConfiguration
 
DriverRuntimeConfigurationOptions - Class in org.apache.reef.runtime.common.driver
Houses the Driver resourcemanager configuration's NamedParameters.
DriverRuntimeConfigurationOptions() - Constructor for class org.apache.reef.runtime.common.driver.DriverRuntimeConfigurationOptions
 
DriverRuntimeConfigurationOptions.JobControlHandler - Class in org.apache.reef.runtime.common.driver
Handler called when a job control message is received by the client.
DriverRuntimeConfigurationOptions.JobControlHandler() - Constructor for class org.apache.reef.runtime.common.driver.DriverRuntimeConfigurationOptions.JobControlHandler
 
DriverRuntimeRestartConfiguration - Class in org.apache.reef.runtime.common.driver
The base configuration module for driver restart configurations of all runtimes.
DriverRuntimeRestartManager - Interface in org.apache.reef.driver.restart
Classes implementing this interface are in charge of recording evaluator changes as they are allocated as well as recovering Evaluators and discovering which evaluators are lost on the event of a driver restart.
DriverServiceConfiguration - Class in org.apache.reef.client
Use this ConfigurationModule to configure Services to be run in the Driver.
DriverServiceConfiguration() - Constructor for class org.apache.reef.client.DriverServiceConfiguration
 
DriverSide - Annotation Type in org.apache.reef.annotations.audience
Annotates interfaces that are meant to be used in the Job Driver.
DriverSideFailure - Exception in org.apache.reef.tests.library.exceptions
Thrown when a test fails on the driver side.
DriverSideFailure() - Constructor for exception org.apache.reef.tests.library.exceptions.DriverSideFailure
 
DriverSideFailure(String) - Constructor for exception org.apache.reef.tests.library.exceptions.DriverSideFailure
 
DriverSideFailure(String, Throwable) - Constructor for exception org.apache.reef.tests.library.exceptions.DriverSideFailure
 
DriverSideFailure(Throwable) - Constructor for exception org.apache.reef.tests.library.exceptions.DriverSideFailure
 
driverStart(StartTime) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
The method is to measure the time used to start the driver.
DriverStartHandler - Class in org.apache.reef.driver.parameters
Called once the Driver is completely setup.
DriverStartHandler() - Constructor for class org.apache.reef.driver.parameters.DriverStartHandler
 
DriverStartHandler - Class in org.apache.reef.runtime.common.driver
This is bound to the start event of the clock and dispatches it to the appropriate application code.
DriverStatus - Enum in org.apache.reef.runtime.common.driver
The status of the Driver.
DriverStatusManager - Class in org.apache.reef.runtime.common.driver
Manages the Driver's status.
driverStderrFilePath - Variable in class org.apache.reef.reef.bridge.client.avro.AvroLocalJobSubmissionParameters
Deprecated.
driverStderrFilePath - Variable in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters
Deprecated.
driverStdoutFilePath - Variable in class org.apache.reef.reef.bridge.client.avro.AvroLocalJobSubmissionParameters
Deprecated.
driverStdoutFilePath - Variable in class org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters
Deprecated.
driverStop(long) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
The method is to measure the time used to stop the driver.
driverSubmit(Boolean) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time to submit a driver.
DURATION - Static variable in class org.apache.reef.util.logging.LoggingScopeImpl
 
DynamicObservable<T> - Interface in org.apache.reef.wake.rx
Defines a "dynamically configured" provider for push-based notification.

E

EchoTask - Class in org.apache.reef.tests.library.tasks
A Task that just sends the memento back.
EdgeVisitor<T> - Interface in org.apache.reef.tang.util.walk
Generic interface to traverse edges of the configuration graph.
ELAPSED_TIME - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
empty() - Static method in class org.apache.reef.util.Optional
 
EMPTY_BYTE_ARR - Static variable in class org.apache.reef.io.network.group.impl.utils.Utils
 
enableAssertions(boolean) - Method in class org.apache.reef.runtime.common.launch.JavaLaunchCommandBuilder
Enable or disable assertions on the child process.
EnableRampup - Class in org.apache.reef.examples.group.bgd.parameters
Maximum Number of Iterations.
EnableRampup() - Constructor for class org.apache.reef.examples.group.bgd.parameters.EnableRampup
 
encode(Vector) - Method in class org.apache.reef.examples.group.utils.math.VectorCodec
 
encode(T) - Method in class org.apache.reef.examples.suspend.ObjectWritableCodec
Encodes Hadoop Writable object into a byte array.
encode(TaskNode) - Static method in class org.apache.reef.io.network.group.impl.driver.TopologySerializer
Recursively encode TaskNodes of a Topology into a byte array.
encode(GroupChanges) - Method in class org.apache.reef.io.network.group.impl.GroupChangesCodec
 
encode(GroupCommunicationMessage) - Method in class org.apache.reef.io.network.group.impl.GroupCommunicationMessageCodec
 
encode(List<T>, List<Integer>, List<? extends Identifier>, Codec<T>) - Method in class org.apache.reef.io.network.group.impl.utils.ScatterEncoder
 
encode(NSMessage<T>) - Method in class org.apache.reef.io.network.impl.NSMessageCodec
Encodes a network service message to bytes.
encode(NamingLookupRequest) - Method in class org.apache.reef.io.network.naming.serialization.NamingLookupRequestCodec
Encodes the identifiers to bytes.
encode(NamingLookupResponse) - Method in class org.apache.reef.io.network.naming.serialization.NamingLookupResponseCodec
Encodes name assignments to bytes.
encode(NamingRegisterRequest) - Method in class org.apache.reef.io.network.naming.serialization.NamingRegisterRequestCodec
Encodes the name assignment to bytes.
encode(NamingRegisterResponse) - Method in class org.apache.reef.io.network.naming.serialization.NamingRegisterResponseCodec
Encodes a naming register response to bytes.
encode(NamingUnregisterRequest) - Method in class org.apache.reef.io.network.naming.serialization.NamingUnregisterRequestCodec
Encodes the naming un-registration request to bytes.
encode(List<T>) - Method in class org.apache.reef.io.network.util.ListCodec
 
encode(String) - Method in class org.apache.reef.io.network.util.StringCodec
 
encode(T) - Method in interface org.apache.reef.io.serialization.Codec
Encodes the given object into a Byte Array.
encode(T) - Method in class org.apache.reef.io.serialization.SerializableCodec
 
encode(Integer) - Method in class org.apache.reef.io.storage.util.IntegerCodec
 
encode(GeneratedMessage) - Method in class org.apache.reef.runtime.common.launch.REEFMessageCodec
 
encode(EvaluatorControl) - Method in class org.apache.reef.runtime.mesos.util.MesosRemoteManagerCodec
 
encode(T) - Method in interface org.apache.reef.wake.remote.Encoder
Encodes the given object into a Byte Array.
encode(byte[]) - Method in class org.apache.reef.wake.remote.impl.ByteCodec
Returns the byte array argument.
encode(T) - Method in class org.apache.reef.wake.remote.impl.MultiCodec
Encodes an object to a byte array.
encode(T) - Method in class org.apache.reef.wake.remote.impl.MultiEncoder
Encodes an object to a byte array.
encode(T) - Method in class org.apache.reef.wake.remote.impl.ObjectSerializableCodec
Encodes the object to bytes.
encode(RemoteEvent<T>) - Method in class org.apache.reef.wake.remote.impl.RemoteEventCodec
Encodes the remote event object to bytes.
encode(RemoteEvent<T>) - Method in class org.apache.reef.wake.remote.impl.RemoteEventEncoder
Encodes the remote event object to bytes.
encode(String) - Method in class org.apache.reef.wake.remote.impl.StringCodec
Returns a byte array representation of the string.
encode(byte[]) - Method in class org.apache.reef.wake.remote.transport.netty.ByteEncoder
 
Encoder<T> - Interface in org.apache.reef.wake.remote
Interface for serialization routines that translate back and forth between byte arrays with low latency.
encodeToStream(GroupCommunicationMessage, DataOutputStream) - Method in class org.apache.reef.io.network.group.impl.GroupCommunicationMessageCodec
 
encodeToStream(T, DataOutputStream) - Method in interface org.apache.reef.io.network.impl.StreamingCodec
 
END_INDICATORS - Static variable in class org.apache.reef.util.logging.LogParser
 
endPackage() - Method in class org.apache.reef.tang.util.Tint
 
enqueueTasklet(VortexFunction<TInput, TOutput>, TInput, Optional<FutureCallback<TOutput>>) - Method in interface org.apache.reef.vortex.driver.VortexMaster
Submit a new Tasklet to be run sometime in the future, with an optional callback function on the result.
enqueueTasklets(VortexAggregateFunction<TOutput>, VortexFunction<TInput, TOutput>, VortexAggregatePolicy, List<TInput>, Optional<FutureCallback<AggregateResult<TInput, TOutput>>>) - Method in interface org.apache.reef.vortex.driver.VortexMaster
Submits aggregate-able Tasklets to be run sometime in the future, with an optional callback function on the aggregation progress.
ENTRY - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
entrySet() - Method in class org.apache.reef.tang.util.MonotonicTreeMap
 
entrySet() - Method in class org.apache.reef.tang.util.TracingMonotonicTreeMap
 
ENVIRONMENT - Static variable in class org.apache.reef.runtime.hdinsight.client.yarnrest.Constants
 
EnvironmentUtils - Class in org.apache.reef.util
Utils which detect environment settings.
Eps - Class in org.apache.reef.examples.group.bgd.parameters
Break criterion for the optimizer.
Eps() - Constructor for class org.apache.reef.examples.group.bgd.parameters.Eps
 
equals(Object) - Method in class org.apache.reef.client.LauncherStatus
Compare the State of two LauncherStatus objects.
equals(Object) - Method in class org.apache.reef.io.checkpoint.fs.FSCheckpointID
 
equals(Object) - Method in class org.apache.reef.io.data.loading.impl.DistributedDataSetPartition
 
equals(Object) - Method in class org.apache.reef.io.data.loading.impl.NumberedSplit
 
equals(Object) - Method in class org.apache.reef.io.network.group.impl.driver.IndexedMsg
 
equals(Object) - Method in class org.apache.reef.io.network.group.impl.driver.MsgKey
 
equals(Object) - Method in class org.apache.reef.io.network.group.impl.driver.TaskNodeImpl
 
equals(Object) - Method in class org.apache.reef.io.network.group.impl.GroupCommunicationMessage
 
equals(Object) - Method in class org.apache.reef.io.network.group.impl.task.NodeStructImpl
 
equals(Object) - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupCommMessage
 
equals(Object) - Method in class org.apache.reef.io.network.proto.ReefNetworkGroupCommProtos.GroupMessageBody
 
equals(Object) - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSMessagePBuf
 
equals(Object) - Method in class org.apache.reef.io.network.proto.ReefNetworkServiceProtos.NSRecordPBuf
 
equals(Object) - Method in class org.apache.reef.io.network.util.StringIdentifier
Checks that another object is equal to this object.
equals(Object) - Method in class org.apache.reef.io.Tuple
 
equals(Object) - Method in class org.apache.reef.proto.ClientRuntimeProtocol.JobControlProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.AddContextProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextControlProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.ContextMessageProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.DoneEvaluatorProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorControlProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.KillEvaluatorProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.RemoveContextProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StartTaskProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StopEvaluatorProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.StopTaskProto
 
equals(Object) - Method in class org.apache.reef.proto.EvaluatorRuntimeProtocol.SuspendTaskProto
 
equals(Object) - Method in class org.apache.reef.proto.REEFProtocol.REEFMessage
 
equals(Object) - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto.ContextMessageProto
 
equals(Object) - Method in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto
 
equals(Object) - Method in class org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto
 
equals(Object) - Method in class org.apache.reef.proto.ReefServiceProtos.JobStatusProto
 
equals(Object) - Method in class org.apache.reef.proto.ReefServiceProtos.RuntimeErrorProto
 
equals(Object) - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto
 
equals(Object) - Method in class org.apache.reef.proto.ReefServiceProtos.TaskStatusProto.TaskMessageProto
 
equals(Object) - Method in class org.apache.reef.runtime.common.driver.catalog.RackDescriptorImpl
 
equals(Object) - Method in class org.apache.reef.runtime.hdinsight.client.yarnrest.StringEntry
 
equals(Object) - Method in class org.apache.reef.tang.implementation.ConfigurationBuilderImpl
 
equals(Object) - Method in class org.apache.reef.tang.implementation.ConfigurationImpl
 
equals(Object) - Method in class org.apache.reef.tang.implementation.types.AbstractNode
 
equals(Object) - Method in class org.apache.reef.tang.implementation.types.ConstructorArgImpl
 
equals(Object) - Method in class org.apache.reef.tang.implementation.types.ConstructorDefImpl
 
equals(Object) - Method in class org.apache.reef.tang.util.MonotonicTreeMap
 
equals(Object) - Method in class org.apache.reef.tang.util.TracingMonotonicTreeMap
 
equals(Object) - Method in class org.apache.reef.util.Optional
 
equals(Object) - Method in class org.apache.reef.wake.examples.accumulate.CombinerStage.Pair
 
equals(Object) - Method in class org.apache.reef.wake.examples.join.TupleEvent
 
equals(Object) - Method in interface org.apache.reef.wake.Identifier
Checks that another object is equal to this object.
equals(Object) - Method in class org.apache.reef.wake.remote.impl.SocketRemoteIdentifier
Checks that another object is equal to this object.
equals(Object) - Method in class org.apache.reef.wake.remote.impl.Tuple2
 
equals(Object) - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeMessagePBuf
 
equals(Object) - Method in class org.apache.reef.wake.remote.proto.WakeRemoteProtos.WakeTuplePBuf
 
equals(Object) - Method in class org.apache.reef.wake.test.proto.TestProtos.TestEventPBuf
 
equals(Object) - Method in class org.apache.reef.wake.time.Time
 
error(ExecutorDriver, String) - Method in class org.apache.reef.runtime.mesos.evaluator.REEFExecutor
 
ERROR_FIELD_NUMBER - Static variable in class org.apache.reef.proto.ReefServiceProtos.ContextStatusProto
 
ERROR_FIELD_NUMBER - Static variable in class org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto
 
ErrorHandlerRID - Class in org.apache.reef.runtime.common.launch.parameters
The error handler remote identifier.
EStage<T> - Interface in org.apache.reef.wake
Stage that executes an event handler.
Eta - Class in org.apache.reef.examples.group.bgd.parameters
Break criterion for the optimizer.
Eta() - Constructor for class org.apache.reef.examples.group.bgd.parameters.Eta
 
EVALUATOR_ALLOCATED - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
EVALUATOR_BRIDGE_SUBMIT - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
EVALUATOR_COMPLETED - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
EVALUATOR_CONFIGURATION - Static variable in class org.apache.reef.runtime.common.evaluator.EvaluatorConfiguration
 
EVALUATOR_DISPATCHER_THREADS - Static variable in class org.apache.reef.client.DriverConfiguration
Number of threads allocated per evaluator to dispatch events from this Evaluator.
EVALUATOR_FAILED - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
EVALUATOR_ID_FIELD_NUMBER - Static variable in class org.apache.reef.proto.ReefServiceProtos.EvaluatorStatusProto
 
EVALUATOR_IDENTIFIER - Static variable in class org.apache.reef.runtime.common.evaluator.EvaluatorConfiguration
 
EVALUATOR_IDLENESS_THREAD_POOL_SIZE - Static variable in class org.apache.reef.client.DriverConfiguration
The number of Threads in a Driver to verify the completion of Evaluators.
EVALUATOR_IDLENESS_WAIT_IN_MS - Static variable in class org.apache.reef.client.DriverConfiguration
The number of Threads in a Driver to verify the completion of Evaluators.
evaluator_launch - Variable in class org.apache.reef.runtime.mesos.util.EvaluatorControl
Deprecated.
EVALUATOR_LAUNCH - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
EVALUATOR_PRESERVER - Static variable in class org.apache.reef.runtime.yarn.driver.YarnDriverRestartConfiguration
The Evaluator Preserver implementation used for YARN.
evaluator_release - Variable in class org.apache.reef.runtime.mesos.util.EvaluatorControl
Deprecated.
EVALUATOR_REQUESTOR - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
EVALUATOR_STATUS_FIELD_NUMBER - Static variable in class org.apache.reef.proto.EvaluatorRuntimeProtocol.EvaluatorHeartbeatProto
 
EVALUATOR_SUBMIT - Static variable in class org.apache.reef.util.logging.LoggingScopeFactory
 
EVALUATOR_TIMEOUT - Static variable in class org.apache.reef.runtime.hdinsight.client.HDInsightDriverConfiguration
 
EVALUATOR_TIMEOUT - Static variable in class org.apache.reef.runtime.mesos.driver.MesosDriverConfiguration
 
EVALUATOR_TIMEOUT - Static variable in class org.apache.reef.runtime.yarn.client.unmanaged.UnmanagedAmYarnDriverConfiguration
 
EVALUATOR_TIMEOUT - Static variable in class org.apache.reef.runtime.yarn.driver.YarnDriverConfiguration
 
evaluatorAllocated(String) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time on evaluatorAllocated handler.
EvaluatorAllocatedHandlers - Class in org.apache.reef.driver.parameters
Called when an allocated evaluator is given to the client.
evaluatorCompleted(String) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time in calling evaluatorCompleted handler.
EvaluatorCompletedHandlers - Class in org.apache.reef.driver.parameters
Called when an exception occurs on a running evaluator.
EvaluatorConfiguration - Class in org.apache.reef.runtime.common.evaluator
The runtime configuration of an evaluator.
EvaluatorConfiguration() - Constructor for class org.apache.reef.runtime.common.evaluator.EvaluatorConfiguration
 
EvaluatorConfiguration - Class in org.apache.reef.runtime.common.evaluator.parameters
The evaluator configuration.
EvaluatorConfigurationProviders - Class in org.apache.reef.driver.parameters
Configuration provides whose Configurations will be mixed into the Evaluator Configuration.
EvaluatorConfigurationProviders() - Constructor for class org.apache.reef.driver.parameters.EvaluatorConfigurationProviders
 
EvaluatorContext - Class in org.apache.reef.runtime.common.driver.context
Driver-side representation of a Context on an Evaluator.
EvaluatorContext(String, String, EvaluatorDescriptor, Optional<String>, ConfigurationSerializer, ContextControlHandler, EvaluatorMessageDispatcher, ExceptionCodec, ContextRepresenters) - Constructor for class org.apache.reef.runtime.common.driver.context.EvaluatorContext
 
EvaluatorControl - Class in org.apache.reef.runtime.mesos.util
 
EvaluatorControl() - Constructor for class org.apache.reef.runtime.mesos.util.EvaluatorControl
Default constructor.
EvaluatorControl(EvaluatorLaunch, EvaluatorRelease) - Constructor for class org.apache.reef.runtime.mesos.util.EvaluatorControl
All-args constructor.
EvaluatorControl.Builder - Class in org.apache.reef.runtime.mesos.util
RecordBuilder for EvaluatorControl instances.
EVALUATORCONTROL_FIELD_NUMBER - Static variable in class org.apache.reef.proto.REEFProtocol.REEFMessage
 
EvaluatorControlHandler - Class in org.apache.reef.runtime.common.driver.evaluator
This class handles the sending of Evaluator control messages to the Evaluator.
EvaluatorDescriptor - Interface in org.apache.reef.driver.evaluator
Metadata about an Evaluator.
evaluatorDescriptor - Variable in class org.apache.reef.io.watcher.driver.context.AvroContextBase
Deprecated.
evaluatorDescriptor - Variable in class org.apache.reef.io.watcher.driver.evaluator.AvroAllocatedEvaluator
Deprecated.
EvaluatorDispatcherThreads - Class in org.apache.reef.driver.parameters
Number of threads allocated per evaluator to dispatch events from that Evaluator.
EvaluatorException - Exception in org.apache.reef.exception
Exception thrown to the Driver when an Evaluator becomes unusable.
EvaluatorException(String) - Constructor for exception org.apache.reef.exception.EvaluatorException
 
EvaluatorException(String, String, Throwable) - Constructor for exception org.apache.reef.exception.EvaluatorException
 
EvaluatorException(String, String) - Constructor for exception org.apache.reef.exception.EvaluatorException
 
EvaluatorException(String, Throwable) - Constructor for exception org.apache.reef.exception.EvaluatorException
 
evaluatorException - Variable in class org.apache.reef.io.watcher.driver.evaluator.AvroFailedEvaluator
Deprecated.
evaluatorFailed(String) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time in calling evaluatorFailed handler.
EvaluatorFailedHandlers - Class in org.apache.reef.driver.parameters
Called when an exception occurs on a running evaluator.
EVALUATORHEARTBEAT_FIELD_NUMBER - Static variable in class org.apache.reef.proto.REEFProtocol.REEFMessage
 
EvaluatorHeartbeatHandler - Class in org.apache.reef.runtime.common.driver.evaluator
Receives heartbeats from all Evaluators and dispatches them to the right EvaluatorManager instance.
evaluatorId - Variable in class org.apache.reef.io.watcher.driver.context.AvroContextBase
Deprecated.
evaluatorId - Variable in class org.apache.reef.webserver.AvroEvaluatorInfo
Deprecated.
EvaluatorIdentifier - Class in org.apache.reef.runtime.common.evaluator.parameters
The evaluator identifier.
EvaluatorIdlenessThreadPool - Class in org.apache.reef.runtime.common.driver.evaluator
Runs threads in a thread pool to check the completion of Evaluators on the closing of an EvaluatorManager in order to trigger Evaluator idleness checks.
EvaluatorIdlenessThreadPoolSize - Class in org.apache.reef.runtime.common.driver.parameters
The number of Threads in a Driver to verify the completion of Evaluators.
EvaluatorIdlenessWaitInMilliseconds - Class in org.apache.reef.runtime.common.driver.parameters
The number of Threads in a Driver to verify the completion of Evaluators.
EvaluatorInfoSerializer - Interface in org.apache.reef.webserver
Interface for EvaluatorInfoSerializer.
evaluatorIsClosed() - Method in class org.apache.reef.runtime.common.driver.task.TaskRepresenter
Check whether this evaluator is in closed state.
evaluatorIsClosing() - Method in class org.apache.reef.runtime.common.driver.task.TaskRepresenter
Check whether this evaluator is in closing state.
EvaluatorKilledByResourceManagerException - Exception in org.apache.reef.exception
Reported as part of a FailedEvaluator when the resource manager killed the Evaluator.
EvaluatorKilledByResourceManagerException(String, String) - Constructor for exception org.apache.reef.exception.EvaluatorKilledByResourceManagerException
 
EvaluatorLaunch - Class in org.apache.reef.runtime.mesos.util
 
EvaluatorLaunch() - Constructor for class org.apache.reef.runtime.mesos.util.EvaluatorLaunch
Default constructor.
EvaluatorLaunch(CharSequence, CharSequence) - Constructor for class org.apache.reef.runtime.mesos.util.EvaluatorLaunch
All-args constructor.
evaluatorLaunch(String) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
This is to measure the time to launch an evaluator.
EvaluatorLaunch.Builder - Class in org.apache.reef.runtime.mesos.util
RecordBuilder for EvaluatorLaunch instances.
EvaluatorListSerializer - Interface in org.apache.reef.webserver
Interface for EvaluatorListSerializer.
EvaluatorManager - Class in org.apache.reef.runtime.common.driver.evaluator
Manages a single Evaluator instance including all lifecycle instances: (AllocatedEvaluator, CompletedEvaluator, FailedEvaluator).
EvaluatorManager.EvaluatorDescriptorName - Class in org.apache.reef.runtime.common.driver.evaluator
The Evaluator Host.
EvaluatorManager.EvaluatorDescriptorName() - Constructor for class org.apache.reef.runtime.common.driver.evaluator.EvaluatorManager.EvaluatorDescriptorName
 
EvaluatorManager.EvaluatorIdentifier - Class in org.apache.reef.runtime.common.driver.evaluator
The Evaluator Identifier.
EvaluatorManager.EvaluatorIdentifier() - Constructor for class org.apache.reef.runtime.common.driver.evaluator.EvaluatorManager.EvaluatorIdentifier
 
EvaluatorManagerFactory - Class in org.apache.reef.runtime.common.driver.evaluator
Helper class that creates new EvaluatorManager instances from allocations.
EvaluatorMemory - Class in org.apache.reef.examples.group.bgd.parameters
The memory used for each Evaluator.
EvaluatorMemory() - Constructor for class org.apache.reef.examples.group.bgd.parameters.EvaluatorMemory
 
EvaluatorMessageDispatcher - Class in org.apache.reef.runtime.common.driver.evaluator
Central dispatcher for all Evaluator related events.
EvaluatorPreserver - Interface in org.apache.reef.runtime.common.driver
A interface to preserve evaluators across driver restarts.
EvaluatorPreservingEvaluatorAllocatedHandler - Class in org.apache.reef.driver.restart
Records allocated evaluators for recovery on driver restart by using a DriverRuntimeRestartManager.
EvaluatorPreservingEvaluatorCompletedHandler - Class in org.apache.reef.driver.restart
Removes an evaluator from the evaluators to restart after it has completed.
EvaluatorPreservingEvaluatorFailedHandler - Class in org.apache.reef.driver.restart
Removes an evaluator from the evaluators to restart after it has failed.
EvaluatorProcess - Interface in org.apache.reef.driver.evaluator
Defines the setup of an evaluator's process.
EvaluatorProcessFactory<T> - Interface in org.apache.reef.driver.evaluator
Factory to create new evaluator process setups.
EvaluatorRelease - Class in org.apache.reef.runtime.mesos.util
 
EvaluatorRelease() - Constructor for class org.apache.reef.runtime.mesos.util.EvaluatorRelease
Default constructor.
EvaluatorRelease(CharSequence) - Constructor for class org.apache.reef.runtime.mesos.util.EvaluatorRelease
All-args constructor.
EvaluatorRelease.Builder - Class in org.apache.reef.runtime.mesos.util
RecordBuilder for EvaluatorRelease instances.
EvaluatorRequest - Class in org.apache.reef.driver.evaluator
A request for one ore more Evaluators.
EvaluatorRequest.Builder<T extends EvaluatorRequest.Builder> - Class in org.apache.reef.driver.evaluator
EvaluatorRequests are build using this Builder.
EvaluatorRequest.Builder() - Constructor for class org.apache.reef.driver.evaluator.EvaluatorRequest.Builder
 
EvaluatorRequestor - Interface in org.apache.reef.driver.evaluator
Interface through which Evaluators can be requested.
EvaluatorRequestorBridge - Class in org.apache.reef.javabridge
The Java-CLR bridge object for EvaluatorRequestor.
EvaluatorRequestorBridge(EvaluatorRequestor, boolean, LoggingScopeFactory, Set<String>) - Constructor for class org.apache.reef.javabridge.EvaluatorRequestorBridge
 
EvaluatorRequestorImpl - Class in org.apache.reef.runtime.common.driver
Implementation of the EvaluatorRequestor that translates the request and hands it down to the underlying RM.
EvaluatorRequestorImpl(ResourceCatalog, ResourceRequestHandler, LoggingScopeFactory) - Constructor for class org.apache.reef.runtime.common.driver.EvaluatorRequestorImpl
 
EvaluatorRequestorImpl.Builder - Class in org.apache.reef.runtime.common.driver
EvaluatorRequest.Builder extended with a new submit method.
EvaluatorRequestorImpl.Builder() - Constructor for class org.apache.reef.runtime.common.driver.EvaluatorRequestorImpl.Builder
 
evaluatorRequestorPassToCs() - Method in class org.apache.reef.util.logging.LoggingScopeFactory
The method is to measure the time used to pass EvaluatorRequestor from Java to .Net.
evaluatorRequestSubmitToJavaDriver(int) - Method in class org.apache.reef.util.logging.LoggingScopeFactory
The method is to measure the time used to submit Evaluator request from CLR to Java driver.
EvaluatorResourceManagerErrorHandler - Class in org.apache.reef.runtime.common.driver.evaluator
The error handler receives all resourcemanager errors from all evaluators in the system.
EvaluatorRestartInfo - Class in or