yanghua commented on a change in pull request #2567:
URL: https://github.com/apache/hudi/pull/2567#discussion_r574254945
##########
File path: hudi-flink/src/test/java/org/apache/hudi/operator/utils/TestData.java
##########
@@ -149,6 +156,51 @@ public static void checkWrittenData(
}
}
+ /**
+ * Checks the source data are written as expected.
+ *
+ * <p>Note: Replace it with the Flink reader when it is supported.
+ *
+ * @param basePath The file base to check, should be a directory
+ * @param expected The expected results mapping, the key should be the
partition path
+ */
+ public static void checkWrittenFullData(
Review comment:
@lamber-ken It seems this mechanism looks more reasonable. So, a
question is this method can fully replace `checkWrittenData`?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
