| Package | Description | 
|---|---|
| org.apache.reef.examples.suspend | 
 suspend/resume demo. 
 | 
| org.apache.reef.io.network.impl | 
 Licensed to the Apache Software Foundation (ASF) under one
 or more contributor license agreements. 
 | 
| org.apache.reef.io.network.naming.serialization | 
 Contains naming serialization codecs 
 | 
| org.apache.reef.io.network.util | 
 Licensed to the Apache Software Foundation (ASF) under one
 or more contributor license agreements. 
 | 
| org.apache.reef.runtime.common.launch | 
 Common launch code between Driver and Evaluator. 
 | 
| org.apache.reef.wake.remote.impl | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ObjectWritableCodec<T extends org.apache.hadoop.io.Writable>
Codec for Hadoop Writable object serialization. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
StreamingCodec<T>
A codec that can make serialization more efficient when an object has to be
 codec'ed through a chain of codecs 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
NSMessageCodec<T>
Network service message codec 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Codec<T> | 
NetworkService.getCodec()  | 
| Constructor and Description | 
|---|
NetworkService(IdentifierFactory factory,
                            int nsPort,
                            String nameServerAddr,
                            int nameServerPort,
                            Codec<T> codec,
                            TransportFactory tpFactory,
                            EventHandler<Message<T>> recvHandler,
                            EventHandler<Exception> exHandler)  | 
NetworkService(IdentifierFactory factory,
                            int nsPort,
                            String nameServerAddr,
                            int nameServerPort,
                            int retryCount,
                            int retryTimeout,
                            Codec<T> codec,
                            TransportFactory tpFactory,
                            EventHandler<Message<T>> recvHandler,
                            EventHandler<Exception> exHandler)  | 
NSMessageCodec(Codec<T> codec,
                            IdentifierFactory factory)
Constructs a network service message codec 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
NamingLookupRequestCodec
Naming lookup request codec 
 | 
class  | 
NamingLookupResponseCodec
Naming lookup response codec 
 | 
class  | 
NamingRegisterRequestCodec
Naming registration request codec 
 | 
class  | 
NamingRegisterResponseCodec
naming registration response codec 
 | 
class  | 
NamingUnregisterRequestCodec
Naming un-registration request codec 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ListCodec<T>  | 
| Constructor and Description | 
|---|
ListCodec(Codec<T> codec)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
REEFMessageCodec
Codec for REEF's control flow messages. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ByteCodec
Codec that performs identity transformation on bytes 
 | 
class  | 
MultiCodec<T>
Codec using the WakeTuple protocol buffer
 (class name and bytes) 
 | 
class  | 
ObjectSerializableCodec<T>
Codec that uses Java serialization 
 | 
class  | 
RemoteEventCodec<T>
Codec of the event sent remotely 
 | 
class  | 
StringCodec
Codec that encodes/decodes a string 
 | 
| Constructor and Description | 
|---|
DefaultRemoteManagerImplementation(String name,
                                                                    String hostAddress,
                                                                    int listeningPort,
                                                                    Codec<T> codec,
                                                                    EventHandler<Throwable> errorHandler,
                                                                    boolean orderingGuarantee,
                                                                    int numberOfTries,
                                                                    int retryTimeout)  | 
RemoteEventCodec(Codec<T> codec)
Constructs a remote event codec 
 | 
| Constructor and Description | 
|---|
MultiCodec(Map<Class<? extends T>,Codec<? extends T>> clazzToCodecMap)
Constructs a codec that encodes/decodes an object to/from bytes based on the class name 
 | 
Copyright © 2015 The Apache Software Foundation. All rights reserved.