org.apache.spark.security

Class CryptoStreamUtils

Object

org.apache.spark.security.CryptoStreamUtils

public class CryptoStreamUtils
extends Object

A util class for manipulating IO encryption and decryption streams.

Constructor Summary

Constructors

Constructor and Description
CryptoStreamUtils()

Method Summary

Modifier and Type	Method and Description
static java.io.InputStream	createCryptoInputStream(java.io.InputStream is, SparkConf sparkConf, byte[] key) Helper method to wrap InputStream with CryptoInputStream for decryption.
static java.io.OutputStream	createCryptoOutputStream(java.io.OutputStream os, SparkConf sparkConf, byte[] key) Helper method to wrap OutputStream with CryptoOutputStream for encryption.
static byte[]	createKey(SparkConf conf) Creates a new encryption key.
static java.nio.channels.ReadableByteChannel	createReadableChannel(java.nio.channels.ReadableByteChannel channel, SparkConf sparkConf, byte[] key) Wrap a ReadableByteChannel for decryption.
static java.nio.channels.WritableByteChannel	createWritableChannel(java.nio.channels.WritableByteChannel channel, SparkConf sparkConf, byte[] key) Wrap a WritableByteChannel for encryption.
static int	IV_LENGTH_IN_BYTES()
static String	SPARK_IO_ENCRYPTION_COMMONS_CONFIG_PREFIX()
static java.util.Properties	toCryptoConf(SparkConf conf)

Methods inherited from class Object

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

Constructor Detail

CryptoStreamUtils

public CryptoStreamUtils()

Method Detail

IV_LENGTH_IN_BYTES

public static int IV_LENGTH_IN_BYTES()

SPARK_IO_ENCRYPTION_COMMONS_CONFIG_PREFIX

public static String SPARK_IO_ENCRYPTION_COMMONS_CONFIG_PREFIX()

createCryptoOutputStream

public static java.io.OutputStream createCryptoOutputStream(java.io.OutputStream os,
                                                            SparkConf sparkConf,
                                                            byte[] key)

Helper method to wrap OutputStream with CryptoOutputStream for encryption.

Parameters:

os - (undocumented)

sparkConf - (undocumented)

key - (undocumented)

Returns:

(undocumented)

createWritableChannel

public static java.nio.channels.WritableByteChannel createWritableChannel(java.nio.channels.WritableByteChannel channel,
                                                                          SparkConf sparkConf,
                                                                          byte[] key)

Wrap a WritableByteChannel for encryption.

Parameters:

channel - (undocumented)

sparkConf - (undocumented)

key - (undocumented)

Returns:

(undocumented)

createCryptoInputStream

public static java.io.InputStream createCryptoInputStream(java.io.InputStream is,
                                                          SparkConf sparkConf,
                                                          byte[] key)

Helper method to wrap InputStream with CryptoInputStream for decryption.

Parameters:

is - (undocumented)

sparkConf - (undocumented)

key - (undocumented)

Returns:

(undocumented)

createReadableChannel

public static java.nio.channels.ReadableByteChannel createReadableChannel(java.nio.channels.ReadableByteChannel channel,
                                                                          SparkConf sparkConf,
                                                                          byte[] key)

Wrap a ReadableByteChannel for decryption.

Parameters:

channel - (undocumented)

sparkConf - (undocumented)

key - (undocumented)

Returns:

(undocumented)

toCryptoConf

public static java.util.Properties toCryptoConf(SparkConf conf)

createKey

public static byte[] createKey(SparkConf conf)

Creates a new encryption key.

Parameters:

conf - (undocumented)

Returns:

(undocumented)