org.iq80.leveldb.impl

Class DbImpl

java.lang.Object

org.iq80.leveldb.impl.DbImpl

All Implemented Interfaces:

Closeable, AutoCloseable, Iterable<Map.Entry<byte[],byte[]>>, DB

public class DbImpl
extends Object
implements DB

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DbImpl.BackgroundProcessingException
static class	DbImpl.DatabaseShutdownException

Constructor Summary

Constructors

Constructor and Description
DbImpl(Options options, File databaseDir)

Method Summary

Modifier and Type	Method and Description
void	checkBackgroundException()
void	close()
void	compactMemTable()
void	compactRange(byte[] begin, byte[] end) Force a compaction of the specified key range.
void	compactRange(int level, Slice start, Slice end)
WriteBatch	createWriteBatch()
void	delete(byte[] key)
Snapshot	delete(byte[] key, WriteOptions options)
void	flushMemTable()
byte[]	get(byte[] key)
byte[]	get(byte[] key, ReadOptions options)
long[]	getApproximateSizes(Range... ranges)
long	getApproximateSizes(Range range)
long	getMaxNextLevelOverlappingBytes()
String	getProperty(String name)
Snapshot	getSnapshot()
SeekingIteratorAdapter	iterator()
SeekingIteratorAdapter	iterator(ReadOptions options)
void	put(byte[] key, byte[] value)
Snapshot	put(byte[] key, byte[] value, WriteOptions options)
void	resumeCompactions() Resumes the background compaction threads.
void	suspendCompactions() Suspends any background compaction threads.
void	write(WriteBatch updates)
Snapshot	write(WriteBatch updates, WriteOptions options)
Snapshot	writeInternal(WriteBatchImpl updates, WriteOptions options)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

DbImpl

public DbImpl(Options options,
              File databaseDir)
       throws IOException

Throws:

IOException

Method Detail

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getProperty

public String getProperty(String name)

Specified by:

getProperty in interface DB

flushMemTable

public void flushMemTable()

compactRange

public void compactRange(int level,
                         Slice start,
                         Slice end)

checkBackgroundException

public void checkBackgroundException()

get

public byte[] get(byte[] key)
           throws DBException

Specified by:

get in interface DB

Throws:

DBException

get

public byte[] get(byte[] key,
                  ReadOptions options)
           throws DBException

Specified by:

get in interface DB

Throws:

DBException

put

public void put(byte[] key,
                byte[] value)
         throws DBException

Specified by:

put in interface DB

Throws:

DBException

put

public Snapshot put(byte[] key,
                    byte[] value,
                    WriteOptions options)
             throws DBException

Specified by:

put in interface DB

Returns:

null if options.isSnapshot()==false otherwise returns a snapshot of the DB after this operation.

Throws:

DBException

delete

public void delete(byte[] key)
            throws DBException

Specified by:

delete in interface DB

Throws:

DBException

delete

public Snapshot delete(byte[] key,
                       WriteOptions options)
                throws DBException

Specified by:

delete in interface DB

Returns:

null if options.isSnapshot()==false otherwise returns a snapshot of the DB after this operation.

Throws:

DBException

write

public void write(WriteBatch updates)
           throws DBException

Specified by:

write in interface DB

Throws:

DBException

write

public Snapshot write(WriteBatch updates,
                      WriteOptions options)
               throws DBException

Specified by:

write in interface DB

Returns:

null if options.isSnapshot()==false otherwise returns a snapshot of the DB after this operation.

Throws:

DBException

writeInternal

public Snapshot writeInternal(WriteBatchImpl updates,
                              WriteOptions options)
                       throws DBException

Throws:

DBException

createWriteBatch

public WriteBatch createWriteBatch()

Specified by:

createWriteBatch in interface DB

iterator

public SeekingIteratorAdapter iterator()

Specified by:

iterator in interface Iterable<Map.Entry<byte[],byte[]>>

Specified by:

iterator in interface DB

iterator

public SeekingIteratorAdapter iterator(ReadOptions options)

Specified by:

iterator in interface DB

getSnapshot

public Snapshot getSnapshot()

Specified by:

getSnapshot in interface DB

compactMemTable

public void compactMemTable()
                     throws IOException

Throws:

IOException

getApproximateSizes

public long[] getApproximateSizes(Range... ranges)

Specified by:

getApproximateSizes in interface DB

getApproximateSizes

public long getApproximateSizes(Range range)

getMaxNextLevelOverlappingBytes

public long getMaxNextLevelOverlappingBytes()

suspendCompactions

public void suspendCompactions()
                        throws InterruptedException

Description copied from interface: DB

Suspends any background compaction threads. This methods returns once the background compactions are suspended.

Specified by:

suspendCompactions in interface DB

Throws:

InterruptedException

resumeCompactions

public void resumeCompactions()

Description copied from interface: DB

Resumes the background compaction threads.

Specified by:

resumeCompactions in interface DB

compactRange

public void compactRange(byte[] begin,
                         byte[] end)
                  throws DBException

Description copied from interface: DB

Force a compaction of the specified key range.

Specified by:

compactRange in interface DB

Parameters:

begin - if null then compaction start from the first key

end - if null then compaction ends at the last key

Throws:

DBException