org.apache.hadoop.hive.shims

Class Hadoop20SShims

java.lang.Object

org.apache.hadoop.hive.shims.HadoopShimsSecure

org.apache.hadoop.hive.shims.Hadoop20SShims

All Implemented Interfaces:

HadoopShims

public class Hadoop20SShims
extends HadoopShimsSecure

Implemention of shims against Hadoop 0.20 with Security.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	Hadoop20SShims.Hadoop20SFileStatus
class	Hadoop20SShims.KerberosNameShim Shim for KerberosName
class	Hadoop20SShims.MiniDFSShim MiniDFSShim.
class	Hadoop20SShims.MiniMrShim Shim for MiniMrCluster

Nested classes/interfaces inherited from class org.apache.hadoop.hive.shims.HadoopShimsSecure

HadoopShimsSecure.CombineFileInputFormatShim<K,V>, HadoopShimsSecure.CombineFileRecordReader<K,V>, HadoopShimsSecure.InputSplitShim

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.shims.HadoopShims

HadoopShims.ByteBufferPoolShim, HadoopShims.DirectCompressionType, HadoopShims.DirectDecompressorShim, HadoopShims.HCatHadoopShims, HadoopShims.HdfsEncryptionShim, HadoopShims.HdfsFileStatus, HadoopShims.JobTrackerState, HadoopShims.NoopHdfsEncryptionShim, HadoopShims.StoragePolicyShim, HadoopShims.StoragePolicyValue, HadoopShims.WebHCatJTShim, HadoopShims.ZeroCopyReaderShim

Constructor Summary

Constructors

Constructor and Description
Hadoop20SShims()

Method Summary

Methods

