Minor Tried adding reject output for the component using following approach:
public class OutputSink implements Serializable { ... @ElementListener public void onNext(@Input final JsonObject record, @Output("reject") final OutputEmitter<Reject> reject) throws SQLException { try { ... statement.execute(); } catch (Exception e) { reject.emit(new Reject(e.getMessage(), record)); } }
When connecting Reject flow with tLogRow component, if all the records are successful we still receive the output with empty records:
[statistics] connected | | | ... [statistics] disconnected
And count of records above the Reject flow is also total count of records (including successful ones).
Please clarify if this behavior is correct.
- is child of
-
TCOMP-900
[tacokit studio integration] - Handle conditional outputs
-
- Done
-