本文整理了Java中org.apache.hadoop.crypto.key.kms.KMSClientProvider.<init>()方法的一些代码示例，展示了KMSClientProvider.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。KMSClientProvider.<init>()方法的具体详情如下：
包路径：org.apache.hadoop.crypto.key.kms.KMSClientProvider
类名称：KMSClientProvider
方法名：<init>

KMSClientProvider.<init>介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

private KMSClientProvider[] createProviders(Configuration conf,
   URL origUrl, int port, String hostsPart) throws IOException {
  String[] hosts = hostsPart.split(";");
  KMSClientProvider[] providers = new KMSClientProvider[hosts.length];
  for (int i = 0; i < hosts.length; i++) {
   try {
    providers[i] =
      new KMSClientProvider(
        new URI("kms", origUrl.getProtocol(), hosts[i], port,
          origUrl.getPath(), null, null), conf);
   } catch (URISyntaxException e) {
    throw new IOException("Could not instantiate KMSProvider.", e);
   }
  }
  return providers;
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

private KeyProvider createProvider(URI providerUri, Configuration conf,
   URL origUrl, int port, String hostsPart) throws IOException {
  String[] hosts = hostsPart.split(";");
  if (hosts.length == 1) {
   return new KMSClientProvider(providerUri, conf);
  } else {
   KMSClientProvider[] providers = new KMSClientProvider[hosts.length];
   for (int i = 0; i < hosts.length; i++) {
    try {
     providers[i] =
       new KMSClientProvider(
         new URI("kms", origUrl.getProtocol(), hosts[i], port,
           origUrl.getPath(), null, null), conf);
    } catch (URISyntaxException e) {
     throw new IOException("Could not instantiate KMSProvider..", e);
    }
   }
   return new LoadBalancingKMSClientProvider(providers, conf);
  }
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

private KeyProvider createProvider(URI providerUri, Configuration conf,
   URL origUrl, int port, String hostsPart) throws IOException {
  String[] hosts = hostsPart.split(";");
  if (hosts.length == 1) {
   return new KMSClientProvider(providerUri, conf);
  } else {
   KMSClientProvider[] providers = new KMSClientProvider[hosts.length];
   for (int i = 0; i < hosts.length; i++) {
    try {
     providers[i] =
       new KMSClientProvider(
         new URI("kms", origUrl.getProtocol(), hosts[i], port,
           origUrl.getPath(), null, null), conf);
    } catch (URISyntaxException e) {
     throw new IOException("Could not instantiate KMSProvider..", e);
    }
   }
   return new LoadBalancingKMSClientProvider(providers, conf);
  }
 }
}

代码示例来源：origin: io.hops/hadoop-common

private KeyProvider createProvider(URI providerUri, Configuration conf,
   URL origUrl, int port, String hostsPart) throws IOException {
  String[] hosts = hostsPart.split(";");
  if (hosts.length == 1) {
   return new KMSClientProvider(providerUri, conf);
  } else {
   KMSClientProvider[] providers = new KMSClientProvider[hosts.length];
   for (int i = 0; i < hosts.length; i++) {
    try {
     providers[i] =
       new KMSClientProvider(
         new URI("kms", origUrl.getProtocol(), hosts[i], port,
           origUrl.getPath(), null, null), conf);
    } catch (URISyntaxException e) {
     throw new IOException("Could not instantiate KMSProvider..", e);
    }
   }
   return new LoadBalancingKMSClientProvider(providers, conf);
  }
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

private KeyProvider createProvider(URI providerUri, Configuration conf,
   URL origUrl, int port, String hostsPart) throws IOException {
  String[] hosts = hostsPart.split(";");
  if (hosts.length == 1) {
   return new KMSClientProvider(providerUri, conf);
  } else {
   KMSClientProvider[] providers = new KMSClientProvider[hosts.length];
   for (int i = 0; i < hosts.length; i++) {
    try {
     providers[i] =
       new KMSClientProvider(
         new URI("kms", origUrl.getProtocol(), hosts[i], port,
           origUrl.getPath(), null, null), conf);
    } catch (URISyntaxException e) {
     throw new IOException("Could not instantiate KMSProvider..", e);
    }
   }
   return new LoadBalancingKMSClientProvider(providers, conf);
  }
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-kms

private KMSClientProvider createKMSClientProvider(URI uri, Configuration conf)
  throws IOException {
 final KMSClientProvider ret = new KMSClientProvider(uri, conf);
 providersCreated.add(ret);
 return ret;
}

代码示例来源：origin: ch.cern.hadoop/hadoop-kms

protected KeyProvider createProvider(URI uri, Configuration conf)
  throws IOException {
 return new LoadBalancingKMSClientProvider(
   new KMSClientProvider[] { new KMSClientProvider(uri, conf) }, conf);
}

代码示例来源：origin: org.apache.hadoop/hadoop-kms

protected KeyProvider createProvider(URI uri, Configuration conf)
  throws IOException {
 final KeyProvider ret = new LoadBalancingKMSClientProvider(uri,
   new KMSClientProvider[] {new KMSClientProvider(uri, conf)}, conf);
 providersCreated.add(ret);
 return ret;
}

代码示例来源：origin: org.apache.hadoop/hadoop-kms

/**
* create a LoadBalancingKMSClientProvider from an array of URIs.
* @param uris an array of KMS URIs
* @param conf configuration object
* @return a LoadBalancingKMSClientProvider object
* @throws IOException
*/
protected LoadBalancingKMSClientProvider createHAProvider(URI lbUri,
  URI[] uris, Configuration conf) throws IOException {
 KMSClientProvider[] providers = new KMSClientProvider[uris.length];
 for (int i = 0; i < providers.length; i++) {
  providers[i] =
    new KMSClientProvider(uris[i], conf);
 }
 final LoadBalancingKMSClientProvider ret =
   new LoadBalancingKMSClientProvider(lbUri, providers, conf);
 providersCreated.add(ret);
 return ret;
}