@Test public void testGetStep() { StepMockHelper<CouchDbInputMeta, CouchDbInputData> stepMockHelper = new StepMockHelper<CouchDbInputMeta, CouchDbInputData>( "testName", CouchDbInputMeta.class, CouchDbInputData.class ); when( stepMockHelper.logChannelInterfaceFactory.create( anyObject(), any( LoggingObjectInterface.class ) ) ) .thenReturn( mock( LogChannelInterface.class ) ); assertTrue( couchDbInputMeta .getStep( stepMockHelper.stepMeta, stepMockHelper.stepDataInterface, 0, stepMockHelper.transMeta, stepMockHelper.trans ) instanceof CouchDbInput ); }
@Override public StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr, Trans trans ) { return new CouchDbInput( stepMeta, stepDataInterface, cnr, tr, trans ); }
CouchDbInputMeta extends BaseStepMeta implements StepMetaInterface { @Override public StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr, Trans trans ) { return new CouchDbInput( stepMeta, stepDataInterface, cnr, tr, trans ); } }
CouchDbInputMeta extends BaseStepMeta implements StepMetaInterface { @Override public StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr, Trans trans ) { return new CouchDbInput( stepMeta, stepDataInterface, cnr, tr, trans ); } CouchDbInputMeta(); }
CouchDbInputMeta extends BaseStepMeta implements StepMetaInterface { @Override public StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr, Trans trans ) { return new CouchDbInput( stepMeta, stepDataInterface, cnr, tr, trans ); } CouchDbInputMeta(); @Override void loadXML( Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore ); @Override Object clone(); @Override void setDefault(); @Override void getFields( RowMetaInterface rowMeta, String origin, RowMetaInterface[] info, StepMeta nextStep,
                         VariableSpace space, Repository repository, IMetaStore metaStore ); @Override String getXML(); @Override void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ); @Override void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_transformation, ObjectId id_step ); @Override StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr,
                                Trans trans ); @Override StepDataInterface getStepData(); String getHostname(); void setHostname( String hostname ); String getPort(); void setPort( String port ); String getDbName(); void setDbName( String dbName ); String getAuthenticationUser(); void setAuthenticationUser( String authenticationUser ); String getAuthenticationPassword(); void setAuthenticationPassword( String authenticationPassword ); String getViewName(); void setViewName( String viewName ); String getDesignDocument(); void setDesignDocument( String designDocument ); }
CouchDbInputMeta extends BaseStepMeta implements StepMetaInterface { @Override public StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr, Trans trans ) { return new CouchDbInput( stepMeta, stepDataInterface, cnr, tr, trans ); } CouchDbInputMeta(); @Override void loadXML( Node stepnode, List<DatabaseMeta> databases, IMetaStore metaStore ); @Override Object clone(); @Override void setDefault(); @Override void getFields( RowMetaInterface rowMeta, String origin, RowMetaInterface[] info, StepMeta nextStep,
                         VariableSpace space, Repository repository, IMetaStore metaStore ); @Override String getXML(); @Override void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ); @Override void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_transformation, ObjectId id_step ); @Override StepInterface getStep( StepMeta stepMeta, StepDataInterface stepDataInterface, int cnr, TransMeta tr,
                                Trans trans ); @Override StepDataInterface getStepData(); String getHostname(); void setHostname( String hostname ); String getPort(); void setPort( String port ); String getDbName(); void setDbName( String dbName ); String getAuthenticationUser(); void setAuthenticationUser( String authenticationUser ); String getAuthenticationPassword(); void setAuthenticationPassword( String authenticationPassword ); String getViewName(); void setViewName( String viewName ); String getDesignDocument(); void setDesignDocument( String designDocument ); static final String DEFAULT_HOSTNAME; static final String DEFAULT_PORT; static final String DEFAULT_DB_NAME; static final String DEFAULT_VIEW_NAME; static final String VALUE_META_NAME; }