Package org.apache.cassandra.repair.asymmetric

Class RangeDenormalizer

java.lang.Object

org.apache.cassandra.repair.asymmetric.RangeDenormalizer

public class RangeDenormalizer
extends Object

Constructor Summary

Constructors

Constructor	Description
RangeDenormalizer()

Method Summary

Modifier and Type	Method	Description
static Set<Range<Token>>	denormalize(Range<Token> range, RangeMap<StreamFromOptions> incoming)	"Denormalizes" (kind of the opposite of what Range.normalize does) the ranges in the keys of {{incoming}} It makes sure that if there is an intersection between {{range}} and some of the ranges in {{incoming.keySet()}} we know that all intersections are keys in the updated {{incoming}}
static Set<Range<Token>>	subtractAll(Collection<Map.Entry<Range<Token>,StreamFromOptions>> ranges, Range<Token> toSubtract)	copied from Range - need to iterate over the map entries

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RangeDenormalizer

public RangeDenormalizer()

Method Details

denormalize

public static Set<Range<Token>> denormalize(Range<Token> range,
 RangeMap<StreamFromOptions> incoming)

"Denormalizes" (kind of the opposite of what Range.normalize does) the ranges in the keys of {{incoming}} It makes sure that if there is an intersection between {{range}} and some of the ranges in {{incoming.keySet()}} we know that all intersections are keys in the updated {{incoming}}

subtractAll

public static Set<Range<Token>> subtractAll(Collection<Map.Entry<Range<Token>,StreamFromOptions>> ranges,
 Range<Token> toSubtract)

copied from Range - need to iterate over the map entries