Package 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>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	VersionSet.Builder	A helper class so we can efficiently apply a whole sequence of edits to a particular state without creating intermediate Versions that contain full copies of the intermediate state.

Field Summary

Fields

Modifier and Type	Field	Description
private final Map<Version,Object>	activeVersions
private final Map<Integer,InternalKey>	compactPointers
private Version	current
private final File	databaseDir
private LogWriter	descriptorLog
private final InternalKeyComparator	internalKeyComparator
private static final int	L0_COMPACTION_TRIGGER
private long	lastSequence
private long	logNumber
private long	manifestFileNumber
static final long	MAX_GRAND_PARENT_OVERLAP_BYTES
private final AtomicLong	nextFileNumber
private long	prevLogNumber
private final TableCache	tableCache
static final int	TARGET_FILE_SIZE

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
private void	appendVersion(Version version)
private static <V> V	coalesce(V... values)
Compaction	compactRange(int level, InternalKey begin, InternalKey end)
void	destroy()
private void	finalizeVersion(Version version)
LookupResult	get(LookupKey key)
Version	getCurrent()
InternalKeyComparator	getInternalKeyComparator()
long	getLastSequence()
List<FileMetaData>	getLiveFiles()
long	getLogNumber()
long	getManifestFileNumber()
long	getMaxNextLevelOverlappingBytes()
long	getNextFileNumber()
(package private) List<FileMetaData>	getOverlappingInputs(int level, InternalKey begin, InternalKey end)
long	getPrevLogNumber()
private Map.Entry<InternalKey,InternalKey>	getRange(List<FileMetaData>... inputLists)
TableCache	getTableCache()
private void	initializeIfNeeded()
MergingIterator	iterator()
void	logAndApply(VersionEdit edit)
MergingIterator	makeInputIterator(Compaction c)
private static double	maxBytesForLevel(int level)
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)
private Compaction	setupOtherInputs(int level, List<FileMetaData> levelInputs)
private void	writeSnapshot(LogWriter log)

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 Details

L0_COMPACTION_TRIGGER

private static final int L0_COMPACTION_TRIGGER

See Also:

• Constant Field Values

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

nextFileNumber

private final AtomicLong nextFileNumber

manifestFileNumber

private long manifestFileNumber

current

private Version current

lastSequence

private long lastSequence

logNumber

private long logNumber

prevLogNumber

private long prevLogNumber

activeVersions

private final Map<Version,Object> activeVersions

databaseDir

private final File databaseDir

tableCache

private final TableCache tableCache

internalKeyComparator

private final InternalKeyComparator internalKeyComparator

descriptorLog

private LogWriter descriptorLog

compactPointers

private final Map<Integer,InternalKey> compactPointers

Constructor Details

VersionSet

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

Throws:

IOException

Method Details

initializeIfNeeded

private void initializeIfNeeded()
                         throws IOException

Throws:

IOException

destroy

public void destroy()
             throws IOException

Throws:

IOException

appendVersion

private void appendVersion(Version version)

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

writeSnapshot

private void writeSnapshot(LogWriter log)
                    throws IOException

Throws:

IOException

recover

public void recover()
             throws IOException

Throws:

IOException

finalizeVersion

private void finalizeVersion(Version version)

coalesce

private static <V> V coalesce(V... values)

getLiveFiles

public List<FileMetaData> getLiveFiles()

maxBytesForLevel

private static double maxBytesForLevel(int level)

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()

setupOtherInputs

private Compaction setupOtherInputs(int level,
 List<FileMetaData> levelInputs)

getOverlappingInputs

List<FileMetaData> getOverlappingInputs(int level,
 InternalKey begin,
 InternalKey end)

getRange

private Map.Entry<InternalKey,InternalKey> getRange(List<FileMetaData>... inputLists)

getMaxNextLevelOverlappingBytes

public long getMaxNextLevelOverlappingBytes()