org.apache.hadoop.crypto.key.kms.KMSClientProvider.createKey()方法的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(9.0k)|赞(0)|评价(0)|浏览(105)

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

KMSClientProvider.createKey介绍

暂无

代码示例

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

@Override
 public KeyVersion call(KMSClientProvider provider) throws IOException {
  return provider.createKey(name, material, options);
 }
}, nextIdx(), false);

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

@Override
 public KeyVersion call(KMSClientProvider provider) throws IOException,
   NoSuchAlgorithmException {
  return provider.createKey(name, options);
 }
}, nextIdx(), false);

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

@Override
 public KeyVersion call(KMSClientProvider provider) throws IOException {
  return provider.createKey(name, material, options);
 }
}, nextIdx());

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

@Override
 public KeyVersion call(KMSClientProvider provider) throws IOException {
  return provider.createKey(name, material, options);
 }
}, nextIdx());

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

@Override
 public KeyVersion call(KMSClientProvider provider) throws IOException {
  return provider.createKey(name, material, options);
 }
}, nextIdx());

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

@Override
 public KeyVersion call(KMSClientProvider provider) throws IOException,
   NoSuchAlgorithmException {
  return provider.createKey(name, options);
 }
}, nextIdx());

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

@Override
 public KeyVersion call(KMSClientProvider provider) throws IOException,
   NoSuchAlgorithmException {
  return provider.createKey(name, options);
 }
}, nextIdx());

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

@Override
 public KeyVersion call(KMSClientProvider provider) throws IOException {
  return provider.createKey(name, material, options);
 }
}, nextIdx());

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

@Override
 public KeyVersion call(KMSClientProvider provider) throws IOException,
   NoSuchAlgorithmException {
  return provider.createKey(name, options);
 }
}, nextIdx());

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

@Override
 public KeyVersion call(KMSClientProvider provider) throws IOException,
   NoSuchAlgorithmException {
  return provider.createKey(name, options);
 }
}, nextIdx());

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

@Test
 public void testLoadBalancingWithAllBadNodes() throws Exception {
  Configuration conf = new Configuration();
  KMSClientProvider p1 = mock(KMSClientProvider.class);
  when(p1.createKey(Mockito.anyString(), Mockito.any(Options.class)))
    .thenThrow(new IOException("p1"));
  KMSClientProvider p2 = mock(KMSClientProvider.class);
  when(p2.createKey(Mockito.anyString(), Mockito.any(Options.class)))
    .thenThrow(new IOException("p2"));
  KMSClientProvider p3 = mock(KMSClientProvider.class);
  when(p3.createKey(Mockito.anyString(), Mockito.any(Options.class)))
    .thenThrow(new IOException("p3"));
  KMSClientProvider p4 = mock(KMSClientProvider.class);
  when(p4.createKey(Mockito.anyString(), Mockito.any(Options.class)))
    .thenThrow(new IOException("p4"));
  when(p1.getKMSUrl()).thenReturn("p1");
  when(p2.getKMSUrl()).thenReturn("p2");
  when(p3.getKMSUrl()).thenReturn("p3");
  when(p4.getKMSUrl()).thenReturn("p4");
  KeyProvider kp = new LoadBalancingKMSClientProvider(
    new KMSClientProvider[] { p1, p2, p3, p4 }, 0, conf);
  try {
   kp.createKey("test3", new Options(conf)).getName();
   fail("Should fail since all providers threw an IOException");
  } catch (Exception e) {
   assertTrue(e instanceof IOException);
  }
 }
}

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

@Test
 public void testLoadBalancingWithAllBadNodes() throws Exception {
  Configuration conf = new Configuration();
  KMSClientProvider p1 = mock(KMSClientProvider.class);
  when(p1.createKey(Mockito.anyString(), Mockito.any(Options.class)))
    .thenThrow(new IOException("p1"));
  KMSClientProvider p2 = mock(KMSClientProvider.class);
  when(p2.createKey(Mockito.anyString(), Mockito.any(Options.class)))
    .thenThrow(new IOException("p2"));
  KMSClientProvider p3 = mock(KMSClientProvider.class);
  when(p3.createKey(Mockito.anyString(), Mockito.any(Options.class)))
    .thenThrow(new IOException("p3"));
  KMSClientProvider p4 = mock(KMSClientProvider.class);
  when(p4.createKey(Mockito.anyString(), Mockito.any(Options.class)))
    .thenThrow(new IOException("p4"));
  when(p1.getKMSUrl()).thenReturn("p1");
  when(p2.getKMSUrl()).thenReturn("p2");
  when(p3.getKMSUrl()).thenReturn("p3");
  when(p4.getKMSUrl()).thenReturn("p4");
  KeyProvider kp = new LoadBalancingKMSClientProvider(
    new KMSClientProvider[] { p1, p2, p3, p4 }, 0, conf);
  try {
   kp.createKey("test3", new Options(conf)).getName();
   fail("Should fail since all providers threw an IOException");
  } catch (Exception e) {
   assertTrue(e instanceof IOException);
  }
 }
}

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

