| 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 | |
| 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 | 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> |
| Modifier and Type | Class and Description |
|---|---|
class |
REEFMessageCodec
Codec for REEF's control flow messages.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
Codec<T>
Interface for serialization routines that translate back and forth between
byte arrays with low latency.
|
| 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 |
MultiDecoder<T>
Decoder 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 |
RemoteEventDecoder<T>
Remote event decoder using the WakeMessage protocol buffer
|
class |
StringCodec
Codec that encodes/decodes a string
|
| Constructor and Description |
|---|
RemoteEventDecoder(Decoder<T> decoder)
Constructs a remote event decoder
|
| Constructor and Description |
|---|
MultiDecoder(Map<Class<? extends T>,Decoder<? extends T>> clazzToDecoderMap)
Constructs a decoder that decodes bytes based on the class name
|
Copyright © 2015 The Apache Software Foundation. All rights reserved.