Package org.apache.flink.runtime.topology

Interface Vertex<VID extends VertexID,RID extends ResultID,V extends Vertex<VID,RID,V,R>,R extends Result<VID,RID,V,R>>

All Known Subinterfaces:

LogicalVertex, SchedulingExecutionVertex

All Known Implementing Classes:

DefaultLogicalVertex

public interface Vertex<VID extends VertexID,RID extends ResultID,V extends Vertex<VID,RID,V,R>,R extends Result<VID,RID,V,R>>

Represents a logical or execution task. Each vertex can consume data from multiple Result. Each vertex can produce multiple Result.

Method Summary

Modifier and Type	Method	Description
Iterable<? extends R>	getConsumedResults()
VID	getId()
Iterable<? extends R>	getProducedResults()

Method Detail

getId

VID getId()

getConsumedResults

Iterable<? extends R> getConsumedResults()

getProducedResults

Iterable<? extends R> getProducedResults()