@Test public void testLoadReferencedObject() { BaseStreamStepMeta meta = new StuffStreamMeta(); meta.setFileName( getClass().getResource( "/org/pentaho/di/trans/subtrans-executor-sub.ktr" ).getPath() ); meta.setSpecificationMethod( ObjectLocationSpecificationMethod.FILENAME ); try { TransMeta subTrans = (TransMeta) meta.loadReferencedObject( 0, null, null, new Variables() ); assertEquals( "subtrans-executor-sub", subTrans.getName() ); } catch ( KettleException e ) { fail(); } testRoundTrip( meta ); }
@Override public Object loadReferencedObject( int index, Repository rep, IMetaStore metaStore, VariableSpace space ) throws KettleException { return loadMappingMeta( this, rep, metaStore, space ); }
BaseStreamStepMeta extends StepWithMappingMeta implements StepMetaInterface { @Override public Object loadReferencedObject( int index, Repository rep, IMetaStore metaStore, VariableSpace space ) throws KettleException { return loadMappingMeta( this, rep, metaStore, space ); } }
BaseStreamStepMeta extends StepWithMappingMeta implements StepMetaInterface { @Override public Object loadReferencedObject( int index, Repository rep, IMetaStore metaStore, VariableSpace space ) throws KettleException { return loadMappingMeta( this, rep, metaStore, space ); }  }
BaseStreamStepMeta extends StepWithMappingMeta implements StepMetaInterface { @Override public Object loadReferencedObject( int index, Repository rep, IMetaStore metaStore, VariableSpace space ) throws KettleException { return loadMappingMeta( this, rep, metaStore, space ); }  String getSubStep(); void setSubStep( String subStep ); void setTransformationPath( String transformationPath ); void setBatchSize( String batchSize ); void setBatchDuration( String batchDuration ); @Override void setDefault(); String getTransformationPath(); String getBatchSize(); String getBatchDuration(); @Override void replaceFileName( String fileName ); void check( List<CheckResultInterface> remarks, TransMeta transMeta,
                     StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output,
                     RowMetaInterface info, VariableSpace space, Repository repository,
                     IMetaStore metaStore ); @Override List<ResourceReference> getResourceDependencies( TransMeta transMeta, StepMeta stepInfo ); @Override String[] getReferencedObjectDescriptions(); @Override boolean[] isReferencedObjectEnabled(); @Override Object loadReferencedObject( int index, Repository rep, IMetaStore metaStore, VariableSpace space ); abstract RowMeta getRowMeta( String origin, VariableSpace space ); @Override void getFields( RowMetaInterface rowMeta, String origin, RowMetaInterface[] info, StepMeta nextStep,
                                   VariableSpace space, Repository repository, IMetaStore metaStore ); }
BaseStreamStepMeta extends StepWithMappingMeta implements StepMetaInterface { @Override public Object loadReferencedObject( int index, Repository rep, IMetaStore metaStore, VariableSpace space ) throws KettleException { return loadMappingMeta( this, rep, metaStore, space ); }  String getSubStep(); void setSubStep( String subStep ); void setTransformationPath( String transformationPath ); void setBatchSize( String batchSize ); void setBatchDuration( String batchDuration ); @Override void setDefault(); String getTransformationPath(); String getBatchSize(); String getBatchDuration(); @Override void replaceFileName( String fileName ); void check( List<CheckResultInterface> remarks, TransMeta transMeta,
                     StepMeta stepMeta, RowMetaInterface prev, String[] input, String[] output,
                     RowMetaInterface info, VariableSpace space, Repository repository,
                     IMetaStore metaStore ); @Override List<ResourceReference> getResourceDependencies( TransMeta transMeta, StepMeta stepInfo ); @Override String[] getReferencedObjectDescriptions(); @Override boolean[] isReferencedObjectEnabled(); @Override Object loadReferencedObject( int index, Repository rep, IMetaStore metaStore, VariableSpace space ); abstract RowMeta getRowMeta( String origin, VariableSpace space ); @Override void getFields( RowMetaInterface rowMeta, String origin, RowMetaInterface[] info, StepMeta nextStep,
                                   VariableSpace space, Repository repository, IMetaStore metaStore ); static final String TRANSFORMATION_PATH; static final String NUM_MESSAGES; static final String DURATION; static final String SUB_STEP; }