org.apache.flink.runtime.scheduler.strategy

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 identifying ExecutionVertex.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	SIZE The size of the ID in byte.

Constructor Summary

Constructors

Constructor and Description
ExecutionVertexID(JobVertexID jobVertexId, int subtaskIndex)

Method Summary

Modifier and Type	Method and 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)

Methods inherited from class java.lang.Object

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

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)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object