new_s3_operator

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,
    bucket: String,
    s3_endpoint: String,
) -> ConnectorResult<Operator>