Rejecting tuples by using your own implementation

If you must have a special business logic to reject data records, you enable a composite to implement your rejection logic.

About this task

Enable the framework’s customizable reject composite.

Procedure

  1. In the file <PathToYourApplication>/config/config.cfg, find the ite.storage.rejectWriter.custom parameter description
  2. Enable the customizable reject composite operator by setting the parameter to on: ite.storage.rejectWriter.custom=on

Use the <namespace>.chainsink.custom::RejectWriterCustom composite operator to implement your code.