Struct deltalake::datafusion::datasource::file_format::file_compression_type::FileCompressionType

pub struct FileCompressionType { /* private fields */ }

Readable file compression type

Implementations

impl FileCompressionType

FileCompressionType implementation

pub const GZIP: FileCompressionType = _

Gzip-ed file

pub const BZIP2: FileCompressionType = _

Bzip2-ed file

pub const XZ: FileCompressionType = _

Xz-ed file (liblzma)

pub const ZSTD: FileCompressionType = _

Zstd-ed file

pub const UNCOMPRESSED: FileCompressionType = _

Uncompressed file

pub const fn is_compressed(&self) -> bool

The file is compressed or not

pub fn convert_to_compress_stream( &self, s: Pin<Box<dyn Stream<Item = Result<Bytes, DataFusionError>> + Send>> ) -> Result<Pin<Box<dyn Stream<Item = Result<Bytes, DataFusionError>> + Send>>, DataFusionError>

Given a Stream, create a Stream which data are compressed with FileCompressionType.

pub fn convert_async_writer( &self, w: BufWriter ) -> Result<Box<dyn AsyncWrite + Unpin + Send>, DataFusionError>

Wrap the given BufWriter so that it performs compressed writes according to this FileCompressionType.

pub fn convert_stream( &self, s: Pin<Box<dyn Stream<Item = Result<Bytes, DataFusionError>> + Send>> ) -> Result<Pin<Box<dyn Stream<Item = Result<Bytes, DataFusionError>> + Send>>, DataFusionError>

Given a Stream, create a Stream which data are decompressed with FileCompressionType.

pub fn convert_read<T>( &self, r: T ) -> Result<Box<dyn Read + Send>, DataFusionError>

where T: Read + Send + 'static,

Given a Read, create a Read which data are decompressed with FileCompressionType.

Trait Implementations

impl Clone for FileCompressionType

fn clone(&self) -> FileCompressionType

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FileCompressionType

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

Formats the value using the given formatter.

impl From<CompressionTypeVariant> for FileCompressionType

fn from(t: CompressionTypeVariant) -> FileCompressionType

Converts to this type from the input type.

impl From<FileCompressionType> for CompressionTypeVariant

fn from(t: FileCompressionType) -> CompressionTypeVariant

Converts to this type from the input type.

impl FromStr for FileCompressionType

type Err = DataFusionError

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<FileCompressionType, DataFusionError>

Parses a string s to return a value of this type.

impl GetExt for FileCompressionType

fn get_ext(&self) -> String

File extension getter

impl PartialEq for FileCompressionType

fn eq(&self, other: &FileCompressionType) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for FileCompressionType

impl Eq for FileCompressionType

impl StructuralPartialEq for FileCompressionType