linliu-code commented on code in PR #13519:
URL: https://github.com/apache/hudi/pull/13519#discussion_r2223126392
##########
hudi-common/src/test/java/org/apache/hudi/common/testutils/HoodieTestDataGenerator.java:
##########
@@ -477,6 +486,22 @@ private void generateFareNestedValues(GenericRecord rec) {
rec.put("fare", fareRecord);
}
+ /**
+ * Populate "Op" column.
+ */
+ private void generateOpColumnValue(GenericRecord rec) {
+ // No delete records; otherwise, it is hard to data validation.
+ int index = rand.nextInt(2);
+ rec.put("Op", OPERATIONS[index]);
+ }
+
+ /**
+ * Populate "_event_lsn" column.
+ */
+ private void generateEventLSNValue(GenericRecord rec) {
+ rec.put("_event_lsn", rand.nextLong());
Review Comment:
The unit tests use the schema to make sure the postgres payload has such
values. This is not used for functional tests.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
