Package com.northconcepts.datapipeline.foundations.decisiontable

Class DecisionTableWriter

java.lang.Object
com.northconcepts.datapipeline.core.DataObject
com.northconcepts.datapipeline.core.Endpoint
com.northconcepts.datapipeline.core.DataEndpoint
com.northconcepts.datapipeline.core.DataWriter
com.northconcepts.datapipeline.core.ProxyWriter
com.northconcepts.datapipeline.internal.lang.IntegrationProxyWriter
com.northconcepts.datapipeline.foundations.decisiontable.DecisionTableWriter
public class DecisionTableWriter extends IntegrationProxyWriter
Evaluates a DecisionTable for each record and adds the outcome fields to it before writing it to a nested writer.

  • Constructor Details

  • Method Details

    • getExpressionContext

      public RecordExpressionContext getExpressionContext()

    • getDecisionTable

      public DecisionTable getDecisionTable()

    • isOverwrite

      public boolean isOverwrite()
      Indicates if outcome fields replace existing non-null fields with the same name instead of being added under a numbered name (default false).

    • setOverwrite

      public DecisionTableWriter setOverwrite(boolean overwrite)
      Indicates if outcome fields replace existing non-null fields with the same name instead of being added under a numbered name (default false).

    • interceptRecord

      protected Record interceptRecord(Record record) throws Throwable
      Description copied from class: ProxyWriter
      Overridden by subclasses to transform, drop, or observe a record on its way through this proxy.

      Contract for subclasses (see also docs/authoring/ProxyWriter.md):

      • Return the record (possibly modified) to forward it to the nested DataWriter.
      • Return null to drop the record; the framework will not write it downstream.
      • Throw to fail the pipeline; the framework wraps the throwable in a DataException with .setRecord(record).
      • The nested DataWriter is opened and closed for you; do not write to it here.
      • Do not call DataEndpoint.incrementRecordCount() here.
      Overrides:
      interceptRecord in class ProxyWriter
      Throws:
      Throwable

    • addExceptionProperties

      public DataException addExceptionProperties(DataException exception)
      Description copied from class: Endpoint
      Adds this endpoint's current state to a DataException. Since this method is called whenever an exception is thrown, subclasses should override it to add their specific information.
      Overrides:
      addExceptionProperties in class ProxyWriter