Class AbstractPartitionAnalyzer

  • All Implemented Interfaces:
    PartitionAnalyzer


    public abstract class AbstractPartitionAnalyzer
    extends java.lang.Object
    implements PartitionAnalyzer
    The AbstractPartitionAnalyzer provides default implementations of less commonly implemented methods.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void analyzeCollectorData​(java.io.Serializable data)
      Override this method to analyze PartitionCollector payloads.
      void analyzeStatus​(BatchStatus batchStatus, java.lang.String exitStatus)
      Override this method to analyze partition end status.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • AbstractPartitionAnalyzer

        public AbstractPartitionAnalyzer​()
    • Method Detail

      • analyzeCollectorData

        public void analyzeCollectorData​(java.io.Serializable data)
                                  throws java.lang.Exception
        Override this method to analyze PartitionCollector payloads.
        Specified by:
        analyzeCollectorData in interface PartitionAnalyzer
        Parameters:
        data - specifies the payload sent by the PartitionCollector.
        Throws:
        java.lang.Exception - is thrown if an error occurs.
      • analyzeStatus

        public void analyzeStatus​(BatchStatus batchStatus,
                                  java.lang.String exitStatus)
                           throws java.lang.Exception
        Override this method to analyze partition end status.
        Specified by:
        analyzeStatus in interface PartitionAnalyzer
        Parameters:
        batchStatus - specifies the batch status of a partition.
        exitStatus - specifies the exit status of a partition.
        Throws:
        java.lang.Exception - is thrown if an error occurs.