prefer to use try_collect

Signed-off-by: TennyZhuang <[email protected]>

src/batch/src/executor/values.rs

@@ -23,7 +23,6 @@ use risingwave_common::catalog::{Field, Schema};
 use risingwave_common::error::{Result, RwError};
 use risingwave_common::util::chunk_coalesce::DEFAULT_CHUNK_BUFFER_SIZE;
 use risingwave_expr::expr::{build_from_prost, BoxedExpression};
-use risingwave_expr::ExprResult;
 use risingwave_pb::batch_plan::plan_node::NodeBody;
 
 use crate::executor::{
@@ -118,11 +117,7 @@ impl BoxedExecutorBuilder for ValuesExecutor {
 
         let mut rows: Vec<Vec<BoxedExpression>> = Vec::with_capacity(value_node.get_tuples().len());
         for row in value_node.get_tuples() {
-            let expr_row = row
-                .get_cells()
-                .iter()
-                .map(build_from_prost)
-                .collect::<ExprResult<Vec<BoxedExpression>>>()?;
+            let expr_row: Vec<_> = row.get_cells().iter().map(build_from_prost).try_collect()?;
             rows.push(expr_row);
         }
 

src/expr/src/lib.rs

@@ -39,4 +39,3 @@ pub mod vector_op;
 
 pub use error::ExprError;
 pub type Result<T> = std::result::Result<T, ExprError>;
-pub type ExprResult<T> = Result<T>;

src/stream/src/from_proto/project.rs

@@ -13,7 +13,6 @@
 // limitations under the License.
 
 use risingwave_expr::expr::build_from_prost;
-use risingwave_expr::ExprResult;
 
 use super::*;
 use crate::executor::ProjectExecutor;
@@ -28,11 +27,11 @@ impl ExecutorBuilder for ProjectExecutorBuilder {
         _stream: &mut LocalStreamManagerCore,
     ) -> Result<BoxedExecutor> {
         let node = try_match_expand!(node.get_node_body().unwrap(), NodeBody::Project)?;
-        let project_exprs = node
+        let project_exprs: Vec<_> = node
             .get_select_list()
             .iter()
             .map(build_from_prost)
-            .collect::<ExprResult<Vec<_>>>()?;
+            .try_collect()?;
 
         Ok(ProjectExecutor::new(
             params.input.remove(0),