risingwave_connector::source::iceberg::parquet_file_handler

Function read_parquet_file

source 
pub async fn read_parquet_file(
    op: Operator,
    file_name: String,
    rw_columns: Option<Vec<Column>>,
    parser_columns: Option<Vec<SourceColumnDesc>>,
    batch_size: usize,
    offset: usize,
) -> ConnectorResult<Pin<Box<dyn Stream<Item = Result<StreamChunk, ConnectorError>> + Send>>>
Expand description

Reads a specified Parquet file and converts its content into a stream of chunks.