/// Formats a dataflow configuration for Flink scripts
Formats a dataflow configuration for Flink scripts
Formats a dataflow configuration for Flink scripts
fn format_flink_configuration(conf: &Vec<(OperatorId,OperatorInstances)>) -> String
{
    let mut flink_conf = String::from("");
    for pair in conf.iter()
    { // Format dataflow configuration for Flink's script
        flink_conf.push_str(format!("{},{}#", pair.0, pair.1).as_str());
    }
    flink_conf
}
fn format_flink_configuration ( conf : & Vec < ( OperatorId , OperatorInstances ) > ) -> String { let mut flink_conf = String :: from ( " " ) ; for pair in conf . iter ( ) { // Format dataflow configuration for Flink's script flink_conf . push_str ( format ! ( " " pair 0 pair 1 ) . as_str ( ) ) ; } flink_conf }
Formats a dataflow configuration for Flink scripts
Formats a dataflow configuration for Flink scripts
conf
&Vec<(OperatorId,OperatorInstances)>