chore: Bump to rust 2024-02-08 (also 1.78) (#15456)

* ci: Bump version to 2024-02-08 (the same commit with 1.78)

Signed-off-by: Xuanwo <github@xuanwo.io>

* chore: Bump to rust 2024-02-08 (also 1.78)

Signed-off-by: Xuanwo <github@xuanwo.io>

---------

Signed-off-by: Xuanwo <github@xuanwo.io>

Author: Xuanwo

rust-toolchain.toml

@@ -1,3 +1,3 @@
 [toolchain]
-channel = "nightly-2024-01-23"
+channel = "nightly-2024-02-08"
 components = ["rustfmt", "clippy", "rust-src", "miri", "rust-analyzer"]

src/common/arrow/src/lib.rs

@@ -17,6 +17,7 @@
 #![cfg_attr(feature = "simd", feature(portable_simd))]
 #![allow(clippy::redundant_closure_call)]
 #![allow(clippy::non_canonical_partial_ord_impl)]
+#![allow(dead_code)]
 
 //#[macro_use]
 // mod errors;

src/common/io/src/binary_write.rs

@@ -12,7 +12,6 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-use bytes::BufMut;
 use databend_common_exception::Result;
 use micromarshal::Marshal;
 
@@ -85,62 +84,6 @@ where T: std::io::Write
     }
 }
 
-// Another trait like BinaryWrite
-// This is aimed to make BufMut to implement it
-pub trait BinaryWriteBuf {
-    fn write_scalar<V>(&mut self, v: &V) -> Result<()>
-    where V: Marshal + StatBuffer;
-
-    fn write_opt_scalar<V>(&mut self, v: &Option<V>) -> Result<()>
-    where V: Marshal + StatBuffer {
-        match v {
-            Some(v) => {
-                self.write_scalar(&1u8)?;
-                self.write_scalar(v)
-            }
-            None => self.write_scalar(&0u8),
-        }
-    }
-    fn write_string(&mut self, text: impl AsRef<str>) -> Result<()>;
-    fn write_uvarint(&mut self, v: u64) -> Result<()>;
-    fn write_binary(&mut self, text: impl AsRef<[u8]>) -> Result<()>;
-}
-
-// We must ensure there are enough buffer to write because BytesMut do not implicitly grow the buffer.
-impl<T> BinaryWriteBuf for T
-where T: BufMut
-{
-    fn write_scalar<V>(&mut self, v: &V) -> Result<()>
-    where V: Marshal + StatBuffer {
-        let mut buffer = V::buffer();
-        v.marshal(buffer.as_mut());
-
-        self.put_slice(buffer.as_ref());
-        Ok(())
-    }
-
-    fn write_string(&mut self, text: impl AsRef<str>) -> Result<()> {
-        let bytes = text.as_ref().as_bytes();
-        self.write_uvarint(bytes.len() as u64)?;
-        self.put_slice(bytes);
-        Ok(())
-    }
-
-    fn write_uvarint(&mut self, v: u64) -> Result<()> {
-        let mut scratch = [0u8; MAX_VARINT_LEN64];
-        let ln = put_uvarint(&mut scratch[..], v);
-        self.put_slice(&scratch[..ln]);
-        Ok(())
-    }
-
-    fn write_binary(&mut self, text: impl AsRef<[u8]>) -> Result<()> {
-        let bytes = text.as_ref();
-        self.write_uvarint(bytes.len() as u64)?;
-        self.put_slice(bytes);
-        Ok(())
-    }
-}
-
 // put_uvarint encodes a uint64 into buf and returns the number of bytes written.
 // If the buffer is too small, put_uvarint will panic.
 pub fn put_uvarint(mut buffer: impl AsMut<[u8]>, x: u64) -> usize {

src/meta/raft-store/src/sm_v002/leveled_store/map_api.rs

@@ -95,6 +95,7 @@ where K: MapKey
 }
 
 /// Trait for using Self as an implementation of the MapApi.
+#[allow(dead_code)]
 pub(in crate::sm_v002) trait AsMap {
     /// Use Self as an implementation of the [`MapApiRO`] (Read-Only) interface.
     fn as_map<K: MapKey>(&self) -> &impl MapApiRO<K>

src/query/expression/src/lib.rs

@@ -40,6 +40,7 @@
 #![feature(lazy_cell)]
 #![feature(try_blocks)]
 #![feature(let_chains)]
+#![feature(trait_upcasting)]
 
 #[allow(dead_code)]
 mod block;

src/query/service/src/pipelines/processors/transforms/group_by/aggregator_state_entity.rs

@@ -17,7 +17,6 @@ mod aggregator_keys_builder;
 mod aggregator_keys_iter;
 mod aggregator_polymorphic_keys;
 mod aggregator_state;
-mod aggregator_state_entity;
 mod large_number;
 
 pub use aggregator_groups_builder::*;

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

@@ -14,20 +14,11 @@
 
 use std::sync::Arc;
 
-use databend_common_arrow::arrow::io::ipc::write::WriteOptions;
-use databend_common_arrow::arrow::io::ipc::IpcField;
 use databend_common_expression::DataSchemaRef;
 
 use crate::servers::flight::v1::exchange::ExchangeInjector;
 use crate::servers::flight::v1::scatter::FlightScatter;
 
-#[derive(Clone)]
-pub struct SerializeParams {
-    pub options: WriteOptions,
-    pub ipc_fields: Vec<IpcField>,
-    pub local_executor_pos: usize,
-}
-
 #[derive(Clone)]
 pub struct ShuffleExchangeParams {
     pub query_id: String,