EncryptionUtil

java.lang.Object

org.apache.iceberg.encryption.EncryptionUtil

public class EncryptionUtil extends Object

Method Summary

Modifier and Type

Method

Description

static void

checkCompatibility(Map<String,String> tableProperties, int formatVersion)

static EncryptionManager

createEncryptionManager(List<EncryptedKey> keys, Map<String,String> tableProperties, KeyManagementClient kmsClient)

static KeyManagementClient

createKmsClient(Map<String,String> catalogProperties)

static ByteBuffer

decryptManifestListKeyMetadata(ManifestListFile manifestList, EncryptionManager em)

Decrypt the key metadata for a manifest list.

static Map<String,EncryptedKey>

encryptionKeys(EncryptionManager em)

static EncryptedOutputFile

plainAsEncryptedOutput(OutputFile encryptingOutputFile)

static ByteBuffer

setFileLength(ByteBuffer keyMetadata, long fileLength)

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- createKmsClient
  
  public static KeyManagementClient createKmsClient(Map<String,String> catalogProperties)
- createEncryptionManager
  
  public static EncryptionManager createEncryptionManager(List<EncryptedKey> keys, Map<String,String> tableProperties, KeyManagementClient kmsClient)
- plainAsEncryptedOutput
  
  public static EncryptedOutputFile plainAsEncryptedOutput(OutputFile encryptingOutputFile)
- setFileLength
  
  public static ByteBuffer setFileLength(ByteBuffer keyMetadata, long fileLength)
- decryptManifestListKeyMetadata
  
  public static ByteBuffer decryptManifestListKeyMetadata(ManifestListFile manifestList, EncryptionManager em)
  
  Decrypt the key metadata for a manifest list.
  
  Parameters:
  
  manifestList - a ManifestListFile
  
  em - the table's EncryptionManager
  
  Returns:
  
  a decrypted key metadata buffer
- encryptionKeys
  
  public static Map<String,EncryptedKey> encryptionKeys(EncryptionManager em)
- checkCompatibility
  
  public static void checkCompatibility(Map<String,String> tableProperties, int formatVersion)