org.apache.flink.runtime.util

Class HadoopUtils

java.lang.Object

org.apache.flink.runtime.util.HadoopUtils

public class HadoopUtils
extends Object

Utility class for working with Hadoop-related classes. This should only be used if Hadoop is on the classpath.

Constructor Summary

Constructors

Constructor and Description
HadoopUtils()

Method Summary

Modifier and Type	Method and Description
static boolean	areKerberosCredentialsValid(org.apache.hadoop.security.UserGroupInformation ugi, boolean useTicketCache)
static org.apache.hadoop.conf.Configuration	getHadoopConfiguration(Configuration flinkConfiguration)
static boolean	hasHDFSDelegationToken(org.apache.hadoop.security.UserGroupInformation ugi) Indicates whether the user has an HDFS delegation token.
static boolean	isKerberosSecurityEnabled(org.apache.hadoop.security.UserGroupInformation ugi)
static boolean	isMaxHadoopVersion(int major, int minor) Checks if the Hadoop dependency is at most the given version.
static boolean	isMinHadoopVersion(int major, int minor) Checks if the Hadoop dependency is at least the given version.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HadoopUtils

public HadoopUtils()

Method Detail

getHadoopConfiguration

public static org.apache.hadoop.conf.Configuration getHadoopConfiguration(Configuration flinkConfiguration)

isKerberosSecurityEnabled

public static boolean isKerberosSecurityEnabled(org.apache.hadoop.security.UserGroupInformation ugi)

areKerberosCredentialsValid

public static boolean areKerberosCredentialsValid(org.apache.hadoop.security.UserGroupInformation ugi,
                                                  boolean useTicketCache)

hasHDFSDelegationToken

public static boolean hasHDFSDelegationToken(org.apache.hadoop.security.UserGroupInformation ugi)

Indicates whether the user has an HDFS delegation token.

isMinHadoopVersion

public static boolean isMinHadoopVersion(int major,
                                         int minor)
                                  throws FlinkRuntimeException

Checks if the Hadoop dependency is at least the given version.

Throws:

FlinkRuntimeException

isMaxHadoopVersion

public static boolean isMaxHadoopVersion(int major,
                                         int minor)
                                  throws FlinkRuntimeException

Checks if the Hadoop dependency is at most the given version.

Throws:

FlinkRuntimeException