Crate rlink_sink_conf[−][src]
Expand description
rlink-sink-conf
A library to upgrade rlink task smoothly.
Example
use rlink_sink_conf::sink_config::{init_sink_config, get_sink_topic}; use std::collections::HashMap; let sin_conf_url = "testUrl"; let application_name = "tlb_base_qa"; let timestamp = 123 as u64; init_sink_config(sin_conf_url.to_string(), application_name.to_string()); let mut expression_param = HashMap::new(); expression_param.insert("timestamp".to_string(), timestamp.to_string()); let sink_topic = get_sink_topic(expression_param);
Modules
sink_config |