com.splicemachine.si.data.hbase.coprocessor

Class HBaseSIEnvironment

java.lang.Object

com.splicemachine.si.data.hbase.coprocessor.HBaseSIEnvironment

All Implemented Interfaces:

SIEnvironment

public class HBaseSIEnvironment
extends java.lang.Object
implements SIEnvironment

Constructor Summary

Constructors

Constructor and Description
HBaseSIEnvironment(org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper rzk, Clock clock)
HBaseSIEnvironment(TimestampSource timeSource, Clock clock)

Method Summary

Modifier and Type	Method and Description
OperationFactory	baseOperationFactory()
ClusterHealth	clusterHealthFactory()
SConfiguration	configuration()
ExceptionFactory	exceptionFactory()
DistributedFileSystem	fileSystem(java.lang.String path) Retrieve the appropriate filesystem based on the path and configuration.
FilesystemAdmin	filesystemAdmin()
DataFilterFactory	filterFactory()
SIDriver	getSIDriver()
IgnoreTxnSupplier	ignoreTxnSupplier()
KeepAliveScheduler	keepAliveScheduler()
KeyedReadResolver	keyedReadResolver()
static HBaseSIEnvironment	loadEnvironment(Clock clock, org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper rzk)
TxnOperationFactory	operationFactory()
PartitionInfoCache	partitionInfoCache()
RollForward	rollForward()
static void	setEnvironment(HBaseSIEnvironment siEnv)
void	setSIDriver(SIDriver siDriver)
SnowflakeFactory	snowflakeFactory()
OperationStatusFactory	statusFactory()
Clock	systemClock()
PartitionFactory	tableFactory()
TimestampSource	timestampSource()
TxnStore	txnStore()
TxnSupplier	txnSupplier()

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseSIEnvironment

public HBaseSIEnvironment(TimestampSource timeSource,
                          Clock clock)
                   throws java.io.IOException

Throws:

java.io.IOException

HBaseSIEnvironment

public HBaseSIEnvironment(org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper rzk,
                          Clock clock)
                   throws java.io.IOException

Throws:

java.io.IOException

Method Detail

loadEnvironment

public static HBaseSIEnvironment loadEnvironment(Clock clock,
                                                 org.apache.hadoop.hbase.zookeeper.RecoverableZooKeeper rzk)
                                          throws java.io.IOException

Throws:

java.io.IOException

setEnvironment

public static void setEnvironment(HBaseSIEnvironment siEnv)

tableFactory

public PartitionFactory tableFactory()

Specified by:

tableFactory in interface SIEnvironment

exceptionFactory

public ExceptionFactory exceptionFactory()

Specified by:

exceptionFactory in interface SIEnvironment

configuration

public SConfiguration configuration()

Specified by:

configuration in interface SIEnvironment

txnStore

public TxnStore txnStore()

Specified by:

txnStore in interface SIEnvironment

txnSupplier

public TxnSupplier txnSupplier()

Specified by:

txnSupplier in interface SIEnvironment

ignoreTxnSupplier

public IgnoreTxnSupplier ignoreTxnSupplier()

Specified by:

ignoreTxnSupplier in interface SIEnvironment

statusFactory

public OperationStatusFactory statusFactory()

Specified by:

statusFactory in interface SIEnvironment

timestampSource

public TimestampSource timestampSource()

Specified by:

timestampSource in interface SIEnvironment

rollForward

public RollForward rollForward()

Specified by:

rollForward in interface SIEnvironment

operationFactory

public TxnOperationFactory operationFactory()

Specified by:

operationFactory in interface SIEnvironment

getSIDriver

public SIDriver getSIDriver()

Specified by:

getSIDriver in interface SIEnvironment

partitionInfoCache

public PartitionInfoCache partitionInfoCache()

Specified by:

partitionInfoCache in interface SIEnvironment

keepAliveScheduler

public KeepAliveScheduler keepAliveScheduler()

Specified by:

keepAliveScheduler in interface SIEnvironment

filterFactory

public DataFilterFactory filterFactory()

Specified by:

filterFactory in interface SIEnvironment

systemClock

public Clock systemClock()

Specified by:

systemClock in interface SIEnvironment

keyedReadResolver

public KeyedReadResolver keyedReadResolver()

Specified by:

keyedReadResolver in interface SIEnvironment

fileSystem

public DistributedFileSystem fileSystem(java.lang.String path)
                                 throws java.io.IOException,
                                        java.net.URISyntaxException

Description copied from interface: SIEnvironment

Retrieve the appropriate filesystem based on the path and configuration.

Specified by:

fileSystem in interface SIEnvironment

Returns:

Throws:

java.io.IOException

java.net.URISyntaxException

baseOperationFactory

public OperationFactory baseOperationFactory()

Specified by:

baseOperationFactory in interface SIEnvironment

setSIDriver

public void setSIDriver(SIDriver siDriver)

snowflakeFactory

public SnowflakeFactory snowflakeFactory()

Specified by:

snowflakeFactory in interface SIEnvironment

clusterHealthFactory

public ClusterHealth clusterHealthFactory()

Specified by:

clusterHealthFactory in interface SIEnvironment

filesystemAdmin

public FilesystemAdmin filesystemAdmin()

Specified by:

filesystemAdmin in interface SIEnvironment