org.apache.flink.streaming.api.graph

Class StreamEdge

java.lang.Object

org.apache.flink.streaming.api.graph.StreamEdge

All Implemented Interfaces:

Serializable

@Internal
public class StreamEdge
extends Object
implements Serializable

An edge in the streaming topology. One edge like this does not necessarily gets converted to a connection between two job vertices (due to chaining/optimization).

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StreamEdge(StreamNode sourceVertex, StreamNode targetVertex, int typeNumber, long bufferTimeout, StreamPartitioner<?> outputPartitioner, OutputTag outputTag, StreamExchangeMode exchangeMode, int uniqueId, IntermediateDataSetID intermediateDatasetId)
StreamEdge(StreamNode sourceVertex, StreamNode targetVertex, int typeNumber, StreamPartitioner<?> outputPartitioner, OutputTag outputTag)
StreamEdge(StreamNode sourceVertex, StreamNode targetVertex, int typeNumber, StreamPartitioner<?> outputPartitioner, OutputTag outputTag, StreamExchangeMode exchangeMode, int uniqueId, IntermediateDataSetID intermediateDatasetId)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getBufferTimeout()
StreamExchangeMode	getExchangeMode()
IntermediateDataSetID	getIntermediateDatasetIdToProduce()
OutputTag	getOutputTag()
StreamPartitioner<?>	getPartitioner()
int	getSourceId()
int	getTargetId()
int	getTypeNumber()
int	hashCode()
void	setBufferTimeout(long bufferTimeout)
void	setPartitioner(StreamPartitioner<?> partitioner)
void	setSupportsUnalignedCheckpoints(boolean supportsUnalignedCheckpoints)
boolean	supportsUnalignedCheckpoints()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

StreamEdge

public StreamEdge(StreamNode sourceVertex,
                  StreamNode targetVertex,
                  int typeNumber,
                  StreamPartitioner<?> outputPartitioner,
                  OutputTag outputTag)

StreamEdge

public StreamEdge(StreamNode sourceVertex,
                  StreamNode targetVertex,
                  int typeNumber,
                  StreamPartitioner<?> outputPartitioner,
                  OutputTag outputTag,
                  StreamExchangeMode exchangeMode,
                  int uniqueId,
                  IntermediateDataSetID intermediateDatasetId)

StreamEdge

public StreamEdge(StreamNode sourceVertex,
                  StreamNode targetVertex,
                  int typeNumber,
                  long bufferTimeout,
                  StreamPartitioner<?> outputPartitioner,
                  OutputTag outputTag,
                  StreamExchangeMode exchangeMode,
                  int uniqueId,
                  IntermediateDataSetID intermediateDatasetId)

Method Detail

getSourceId

public int getSourceId()

getTargetId

public int getTargetId()

getTypeNumber

public int getTypeNumber()

getOutputTag

public OutputTag getOutputTag()

getPartitioner

public StreamPartitioner<?> getPartitioner()

getExchangeMode

public StreamExchangeMode getExchangeMode()

setPartitioner

public void setPartitioner(StreamPartitioner<?> partitioner)

setBufferTimeout

public void setBufferTimeout(long bufferTimeout)

getBufferTimeout

public long getBufferTimeout()

setSupportsUnalignedCheckpoints

public void setSupportsUnalignedCheckpoints(boolean supportsUnalignedCheckpoints)

supportsUnalignedCheckpoints

public boolean supportsUnalignedCheckpoints()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object

getIntermediateDatasetIdToProduce

public IntermediateDataSetID getIntermediateDatasetIdToProduce()