Module parquet_file_handler

Structs

• ParquetFileReader

Enums

• FileScanBackend

Functions

• create_parquet_stream_builder
• extract_bucket_and_file_name
• get_parquet_fields
• get_project_mask
  Extracts a suitable ProjectionMask from a Parquet file schema based on the user’s requested schema.
• is_parquet_schema_match_source_schema
  This function checks whether the schema of a Parquet file matches the user defined schema. It handles the following special cases:
• list_data_directory
• new_azblob_operator
• new_gcs_operator
• new_s3_operator
• read_parquet_file
  Reads a specified Parquet file and converts its content into a stream of chunks.