Package org.apache.hadoop.hdfs.rbfbalance

Class RouterDistCpProcedure

java.lang.Object
org.apache.hadoop.tools.fedbalance.procedure.BalanceProcedure
org.apache.hadoop.tools.fedbalance.DistCpProcedure
org.apache.hadoop.hdfs.rbfbalance.RouterDistCpProcedure
All Implemented Interfaces:
org.apache.hadoop.io.Writable
public class RouterDistCpProcedure extends org.apache.hadoop.tools.fedbalance.DistCpProcedure
Copy data through distcp in router-based federation cluster. It disables write by setting mount entry readonly.

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.hadoop.tools.fedbalance.DistCpProcedure

    org.apache.hadoop.tools.fedbalance.DistCpProcedure.Stage

    Nested classes/interfaces inherited from class org.apache.hadoop.tools.fedbalance.procedure.BalanceProcedure

    org.apache.hadoop.tools.fedbalance.procedure.BalanceProcedure.RetryException

  • Field Summary

    Fields inherited from class org.apache.hadoop.tools.fedbalance.DistCpProcedure

    LOG

  • Constructor Summary

    Constructors
    Constructor
    Description
    RouterDistCpProcedure()
     
    RouterDistCpProcedure(String name, String nextProcedure, long delayDuration, org.apache.hadoop.tools.fedbalance.FedBalanceContext context)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    disableWrite(org.apache.hadoop.tools.fedbalance.FedBalanceContext context)
    Disable write by making the mount entry readonly.
    protected void
    enableWrite()
    Enable write.

    Methods inherited from class org.apache.hadoop.tools.fedbalance.DistCpProcedure

    disableForTest, enableForTest, execute, readFields, updateStage, write

    Methods inherited from class org.apache.hadoop.tools.fedbalance.procedure.BalanceProcedure

    delayMillisBeforeRetry, equals, hashCode, isSchedulerShutdown, name, nextProcedure, setNextProcedure, toString

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • RouterDistCpProcedure

      public RouterDistCpProcedure()

    • RouterDistCpProcedure

      public RouterDistCpProcedure(String name, String nextProcedure, long delayDuration, org.apache.hadoop.tools.fedbalance.FedBalanceContext context) throws IOException
      Throws:
      IOException

  • Method Details

    • disableWrite

      protected void disableWrite(org.apache.hadoop.tools.fedbalance.FedBalanceContext context) throws IOException
      Disable write by making the mount entry readonly.
      Overrides:
      disableWrite in class org.apache.hadoop.tools.fedbalance.DistCpProcedure
      Throws:
      IOException

    • enableWrite

      protected void enableWrite() throws IOException
      Enable write.
      Overrides:
      enableWrite in class org.apache.hadoop.tools.fedbalance.DistCpProcedure
      Throws:
      IOException