class 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
      );
    }
  }

}