public final class TransactionService extends InMemoryTransactionService
address, ioThreads, maxReadBufferBytes, port, threads, txManager, txManagerProvider
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) |
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() |
doRegister, undoRegister
@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)
protected InetSocketAddress getAddress()
getAddress
in class InMemoryTransactionService
protected void doStart()
doStart
in class InMemoryTransactionService
protected void doStop()
doStop
in class InMemoryTransactionService
protected void abort(Throwable cause)
protected void internalStop()
@Nullable public TransactionManager getTransactionManager()
Copyright © 2017 The Apache Software Foundation. All rights reserved.