Struct 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 fn get_variant(&self) -> &CompressionTypeVariant

Read only access to self.variant

pub const fn is_compressed(&self) -> bool

The file is compressed or not

pub fn convert_to_compress_stream<'a>( &self, s: Pin<Box<dyn Stream<Item = Result<Bytes, DataFusionError>> + Send + 'a>>, ) -> Result<Pin<Box<dyn Stream<Item = Result<Bytes, DataFusionError>> + Send + 'a>>, 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 + Send + Unpin>, DataFusionError>

Wrap the given BufWriter so that it performs compressed writes according to this FileCompressionType using the default compression level.

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

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

If compression_level is Some, the encoder will use the specified compression level. If None, the default level for each algorithm is used.

pub fn convert_stream<'a>( &self, s: Pin<Box<dyn Stream<Item = Result<Bytes, DataFusionError>> + Send + 'a>>, ) -> Result<Pin<Box<dyn Stream<Item = Result<Bytes, DataFusionError>> + Send + 'a>>, 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 duplicate 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

Tests for self and other values to be equal, and is used by ==.

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

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