public class LlapUtil extends Object
Modifier and Type | Class and Description |
---|---|
static class |
LlapUtil.StatisticsData |
Modifier and Type | Field and Description |
---|---|
static char |
DERIVED_ENTITY_PARTITION_SEPARATOR |
Constructor and Description |
---|
LlapUtil() |
Modifier and Type | Method and Description |
---|---|
static List<LlapUtil.StatisticsData> |
cloneThreadLocalFileSystemStatistics() |
static org.apache.hadoop.ipc.RPC.Server |
createRpcServer(Class<?> pbProtocol,
InetSocketAddress addr,
org.apache.hadoop.conf.Configuration conf,
int numHandlers,
com.google.protobuf.BlockingService blockingService,
org.apache.hadoop.security.token.SecretManager<?> secretManager,
org.apache.hadoop.security.authorize.PolicyProvider provider,
HiveConf.ConfVars... aclVars) |
static String |
generateClusterName(org.apache.hadoop.conf.Configuration conf) |
static String |
getAmHostNameFromAddress(InetSocketAddress address,
org.apache.hadoop.conf.Configuration conf) |
static Map<String,org.apache.hadoop.fs.FileSystem.Statistics> |
getCombinedFileSystemStatistics() |
static String |
getDaemonLocalDirString(org.apache.hadoop.conf.Configuration conf,
String workDirsEnvString) |
static String |
getDbAndTableNameForMetrics(org.apache.hadoop.fs.Path path,
boolean includeParts) |
static List<LlapUtil.StatisticsData> |
getStatisticsForScheme(String scheme,
List<LlapUtil.StatisticsData> stats) |
static String |
getUserNameFromPrincipal(String principal) |
static String |
humanReadableByteCount(long bytes) |
static org.apache.hadoop.security.UserGroupInformation |
loginWithKerberos(String principal,
String keytabFile)
Login using kerberos.
|
static void |
loginWithKerberosAndUpdateCurrentUser(String principal,
String keytabFile)
Login using kerberos and also updates the current logged in user
|
static org.apache.hadoop.ipc.RPC.Server |
startProtocolServer(int srvPort,
int numHandlers,
AtomicReference<InetSocketAddress> bindAddress,
org.apache.hadoop.conf.Configuration conf,
com.google.protobuf.BlockingService impl,
Class<?> protocolClass,
org.apache.hadoop.security.token.SecretManager<?> secretManager,
org.apache.hadoop.security.authorize.PolicyProvider provider,
HiveConf.ConfVars... aclVars) |
public static final char DERIVED_ENTITY_PARTITION_SEPARATOR
public static String getDaemonLocalDirString(org.apache.hadoop.conf.Configuration conf, String workDirsEnvString)
public static org.apache.hadoop.security.UserGroupInformation loginWithKerberos(String principal, String keytabFile) throws IOException
principal
- - kerberos principalkeytabFile
- - keytab fileIOException
- - if keytab file cannot be foundpublic static void loginWithKerberosAndUpdateCurrentUser(String principal, String keytabFile) throws IOException
principal
- - kerberos principalkeytabFile
- - keytab fileIOException
- - if keytab file cannot be foundpublic static String generateClusterName(org.apache.hadoop.conf.Configuration conf)
public static List<LlapUtil.StatisticsData> getStatisticsForScheme(String scheme, List<LlapUtil.StatisticsData> stats)
public static Map<String,org.apache.hadoop.fs.FileSystem.Statistics> getCombinedFileSystemStatistics()
public static List<LlapUtil.StatisticsData> cloneThreadLocalFileSystemStatistics()
public static String getAmHostNameFromAddress(InetSocketAddress address, org.apache.hadoop.conf.Configuration conf)
public static String humanReadableByteCount(long bytes)
public static org.apache.hadoop.ipc.RPC.Server createRpcServer(Class<?> pbProtocol, InetSocketAddress addr, org.apache.hadoop.conf.Configuration conf, int numHandlers, com.google.protobuf.BlockingService blockingService, org.apache.hadoop.security.token.SecretManager<?> secretManager, org.apache.hadoop.security.authorize.PolicyProvider provider, HiveConf.ConfVars... aclVars) throws IOException
IOException
public static org.apache.hadoop.ipc.RPC.Server startProtocolServer(int srvPort, int numHandlers, AtomicReference<InetSocketAddress> bindAddress, org.apache.hadoop.conf.Configuration conf, com.google.protobuf.BlockingService impl, Class<?> protocolClass, org.apache.hadoop.security.token.SecretManager<?> secretManager, org.apache.hadoop.security.authorize.PolicyProvider provider, HiveConf.ConfVars... aclVars)
public static String getDbAndTableNameForMetrics(org.apache.hadoop.fs.Path path, boolean includeParts)
Copyright © 2022 The Apache Software Foundation. All rights reserved.