risingwave_connector::source::iceberg::parquet_file_handler

Function new_azblob_operator

Source 
pub fn new_azblob_operator(
    endpoint: String,
    account_name: String,
    account_key: String,
    container_name: String,
) -> ConnectorResult<Operator>