@Test public void testRead() throws MetaStoreException { String testName = "testName"; NamedClusterImpl namedCluster = new NamedClusterImpl(); when( metaStoreFactory.loadElement( testName ) ).thenReturn( namedCluster ); assertTrue( namedCluster == namedClusterManager.read( testName, metaStore ) ); }
@Override public NamedCluster read( String clusterName, IMetaStore metastore ) throws MetaStoreException { MetaStoreFactory<NamedClusterImpl> factory = getMetaStoreFactory( metastore ); if ( metastore == null || !listNames( metastore ).contains( clusterName ) ) { IMetaStore slaveMetastore = getSlaveServerMetastore(); if ( slaveMetastore != null && listNames( slaveMetastore ).contains( clusterName ) ) { factory = getMetaStoreFactory( slaveMetastore ); } } NamedCluster namedCluster = null; try { namedCluster = factory.loadElement( clusterName ); } catch ( MetaStoreException e ) { namedCluster = factory.loadElement( clusterName, false ); } return namedCluster; }
NamedClusterManager implements NamedClusterService { @Override public NamedCluster read( String clusterName, IMetaStore metastore ) throws MetaStoreException { MetaStoreFactory<NamedClusterImpl> factory = getMetaStoreFactory( metastore ); if ( metastore == null || !listNames( metastore ).contains( clusterName ) ) { IMetaStore slaveMetastore = getSlaveServerMetastore(); if ( slaveMetastore != null && listNames( slaveMetastore ).contains( clusterName ) ) { factory = getMetaStoreFactory( slaveMetastore ); } } NamedCluster namedCluster = null; try { namedCluster = factory.loadElement( clusterName ); } catch ( MetaStoreException e ) { namedCluster = factory.loadElement( clusterName, false ); } return namedCluster; } }
NamedClusterManager implements NamedClusterService { @Override public NamedCluster read( String clusterName, IMetaStore metastore ) throws MetaStoreException { MetaStoreFactory<NamedClusterImpl> factory = getMetaStoreFactory( metastore ); if ( metastore == null || !listNames( metastore ).contains( clusterName ) ) { IMetaStore slaveMetastore = getSlaveServerMetastore(); if ( slaveMetastore != null && listNames( slaveMetastore ).contains( clusterName ) ) { factory = getMetaStoreFactory( slaveMetastore ); } } NamedCluster namedCluster = null; try { namedCluster = factory.loadElement( clusterName ); } catch ( MetaStoreException e ) { namedCluster = factory.loadElement( clusterName, false ); } return namedCluster; }  }
NamedClusterManager implements NamedClusterService { @Override public NamedCluster read( String clusterName, IMetaStore metastore ) throws MetaStoreException { MetaStoreFactory<NamedClusterImpl> factory = getMetaStoreFactory( metastore ); if ( metastore == null || !listNames( metastore ).contains( clusterName ) ) { IMetaStore slaveMetastore = getSlaveServerMetastore(); if ( slaveMetastore != null && listNames( slaveMetastore ).contains( clusterName ) ) { factory = getMetaStoreFactory( slaveMetastore ); } } NamedCluster namedCluster = null; try { namedCluster = factory.loadElement( clusterName ); } catch ( MetaStoreException e ) { namedCluster = factory.loadElement( clusterName, false ); } return namedCluster; }  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 NamedCluster read( String clusterName, IMetaStore metastore ) throws MetaStoreException { MetaStoreFactory<NamedClusterImpl> factory = getMetaStoreFactory( metastore ); if ( metastore == null || !listNames( metastore ).contains( clusterName ) ) { IMetaStore slaveMetastore = getSlaveServerMetastore(); if ( slaveMetastore != null && listNames( slaveMetastore ).contains( clusterName ) ) { factory = getMetaStoreFactory( slaveMetastore ); } } NamedCluster namedCluster = null; try { namedCluster = factory.loadElement( clusterName ); } catch ( MetaStoreException e ) { namedCluster = factory.loadElement( clusterName, false ); } return namedCluster; }  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; }