public class InMemoryTransactionService
extends com.google.common.util.concurrent.AbstractService
Transaction server is HA, one can start multiple instances, only one of which is active and will register itself in discovery service.
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 and Description |
---|
InMemoryTransactionService(org.apache.hadoop.conf.Configuration conf,
org.apache.twill.discovery.DiscoveryService discoveryService,
com.google.inject.Provider<TransactionManager> txManagerProvider) |
Modifier and Type | Method and Description |
---|---|
protected void |
doRegister() |
protected void |
doStart() |
protected void |
doStop() |
protected InetSocketAddress |
getAddress() |
protected void |
undoRegister() |
protected final com.google.inject.Provider<TransactionManager> txManagerProvider
protected TransactionManager txManager
protected final String address
protected final int port
protected final int threads
protected final int ioThreads
protected final int maxReadBufferBytes
@Inject public InMemoryTransactionService(org.apache.hadoop.conf.Configuration conf, org.apache.twill.discovery.DiscoveryService discoveryService, com.google.inject.Provider<TransactionManager> txManagerProvider)
protected void undoRegister()
protected void doRegister()
protected InetSocketAddress getAddress()
protected void doStart()
doStart
in class com.google.common.util.concurrent.AbstractService
protected void doStop()
doStop
in class com.google.common.util.concurrent.AbstractService
Copyright © 2016 The Apache Software Foundation. All rights reserved.