File tree Expand file tree Collapse file tree 1 file changed +13
-4
lines changed
src/query/datavalues/src/columns/string Expand file tree Collapse file tree 1 file changed +13
-4
lines changed Original file line number Diff line number Diff line change @@ -64,14 +64,23 @@ impl StringColumn {
64
64
65
65
if arrow_type == & ArrowType :: Utf8 {
66
66
let arr = array. as_any ( ) . downcast_ref :: < Utf8Array < i32 > > ( ) . unwrap ( ) ;
67
- let iter = arr. values_iter ( ) ;
68
- return Self :: new_from_iter ( iter) ;
67
+ let offsets = arr
68
+ . offsets ( )
69
+ . iter ( )
70
+ . map ( |x| * x as i64 )
71
+ . collect :: < Buffer < _ > > ( ) ;
72
+ return Self {
73
+ offsets,
74
+ values : arr. values ( ) . clone ( ) ,
75
+ } ;
69
76
}
70
77
71
78
if arrow_type == & ArrowType :: LargeUtf8 {
72
79
let arr = array. as_any ( ) . downcast_ref :: < Utf8Array < i64 > > ( ) . unwrap ( ) ;
73
- let iter = arr. values_iter ( ) ;
74
- return Self :: new_from_iter ( iter) ;
80
+ return Self {
81
+ offsets : arr. offsets ( ) . clone ( ) ,
82
+ values : arr. values ( ) . clone ( ) ,
83
+ } ;
75
84
}
76
85
77
86
Self :: new (
You can’t perform that action at this time.
0 commit comments