Class StreamManager.StreamRateLimiter

  • Enclosing class:
    StreamManager

    public static class StreamManager.StreamRateLimiter
    extends java.lang.Object
    • 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()