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 Configuration	getHadoopConfiguration(Configuration flinkConfiguration)
static boolean	hasHDFSDelegationToken() Indicates whether the current user has an HDFS delegation token.

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 Configuration getHadoopConfiguration(Configuration flinkConfiguration)

hasHDFSDelegationToken

public static boolean hasHDFSDelegationToken()
                                      throws Exception

Indicates whether the current user has an HDFS delegation token.

Throws:

Exception