@Test public void testInitNullRowMeta() throws KettleException { hadoopExitData.init( null, null, null ); }
public void init( RowMetaInterface rowMeta, HadoopExitMeta stepMeta, VariableSpace space ) throws KettleException { if ( rowMeta != null ) { outputRowMeta = rowMeta.clone(); stepMeta.getFields( outputRowMeta, stepMeta.getName(), null, null, space ); setInKeyOrdinal( rowMeta.indexOfValue( stepMeta.getOutKeyFieldname() ) ); setInValueOrdinal( rowMeta.indexOfValue( stepMeta.getOutValueFieldname() ) ); } }
HadoopExitData extends BaseStepData implements StepDataInterface { public void init( RowMetaInterface rowMeta, HadoopExitMeta stepMeta, VariableSpace space ) throws KettleException { if ( rowMeta != null ) { outputRowMeta = rowMeta.clone(); stepMeta.getFields( outputRowMeta, stepMeta.getName(), null, null, space ); setInKeyOrdinal( rowMeta.indexOfValue( stepMeta.getOutKeyFieldname() ) ); setInValueOrdinal( rowMeta.indexOfValue( stepMeta.getOutValueFieldname() ) ); } } }
HadoopExitData extends BaseStepData implements StepDataInterface { public void init( RowMetaInterface rowMeta, HadoopExitMeta stepMeta, VariableSpace space ) throws KettleException { if ( rowMeta != null ) { outputRowMeta = rowMeta.clone(); stepMeta.getFields( outputRowMeta, stepMeta.getName(), null, null, space ); setInKeyOrdinal( rowMeta.indexOfValue( stepMeta.getOutKeyFieldname() ) ); setInValueOrdinal( rowMeta.indexOfValue( stepMeta.getOutValueFieldname() ) ); } } HadoopExitData(); }
HadoopExitData extends BaseStepData implements StepDataInterface { public void init( RowMetaInterface rowMeta, HadoopExitMeta stepMeta, VariableSpace space ) throws KettleException { if ( rowMeta != null ) { outputRowMeta = rowMeta.clone(); stepMeta.getFields( outputRowMeta, stepMeta.getName(), null, null, space ); setInKeyOrdinal( rowMeta.indexOfValue( stepMeta.getOutKeyFieldname() ) ); setInValueOrdinal( rowMeta.indexOfValue( stepMeta.getOutValueFieldname() ) ); } } HadoopExitData(); void init( RowMetaInterface rowMeta, HadoopExitMeta stepMeta, VariableSpace space ); RowMetaInterface getOutputRowMeta(); void setInKeyOrdinal( int inKeyOrdinal ); int getInKeyOrdinal(); void setInValueOrdinal( int inValueOrdinal ); int getInValueOrdinal(); static int getOutKeyOrdinal(); static int getOutValueOrdinal(); }
HadoopExitData extends BaseStepData implements StepDataInterface { public void init( RowMetaInterface rowMeta, HadoopExitMeta stepMeta, VariableSpace space ) throws KettleException { if ( rowMeta != null ) { outputRowMeta = rowMeta.clone(); stepMeta.getFields( outputRowMeta, stepMeta.getName(), null, null, space ); setInKeyOrdinal( rowMeta.indexOfValue( stepMeta.getOutKeyFieldname() ) ); setInValueOrdinal( rowMeta.indexOfValue( stepMeta.getOutValueFieldname() ) ); } } HadoopExitData(); void init( RowMetaInterface rowMeta, HadoopExitMeta stepMeta, VariableSpace space ); RowMetaInterface getOutputRowMeta(); void setInKeyOrdinal( int inKeyOrdinal ); int getInKeyOrdinal(); void setInValueOrdinal( int inValueOrdinal ); int getInValueOrdinal(); static int getOutKeyOrdinal(); static int getOutValueOrdinal(); static final int outKeyOrdinal; static final int outValueOrdinal; }