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

Class KeyedReduceConfig

java.lang.Object

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

edu.iu.dsc.tws.task.impl.ops.AbstractKeyedOpsConfig<KeyedReduceConfig>

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

public class KeyedReduceConfig
extends AbstractKeyedOpsConfig<KeyedReduceConfig>

Field Summary

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

opKeyType, tPartitioner

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

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

Constructor Summary

Constructors

Constructor and Description
KeyedReduceConfig(java.lang.String parent, ComputeConnection computeConnection)

Method Summary

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

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

generateSchema, useDisk, withKeyType, withTaskPartitioner, withTaskPartitioner

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

connect, failValidation, 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

KeyedReduceConfig

public KeyedReduceConfig(java.lang.String parent,
                         ComputeConnection computeConnection)

Method Detail

withReductionFunction

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

Define a function to handle the reduction

Parameters:

tClass - Class of IFunction arguments

withReductionFunction

public KeyedReduceConfig withReductionFunction(IFunction reductionFunction)

withOperation

public KeyedReduceConfig withOperation(Op operation,
                                       MessageType dataType)

updateEdge

protected Edge updateEdge(Edge newEdge)

Specified by:

updateEdge in class AbstractOpsConfig<KeyedReduceConfig>