public class ApiHdfsReplicationArguments extends Object
Constructor and Description |
---|
ApiHdfsReplicationArguments() |
ApiHdfsReplicationArguments(ApiServiceRef sourceService,
String sourcePath,
String destinationPath,
String mapreduceServiceName,
Integer numMaps,
String userName) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
boolean |
getAbortOnError()
Whether to abort on a replication failure.
|
Integer |
getBandwidthPerMap()
The maximum bandwidth (in MB) per mapper in the mapreduce replication
job.
|
String |
getDestinationPath()
The destination to replicate to.
|
String |
getLogPath()
The HDFS path where the replication log files should be written to.
|
String |
getMapreduceServiceName()
The mapreduce service to use for the replication job.
|
Integer |
getNumMaps()
The number of mappers to use for the mapreduce replication job.
|
boolean |
getPreserveBlockSize()
Whether to preserve the HDFS block size.
|
boolean |
getPreservePermissions()
Whether to preserve the HDFS owner, group and permissions.
|
boolean |
getPreserveReplicationCount()
Whether to preserve the HDFS replication count.
|
boolean |
getRemoveMissingFiles()
Whether to delete destination files that are missing in source.
|
String |
getSchedulerPoolName()
Name of the scheduler pool to use when submitting the MapReduce job.
|
boolean |
getSkipChecksumChecks()
Whether to skip checksum based file validation/comparison during
replication.
|
String |
getSourcePath()
The path to replicate.
|
ApiServiceRef |
getSourceService()
The service to replicate from.
|
String |
getUserName()
The user which will execute the MapReduce job.
|
int |
hashCode() |
boolean |
isDryRun()
Whether to perform a dry run.
|
void |
setAbortOnError(boolean abortOnError) |
void |
setBandwidthPerMap(Integer bandwidthPerMap) |
void |
setDestinationPath(String path) |
void |
setDryRun(boolean dryRun) |
void |
setLogPath(String logPath) |
void |
setMapreduceServiceName(String name) |
void |
setNumMaps(Integer numMaps) |
void |
setPreserveBlockSize(boolean preserveBlockSize) |
void |
setPreservePermissions(boolean preservePermissions) |
void |
setPreserveReplicationCount(boolean preserveReplicationCount) |
void |
setRemoveMissingFiles(boolean removeMissingFiles) |
void |
setSchedulerPoolName(String schedulerPoolName) |
void |
setSkipChecksumChecks(boolean skipChecksumChecks) |
void |
setSourcePath(String path) |
void |
setSourceService(ApiServiceRef sourceService) |
void |
setUserName(String userName) |
String |
toString() |
public ApiServiceRef getSourceService()
public void setSourceService(ApiServiceRef sourceService)
public String getSourcePath()
public void setSourcePath(String path)
public String getDestinationPath()
public void setDestinationPath(String path)
public String getMapreduceServiceName()
public void setMapreduceServiceName(String name)
public String getSchedulerPoolName()
public void setSchedulerPoolName(String schedulerPoolName)
public String getUserName()
public void setUserName(String userName)
public Integer getNumMaps()
public void setNumMaps(Integer numMaps)
public boolean isDryRun()
public void setDryRun(boolean dryRun)
public Integer getBandwidthPerMap()
public void setBandwidthPerMap(Integer bandwidthPerMap)
public boolean getAbortOnError()
public void setAbortOnError(boolean abortOnError)
public boolean getRemoveMissingFiles()
public void setRemoveMissingFiles(boolean removeMissingFiles)
public boolean getPreserveReplicationCount()
public void setPreserveReplicationCount(boolean preserveReplicationCount)
public boolean getPreserveBlockSize()
public void setPreserveBlockSize(boolean preserveBlockSize)
public boolean getPreservePermissions()
public void setPreservePermissions(boolean preservePermissions)
public String getLogPath()
public void setLogPath(String logPath)
public boolean getSkipChecksumChecks()
public void setSkipChecksumChecks(boolean skipChecksumChecks)
Copyright © Cloudera, Inc. Released under Apache License, Version 2.0.