stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r974416546
##
flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/util/RateLimitedSourceReaderITCase.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache Sof
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r974416546
##
flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/util/RateLimitedSourceReaderITCase.java:
##
@@ -0,0 +1,138 @@
+/*
+ * Licensed to the Apache Sof
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r967254247
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java:
##
@@ -22,8 +22,14 @@
import java.util.concurrent.CompletionStage;
/**
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r967254247
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java:
##
@@ -22,8 +22,14 @@
import java.util.concurrent.CompletionStage;
/**
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r967254247
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/util/RateLimiter.java:
##
@@ -22,8 +22,14 @@
import java.util.concurrent.CompletionStage;
/**
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r966164935
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r965058470
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation
stevenzwu commented on code in PR #20757:
URL: https://github.com/apache/flink/pull/20757#discussion_r964946446
##
flink-core/src/main/java/org/apache/flink/api/connector/source/lib/DataGeneratorSource.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation