risingwave_connector::source::iceberg::parquet_file_handler

Function get_parquet_fields

source 
pub async fn get_parquet_fields(
    op: Operator,
    file_name: String,
) -> ConnectorResult<Fields>