gobblin.util.hadoop

Class TokenUtils

java.lang.Object

gobblin.util.hadoop.TokenUtils

public class TokenUtils
extends Object

A utility class for obtain Hadoop tokens and Hive metastore tokens for Azkaban jobs.

This class is compatible with Hadoop 2.

Constructor Summary

Constructors

Constructor and Description
TokenUtils()

Method Summary

Modifier and Type	Method and Description
static File	getHadoopTokens(State state) Get Hadoop tokens (tokens for job history server, job tracker and HDFS) using Kerberos keytab.

Methods inherited from class java.lang.Object

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

Constructor Detail

TokenUtils

public TokenUtils()

Method Detail

getHadoopTokens

public static File getHadoopTokens(State state)
                            throws IOException,
                                   InterruptedException

Get Hadoop tokens (tokens for job history server, job tracker and HDFS) using Kerberos keytab.

Parameters:

state - A State object that should contain property USER_TO_PROXY, KEYTAB_USER and KEYTAB_LOCATION. To obtain tokens for other namenodes, use property OTHER_NAMENODES with comma separated HDFS URIs.

Returns:

A File containing the negotiated credentials.

Throws:

IOException

InterruptedException