Struct MetadataObjectWriter

struct MetadataObjectWriter {
    file_encryptor: Option<Arc<FileEncryptor>>,
}

Fields

file_encryptor: Option<Arc<FileEncryptor>>

Implementations

impl MetadataObjectWriter

fn write_object(object: &impl TSerializable, sink: impl Write) -> Result<()>

impl MetadataObjectWriter

Implementations of MetadataObjectWriter methods that rely on encryption being enabled

fn with_file_encryptor(self, encryptor: Option<Arc<FileEncryptor>>) -> Self

Set the file encryptor to use

fn write_file_metadata( &self, file_metadata: &FileMetaData, sink: impl Write, ) -> Result<()>

Write FileMetaData in Thrift format, possibly encrypting it if required

fn write_offset_index( &self, offset_index: &OffsetIndex, column_chunk: &ColumnChunk, row_group_idx: usize, column_idx: usize, sink: impl Write, ) -> Result<()>

Write a column OffsetIndex in Thrift format, possibly encrypting it if required

fn write_column_index( &self, column_index: &ColumnIndex, column_chunk: &ColumnChunk, row_group_idx: usize, column_idx: usize, sink: impl Write, ) -> Result<()>

Write a column ColumnIndex in Thrift format, possibly encrypting it if required

fn apply_row_group_encryption( &self, row_groups: Vec<RowGroup>, ) -> Result<(Vec<RowGroup>, Option<Vec<RowGroup>>)>

If encryption is enabled and configured, encrypt row group metadata. Returns a tuple of the row group metadata to write, and possibly unencrypted metadata to be returned to clients if data was encrypted.

fn get_file_magic(&self) -> &[u8; 4]

Get the “magic” bytes identifying the file type

fn write_object_with_encryption( object: &impl TSerializable, sink: impl Write, file_encryptor: &FileEncryptor, column_metadata: &ColumnChunk, module_type: ModuleType, row_group_index: usize, column_index: usize, ) -> Result<()>

fn file_crypto_metadata( file_encryptor: &FileEncryptor, ) -> Result<FileCryptoMetaData>

fn encrypt_row_groups( row_groups: Vec<RowGroup>, file_encryptor: &Arc<FileEncryptor>, ) -> Result<Vec<RowGroup>>

fn encrypt_column_chunk( column_chunk: ColumnChunk, file_encryptor: &Arc<FileEncryptor>, row_group_index: usize, column_index: usize, ) -> Result<ColumnChunk>

Apply column encryption to column chunk metadata

Trait Implementations

impl Debug for MetadataObjectWriter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MetadataObjectWriter

fn default() -> MetadataObjectWriter

Returns the “default value” for a type.