feat: basic implementation of TransformWindow. (#10772)

Author: RinChanNOWWW

src/query/service/src/pipelines/processors/mod.rs

@@ -39,3 +39,6 @@ pub use transforms::TransformLimit;
 pub use transforms::TransformResortAddOn;
 pub use transforms::TransformRuntimeFilter;
 pub use transforms::TransformSortPartial;
+pub use transforms::TransformWindow;
+pub use transforms::WindowFrame;
+pub use transforms::WindowFrameBound;

src/query/service/src/pipelines/processors/transforms/mod.rs

@@ -21,6 +21,7 @@ mod transform_hash_join;
 mod transform_left_join;
 mod transform_limit;
 mod transform_mark_join;
+mod window;
 
 mod profile_wrapper;
 mod runtime_filter;
@@ -90,3 +91,6 @@ pub use transform_runtime_filter::SinkRuntimeFilterSource;
 pub use transform_runtime_filter::TransformRuntimeFilter;
 pub use transform_sort_merge::SortMergeCompactor;
 pub use transform_sort_partial::TransformSortPartial;
+pub use window::TransformWindow;
+pub use window::WindowFrame;
+pub use window::WindowFrameBound;

src/query/service/src/pipelines/processors/transforms/window/frame.rs

@@ -0,0 +1,30 @@
+// Copyright 2023 Datafuse Labs.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#[derive(Clone)]
+pub enum WindowFrameBound {
+    /// `CURRENT ROW`
+    CurrentRow,
+    /// `<N> PRECEDING` or `UNBOUNDED PRECEDING`.
+    Preceding(Option<usize>),
+    /// `<N> FOLLOWING` or `UNBOUNDED FOLLOWING`.
+    Following(Option<usize>),
+}
+
+#[derive(Clone)]
+pub struct WindowFrame {
+    // TODO: support RANGE frame, only support Rows frame now.
+    pub start_bound: WindowFrameBound,
+    pub end_bound: WindowFrameBound,
+}

src/query/service/src/pipelines/processors/transforms/window/mod.rs

@@ -0,0 +1,20 @@
+// Copyright 2023 Datafuse Labs.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+mod frame;
+mod transform_window;
+
+pub use frame::WindowFrame;
+pub use frame::WindowFrameBound;
+pub use transform_window::TransformWindow;