org.apache.reef.io.network.group.impl.config

Class ReduceOperatorSpec

java.lang.Object

org.apache.reef.io.network.group.impl.config.ReduceOperatorSpec

All Implemented Interfaces:

OperatorSpec

public class ReduceOperatorSpec
extends Object
implements OperatorSpec

The specification for the Reduce operator.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ReduceOperatorSpec.Builder

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
Class<? extends Codec>	getDataCodecClass()
String	getReceiverId()
Class<? extends Reduce.ReduceFunction>	getRedFuncClass()
static ReduceOperatorSpec.Builder	newBuilder()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReduceOperatorSpec

public ReduceOperatorSpec(String receiverId,
                  Class<? extends Codec> dataCodecClass,
                  Class<? extends Reduce.ReduceFunction> redFuncClass)

Method Detail

getReceiverId

public String getReceiverId()

getRedFuncClass

public Class<? extends Reduce.ReduceFunction> getRedFuncClass()

Returns:

the redFuncClass

getDataCodecClass

public Class<? extends Codec> getDataCodecClass()

Specified by:

getDataCodecClass in interface OperatorSpec

Returns:

The codec class to be used to serialize and deserialize data in the group communication operators.

toString

public String toString()

Overrides:

toString in class Object

newBuilder

public static ReduceOperatorSpec.Builder newBuilder()