org.apache.tephra.inmemory

Class InMemoryTransactionService

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.apache.tephra.inmemory.InMemoryTransactionService

All Implemented Interfaces:

com.google.common.util.concurrent.Service

Direct Known Subclasses:

TransactionService

public class InMemoryTransactionService
extends com.google.common.util.concurrent.AbstractService

Transaction server that manages transaction data for the Reactor.

Transaction server is HA, one can start multiple instances, only one of which is active and will register itself in discovery service.

Nested Class Summary

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field and Description
protected String	address
protected int	ioThreads
protected int	maxReadBufferBytes
protected int	port
protected int	threads
protected TransactionManager	txManager
protected com.google.inject.Provider<TransactionManager>	txManagerProvider

Constructor Summary

Constructors

Constructor and Description
InMemoryTransactionService(org.apache.hadoop.conf.Configuration conf, org.apache.twill.discovery.DiscoveryService discoveryService, com.google.inject.Provider<TransactionManager> txManagerProvider)

Method Summary

Modifier and Type	Method and Description
protected void	doRegister()
protected void	doStart()
protected void	doStop()
protected InetSocketAddress	getAddress()
protected void	undoRegister()

Methods inherited from class com.google.common.util.concurrent.AbstractService

addListener, isRunning, notifyFailed, notifyStarted, notifyStopped, start, startAndWait, state, stop, stopAndWait, toString

Methods inherited from class java.lang.Object

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

Field Detail

txManagerProvider

protected final com.google.inject.Provider<TransactionManager> txManagerProvider

txManager

protected TransactionManager txManager

address

protected final String address

port

protected final int port

threads

protected final int threads

ioThreads

protected final int ioThreads

maxReadBufferBytes

protected final int maxReadBufferBytes

Constructor Detail

InMemoryTransactionService

@Inject
public InMemoryTransactionService(org.apache.hadoop.conf.Configuration conf,
                                          org.apache.twill.discovery.DiscoveryService discoveryService,
                                          com.google.inject.Provider<TransactionManager> txManagerProvider)

Method Detail

undoRegister

protected void undoRegister()

doRegister

protected void doRegister()

getAddress

protected InetSocketAddress getAddress()

doStart

protected void doStart()

Specified by:

doStart in class com.google.common.util.concurrent.AbstractService

doStop

protected void doStop()

Specified by:

doStop in class com.google.common.util.concurrent.AbstractService