Modifier and Type	Method and Description
void	addDelegationTokens(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.security.Credentials cred, String uname) Get Delegation token and add it to Credential.
HadoopShims.HdfsEncryptionShim	createHdfsEncryptionShim(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf) Returns a new instance of the HdfsEncryption shim.
org.apache.hadoop.fs.FileSystem	createProxyFileSystem(org.apache.hadoop.fs.FileSystem fs, URI uri) Create a proxy file system that can serve a given scheme/authority using some other file system.
HadoopShims.CombineFileInputFormatShim	getCombineFileInputFormat()
org.apache.hadoop.conf.Configuration	getConfiguration(org.apache.hadoop.mapreduce.JobContext context) Get configuration from JobContext
org.apache.hadoop.fs.Path	getCurrentTrashPath(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs)
long	getDefaultBlockSize(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) Get the default block size for the path.
short	getDefaultReplication(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) Get the default replication for a path.
HadoopShims.DirectDecompressorShim	getDirectDecompressor(HadoopShims.DirectCompressionType codec)
HadoopShims.HdfsFileStatus	getFullFileStatus(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file) For a given file, return a file status
Map<String,String>	getHadoopConfNames()
HadoopShims.HCatHadoopShims	getHCatShim()
org.apache.hadoop.mapred.JobConf	getJobConf(org.apache.hadoop.mapred.JobContext context) Get job conf from the old style JobContext.
String	getJobLauncherHttpAddress(org.apache.hadoop.conf.Configuration conf) All references to jobtracker/resource manager http address in the configuration should be done through this shim
String	getJobLauncherRpcAddress(org.apache.hadoop.conf.Configuration conf) All retrieval of jobtracker/resource manager rpc address in the configuration should be done through this shim
HadoopShims.JobTrackerState	getJobTrackerState(org.apache.hadoop.mapred.ClusterStatus clusterStatus) Convert the ClusterStatus to its Thrift equivalent: JobTrackerState.
Hadoop20SShims.KerberosNameShim	getKerberosNameShim(String name) Returns a shim to wrap KerberosName
org.apache.hadoop.fs.BlockLocation[]	getLocations(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus status) For file status returned by listLocatedStatus, convert them into a list of block locations.
TreeMap<Long,org.apache.hadoop.fs.BlockLocation>	getLocationsWithOffset(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus status) For the block locations returned by getLocations() convert them into a Treemap by iterating over the list of blockLocation.
Comparator<org.apache.hadoop.io.LongWritable>	getLongComparator()
void	getMergedCredentials(org.apache.hadoop.mapred.JobConf jobConf)
HadoopShims.MiniDFSShim	getMiniDfs(org.apache.hadoop.conf.Configuration conf, int numDataNodes, boolean format, String[] racks) Returns a shim to wrap MiniDFSCluster.
Hadoop20SShims.MiniMrShim	getMiniMrCluster(org.apache.hadoop.conf.Configuration conf, int numberOfTaskTrackers, String nameNode, int numDir) Returns a shim to wrap MiniMrCluster
Hadoop20SShims.MiniMrShim	getMiniSparkCluster(org.apache.hadoop.conf.Configuration conf, int numberOfTaskTrackers, String nameNode, int numDir)
Hadoop20SShims.MiniMrShim	getMiniTezCluster(org.apache.hadoop.conf.Configuration conf, int numberOfTaskTrackers, String nameNode, int numDir)
org.apache.hadoop.fs.FileSystem	getNonCachedFileSystem(URI uri, org.apache.hadoop.conf.Configuration conf)
String	getPassword(org.apache.hadoop.conf.Configuration conf, String name) Use password API (if available) to fetch credentials/password
org.apache.hadoop.fs.Path	getPathWithoutSchemeAndAuthority(org.apache.hadoop.fs.Path path)
HadoopShims.StoragePolicyShim	getStoragePolicyShim(org.apache.hadoop.fs.FileSystem fs) obtain a storage policy shim associated with the filesystem.
String	getTaskAttemptLogUrl(org.apache.hadoop.mapred.JobConf conf, String taskTrackerHttpAddress, String taskAttemptId) Constructs and Returns TaskAttempt Log Url or null if the TaskLogServlet is not available
HadoopShims.WebHCatJTShim	getWebHCatShim(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.UserGroupInformation ugi) Provides a Hadoop JobTracker shim.
HadoopShims.ZeroCopyReaderShim	getZeroCopyReader(org.apache.hadoop.fs.FSDataInputStream in, HadoopShims.ByteBufferPoolShim pool) Provides an HDFS ZeroCopyReader shim.
boolean	hasStickyBit(org.apache.hadoop.fs.permission.FsPermission permission) Check stick bit in the permission
void	hflush(org.apache.hadoop.fs.FSDataOutputStream stream) Flush and make visible to other users the changes to the given stream.
boolean	isDirectory(org.apache.hadoop.fs.FileStatus fileStatus) Check whether file is directory.
boolean	isLocalMode(org.apache.hadoop.conf.Configuration conf) Check wether MR is configured to run in local-mode
List<org.apache.hadoop.fs.FileStatus>	listLocatedStatus(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.PathFilter filter) Get the block locations for the given directory.
void	mergeCredentials(org.apache.hadoop.mapred.JobConf dest, org.apache.hadoop.mapred.JobConf src)
boolean	moveToAppropriateTrash(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf) Move the directory/file to trash.
org.apache.hadoop.mapreduce.JobContext	newJobContext(org.apache.hadoop.mapreduce.Job job)
org.apache.hadoop.mapreduce.TaskAttemptContext	newTaskAttemptContext(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.util.Progressable progressable)
org.apache.hadoop.mapreduce.TaskAttemptID	newTaskAttemptID(org.apache.hadoop.mapreduce.JobID jobId, boolean isMap, int taskId, int id)
int	readByteBuffer(org.apache.hadoop.fs.FSDataInputStream file, ByteBuffer dest) Reads data into ByteBuffer.
void	refreshDefaultQueue(org.apache.hadoop.conf.Configuration conf, String userName) Reset the default fair scheduler queue mapping to end user.
boolean	runDistCp(org.apache.hadoop.fs.Path src, org.apache.hadoop.fs.Path dst, org.apache.hadoop.conf.Configuration conf) Copies a source dir/file to a destination by orchestrating the copy between hdfs nodes.
void	setFullFileStatus(org.apache.hadoop.conf.Configuration conf, HadoopShims.HdfsFileStatus sourceStatus, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path target) For a given file, set a given file status.
void	setJobLauncherRpcAddress(org.apache.hadoop.conf.Configuration conf, String val) All updates to jobtracker/resource manager rpc address in the configuration should be done through this shim
void	setTotalOrderPartitionFile(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.fs.Path partitionFile) The method sets to set the partition file has a different signature between hadoop versions.
void	startPauseMonitor(org.apache.hadoop.conf.Configuration conf)
boolean	supportStickyBit() check whether current hadoop supports sticky bit
boolean	supportTrashFeature()

