Package org.apache.cassandra.repair.asymmetric

Class IncomingRepairStreamTracker

java.lang.Object

org.apache.cassandra.repair.asymmetric.IncomingRepairStreamTracker

public class IncomingRepairStreamTracker
extends Object

Tracks incoming streams for a single host

Constructor Summary

Constructors

Constructor	Description
IncomingRepairStreamTracker(DifferenceHolder differences)

Method Summary

Modifier and Type	Method	Description
void	addIncomingRangeFrom(Range<Token> range, InetAddressAndPort streamFromNode)	Adds a range to be streamed from streamFromNode First the currently tracked ranges are denormalized to make sure that no ranges overlap, then the streamFromNode is added to the StreamFromOptions for the range
com.google.common.collect.ImmutableMap<Range<Token>,StreamFromOptions>	getIncoming()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

IncomingRepairStreamTracker

public IncomingRepairStreamTracker(DifferenceHolder differences)

Method Details

toString

public String toString()

Overrides:

toString in class Object

addIncomingRangeFrom

public void addIncomingRangeFrom(Range<Token> range,
 InetAddressAndPort streamFromNode)

Adds a range to be streamed from streamFromNode First the currently tracked ranges are denormalized to make sure that no ranges overlap, then the streamFromNode is added to the StreamFromOptions for the range

Parameters:

range - the range we need to stream from streamFromNode

streamFromNode - the node we should stream from

getIncoming

public com.google.common.collect.ImmutableMap<Range<Token>,StreamFromOptions> getIncoming()