risingwave_connector::source::iceberg::parquet_file_handler

Function create_parquet_stream_builder

source 
pub async fn create_parquet_stream_builder(
    s3_region: String,
    s3_access_key: String,
    s3_secret_key: String,
    location: String,
) -> Result<ParquetRecordBatchStreamBuilder<ParquetFileReader<impl FileRead>>, Error>