fix old pipeline using string key
@@ -22,6 +22,7 @@ use bumpalo::Bump;
use common_base::infallible::RwLock;
use common_datablocks::DataBlock;
use common_datablocks::HashMethodKind;
+use common_datablocks::HashMethodSerializer;
use common_datavalues::prelude::MutableColumn;
use common_datavalues::prelude::*;
use common_exception::ErrorCode;
@@ -267,7 +268,8 @@ impl Processor for GroupByFinalTransform {
apply! { hash_method , &UInt64Column, RwLock<HashMap<u64, usize, ahash::RandomState>> }
}
_ => {
- Err(ErrorCode::UnImplement("Other hashmethod is not supported in old pipeline".to_string()))
+ let method = HashMethodSerializer::default();
+ apply! { method , &StringColumn, RwLock<HashMap<Vec<u8>, usize, ahash::RandomState>> }
}
}
}};
