org.apache.flink.runtime.jobgraph

Class IntermediateDataSetID

java.lang.Object

org.apache.flink.util.AbstractID

org.apache.flink.runtime.jobgraph.IntermediateDataSetID

All Implemented Interfaces:

Serializable, Comparable<AbstractID>, ResultID

public class IntermediateDataSetID
extends AbstractID
implements ResultID

Id identifying IntermediateDataSet.

See Also:

Serialized Form

Field Summary

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

lowerPart, SIZE, upperPart

Constructor Summary

Constructors

Constructor and Description
IntermediateDataSetID() Creates an new random intermediate data set ID.
IntermediateDataSetID(AbstractID from) Creates a new intermediate data set ID with the bytes of the given ID.
IntermediateDataSetID(UUID from) Creates a new intermediate data set ID with the bytes of the given UUID.

Method Summary

Modifier and Type	Method and Description
static IntermediateDataSetID	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, toHexString, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

IntermediateDataSetID

public IntermediateDataSetID()

Creates an new random intermediate data set ID.

IntermediateDataSetID

public IntermediateDataSetID(AbstractID from)

Creates a new intermediate data set ID with the bytes of the given ID.

Parameters:

from - The ID to create this ID from.

IntermediateDataSetID

public IntermediateDataSetID(UUID from)

Creates a new intermediate data set ID with the bytes of the given UUID.

Parameters:

from - The UUID to create this ID from.

Method Detail

writeTo

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

fromByteBuf

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