@Test public void testGetNamedClusterByName_metastoreNotExist() throws FileSystemException, MetaStoreException { String ncName = "ncName"; NamedClusterProvider provider = new NamedClusterProvider( hdfsLocator, ncService, fileSystemManager, fileNameParser, scheme, metastoreLocator ); assertNull( provider.getNamedClusterByName( ncName, null ) ); verify( ncService, never() ).read( eq( ncName ), eq( metastore ) ); }
NamedCluster getNamedClusterByName( String clusterNameToResolve, FileSystemOptions fileSystemOptions ) throws FileSystemException { IMetaStore metaStore = getMetastore( clusterNameToResolve, fileSystemOptions ); NamedCluster namedCluster = null; try { namedCluster = namedClusterService.read( clusterNameToResolve, metaStore ); } catch ( MetaStoreException e ) { throw new FileSystemException( e ); } return namedCluster; }
NamedClusterProvider extends HDFSFileProvider implements VfsEmbeddedFileSystemCloser { NamedCluster getNamedClusterByName( String clusterNameToResolve, FileSystemOptions fileSystemOptions ) throws FileSystemException { IMetaStore metaStore = getMetastore( clusterNameToResolve, fileSystemOptions ); NamedCluster namedCluster = null; try { namedCluster = namedClusterService.read( clusterNameToResolve, metaStore ); } catch ( MetaStoreException e ) { throw new FileSystemException( e ); } return namedCluster; } }
NamedClusterProvider extends HDFSFileProvider implements VfsEmbeddedFileSystemCloser { NamedCluster getNamedClusterByName( String clusterNameToResolve, FileSystemOptions fileSystemOptions ) throws FileSystemException { IMetaStore metaStore = getMetastore( clusterNameToResolve, fileSystemOptions ); NamedCluster namedCluster = null; try { namedCluster = namedClusterService.read( clusterNameToResolve, metaStore ); } catch ( MetaStoreException e ) { throw new FileSystemException( e ); } return namedCluster; } NamedClusterProvider( HadoopFileSystemLocator hadoopFileSystemLocator,
                               NamedClusterService namedClusterService,
                               FileNameParser fileNameParser,
                               String[] schemes,
                               MetastoreLocatorOsgi metaStore );  NamedClusterProvider( HadoopFileSystemLocator hadoopFileSystemLocator,
                               NamedClusterService namedClusterService,
                               FileNameParser fileNameParser,
                               String schema,
                               MetastoreLocatorOsgi metaStore );  NamedClusterProvider( HadoopFileSystemLocator hadoopFileSystemLocator,
                               NamedClusterService namedClusterService,
                               DefaultFileSystemManager fileSystemManager,
                               FileNameParser fileNameParser,
                               String[] schemes,
                               MetastoreLocatorOsgi metaStore ); }
NamedClusterProvider extends HDFSFileProvider implements VfsEmbeddedFileSystemCloser { NamedCluster getNamedClusterByName( String clusterNameToResolve, FileSystemOptions fileSystemOptions ) throws FileSystemException { IMetaStore metaStore = getMetastore( clusterNameToResolve, fileSystemOptions ); NamedCluster namedCluster = null; try { namedCluster = namedClusterService.read( clusterNameToResolve, metaStore ); } catch ( MetaStoreException e ) { throw new FileSystemException( e ); } return namedCluster; } NamedClusterProvider( HadoopFileSystemLocator hadoopFileSystemLocator,
                               NamedClusterService namedClusterService,
                               FileNameParser fileNameParser,
                               String[] schemes,
                               MetastoreLocatorOsgi metaStore );  NamedClusterProvider( HadoopFileSystemLocator hadoopFileSystemLocator,
                               NamedClusterService namedClusterService,
                               FileNameParser fileNameParser,
                               String schema,
                               MetastoreLocatorOsgi metaStore );  NamedClusterProvider( HadoopFileSystemLocator hadoopFileSystemLocator,
                               NamedClusterService namedClusterService,
                               DefaultFileSystemManager fileSystemManager,
                               FileNameParser fileNameParser,
                               String[] schemes,
                               MetastoreLocatorOsgi metaStore ); @Override FileSystemConfigBuilder getConfigBuilder(); void closeFileSystem( String embeddedMetastoreKey ); }
NamedClusterProvider extends HDFSFileProvider implements VfsEmbeddedFileSystemCloser { NamedCluster getNamedClusterByName( String clusterNameToResolve, FileSystemOptions fileSystemOptions ) throws FileSystemException { IMetaStore metaStore = getMetastore( clusterNameToResolve, fileSystemOptions ); NamedCluster namedCluster = null; try { namedCluster = namedClusterService.read( clusterNameToResolve, metaStore ); } catch ( MetaStoreException e ) { throw new FileSystemException( e ); } return namedCluster; } NamedClusterProvider( HadoopFileSystemLocator hadoopFileSystemLocator,
                               NamedClusterService namedClusterService,
                               FileNameParser fileNameParser,
                               String[] schemes,
                               MetastoreLocatorOsgi metaStore );  NamedClusterProvider( HadoopFileSystemLocator hadoopFileSystemLocator,
                               NamedClusterService namedClusterService,
                               FileNameParser fileNameParser,
                               String schema,
                               MetastoreLocatorOsgi metaStore );  NamedClusterProvider( HadoopFileSystemLocator hadoopFileSystemLocator,
                               NamedClusterService namedClusterService,
                               DefaultFileSystemManager fileSystemManager,
                               FileNameParser fileNameParser,
                               String[] schemes,
                               MetastoreLocatorOsgi metaStore ); @Override FileSystemConfigBuilder getConfigBuilder(); void closeFileSystem( String embeddedMetastoreKey );  }