Package | Description |
---|---|
org.apache.tephra |
This package contains implementations of the transaction system v2.
|
org.apache.tephra.metrics | |
org.apache.tephra.persist |
This package contains interfaces and implementations for persisting transaction state.
|
Constructor and Description |
---|
TransactionManager(org.apache.hadoop.conf.Configuration conf,
TransactionStateStorage persistor,
MetricsCollector txMetricsCollector) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultMetricsCollector
Default metrics collector implementation using Yammer Metrics.
|
class |
TxMetricsCollector
Metrics Collector Class, to emit Transaction Related Metrics.
|
Constructor and Description |
---|
AbstractTransactionLog(long timestamp,
MetricsCollector metricsCollector) |
HDFSTransactionLog(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.conf.Configuration hConf,
org.apache.hadoop.fs.Path logPath,
long timestamp,
MetricsCollector metricsCollector)
Creates a new HDFS-backed write-ahead log for storing transaction state.
|
HDFSTransactionStateStorage(org.apache.hadoop.conf.Configuration hConf,
SnapshotCodecProvider codecProvider,
MetricsCollector metricsCollector) |
LocalFileTransactionLog(File logFile,
long timestamp,
MetricsCollector metricsCollector)
Creates a new transaction log using the given file instance.
|
LocalFileTransactionStateStorage(org.apache.hadoop.conf.Configuration conf,
SnapshotCodecProvider codecProvider,
MetricsCollector metricsCollector) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.