org.apache.flink.runtime.jobgraph

Class IntermediateResultPartitionID

java.lang.Object

org.apache.flink.util.AbstractID

org.apache.flink.runtime.jobgraph.IntermediateResultPartitionID

All Implemented Interfaces:

Serializable, Comparable<AbstractID>, IOReadableWritable

public class IntermediateResultPartitionID
extends AbstractID

See Also:

Serialized Form

Field Summary

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

lowerPart, SIZE, upperPart

Constructor Summary

Constructors

Constructor and Description
IntermediateResultPartitionID() Creates an new random intermediate result partition ID.
IntermediateResultPartitionID(long lowerPart, long upperPart)

Method Summary

Modifier and Type	Method and Description
static IntermediateResultPartitionID	fromByteBuf(io.netty.buffer.ByteBuf buf)
void	writeTo(io.netty.buffer.ByteBuf buf)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

IntermediateResultPartitionID

public IntermediateResultPartitionID()

Creates an new random intermediate result partition ID.

IntermediateResultPartitionID

public IntermediateResultPartitionID(long lowerPart,
                                     long upperPart)

Method Detail

writeTo

public void writeTo(io.netty.buffer.ByteBuf buf)

fromByteBuf

public static IntermediateResultPartitionID fromByteBuf(io.netty.buffer.ByteBuf buf)