public class ReplLoadWork extends Object implements Serializable, ReplLoadWorkMBean
Modifier and Type | Field and Description |
---|---|
static boolean |
disableMbeanUnregistrationForTests |
boolean |
isFirstFailover |
boolean |
isSecondFailover |
List<String> |
tablesToBootstrap |
List<String> |
tablesToDrop |
Constructor and Description |
---|
ReplLoadWork(HiveConf hiveConf,
String dumpDirectory,
String sourceDbName,
String dbNameToLoadIn,
ReplScope currentReplScope,
LineageState lineageState,
boolean isIncrementalDump,
Long eventTo,
Long dumpExecutionId,
ReplicationMetricCollector metricCollector,
boolean replScopeModified) |
Modifier and Type | Method and Description |
---|---|
List<Task<?>> |
externalTableCopyTasks(TaskTracker tracker,
HiveConf conf) |
String |
getCurrentEventId()
Gets the event id that just got processed.
|
String |
getDumpDirectory()
Gets the dump directory.
|
Long |
getDumpExecutionId() |
Long |
getExecutionId()
Gets the execution id of the policy.
|
Iterator<String> |
getExternalTableDataCopyItr() |
Long |
getLastEventId()
Gets the last event id for the load.
|
ReplicationMetricCollector |
getMetricCollector() |
String |
getReplicationType()
Gets the Replication Type.
|
String |
getReplStats()
Gets the string representation of replication statistics
|
Task<?> |
getRootTask() |
String |
getScheduledQueryName()
Gets the name of scheduled query being run.
|
String |
getSourceDatabase()
Gets the name of the database which is being loaded.
|
String |
getSourceDbName() |
String |
getTargetDatabase()
Gets the name of the database on which load is happening.
|
boolean |
isLastReplIDUpdated() |
void |
setExternalTableDataCopyItr(Iterator<String> externalTableDataCopyItr) |
void |
setLastReplIDUpdated(boolean lastReplIDUpdated) |
static void |
setMbeansParamsForTesting(boolean enableRegistration,
boolean disableUnregistration)
Enable JMX tracking for testing.
|
void |
setRootTask(Task<?> rootTask) |
public static boolean disableMbeanUnregistrationForTests
public boolean isFirstFailover
public boolean isSecondFailover
public ReplLoadWork(HiveConf hiveConf, String dumpDirectory, String sourceDbName, String dbNameToLoadIn, ReplScope currentReplScope, LineageState lineageState, boolean isIncrementalDump, Long eventTo, Long dumpExecutionId, ReplicationMetricCollector metricCollector, boolean replScopeModified) throws IOException, SemanticException
IOException
SemanticException
public Task<?> getRootTask()
public String getDumpDirectory()
ReplLoadWorkMBean
getDumpDirectory
in interface ReplLoadWorkMBean
public void setRootTask(Task<?> rootTask)
public boolean isLastReplIDUpdated()
public void setLastReplIDUpdated(boolean lastReplIDUpdated)
public String getSourceDbName()
public ReplicationMetricCollector getMetricCollector()
public Long getDumpExecutionId()
public List<Task<?>> externalTableCopyTasks(TaskTracker tracker, HiveConf conf) throws IOException
IOException
public void setExternalTableDataCopyItr(Iterator<String> externalTableDataCopyItr)
public String getSourceDatabase()
ReplLoadWorkMBean
getSourceDatabase
in interface ReplLoadWorkMBean
public String getTargetDatabase()
ReplLoadWorkMBean
getTargetDatabase
in interface ReplLoadWorkMBean
public String getReplicationType()
ReplLoadWorkMBean
getReplicationType
in interface ReplLoadWorkMBean
public String getScheduledQueryName()
ReplLoadWorkMBean
getScheduledQueryName
in interface ReplLoadWorkMBean
public Long getExecutionId()
ReplLoadWorkMBean
getExecutionId
in interface ReplLoadWorkMBean
public String getReplStats()
ReplLoadWorkMBean
getReplStats
in interface ReplLoadWorkMBean
public String getCurrentEventId()
ReplLoadWorkMBean
getCurrentEventId
in interface ReplLoadWorkMBean
public Long getLastEventId()
ReplLoadWorkMBean
getLastEventId
in interface ReplLoadWorkMBean
public static void setMbeansParamsForTesting(boolean enableRegistration, boolean disableUnregistration)
enableRegistration
- enable registering MBeans.disableUnregistration
- disable unregistering MBeans, so that value can be used by tests to validate.Copyright © 2023 The Apache Software Foundation. All rights reserved.