co.cask.hydrator.common

Class FieldEncryptor

java.lang.Object

co.cask.hydrator.common.FieldEncryptor

public abstract class FieldEncryptor
extends Object

Encrypts and decrypts fields based on their schema.

Constructor Summary

Constructors

Constructor and Description
FieldEncryptor(KeystoreConf conf, int mode)

Method Summary

Methods

Modifier and Type	Method and Description
Object	decrypt(byte[] fieldBytes, co.cask.cdap.api.data.schema.Schema fieldSchema)
byte[]	encrypt(Object fieldVal, co.cask.cdap.api.data.schema.Schema fieldSchema)
abstract InputStream	getKeystoreInputStream(String keystorePath)
void	initialize()

Methods inherited from class java.lang.Object

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

Constructor Detail

FieldEncryptor

public FieldEncryptor(KeystoreConf conf,
              int mode)

Method Detail

initialize

public void initialize()
                throws Exception

Throws:

Exception

getKeystoreInputStream

public abstract InputStream getKeystoreInputStream(String keystorePath)
                                            throws Exception

Throws:

Exception

encrypt

public byte[] encrypt(Object fieldVal,
             co.cask.cdap.api.data.schema.Schema fieldSchema)
               throws BadPaddingException,
                      IllegalBlockSizeException

Throws:

BadPaddingException

IllegalBlockSizeException

decrypt

public Object decrypt(byte[] fieldBytes,
             co.cask.cdap.api.data.schema.Schema fieldSchema)
               throws BadPaddingException,
                      IllegalBlockSizeException

Throws:

BadPaddingException

IllegalBlockSizeException