|
Apache REEF
0.14.0
Retainable Evaluator Execution Framework
|
|
Apache REEF
0.14.0
Retainable Evaluator Execution Framework
|
| ▼NOrg | |
| ▼NApache | |
| ▼NREEF | |
| ►NClient | |
| ►NAPI | |
| ►NExceptions | |
| CClasspathException | Thrown when the client fails to assemble the classpath for the Java part of the client |
| CJavaNotFoundException | Thrown when the java installation cannot be found on the client |
| CAppParameters | The parameters for a REEF application, used to specify application parameters for each REEF application |
| CAppParametersBuilder | A builder for AppParameters |
| CClientFactory | Instantiates the client based on IConfiguration for the chosen runtime |
| CIJobSubmission | This interfaces provides all the information that is needed for a job submission |
| CIJobSubmissionBuilder | Facilitates building of job submissions |
| CIREEFClient | Interface for job submission on a REEF cluster |
| CJobParameters | The parameters for a REEF job, used to specify job parameters on each REEF submission |
| CJobParametersBuilder | A builder for JobParameters |
| CJobRequest | Describes parameters for a single job submission |
| CJobRequestBuilder | |
| CJobSubmissionBuilderFactory | Instantiates IJobSubmissionBuilder based on configurationProviders |
| CTcpPortConfigurationModule | Configuration Module for the TCP port provider |
| ►NAvro | |
| ►NLocal | |
| CAvroLocalAppSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroLocalAppSubmissionParameters |
| ►NYARN | |
| CAvroYarnAppSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroYarnAppSubmissionParameters |
| CAvroYarnClusterJobSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroYarnClusterJobSubmissionParameters |
| CAvroYarnJobSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroYarnJobSubmissionParameters |
| CAvroAppSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroAppSubmissionParameters |
| CAvroJobSubmissionParameters | Used to serialize and deserialize Avro record org.apache.reef.reef.bridge.client.avro.AvroJobSubmissionParameters |
| ►NCommon | |
| CIJobSubmissionResult | |
| ►NLocal | |
| ►NParameters | |
| CLocalRuntimeDirectory | |
| CNumberOfEvaluators | |
| CLocalClient | An implementation of the REEF interface using an external Java program |
| CLocalRuntimeClientConfiguration | |
| ►NYarn | |
| ►NRestClient | |
| CIUrlProvider | |
| CIJobResourceUploader | |
| CIJobSubmissionDirectoryProvider | Provides path to job submission directory |
| CJobResource | |
| CJobSubmissionDirectoryProvider | Provides path to job submission directory |
| CYARNClientConfiguration | The Configuration for the YARN Client |
| ►NYARN | |
| ►NHDI | |
| CHDInsightClientConfiguration | |
| CHDInsightCommandLineEnvironment | Provides YARN classpath for HDInsight environment |
| CHDInsightPasswordSecureString | |
| CHDInsightPasswordString | |
| CHDInsightUrl | |
| CHDInsightUserName | |
| ►NParameters | |
| CDriverMaxMemoryAllicationPoolSizeMB | |
| CDriverMaxPermSizeMB | |
| CEnableDebugLogging | |
| CJobSubmissionDirectoryPrefixParameter | |
| CSecurityTokenKindParameter | |
| CSecurityTokenServiceParameter | |
| ►NRestClient | |
| CIYarnRestClientCredential | Provides the credentials to be used by the REST client to connect to YARN RM |
| CMultipleRMUrlProvider | |
| CYarnREEFDotNetClient | Temporary client for developing and testing .NET job submission E2E |
| ►NCommon | |
| ►NApi | |
| CAbstractFailure | |
| CIAbstractFailure | |
| CIFailure | Common interface for all error messages in REEF |
| ►NAvro | |
| CAvroDriverInfo | Used to serialize and deserialize Avro record org.apache.reef.webserver.AvroDriverInfo |
| CAvroHttpRequest | Used to serialize and deserialize Avro record org.apache.reef.webserver.AvroHttpRequest |
| CAvroJsonSerializer | Wrapper class for serialize/deserialize Avro json |
| CAvroReefServiceInfo | Used to serialize and deserialize Avro record org.apache.reef.webserver.AvroReefServiceInfo |
| CHeaderEntry | Used to serialize and deserialize Avro record org.apache.reef.webserver.HeaderEntry |
| ►NCatalog | |
| ►NCapabilities | |
| CCPU | |
| CICapability | |
| CRAM | |
| CINodeDescriptor | |
| CIRackDescriptor | |
| CIResourceCatalog | |
| ►NClient | |
| ►NParameters | |
| CDriverConfigurationProviders | |
| ►NContext | |
| ►NDefaults | |
| CDefaultContextMessageSource | Default ContextMessageSource: return nothing |
| CDefaultContextStartHandler | Default handler for ContextStart |
| CDefaultContextStopHandler | Default event handler for ContextStop |
| CContextConfiguration | |
| ►CContextConfigurationOptions | Configuration parameters for ContextConfiguration module |
| CContextIdentifier | |
| CContextMessageHandlers | |
| CContextMessageSources | |
| CStartHandlers | |
| CStopHandlers | |
| CContextMessage | |
| CIContextMessage | |
| CIContextMessageHandler | |
| CIContextMessageSource | Implement (and bind) this interface to send messages from a context as part of a heartbeat from Evaluator to Driver |
| ►NEvaluator | |
| ►NParameters | |
| CEvaluatorConfigurationProviders | |
| CDefaultLocalHttpDriverConnection | |
| CDefaultYarnClusterHttpDriverConnection | |
| CDefaultYarnOneBoxHttpDriverConnection | |
| CDriverInformation | |
| CIDriverConnection | |
| ►NEvents | |
| CIContextStart | |
| CIContextStop | |
| ►NExceptions | |
| CJobException | |
| ►NFiles | |
| CREEFFileNames | Contains all file system constants used by REEF |
| ►NIo | |
| CINameClient | Client for the Reef name service |
| CNameAssignment | Tuple containing the string identifier and IPEndpoint |
| CNamingConfiguration | |
| ►CNamingConfigurationOptions | |
| CNameServerAddress | |
| CNameServerPort | |
| CTcpPortConfigurationProvider | |
| ►NJar | |
| CResourceHelper | Helps with retrieval of embedded resources |
| ►NProtobuf | |
| ►NReefProtocol | |
| CAddContextProto | |
| CContextControlProto | |
| CContextMessageProto | |
| ►CContextStatusProto | |
| CContextMessageProto | |
| CDriverProcessRegistrationProto | |
| CEvaluatorControlProto | |
| CEvaluatorHeartbeatProto | Add serializer/deserializer to EvaluatorHeartbeatProto |
| CEvaluatorHeartbeatProtoCodec | |
| CEvaluatorStatusProto | |
| CFileResourceProto | |
| CJobControlProto | |
| CJobStatusProto | |
| CJobSubmissionProto | |
| CKillEvaluatorProto | |
| CNodeDescriptorProto | |
| CREEFMessage | Add serializer/deserializer to REEFMessage |
| CREEFMessageCodec | |
| CRemoveContextProto | |
| CResourceAllocationProto | |
| CResourceLaunchProto | |
| CResourceReleaseProto | |
| CResourceRequestProto | |
| CResourceStatusProto | |
| CRuntimeErrorProto | |
| CRuntimeStatusProto | |
| CStartTaskProto | |
| CStopEvaluatorProto | |
| CStopTaskProto | |
| CSuspendTaskProto | |
| ►CTaskStatusProto | |
| CTaskMessageProto | |
| ►NRuntime | |
| ►NEvaluator | |
| CMachineStatus | |
| ►NServices | |
| CServiceConfiguration | Configuration module for services |
| CServicesSet | |
| ►NTasks | |
| ►NDefaults | |
| CDefaultDriverConnectionMessageHandler | |
| CDefaultDriverMessageHandler | |
| CDefaultTaskMessageSource | |
| ►NEvents | |
| CICloseEvent | |
| CIDriverMessage | |
| CISuspendEvent | |
| CITaskStart | |
| CITaskStop | |
| CIDriverConnectionMessage | The message triggered on a change of status in heartbeat to Driver |
| CIDriverConnectionMessageHandler | The handler implementable by users to handle IDriverConnectionMessages, which notifies the Task when there is a change in driver connection state |
| CIDriverMessageHandler | |
| CITask | |
| CITaskMessageSource | |
| CTaskConfiguration | |
| ►CTaskConfigurationOptions | |
| CCloseHandler | |
| CIdentifier | |
| CMemento | |
| CMessageHandler | |
| CStartHandlers | |
| CStopHandlers | |
| CSuspendHandler | |
| CTaskMessageSources | |
| CTaskMessage | |
| CConstants | |
| CIContextAndTaskSubmittable | Base interface for classes that support the simultaneous submission of both Context and Task configurations |
| CIContextSubmittable | Base interface for classes that support Context submission |
| CITaskSubmittable | Base interface for classes that support Task submission |
| ►NDriver | |
| ►NBridge | |
| ►NClr2java | |
| CIActiveContextClr2Java | |
| CIAllocatedEvaluatorClr2Java | |
| CIClosedContextClr2Java | A closed context event from Java |
| CIClr2Java | |
| CIClr2JavaTaskMessage | An message sent from a Task to a Driver |
| CICompletedEvaluatorClr2Java | |
| CICompletedTaskClr2Java | |
| CIContextMessageClr2Java | |
| CIDriverRestartCompletedClr2Java | |
| CIDriverRestartedClr2Java | |
| CIEvaluatorRequestorClr2Java | |
| CIFailedContextClr2Java | |
| CIFailedEvaluatorClr2Java | |
| CIFailedTaskClr2Java | |
| CIHttpServerBridgeClr2Java | |
| CIRunningTaskClr2Java | |
| CISuspendedTaskClr2Java | |
| CITaskMessageClr2Java | |
| CBridgeHandlerManager | A class that holds all .NET handles for Java InterOp calls |
| CBridgeLogger | A wrapper around the general Logger class used specifically for logging in CPP bridge code |
| CClrClientHelper | |
| CClrHandlerHelper | |
| CClrSystemHandlerWrapper | |
| CCommandLineArguments | |
| CCustomTraceLevel | |
| CCustomTraceListeners | |
| ►CDriverBridgeConfigurationOptions | Hosts all named parameters for Drivers, including bridge handlers |
| CActiveContextHandlers | |
| CAllocatedEvaluatorHandlers | |
| CArgumentSets | |
| CClosedContextHandlers | |
| CCompletedEvaluatorHandlers | |
| CCompletedTaskHandlers | |
| CContextMessageHandlers | |
| CDriverRestartActiveContextHandlers | |
| CDriverRestartCompletedHandlers | |
| CDriverRestartedHandlers | |
| CDriverRestartEvaluatorRecoverySeconds | |
| CDriverRestartFailedEvaluatorHandlers | |
| CDriverRestartRunningTaskHandlers | |
| CDriverStartedHandlers | |
| CEvaluatorRequestHandlers | |
| CFailedContextHandlers | |
| CFailedEvaluatorHandlers | |
| CFailedTaskHandlers | |
| CHttpEventHandlers | |
| CMaxApplicationSubmissions | |
| CRunningTaskHandlers | |
| CSetOfAssemblies | |
| CSuspendedTaskHandlers | |
| CTaskMessageHandlers | |
| CTraceLevel | |
| CTraceListenersSet | |
| CHttpServerPort | |
| CIHttpHandler | |
| CIHttpMessage | |
| CIInteropReturnInfo | |
| CILogger | |
| CReefHttpRequest | |
| CReefHttpResponse | |
| ►NContext | |
| ►NDefaults | |
| CDefaultContextMessageSource | Default ContextMessageSource: return nothing |
| CDefaultContextStartHandler | Default handler for ContextStart |
| CDefaultContextStopHandler | Default event handler for ContextStop |
| CContextConfiguration | |
| ►CContextConfigurationOptions | Configuration parameters for ContextConfiguration module |
| CContextIdentifier | |
| CContextMessageHandlers | |
| CContextMessageSources | |
| CStartHandlers | |
| CStopHandlers | |
| CIActiveContext | |
| CIClosedContext | A closed context |
| CIContext | A common base interface for Contexts, available or failed |
| CIFailedContext | |
| ►NDefaults | |
| CDefaultClientCloseHandler | Default handler for close messages from the client: logging it |
| CDefaultClientCloseWithMessageHandler | Default handler for close messages from the client: Throw an Exception |
| CDefaultClientMessageHandler | DDefault event handler for Client messages: Logging it |
| CDefaultContextActiveHandler | Default handler for ActiveContext: Close it |
| CDefaultContextClosureHandler | Default event handler for ClosedContext: Logging it |
| CDefaultContextFailureHandler | Default event handler used for FailedContext: It crashes the driver |
| CDefaultContextMessageHandler | Default event handler for ContextMessage: Logging it |
| CDefaultCustomTraceListener | |
| CDefaultDriverRestartCompletedHandler | The default driver restart completed handler |
| CDefaultDriverRestartContextActiveHandler | Default handler for ActiveContext received during driver restart: Close it |
| CDefaultDriverRestartHandler | Default event handler for driver restart: Logging it |
| CDefaultDriverRestartTaskRunningHandler | Default event handler for TaskRuntime received during driver restart: Logging it |
| CDefaultEvaluatorAllocationHandler | Default handler for AllocatedEvaluator: close it |
| CDefaultEvaluatorCompletionHandler | Default event handler for CompletedEvaluator: Logging it |
| CDefaultEvaluatorFailureHandler | Default event handler used for FailedEvaluator: It crashes the driver |
| CDefaultEvaluatorRequestorHandler | Default handler for close messages from the client: logging it |
| CDefaultHttpHandler | |
| CDefaultTaskCompletionHandler | Default event handler for CompletedTask: Log it and close the context |
| CDefaultTaskFailureHandler | Default event handler used for FailedTask: It crashes the driver |
| CDefaultTaskMessageHandler | Default event handler for TaskMessage: Logging it |
| CDefaultTaskRunningHandler | Default event handler for TaskRuntime: Logging it |
| CDefaultTaskSuspensionHandler | Default event handler used for SuspendedTask: It crashes the driver |
| ►NEvaluator | |
| CEvaluatorDescriptorImpl | |
| CEvaluatorException | |
| CEvaluatorRequestBuilder | |
| CIAllocatedEvaluator | Represents an Evaluator that is allocated, but is not running yet |
| CICompletedEvaluator | Represents an Evaluator that has completed |
| CIEvaluatorDescriptor | Metadata about an Evaluator |
| CIEvaluatorRequest | A request for an Evaluator allocation |
| CIEvaluatorRequestor | Interface through which Evaluators can be requested |
| CIFailedEvaluator | Represents an Evaluator that became unavailable |
| ►NTask | |
| CICompletedTask | |
| CIFailedTask | |
| CIRunningTask | Represents a running Task |
| CISuspendedTask | Represents a suspended task |
| CITaskMessage | Driver-side representation of a message sent from a Task to the Driver |
| CConstants | |
| CDriverConfigGenerator | |
| CDriverConfiguration | Fill this out to configure a Driver |
| CDriverConfigurationSettings | |
| CDriverSubmissionSettings | |
| CIDriver | empty driver interface to facilitate referencing driver dll |
| CIDriverRestartCompleted | Event fired on Driver restart completed |
| CIDriverRestarted | Event fired on Driver restarts instead of IDriverStarted |
| CIDriverStarted | Event fired when the Driver started |
| CIProgressProvider | Provides the progress of the job to the Resource Manager |
| ►NEvaluator | |
| CEvaluator | |
| ►NIMRU | |
| ►NAPI | |
| CIIMRUClient | |
| CIIMRUResultHandler | Interface defining how to handle the output of Update function in IMRU |
| CIMapFunction | Interface to be implemented by Map functions in IMRU |
| CIMRUCodecConfiguration | A configuration module for specifying codecs for IMRU |
| CIMRUJobDefinition | Describes an IMRU Job |
| CIMRUJobDefinitionBuilder | Use this class to create an IMRU Job Definition |
| CIMRUMapConfiguration | A configuration module for IMRU IMapFunction |
| CIMRUPerMapperConfigGeneratorConfiguration | A configuration module for per mapper configuration |
| CIMRUPipelineDataConverterConfiguration | A configuration module for The PipelineDataConverter used for chunking and dechunking TMapInput and TMapOutput |
| CIMRUReduceFunctionConfiguration | A configuration module for IMRU Reduce function |
| CIMRUUpdateConfiguration | A configuration module for IMRU Update function |
| CIPerMapperConfigGenerator | Class returning mapper specific configuration |
| CIUpdateFunction | The interface for the Update function of IMRU |
| CPerMapConfigGeneratorSet | |
| CUpdateResult | Represents the output of an IUpdateFunction |
| ►NInProcess | |
| ►NParameters | |
| CNumberOfMappers | The number of mappers to instantiate |
| CInProcessIMRUClient | Implements the IMRU client API for in-process execution |
| CInProcessIMRUConfiguration | Configuration module for the in-process IMRU |
| ►NOnREEF | |
| ►NClient | |
| CREEFIMRUClientConfiguration | A configuration module for specifying REEFIMRUClient |
| ►NResultHandler | |
| CResultOutputLocation | |
| CWriteResultHandler | Writes IMRU result from Update task to a file |
| ►NIO | |
| ►NFileSystem | |
| ►NAzureBlob | |
| ►NParameters | |
| CAzureStorageConnectionString | |
| ►NRetryPolicy | |
| CIAzureBlobRetryPolicy | |
| CAzureBlockBlobFileSystemConfiguration | Configuration Module for the Azure Block Blob (WASB) file system implementation of IFileSystem |
| ►NHadoop | |
| CHadoopFileSystemConfiguration | Configuration Module for the (command based) Hadoop file system implementation of IFileSystem |
| CHDFSConfigurationWithoutDriverBinding | Configuration Module for the (command based) Hadoop file system implementation of IFileSystem |
| ►NLocal | |
| CLocalFileSystemConfiguration | ConfigurationModule for the local file system |
| CFileStatus | Represents metadata about a file |
| CIFileSystem | A file system abstraction |
| ►NPartitionedData | |
| ►NFileSystem | |
| CFileSystemInputPartitionConfiguration | This configuration module set FileSystemDataSet as IPartitionedDataSet |
| CIFileDeSerializer | A interface for user to implement its deserializer |
| ►NRandom | |
| CRandomInputDataConfiguration | Configuration module for the random dataset generator |
| CIInputPartition | Evaluator-Side representation of a data set partition |
| CIPartitionDescriptor | Driver-Side representation of a partition |
| CIPartitionedInputDataSet | Driver-Side representation of a partitioned data set |
| ►NTempFileCreation | |
| CITempFileCreator | Provide interface to wrap temp file folder and temp file folder creation |
| CTempFileConfigurationModule | Configuration Module for TempFileCreator |
| CTempFileFolder | Folder for local temp file |
| ►NTestClient | |
| CAssert | |
| CAssertFailedException | |
| CHadoopFileSystemTest | |
| CRun | This purpose of this test is to run tests in Yarn environment |
| ►NNetwork | |
| ►NGroup | |
| ►NConfig | |
| CCodecConfiguration | |
| CCodecToStreamingCodecConfiguration | |
| ►CGroupCommConfigurationOptions | |
| CCommunicationGroupName | |
| CDriverId | |
| CFanOut | |
| CGroupName | |
| CInitialize | |
| CMasterTaskId | |
| CMessageType | |
| CNumberOfTasks | |
| COperatorName | |
| CSerializedGroupConfigs | |
| CSerializedOperatorConfigs | |
| CTimeout | |
| CTopologyChildTaskIds | |
| CTopologyRootTaskId | |
| CPipelineDataConverterConfiguration | |
| CReduceFunctionConfiguration | |
| CStreamingCodecConfiguration | Defines configuration for streaming codecs and pipeline message streaming codecs by taking streaming codec as input |
| CStreamingCodecConfigurationMinusMessage | Defines configuration for internal streaming codecs and internal pipeline message streaming codecs required for group communication |
| ►NDriver | |
| ►NImpl | |
| CGeneralGroupCommunicationMessage | Messages sent by MPI Operators |
| CGroupCommDriver | Used to create Communication Groups for Group Communication Operators on the Reef driver |
| CTaskStarter | Helper class to start Group Communication tasks |
| CICommunicationGroupDriver | Used to configure Group Communication operators in Reef driver |
| CIGroupCommDriver | Used to create Communication Groups for Group Communication Operators |
| ►NOperators | |
| ►NImpl | |
| CBroadcastOperatorSpec | The specification used to define Broadcast Operators |
| CBroadcastReceiver | Group Communication Operator used to receive broadcast messages in pipelined fashion |
| CBroadcastSender | Group Communication Operator used to send messages to child Tasks in pipelined fashion |
| CPipelinedReduceFunction | The class used to aggregate pipelined messages sent by ReduceSenders |
| CReduceFunction | |
| CReduceOperatorSpec | The specification used to define Reduce Group Communication Operators |
| CReduceReceiver | Group Communication operator used to receive and reduce messages in pipelined fashion |
| CReduceSender | Group Communication Operator used to send messages to be reduced by the ReduceReceiver in pipelined fashion |
| CScatterOperatorSpec | The specification used to define Scatter Group Communication Operators |
| CScatterReceiver | Group Communication operator used to receive a sublist of messages sent from the IScatterSender |
| CScatterSender | Group Communication operator used to scatter a list of elements to all of the IScatterReceivers |
| CIBroadcastReceiver | Group Communication Operator used to receive broadcast messages |
| CIBroadcastSender | Group Communication Operator used to send messages to child Tasks |
| CIGroupCommOperator | An Group Communication Operator to be used in a Reef Task |
| CIOperatorSpec | The specification used to define Broadcast Operators |
| CIReduceFunction | The class used to aggregate messages sent by ReduceSenders |
| CIReduceReceiver | Group Communication operator used to receive and reduce messages |
| CIReduceSender | Group Communication Operator used to send messages to be reduced by the ReduceReceiver |
| CIScatterReceiver | Group Communication operator used to receive a sublist of messages sent from the IScatterSender |
| CIScatterSender | Group Communication operator used to scatter a list of elements to all of the IScatterReceivers |
| ►NPipelining | |
| ►NImpl | |
| CDefaultPipelineDataConverter | Default IPipelineDataConverter implementation This basically is a non-pipelined implementation that just packs the whole message in one single PipelineMessage |
| CIPipelineDataConverter | User specified class to convert the message to be communicated in to pipelining amenable data and vice-versa |
| CPipelineMessage | the message for pipelined communication |
| CPipelineMessageCodec | The codec for PipelineMessage |
| CStreamingPipelineMessageCodec | The streaming codec for PipelineMessage |
| ►NTask | |
| ►NImpl | |
| CGroupCommClient | Used by Tasks to fetch CommunicationGroupClients |
| COperatorTopology | Contains the Operator's topology graph |
| CICommunicationGroupClient | Used by Tasks to fetch Group Communication Operators in the group configured by the driver |
| CIGroupCommClient | Used by Tasks to fetch CommunicationGroupClients |
| CIOperatorTopology | Contains the Operator's topology graph |
| ►NTopology | |
| CITopology | Represents a topology graph for IGroupCommOperators |
| ►NNaming | |
| ►NContracts | |
| CAvroNamingAssignment | Used to serialize and deserialize Avro record Org.Apache.REEF.Network.Naming.Contracts.AvroNamingAssignment |
| CAvroNamingLookupRequest | Used to serialize and deserialize Avro record Org.Apache.REEF.Network.Naming.Contracts.AvroNamingLookupRequest |
| CAvroNamingLookupResponse | Used to serialize and deserialize Avro record Org.Apache.REEF.Network.Naming.Contracts.AvroNamingLookupResponse |
| CAvroNamingRegisterRequest | Used to serialize and deserialize Avro record Org.Apache.REEF.Network.Naming.Contracts.AvroNamingRegisterRequest |
| CAvroNamingUnRegisterRequest | Used to serialize and deserialize Avro record Org.Apache.REEF.Network.Naming.Contracts.AvroNamingUnRegisterRequest |
| ►NParameters | |
| ►CNameCacheConfiguration | |
| CCacheEntryExpiryTime | |
| CCacheMemoryLimit | |
| CPollingInterval | |
| CINameServer | Service that manages names and IPEndpoints for well known hosts |
| CNameClient | Client for the Reef name service |
| ►CNameServer | Service that manages names and IPEndpoints for well known hosts |
| CPort | |
| ►NNetworkService | |
| ►NCodec | |
| CControlMessageCodec | |
| CNsMessageCodec | Codec to serialize NsMessages for NetworkService |
| CNsMessageProto | |
| CIConnection | Represents a connection between two endpoints named by identifiers |
| CINetworkService | Network service used for Reef Task communication |
| CNetworkService | Network service used for Reef Task communication |
| CNetworkServiceConfiguration | |
| ►CNetworkServiceOptions | |
| CNetworkServicePort | |
| CNsConnection | Represents a connection between two hosts using the NetworkService |
| CNsMessage | Message sent between NetworkServices |
| CStreamingNetworkService | Writable Network service used for Reef Task communication |
| ►NUtilities | |
| CBlockingCollectionExtensions | |
| ►NTang | |
| ►NAnnotations | |
| CDefaultImplementationAttribute | DefaultImplementationAttribute |
| CInjectAttribute | InjectAttribute |
| CName | Base class for named parameters |
| CNamedParameterAttribute | |
| CParameterAttribute | ParameterAttribute |
| CUnitAttribute | UnitAttribute |
| ►NExceptions | |
| CBindException | |
| CClassHierarchyException | |
| CIllegalStateException | |
| CInjectionException | |
| CNameResolutionException | |
| CParseException | |
| ►NFormats | |
| ►NAvroConfigurationDataContract | |
| CAvroConfiguration | |
| CConfigurationEntry | |
| CAvroConfigurationResolver | |
| CAvroConfigurationSerializer | |
| CConfigurationFile | |
| CConfigurationModule | Allows applications to bundle sets of configuration options together into discrete packages |
| CConfigurationModuleBuilder | |
| CIConfigurationSerializer | |
| CIImpl | |
| CIParam | |
| COptionalImpl | |
| COptionalParameter | |
| CProvides | |
| CRequiredImpl | |
| CRequiredParameter | |
| ►NImplementations | |
| ►NClassHierarchy | |
| ►NAvroDataContract | |
| CAvroClassNode | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroClassNode |
| CAvroConstructorArg | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroConstructorArg |
| CAvroConstructorDef | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroConstructorDef |
| CAvroNamedParameterNode | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroNamedParameterNode |
| CAvroNode | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroNode |
| CAvroPackageNode | Used to serialize and deserialize Avro record org.apache.reef.tang.implementation.avro.AvroPackageNode |
| ►NConfiguration | |
| CConfigurations | |
| ►NInjectionPlan | |
| CIInjectionFuture | |
| CInjectionFutureImpl | |
| CInjectionPlan | |
| ►NTang | |
| CTangFactory | |
| ►NInterface | |
| CAspect | |
| CIClassHierarchy | |
| CIClassHierarchySerializer | |
| CIConfiguration | |
| CIConfigurationBuilder | |
| CIConfigurationProvider | Provides configurations |
| CICsClassHierarchy | |
| CICsConfigurationBuilder | |
| CIExternalConstructor | |
| CIInjector | |
| CITang | |
| ►NProtobuf | |
| CClassNode | |
| CConstructor | |
| CConstructorArg | |
| CConstructorDef | |
| CInjectionPlan | |
| CInstance | |
| CNamedParameterNode | |
| CNode | |
| CPackageNode | |
| CProtocolBufferClassHierarchy | |
| CSubplan | |
| ►NTools | |
| CClassHierarchyBuilder | |
| ►NTypes | |
| CIClassNode | |
| CIConstructorArg | |
| CIConstructorDef | |
| CINamedParameterNode | |
| CINode | |
| CIPackageNode | |
| CITraversable | |
| ►NUtil | |
| CAbstractMonotonicMultiMap | |
| CAssemblyLoader | |
| CGenericType | |
| CMonotonicHashMap | |
| CMonotonicHashSet | |
| CMonotonicMultiHashMap | |
| CMonotonicMultiMap | |
| CMonotonicSet | |
| CMonotonicTreeMap | |
| CReflectionUtilities | |
| ►NUtilities | |
| ►NAsyncUtils | |
| CRemoveSynchronizationContextAwaiter | This is to avoid deadlocks in clients that use synchronization context (WinForms/ASP.NET) Use at asynchronous entry points of all async REEF client APIs |
| CVoidResult | A type used to indicate that no meaningful value is returned |
| ►NAttributes | |
| CClientSideAttribute | Attribute target should be used by REEF Clients |
| CDriverSideAttribute | Attribute target should be used at the Job Driver |
| CEvaluatorSideAttribute | Attribute target should be used by Evaluators |
| CInteropAttribute | Attribute target is used at the Interop layer |
| CPrivateAttribute | Attribute target should not be used by users, and may change at any time without a deprecation phase |
| CTaskSideAttribute | Attribute target should be used by Tasks |
| CTestingAttribute | Attribute target should only be used in tests |
| CUnstableAttribute | Signals that the API is NOT stabilized |
| ►NCollections | |
| CPriorityQueue | A simple priority queue implementation, where the head of the queue is the smallest element in the priority queue |
| CReadOnlySet | An implementation of a set that is read only |
| ►NDiagnostics | |
| CExceptions | |
| ►NLogging | |
| CLogger | |
| CAvroUtils | |
| CByteUtilities | |
| CIIdentifiable | Denotes an object that has a string identifier |
| CIMessage | A message from a REEF component |
| CNetUtilities | |
| COptional | |
| CValidationUtilities | |
| ►NWake | |
| ►NExamples | |
| ►NP2p | |
| CIEventSource | The pull side of the interface: Clients implement this and register it with the PullToPush class |
| CPull2Push | Performs a Pull-to-Push conversion in Wake |
| ►NImpl | |
| CLoggingEventHandler | A logging event handler |
| CMissingStartHandlerHandler | |
| CMultiEventHandler | Event handler that dispatches an event to a specific handler based on an event class type |
| CPeriodicEvent | Periodic event for timers |
| CPubSubEventHandler | Event handler to provide publish/subscribe interfaces |
| CSingleThreadStage | Single thread stage that runs the event handler |
| CSyncStage | Stage that synchronously executes an event handler |
| CThreadPoolStage | Stage that executes an event handler with a thread pool |
| CTimerStage | Stage that triggers an event handler periodically |
| ►NRemote | |
| ►NImpl | |
| CByteCodec | |
| CByteCodecFactory | |
| CChannel | Performs low level network IO operations between hosts |
| CDefaultRemoteManager | Manages incoming and outgoing messages between remote hosts |
| CIntCodec | |
| CLink | Represents an open connection between remote hosts |
| CMultiCodec | Codec that can encode and decode a class depending on the class type |
| CMultiDecoder | Decoder using the WakeTuple protocol buffer (class name and bytes) |
| CMultiEncoder | Encoder using the WakeTuple protocol buffer (class name and bytes) |
| CRemoteEvent | |
| CRemoteEventDecoder | |
| CRemoteEventEncoder | |
| CRemoteEventEndPoint | |
| CSocketRemoteIdentifier | Remote identifier based on a socket address |
| CStreamDataReader | Class with functions to Read from stream |
| CStreamDataWriter | |
| CStreamingRemoteManagerFactory | StreamingRemoteManagerFactory for StreamingRemoteManager |
| CStringCodec | |
| CStringIdentifier | |
| CStringIdentifierFactory | |
| CTransportClient | Establish connections to TransportServer for remote message passing |
| CTransportEvent | |
| CTransportServer | Server to handle incoming remote messages |
| ►NParameters | |
| CTcpPortRangeCount | |
| CTcpPortRangeSeed | |
| CTcpPortRangeStart | |
| CTcpPortRangeTryCount | |
| ►NProto | |
| CWakeMessagePBuf | Message p buff |
| CWakeTuplePBuf | Wake tuple buf |
| CICodec | |
| CICodecFactory | |
| CIDataReader | Interface for reading standard primitives |
| CIDataWriter | Interface for writing standard primitives |
| CIDecoder | |
| CIEncoder | |
| CILink | Represents a link between two endpoints |
| CIRemoteEvent | |
| CIRemoteIdentifier | An identifier that represents a remote source |
| CIRemoteIdentifierFactory | Factory that creates a RemoteIdentifier |
| CIRemoteManager | |
| CIRemoteManagerFactory | Creates new instances of IRemoteManager |
| CIRemoteMessage | Message received from a remote handler |
| CISubscriptionManager | |
| CITcpPortProvider | Provides port numbers for tcp listeners |
| ►CRemoteConfiguration | |
| CErrorHandler | |
| CHostAddress | |
| CManagerName | |
| CMessageCodec | |
| COrderingGuarantee | |
| CPort | |
| CRemoteRuntimeException | Wake remote runtime exception |
| CTcpPortProvider | |
| ►NRX | |
| ►NImpl | |
| CPubSubSubject | Subject to provide publish/subscribe interface |
| CRxSyncStage | Stage that executes the observer synchronously |
| CRxThreadPoolStage | Stage that executes the observer with a thread pool |
| CRxTimerStage | Timer stage that provides events to the observer periodically |
| CSimpleSubject | A Subject that relays all messages to its subscribers. |
| CAbstractObserver | An observer with logging-only onError and onCompleted() methods |
| CAbstractRxStage | An Rx stage that implements metering |
| CIRxStage | Stage that executes the observer |
| CIStaticObservable | |
| CISubject | A class implementing Observer> and StaticObservable |
| CObserverCompletedException | It is illegal to call onError() or onCompleted() when a call to onNext() is still outstanding, or to call onNext(), onError() or onCompleted() after a call to onError() or onCompleted() has been dispatched |
| ►NStreamingCodec | |
| ►NCommonStreamingCodecs | |
| CDoubleArrayStreamingCodec | Streaming codec for double array |
| CDoubleStreamingCodec | Streaming codec for double |
| CFloatArrayStreamingCodec | Streaming codec for float array |
| CFloatStreamingCodec | Streaming codec for float |
| CIntArrayStreamingCodec | Streaming codec for integer array |
| CIntStreamingCodec | Streaming codec for integer |
| CStringStreamingCodec | Streaming codec for string |
| CCodecToStreamingCodec | Converts codec to streaming codec |
| CIStreamingCodec | Codec Interface that external users should implement to directly write to the stream |
| ►NTime | |
| ►NEvent | |
| CAlarm | Represents a timer event |
| CStartTime | Represents the Time at which a component started |
| CStopTime | Represents the Time at which a component stops |
| ►NRuntime | |
| ►NEvent | |
| CClientAlarm | |
| CIdleClock | |
| CRuntimeAlarm | |
| CRuntimeStart | |
| CRuntimeStop | |
| CITimer | |
| CLogicalTimer | LogicalTimer class used for testing purposes |
| CRealTimer | |
| CRuntimeClock | |
| ►CIClock | |
| CIdleHandler | Bind this to an event handler to statically subscribe to the IdleClock Event |
| CRuntimeStartHandler | Bind this to an event handler to statically subscribe to the RuntimeStart Event |
| CRuntimeStopHandler | Bind this to an event handler to statically subscribe to the RuntimeStop Event |
| CStartHandler | Bind this to an event handler to statically subscribe to the StartTime Event |
| CStopHandler | Bind this to an event handler to statically subscribe to the StopTime Event |
| CTime | Time object |
| ►NUtil | |
| CActionable | |
| CFixedThreadPoolTaskService | |
| CIStartable | |
| CITaskService | |
| CNetworkUtils | |
| CSerializationHelper | |
| CTaskExtensions | |
| CTimeHelper | |
| CAbstractEStage | An estage that implements metering |
| CIEStage | Stage that executes an event handler |
| CIEventHandler | Handler to process an event |
| CIIdentifier | Identifier class for REEF |
| CIIdentifierFactory | |
| CIObserverFactory | |
| CIStage | Stage is an execution unit for events and provides a way to reclaim its resources |
| CWakeRuntimeException | Wake runtime exception |
1.8.11
