Package org.iq80.leveldb.benchmark

Class DbBenchmark

java.lang.Object

org.iq80.leveldb.benchmark.DbBenchmark

public class DbBenchmark
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static enum	DbBenchmark.DBState
private static enum	DbBenchmark.Flag
(package private) static enum	DbBenchmark.Order
private static class	DbBenchmark.RandomGenerator

Field Summary

Fields

Modifier and Type	Field	Description
private final List<String>	benchmarks
private long	bytes
private final double	compressionRatio
private final File	databaseDir
private DB	db
private int	done
private final DBFactory	factory
private final DbBenchmark.RandomGenerator	generator
private int	heapCounter
private double	lastOpFinish
private String	message
private int	nextReport
private final int	num
private String	postMessage
private final Random	random
private int	reads
private long	startTime
private final boolean	useExisting
private final int	valueSize
private final Integer	writeBufferSize

Constructor Summary

Constructors

Constructor	Description
DbBenchmark(Map<DbBenchmark.Flag,Object> flags)

Method Summary

Modifier and Type	Method	Description
private void	acquireLoad()
private void	compact()
private static Slice	compressibleString(Random rnd, double compressionRatio, int len)
private void	crc32c(int blockSize, String message)
private void	destroyDb()
private void	finishedSingleOp()
static byte[]	formatNumber(long n)
private static Slice	generateRandomSlice(Random random, int length)
private void	heapProfile()
static void	main(String[] args)
private void	open()
(package private) void	printEnvironment()
private void	printHeader()
private void	printStats()
(package private) static void	printWarnings()
private void	readHot()
private void	readRandom()
private void	readReverse()
private void	readSequential()
private void	run()
private void	snappyCompress()
private void	snappyUncompressArray()
private void	snappyUncompressDirectBuffer()
private void	start()
private void	stop(String benchmark)
private void	write(WriteOptions writeOptions, DbBenchmark.Order order, DbBenchmark.DBState state, int numEntries, int valueSize, int entriesPerBatch)

Methods inherited from class java.lang.Object

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

Field Details

useExisting

private final boolean useExisting

writeBufferSize

private final Integer writeBufferSize

databaseDir

private final File databaseDir

compressionRatio

private final double compressionRatio

startTime

private long startTime

benchmarks

private final List<String> benchmarks

db

private DB db

num

private final int num

reads

private int reads

valueSize

private final int valueSize

heapCounter

private int heapCounter

lastOpFinish

private double lastOpFinish

bytes

private long bytes

message

private String message

postMessage

private String postMessage

generator

private final DbBenchmark.RandomGenerator generator

random

private final Random random

done

private int done

nextReport

private int nextReport

factory

private final DBFactory factory

Constructor Details

DbBenchmark

public DbBenchmark(Map<DbBenchmark.Flag,Object> flags)
            throws Exception

Throws:

Exception

Method Details

run

private void run()
          throws IOException

Throws:

IOException

printHeader

private void printHeader()
                  throws IOException

Throws:

IOException

printWarnings

static void printWarnings()

printEnvironment

void printEnvironment()
               throws IOException

Throws:

IOException

open

private void open()
           throws IOException

Throws:

IOException

start

private void start()

stop

private void stop(String benchmark)

write

private void write(WriteOptions writeOptions,
 DbBenchmark.Order order,
 DbBenchmark.DBState state,
 int numEntries,
 int valueSize,
 int entriesPerBatch)
            throws IOException

Throws:

IOException

formatNumber

public static byte[] formatNumber(long n)

finishedSingleOp

private void finishedSingleOp()

readSequential

private void readSequential()

readReverse

private void readReverse()

readRandom

private void readRandom()

readHot

private void readHot()

compact

private void compact()
              throws IOException

Throws:

IOException

crc32c

private void crc32c(int blockSize,
 String message)

acquireLoad

private void acquireLoad()

snappyCompress

private void snappyCompress()

snappyUncompressArray

private void snappyUncompressArray()

snappyUncompressDirectBuffer

private void snappyUncompressDirectBuffer()

heapProfile

private void heapProfile()

destroyDb

private void destroyDb()

printStats

private void printStats()

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

compressibleString

private static Slice compressibleString(Random rnd,
 double compressionRatio,
 int len)

generateRandomSlice

private static Slice generateRandomSlice(Random random,
 int length)