starred/openobserve
1
0
Fork 0
mirror of https://github.com/openobserve/openobserve.git synced 2026-11-04 16:09:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

ci: cargo clippy

Browse Source
This commit is contained in:
hengfei yang
2025-07-13 06:41:47 -07:00
committed by Prabhat Sharma
parent 31d5e6de07
commit 45b303cd48
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/service/search/datafusion/distributed_plan/codec/mod.rs
+4 -4
View File
@@ -70,10 +70,10 @@ impl PhysicalExtensionCodec for ComposedPhysicalExtensionCodec {
Err(last_err.unwrap())
}
fn try_decode_udf(&self, name: &str, _buf: &[u8]) -> Result<Arc<ScalarUDF>> {
fn try_decode_udf(&self, name: &str, buf: &[u8]) -> Result<Arc<ScalarUDF>> {
let mut last_err = None;
for codec in &self.codecs {
match codec.try_decode_udf(name, _buf) {
match codec.try_decode_udf(name, buf) {
Ok(plan) => return Ok(plan),
Err(e) => last_err = Some(e),
}
@@ -81,10 +81,10 @@ impl PhysicalExtensionCodec for ComposedPhysicalExtensionCodec {
Err(last_err.unwrap())
}
fn try_encode_udf(&self, _node: &ScalarUDF, _buf: &mut Vec<u8>) -> Result<()> {
fn try_encode_udf(&self, _node: &ScalarUDF, buf: &mut Vec<u8>) -> Result<()> {
let mut last_err = None;
for codec in &self.codecs {
match codec.try_encode_udf(_node, _buf) {
match codec.try_encode_udf(_node, buf) {
Ok(_) => return Ok(()),
Err(e) => last_err = Some(e),
}