Package com.nt.udc.ndk.node

Interface DataProviderIfc

All Known Subinterfaces:
DCStreamHandler
All Known Implementing Classes:
AggregatorFieldProcessor, DCFieldProcessor, DeclNPLFieldProcessor, DiscProcFieldProcessor, DupRemoverFieldProcessor, EITransport, FileEITransport, FileEITransport, FlatFileEIProcessor, FlexibleAggregatorFieldProcessor, FtpEITransport, GenericFlatFileProcessor, GenericUdpEITransport, HCDeDupFieldProcessor, IPDRFileTransport, IPDRTransport, JDBCEITransport, JDBCOIFieldProcessor, KnownFieldLengthFileProcessor, MXNARFileManager, MXNarOutReceiverWrapper, MXNarProvider, MXNPLFieldProcessor, NAREIFileProcessor, NARFileManager, NARFileManagerMT, NARSelectorFieldProcessor, NARStreamHandler, NPLFieldProcessor, OpenFileEITransport, SeqProcFieldProcessor, SoapXmlEITransport, Sol42EITransport, Sol42FieldProcessor, TcpEITransport, UdpEITransport, XMLFileTransport, XMLTransport
public interface DataProviderIfc
Methods which allow a DataReceiver to communicate with a DataProvider

  • Method Details

    • isDataAvailable

      boolean isDataAvailable()
      Allows a DataReceiver to determine whether some data is available for processing
      Returns:
      true, if data is available

    • getData

      DCFieldContainer getData()
      Allows a DataReceiver to obtain the available data in a known format.
      Returns:
      DCFieldContainer object containing the data that is available for processing

    • signalBatchCompletion

      void signalBatchCompletion(String batch)
      Allows a DataReceiver to know that the nars under the specified batch are completed and handed over to the Data receiver

    • getData

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

    • getBulkData

      DCFieldContainer[] getBulkData()
      Allows a DataReceiver to obtain the available data in a known format.
      Returns:
      DCFieldContainer object array, containing the data that is for processing

    • setDataReceiver

      void setDataReceiver(DataReceiverIfc receiver)
      Sets the object to which this DataProvider will send its data.
      Parameters:
      receiver - Object which will obtain data from this DataProvider

    • getDataReceiver

      DataReceiverIfc getDataReceiver()
      Gets the object that is retrieving data from this DataProvider
      Returns:
      Object to which this DataProvider is sending data

    • getCurrArchFile

      File getCurrArchFile()
      Allows a DataReceiver to obtain the currently processing .arch file
      Returns:
      currently processing .arch file

    • removeProcessedFile

      void removeProcessedFile(File currArchFile)
      Allows a DataReceiver to remove .arch file once processed currArchFile - processed .arch file

    • getProcessedArchFile

      String getProcessedArchFile()
      Allows a DataReceiver to obtain the last processed .arch file
      Returns:
      currently processing .arch file absolute path

    • setProcessedArchFile

      void setProcessedArchFile(String processedArchFile)
      Sets the processed .arch file absolute path
      Parameters:
      processedArchFile - absolute path of processed .arch file

    • validOIMinorType

      boolean validOIMinorType()
      Allows a DataReceiver to check if Minor Type supported for disaster recovery
      Returns:
      true if valid