Package com.metasolv.nm.processor.MXAggregator

Class MXNarProvider

java.lang.Object
com.metasolv.nm.processor.MXAggregator.MXNarProvider
All Implemented Interfaces:
DataProviderIfc
public class MXNarProvider extends Object implements DataProviderIfc
New interface between field processor threads and the NarInputProcessor.

  • Constructor Details

  • Method Details

    • isDataAvailable

      public boolean isDataAvailable()
      Description copied from interface: DataProviderIfc
      Allows a DataReceiver to determine whether some data is available for processing
      Specified by:
      isDataAvailable in interface DataProviderIfc
      Returns:
      true, if data is available

    • getData

      public DCFieldContainer getData()
      Description copied from interface: DataProviderIfc
      Allows a DataReceiver to obtain the available data in a known format.
      Specified by:
      getData in interface DataProviderIfc
      Returns:
      DCFieldContainer object containing the data that is available for processing

    • getBulkData

      public DCFieldContainer[] getBulkData()
      Only return an array of one NAR.
      Specified by:
      getBulkData in interface DataProviderIfc
      Returns:
      DCFieldContainer object array, containing the data that is for processing

    • setDataReceiver

      @Deprecated public void setDataReceiver(DataReceiverIfc receiver)
      Deprecated.
      Not used.
      Specified by:
      setDataReceiver in interface DataProviderIfc
      Parameters:
      receiver - Object which will obtain data from this DataProvider

    • getDataReceiver

      @Deprecated public DataReceiverIfc getDataReceiver()
      Deprecated.
      Not used.
      Specified by:
      getDataReceiver in interface DataProviderIfc
      Returns:
      Object to which this DataProvider is sending data

    • endRecordProcessing

      public void endRecordProcessing(DCFieldContainer dcfc)

    • getData

      public DCFieldContainer getData(String batch)
      Description copied from interface: DataProviderIfc
      Allows a DataReceiver to obtain the available data in a known format. batch - The nars read will be grouped under the specified batch
      Specified by:
      getData in interface DataProviderIfc
      Returns:
      DCFieldContainer object containing the data that is available for processing

    • signalBatchCompletion

      public void signalBatchCompletion(String batch)
      Description copied from interface: DataProviderIfc
      Allows a DataReceiver to know that the nars under the specified batch are completed and handed over to the Data receiver
      Specified by:
      signalBatchCompletion in interface DataProviderIfc

    • removeProcessedFile

      public void removeProcessedFile(File currArchFile)
      Description copied from interface: DataProviderIfc
      Allows a DataReceiver to remove .arch file once processed currArchFile - processed .arch file
      Specified by:
      removeProcessedFile in interface DataProviderIfc

    • getProcessedArchFile

      public String getProcessedArchFile()
      Description copied from interface: DataProviderIfc
      Allows a DataReceiver to obtain the last processed .arch file
      Specified by:
      getProcessedArchFile in interface DataProviderIfc
      Returns:
      currently processing .arch file absolute path

    • setProcessedArchFile

      public void setProcessedArchFile(String file)
      Description copied from interface: DataProviderIfc
      Sets the processed .arch file absolute path
      Specified by:
      setProcessedArchFile in interface DataProviderIfc
      Parameters:
      file - absolute path of processed .arch file

    • getCurrArchFile

      public File getCurrArchFile()
      Description copied from interface: DataProviderIfc
      Allows a DataReceiver to obtain the currently processing .arch file
      Specified by:
      getCurrArchFile in interface DataProviderIfc
      Returns:
      currently processing .arch file

    • validOIMinorType

      public boolean validOIMinorType()
      Description copied from interface: DataProviderIfc
      Allows a DataReceiver to check if Minor Type supported for disaster recovery
      Specified by:
      validOIMinorType in interface DataProviderIfc
      Returns:
      true if valid