risingwave_connector::source::iceberg::parquet_file_handler

Function new_s3_operator

source 
pub fn new_s3_operator(
    s3_region: String,
    s3_access_key: String,
    s3_secret_key: String,
    location: String,
) -> ConnectorResult<Operator>