org.apache.flink.runtime.jobgraph

Class IntermediateDataSet

java.lang.Object

org.apache.flink.runtime.jobgraph.IntermediateDataSet

All Implemented Interfaces:

Serializable

public class IntermediateDataSet
extends Object
implements Serializable

An intermediate data set is the data set produced by an operator - either a source or any intermediate operation.

Intermediate data sets may be read by other operators, materialized, or discarded.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
IntermediateDataSet(IntermediateDataSetID id, ResultPartitionType resultType, JobVertex producer)

Method Summary

Modifier and Type	Method and Description
void	addConsumer(JobEdge edge)
List<JobEdge>	getConsumers()
DistributionPattern	getDistributionPattern()
IntermediateDataSetID	getId()
JobVertex	getProducer()
ResultPartitionType	getResultType()
boolean	isBroadcast()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

IntermediateDataSet

public IntermediateDataSet(IntermediateDataSetID id,
                           ResultPartitionType resultType,
                           JobVertex producer)

Method Detail

getId

public IntermediateDataSetID getId()

getProducer

public JobVertex getProducer()

getConsumers

public List<JobEdge> getConsumers()

isBroadcast

public boolean isBroadcast()

getDistributionPattern

public DistributionPattern getDistributionPattern()

getResultType

public ResultPartitionType getResultType()

addConsumer

public void addConsumer(JobEdge edge)

toString

public String toString()

Overrides:

toString in class Object