Package com.google.cloud.hadoop.fs.gcs.auth

Class GcsDtFetcher

java.lang.Object

com.google.cloud.hadoop.fs.gcs.auth.GcsDtFetcher

All Implemented Interfaces:

org.apache.hadoop.security.token.DtFetcher

public class GcsDtFetcher
extends Object
implements org.apache.hadoop.security.token.DtFetcher

A DT fetcher for GCS. This is a copy-and-paste of org.apache.hadoop.hdfs.HdfsDtFetcher.

Constructor Summary

Constructors

Constructor	Description
GcsDtFetcher()

Method Summary

Modifier and Type	Method	Description
org.apache.hadoop.security.token.Token<?>	addDelegationTokens(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.Credentials creds, String renewer, String url)	Returns Token object via FileSystem, null if bad argument.
org.apache.hadoop.io.Text	getServiceName()	Returns the service name for GCS, which is also a valid URL prefix.
boolean	isTokenRequired()

Methods inherited from class java.lang.Object

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

Constructor Details

GcsDtFetcher

public GcsDtFetcher()

Method Details

getServiceName

public org.apache.hadoop.io.Text getServiceName()

Returns the service name for GCS, which is also a valid URL prefix.

Specified by:

getServiceName in interface org.apache.hadoop.security.token.DtFetcher

isTokenRequired

public boolean isTokenRequired()

Specified by:

isTokenRequired in interface org.apache.hadoop.security.token.DtFetcher

addDelegationTokens

public org.apache.hadoop.security.token.Token<?> addDelegationTokens(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.security.Credentials creds,
 String renewer,
 String url)
                                                              throws Exception

Returns Token object via FileSystem, null if bad argument.

Specified by:

addDelegationTokens in interface org.apache.hadoop.security.token.DtFetcher

Parameters:

conf - - a Configuration object used with FileSystem.get()

creds - - a Credentials object to which token(s) will be added

renewer - - the renewer to send with the token request

url - - the URL to which the request is sent

Returns:

a Token, or null if fetch fails.

Throws:

Exception