marklogic-data-hub
marklogic-data-hub copied to clipboard
[FEATURE] onStatusChanged, onItemComplete and onItemFailed available from FlowRunner Java API
What gap would you like Data Hub Framework to address?
In previous versions and in the LegacyFlowRunner the Java API provided a way to execute some code when processing (harmonization) of item was done. Namely onItemComplete
and onItemFailed
. We were using this in our java code because some of our collectors are returning values that are concatenated URIs that we need to split to get the correct count (onItemComplete).
But in the process of migrating our flows from legacy 4.x to new Steps approach we found out that the functionality is no longer available. There still is (at least in v5.4.1) onStatusChanged
but without access to the id/uri processed.
Describe the solution you'd like
Extend the java API in a way a user can add a custom onItemComplete
and onItemFailed
listeners to a flow/step.