IncomingRepairStreamTracker (apache-cassandra API)

java.lang.Object
- org.apache.cassandra.repair.asymmetric.IncomingRepairStreamTracker

public class IncomingRepairStreamTracker
extends java.lang.Object

Tracks incoming streams for a single host

Constructor Summary

Constructors
Constructor Description

IncomingRepairStreamTracker(DifferenceHolder differences)

Method Summary

All Methods Instance Methods Concrete Methods
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()`
`java.lang.String`	`toString()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Constructor Detail
  - IncomingRepairStreamTracker
```
public IncomingRepairStreamTracker(DifferenceHolder differences)
```
- Method Detail
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.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()
```