org.apache.hadoop.hive.shims

Class Hadoop23Shims.HdfsEncryptionShim

java.lang.Object

org.apache.hadoop.hive.shims.Hadoop23Shims.HdfsEncryptionShim

All Implemented Interfaces:

HadoopShims.HdfsEncryptionShim

Enclosing class:

Hadoop23Shims

public class Hadoop23Shims.HdfsEncryptionShim
extends Object
implements HadoopShims.HdfsEncryptionShim

Constructor Summary

Constructors

Constructor and Description
Hadoop23Shims.HdfsEncryptionShim(URI uri, org.apache.hadoop.conf.Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	arePathsOnSameEncryptionZone(org.apache.hadoop.fs.Path path1, org.apache.hadoop.fs.Path path2) Checks if two HDFS paths are on the same encrypted or unencrypted zone.
int	comparePathKeyStrength(org.apache.hadoop.fs.Path path1, org.apache.hadoop.fs.Path path2) Compares two encrypted path strengths.
void	createEncryptionZone(org.apache.hadoop.fs.Path path, String keyName) create encryption zone by path and keyname
void	createKey(String keyName, int bitLength) Creates an encryption key.
void	deleteKey(String keyName)
List<String>	getKeys()
boolean	isPathEncrypted(org.apache.hadoop.fs.Path path) Checks if a given HDFS path is encrypted.

Methods inherited from class java.lang.Object

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

Constructor Detail

Hadoop23Shims.HdfsEncryptionShim

public Hadoop23Shims.HdfsEncryptionShim(URI uri,
                                org.apache.hadoop.conf.Configuration conf)
                                 throws IOException

Throws:

IOException

Method Detail

isPathEncrypted

public boolean isPathEncrypted(org.apache.hadoop.fs.Path path)
                        throws IOException

Description copied from interface: HadoopShims.HdfsEncryptionShim

Checks if a given HDFS path is encrypted.

Specified by:

isPathEncrypted in interface HadoopShims.HdfsEncryptionShim

Parameters:

path - Path to HDFS file system

Returns:

True if it is encrypted; False otherwise.

Throws:

IOException - If an error occurred attempting to get encryption information

arePathsOnSameEncryptionZone

public boolean arePathsOnSameEncryptionZone(org.apache.hadoop.fs.Path path1,
                                   org.apache.hadoop.fs.Path path2)
                                     throws IOException

Description copied from interface: HadoopShims.HdfsEncryptionShim

Checks if two HDFS paths are on the same encrypted or unencrypted zone.

Specified by:

arePathsOnSameEncryptionZone in interface HadoopShims.HdfsEncryptionShim

Parameters:

path1 - Path to HDFS file system

path2 - Path to HDFS file system

Returns:

True if both paths are in the same zone; False otherwise.

Throws:

IOException - If an error occurred attempting to get encryption information

comparePathKeyStrength

public int comparePathKeyStrength(org.apache.hadoop.fs.Path path1,
                         org.apache.hadoop.fs.Path path2)
                           throws IOException

Description copied from interface: HadoopShims.HdfsEncryptionShim

Compares two encrypted path strengths.

Specified by:

comparePathKeyStrength in interface HadoopShims.HdfsEncryptionShim

Parameters:

path1 - HDFS path to compare.

path2 - HDFS path to compare.

Returns:

1 if path1 is stronger; 0 if paths are equals; -1 if path1 is weaker.

Throws:

IOException - If an error occurred attempting to get encryption/key metadata

createEncryptionZone

public void createEncryptionZone(org.apache.hadoop.fs.Path path,
                        String keyName)
                          throws IOException

Description copied from interface: HadoopShims.HdfsEncryptionShim

create encryption zone by path and keyname

Specified by:

createEncryptionZone in interface HadoopShims.HdfsEncryptionShim

Parameters:

path - HDFS path to create encryption zone

keyName - keyname

Throws:

IOException

createKey

public void createKey(String keyName,
             int bitLength)
               throws IOException,
                      NoSuchAlgorithmException

Description copied from interface: HadoopShims.HdfsEncryptionShim

Creates an encryption key.

Specified by:

createKey in interface HadoopShims.HdfsEncryptionShim

Parameters:

keyName - Name of the key

bitLength - Key encryption length in bits (128 or 256).

Throws:

IOException - If an error occurs while creating the encryption key

NoSuchAlgorithmException - If cipher algorithm is invalid.

deleteKey

public void deleteKey(String keyName)
               throws IOException

Specified by:

deleteKey in interface HadoopShims.HdfsEncryptionShim

Throws:

IOException

getKeys

public List<String> getKeys()
                     throws IOException

Specified by:

getKeys in interface HadoopShims.HdfsEncryptionShim

Throws:

IOException