hadoop class
2022-01-05 16:15:41 4 举报hadoop class
作者其他创作
大纲/内容
ReadSlice
+ByteBuffer buffer;+Page page;+boolean success;+long startPos;+CountDownLatch latch;
+load()+read()
PYFSAbsFileSystem
+String pyScheme = \"py\";+Path workingDir;+ URI uri;+ FSDelegate fsDelegate;+FSAttribute fsAttribute;+AsyncStorage storage;+String user;+String group;
open()create()delete()mkdir()close()
FileSystem
AbstractInputStream
updateCacheRange()hit()
PYFSFileSystem
PYFSInputStream
+long filePos
+seek()+read()
CachePage
+ WriteSlice[] writeSlices;+Page page;
+canCommit()+commitPage()+flush
WriteSlice
+write()+writeToStorage()
AbstractOutputStream
flush()
Hadoop接口
PYFSOutputStream
+write()+flush()
AbstractFileSystem
FSInputStream
OutputStream
0 条评论
下一页
