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

Class KeyedGatherConfig

java.lang.Object

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

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

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

public class KeyedGatherConfig
extends AbstractKeyedOpsConfig<KeyedGatherConfig>

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
KeyedGatherConfig(java.lang.String parent, ComputeConnection computeConnection)

Method Summary

Modifier and Type	Method and Description
KeyedGatherConfig	groupBatchByKey(boolean groupByKey)
<T> KeyedGatherConfig	sortBatchByKey(java.lang.Class<T> tClass, java.util.Comparator<T> keyComparator)
<T> KeyedGatherConfig	sortBatchByKey(java.util.Comparator<T> keyComparator)
protected Edge	updateEdge(Edge newEdge)

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

KeyedGatherConfig

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

Method Detail

sortBatchByKey

public <T> KeyedGatherConfig sortBatchByKey(java.util.Comparator<T> keyComparator)

sortBatchByKey

public <T> KeyedGatherConfig sortBatchByKey(java.lang.Class<T> tClass,
                                            java.util.Comparator<T> keyComparator)

groupBatchByKey

public KeyedGatherConfig groupBatchByKey(boolean groupByKey)

updateEdge

protected Edge updateEdge(Edge newEdge)

Specified by:

updateEdge in class AbstractOpsConfig<KeyedGatherConfig>