@Test public void testGetNamedClusterList() throws Exception { assertEquals( namedClusterList, impalaDatabaseMeta.getNamedClusterList() ); verify( namedClusterService ).listNames( iMetaStoreCaptor.capture() ); }
@Override public List<String> getNamedClusterList() { try { return namedClusterService.listNames( metastoreLocator.getMetastore() ); } catch ( MetaStoreException e ) { logChannel.error( e.getMessage(), e ); return Collections.emptyList(); } }
ImpalaDatabaseMeta extends Hive2DatabaseMeta implements DatabaseInterface { @Override public List<String> getNamedClusterList() { try { return namedClusterService.listNames( metastoreLocator.getMetastore() ); } catch ( MetaStoreException e ) { logChannel.error( e.getMessage(), e ); return Collections.emptyList(); } } }
ImpalaDatabaseMeta extends Hive2DatabaseMeta implements DatabaseInterface { @Override public List<String> getNamedClusterList() { try { return namedClusterService.listNames( metastoreLocator.getMetastore() ); } catch ( MetaStoreException e ) { logChannel.error( e.getMessage(), e ); return Collections.emptyList(); } } ImpalaDatabaseMeta( DriverLocator driverLocator, NamedClusterService namedClusterService,
                             MetastoreLocator metastoreLocator ); }
ImpalaDatabaseMeta extends Hive2DatabaseMeta implements DatabaseInterface { @Override public List<String> getNamedClusterList() { try { return namedClusterService.listNames( metastoreLocator.getMetastore() ); } catch ( MetaStoreException e ) { logChannel.error( e.getMessage(), e ); return Collections.emptyList(); } } ImpalaDatabaseMeta( DriverLocator driverLocator, NamedClusterService namedClusterService,
                             MetastoreLocator metastoreLocator ); @Override int[] getAccessTypeList(); @Override String getDriverClass(); @Override String getFieldDefinition( ValueMetaInterface v, String tk, String pk, boolean useAutoinc,
                                    boolean addFieldname, boolean addCr ); @Override String getURL( String hostname, String port, String databaseName ); @Override String[] getUsedLibraries(); @Override int getDefaultDatabasePort(); @Override List<String> getNamedClusterList(); @Override void putOptionalOptions( Map<String, String> extraOptions ); }
ImpalaDatabaseMeta extends Hive2DatabaseMeta implements DatabaseInterface { @Override public List<String> getNamedClusterList() { try { return namedClusterService.listNames( metastoreLocator.getMetastore() ); } catch ( MetaStoreException e ) { logChannel.error( e.getMessage(), e ); return Collections.emptyList(); } } ImpalaDatabaseMeta( DriverLocator driverLocator, NamedClusterService namedClusterService,
                             MetastoreLocator metastoreLocator ); @Override int[] getAccessTypeList(); @Override String getDriverClass(); @Override String getFieldDefinition( ValueMetaInterface v, String tk, String pk, boolean useAutoinc,
                                    boolean addFieldname, boolean addCr ); @Override String getURL( String hostname, String port, String databaseName ); @Override String[] getUsedLibraries(); @Override int getDefaultDatabasePort(); @Override List<String> getNamedClusterList(); @Override void putOptionalOptions( Map<String, String> extraOptions ); static final String AUTH_NO_SASL; }