org.apache.flink.runtime.checkpoint

Class RescaleMappings

java.lang.Object

org.apache.flink.runtime.checkpoint.RescaleMappings

All Implemented Interfaces:

Serializable

public class RescaleMappings
extends Object
implements Serializable

Contains the fine-grain channel mappings that occur when a connected operator has been rescaled.

Usually the mapping is materialized from new->old channel/subtask indexes. Through invert(), the direction may change accordingly. To generalize, the left side is called source and the right side is called target(s) in this class.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static RescaleMappings	SYMMETRIC_IDENTITY

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
Set<Integer>	getAmbiguousTargets()
int[]	getMappedIndexes(int sourceIndex)
int	hashCode()
static RescaleMappings	identity(int numberOfSources, int numberOfTargets)
RescaleMappings	invert()
boolean	isIdentity()
static RescaleMappings	of(java.util.stream.Stream<int[]> mappedTargets, int numberOfTargets)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

SYMMETRIC_IDENTITY

public static final RescaleMappings SYMMETRIC_IDENTITY

Method Detail

identity

public static RescaleMappings identity(int numberOfSources,
                                       int numberOfTargets)

isIdentity

public boolean isIdentity()

getMappedIndexes

public int[] getMappedIndexes(int sourceIndex)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

invert

public RescaleMappings invert()

getAmbiguousTargets

public Set<Integer> getAmbiguousTargets()

of

public static RescaleMappings of(java.util.stream.Stream<int[]> mappedTargets,
                                 int numberOfTargets)