org.apache.reef.vortex.examples.sumones

Class IdentityFunction

java.lang.Object

org.apache.reef.vortex.examples.sumones.IdentityFunction

All Implemented Interfaces:

Serializable, VortexFunction<Integer,Integer>

public final class IdentityFunction
extends Object
implements VortexFunction<Integer,Integer>

Identity function.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
IdentityFunction()

Method Summary

Methods

Modifier and Type	Method and Description
Integer	call(Integer input) Outputs input.
Codec<Integer>	getInputCodec() Users must define codec for the input.
Codec<Integer>	getOutputCodec() Users must define codec for the output.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IdentityFunction

public IdentityFunction()

Method Detail

call

public Integer call(Integer input)
             throws Exception

Outputs input.

Specified by:

call in interface VortexFunction<Integer,Integer>

Parameters:

input - of the function

Returns:

output of the function

Throws:

Exception - thrown here will bubble up in VortexFuture#get as ExecutionException Exception should be thrown only after all resources are released as they cannot be cleared by Vortex For example if threads are spawned here, shut them down before throwing an exception

getInputCodec

public Codec<Integer> getInputCodec()

Description copied from interface: VortexFunction

Users must define codec for the input. VoidCodec can be used if the input is empty, and SerializableCodec can be used for (Serializable input. MatMulInputCodec is an example of codec for the custom input.

Specified by:

getInputCodec in interface VortexFunction<Integer,Integer>

Returns:

Codec used to serialize/deserialize the input.

getOutputCodec

public Codec<Integer> getOutputCodec()

Description copied from interface: VortexFunction

Users must define codec for the output. VoidCodec can be used if the output is empty, and SerializableCodec can be used for (Serializable output. MatMulOutputCodec is an example of codec for the custom output.

Specified by:

getOutputCodec in interface VortexFunction<Integer,Integer>

Returns:

Codec used to serialize/deserialize the output.