Struct datafusion::common::file_type::FileCompressionType

pub struct FileCompressionType { /* private fields */ }

Readable file compression type

Implementations

impl FileCompressionType

FileCompressionType implementation

pub const GZIP: FileCompressionType = Self{ variant: GZIP,}

Gzip-ed file

pub const BZIP2: FileCompressionType = Self{ variant: BZIP2,}

Bzip2-ed file

pub const XZ: FileCompressionType = Self{ variant: XZ,}

Xz-ed file (liblzma)

pub const ZSTD: FileCompressionType = Self{ variant: ZSTD,}

Zstd-ed file

pub const UNCOMPRESSED: FileCompressionType = Self{ variant: UNCOMPRESSED,}

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, Global>> ) -> Result<Pin<Box<dyn Stream<Item = Result<Bytes, DataFusionError>> + Send, Global>>, DataFusionError>

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

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

Wrap the given AsyncWrite 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, Global>> ) -> Result<Pin<Box<dyn Stream<Item = Result<Bytes, DataFusionError>> + Send, Global>>, 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, Global>, 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 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<FileCompressionType> 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 StructuralEq for FileCompressionType

impl StructuralPartialEq for FileCompressionType