public class DefaultLogicalPipelinedRegion extends Object implements LogicalPipelinedRegion
LogicalVertex
that are connected through pipelined LogicalResult
.Constructor and Description |
---|
DefaultLogicalPipelinedRegion(Set<? extends LogicalVertex> logicalVertices) |
Modifier and Type | Method and Description |
---|---|
boolean |
contains(JobVertexID vertexId)
Returns whether the vertex is in this pipelined region or not.
|
LogicalVertex |
getVertex(JobVertexID vertexId)
Returns the vertex with the specified vertex id.
|
Iterable<? extends LogicalVertex> |
getVertices()
Returns vertices that are in this pipelined region.
|
String |
toString() |
public DefaultLogicalPipelinedRegion(Set<? extends LogicalVertex> logicalVertices)
public Iterable<? extends LogicalVertex> getVertices()
PipelinedRegion
getVertices
in interface PipelinedRegion<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>
public LogicalVertex getVertex(JobVertexID vertexId)
PipelinedRegion
getVertex
in interface PipelinedRegion<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>
vertexId
- the vertex id used to look up the vertexpublic boolean contains(JobVertexID vertexId)
PipelinedRegion
contains
in interface PipelinedRegion<JobVertexID,IntermediateDataSetID,LogicalVertex,LogicalResult>
vertexId
- the vertex id used to look upCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.