Skip to content
This repository has been archived by the owner on Dec 15, 2022. It is now read-only.

Implement step error handling #2

Open
mattcasters opened this issue Nov 28, 2018 · 1 comment
Open

Implement step error handling #2

mattcasters opened this issue Nov 28, 2018 · 1 comment

Comments

@mattcasters
Copy link
Owner

Probably by moving everything to multiple PCollections, one for data, one for errors.

mattcasters added a commit that referenced this issue Nov 30, 2018
@mattcasters
Copy link
Owner Author

This should be a question of capturing the error rows in the StepFn rowListener

            rowListener = new RowAdapter() {
              @Override public void rowWrittenEvent( RowMetaInterface rowMeta, Object[] row ) throws KettleStepException {

                // if (infoSteps.size()>0 && resultRows.size()==0) {
                //  System.out.println( ">>>>>>>>> CAPTURE ROW: "+rowMeta.toString());
                // }
                resultRows.add( row );
              }

              @Override public void errorRowWrittenEvent( RowMetaInterface rowMeta, Object[] row ) throws KettleStepException {
                errorRows.add(row)
              }
            };```

@mattcasters mattcasters changed the title Implement error handling Implement step error handling Dec 10, 2018
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant