Skip to content

Commit 1b69660

Browse files
gatesngatesn
committed
AggregateFn MinMax
Signed-off-by: Nicholas Gates <nick@nickgates.com>
1 parent 0ac3646 commit 1b69660

File tree

1 file changed

+195
-3
lines changed

1 file changed

+195
-3
lines changed

‎vortex-array/public-api.lock‎

Lines changed: 195 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,134 @@ pub mod vortex_array::aggregate_fn
3030

3131
pub mod vortex_array::aggregate_fn::fns
3232

33+
pub mod vortex_array::aggregate_fn::fns::mean
34+
35+
pub struct vortex_array::aggregate_fn::fns::mean::Mean
36+
37+
impl core::clone::Clone for vortex_array::aggregate_fn::fns::mean::Mean
38+
39+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::clone(&self) -> vortex_array::aggregate_fn::fns::mean::Mean
40+
41+
impl vortex_array::aggregate_fn::AggregateFnVTable for vortex_array::aggregate_fn::fns::mean::Mean
42+
43+
pub type vortex_array::aggregate_fn::fns::mean::Mean::Options = vortex_array::scalar_fn::EmptyOptions
44+
45+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::accumulator(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<alloc::boxed::Box<dyn vortex_array::aggregate_fn::Accumulator>>
46+
47+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::deserialize(&self, _metadata: &[u8], _session: &vortex_session::VortexSession) -> vortex_error::VortexResult<Self::Options>
48+
49+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::id(&self) -> vortex_array::aggregate_fn::AggregateFnId
50+
51+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::return_dtype(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
52+
53+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::serialize(&self, options: &Self::Options) -> vortex_error::VortexResult<core::option::Option<alloc::vec::Vec<u8>>>
54+
55+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::state_dtype(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
56+
57+
pub mod vortex_array::aggregate_fn::fns::min_max
58+
59+
pub struct vortex_array::aggregate_fn::fns::min_max::Max
60+
61+
impl core::clone::Clone for vortex_array::aggregate_fn::fns::min_max::Max
62+
63+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::clone(&self) -> vortex_array::aggregate_fn::fns::min_max::Max
64+
65+
impl vortex_array::aggregate_fn::AggregateFnVTable for vortex_array::aggregate_fn::fns::min_max::Max
66+
67+
pub type vortex_array::aggregate_fn::fns::min_max::Max::Options = vortex_array::scalar_fn::EmptyOptions
68+
69+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::accumulator(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<alloc::boxed::Box<dyn vortex_array::aggregate_fn::Accumulator>>
70+
71+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::deserialize(&self, _metadata: &[u8], _session: &vortex_session::VortexSession) -> vortex_error::VortexResult<Self::Options>
72+
73+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::id(&self) -> vortex_array::aggregate_fn::AggregateFnId
74+
75+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::return_dtype(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
76+
77+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::serialize(&self, options: &Self::Options) -> vortex_error::VortexResult<core::option::Option<alloc::vec::Vec<u8>>>
78+
79+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::state_dtype(&self, options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
80+
81+
pub struct vortex_array::aggregate_fn::fns::min_max::Min
82+
83+
impl core::clone::Clone for vortex_array::aggregate_fn::fns::min_max::Min
84+
85+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::clone(&self) -> vortex_array::aggregate_fn::fns::min_max::Min
86+
87+
impl vortex_array::aggregate_fn::AggregateFnVTable for vortex_array::aggregate_fn::fns::min_max::Min
88+
89+
pub type vortex_array::aggregate_fn::fns::min_max::Min::Options = vortex_array::scalar_fn::EmptyOptions
90+
91+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::accumulator(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<alloc::boxed::Box<dyn vortex_array::aggregate_fn::Accumulator>>
92+
93+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::deserialize(&self, _metadata: &[u8], _session: &vortex_session::VortexSession) -> vortex_error::VortexResult<Self::Options>
94+
95+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::id(&self) -> vortex_array::aggregate_fn::AggregateFnId
96+
97+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::return_dtype(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
98+
99+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::serialize(&self, options: &Self::Options) -> vortex_error::VortexResult<core::option::Option<alloc::vec::Vec<u8>>>
100+
101+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::state_dtype(&self, options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
102+
103+
pub mod vortex_array::aggregate_fn::fns::sum
104+
105+
pub struct vortex_array::aggregate_fn::fns::sum::Sum
106+
107+
impl core::clone::Clone for vortex_array::aggregate_fn::fns::sum::Sum
108+
109+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::clone(&self) -> vortex_array::aggregate_fn::fns::sum::Sum
110+
111+
impl vortex_array::aggregate_fn::AggregateFnVTable for vortex_array::aggregate_fn::fns::sum::Sum
112+
113+
pub type vortex_array::aggregate_fn::fns::sum::Sum::Options = vortex_array::aggregate_fn::fns::sum::SumOptions
114+
115+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::accumulator(&self, options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<alloc::boxed::Box<dyn vortex_array::aggregate_fn::Accumulator>>
116+
117+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::deserialize(&self, _metadata: &[u8], _session: &vortex_session::VortexSession) -> vortex_error::VortexResult<Self::Options>
118+
119+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::id(&self) -> vortex_array::aggregate_fn::AggregateFnId
120+
121+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::return_dtype(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
122+
123+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::serialize(&self, options: &Self::Options) -> vortex_error::VortexResult<core::option::Option<alloc::vec::Vec<u8>>>
124+
125+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::state_dtype(&self, options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
126+
127+
pub struct vortex_array::aggregate_fn::fns::sum::SumOptions
128+
129+
pub vortex_array::aggregate_fn::fns::sum::SumOptions::checked: bool
130+
131+
impl core::clone::Clone for vortex_array::aggregate_fn::fns::sum::SumOptions
132+
133+
pub fn vortex_array::aggregate_fn::fns::sum::SumOptions::clone(&self) -> vortex_array::aggregate_fn::fns::sum::SumOptions
134+
135+
impl core::cmp::Eq for vortex_array::aggregate_fn::fns::sum::SumOptions
136+
137+
impl core::cmp::PartialEq for vortex_array::aggregate_fn::fns::sum::SumOptions
138+
139+
pub fn vortex_array::aggregate_fn::fns::sum::SumOptions::eq(&self, other: &vortex_array::aggregate_fn::fns::sum::SumOptions) -> bool
140+
141+
impl core::default::Default for vortex_array::aggregate_fn::fns::sum::SumOptions
142+
143+
pub fn vortex_array::aggregate_fn::fns::sum::SumOptions::default() -> vortex_array::aggregate_fn::fns::sum::SumOptions
144+
145+
impl core::fmt::Debug for vortex_array::aggregate_fn::fns::sum::SumOptions
146+
147+
pub fn vortex_array::aggregate_fn::fns::sum::SumOptions::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
148+
149+
impl core::fmt::Display for vortex_array::aggregate_fn::fns::sum::SumOptions
150+
151+
pub fn vortex_array::aggregate_fn::fns::sum::SumOptions::fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result
152+
153+
impl core::hash::Hash for vortex_array::aggregate_fn::fns::sum::SumOptions
154+
155+
pub fn vortex_array::aggregate_fn::fns::sum::SumOptions::hash<__H: core::hash::Hasher>(&self, state: &mut __H)
156+
157+
impl core::marker::Copy for vortex_array::aggregate_fn::fns::sum::SumOptions
158+
159+
impl core::marker::StructuralPartialEq for vortex_array::aggregate_fn::fns::sum::SumOptions
160+
33161
pub mod vortex_array::aggregate_fn::session
34162

35163
pub struct vortex_array::aggregate_fn::session::AggregateFnSession
@@ -42,7 +170,7 @@ pub fn vortex_array::aggregate_fn::session::AggregateFnSession::registry(&self)
42170

43171
impl core::default::Default for vortex_array::aggregate_fn::session::AggregateFnSession
44172

45-
pub fn vortex_array::aggregate_fn::session::AggregateFnSession::default() -> vortex_array::aggregate_fn::session::AggregateFnSession
173+
pub fn vortex_array::aggregate_fn::session::AggregateFnSession::default() -> Self
46174

47175
impl core::fmt::Debug for vortex_array::aggregate_fn::session::AggregateFnSession
48176

@@ -166,9 +294,9 @@ pub fn vortex_array::aggregate_fn::AggregateFnPlugin::id(&self) -> vortex_array:
166294

167295
impl<V: vortex_array::aggregate_fn::AggregateFnVTable> vortex_array::aggregate_fn::AggregateFnPlugin for V
168296

169-
pub fn V::deserialize(&self, metadata: &[u8], session: &vortex_session::VortexSession) -> vortex_error::VortexResult<vortex_array::aggregate_fn::AggregateFnRef>
297+
pub fn V::deserialize(&self, metadata: &[u8], session: &vortex_session::VortexSession) -> core::result::Result<vortex_array::aggregate_fn::AggregateFnRef, vortex_error::VortexError>
170298

171-
pub fn V::id(&self) -> vortex_array::aggregate_fn::AggregateFnId
299+
pub fn V::id(&self) -> arcref::ArcRef<str>
172300

173301
pub trait vortex_array::aggregate_fn::AggregateFnVTable: 'static + core::marker::Sized + core::clone::Clone + core::marker::Send + core::marker::Sync
174302

@@ -186,6 +314,70 @@ pub fn vortex_array::aggregate_fn::AggregateFnVTable::serialize(&self, options:
186314

187315
pub fn vortex_array::aggregate_fn::AggregateFnVTable::state_dtype(&self, options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
188316

317+
impl vortex_array::aggregate_fn::AggregateFnVTable for vortex_array::aggregate_fn::fns::mean::Mean
318+
319+
pub type vortex_array::aggregate_fn::fns::mean::Mean::Options = vortex_array::scalar_fn::EmptyOptions
320+
321+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::accumulator(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<alloc::boxed::Box<dyn vortex_array::aggregate_fn::Accumulator>>
322+
323+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::deserialize(&self, _metadata: &[u8], _session: &vortex_session::VortexSession) -> vortex_error::VortexResult<Self::Options>
324+
325+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::id(&self) -> vortex_array::aggregate_fn::AggregateFnId
326+
327+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::return_dtype(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
328+
329+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::serialize(&self, options: &Self::Options) -> vortex_error::VortexResult<core::option::Option<alloc::vec::Vec<u8>>>
330+
331+
pub fn vortex_array::aggregate_fn::fns::mean::Mean::state_dtype(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
332+
333+
impl vortex_array::aggregate_fn::AggregateFnVTable for vortex_array::aggregate_fn::fns::min_max::Max
334+
335+
pub type vortex_array::aggregate_fn::fns::min_max::Max::Options = vortex_array::scalar_fn::EmptyOptions
336+
337+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::accumulator(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<alloc::boxed::Box<dyn vortex_array::aggregate_fn::Accumulator>>
338+
339+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::deserialize(&self, _metadata: &[u8], _session: &vortex_session::VortexSession) -> vortex_error::VortexResult<Self::Options>
340+
341+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::id(&self) -> vortex_array::aggregate_fn::AggregateFnId
342+
343+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::return_dtype(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
344+
345+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::serialize(&self, options: &Self::Options) -> vortex_error::VortexResult<core::option::Option<alloc::vec::Vec<u8>>>
346+
347+
pub fn vortex_array::aggregate_fn::fns::min_max::Max::state_dtype(&self, options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
348+
349+
impl vortex_array::aggregate_fn::AggregateFnVTable for vortex_array::aggregate_fn::fns::min_max::Min
350+
351+
pub type vortex_array::aggregate_fn::fns::min_max::Min::Options = vortex_array::scalar_fn::EmptyOptions
352+
353+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::accumulator(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<alloc::boxed::Box<dyn vortex_array::aggregate_fn::Accumulator>>
354+
355+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::deserialize(&self, _metadata: &[u8], _session: &vortex_session::VortexSession) -> vortex_error::VortexResult<Self::Options>
356+
357+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::id(&self) -> vortex_array::aggregate_fn::AggregateFnId
358+
359+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::return_dtype(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
360+
361+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::serialize(&self, options: &Self::Options) -> vortex_error::VortexResult<core::option::Option<alloc::vec::Vec<u8>>>
362+
363+
pub fn vortex_array::aggregate_fn::fns::min_max::Min::state_dtype(&self, options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
364+
365+
impl vortex_array::aggregate_fn::AggregateFnVTable for vortex_array::aggregate_fn::fns::sum::Sum
366+
367+
pub type vortex_array::aggregate_fn::fns::sum::Sum::Options = vortex_array::aggregate_fn::fns::sum::SumOptions
368+
369+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::accumulator(&self, options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<alloc::boxed::Box<dyn vortex_array::aggregate_fn::Accumulator>>
370+
371+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::deserialize(&self, _metadata: &[u8], _session: &vortex_session::VortexSession) -> vortex_error::VortexResult<Self::Options>
372+
373+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::id(&self) -> vortex_array::aggregate_fn::AggregateFnId
374+
375+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::return_dtype(&self, _options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
376+
377+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::serialize(&self, options: &Self::Options) -> vortex_error::VortexResult<core::option::Option<alloc::vec::Vec<u8>>>
378+
379+
pub fn vortex_array::aggregate_fn::fns::sum::Sum::state_dtype(&self, options: &Self::Options, input_dtype: &vortex_array::dtype::DType) -> vortex_error::VortexResult<vortex_array::dtype::DType>
380+
189381
pub trait vortex_array::aggregate_fn::AggregateFnVTableExt: vortex_array::aggregate_fn::AggregateFnVTable
190382

191383
pub fn vortex_array::aggregate_fn::AggregateFnVTableExt::bind(&self, options: Self::Options) -> vortex_array::aggregate_fn::AggregateFnRef

0 commit comments

Comments
 (0)