Uses of Interface
org.apache.reef.io.serialization.Codec

Packages that use Codec

Package	Description
org.apache.reef.io.network.group.api.config	The operator configurations used by users.
org.apache.reef.io.network.group.api.task	Elastic Group Communications Task-side API Interfaces.
org.apache.reef.io.network.group.impl	Implementations for Elastic Group Communications.
org.apache.reef.io.network.group.impl.config	Group Communication Operator Specifications.
org.apache.reef.io.network.group.impl.operators	Implementations for Group Communication Operators.
org.apache.reef.io.network.group.impl.task	Implementations for Elastic Group Communications Task-side API.
org.apache.reef.io.network.group.impl.utils	Utilities for group communication.
org.apache.reef.io.serialization	Serialization utilities.
org.apache.reef.io.storage.local	Implementations for local filesystem-based storage service.
org.apache.reef.io.storage.ram	Implementations for RAM-based storage service.
org.apache.reef.io.storage.util	Utilities for storage services.
org.apache.reef.vortex.api	Vortex user api for running jobs on Vortex.
org.apache.reef.vortex.examples.sumones	A Simple Vortex addition and aggregation example.
org.apache.reef.vortex.util	Utilities used in Vortex.

Uses of Codec in org.apache.reef.io.network.group.api.config

Methods in org.apache.reef.io.network.group.api.config that return types with arguments of type Codec

Modifier and Type	Method and Description
Class<? extends Codec>	OperatorSpec.getDataCodecClass()

Uses of Codec in org.apache.reef.io.network.group.api.task

Methods in org.apache.reef.io.network.group.api.task with parameters of type Codec

Modifier and Type	Method and Description
<T> T	OperatorTopologyStruct.recvFromChildren(Reduce.ReduceFunction<T> redFunc, Codec<T> dataCodec)
<T> T	OperatorTopology.recvFromChildren(Reduce.ReduceFunction<T> redFunc, Codec<T> dataCodec)

Uses of Codec in org.apache.reef.io.network.group.impl

Classes in org.apache.reef.io.network.group.impl that implement Codec

Modifier and Type	Class and Description
class	GroupChangesCodec

Uses of Codec in org.apache.reef.io.network.group.impl.config

Methods in org.apache.reef.io.network.group.impl.config that return types with arguments of type Codec

Modifier and Type	Method and Description
Class<? extends Codec>	ScatterOperatorSpec.getDataCodecClass()
Class<? extends Codec>	ReduceOperatorSpec.getDataCodecClass()
Class<? extends Codec>	GatherOperatorSpec.getDataCodecClass()
Class<? extends Codec>	BroadcastOperatorSpec.getDataCodecClass()

Method parameters in org.apache.reef.io.network.group.impl.config with type arguments of type Codec

Modifier and Type	Method and Description
ScatterOperatorSpec.Builder	ScatterOperatorSpec.Builder.setDataCodecClass(Class<? extends Codec> dataCodecClass)
ReduceOperatorSpec.Builder	ReduceOperatorSpec.Builder.setDataCodecClass(Class<? extends Codec> codecClazz)
GatherOperatorSpec.Builder	GatherOperatorSpec.Builder.setDataCodecClass(Class<? extends Codec> dataCodecClass)
BroadcastOperatorSpec.Builder	BroadcastOperatorSpec.Builder.setDataCodecClass(Class<? extends Codec> codecClazz)

Constructor parameters in org.apache.reef.io.network.group.impl.config with type arguments of type Codec

Constructor and Description
BroadcastOperatorSpec(String senderId, Class<? extends Codec> dataCodecClass)
GatherOperatorSpec(String receiverId, Class<? extends Codec> dataCodecClass)
ReduceOperatorSpec(String receiverId, Class<? extends Codec> dataCodecClass, Class<? extends Reduce.ReduceFunction> redFuncClass)
ScatterOperatorSpec(String senderId, Class<? extends Codec> dataCodecClass)

Uses of Codec in org.apache.reef.io.network.group.impl.operators

Constructors in org.apache.reef.io.network.group.impl.operators with parameters of type Codec

