risingwave_connector::source::iceberg::parquet_file_handler

Function new_gcs_operator

Source 
pub fn new_gcs_operator(
    credential: String,
    bucket: String,
) -> ConnectorResult<Operator>