PentahoDataIntegration中BaseStep类getOutputRowSets方法详解与代码实例

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

BaseStep.getOutputRowSets介绍

暂无

代码示例

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

public List getOutputRowSetsImpl() {
return super.getOutputRowSets();
}

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

@Override
BaseStep doCall() {
for ( RowSet rowSet : baseStep.getInputRowSets() ) {
rowSet.setRowMeta( mock( RowMetaInterface.class ) );
}
for ( RowSet rowSet : baseStep.getOutputRowSets() ) {
rowSet.setRowMeta( mock( RowMetaInterface.class ) );
}
return null;
}
}

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

baseStep.putRow( rowMeta1, objects1 );
assertEquals( object0, baseStep.getOutputRowSets().get( 0 ).getRow()[ 0 ] );
assertEquals( object1, baseStep.getOutputRowSets().get( 1 ).getRow()[ 0 ] );
assertEquals( object0, baseStep.getOutputRowSets().get( 2 ).getRow()[ 0 ] );
assertEquals( object1, baseStep.getOutputRowSets().get( 3 ).getRow()[ 0 ] );

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

@Test
public void outputRowMetasAreNotSharedAmongSeveralStreams() throws Exception {
RowSet rs1 = new SingleRowRowSet();
RowSet rs2 = new SingleRowRowSet();
when( mockHelper.trans.isRunning() ).thenReturn( true );
BaseStep baseStep =
new BaseStep( mockHelper.stepMeta, mockHelper.stepDataInterface, 0, mockHelper.transMeta, mockHelper.trans );
baseStep.setStopped( false );
baseStep.setRepartitioning( StepPartitioningMeta.PARTITIONING_METHOD_NONE );
baseStep.setOutputRowSets( Arrays.asList( rs1, rs2 ) );
for ( RowSet rowSet : baseStep.getOutputRowSets() ) {
assertNull( "RowMeta should be null, since no calls were done", rowSet.getRowMeta() );
}
RowMetaInterface rowMeta = new RowMeta();
rowMeta.addValueMeta( new ValueMetaString( "string" ) );
rowMeta.addValueMeta( new ValueMetaInteger( "integer" ) );
baseStep.putRow( rowMeta, new Object[] { "a", 1 } );
RowMetaInterface meta1 = rs1.getRowMeta();
RowMetaInterface meta2 = rs2.getRowMeta();
assertNotNull( meta1 );
assertNotNull( meta2 );
// content is same
for ( ValueMetaInterface meta : meta1.getValueMetaList() ) {
assertTrue( meta.getName(), meta2.exists( meta ) );
}
// whereas instances differ
assertFalse( meta1 == meta2 );
}