public static class SecurityUtils.SecurityConfiguration extends Object
SecurityOptions
for corresponding configuration options.Constructor and Description |
---|
SecurityConfiguration(Configuration flinkConf)
Create a security configuration from the global configuration.
|
SecurityConfiguration(Configuration flinkConf,
org.apache.hadoop.conf.Configuration hadoopConf)
Create a security configuration from the global configuration.
|
SecurityConfiguration(Configuration flinkConf,
org.apache.hadoop.conf.Configuration hadoopConf,
List<? extends Class<? extends SecurityModule>> securityModules)
Create a security configuration from the global configuration.
|
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.conf.Configuration |
getHadoopConfiguration() |
String |
getKeytab() |
List<String> |
getLoginContextNames() |
String |
getPrincipal() |
List<Class<? extends SecurityModule>> |
getSecurityModules() |
String |
getZooKeeperLoginContextName() |
String |
getZooKeeperServiceName() |
boolean |
useTicketCache() |
public SecurityConfiguration(Configuration flinkConf)
flinkConf
- the Flink global configuration.public SecurityConfiguration(Configuration flinkConf, org.apache.hadoop.conf.Configuration hadoopConf)
flinkConf
- the Flink global configuration.hadoopConf
- the Hadoop configuration.public SecurityConfiguration(Configuration flinkConf, org.apache.hadoop.conf.Configuration hadoopConf, List<? extends Class<? extends SecurityModule>> securityModules)
flinkConf
- the Flink global configuration.hadoopConf
- the Hadoop configuration.securityModules
- the security modules to apply.public String getKeytab()
public String getPrincipal()
public boolean useTicketCache()
public org.apache.hadoop.conf.Configuration getHadoopConfiguration()
public List<Class<? extends SecurityModule>> getSecurityModules()
public String getZooKeeperServiceName()
public String getZooKeeperLoginContextName()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.