| 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.