Methods inherited from class org.apache.hadoop.hive.shims.HadoopShimsSecure

checkFileAccess, run

Methods inherited from class java.lang.Object

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

Constructor Detail

Hadoop20SShims

public Hadoop20SShims()

Method Detail

getCombineFileInputFormat

public HadoopShims.CombineFileInputFormatShim getCombineFileInputFormat()

getTaskAttemptLogUrl

public String getTaskAttemptLogUrl(org.apache.hadoop.mapred.JobConf conf,
                          String taskTrackerHttpAddress,
                          String taskAttemptId)
                            throws MalformedURLException

Description copied from interface: HadoopShims

Constructs and Returns TaskAttempt Log Url or null if the TaskLogServlet is not available

Returns:

TaskAttempt Log Url

Throws:

MalformedURLException

getJobTrackerState

public HadoopShims.JobTrackerState getJobTrackerState(org.apache.hadoop.mapred.ClusterStatus clusterStatus)
                                               throws Exception

Description copied from interface: HadoopShims

Convert the ClusterStatus to its Thrift equivalent: JobTrackerState. See MAPREDUCE-2455 for why this is a part of the shim.

Specified by:

getJobTrackerState in interface HadoopShims

Specified by:

getJobTrackerState in class HadoopShimsSecure

Returns:

the matching JobTrackerState

Throws:

Exception - if no equivalent JobTrackerState exists

newTaskAttemptContext

public org.apache.hadoop.mapreduce.TaskAttemptContext newTaskAttemptContext(org.apache.hadoop.conf.Configuration conf,
                                                                   org.apache.hadoop.util.Progressable progressable)

Specified by:

newTaskAttemptContext in interface HadoopShims

Specified by:

newTaskAttemptContext in class HadoopShimsSecure

newTaskAttemptID

public org.apache.hadoop.mapreduce.TaskAttemptID newTaskAttemptID(org.apache.hadoop.mapreduce.JobID jobId,
                                                         boolean isMap,
                                                         int taskId,
                                                         int id)

newJobContext

public org.apache.hadoop.mapreduce.JobContext newJobContext(org.apache.hadoop.mapreduce.Job job)

Specified by:

newJobContext in interface HadoopShims

Specified by:

newJobContext in class HadoopShimsSecure

startPauseMonitor

public void startPauseMonitor(org.apache.hadoop.conf.Configuration conf)

isLocalMode

