edu.iu.dsc.tws.tset

Interface Buildable

All Known Subinterfaces:

BuildableTLink, BuildableTSet

All Known Implementing Classes:

AllGatherTLink, AllReduceTLink, BaseTLink, BaseTLinkWithSchema, BaseTSet, BaseTSetWithSchema, BatchGatherLink, BatchIteratorLink, BatchIteratorLinkWrapper, BatchRowTSetImpl, BatchSingleLink, BatchTLinkImpl, BatchTSetImpl, BatchTupleTSetImpl, CachedTSet, CheckpointedTSet, ComputeTSet, DirectTLink, GatherTLink, JoinTLink, KeyedBatchIteratorLinkWrapper, KeyedCachedTSet, KeyedCheckpointedTSet, KeyedDirectTLink, KeyedGatherTLink, KeyedGatherUngroupedTLink, KeyedPartitionTLink, KeyedPersistedTSet, KeyedPipeTLink, KeyedReduceTLink, KeyedSourceTSet, KeyedStoredTSet, KeyedTSet, PartitionTLink, PersistedTSet, PipeTLink, ReduceTLink, ReplicateTLink, RowBatchTLinkImpl, RowCachedTSet, RowCheckpointedTSet, RowComputeTSet, RowDirectLink, RowPartitionTLink, RowPersistedTSet, RowPipeTLink, RowSinkTSet, RowSourceTSet, RowStoredTSet, SAllGatherTLink, SAllReduceTLink, SComputeTSet, SDirectTLink, SGatherTLink, SinkTSet, SKeyedDirectTLink, SKeyedPartitionTLink, SKeyedSourceTSet, SKeyedTSet, SourceTSet, SPartitionTLink, SReduceTLink, SReplicateTLink, SSinkTSet, SSourceTSet, StoredTSet, StreamingGatherLink, StreamingIteratorLink, StreamingSingleLink, StreamingTLinkImpl, StreamingTSetImpl, StreamingTupleTSetImpl, WindowComputeTSet

public interface Buildable

Interface that provides buildable functionality for sets and links

Method Summary

Modifier and Type	Method and Description
void	build(GraphBuilder graphBuilder, java.util.Collection<? extends TBase> buildSequence) Builds the underlying node or edge
default java.lang.String	generateID(java.lang.String prefix) generates a unique ID for tsets or tlinks.
default TBaseGraph	getTBaseGraph() tbase graph
TSetEnvironment	getTSetEnv() tset env

Method Detail

build

void build(GraphBuilder graphBuilder,
           java.util.Collection<? extends TBase> buildSequence)

Builds the underlying node or edge

Parameters:

graphBuilder - Dataflow graph builder

buildSequence - partial build sequence. i.e. the set of nodes and edges that have been

getTSetEnv

TSetEnvironment getTSetEnv()

tset env

Returns:

tset env

getTBaseGraph

default TBaseGraph getTBaseGraph()

tbase graph

Returns:

tbase graph

generateID

default java.lang.String generateID(java.lang.String prefix)

generates a unique ID for tsets or tlinks.

todo: check how this behaves with fault tolerance

Parameters:

prefix - prefix

Returns:

ID