public class SecurityConfiguration extends Object
See SecurityOptions
for corresponding configuration options.
Constructor and Description |
---|
SecurityConfiguration(Configuration flinkConf)
Create a security configuration from the global configuration.
|
SecurityConfiguration(Configuration flinkConf,
List<SecurityModuleFactory> securityModuleFactories)
Create a security configuration from the global configuration.
|
Modifier and Type | Method and Description |
---|---|
Configuration |
getFlinkConfig() |
String |
getKeytab() |
List<String> |
getLoginContextNames() |
String |
getPrincipal() |
List<SecurityModuleFactory> |
getSecurityModuleFactories() |
String |
getZooKeeperLoginContextName() |
String |
getZooKeeperServiceName() |
boolean |
isZkSaslDisable() |
boolean |
useTicketCache() |
public SecurityConfiguration(Configuration flinkConf)
flinkConf
- the Flink global configuration.public SecurityConfiguration(Configuration flinkConf, List<SecurityModuleFactory> securityModuleFactories)
flinkConf
- the Flink global configuration.securityModuleFactories
- the security modules to apply.public boolean isZkSaslDisable()
public String getKeytab()
public String getPrincipal()
public boolean useTicketCache()
public Configuration getFlinkConfig()
public List<SecurityModuleFactory> getSecurityModuleFactories()
public String getZooKeeperServiceName()
public String getZooKeeperLoginContextName()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.