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

Class AbstractOpsConfig<T extends AbstractOpsConfig>

java.lang.Object

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

Direct Known Subclasses:

AbstractKeyedOpsConfig, BroadcastConfig, DirectConfig, GatherConfig, PartitionConfig, ReduceConfig

public abstract class AbstractOpsConfig<T extends AbstractOpsConfig>
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected ComputeConnection	computeConnection
protected java.lang.String	edgeName
protected MessageSchema	messageSchema
protected MessageType	opDataType
protected java.lang.String	operationName
protected java.util.Map<java.lang.String,java.lang.Object>	propertiesMap
protected java.lang.String	source

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
ComputeConnection	connect()
protected static void	failValidation(java.lang.String msg)
protected void	generateSchema() This method tries to generate a schema, if user hasn't given a schema
java.lang.String	getEdgeName()
protected MessageType	getOpDataType()
java.lang.String	getSource()
protected void	runValidation()
protected abstract Edge	updateEdge(Edge newEdge)
T	viaEdge(java.lang.String edge)
T	withDataType(MessageType dataType)
T	withMessageSchema(MessageSchema mc)
T	withProperties(java.util.Map<java.lang.String,java.lang.Object> properties)
T	withProperty(java.lang.String propertyName, java.lang.Object property)

Methods inherited from class java.lang.Object

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

Field Detail

source

protected java.lang.String source

operationName

protected java.lang.String operationName

computeConnection

protected ComputeConnection computeConnection

edgeName

protected java.lang.String edgeName

opDataType

protected MessageType opDataType

propertiesMap

protected java.util.Map<java.lang.String,java.lang.Object> propertiesMap

messageSchema

protected MessageSchema messageSchema

Constructor Detail

AbstractOpsConfig

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

Method Detail

viaEdge

public T viaEdge(java.lang.String edge)

withProperties

public T withProperties(java.util.Map<java.lang.String,java.lang.Object> properties)

withProperty

public T withProperty(java.lang.String propertyName,
                      java.lang.Object property)

withDataType

public T withDataType(MessageType dataType)

withMessageSchema

public T withMessageSchema(MessageSchema mc)

getSource

public java.lang.String getSource()

getEdgeName

public java.lang.String getEdgeName()

getOpDataType

protected MessageType getOpDataType()

runValidation

protected void runValidation()

failValidation

protected static void failValidation(java.lang.String msg)

updateEdge

protected abstract Edge updateEdge(Edge newEdge)

connect

public ComputeConnection connect()

generateSchema

protected void generateSchema()

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