org.apache.hadoop.hive.shims

Class HadoopShims.NoopHdfsEncryptionShim

java.lang.Object

org.apache.hadoop.hive.shims.HadoopShims.NoopHdfsEncryptionShim

All Implemented Interfaces:

HadoopShims.HdfsEncryptionShim

Enclosing interface:

HadoopShims

public static class HadoopShims.NoopHdfsEncryptionShim
extends Object
implements HadoopShims.HdfsEncryptionShim

This is a dummy class used when the hadoop version does not support hdfs encryption.

Constructor Summary

Constructors

Constructor and Description
HadoopShims.NoopHdfsEncryptionShim()

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

HadoopShims.NoopHdfsEncryptionShim

public HadoopShims.NoopHdfsEncryptionShim()

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)

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

createKey

public void createKey(String keyName,
             int bitLength)

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).

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