Commit 9b900f6a by dongshufeng

little change

parent fec00da5
...@@ -26,7 +26,7 @@ pub unsafe fn run(ptr: i32, len: u32) -> u64 { ...@@ -26,7 +26,7 @@ pub unsafe fn run(ptr: i32, len: u32) -> u64 {
error = Some(s.clone()); error = Some(s.clone());
} }
let mut config= HashMap::with_capacity(0); let mut config= HashMap::with_capacity(0);
let mut csv_str = String::from("dev_id,conductor\n"); let mut csv_str = String::from("dev_id,ohm\n");
if error.is_none() { if error.is_none() {
let (island, prop_defs, defines) = r.unwrap(); let (island, prop_defs, defines) = r.unwrap();
let from = r2.unwrap(); let from = r2.unwrap();
...@@ -79,7 +79,7 @@ pub unsafe fn run(ptr: i32, len: u32) -> u64 { ...@@ -79,7 +79,7 @@ pub unsafe fn run(ptr: i32, len: u32) -> u64 {
// build schema // build schema
let schema = Schema::new(vec![ let schema = Schema::new(vec![
Field::new("dev_id", DataType::UInt64, false), Field::new("dev_id", DataType::UInt64, false),
Field::new("conductor", DataType::Utf8, false), Field::new("ohm", DataType::Utf8, false),
]); ]);
let csv_bytes = vec![("".to_string(), csv_str.into_bytes())]; let csv_bytes = vec![("".to_string(), csv_str.into_bytes())];
let output = PluginOutput { let output = PluginOutput {
......
[package]
name = "ds-tn-input"
version = "0.1.0"
edition = "2021"
[lib]
crate-type = ["cdylib"]
[dependencies]
log = "0.4"
serde_cbor = "0.11"
arrow-schema = { version = "52.1", features = ["serde"] }
mems = { path = "../../../mems" }
\ No newline at end of file
pub fn add(left: usize, right: usize) -> usize {
left + right
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn it_works() {
let result = add(2, 2);
assert_eq!(result, 4);
}
}
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论