com.splicemachine.si.impl

Class MSynchronousReadResolver

java.lang.Object

com.splicemachine.si.impl.MSynchronousReadResolver

All Implemented Interfaces:

KeyedReadResolver

@ThreadSafe
public class MSynchronousReadResolver
extends java.lang.Object
implements KeyedReadResolver

Read-Resolver which resolves elements synchronously on the calling thread.

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	DISABLED_ROLLFORWARD
static MSynchronousReadResolver	INSTANCE

Method Summary

Modifier and Type	Method and Description
static ReadResolver	getResolver(Partition region, TxnSupplier txnSupplier, RollForwardStatus status)
static ReadResolver	getResolver(Partition region, TxnSupplier txnSupplier, RollForwardStatus status, TrafficControl trafficControl, boolean failOnError)
boolean	resolve(Partition region, ByteSlice rowKey, long txnId, TxnSupplier supplier, RollForwardStatus status, boolean failOnError, TrafficControl trafficControl)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final MSynchronousReadResolver INSTANCE

DISABLED_ROLLFORWARD

public static volatile boolean DISABLED_ROLLFORWARD

Method Detail

getResolver

@ThreadSafe
public static ReadResolver getResolver(Partition region,
                                                   TxnSupplier txnSupplier,
                                                   RollForwardStatus status)

Parameters:

region - the region for the relevant read resolver

txnSupplier - a Transaction Supplier for fetching transaction information

Returns:

a ReadResolver which uses Synchronous Read Resolution under the hood.

getResolver

@ThreadSafe
public static ReadResolver getResolver(Partition region,
                                                   TxnSupplier txnSupplier,
                                                   RollForwardStatus status,
                                                   TrafficControl trafficControl,
                                                   boolean failOnError)

resolve

public boolean resolve(Partition region,
                       ByteSlice rowKey,
                       long txnId,
                       TxnSupplier supplier,
                       RollForwardStatus status,
                       boolean failOnError,
                       TrafficControl trafficControl)

Specified by:

resolve in interface KeyedReadResolver