Class ExpFaultToleranceHandler

java.lang.Object
wt.ixb.publicforapps.ExpFaultToleranceHandler

public class ExpFaultToleranceHandler extends Object
Fault tolerance handling while Export.

Supported API: true
  • Method Details

    • reportFaulty

      public void reportFaulty(WTCollection associatedObjects, WTException exc, String stageName, String errorMessage) throws WTException
      Reports the collection of objects as Faulty objects to the Framework depending on the executor implementation

      Supported API: true
      Parameters:
      associatedObjects - The Collection to be marked as Faulty
      exc - The Exception encountered while processing the associatedObjects
      stageName - The Name of the stage during which the Exception occurred
      errorMessage - The Error Message to show the user
      Throws:
      WTException
    • reportFaulty

      public void reportFaulty(Persistable persistable, WTException exc, String stageName, String errorMessage) throws WTException
      Reports the Persistable object as Faulty objects to the Framework depending on the executor implementation

      Supported API: true
      Parameters:
      persistable - The Object that will be marked faulty in case exception occurs
      exc - The Exception encountered while processing the associatedObjects
      stageName - The Name of the stage during which the Exception occurred
      errorMessage - The Error Message to show the user
      Throws:
      WTException
    • reportFaulty

      public void reportFaulty(ObjectReference objRefn, WTException exc, String stageName, String errorMessage) throws WTException
      Reports the ObjectIdentifier object as Faulty objects to the Framework depending on the executor implementation

      Supported API: true
      Parameters:
      objRefn - The Object that will be marked faulty in case exception occurs
      exc - The Exception encountered while processing the associatedObjects
      stageName - The Name of the stage during which the Exception occurred
      errorMessage - The Error Message to show the user
      Throws:
      WTException
    • reportError

      public void reportError(WTException exc, String stageName, String errorMessage) throws WTException
      Reports an error to the Framework depending on the executor implementation

      Supported API: true
      Parameters:
      exc - The Exception encountered while processing the associatedObjects
      stageName - The Name of the stage during which the Exception occurred
      errorMessage - The Error Message to show the user
      Throws:
      WTException
    • processDependencies

      public void processDependencies(Map<ObjectIdentifier,? extends QueryKey> dependentToPrimaryMap)
      Process the dependencies for fault tolerance. Dependents would be marked based on faulty primary objects
      Dependency graph of All dependent to primary is expected to be passed (no knowledge of faulty primary required)
      Supported API: true
      Parameters:
      dependentObjectId - dependency graph of dependent to primary
      faultyObjectRefn -
    • processDependency

      public void processDependency(ObjectIdentifier dependentRefn, QueryKey primaryRefn)
      Process the dependencies for fault tolerance. Dependents would be marked if primary object is faulty
      Single object flavor of preferable processDependencies(Map) and recommended to be referred for details Supported API: true
      Parameters:
      dependentRefn -
      primaryRefn -