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 final class TransactionService
extends InMemoryTransactionService

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

Methods

Modifier and Type	Method and Description
protected void	abort(Throwable cause)
protected void	doStart()
protected void	doStop()
protected InetSocketAddress	getAddress()
TransactionManager	getTransactionManager()
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

doStop

protected void doStop()

Overrides:

doStop in class InMemoryTransactionService

abort

protected void abort(Throwable cause)

internalStop

protected void internalStop()

getTransactionManager

@Nullable
public TransactionManager getTransactionManager()