risingwave_
connector
2.2.0-alpha
Module parquet_
file_
handler
Module Items
Structs
Functions
In risingwave_
connector::
source::
iceberg
risingwave_connector
::
source
::
iceberg
Module
parquet_file_handler
Copy item path
source
Structs
§
Parquet
File
Reader
Functions
§
create_
parquet_
stream_
builder
extract_
bucket
🔒
extract_
valid_
column_
indices
Extracts valid column indices from a Parquet file schema based on the user’s requested schema.
get_
parquet_
fields
list_
s3_
directory
new_
s3_
operator
read_
parquet_
file
Reads a specified Parquet file and converts its content into a stream of chunks.