nsivabalan commented on a change in pull request #3315:
URL: https://github.com/apache/hudi/pull/3315#discussion_r678649799
##########
File path:
hudi-client/hudi-spark-client/src/test/java/org/apache/hudi/testutils/HoodieClientTestUtils.java
##########
@@ -171,6 +171,33 @@ public static long countRecordsSince(JavaSparkContext jsc,
String basePath, SQLC
}
}
+ /**
+ * Obtain all new data written into the Hoodie table since the given
timestamp.
+ */
+ public static long countAllRecords(JavaSparkContext jsc, String basePath,
SQLContext sqlContext,
Review comment:
We already have helper methods in this class only. readCommit,
countRecordsSince. Thats why placed it here. anyways, I have fixed the existing
method with optional additional argument.
--
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]
