Github user xuchuanyin commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1707#discussion_r158902533
--- Diff:
core/src/main/java/org/apache/carbondata/core/datastore/filesystem/AbstractDFSCarbonFile.java
---
@@ -315,6 +319,49 @@ public boolean delete() {
return new DataInputStream(new BufferedInputStream(stream));
}
+ @Override public DataInputStream getDataInputStream(String path,
FileFactory.FileType fileType,
--- End diff --
Fine, I'll reduce the duplicate code.
---