Package ca.uhn.fhir.batch2.api

Interface IJobDataSink<OT extends ca.uhn.fhir.model.api.IModelJson>

All Known Implementing Classes:
ReductionStepDataSink
public interface IJobDataSink<OT extends ca.uhn.fhir.model.api.IModelJson>

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    accept(WorkChunkData<OT> theData)
    Step workers may call this 0..* times in order to provide output work chunks that will be passed to subsequent steps.
    default void
    accept(OT theData)
    Step workers may call this 0..* times in order to provide output work chunks that will be passed to subsequent steps.
    void
    recoveredError(String theMessage)
    Step workers may invoke this method to indicate that an error occurred during processing but that it was successfully recovered, or it does not need to be recovered, or at least that it does not mean that processing should stop.
    void
    setWarningProcessor(IWarningProcessor theWarningProcessor)
    Step workers may invoke this method to indicate that a warning message processor

  • Method Details

    • accept

      default void accept(OT theData)
      Step workers may call this 0..* times in order to provide output work chunks that will be passed to subsequent steps. Multiple invocations will result in multiple discrete chunks of work, each of which will be processed separately (and potentially in parallel) by the next step in the job definition.

      This method may not be called by the final step worker and will result in an error.

      Parameters:
      theData - The data to pass to the next step worker

    • accept

      void accept(WorkChunkData<OT> theData)
      Step workers may call this 0..* times in order to provide output work chunks that will be passed to subsequent steps. Multiple invocations will result in multiple discrete chunks of work, each of which will be processed separately (and potentially in parallel) by the next step in the job definition.

      This method is not currently any different to calling accept(IModelJson) other than the fact that it adds a wrapper object, but additional fields may be added to the wrapper in the future.

      This method may not be called by the final step worker and will result in an error.

      Parameters:
      theData - The data to pass to the next step worker

    • recoveredError

      void recoveredError(String theMessage)
      Step workers may invoke this method to indicate that an error occurred during processing but that it was successfully recovered, or it does not need to be recovered, or at least that it does not mean that processing should stop.
      Parameters:
      theMessage - An error message. This will be logged, and in the future it may be stored

    • setWarningProcessor

      void setWarningProcessor(IWarningProcessor theWarningProcessor)
      Step workers may invoke this method to indicate that a warning message processor
      Parameters:
      theWarningProcessor - The processor for the warning.