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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	CryptoStreamUtils.BaseErrorHandler SPARK-25535.
static class	CryptoStreamUtils.ErrorHandlingReadableChannel

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)