org.pentaho.di.trans.step.BaseStep.setInputRowSets()方法的使用及代码示例

本文整理了Java中org.pentaho.di.trans.step.BaseStep.setInputRowSets()方法的一些代码示例，展示了BaseStep.setInputRowSets()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。BaseStep.setInputRowSets()方法的具体详情如下：
包路径：org.pentaho.di.trans.step.BaseStep
类名称：BaseStep
方法名：setInputRowSets

BaseStep.setInputRowSets介绍

暂无

代码示例

代码示例来源：origin: pentaho/pentaho-kettle

public void setInputRowSetsImpl( List inputRowSets ) {
super.setInputRowSets( inputRowSets );
}

代码示例来源：origin: pentaho/pentaho-kettle

@Test
public void testGetRowSafeModeEnabled() throws KettleException {
Trans transMock = mock( Trans.class );
when( transMock.isSafeModeEnabled() ).thenReturn( true );
BaseStep baseStepSpy =
spy( new BaseStep( mockHelper.stepMeta, mockHelper.stepDataInterface,
0, mockHelper.transMeta, transMock ) );
doNothing().when( baseStepSpy ).waitUntilTransformationIsStarted();
doNothing().when( baseStepSpy ).openRemoteInputStepSocketsOnce();
BlockingRowSet rowSet = new BlockingRowSet( 1 );
List valueMetaList = Arrays.asList( new ValueMetaInteger( "x" ), new ValueMetaString( "a" ) );
RowMeta rowMeta = new RowMeta();
rowMeta.setValueMetaList( valueMetaList );
final Object[] row = new Object[] {};
rowSet.putRow( rowMeta, row );
baseStepSpy.setInputRowSets( Arrays.asList( rowSet ) );
doReturn( rowSet ).when( baseStepSpy ).currentInputStream();
baseStepSpy.getRow();
verify( mockHelper.transMeta, times( 1 ) ).checkRowMixingStatically( any( StepMeta.class ), anyObject() );
}
}