Package 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	Description
InputChannelID()
InputChannelID(long lowerPart, long upperPart)
InputChannelID(AbstractID id)

Method Summary

Modifier and Type	Method	Description
static InputChannelID	fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
static int	getByteBufLength()
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, toHexString, 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)

getByteBufLength

public static int getByteBufLength()