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

Class AbstractKeyedOpsConfig<T extends AbstractOpsConfig>

java.lang.Object

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

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

Direct Known Subclasses:

JoinConfig, KeyedGatherConfig, KeyedPartitionConfig, KeyedReduceConfig

public abstract class AbstractKeyedOpsConfig<T extends AbstractOpsConfig>
extends AbstractOpsConfig<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected MessageType	opKeyType
protected TaskPartitioner	tPartitioner

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

Method Summary

Modifier and Type	Method and Description
protected void	generateSchema() This method tries to generate a schema, if user hasn't given a schema
T	useDisk(boolean useDisk)
T	withKeyType(MessageType keyType)
<C> T	withTaskPartitioner(java.lang.Class<C> tClass, TaskPartitioner<C> taskPartitioner)
T	withTaskPartitioner(TaskPartitioner taskPartitioner)

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

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

Methods inherited from class java.lang.Object

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

Field Detail

opKeyType

protected MessageType opKeyType

tPartitioner

protected TaskPartitioner tPartitioner

Constructor Detail

AbstractKeyedOpsConfig

protected AbstractKeyedOpsConfig(java.lang.String parent,
                                 java.lang.String operationName,
                                 ComputeConnection computeConnection)

Method Detail

withTaskPartitioner

public <C> T withTaskPartitioner(java.lang.Class<C> tClass,
                                 TaskPartitioner<C> taskPartitioner)

withTaskPartitioner

public T withTaskPartitioner(TaskPartitioner taskPartitioner)

withKeyType

public T withKeyType(MessageType keyType)

useDisk

public T useDisk(boolean useDisk)

generateSchema

protected void generateSchema()

Description copied from class: AbstractOpsConfig

This method tries to generate a schema, if user hasn't given a schema

Overrides:

generateSchema in class AbstractOpsConfig<T extends AbstractOpsConfig>