Class ExecutionVertexID
- java.lang.Object
-
- org.apache.flink.runtime.scheduler.strategy.ExecutionVertexID
-
- All Implemented Interfaces:
Serializable
,VertexID
public class ExecutionVertexID extends Object implements VertexID
Id identifyingExecutionVertex
.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static int
SIZE
The size of the ID in byte.
-
Constructor Summary
Constructors Constructor Description ExecutionVertexID(JobVertexID jobVertexId, int subtaskIndex)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
static ExecutionVertexID
fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
JobVertexID
getJobVertexId()
int
getSubtaskIndex()
int
hashCode()
String
toString()
void
writeTo(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
-
-
-
Field Detail
-
SIZE
public static final int SIZE
The size of the ID in byte. It is the sum of one JobVertexID type(jobVertexId) and one int type(subtaskIndex).- See Also:
- Constant Field Values
-
-
Constructor Detail
-
ExecutionVertexID
public ExecutionVertexID(JobVertexID jobVertexId, int subtaskIndex)
-
-
Method Detail
-
getJobVertexId
public JobVertexID getJobVertexId()
-
getSubtaskIndex
public int getSubtaskIndex()
-
writeTo
public void writeTo(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
-
fromByteBuf
public static ExecutionVertexID fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
-
-