edu.iu.dsc.tws.task.impl.ops

Class ReduceConfig

java.lang.Object

edu.iu.dsc.tws.task.impl.ops.AbstractOpsConfig<ReduceConfig>

edu.iu.dsc.tws.task.impl.ops.ReduceConfig

Direct Known Subclasses:

AllReduceConfig

public class ReduceConfig
extends AbstractOpsConfig<ReduceConfig>

Field Summary

Fields inherited from class edu.iu.dsc.tws.task.impl.ops.AbstractOpsConfig

computeConnection, edgeName, messageSchema, opDataType, operationName, propertiesMap, source

Constructor Summary

Constructors

Modifier	Constructor and Description
	ReduceConfig(java.lang.String source, ComputeConnection computeConnection)
protected	ReduceConfig(java.lang.String source, java.lang.String operationName, ComputeConnection computeConnection)

Method Summary

Modifier and Type	Method and Description
protected Edge	updateEdge(Edge newEdge)
static void	updateReduceEdge(Edge reduceEdge, IFunction reductionFunction, Op operation, MessageType dataType)
static void	validateReduce(IFunction reductionFunction, Op operation, MessageType dataType)
ReduceConfig	withOperation(Op operation, MessageType dataType)
<T> ReduceConfig	withReductionFunction(java.lang.Class<T> tClass, IFunction<T> reductionFunction) Define a function to handle the reduction
ReduceConfig	withReductionFunction(IFunction reductionFunction)

Methods inherited from class edu.iu.dsc.tws.task.impl.ops.AbstractOpsConfig

connect, failValidation, generateSchema, getEdgeName, getOpDataType, getSource, runValidation, viaEdge, withDataType, withMessageSchema, withProperties, withProperty

Methods inherited from class java.lang.Object

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

Constructor Detail

ReduceConfig

public ReduceConfig(java.lang.String source,
                    ComputeConnection computeConnection)

ReduceConfig

protected ReduceConfig(java.lang.String source,
                       java.lang.String operationName,
                       ComputeConnection computeConnection)

Method Detail

withReductionFunction

public <T> ReduceConfig withReductionFunction(java.lang.Class<T> tClass,
                                              IFunction<T> reductionFunction)

Define a function to handle the reduction

Parameters:

tClass - Class of IFunction arguments

withReductionFunction

public ReduceConfig withReductionFunction(IFunction reductionFunction)

withOperation

public ReduceConfig withOperation(Op operation,
                                  MessageType dataType)

validateReduce

public static void validateReduce(IFunction reductionFunction,
                                  Op operation,
                                  MessageType dataType)

updateReduceEdge

public static void updateReduceEdge(Edge reduceEdge,
                                    IFunction reductionFunction,
                                    Op operation,
                                    MessageType dataType)

updateEdge

protected Edge updateEdge(Edge newEdge)

Specified by:

updateEdge in class AbstractOpsConfig<ReduceConfig>