Package org.apache.cassandra.streaming
Class StreamManager.StreamRateLimiter
- java.lang.Object
-
- org.apache.cassandra.streaming.StreamManager.StreamRateLimiter
-
- All Implemented Interfaces:
StreamingDataOutputPlus.RateLimiter
- Enclosing class:
- StreamManager
public static class StreamManager.StreamRateLimiter extends java.lang.Object implements StreamingDataOutputPlus.RateLimiter
-
-
Field Summary
Fields Modifier and Type Field Description static doubleBYTES_PER_MEBIBYTE
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description voidacquire(int toTransfer)static doublegetEntireSSTableInterDCRateLimiterRateInBytes()static doublegetEntireSSTableRateLimiterRateInBytes()static doublegetInterDCRateLimiterRateInBytes()static doublegetRateLimiterRateInBytes()booleanisRateLimited()static voidupdateEntireSSTableInterDCThroughput()static voidupdateEntireSSTableThroughput()static voidupdateInterDCThroughput()static voidupdateThroughput()
-
-
-
Field Detail
-
BYTES_PER_MEBIBYTE
public static final double BYTES_PER_MEBIBYTE
- See Also:
- Constant Field Values
-
-
Method Detail
-
acquire
public void acquire(int toTransfer)
- Specified by:
acquirein interfaceStreamingDataOutputPlus.RateLimiter
-
isRateLimited
public boolean isRateLimited()
- Specified by:
isRateLimitedin interfaceStreamingDataOutputPlus.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()
-
-