Missing stage definition and callback for "SourceKeysStage.CONVERT_SOURCE_ROWS" #246

Author: andrus

RELEASE-NOTES.md

@@ -2,6 +2,7 @@
 
 * #239 Remove APIs deprecated in 3.0.0 
 * #244 Simplify StringConverter
+* #246 Missing stage definition and callback for "SourceKeysStage.CONVERT_SOURCE_ROWS"
 
 ## Release 3.0.0-RC4
 

link-move/src/main/java/com/nhl/link/move/runtime/task/sourcekeys/SourceKeysSegmentProcessor.java

@@ -27,12 +27,13 @@ public SourceKeysSegmentProcessor(
     public void process(Execution exec, SourceKeysSegment segment) {
         callbackExecutor.executeCallbacks(SourceKeysStage.EXTRACT_SOURCE_ROWS, exec, segment);
 
-        convertSrc(segment);
+        convertSrc(exec, segment);
         collectSourceKeys(exec, segment);
     }
 
-    private void convertSrc(SourceKeysSegment segment) {
+    private void convertSrc(Execution exec, SourceKeysSegment segment) {
         segment.setSources(rowConverter.convert(segment.getSourceRowsHeader(), segment.getSourceRows()));
+        callbackExecutor.executeCallbacks(SourceKeysStage.CONVERT_SOURCE_ROWS, exec, segment);
     }
 
     private void collectSourceKeys(Execution exec, SourceKeysSegment segment) {

link-move/src/main/java/com/nhl/link/move/runtime/task/sourcekeys/SourceKeysStage.java

@@ -7,5 +7,11 @@
  */
 public enum SourceKeysStage implements TaskStageType {
     EXTRACT_SOURCE_ROWS,
+
+    /**
+     * @since 4.0.0
+     */
+    CONVERT_SOURCE_ROWS,
+
     COLLECT_SOURCE_KEYS
 }