Uses of Interface
org.apache.reef.wake.remote.Encoder

Packages that use Encoder

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
org.apache.reef.wake.remote.transport
org.apache.reef.wake.remote.transport.netty

Uses of Encoder in org.apache.reef.examples.suspend

Classes in org.apache.reef.examples.suspend that implement Encoder

Modifier and Type	Class and Description
class	ObjectWritableCodec<T extends org.apache.hadoop.io.Writable> Codec for Hadoop Writable object serialization.

Uses of Encoder in org.apache.reef.io.network.impl

Subinterfaces of Encoder in org.apache.reef.io.network.impl

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

Classes in org.apache.reef.io.network.impl that implement Encoder

Modifier and Type	Class and Description
class	NSMessageCodec<T> Network service message codec

Uses of Encoder in org.apache.reef.io.network.naming.serialization

Classes in org.apache.reef.io.network.naming.serialization that implement Encoder

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

Uses of Encoder in org.apache.reef.io.network.util

Classes in org.apache.reef.io.network.util that implement Encoder

Modifier and Type	Class and Description
class	ListCodec<T>

Uses of Encoder in org.apache.reef.runtime.common.launch

Classes in org.apache.reef.runtime.common.launch that implement Encoder

Modifier and Type	Class and Description
class	REEFMessageCodec Codec for REEF's control flow messages.

Uses of Encoder in org.apache.reef.wake.remote

Subinterfaces of Encoder in org.apache.reef.wake.remote

Modifier and Type	Interface and Description
interface	Codec<T> Interface for serialization routines that translate back and forth between byte arrays with low latency.

Uses of Encoder in org.apache.reef.wake.remote.impl

Classes in org.apache.reef.wake.remote.impl that implement Encoder

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	MultiEncoder<T> Encoder 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	RemoteEventEncoder<T> Remote event encoder using the WakeMessage protocol buffer
class	StringCodec Codec that encodes/decodes a string

Constructors in org.apache.reef.wake.remote.impl with parameters of type Encoder

Constructor and Description
RemoteEventEncoder(Encoder<T> encoder) Constructs a remote event encoder
RemoteSenderStage(Encoder encoder, Transport transport, int numThreads) Constructs a remote sender stage

Constructor parameters in org.apache.reef.wake.remote.impl with type arguments of type Encoder

Constructor and Description
MultiEncoder(Map<Class<? extends T>,Encoder<? extends T>> clazzToEncoderMap) Constructs an encoder that encodes an object to bytes based on the class name

Uses of Encoder in org.apache.reef.wake.remote.transport

Methods in org.apache.reef.wake.remote.transport with parameters of type Encoder

Modifier and Type	Method and Description
<T> Link<T>	Transport.open(SocketAddress remoteAddr, Encoder<? super T> encoder, LinkListener<? super T> listener) Returns a link for the remote address if cached; otherwise opens, caches and returns When it opens a link for the remote address, only one attempt for the address is made at a given time

Uses of Encoder in org.apache.reef.wake.remote.transport.netty

Classes in org.apache.reef.wake.remote.transport.netty that implement Encoder

Modifier and Type	Class and Description
class	ByteEncoder Wrapping encoder for byte[]

Methods in org.apache.reef.wake.remote.transport.netty with parameters of type Encoder

Modifier and Type	Method and Description
<T> Link<T>	NettyMessagingTransport.open(SocketAddress remoteAddr, Encoder<? super T> encoder, LinkListener<? super T> listener) Returns a link for the remote address if cached; otherwise opens, caches and returns When it opens a link for the remote address, only one attempt for the address is made at a given time

Constructors in org.apache.reef.wake.remote.transport.netty with parameters of type Encoder

Constructor and Description
NettyLink(io.netty.channel.Channel channel, Encoder<? super T> encoder) Constructs a link
NettyLink(io.netty.channel.Channel channel, Encoder<? super T> encoder, LinkListener<? super T> listener) Constructs a link