Package org.apache.cassandra.streaming
Class StreamManager.StreamRateLimiter
- java.lang.Object
-
- org.apache.cassandra.streaming.StreamManager.StreamRateLimiter
-
- Enclosing class:
- StreamManager
public static class StreamManager.StreamRateLimiter extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description static double
BYTES_PER_MEGABIT
-
Constructor Summary
Constructors Constructor Description StreamRateLimiter(InetAddressAndPort peer)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description void
acquire(int toTransfer)
static double
getInterDCRateLimiterRateInBytes()
static double
getRateLimiterRateInBytes()
static void
updateInterDCThroughput()
static void
updateThroughput()
-
-
-
Field Detail
-
BYTES_PER_MEGABIT
public static final double BYTES_PER_MEGABIT
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
StreamRateLimiter
public StreamRateLimiter(InetAddressAndPort peer)
-
-
Method Detail
-
acquire
public void acquire(int toTransfer)
-
updateThroughput
public static void updateThroughput()
-
updateInterDCThroughput
public static void updateInterDCThroughput()
-
getRateLimiterRateInBytes
public static double getRateLimiterRateInBytes()
-
getInterDCRateLimiterRateInBytes
public static double getInterDCRateLimiterRateInBytes()
-
-