org.iq80.leveldb.impl

Class VersionSet

java.lang.Object

org.iq80.leveldb.impl.VersionSet

All Implemented Interfaces:

Iterable<Map.Entry<InternalKey,Slice>>, SeekingIterable<InternalKey,Slice>

public class VersionSet
extends Object
implements SeekingIterable<InternalKey,Slice>

Field Summary

Fields

Modifier and Type	Field and Description
static long	MAX_GRAND_PARENT_OVERLAP_BYTES
static int	TARGET_FILE_SIZE

Constructor Summary

Constructors

Constructor and Description
VersionSet(File databaseDir, TableCache tableCache, InternalKeyComparator internalKeyComparator)

Method Summary

Modifier and Type	Method and Description
Compaction	compactRange(int level, InternalKey begin, InternalKey end)
void	destroy()
LookupResult	get(LookupKey key)
Version	getCurrent()
InternalKeyComparator	getInternalKeyComparator()
long	getLastSequence()
List<FileMetaData>	getLiveFiles()
long	getLogNumber()
long	getManifestFileNumber()
long	getMaxNextLevelOverlappingBytes()
long	getNextFileNumber()
long	getPrevLogNumber()
TableCache	getTableCache()
MergingIterator	iterator()
void	logAndApply(VersionEdit edit)
MergingIterator	makeInputIterator(Compaction c)
static long	maxFileSizeForLevel(int level)
boolean	needsCompaction()
long	numberOfBytesInLevel(int level)
int	numberOfFilesInLevel(int level)
boolean	overlapInLevel(int level, Slice smallestUserKey, Slice largestUserKey)
Compaction	pickCompaction()
void	recover()
void	removeVersion(Version version)
void	setLastSequence(long newLastSequence)

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

Field Detail

TARGET_FILE_SIZE

public static final int TARGET_FILE_SIZE

See Also:

Constant Field Values

MAX_GRAND_PARENT_OVERLAP_BYTES

public static final long MAX_GRAND_PARENT_OVERLAP_BYTES

See Also:

Constant Field Values

Constructor Detail

VersionSet

public VersionSet(File databaseDir,
                  TableCache tableCache,
                  InternalKeyComparator internalKeyComparator)
           throws IOException

Throws:

IOException

Method Detail

destroy

public void destroy()
             throws IOException

Throws:

IOException

removeVersion

public void removeVersion(Version version)

getInternalKeyComparator

public InternalKeyComparator getInternalKeyComparator()

getTableCache

public TableCache getTableCache()

getCurrent

public Version getCurrent()

getManifestFileNumber

public long getManifestFileNumber()

getNextFileNumber

public long getNextFileNumber()

getLogNumber

public long getLogNumber()

getPrevLogNumber

public long getPrevLogNumber()

iterator

public MergingIterator iterator()

Specified by:

iterator in interface Iterable<Map.Entry<InternalKey,Slice>>

Specified by:

iterator in interface SeekingIterable<InternalKey,Slice>

makeInputIterator

public MergingIterator makeInputIterator(Compaction c)

get

public LookupResult get(LookupKey key)

overlapInLevel

public boolean overlapInLevel(int level,
                              Slice smallestUserKey,
                              Slice largestUserKey)

numberOfFilesInLevel

public int numberOfFilesInLevel(int level)

numberOfBytesInLevel

public long numberOfBytesInLevel(int level)

getLastSequence

public long getLastSequence()

setLastSequence

public void setLastSequence(long newLastSequence)

logAndApply

public void logAndApply(VersionEdit edit)
                 throws IOException

Throws:

IOException

recover

public void recover()
             throws IOException

Throws:

IOException

getLiveFiles

public List<FileMetaData> getLiveFiles()

maxFileSizeForLevel

public static long maxFileSizeForLevel(int level)

needsCompaction

public boolean needsCompaction()

compactRange

public Compaction compactRange(int level,
                               InternalKey begin,
                               InternalKey end)

pickCompaction

public Compaction pickCompaction()

getMaxNextLevelOverlappingBytes

public long getMaxNextLevelOverlappingBytes()