public class ReplTxnWork extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
static class |
ReplTxnWork.OperationType
OperationType.
|
Constructor and Description |
---|
ReplTxnWork(String dbName,
String tableName,
List<String> partNames,
String validWriteIdList,
ReplTxnWork.OperationType type) |
ReplTxnWork(String dbName,
String tableName,
List<String> partNames,
String validWriteIdList,
ReplTxnWork.OperationType type,
String dumpDirectory,
ReplicationMetricCollector metricCollector) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
List<Long> txnIds,
ReplTxnWork.OperationType type,
List<TxnToWriteId> txnToWriteIdList,
ReplicationSpec replicationSpec) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
List<Long> txnIds,
ReplTxnWork.OperationType type,
ReplicationSpec replicationSpec) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
List<Long> txnIds,
ReplTxnWork.OperationType type,
ReplicationSpec replicationSpec,
String dumpDirectory,
ReplicationMetricCollector metricCollector) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
Long txnId,
ReplTxnWork.OperationType type,
ReplicationSpec replicationSpec) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
Long txnId,
ReplTxnWork.OperationType type,
ReplicationSpec replicationSpec,
String dumpDirectory,
ReplicationMetricCollector metricCollector) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
ReplTxnWork.OperationType type,
List<TxnToWriteId> txnToWriteIdList,
ReplicationSpec replicationSpec) |
ReplTxnWork(String replPolicy,
String dbName,
String tableName,
ReplTxnWork.OperationType type,
List<TxnToWriteId> txnToWriteIdList,
ReplicationSpec replicationSpec,
String dumpDirectory,
ReplicationMetricCollector metricCollector) |
Modifier and Type | Method and Description |
---|---|
void |
addWriteEventInfo(WriteEventInfo writeEventInfo) |
String |
getDbName() |
String |
getDumpDirectory() |
ReplicationMetricCollector |
getMetricCollector() |
ReplTxnWork.OperationType |
getOperationType() |
List<String> |
getPartNames() |
ReplicationSpec |
getReplicationSpec() |
ReplLastIdInfo |
getReplLastIdInfo() |
String |
getReplPolicy() |
String |
getTableName() |
List<Long> |
getTxnIds() |
List<TxnToWriteId> |
getTxnToWriteIdList() |
String |
getValidWriteIdList() |
List<WriteEventInfo> |
getWriteEventInfos() |
public ReplTxnWork(String replPolicy, String dbName, String tableName, List<Long> txnIds, ReplTxnWork.OperationType type, List<TxnToWriteId> txnToWriteIdList, ReplicationSpec replicationSpec)
public ReplTxnWork(String replPolicy, String dbName, String tableName, List<Long> txnIds, ReplTxnWork.OperationType type, ReplicationSpec replicationSpec)
public ReplTxnWork(String replPolicy, String dbName, String tableName, List<Long> txnIds, ReplTxnWork.OperationType type, ReplicationSpec replicationSpec, String dumpDirectory, ReplicationMetricCollector metricCollector)
public ReplTxnWork(String replPolicy, String dbName, String tableName, Long txnId, ReplTxnWork.OperationType type, ReplicationSpec replicationSpec)
public ReplTxnWork(String replPolicy, String dbName, String tableName, Long txnId, ReplTxnWork.OperationType type, ReplicationSpec replicationSpec, String dumpDirectory, ReplicationMetricCollector metricCollector)
public ReplTxnWork(String replPolicy, String dbName, String tableName, ReplTxnWork.OperationType type, List<TxnToWriteId> txnToWriteIdList, ReplicationSpec replicationSpec)
public ReplTxnWork(String replPolicy, String dbName, String tableName, ReplTxnWork.OperationType type, List<TxnToWriteId> txnToWriteIdList, ReplicationSpec replicationSpec, String dumpDirectory, ReplicationMetricCollector metricCollector)
public ReplTxnWork(String dbName, String tableName, List<String> partNames, String validWriteIdList, ReplTxnWork.OperationType type)
public ReplTxnWork(String dbName, String tableName, List<String> partNames, String validWriteIdList, ReplTxnWork.OperationType type, String dumpDirectory, ReplicationMetricCollector metricCollector)
public void addWriteEventInfo(WriteEventInfo writeEventInfo)
public String getDbName()
public String getTableName()
public String getReplPolicy()
public String getValidWriteIdList()
public ReplTxnWork.OperationType getOperationType()
public List<TxnToWriteId> getTxnToWriteIdList()
public ReplicationSpec getReplicationSpec()
public List<WriteEventInfo> getWriteEventInfos()
public ReplLastIdInfo getReplLastIdInfo()
public ReplicationMetricCollector getMetricCollector()
public String getDumpDirectory()
Copyright © 2022 The Apache Software Foundation. All rights reserved.