StreamManager.StreamRateLimiter (apache-cassandra API)

java.lang.Object

org.apache.cassandra.streaming.StreamManager.StreamRateLimiter

All Implemented Interfaces:: StreamingDataOutputPlus.RateLimiter

Enclosing class:: StreamManager

public static class StreamManager.StreamRateLimiter extends Object implements StreamingDataOutputPlus.RateLimiter

Field Summary

Fields

Modifier and Type

Field

Description

static final double

BYTES_PER_MEBIBYTE
Method Summary

Modifier and Type

Method

Description

void

acquire(int toTransfer)

static double

getEntireSSTableInterDCRateLimiterRateInBytes()

static double

getEntireSSTableRateLimiterRateInBytes()

static double

getInterDCRateLimiterRateInBytes()

static double

getRateLimiterRateInBytes()

boolean

isRateLimited()

static void

updateEntireSSTableInterDCThroughput()

static void

updateEntireSSTableThroughput()

static void

updateInterDCThroughput()

static void

updateThroughput()

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

Field Details
- BYTES_PER_MEBIBYTE
  
  public static final double BYTES_PER_MEBIBYTE
  See Also:
  
  Constant Field Values
Method Details
- acquire
  
  public void acquire(int toTransfer)
  
  Specified by:
  
  acquire in interface StreamingDataOutputPlus.RateLimiter
- isRateLimited
  
  public boolean isRateLimited()
  
  Specified by:
  
  isRateLimited in interface StreamingDataOutputPlus.RateLimiter
- updateThroughput
  
  public static void updateThroughput()
- updateInterDCThroughput
  
  public static void updateInterDCThroughput()
- updateEntireSSTableThroughput
  
  public static void updateEntireSSTableThroughput()
- updateEntireSSTableInterDCThroughput
  
  public static void updateEntireSSTableInterDCThroughput()
- getRateLimiterRateInBytes
  
  public static double getRateLimiterRateInBytes()
- getInterDCRateLimiterRateInBytes
  
  public static double getInterDCRateLimiterRateInBytes()
- getEntireSSTableRateLimiterRateInBytes
  
  public static double getEntireSSTableRateLimiterRateInBytes()
- getEntireSSTableInterDCRateLimiterRateInBytes
  
  public static double getEntireSSTableInterDCRateLimiterRateInBytes()