public class IntermediateResultPartitionID extends Object implements ResultID
IntermediateResultPartition
.Constructor and Description |
---|
IntermediateResultPartitionID()
Creates an new random intermediate result partition ID for testing.
|
IntermediateResultPartitionID(IntermediateDataSetID intermediateDataSetID,
int partitionNum)
Creates an new intermediate result partition ID with
IntermediateDataSetID and the
partitionNum. |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
static IntermediateResultPartitionID |
fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf) |
int |
hashCode() |
String |
toString() |
void |
writeTo(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf) |
@VisibleForTesting public IntermediateResultPartitionID()
public IntermediateResultPartitionID(IntermediateDataSetID intermediateDataSetID, int partitionNum)
IntermediateDataSetID
and the
partitionNum.public void writeTo(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
public static IntermediateResultPartitionID fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf buf)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.