replace append_record_eliminate_noop_update with append_record

Signed-off-by: Bugen Zhao <i@bugenzhao.com>

Author: BugenZhao

src/stream/src/common/change_buffer.rs

@@ -188,6 +188,12 @@ where
     }
 }
 
+impl<K, R> Default for ChangeBuffer<K, R> {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
 impl<K, R> ChangeBuffer<K, R> {
     /// Create a new `ChangeBuffer` that panics on inconsistency.
     pub fn new() -> Self {

src/stream/src/executor/top_n/group_top_n.rs

@@ -234,7 +234,7 @@ where
         for staging in stagings.into_values() {
             for res in staging.into_deserialized_changes(&deserializer) {
                 let record = res?;
-                let _none = chunk_builder.append_record_eliminate_noop_update(record);
+                let _none = chunk_builder.append_record(record);
             }
         }
         Ok(chunk_builder.take())

src/stream/src/executor/top_n/group_top_n_appendonly.rs

@@ -203,7 +203,7 @@ where
         for staging in stagings.into_values() {
             for res in staging.into_deserialized_changes(&deserializer) {
                 let record = res?;
-                let _none = chunk_builder.append_record_eliminate_noop_update(record);
+                let _none = chunk_builder.append_record(record);
             }
         }
 

src/stream/src/executor/top_n/top_n_appendonly.rs

@@ -134,7 +134,7 @@ where
         let mut chunk_builder = StreamChunkBuilder::unlimited(data_types, Some(staging.len()));
         for res in staging.into_deserialized_changes(&deserializer) {
             let record = res?;
-            let _none = chunk_builder.append_record_eliminate_noop_update(record);
+            let _none = chunk_builder.append_record(record);
         }
         Ok(chunk_builder.take())
     }

src/stream/src/executor/top_n/top_n_plain.rs

@@ -171,7 +171,7 @@ where
         let mut chunk_builder = StreamChunkBuilder::unlimited(data_types, Some(staging.len()));
         for res in staging.into_deserialized_changes(&deserializer) {
             let record = res?;
-            let _none = chunk_builder.append_record_eliminate_noop_update(record);
+            let _none = chunk_builder.append_record(record);
         }
         Ok(chunk_builder.take())
     }