org.apache.flink.runtime.io.network.partition.consumer

Class InputChannelID

java.lang.Object

org.apache.flink.util.AbstractID

org.apache.flink.runtime.io.network.partition.consumer.InputChannelID

All Implemented Interfaces:

Serializable, Comparable<AbstractID>

public class InputChannelID
extends AbstractID

Identifier for input channels.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.util.AbstractID

lowerPart, SIZE, upperPart

Constructor Summary

Constructors

Constructor and Description
InputChannelID()
InputChannelID(AbstractID id)
InputChannelID(long lowerPart, long upperPart)

Method Summary

Modifier and Type	Method and Description
static InputChannelID	fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
void	writeTo(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)

Methods inherited from class org.apache.flink.util.AbstractID

compareTo, equals, getBytes, getLowerPart, getUpperPart, hashCode, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

InputChannelID

public InputChannelID()

InputChannelID

public InputChannelID(long lowerPart,
                      long upperPart)

InputChannelID

public InputChannelID(AbstractID id)

Method Detail

writeTo

public void writeTo(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)

fromByteBuf

public static InputChannelID fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)