HadoopVfsConnection { public void setCustomParameters( Props pr ) { pr.setCustomParameter( "HadoopVfsFileChooserDialog.host", getHostname() ); pr.setCustomParameter( "HadoopVfsFileChooserDialog.port", getPort() ); pr.setCustomParameter( "HadoopVfsFileChooserDialog.user", getUsername() ); pr.setCustomParameter( "HadoopVfsFileChooserDialog.password", getPassword() ); } HadoopVfsConnection( String ncHostname, String ncPort, String ncUsername, String ncPassword );  HadoopVfsConnection();  HadoopVfsConnection( NamedCluster nCluster, VariableSpace vs ); String getConnectionString( String schemeName ); void setCustomParameters( Props pr ); String getHostname(); String getPort(); String getUsername(); String getPassword();  }
@Test public void tesSetSustomParameters() throws KettleFileException { Props.init( 0 ); HadoopVfsConnection hdfsConnection = new HadoopVfsConnection( getTestNamedCluster(), new Variables() ); hdfsConnection.setCustomParameters( Props.getInstance() ); assertEquals( TEST_HOST, Props.getInstance().getCustomParameter( "HadoopVfsFileChooserDialog.host", DEFAULT_VALUE ) ); assertEquals( TEST_PORT, Props.getInstance().getCustomParameter( "HadoopVfsFileChooserDialog.port", DEFAULT_VALUE ) ); assertEquals( TEST_USER, Props.getInstance().getCustomParameter( "HadoopVfsFileChooserDialog.user", DEFAULT_VALUE ) ); assertEquals( TEST_PASSWORD, Props.getInstance().getCustomParameter( "HadoopVfsFileChooserDialog.password", DEFAULT_VALUE ) ); }