public class LlapUtil extends Object
Modifier and Type | Class and Description |
---|---|
static class |
LlapUtil.StatisticsData |
Constructor and Description |
---|
LlapUtil() |
Modifier and Type | Method and Description |
---|---|
static List<LlapUtil.StatisticsData> |
cloneThreadLocalFileSystemStatistics() |
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 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
|
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)
Copyright © 2021 The Apache Software Foundation. All rights reserved.