Class LevelDBFile
- java.lang.Object
-
- org.apache.camel.component.leveldb.LevelDBFile
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.Service
public class LevelDBFile extends Object implements org.apache.camel.Service
Manages access to a shared LevelDB file. Will by default not sync writes which allows it to be faster. You can force syncing by setting the sync option to true.
-
-
Constructor Summary
Constructors Constructor Description LevelDBFile()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getBlockRestartInterval()
int
getBlockSize()
long
getCacheSize()
String
getCompressionType()
org.iq80.leveldb.DB
getDb()
File
getFile()
String
getFileName()
int
getMaxOpenFiles()
int
getWriteBufferSize()
org.iq80.leveldb.WriteOptions
getWriteOptions()
boolean
isParanoidChecks()
boolean
isSync()
boolean
isVerifyChecksums()
void
setBlockRestartInterval(int blockRestartInterval)
void
setBlockSize(int blockSize)
void
setCacheSize(long cacheSize)
void
setCompressionType(String compressionType)
void
setFile(File file)
void
setFileName(String fileName)
void
setMaxOpenFiles(int maxOpenFiles)
void
setParanoidChecks(boolean paranoidChecks)
void
setSync(boolean sync)
void
setVerifyChecksums(boolean verifyChecksums)
void
setWriteBufferSize(int writeBufferSize)
void
start()
void
stop()
-
-
-
Method Detail
-
getDb
public org.iq80.leveldb.DB getDb()
-
getFile
public File getFile()
-
setFile
public void setFile(File file) throws IOException
- Throws:
IOException
-
getFileName
public String getFileName() throws IOException
- Throws:
IOException
-
setFileName
public void setFileName(String fileName)
-
getWriteBufferSize
public int getWriteBufferSize()
-
setWriteBufferSize
public void setWriteBufferSize(int writeBufferSize)
-
getMaxOpenFiles
public int getMaxOpenFiles()
-
setMaxOpenFiles
public void setMaxOpenFiles(int maxOpenFiles)
-
getBlockRestartInterval
public int getBlockRestartInterval()
-
setBlockRestartInterval
public void setBlockRestartInterval(int blockRestartInterval)
-
getBlockSize
public int getBlockSize()
-
setBlockSize
public void setBlockSize(int blockSize)
-
getCompressionType
public String getCompressionType()
-
setCompressionType
public void setCompressionType(String compressionType)
-
isVerifyChecksums
public boolean isVerifyChecksums()
-
setVerifyChecksums
public void setVerifyChecksums(boolean verifyChecksums)
-
isParanoidChecks
public boolean isParanoidChecks()
-
setParanoidChecks
public void setParanoidChecks(boolean paranoidChecks)
-
getCacheSize
public long getCacheSize()
-
setCacheSize
public void setCacheSize(long cacheSize)
-
isSync
public boolean isSync()
-
setSync
public void setSync(boolean sync)
-
getWriteOptions
public org.iq80.leveldb.WriteOptions getWriteOptions()
-
start
public void start()
- Specified by:
start
in interfaceorg.apache.camel.Service
-
stop
public void stop()
- Specified by:
stop
in interfaceorg.apache.camel.Service
-
-