[flink] 01/02: [refactor][tests] Move some source test utils from flink-connector-base to flink-core

[se...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

sewen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit c1ca7a4c7c21ec8868c14cdddd43c559625b794c
Author: Stephan Ewen <se...@apache.org>
AuthorDate: Tue Sep 29 22:25:37 2020 +0200

    [refactor][tests] Move some source test utils from flink-connector-base to flink-core
    
    This makes them reusable in unit tests for simple sources that are implemented in flink-core
---
 .../flink/connector/base/source/reader/SourceReaderBaseTest.java      | 4 ++--
 .../flink/api/connector/source}/mocks/TestingReaderContext.java       | 2 +-
 .../apache/flink/api/connector/source}/mocks/TestingReaderOutput.java | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/SourceReaderBaseTest.java b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/SourceReaderBaseTest.java
index ce32521..6396b2e 100644
--- a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/SourceReaderBaseTest.java
+++ b/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/SourceReaderBaseTest.java
@@ -21,12 +21,12 @@ package org.apache.flink.connector.base.source.reader;
 import org.apache.flink.api.connector.source.Boundedness;
 import org.apache.flink.api.connector.source.SourceReader;
 import org.apache.flink.api.connector.source.mocks.MockSourceSplit;
+import org.apache.flink.api.connector.source.mocks.TestingReaderContext;
+import org.apache.flink.api.connector.source.mocks.TestingReaderOutput;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.connector.base.source.reader.mocks.MockSourceReader;
 import org.apache.flink.connector.base.source.reader.mocks.MockSplitReader;
 import org.apache.flink.connector.base.source.reader.mocks.PassThroughRecordEmitter;
-import org.apache.flink.connector.base.source.reader.mocks.TestingReaderContext;
-import org.apache.flink.connector.base.source.reader.mocks.TestingReaderOutput;
 import org.apache.flink.connector.base.source.reader.mocks.TestingRecordsWithSplitIds;
 import org.apache.flink.connector.base.source.reader.mocks.TestingSourceSplit;
 import org.apache.flink.connector.base.source.reader.mocks.TestingSplitReader;
diff --git a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderContext.java b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderContext.java
similarity index 97%
rename from flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderContext.java
rename to flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderContext.java
index 5bb9b59..cee4654 100644
--- a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderContext.java
+++ b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderContext.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.connector.base.source.reader.mocks;
+package org.apache.flink.api.connector.source.mocks;
 
 import org.apache.flink.api.connector.source.SourceEvent;
 import org.apache.flink.api.connector.source.SourceReaderContext;
diff --git a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderOutput.java b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderOutput.java
similarity index 96%
rename from flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderOutput.java
rename to flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderOutput.java
index 4483819..1847cc4 100644
--- a/flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/reader/mocks/TestingReaderOutput.java
+++ b/flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/TestingReaderOutput.java
@@ -16,7 +16,7 @@
  * limitations under the License.
  */
 
-package org.apache.flink.connector.base.source.reader.mocks;
+package org.apache.flink.api.connector.source.mocks;
 
 import org.apache.flink.api.common.eventtime.Watermark;
 import org.apache.flink.api.connector.source.ReaderOutput;