HadoopCredentialStoreConfigFilter extends AbstractConfigFilter { public void initializeWithConfiguration(Map<String, String> configuration) { LOGGER.debug("Initializing hadoop credential store."); hadoopConfiguration = new Configuration(); hadoopConfiguration.set( HADOOP_SECURITY + CREDENTIAL_PROVIDER_PATH, configuration.get(CREDENTIAL_PROVIDER_PATH) ); String passwordFile = configuration.get(PASSWORD_FILE_CONFIG_KEY); if (passwordFile != null && !passwordFile.isEmpty()) { checkPasswordFile(passwordFile); hadoopConfiguration.set( HADOOP_SECURITY + PASSWORD_FILE_CONFIG_KEY, passwordFile ); } }  void initializeWithConfiguration(Map<String, String> configuration); @Override String filter(String key);  }
@Test(expected = IllegalArgumentException.class) public void filterErrorWithNoProvider() { HashMap<String, String> configuration = new HashMap<>(); configFilter.initializeWithConfiguration(configuration); }