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