@Generated(value="io.swagger.codegen.v3.generators.java.JavaClientCodegen", date="2024-12-03T04:57:51.616Z[Etc/UTC]") public class ApiHdfsReplicationArguments extends Object
Constructor and Description |
---|
ApiHdfsReplicationArguments() |
Modifier and Type | Method and Description |
---|---|
ApiHdfsReplicationArguments |
abortOnError(Boolean abortOnError) |
ApiHdfsReplicationArguments |
addExclusionFiltersItem(String exclusionFiltersItem) |
ApiHdfsReplicationArguments |
bandwidthPerMap(BigDecimal bandwidthPerMap) |
ApiHdfsReplicationArguments |
deleteLatestSourceSnapshotOnJobFailure(Boolean deleteLatestSourceSnapshotOnJobFailure) |
ApiHdfsReplicationArguments |
destinationCloudAccount(String destinationCloudAccount) |
ApiHdfsReplicationArguments |
destinationPath(String destinationPath) |
ApiHdfsReplicationArguments |
dryRun(Boolean dryRun) |
boolean |
equals(Object o) |
ApiHdfsReplicationArguments |
exclusionFilters(List<String> exclusionFilters) |
BigDecimal |
getBandwidthPerMap()
The maximum bandwidth (in MB) per mapper in the mapreduce replication job.
|
String |
getDestinationCloudAccount()
The cloud account name which is used in direct hive cloud replication, if specified.
|
String |
getDestinationPath()
The destination to replicate to.
|
List<String> |
getExclusionFilters()
Specify regular expression strings to match full paths of files and directories matching source paths and exclude them from the replication.
|
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.
|
BigDecimal |
getNumFetchThreads()
The number of threads to use for fetching the file statuses from HDFS during source file listing.
|
BigDecimal |
getNumMaps()
The number of mappers to use for the mapreduce replication job.
|
ReplicationStrategy |
getReplicationStrategy()
Get replicationStrategy
|
String |
getSchedulerPoolName()
Name of the scheduler pool to use when submitting the MapReduce job.
|
String |
getSourcePath()
The path to replicate.
|
ApiServiceRef |
getSourceService()
Get sourceService
|
String |
getSourceUser()
The user which will perform operations on source cluster.
|
String |
getUserName()
The user which will execute the MapReduce job.
|
int |
hashCode() |
Boolean |
isAbortOnError()
Whether to abort on a replication failure.
|
Boolean |
isDeleteLatestSourceSnapshotOnJobFailure()
A flag configuring distcp behaviour for the case when the distcp mapreduce job fails.
|
Boolean |
isDryRun()
Whether to perform a dry run.
|
Boolean |
isPreserveBlockSize()
Whether to preserve the HDFS block size.
|
Boolean |
isPreservePermissions()
Whether to preserve the HDFS owner, group and permissions.
|
Boolean |
isPreserveReplicationCount()
Whether to preserve the HDFS replication count.
|
Boolean |
isPreserveXAttrs()
Whether to preserve XAttrs, default to false This is introduced in V10.
|
Boolean |
isRaiseSnapshotDiffFailures()
Flag indicating if failures during snapshotDiff should be ignored or not.
|
Boolean |
isRemoveMissingFiles()
Whether to delete destination files that are missing in source.
|
Boolean |
isSkipChecksumChecks()
Whether to skip checksum based file validation during replication.
|
Boolean |
isSkipListingChecksumChecks()
Whether to skip checksum based file comparison during replication.
|
Boolean |
isSkipTrash()
Whether to permanently delete destination files that are missing in source.
|
ApiHdfsReplicationArguments |
logPath(String logPath) |
ApiHdfsReplicationArguments |
mapreduceServiceName(String mapreduceServiceName) |
ApiHdfsReplicationArguments |
numFetchThreads(BigDecimal numFetchThreads) |
ApiHdfsReplicationArguments |
numMaps(BigDecimal numMaps) |
ApiHdfsReplicationArguments |
preserveBlockSize(Boolean preserveBlockSize) |
ApiHdfsReplicationArguments |
preservePermissions(Boolean preservePermissions) |
ApiHdfsReplicationArguments |
preserveReplicationCount(Boolean preserveReplicationCount) |
ApiHdfsReplicationArguments |
preserveXAttrs(Boolean preserveXAttrs) |
ApiHdfsReplicationArguments |
raiseSnapshotDiffFailures(Boolean raiseSnapshotDiffFailures) |
ApiHdfsReplicationArguments |
removeMissingFiles(Boolean removeMissingFiles) |
ApiHdfsReplicationArguments |
replicationStrategy(ReplicationStrategy replicationStrategy) |
ApiHdfsReplicationArguments |
schedulerPoolName(String schedulerPoolName) |
void |
setAbortOnError(Boolean abortOnError) |
void |
setBandwidthPerMap(BigDecimal bandwidthPerMap) |
void |
setDeleteLatestSourceSnapshotOnJobFailure(Boolean deleteLatestSourceSnapshotOnJobFailure) |
void |
setDestinationCloudAccount(String destinationCloudAccount) |
void |
setDestinationPath(String destinationPath) |
void |
setDryRun(Boolean dryRun) |
void |
setExclusionFilters(List<String> exclusionFilters) |
void |
setLogPath(String logPath) |
void |
setMapreduceServiceName(String mapreduceServiceName) |
void |
setNumFetchThreads(BigDecimal numFetchThreads) |
void |
setNumMaps(BigDecimal numMaps) |
void |
setPreserveBlockSize(Boolean preserveBlockSize) |
void |
setPreservePermissions(Boolean preservePermissions) |
void |
setPreserveReplicationCount(Boolean preserveReplicationCount) |
void |
setPreserveXAttrs(Boolean preserveXAttrs) |
void |
setRaiseSnapshotDiffFailures(Boolean raiseSnapshotDiffFailures) |
void |
setRemoveMissingFiles(Boolean removeMissingFiles) |
void |
setReplicationStrategy(ReplicationStrategy replicationStrategy) |
void |
setSchedulerPoolName(String schedulerPoolName) |
void |
setSkipChecksumChecks(Boolean skipChecksumChecks) |
void |
setSkipListingChecksumChecks(Boolean skipListingChecksumChecks) |
void |
setSkipTrash(Boolean skipTrash) |
void |
setSourcePath(String sourcePath) |
void |
setSourceService(ApiServiceRef sourceService) |
void |
setSourceUser(String sourceUser) |
void |
setUserName(String userName) |
ApiHdfsReplicationArguments |
skipChecksumChecks(Boolean skipChecksumChecks) |
ApiHdfsReplicationArguments |
skipListingChecksumChecks(Boolean skipListingChecksumChecks) |
ApiHdfsReplicationArguments |
skipTrash(Boolean skipTrash) |
ApiHdfsReplicationArguments |
sourcePath(String sourcePath) |
ApiHdfsReplicationArguments |
sourceService(ApiServiceRef sourceService) |
ApiHdfsReplicationArguments |
sourceUser(String sourceUser) |
String |
toString() |
ApiHdfsReplicationArguments |
userName(String userName) |
public ApiHdfsReplicationArguments sourceService(ApiServiceRef sourceService)
public ApiServiceRef getSourceService()
public void setSourceService(ApiServiceRef sourceService)
public ApiHdfsReplicationArguments sourcePath(String sourcePath)
public String getSourcePath()
public void setSourcePath(String sourcePath)
public ApiHdfsReplicationArguments destinationPath(String destinationPath)
public String getDestinationPath()
public void setDestinationPath(String destinationPath)
public ApiHdfsReplicationArguments mapreduceServiceName(String mapreduceServiceName)
public String getMapreduceServiceName()
public void setMapreduceServiceName(String mapreduceServiceName)
public ApiHdfsReplicationArguments schedulerPoolName(String schedulerPoolName)
public String getSchedulerPoolName()
public void setSchedulerPoolName(String schedulerPoolName)
public ApiHdfsReplicationArguments userName(String userName)
public String getUserName()
public void setUserName(String userName)
public ApiHdfsReplicationArguments sourceUser(String sourceUser)
public String getSourceUser()
public void setSourceUser(String sourceUser)
public ApiHdfsReplicationArguments numMaps(BigDecimal numMaps)
public BigDecimal getNumMaps()
public void setNumMaps(BigDecimal numMaps)
public ApiHdfsReplicationArguments dryRun(Boolean dryRun)
public Boolean isDryRun()
public void setDryRun(Boolean dryRun)
public ApiHdfsReplicationArguments bandwidthPerMap(BigDecimal bandwidthPerMap)
public BigDecimal getBandwidthPerMap()
public void setBandwidthPerMap(BigDecimal bandwidthPerMap)
public ApiHdfsReplicationArguments abortOnError(Boolean abortOnError)
public Boolean isAbortOnError()
public void setAbortOnError(Boolean abortOnError)
public ApiHdfsReplicationArguments removeMissingFiles(Boolean removeMissingFiles)
public Boolean isRemoveMissingFiles()
public void setRemoveMissingFiles(Boolean removeMissingFiles)
public ApiHdfsReplicationArguments preserveReplicationCount(Boolean preserveReplicationCount)
public Boolean isPreserveReplicationCount()
public void setPreserveReplicationCount(Boolean preserveReplicationCount)
public ApiHdfsReplicationArguments preserveBlockSize(Boolean preserveBlockSize)
public Boolean isPreserveBlockSize()
public void setPreserveBlockSize(Boolean preserveBlockSize)
public ApiHdfsReplicationArguments preservePermissions(Boolean preservePermissions)
public Boolean isPreservePermissions()
public void setPreservePermissions(Boolean preservePermissions)
public ApiHdfsReplicationArguments logPath(String logPath)
public String getLogPath()
public void setLogPath(String logPath)
public ApiHdfsReplicationArguments skipChecksumChecks(Boolean skipChecksumChecks)
public Boolean isSkipChecksumChecks()
public void setSkipChecksumChecks(Boolean skipChecksumChecks)
public ApiHdfsReplicationArguments skipListingChecksumChecks(Boolean skipListingChecksumChecks)
public Boolean isSkipListingChecksumChecks()
public void setSkipListingChecksumChecks(Boolean skipListingChecksumChecks)
public ApiHdfsReplicationArguments skipTrash(Boolean skipTrash)
public Boolean isSkipTrash()
public void setSkipTrash(Boolean skipTrash)
public ApiHdfsReplicationArguments replicationStrategy(ReplicationStrategy replicationStrategy)
public ReplicationStrategy getReplicationStrategy()
public void setReplicationStrategy(ReplicationStrategy replicationStrategy)
public ApiHdfsReplicationArguments preserveXAttrs(Boolean preserveXAttrs)
public Boolean isPreserveXAttrs()
public void setPreserveXAttrs(Boolean preserveXAttrs)
public ApiHdfsReplicationArguments exclusionFilters(List<String> exclusionFilters)
public ApiHdfsReplicationArguments addExclusionFiltersItem(String exclusionFiltersItem)
public List<String> getExclusionFilters()
public ApiHdfsReplicationArguments raiseSnapshotDiffFailures(Boolean raiseSnapshotDiffFailures)
public Boolean isRaiseSnapshotDiffFailures()
public void setRaiseSnapshotDiffFailures(Boolean raiseSnapshotDiffFailures)
public ApiHdfsReplicationArguments deleteLatestSourceSnapshotOnJobFailure(Boolean deleteLatestSourceSnapshotOnJobFailure)
public Boolean isDeleteLatestSourceSnapshotOnJobFailure()
public void setDeleteLatestSourceSnapshotOnJobFailure(Boolean deleteLatestSourceSnapshotOnJobFailure)
public ApiHdfsReplicationArguments numFetchThreads(BigDecimal numFetchThreads)
public BigDecimal getNumFetchThreads()
public void setNumFetchThreads(BigDecimal numFetchThreads)
public ApiHdfsReplicationArguments destinationCloudAccount(String destinationCloudAccount)
public String getDestinationCloudAccount()
public void setDestinationCloudAccount(String destinationCloudAccount)
Copyright © 2024. All rights reserved.