public boolean isLocalMode(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: HadoopShims

Check wether MR is configured to run in local-mode

Specified by:

isLocalMode in interface HadoopShims

Specified by:

isLocalMode in class HadoopShimsSecure

Returns:

getJobLauncherRpcAddress

public String getJobLauncherRpcAddress(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: HadoopShims

All retrieval of jobtracker/resource manager rpc address in the configuration should be done through this shim

Specified by:

getJobLauncherRpcAddress in interface HadoopShims

Specified by:

getJobLauncherRpcAddress in class HadoopShimsSecure

Returns:

setJobLauncherRpcAddress

public void setJobLauncherRpcAddress(org.apache.hadoop.conf.Configuration conf,
                            String val)

Description copied from interface: HadoopShims

All updates to jobtracker/resource manager rpc address in the configuration should be done through this shim

Specified by:

setJobLauncherRpcAddress in interface HadoopShims

Specified by:

setJobLauncherRpcAddress in class HadoopShimsSecure

getJobLauncherHttpAddress

public String getJobLauncherHttpAddress(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: HadoopShims

All references to jobtracker/resource manager http address in the configuration should be done through this shim

Specified by:

getJobLauncherHttpAddress in interface HadoopShims

Specified by:

getJobLauncherHttpAddress in class HadoopShimsSecure

Returns:

moveToAppropriateTrash

public boolean moveToAppropriateTrash(org.apache.hadoop.fs.FileSystem fs,
                             org.apache.hadoop.fs.Path path,
                             org.apache.hadoop.conf.Configuration conf)
                               throws IOException

Description copied from interface: HadoopShims

Move the directory/file to trash. In case of the symlinks or mount points, the file is moved to the trashbin in the actual volume of the path p being deleted

Specified by:

moveToAppropriateTrash in interface HadoopShims

Specified by:

moveToAppropriateTrash in class HadoopShimsSecure

Returns:

false if the item is already in the trash or trash is disabled

Throws:

IOException

getDefaultBlockSize

public long getDefaultBlockSize(org.apache.hadoop.fs.FileSystem fs,
                       org.apache.hadoop.fs.Path path)

Description copied from interface: HadoopShims

Get the default block size for the path. FileSystem alone is not sufficient to determine the same, as in case of CSMT the underlying file system determines that.

Specified by:

getDefaultBlockSize in interface HadoopShims

Specified by:

getDefaultBlockSize in class HadoopShimsSecure

Returns:

getDefaultReplication

public short getDefaultReplication(org.apache.hadoop.fs.FileSystem fs,
                          org.apache.hadoop.fs.Path path)

Description copied from interface: HadoopShims

Get the default replication for a path. In case of CSMT the given path will be used to locate the actual filesystem.

Specified by:

getDefaultReplication in interface HadoopShims

Specified by:

getDefaultReplication in class HadoopShimsSecure

Returns:

refreshDefaultQueue

public void refreshDefaultQueue(org.apache.hadoop.conf.Configuration conf,
                       String userName)

Description copied from interface: HadoopShims

Reset the default fair scheduler queue mapping to end user.

userName - end user name

setTotalOrderPartitionFile

public void setTotalOrderPartitionFile(org.apache.hadoop.mapred.JobConf jobConf,
                              org.apache.hadoop.fs.Path partitionFile)

Description copied from interface: HadoopShims

The method sets to set the partition file has a different signature between hadoop versions.

getLongComparator

public Comparator<org.apache.hadoop.io.LongWritable> getLongComparator()

getMiniMrCluster

public Hadoop20SShims.MiniMrShim getMiniMrCluster(org.apache.hadoop.conf.Configuration conf,
                                         int numberOfTaskTrackers,
                                         String nameNode,
                                         int numDir)
                                           throws IOException

Returns a shim to wrap MiniMrCluster

Throws:

IOException

getMiniTezCluster

public Hadoop20SShims.MiniMrShim getMiniTezCluster(org.apache.hadoop.conf.Configuration conf,
                                          int numberOfTaskTrackers,
                                          String nameNode,
                                          int numDir)
                                            throws IOException

Throws:

IOException

getMiniSparkCluster

public Hadoop20SShims.MiniMrShim getMiniSparkCluster(org.apache.hadoop.conf.Configuration conf,
                                            int numberOfTaskTrackers,
                                            String nameNode,
                                            int numDir)
                                              throws IOException

Throws:

IOException

getMiniDfs

public HadoopShims.MiniDFSShim getMiniDfs(org.apache.hadoop.conf.Configuration conf,
                                 int numDataNodes,
                                 boolean format,
                                 String[] racks)
                                   throws IOException

Description copied from interface: HadoopShims

Returns a shim to wrap MiniDFSCluster. This is necessary since this class was moved from org.apache.hadoop.dfs to org.apache.hadoop.hdfs

Throws:

IOException

getHCatShim

public HadoopShims.HCatHadoopShims getHCatShim()

getWebHCatShim

public HadoopShims.WebHCatJTShim getWebHCatShim(org.apache.hadoop.conf.Configuration conf,
                                       org.apache.hadoop.security.UserGroupInformation ugi)
                                         throws IOException

Description copied from interface: HadoopShims

Provides a Hadoop JobTracker shim.

Parameters:

conf - not null

Throws:

IOException

listLocatedStatus

public List<org.apache.hadoop.fs.FileStatus> listLocatedStatus(org.apache.hadoop.fs.FileSystem fs,
                                                      org.apache.hadoop.fs.Path path,
                                                      org.apache.hadoop.fs.PathFilter filter)
                                                        throws IOException

Description copied from interface: HadoopShims

Get the block locations for the given directory.

Parameters:

fs - the file system

path - the directory name to get the status and block locations

filter - a filter that needs to accept the file (or null)

Returns:

an list for the located file status objects

Throws:

IOException

getLocations

public org.apache.hadoop.fs.BlockLocation[] getLocations(org.apache.hadoop.fs.FileSystem fs,
                                                org.apache.hadoop.fs.FileStatus status)
                                                  throws IOException

Description copied from interface: HadoopShims

For file status returned by listLocatedStatus, convert them into a list of block locations.

Parameters:

fs - the file system

status - the file information

Returns:

the block locations of the file

Throws:

IOException

getLocationsWithOffset

public TreeMap<Long,org.apache.hadoop.fs.BlockLocation> getLocationsWithOffset(org.apache.hadoop.fs.FileSystem fs,
                                                                      org.apache.hadoop.fs.FileStatus status)
                                                                        throws IOException

Description copied from interface: HadoopShims

For the block locations returned by getLocations() convert them into a Treemap by iterating over the list of blockLocation. Using TreeMap from offset to blockLocation, makes it O(logn) to get a particular block based upon offset.

Parameters:

fs - the file system

status - the file information

Returns:

TreeMap

Throws:

IOException

hflush

public void hflush(org.apache.hadoop.fs.FSDataOutputStream stream)
            throws IOException

Description copied from interface: HadoopShims

Flush and make visible to other users the changes to the given stream.

Parameters:

stream - the stream to hflush.

Throws:

IOException

getFullFileStatus

public HadoopShims.HdfsFileStatus getFullFileStatus(org.apache.hadoop.conf.Configuration conf,
                                           org.apache.hadoop.fs.FileSystem fs,
                                           org.apache.hadoop.fs.Path file)
                                             throws IOException

Description copied from interface: HadoopShims

For a given file, return a file status

Returns:

Throws:

IOException

setFullFileStatus

public void setFullFileStatus(org.apache.hadoop.conf.Configuration conf,
                     HadoopShims.HdfsFileStatus sourceStatus,
                     org.apache.hadoop.fs.FileSystem fs,
                     org.apache.hadoop.fs.Path target)
                       throws IOException

Description copied from interface: HadoopShims

For a given file, set a given file status.

Throws:

IOException

createProxyFileSystem

public org.apache.hadoop.fs.FileSystem createProxyFileSystem(org.apache.hadoop.fs.FileSystem fs,
                                                    URI uri)

Description copied from interface: HadoopShims

Create a proxy file system that can serve a given scheme/authority using some other file system.

Specified by:

createProxyFileSystem in interface HadoopShims

Specified by:

createProxyFileSystem in class HadoopShimsSecure

getHadoopConfNames

public Map<String,String> getHadoopConfNames()

getZeroCopyReader

public HadoopShims.ZeroCopyReaderShim getZeroCopyReader(org.apache.hadoop.fs.FSDataInputStream in,
                                               HadoopShims.ByteBufferPoolShim pool)
                                                 throws IOException

Description copied from interface: HadoopShims

Provides an HDFS ZeroCopyReader shim.

Parameters:

in - FSDataInputStream to read from (where the cached/mmap buffers are tied to)

Returns:

returns null if not supported

Throws:

IOException

getDirectDecompressor

public HadoopShims.DirectDecompressorShim getDirectDecompressor(HadoopShims.DirectCompressionType codec)

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration(org.apache.hadoop.mapreduce.JobContext context)

Description copied from interface: HadoopShims

Get configuration from JobContext

getJobConf

public org.apache.hadoop.mapred.JobConf getJobConf(org.apache.hadoop.mapred.JobContext context)

Description copied from interface: HadoopShims

Get job conf from the old style JobContext.

Parameters:

context - job context

Returns:

job conf

getNonCachedFileSystem

public org.apache.hadoop.fs.FileSystem getNonCachedFileSystem(URI uri,
                                                     org.apache.hadoop.conf.Configuration conf)
                                                       throws IOException

Specified by:

getNonCachedFileSystem in interface HadoopShims

Specified by:

getNonCachedFileSystem in class HadoopShimsSecure

Throws:

IOException

getMergedCredentials

public void getMergedCredentials(org.apache.hadoop.mapred.JobConf jobConf)
                          throws IOException

Throws:

IOException

mergeCredentials

public void mergeCredentials(org.apache.hadoop.mapred.JobConf dest,
                    org.apache.hadoop.mapred.JobConf src)
                      throws IOException

Throws:

IOException

getPassword

public String getPassword(org.apache.hadoop.conf.Configuration conf,
                 String name)

Description copied from interface: HadoopShims

Use password API (if available) to fetch credentials/password

Returns:

supportStickyBit

public boolean supportStickyBit()

Description copied from interface: HadoopShims

check whether current hadoop supports sticky bit

Returns:

hasStickyBit

public boolean hasStickyBit(org.apache.hadoop.fs.permission.FsPermission permission)

Description copied from interface: HadoopShims

Check stick bit in the permission

Returns:

sticky bit

supportTrashFeature

public boolean supportTrashFeature()

Returns:

True if the current hadoop supports trash feature.

getCurrentTrashPath

public org.apache.hadoop.fs.Path getCurrentTrashPath(org.apache.hadoop.conf.Configuration conf,
                                            org.apache.hadoop.fs.FileSystem fs)

Returns:

Path to HDFS trash, if current hadoop supports trash feature. Null otherwise.

isDirectory

public boolean isDirectory(org.apache.hadoop.fs.FileStatus fileStatus)

Description copied from interface: HadoopShims

Check whether file is directory.

getKerberosNameShim

public Hadoop20SShims.KerberosNameShim getKerberosNameShim(String name)
                                                    throws IOException

Returns a shim to wrap KerberosName

Throws:

IOException

getStoragePolicyShim

public HadoopShims.StoragePolicyShim getStoragePolicyShim(org.apache.hadoop.fs.FileSystem fs)

Description copied from interface: HadoopShims

obtain a storage policy shim associated with the filesystem. Returns null when the filesystem has no storage policies.

runDistCp

public boolean runDistCp(org.apache.hadoop.fs.Path src,
                org.apache.hadoop.fs.Path dst,
                org.apache.hadoop.conf.Configuration conf)
                  throws IOException

Description copied from interface: HadoopShims

Copies a source dir/file to a destination by orchestrating the copy between hdfs nodes. This distributed process is meant to copy huge files that could take some time if a single copy is done.

Parameters:

src - Path to the source file or directory to copy

dst - Path to the destination file or directory

conf - The hadoop configuration object

Returns:

True if it is successfull; False otherwise.

Throws:

IOException

createHdfsEncryptionShim

public HadoopShims.HdfsEncryptionShim createHdfsEncryptionShim(org.apache.hadoop.fs.FileSystem fs,
                                                      org.apache.hadoop.conf.Configuration conf)
                                                        throws IOException

Description copied from interface: HadoopShims

Returns a new instance of the HdfsEncryption shim.

Parameters:

fs - A FileSystem object to HDFS

conf - A Configuration object

Returns:

A new instance of the HdfsEncryption shim.

Throws:

IOException - If an error occurred while creating the instance.

getPathWithoutSchemeAndAuthority

public org.apache.hadoop.fs.Path getPathWithoutSchemeAndAuthority(org.apache.hadoop.fs.Path path)

readByteBuffer

public int readByteBuffer(org.apache.hadoop.fs.FSDataInputStream file,
                 ByteBuffer dest)
                   throws IOException

Description copied from interface: HadoopShims

Reads data into ByteBuffer.

Parameters:

file - File.

dest - Buffer.

Returns:

Number of bytes read, just like file.read. If any bytes were read, dest position will be set to old position + number of bytes read.

Throws:

IOException

addDelegationTokens

public void addDelegationTokens(org.apache.hadoop.fs.FileSystem fs,
                       org.apache.hadoop.security.Credentials cred,
                       String uname)
                         throws IOException

Description copied from interface: HadoopShims

Get Delegation token and add it to Credential.

Specified by:

addDelegationTokens in interface HadoopShims

Specified by:

addDelegationTokens in class HadoopShimsSecure

Parameters:

fs - FileSystem object to HDFS

cred - Credentials object to add the token to.

uname - user name.

Throws:

IOException - If an error occurred on adding the token.