import org.apache.commons.vfs2.provider.FileNameParser; //导入依赖的package包/类
@Test
public void rootPathNoClusterName() throws FileSystemException {
  final String URI = "maprfs:///";

  FileNameParser parser = new MapRFileNameParser();
  FileName name = parser.parseUri(null, null, URI);

  assertEquals(URI, name.getURI());
  assertEquals("maprfs", name.getScheme());
}
 

import org.apache.commons.vfs2.provider.FileNameParser; //导入依赖的package包/类
@Test
public void withPath() throws FileSystemException
{
  final String URI = "maprfs:///my/file/path";

  FileNameParser parser = new MapRFileNameParser();
  FileName name = parser.parseUri(null, null, URI);

  assertEquals(URI, name.getURI());
  assertEquals("maprfs", name.getScheme());
  assertEquals("/my/file/path", name.getPath());
}
 

import org.apache.commons.vfs2.provider.FileNameParser; //导入依赖的package包/类
@Test
public void withPathAndClusterName() throws FileSystemException {
  final String URI = "maprfs://cluster2/my/file/path";

  FileNameParser parser = new MapRFileNameParser();
  FileName name = parser.parseUri(null, null, URI);

  assertEquals(URI, name.getURI());
  assertEquals("maprfs", name.getScheme());
  assertTrue(name.getURI().startsWith("maprfs://cluster2/"));
  assertEquals("/my/file/path", name.getPath());
}
 

import org.apache.commons.vfs2.provider.FileNameParser; //导入依赖的package包/类
@Test
public void testParseUri_withKeys() throws Exception {
  FileNameParser parser = S3FileNameParser.getInstance();
  String expected = buildS3URL( "/rcf-emr-staging", true );

  FileName filename =
    parser.parseUri( null, null, "s3://" + awsAccessKey + ":" + awsSecretKey + "@" + HOST + "/rcf-emr-staging" );
  assertEquals( expected, filename.getURI() );

}
 

import org.apache.commons.vfs2.provider.FileNameParser; //导入依赖的package包/类
@Test
public void testParseUri_withoutKeys() throws Exception {
  FileNameParser parser = S3FileNameParser.getInstance();
  String expected = buildS3URL( "/", false );

  FileName filename = parser.parseUri( null, null, "s3://" + HOST + "/" );
  assertEquals( expected, filename.getURI() );

}
 

import org.apache.commons.vfs2.provider.FileNameParser; //导入依赖的package包/类
public static FileNameParser getInstance()
{
    return INSTANCE;
}
 

import org.apache.commons.vfs2.provider.FileNameParser; //导入依赖的package包/类
public static FileNameParser getInstance() {
  return INSTANCE;
}
 

import org.apache.commons.vfs2.provider.FileNameParser; //导入依赖的package包/类
/**
 * Publicly expose a generic way to set parameters
 */
@Override
public void setParameter( FileSystemOptions opts, String name, String value, String fullParameterName,
  String vfsUrl ) throws IOException {
  if ( !fullParameterName.startsWith( "vfs.sftp" ) ) {
    // This is not an SFTP parameter. Delegate to the generic handler
    super.setParameter( opts, name, value, fullParameterName, vfsUrl );
  } else {
    // Check for the presence of a host in the full variable name
    try {
      // Parse server name from vfsFilename
      FileNameParser sftpFilenameParser = SftpFileNameParser.getInstance();
      URLFileName file = (URLFileName) sftpFilenameParser.parseUri( null, null, vfsUrl );

      if ( !parameterContainsHost( fullParameterName ) || fullParameterName.endsWith( file.getHostName() ) ) {
        // Match special cases for parameter names
        if ( name.equalsIgnoreCase( "AuthKeyPassphrase" ) ) {
          setParam( opts, UserInfo.class.getName(), new PentahoUserInfo( value ) );
        } else if ( name.equals( "identity" ) ) {

          IdentityInfo[] identities = (IdentityInfo[]) this.getParam( opts, IDENTITY_KEY );

          if ( identities == null ) {
            identities = new IdentityInfo[] { new IdentityInfo( new File( value ) ) };
          } else {
            // Copy, in a Java 5 friendly manner, identities into a larger array
            IdentityInfo[] temp = new IdentityInfo[identities.length + 1];
            System.arraycopy( identities, 0, temp, 0, identities.length );
            identities = temp;

            identities[identities.length - 1] = new IdentityInfo( new File( value ) );
          }
          setParam( opts, IDENTITY_KEY, identities );
        } else {
          super.setParameter( opts, name, value, fullParameterName, vfsUrl );
        }
      } else {
        // No host match found
        log.logDebug( "No host match found for: " + fullParameterName );
      }
    } catch ( IOException e ) {
      log.logError( "Failed to set VFS parameter: [" + fullParameterName + "] " + value, e );
    }
  }
}
 

import org.apache.commons.vfs2.provider.FileNameParser; //导入依赖的package包/类
/**
 * Gets the single instance of GsiFtpFileNameParser.
 * 
 * @return single instance of GsiFtpFileNameParser
 */
public static FileNameParser getInstance() {
    return INSTANCE;
}