org.apache.tephra.distributed

Class TransactionService

java.lang.Object

com.google.common.util.concurrent.AbstractService

org.apache.tephra.inmemory.InMemoryTransactionService

org.apache.tephra.distributed.TransactionService

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class TransactionService
extends InMemoryTransactionService

Transaction Service that includes Transaction Manager, Thrift Server, and Pruning 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 inherited from class org.apache.tephra.inmemory.InMemoryTransactionService

address, ioThreads, maxReadBufferBytes, port, threads, txManager, txManagerProvider

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	abort(Throwable cause)
protected TransactionPruningService	createPruningService(org.apache.hadoop.conf.Configuration conf, TransactionManager txManager) Called at startup to create the pruning service.
protected void	doStart()
protected void	doStop()
protected InetSocketAddress	getAddress()
TransactionManager	getTransactionManager()
TransactionPruningService	getTransactionPruningService() This allows systems that embed the transaction service access to the pruning service, so that they can trigger prunning (rather than waiting for its scheduled run time).
protected void	internalStop()

Methods inherited from class org.apache.tephra.inmemory.InMemoryTransactionService

doRegister, 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

Constructor Detail

TransactionService

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

Method Detail

getAddress

protected InetSocketAddress getAddress()

Overrides:

getAddress in class InMemoryTransactionService

doStart

protected void doStart()

Overrides:

doStart in class InMemoryTransactionService

createPruningService

protected TransactionPruningService createPruningService(org.apache.hadoop.conf.Configuration conf,
                                                         TransactionManager txManager)

Called at startup to create the pruning service.

doStop

protected void doStop()

Overrides:

doStop in class InMemoryTransactionService

abort

protected void abort(Throwable cause)

internalStop

protected void internalStop()

getTransactionManager

@Nullable
public TransactionManager getTransactionManager()

getTransactionPruningService

@Nullable
public TransactionPruningService getTransactionPruningService()

This allows systems that embed the transaction service access to the pruning service, so that they can trigger prunning (rather than waiting for its scheduled run time).

Returns:

null if pruning is not enabled