com.spotify.sparkey.extra

Class ThreadLocalSparkeyReader

java.lang.Object

com.spotify.sparkey.extra.ThreadLocalSparkeyReader

All Implemented Interfaces:

SparkeyReader, Iterable<SparkeyReader.Entry>

public class ThreadLocalSparkeyReader
extends Object
implements SparkeyReader

A thread-safe Sparkey Reader.

Nested Class Summary

Nested classes/interfaces inherited from interface com.spotify.sparkey.SparkeyReader

SparkeyReader.Entry, SparkeyReader.Type

Constructor Summary

Constructors

Constructor and Description
ThreadLocalSparkeyReader(File indexFile)
ThreadLocalSparkeyReader(SparkeyReader reader)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
SparkeyReader	duplicate() Create a duplicate of the reader.
byte[]	getAsByteArray(byte[] key)
SparkeyReader.Entry	getAsEntry(byte[] key) This is mostly useful for retrieving large values that don't fit in a byte array.
String	getAsString(String key)
IndexHeader	getIndexHeader()
LogHeader	getLogHeader()
Iterator<SparkeyReader.Entry>	iterator() Get an iterator over all the live entries.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadLocalSparkeyReader

public ThreadLocalSparkeyReader(File indexFile)
                         throws IOException

Throws:

IOException

ThreadLocalSparkeyReader

public ThreadLocalSparkeyReader(SparkeyReader reader)

Method Detail

getAsString

public String getAsString(String key)
                   throws IOException

Specified by:

getAsString in interface SparkeyReader

Parameters:

key - the key to search for, interpreted as an UTF-8 string.

Returns:

null if the key/value pair was not found, otherwise the value interpreted as an UTF-8 string.

Throws:

IOException

getAsByteArray

public byte[] getAsByteArray(byte[] key)
                      throws IOException

Specified by:

getAsByteArray in interface SparkeyReader

Parameters:

key - the key to search for

Returns:

null if the key/value pair was not found, otherwise the raw byte array value

Throws:

IOException

getAsEntry

public SparkeyReader.Entry getAsEntry(byte[] key)
                               throws IOException

Description copied from interface: SparkeyReader

This is mostly useful for retrieving large values that don't fit in a byte array.

Specified by:

getAsEntry in interface SparkeyReader

Parameters:

key - the key to search for

Returns:

null if the key/value pair was not found, otherwise the entry.

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface SparkeyReader

Throws:

IOException

getIndexHeader

public IndexHeader getIndexHeader()

Specified by:

getIndexHeader in interface SparkeyReader

getLogHeader

public LogHeader getLogHeader()

Specified by:

getLogHeader in interface SparkeyReader

duplicate

public SparkeyReader duplicate()

Description copied from interface: SparkeyReader

Create a duplicate of the reader. Useful for using the reader from another thread.

Specified by:

duplicate in interface SparkeyReader

Returns:

a duplicate of the reader.

iterator

public Iterator<SparkeyReader.Entry> iterator()

Description copied from interface: SparkeyReader

Get an iterator over all the live entries. The iterator object is not thread safe, and the entry objects are highly volatile and will be invalidated by the next iteration step. Don't leak this entry, copy whatever data you want from it instead.

Specified by:

iterator in interface SparkeyReader

Specified by:

iterator in interface Iterable<SparkeyReader.Entry>

Returns:

an iterator