@Test
public void testLoadBalancing() throws Exception {
 Configuration conf = new Configuration();
 KMSClientProvider p1 = mock(KMSClientProvider.class);
 when(p1.createKey(Mockito.anyString(), Mockito.any(Options.class)))
   .thenReturn(
     new KMSClientProvider.KMSKeyVersion("p1", "v1", new byte[0]));
 KMSClientProvider p2 = mock(KMSClientProvider.class);
 when(p2.createKey(Mockito.anyString(), Mockito.any(Options.class)))
   .thenReturn(
     new KMSClientProvider.KMSKeyVersion("p2", "v2", new byte[0]));
 KMSClientProvider p3 = mock(KMSClientProvider.class);
 when(p3.createKey(Mockito.anyString(), Mockito.any(Options.class)))
   .thenReturn(
     new KMSClientProvider.KMSKeyVersion("p3", "v3", new byte[0]));
 KeyProvider kp = new LoadBalancingKMSClientProvider(
   new KMSClientProvider[] { p1, p2, p3 }, 0, conf);
 assertEquals("p1", kp.createKey("test1", new Options(conf)).getName());
 assertEquals("p2", kp.createKey("test2", new Options(conf)).getName());
 assertEquals("p3", kp.createKey("test3", new Options(conf)).getName());
 assertEquals("p1", kp.createKey("test4", new Options(conf)).getName());
}

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

Configuration conf = new Configuration();
KMSClientProvider p1 = mock(KMSClientProvider.class);
when(p1.createKey(Mockito.anyString(), Mockito.any(Options.class)))
  .thenReturn(
    new KMSClientProvider.KMSKeyVersion("p1", "v1", new byte[0]));
when(p2.createKey(Mockito.anyString(), Mockito.any(Options.class)))
  .thenThrow(new NoSuchAlgorithmException("p2"));
when(p2.getKMSUrl()).thenReturn("p2");
KMSClientProvider p3 = mock(KMSClientProvider.class);
when(p3.createKey(Mockito.anyString(), Mockito.any(Options.class)))
  .thenReturn(
    new KMSClientProvider.KMSKeyVersion("p3", "v3", new byte[0]));
when(p4.createKey(Mockito.anyString(), Mockito.any(Options.class)))
  .thenThrow(new IOException("p4"));
when(p4.getKMSUrl()).thenReturn("p4");

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

@Test
public void testLoadBalancing() throws Exception {
 Configuration conf = new Configuration();
 KMSClientProvider p1 = mock(KMSClientProvider.class);
 when(p1.createKey(Mockito.anyString(), Mockito.any(Options.class)))
   .thenReturn(
     new KMSClientProvider.KMSKeyVersion("p1", "v1", new byte[0]));
 KMSClientProvider p2 = mock(KMSClientProvider.class);
 when(p2.createKey(Mockito.anyString(), Mockito.any(Options.class)))
   .thenReturn(
     new KMSClientProvider.KMSKeyVersion("p2", "v2", new byte[0]));
 KMSClientProvider p3 = mock(KMSClientProvider.class);
 when(p3.createKey(Mockito.anyString(), Mockito.any(Options.class)))
   .thenReturn(
     new KMSClientProvider.KMSKeyVersion("p3", "v3", new byte[0]));
 KeyProvider kp = new LoadBalancingKMSClientProvider(
   new KMSClientProvider[] { p1, p2, p3 }, 0, conf);
 assertEquals("p1", kp.createKey("test1", new Options(conf)).getName());
 assertEquals("p2", kp.createKey("test2", new Options(conf)).getName());
 assertEquals("p3", kp.createKey("test3", new Options(conf)).getName());
 assertEquals("p1", kp.createKey("test4", new Options(conf)).getName());
}

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

Configuration conf = new Configuration();
KMSClientProvider p1 = mock(KMSClientProvider.class);
when(p1.createKey(Mockito.anyString(), Mockito.any(Options.class)))
  .thenReturn(
    new KMSClientProvider.KMSKeyVersion("p1", "v1", new byte[0]));
when(p2.createKey(Mockito.anyString(), Mockito.any(Options.class)))
  .thenThrow(new NoSuchAlgorithmException("p2"));
when(p2.getKMSUrl()).thenReturn("p2");
KMSClientProvider p3 = mock(KMSClientProvider.class);
when(p3.createKey(Mockito.anyString(), Mockito.any(Options.class)))
  .thenReturn(
    new KMSClientProvider.KMSKeyVersion("p3", "v3", new byte[0]));
when(p4.createKey(Mockito.anyString(), Mockito.any(Options.class)))
  .thenThrow(new IOException("p4"));
when(p4.getKMSUrl()).thenReturn("p4");

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

options.setBitLength(128);
options.setDescription("l1");
KeyProvider.KeyVersion kv0 = kmscp.createKey(keyName, options);
assertNotNull(kv0.getVersionName());

内容来源于网络，如有侵权，请联系作者删除！

KMSClientProvider

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    KMSClientProvider类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com