public class HadoopUtils extends Object
Constructor and Description |
---|
HadoopUtils() |
Modifier and Type | Method and Description |
---|---|
static Configuration |
getHadoopConfiguration(Configuration flinkConfiguration) |
static boolean |
hasHDFSDelegationToken()
Indicates whether the current user has an HDFS delegation token.
|
static boolean |
isMinHadoopVersion(int major,
int minor)
Checks if the Hadoop dependency is at least of the given version.
|
public static Configuration getHadoopConfiguration(Configuration flinkConfiguration)
public static boolean hasHDFSDelegationToken() throws Exception
Exception
public static boolean isMinHadoopVersion(int major, int minor) throws FlinkRuntimeException
FlinkRuntimeException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.