code: @Override
  	public void open(RuntimeContext runtimeContext) {
  		this.runtimeContext = runtimeContext;
  		localRateBytesPerSecond = globalRateBytesPerSecond / runtimeContext.getNumberOfParallelSubtasks();
  		this.rateLimiter = RateLimiter.create(localRateBytesPerSecond);
  	}
docs: Creates a rate limiter with the runtime context provided.
  @param runtimeContext