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

Class JoinConfig

java.lang.Object

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

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

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

public class JoinConfig
extends AbstractKeyedOpsConfig<JoinConfig>

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
JoinConfig(java.lang.String leftParent, java.lang.String rightParent, ComputeConnection computeConnection, CommunicationContext.JoinType joinType, CommunicationContext.JoinAlgorithm joinAlgorithm)

Method Summary

Modifier and Type	Method and Description
ComputeConnection	connect()
protected void	generateSchema() This method tries to generate a schema, if user hasn't given a schema
protected Edge	updateEdge(Edge newEdge)
JoinConfig	useDisk(boolean useDisk)
JoinConfig	viaLeftEdge(java.lang.String edge)
JoinConfig	viaRightEdge(java.lang.String edge)
<T> JoinConfig	withComparator(java.util.Comparator<T> keyComparator)
JoinConfig	withLeftDataType(MessageType dataType)
JoinConfig	withLeftMessageSchema(MessageSchema messageSchema)
JoinConfig	withMessageSchema(MessageSchema messageSchema)
JoinConfig	withRightDataType(MessageType dataType)
JoinConfig	withRightMessageSchema(MessageSchema messageSchema)
JoinConfig	withTargetEdge(java.lang.String g)

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

withKeyType, withTaskPartitioner, withTaskPartitioner

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

failValidation, getEdgeName, getOpDataType, getSource, runValidation, viaEdge, withDataType, withProperties, withProperty

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinConfig

public JoinConfig(java.lang.String leftParent,
                  java.lang.String rightParent,
                  ComputeConnection computeConnection,
                  CommunicationContext.JoinType joinType,
                  CommunicationContext.JoinAlgorithm joinAlgorithm)

Method Detail

useDisk

public JoinConfig useDisk(boolean useDisk)

Overrides:

useDisk in class AbstractKeyedOpsConfig<JoinConfig>

withComparator

public <T> JoinConfig withComparator(java.util.Comparator<T> keyComparator)

viaLeftEdge

public JoinConfig viaLeftEdge(java.lang.String edge)

viaRightEdge

public JoinConfig viaRightEdge(java.lang.String edge)

withRightDataType

public JoinConfig withRightDataType(MessageType dataType)

withLeftDataType

public JoinConfig withLeftDataType(MessageType dataType)

withMessageSchema

public JoinConfig withMessageSchema(MessageSchema messageSchema)

Overrides:

withMessageSchema in class AbstractOpsConfig<JoinConfig>

withLeftMessageSchema

public JoinConfig withLeftMessageSchema(MessageSchema messageSchema)

withRightMessageSchema

public JoinConfig withRightMessageSchema(MessageSchema messageSchema)

withTargetEdge

public JoinConfig withTargetEdge(java.lang.String g)

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 AbstractKeyedOpsConfig<JoinConfig>

connect

public ComputeConnection connect()

Overrides:

connect in class AbstractOpsConfig<JoinConfig>

updateEdge

protected Edge updateEdge(Edge newEdge)

Specified by:

updateEdge in class AbstractOpsConfig<JoinConfig>