Constructor and Description
BroadcastReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
BroadcastSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
GatherReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
GatherSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
ReduceReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, Reduce.ReduceFunction<T> reduceFunction, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
ReduceSender(String groupName, String operName, String selfId, Codec<T> dataCodec, Reduce.ReduceFunction<T> reduceFunction, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient)
ScatterReceiver(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient, ScatterDecoder scatterDecoder)
ScatterSender(String groupName, String operName, String selfId, Codec<T> dataCodec, String driverId, int version, CommGroupNetworkHandler commGroupNetworkHandler, NetworkService<GroupCommunicationMessage> netService, CommunicationGroupServiceClient commGroupClient, ScatterEncoder scatterEncoder)

Uses of Codec in org.apache.reef.io.network.group.impl.task

Methods in org.apache.reef.io.network.group.impl.task with parameters of type Codec

Modifier and Type	Method and Description
<T> T	OperatorTopologyStructImpl.recvFromChildren(Reduce.ReduceFunction<T> redFunc, Codec<T> dataCodec)
<T> T	OperatorTopologyImpl.recvFromChildren(Reduce.ReduceFunction<T> redFunc, Codec<T> dataCodec)

Uses of Codec in org.apache.reef.io.network.group.impl.utils

Methods in org.apache.reef.io.network.group.impl.utils with parameters of type Codec

Modifier and Type	Method and Description
<T> Map<String,byte[]>	ScatterEncoder.encode(List<T> elements, List<Integer> counts, List<? extends Identifier> taskOrder, Codec<T> dataCodec)

Uses of Codec in org.apache.reef.io.serialization

Classes in org.apache.reef.io.serialization that implement Codec

Modifier and Type	Class and Description
class	SerializableCodec<T extends Serializable> A Codec for Serializable objects.

Uses of Codec in org.apache.reef.io.storage.local

Classes in org.apache.reef.io.storage.local with type parameters of type Codec

Modifier and Type	Class and Description
class	CodecFileAccumulable<T,C extends Codec<T>>
class	CodecFileIterable<T,C extends Codec<T>> A read-only spool implementation, based on files.

Uses of Codec in org.apache.reef.io.storage.ram

Constructors in org.apache.reef.io.storage.ram with parameters of type Codec

Constructor and Description
CodecRamMap(RamStorageService ramStore, Codec<T> c)

Uses of Codec in org.apache.reef.io.storage.util

Classes in org.apache.reef.io.storage.util that implement Codec

Modifier and Type	Class and Description
class	IntegerCodec

Uses of Codec in org.apache.reef.vortex.api

Methods in org.apache.reef.vortex.api that return Codec

Modifier and Type	Method and Description
Codec<TInput>	VortexFunction.getInputCodec() Users must define codec for the input.
Codec<TOutput>	VortexFunction.getOutputCodec() Users must define codec for the output.
Codec<TOutput>	VortexAggregateFunction.getOutputCodec() Users must define codec for the AggregationOutput.

Constructors in org.apache.reef.vortex.api with parameters of type Codec

Constructor and Description
VortexAggregateFuture(Executor executor, Map<Integer,TInput> taskletIdInputMap, Codec<TOutput> aggOutputCodec, FutureCallback<AggregateResult<TInput,TOutput>> callbackHandler)
VortexFuture(Executor executor, VortexMaster vortexMaster, int taskletId, Codec<TOutput> outputCodec) Creates a VortexFuture.
VortexFuture(Executor executor, VortexMaster vortexMaster, int taskletId, Codec<TOutput> outputCodec, FutureCallback<TOutput> callbackHandler) Creates a VortexFuture with a callback.

Uses of Codec in org.apache.reef.vortex.examples.sumones

Methods in org.apache.reef.vortex.examples.sumones that return Codec

Modifier and Type	Method and Description
Codec<Integer>	IdentityFunction.getInputCodec()
Codec<Integer>	IdentityFunction.getOutputCodec()
Codec<Integer>	AdditionAggregateFunction.getOutputCodec()

Uses of Codec in org.apache.reef.vortex.util

Classes in org.apache.reef.vortex.util that implement Codec

Modifier and Type	Class and Description
class	VoidCodec Codec for empty input/output.