risingwave_common/array/
error.rs

1// Copyright 2025 RisingWave Labs
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15use std::convert::Infallible;
16
17pub use anyhow::anyhow;
18use risingwave_pb::PbFieldNotFound;
19use thiserror::Error;
20use thiserror_ext::Construct;
21
22use crate::error::BoxedError;
23
24#[derive(Error, Debug, Construct)]
25pub enum ArrayError {
26    #[error("Pb decode error: {0}")]
27    PbDecode(#[from] prost::DecodeError),
28
29    #[error("I/O error: {0}")]
30    Io(#[from] std::io::Error),
31
32    #[error(transparent)]
33    Internal(
34        #[from]
35        #[backtrace]
36        anyhow::Error,
37    ),
38
39    #[error("Convert from arrow error: {0}")]
40    FromArrow(
41        #[source]
42        #[backtrace]
43        BoxedError,
44    ),
45
46    #[error("Convert to arrow error: {0}")]
47    ToArrow(
48        #[source]
49        #[backtrace]
50        BoxedError,
51    ),
52}
53
54impl From<PbFieldNotFound> for ArrayError {
55    fn from(err: PbFieldNotFound) -> Self {
56        anyhow!("Failed to decode prost: field not found `{}`", err.0).into()
57    }
58}
59
60impl From<Infallible> for ArrayError {
61    fn from(err: Infallible) -> Self {
62        unreachable!("Infallible error: {:?}", err)
63    }
64}
65
66impl ArrayError {
67    pub fn internal(msg: impl ToString) -> Self {
68        ArrayError::Internal(anyhow!(msg.to_string()))
69    }
70}
risingwave_common/array/error.rs

risingwave_common/array/
error.rs
