@Test( expected = KettleStepException.class ) public void errorRowWrittenEvent() throws KettleValueException, KettleStepException { Object[] row = new Object[] { "TEST" }; RowMetaInterface rowMetaInterface = mock( RowMetaInterface.class ); TableProducer tableProducer = new TableProducer( rowMetaInterface, 0, true ); tableProducer.errorRowWrittenEvent( rowMetaInterface, row ); }
public void errorRowWrittenEvent( final RowMetaInterface rowMeta, final Object[] row ) throws KettleStepException { if ( stopOnError ) { throw new KettleStepException( "Aborting transformation due to error detected" ); } error = true; }
TableProducer implements RowListener { public void errorRowWrittenEvent( final RowMetaInterface rowMeta, final Object[] row ) throws KettleStepException { if ( stopOnError ) { throw new KettleStepException( "Aborting transformation due to error detected" ); } error = true; } }
TableProducer implements RowListener { public void errorRowWrittenEvent( final RowMetaInterface rowMeta, final Object[] row ) throws KettleStepException { if ( stopOnError ) { throw new KettleStepException( "Aborting transformation due to error detected" ); } error = true; } TableProducer( final RowMetaInterface rowMeta, final int queryLimit, final boolean stopOnError ); }
TableProducer implements RowListener { public void errorRowWrittenEvent( final RowMetaInterface rowMeta, final Object[] row ) throws KettleStepException { if ( stopOnError ) { throw new KettleStepException( "Aborting transformation due to error detected" ); } error = true; } TableProducer( final RowMetaInterface rowMeta, final int queryLimit, final boolean stopOnError ); void rowWrittenEvent( final RowMetaInterface rowMeta, final Object[] row ); void rowReadEvent( final RowMetaInterface rowMeta, final Object[] row ); void errorRowWrittenEvent( final RowMetaInterface rowMeta, final Object[] row ); TableModel getTableModel(); }
TableProducer implements RowListener { public void errorRowWrittenEvent( final RowMetaInterface rowMeta, final Object[] row ) throws KettleStepException { if ( stopOnError ) { throw new KettleStepException( "Aborting transformation due to error detected" ); } error = true; } TableProducer( final RowMetaInterface rowMeta, final int queryLimit, final boolean stopOnError ); void rowWrittenEvent( final RowMetaInterface rowMeta, final Object[] row ); void rowReadEvent( final RowMetaInterface rowMeta, final Object[] row ); void errorRowWrittenEvent( final RowMetaInterface rowMeta, final Object[] row ); TableModel getTableModel();  }