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

Class ResultSubpartitionIndexSet

java.lang.Object

org.apache.flink.runtime.executiongraph.IndexRange

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

All Implemented Interfaces:

Serializable

public class ResultSubpartitionIndexSet
extends IndexRange

A collection of subpartition indexes.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.runtime.executiongraph.IndexRange

endIndex, startIndex

Constructor Summary

Constructors

Constructor and Description
ResultSubpartitionIndexSet(IndexRange indexRange)
ResultSubpartitionIndexSet(int index)
ResultSubpartitionIndexSet(int startIndex, int endIndex)

Method Summary

Modifier and Type	Method and Description
boolean	contains(int index)
static ResultSubpartitionIndexSet	fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf source)
static int	getByteBufLength(ResultSubpartitionIndexSet indexSet)
Iterable<Integer>	values()
void	writeTo(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf target)

Methods inherited from class org.apache.flink.runtime.executiongraph.IndexRange

equals, getEndIndex, getStartIndex, hashCode, size, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultSubpartitionIndexSet

public ResultSubpartitionIndexSet(int index)

ResultSubpartitionIndexSet

public ResultSubpartitionIndexSet(IndexRange indexRange)

ResultSubpartitionIndexSet

public ResultSubpartitionIndexSet(int startIndex,
                                  int endIndex)

Method Detail

contains

public boolean contains(int index)

values

public Iterable<Integer> values()

writeTo

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

getByteBufLength

public static int getByteBufLength(ResultSubpartitionIndexSet indexSet)

fromByteBuf

public static ResultSubpartitionIndexSet fromByteBuf(org.apache.flink.shaded.netty4.io.netty.buffer.ByteBuf source)