io.permazen.kv.spanner

Class ReadWriteSpannerView

java.lang.Object

io.permazen.kv.AbstractKVStore

io.permazen.kv.mvcc.MutableView

io.permazen.kv.spanner.ReadWriteSpannerView

All Implemented Interfaces:

CloseableKVStore, KVStore, Closeable, AutoCloseable, Cloneable

public class ReadWriteSpannerView
extends MutableView
implements CloseableKVStore

Provides a mutable KVStore view of a ReadContext.

For best performance, supply an ExecutorService for asynchronous batch loading.

Use bufferMutations() to transfer outstanding mutations into a TransactionContext.

See Also:

ReadOnlySpannerView, CachingKVStore

Field Summary

Fields

Modifier and Type	Field and Description
protected Function<? super SpannerException,RuntimeException>	exceptionMapper
protected Logger	log
protected String	tableName

Constructor Summary

Constructors

Constructor and Description
ReadWriteSpannerView(String tableName, ReadContext context, Function<? super SpannerException,RuntimeException> exceptionMapper) Constructor for when no batching is desired.
ReadWriteSpannerView(String tableName, ReadContext context, Function<? super SpannerException,RuntimeException> exceptionMapper, ExecutorService executor, long rttEstimate) Constructor for when batching is desired.

Method Summary

Modifier and Type	Method and Description
void	bufferMutations(TransactionContext context) Atomically transfer all of the outstanding mutations associated with this instance into the given transaction context, and then clear them.
ReadWriteSpannerView	clone() Clone this instance.
void	close() Close the associated ReadContext.
double	getRttEstimate() Get the current RTT estimate.

Methods inherited from class io.permazen.kv.mvcc.MutableView

adjustCounter, apply, decodeCounter, disableReadTracking, encodeCounter, get, getKVStore, getRange, getReads, getWrites, put, remove, removeRange, setKVStore, setReadOnly, setReadTrackingPaused, toString

Methods inherited from class io.permazen.kv.AbstractKVStore

getAtLeast, getAtMost

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.permazen.kv.KVStore

adjustCounter, apply, decodeCounter, encodeCounter, get, getAtLeast, getAtMost, getRange, getRange, getRange, put, remove, removeRange, removeRange

Field Detail

log

protected final Logger log

tableName

protected final String tableName

exceptionMapper

protected final Function<? super SpannerException,RuntimeException> exceptionMapper

Constructor Detail

ReadWriteSpannerView

public ReadWriteSpannerView(String tableName,
                            ReadContext context,
                            Function<? super SpannerException,RuntimeException> exceptionMapper)

Constructor for when no batching is desired.

Parameters:

tableName - name of the Spanner database table

context - read context

exceptionMapper - mapper for any thrown SpannerExceptions, or null for none

Throws:

IllegalArgumentException - if tableName or context is null

ReadWriteSpannerView

public ReadWriteSpannerView(String tableName,
                            ReadContext context,
                            Function<? super SpannerException,RuntimeException> exceptionMapper,
                            ExecutorService executor,
                            long rttEstimate)

Constructor for when batching is desired.

Parameters:

tableName - name of the Spanner database table

context - read context

exceptionMapper - mapper for any thrown SpannerExceptions, or null for none

executor - asynchronous load task executor

rttEstimate - initial RTT estimate in nanoseconds

Throws:

IllegalArgumentException - if tableName, context or executor is null

IllegalArgumentException - if rttEstimate is negative

Method Detail

getRttEstimate

public double getRttEstimate()

Get the current RTT estimate.

Returns:

current RTT estimate in nanoseconds

bufferMutations

public void bufferMutations(TransactionContext context)

Atomically transfer all of the outstanding mutations associated with this instance into the given transaction context, and then clear them.

Parameters:

context - transaction context

Throws:

IllegalArgumentException - if context is null

clone

public ReadWriteSpannerView clone()

Description copied from class: MutableView

Clone this instance.

The clone will have the same underlying KVStore, but its own Reads and Writes, which will themselves be cloned from this instance's copies.

Overrides:

clone in class MutableView

Returns:

clone of this instance

close

public void close()

Close the associated ReadContext.

Specified by:

close in interface CloseableKVStore

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable