net.thevpc.nuts.runtime.standalone.xtra.nanodb.file

Class NanoDBTableStoreFile<T>

java.lang.Object

net.thevpc.nuts.runtime.standalone.xtra.nanodb.file.NanoDBTableStoreFile<T>

All Implemented Interfaces:

AutoCloseable, Iterable<T>, NanoDBTableStore<T>

public class NanoDBTableStoreFile<T>
extends Object
implements NanoDBTableStore<T>

Field Summary

Fields

Modifier and Type	Field and Description
static String	NANODB_TABLE_0_8_1

Constructor Summary

Constructors

Constructor and Description
NanoDBTableStoreFile(Class<T> rowType, File dir, String tableName, NanoDBSerializer<T> serializer, NanoDB db, NanoDBIndexDefinition<T>[] indexDefinitions)

Method Summary

Modifier and Type	Method and Description
long	add(T a)
void	close()
NStream<T>	findByIndex(String indexName, Object value)
<T> NStream<T>	findIndexValues(String indexName)
void	flush()
T	get(long position)
long	getFileLength()
static int	getUTFLength(String s)
Iterable<T>	items()
Iterator<T>	iterator()
NStream<T>	stream()
void	updateIndices(T a, long objectId)

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

NANODB_TABLE_0_8_1

public static final String NANODB_TABLE_0_8_1

See Also:

Constant Field Values

Constructor Detail

NanoDBTableStoreFile

public NanoDBTableStoreFile(Class<T> rowType,
                            File dir,
                            String tableName,
                            NanoDBSerializer<T> serializer,
                            NanoDB db,
                            NanoDBIndexDefinition<T>[] indexDefinitions)

Method Detail

getUTFLength

public static int getUTFLength(String s)

get

public T get(long position)

Specified by:

get in interface NanoDBTableStore<T>

add

public long add(T a)

Specified by:

add in interface NanoDBTableStore<T>

flush

public void flush()

Specified by:

flush in interface NanoDBTableStore<T>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface NanoDBTableStore<T>

stream

public NStream<T> stream()

Specified by:

stream in interface NanoDBTableStore<T>

items

public Iterable<T> items()

Specified by:

items in interface NanoDBTableStore<T>

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>

Specified by:

iterator in interface NanoDBTableStore<T>

updateIndices

public void updateIndices(T a,
                          long objectId)

Specified by:

updateIndices in interface NanoDBTableStore<T>

findByIndex

public NStream<T> findByIndex(String indexName,
                              Object value)

Specified by:

findByIndex in interface NanoDBTableStore<T>

findIndexValues

public <T> NStream<T> findIndexValues(String indexName)

Specified by:

findIndexValues in interface NanoDBTableStore<T>

getFileLength

public long getFileLength()

Specified by:

getFileLength in interface NanoDBTableStore<T>