@Test public void testList() throws MetaStoreException { NamedClusterImpl namedCluster = new NamedClusterImpl(); namedCluster.setName( "testName" ); List<NamedClusterImpl> value = new ArrayList<>( Arrays.asList( namedCluster ) ); when( metaStoreFactory.getElements( anyBoolean(), any( List.class ) ) ).thenReturn( value ); assertEquals( value, namedClusterManager.list( metaStore ) ); }
@Override public List<NamedCluster> list( IMetaStore metastore ) throws MetaStoreException { MetaStoreFactory<NamedClusterImpl> factory = getMetaStoreFactory( metastore ); List<NamedCluster> namedClusters; List<MetaStoreException> exceptionList = new ArrayList<>(); try { namedClusters = new ArrayList<>( factory.getElements( true, exceptionList ) ); } catch ( MetaStoreException ex ) { namedClusters = new ArrayList<>( factory.getElements( false, exceptionList ) ); } return namedClusters; }
NamedClusterManager implements NamedClusterService { @Override public List<NamedCluster> list( IMetaStore metastore ) throws MetaStoreException { MetaStoreFactory<NamedClusterImpl> factory = getMetaStoreFactory( metastore ); List<NamedCluster> namedClusters; List<MetaStoreException> exceptionList = new ArrayList<>(); try { namedClusters = new ArrayList<>( factory.getElements( true, exceptionList ) ); } catch ( MetaStoreException ex ) { namedClusters = new ArrayList<>( factory.getElements( false, exceptionList ) ); } return namedClusters; } }
NamedClusterManager implements NamedClusterService { @Override public List<NamedCluster> list( IMetaStore metastore ) throws MetaStoreException { MetaStoreFactory<NamedClusterImpl> factory = getMetaStoreFactory( metastore ); List<NamedCluster> namedClusters; List<MetaStoreException> exceptionList = new ArrayList<>(); try { namedClusters = new ArrayList<>( factory.getElements( true, exceptionList ) ); } catch ( MetaStoreException ex ) { namedClusters = new ArrayList<>( factory.getElements( false, exceptionList ) ); } return namedClusters; }  }
NamedClusterManager implements NamedClusterService { @Override public List<NamedCluster> list( IMetaStore metastore ) throws MetaStoreException { MetaStoreFactory<NamedClusterImpl> factory = getMetaStoreFactory( metastore ); List<NamedCluster> namedClusters; List<MetaStoreException> exceptionList = new ArrayList<>(); try { namedClusters = new ArrayList<>( factory.getElements( true, exceptionList ) ); } catch ( MetaStoreException ex ) { namedClusters = new ArrayList<>( factory.getElements( false, exceptionList ) ); } return namedClusters; }  BundleContext getBundleContext(); void setBundleContext( BundleContext bundleContext ); @Override void close( IMetaStore metastore ); @Override NamedCluster getClusterTemplate(); @Override void setClusterTemplate( NamedCluster clusterTemplate ); @Override void create( NamedCluster namedCluster, IMetaStore metastore ); @Override NamedCluster read( String clusterName, IMetaStore metastore ); @Override void update( NamedCluster namedCluster, IMetaStore metastore ); @Override void delete( String clusterName, IMetaStore metastore ); @Override List<NamedCluster> list( IMetaStore metastore ); @Override List<NamedCluster> list( IMetaStore metastore, List<MetaStoreException> exceptionList ); @Override List<String> listNames( IMetaStore metastore ); @Override boolean contains( String clusterName, IMetaStore metastore ); @Override NamedCluster getNamedClusterByName( String namedClusterName, IMetaStore metastore ); Map<String, Object> getProperties(); @Override NamedCluster getNamedClusterByHost( String hostName, IMetaStore metastore ); @Override void updateNamedClusterTemplate( String hostName, int port, boolean isMapr ); }
NamedClusterManager implements NamedClusterService { @Override public List<NamedCluster> list( IMetaStore metastore ) throws MetaStoreException { MetaStoreFactory<NamedClusterImpl> factory = getMetaStoreFactory( metastore ); List<NamedCluster> namedClusters; List<MetaStoreException> exceptionList = new ArrayList<>(); try { namedClusters = new ArrayList<>( factory.getElements( true, exceptionList ) ); } catch ( MetaStoreException ex ) { namedClusters = new ArrayList<>( factory.getElements( false, exceptionList ) ); } return namedClusters; }  BundleContext getBundleContext(); void setBundleContext( BundleContext bundleContext ); @Override void close( IMetaStore metastore ); @Override NamedCluster getClusterTemplate(); @Override void setClusterTemplate( NamedCluster clusterTemplate ); @Override void create( NamedCluster namedCluster, IMetaStore metastore ); @Override NamedCluster read( String clusterName, IMetaStore metastore ); @Override void update( NamedCluster namedCluster, IMetaStore metastore ); @Override void delete( String clusterName, IMetaStore metastore ); @Override List<NamedCluster> list( IMetaStore metastore ); @Override List<NamedCluster> list( IMetaStore metastore, List<MetaStoreException> exceptionList ); @Override List<String> listNames( IMetaStore metastore ); @Override boolean contains( String clusterName, IMetaStore metastore ); @Override NamedCluster getNamedClusterByName( String namedClusterName, IMetaStore metastore ); Map<String, Object> getProperties(); @Override NamedCluster getNamedClusterByHost( String hostName, IMetaStore metastore ); @Override void updateNamedClusterTemplate( String hostName, int port, boolean isMapr ); static final String BIG_DATA_SLAVE_METASTORE_DIR; }