@Override
  public void write(Batch batch) throws StageException {
    Iterator<Record> batchIterator = batch.getRecords();

    while (batchIterator.hasNext()) {
      Record record = batchIterator.next();
      try {
        write(record);
      } catch (Exception e) {
        switch (getContext().getOnErrorRecord()) {
          case DISCARD:
            break;
          case TO_ERROR:
            getContext().toError(record, Errors.SAMPLE_01, e.toString());
            break;
          case STOP_PIPELINE:
            throw new StageException(Errors.SAMPLE_01, e.toString());
          default:
            throw new IllegalStateException(
                Utils.format("Unknown OnError value '{}'", getContext().getOnErrorRecord(), e)
            );
        }
      }
    }
  }
@ Override public void write ( Batch batch ) throws StageException { Iterator < Record > batchIterator = batch . getRecords ( ) ; while ( batchIterator . hasNext ( ) ) { Record record = batchIterator . next ( ) ; try { write ( record ) ; } catch ( Exception e ) { switch ( getContext ( ) . getOnErrorRecord ( ) ) { case DISCARD : break ; case TO_ERROR : getContext ( ) . toError ( record , Errors . SAMPLE_01 , e . toString ( ) ) ; break ; case STOP_PIPELINE : throw new StageException ( Errors . SAMPLE_01 , e . toString ( ) ) ; default : throw new IllegalStateException ( Utils . format ( "Unknown OnError value '{}'" , getContext ( ) . getOnErrorRecord ( ) , e ) ) ; } } } }
{@inheritDoc}