@InterfaceAudience.Private public class FileIOEngine extends Object implements IOEngine
Constructor and Description |
---|
FileIOEngine(String filePath,
long fileSize) |
Modifier and Type | Method and Description |
---|---|
boolean |
isPersistent()
File IO engine is always able to support persistent storage for the cache
|
int |
read(ByteBuffer dstBuffer,
long offset)
Transfers data from file to the given byte buffer
|
void |
shutdown()
Close the file
|
void |
sync()
Sync the data to file after writing
|
String |
toString() |
void |
write(ByteBuffer srcBuffer,
long offset)
Transfers data from the given byte buffer to file
|
public FileIOEngine(String filePath, long fileSize) throws IOException
IOException
public boolean isPersistent()
isPersistent
in interface IOEngine
public int read(ByteBuffer dstBuffer, long offset) throws IOException
read
in interface IOEngine
dstBuffer
- the given byte buffer into which bytes are to be writtenoffset
- The offset in the file where the first byte to be readIOException
public void write(ByteBuffer srcBuffer, long offset) throws IOException
write
in interface IOEngine
srcBuffer
- the given byte buffer from which bytes are to be readoffset
- The offset in the file where the first byte to be writtenIOException
public void sync() throws IOException
sync
in interface IOEngine
IOException
Copyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.