prashantwason commented on a change in pull request #2496:
URL: https://github.com/apache/hudi/pull/2496#discussion_r568069059
##########
File path:
hudi-common/src/main/java/org/apache/hudi/common/fs/TimedSizeAwareOutputStream.java
##########
@@ -20,19 +20,21 @@
import org.apache.hudi.exception.HoodieException;
-import org.apache.hadoop.fs.FSDataOutputStream;
import org.apache.hadoop.fs.Path;
import java.io.IOException;
+import java.io.OutputStream;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicLong;
/**
- * Wrapper over <code>FSDataOutputStream</code> to keep track of the size of
the written bytes. This gives a cheap way
+ * Wrapper over <code>OutputStream</code> to keep track of the size of the
written bytes. This gives a cheap way
* to check on the underlying file size.
*/
-public class SizeAwareFSDataOutputStream extends FSDataOutputStream {
+public class TimedSizeAwareOutputStream extends OutputStream {
Review comment:
These file systems are tested by most of the unit tests which read/write
data.
----------------------------------------------------------------
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:
us...@infra.apache.org
