edu.iu.dsc.tws.task.impl

Class ComputeConnection

java.lang.Object

edu.iu.dsc.tws.task.impl.ComputeConnection

public class ComputeConnection
extends java.lang.Object

Represents a compute connection.

Method Summary

Modifier and Type	Method and Description
AllGatherConfig	allgather(java.lang.String source) Create an allgather config
AllReduceConfig	allreduce(java.lang.String source) Create an allreduce config
BroadcastConfig	broadcast(java.lang.String source) Create a broadcast configuration
DirectConfig	direct(java.lang.String source) Crate a direct config
JoinConfig	fullOuterJoin(java.lang.String leftSource, java.lang.String rightSource) Create an full outer join operation.
GatherConfig	gather(java.lang.String source) Create a gather config
JoinConfig	innerJoin(java.lang.String leftSource, java.lang.String rightSource, CommunicationContext.JoinAlgorithm joinAlgorithm) Create an inner join operation.
KeyedGatherConfig	keyedGather(java.lang.String source) Create a keyed gather config
KeyedPartitionConfig	keyedPartition(java.lang.String source) Create a keyed partition config
KeyedReduceConfig	keyedReduce(java.lang.String source) Create a keyed reduce config
JoinConfig	leftOuterJoin(java.lang.String leftSource, java.lang.String rightSource, CommunicationContext.JoinAlgorithm joinAlgorithm) Create an left outer join operation.
PartitionConfig	partition(java.lang.String source) Create a partition config
ReduceConfig	reduce(java.lang.String source) Create a reduce configuration
JoinConfig	rightOuterJoin(java.lang.String leftSource, java.lang.String rightSource, CommunicationContext.JoinAlgorithm joinAlgorithm) Create an right outer join operation.

Methods inherited from class java.lang.Object

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

Method Detail

broadcast

public BroadcastConfig broadcast(java.lang.String source)

Create a broadcast configuration

Parameters:

source - the source to connection

Returns:

the BroadcastConfig

reduce

public ReduceConfig reduce(java.lang.String source)

Create a reduce configuration

Parameters:

source - the source to connection

Returns:

the ReduceConfig

keyedReduce

public KeyedReduceConfig keyedReduce(java.lang.String source)

Create a keyed reduce config

Parameters:

source - the source to connection

Returns:

the KeyedReduceConfig

gather

public GatherConfig gather(java.lang.String source)

Create a gather config

Parameters:

source - the source to connection

Returns:

the GatherConfig

keyedGather

public KeyedGatherConfig keyedGather(java.lang.String source)

Create a keyed gather config

Parameters:

source - the source to connection

Returns:

the KeyedGatherConfig

innerJoin

public JoinConfig innerJoin(java.lang.String leftSource,
                            java.lang.String rightSource,
                            CommunicationContext.JoinAlgorithm joinAlgorithm)

Create an inner join operation. The left source and right source can be the same source

Parameters:

leftSource - the left source to connection

rightSource - the right source to connection

Returns:

the JoinConfig

fullOuterJoin

public JoinConfig fullOuterJoin(java.lang.String leftSource,
                                java.lang.String rightSource)

Create an full outer join operation. The left source and right source can be the same source

Parameters:

leftSource - the left source to connection

rightSource - the right source to connection

Returns:

the JoinConfig

leftOuterJoin

public JoinConfig leftOuterJoin(java.lang.String leftSource,
                                java.lang.String rightSource,
                                CommunicationContext.JoinAlgorithm joinAlgorithm)

Create an left outer join operation. The left source and right source can be the same source

Parameters:

leftSource - the left source to connection

rightSource - the right source to connection

Returns:

the JoinConfig

rightOuterJoin

public JoinConfig rightOuterJoin(java.lang.String leftSource,
                                 java.lang.String rightSource,
                                 CommunicationContext.JoinAlgorithm joinAlgorithm)

Create an right outer join operation. The left source and right source can be the same source

Parameters:

leftSource - the left source to connection

rightSource - the right source to connection

Returns:

the JoinConfig

partition

public PartitionConfig partition(java.lang.String source)

Create a partition config

Parameters:

source - the source to connection

Returns:

the KeyedGatherConfig

keyedPartition

public KeyedPartitionConfig keyedPartition(java.lang.String source)

Create a keyed partition config

Parameters:

source - the source to connection

Returns:

the KeyedPartitionConfig

allreduce

public AllReduceConfig allreduce(java.lang.String source)

Create an allreduce config

Parameters:

source - the source to connection

Returns:

the AllReduceConfig

allgather

public AllGatherConfig allgather(java.lang.String source)

Create an allgather config

Parameters:

source - the source to connection

Returns:

the AllGatherConfig

direct

public DirectConfig direct(java.lang.String source)

Crate a direct config

Parameters:

source - the source to connection

Returns:

the DirectConfig