public class NIOSequentialFileFactory extends AbstractSequentialFileFactory
bufferSize, bufferTimeout, EXECUTOR_TIMEOUT, journalDir, maxIO, timedBuffer, writeExecutor
Constructor and Description |
---|
NIOSequentialFileFactory(File journalDir,
boolean buffered,
int maxIO) |
NIOSequentialFileFactory(File journalDir,
boolean buffered,
int bufferSize,
int bufferTimeout,
int maxIO,
boolean logRates) |
NIOSequentialFileFactory(File journalDir,
boolean buffered,
int bufferSize,
int bufferTimeout,
int maxIO,
boolean logRates,
IOCriticalErrorListener listener) |
NIOSequentialFileFactory(File journalDir,
boolean buffered,
IOCriticalErrorListener listener,
int maxIO) |
NIOSequentialFileFactory(File journalDir,
int maxIO) |
NIOSequentialFileFactory(File journalDir,
IOCriticalErrorListener listener,
int maxIO) |
Modifier and Type | Method and Description |
---|---|
ByteBuffer |
allocateDirectBuffer(int size)
used for cases where you need direct buffer outside of the journal context.
|
static ByteBuffer |
allocateDirectByteBuffer(int size) |
int |
calculateBlockSize(int bytes) |
void |
clearBuffer(ByteBuffer buffer) |
SequentialFile |
createSequentialFile(String fileName) |
int |
getAlignment() |
boolean |
isSupportsCallbacks() |
ByteBuffer |
newBuffer(int size)
Note: You need to release the buffer if is used for reading operations.
|
void |
releaseDirectBuffer(ByteBuffer buffer)
used for cases where you need direct buffer outside of the journal context.
|
ByteBuffer |
wrapBuffer(byte[] bytes) |
activateBuffer, createDirs, deactivateBuffer, flush, getDirectory, getMaxIO, listFiles, onIOError, releaseBuffer, start, stop
public NIOSequentialFileFactory(File journalDir, int maxIO)
public NIOSequentialFileFactory(File journalDir, IOCriticalErrorListener listener, int maxIO)
public NIOSequentialFileFactory(File journalDir, boolean buffered, int maxIO)
public NIOSequentialFileFactory(File journalDir, boolean buffered, IOCriticalErrorListener listener, int maxIO)
public NIOSequentialFileFactory(File journalDir, boolean buffered, int bufferSize, int bufferTimeout, int maxIO, boolean logRates)
public NIOSequentialFileFactory(File journalDir, boolean buffered, int bufferSize, int bufferTimeout, int maxIO, boolean logRates, IOCriticalErrorListener listener)
public static ByteBuffer allocateDirectByteBuffer(int size)
public SequentialFile createSequentialFile(String fileName)
public boolean isSupportsCallbacks()
public ByteBuffer allocateDirectBuffer(int size)
SequentialFileFactory
public void releaseDirectBuffer(ByteBuffer buffer)
SequentialFileFactory
public ByteBuffer newBuffer(int size)
SequentialFileFactory
public void clearBuffer(ByteBuffer buffer)
public ByteBuffer wrapBuffer(byte[] bytes)
public int getAlignment()
public int calculateBlockSize(int bytes)
Copyright © 2016 The Apache Software Foundation. All rights reserved.