Enum PlanError

pub enum PlanError {
    Unsupported {
        feature: String,
        discussion_no: Option<usize>,
    },
    NeverSupported {
        feature: String,
        documentation_link: Option<String>,
        details: Option<String>,
    },
    UnknownColumn {
        table: Option<PartialItemName>,
        column: ColumnName,
        similar: Box<[ColumnName]>,
    },
    UngroupedColumn {
        table: Option<PartialItemName>,
        column: ColumnName,
    },
    WrongJoinTypeForLateralColumn {
        table: Option<PartialItemName>,
        column: ColumnName,
    },
    AmbiguousColumn(ColumnName),
    TooManyColumns {
        max_num_columns: usize,
        req_num_columns: usize,
    },
    ColumnAlreadyExists {
        column_name: ColumnName,
        object_name: String,
    },
    AmbiguousTable(PartialItemName),
    UnknownColumnInUsingClause {
        column: ColumnName,
        join_side: JoinSide,
    },
    AmbiguousColumnInUsingClause {
        column: ColumnName,
        join_side: JoinSide,
    },
    MisqualifiedName(String),
    OverqualifiedDatabaseName(String),
    OverqualifiedSchemaName(String),
    UnderqualifiedColumnName(String),
    SubqueriesDisallowed {
        context: String,
    },
    UnknownParameter(usize),
    ParameterNotAllowed(String),
    WrongParameterType(usize, String, String),
    RecursionLimit(RecursionLimitError),
    StrconvParse(ParseError),
    Catalog(CatalogError),
    UpsertSinkWithoutKey,
    UpsertSinkWithInvalidKey {
        name: String,
        desired_key: Vec<String>,
        valid_keys: Vec<Vec<String>>,
    },
    InvalidWmrRecursionLimit(String),
    InvalidNumericMaxScale(InvalidNumericMaxScaleError),
    InvalidCharLength(InvalidCharLengthError),
    InvalidId(CatalogItemId),
    InvalidIdent(IdentError),
    InvalidObject(Box<ResolvedItemName>),
    InvalidObjectType {
        expected_type: SystemObjectType,
        actual_type: SystemObjectType,
        object_name: String,
    },
    InvalidPrivilegeTypes {
        invalid_privileges: AclMode,
        object_description: ErrorMessageObjectDescription,
    },
    InvalidVarCharMaxLength(InvalidVarCharMaxLengthError),
    InvalidTimestampPrecision(InvalidTimestampPrecisionError),
    InvalidSecret(Box<ResolvedItemName>),
    InvalidTemporarySchema,
    InvalidCast {
        name: String,
        ccx: CastContext,
        from: String,
        to: String,
    },
    InvalidTable {
        name: String,
    },
    InvalidVersion {
        name: String,
        version: String,
    },
    MangedReplicaName(String),
    ParserStatement(ParserStatementError),
    Parser(ParserError),
    DropViewOnMaterializedView(String),
    DependentObjectsStillExist {
        object_type: String,
        object_name: String,
        dependents: Vec<(String, String)>,
    },
    AlterViewOnMaterializedView(String),
    ShowCreateViewOnMaterializedView(String),
    ExplainViewOnMaterializedView(String),
    UnacceptableTimelineName(String),
    FetchingCsrSchemaFailed {
        schema_lookup: String,
        cause: Arc<dyn Error + Send + Sync>,
    },
    PostgresConnectionErr {
        cause: Arc<PostgresError>,
    },
    MySqlConnectionErr {
        cause: Arc<MySqlError>,
    },
    SqlServerConnectionErr {
        cause: Arc<SqlServerError>,
    },
    SubsourceNameConflict {
        name: UnresolvedItemName,
        upstream_references: Vec<UnresolvedItemName>,
    },
    SubsourceDuplicateReference {
        name: UnresolvedItemName,
        target_names: Vec<UnresolvedItemName>,
    },
    NoTablesFoundForSchemas(Vec<String>),
    InvalidProtobufSchema {
        cause: OperationFailedError,
    },
    InvalidOptionValue {
        option_name: String,
        err: Box<PlanError>,
    },
    UnexpectedDuplicateReference {
        name: UnresolvedItemName,
    },
    RecursiveTypeMismatch(String, Vec<String>, Vec<String>),
    UnknownFunction {
        name: String,
        arg_types: Vec<String>,
    },
    IndistinctFunction {
        name: String,
        arg_types: Vec<String>,
    },
    UnknownOperator {
        name: String,
        arg_types: Vec<String>,
    },
    IndistinctOperator {
        name: String,
        arg_types: Vec<String>,
    },
    InvalidPrivatelinkAvailabilityZone {
        name: String,
        supported_azs: BTreeSet<String>,
    },
    DuplicatePrivatelinkAvailabilityZone {
        duplicate_azs: BTreeSet<String>,
    },
    InvalidSchemaName,
    ItemAlreadyExists {
        name: String,
        item_type: CatalogItemType,
    },
    ManagedCluster {
        cluster_name: String,
    },
    InvalidKeysInSubscribeEnvelopeUpsert,
    InvalidKeysInSubscribeEnvelopeDebezium,
    InvalidPartitionByEnvelopeDebezium {
        column_name: String,
    },
    InvalidOrderByInSubscribeWithinTimestampOrderBy,
    FromValueRequiresParen,
    VarError(VarError),
    UnsolvablePolymorphicFunctionInput,
    ShowCommandInView,
    WebhookValidationDoesNotUseColumns,
    WebhookValidationNonDeterministic,
    InternalFunctionCall,
    CommentTooLong {
        length: usize,
        max_size: usize,
    },
    InvalidTimestampInterval {
        min: Duration,
        max: Duration,
        requested: Duration,
    },
    InvalidGroupSizeHints,
    PgSourcePurification(PgSourcePurificationError),
    KafkaSourcePurification(KafkaSourcePurificationError),
    KafkaSinkPurification(KafkaSinkPurificationError),
    IcebergSinkPurification(IcebergSinkPurificationError),
    LoadGeneratorSourcePurification(LoadGeneratorSourcePurificationError),
    CsrPurification(CsrPurificationError),
    MySqlSourcePurification(MySqlSourcePurificationError),
    SqlServerSourcePurificationError(SqlServerSourcePurificationError),
    UseTablesForSources(String),
    MissingName(CatalogItemType),
    InvalidRefreshAt,
    InvalidRefreshEveryAlignedTo,
    CreateReplicaFailStorageObjects {
        current_replica_count: usize,
        internal_replica_count: usize,
        hypothetical_replica_count: usize,
    },
    MismatchedObjectType {
        name: PartialItemName,
        is_type: ObjectType,
        expected_type: ObjectType,
    },
    TableContainsUningestableTypes {
        name: String,
        type_: String,
        column: String,
    },
    RetainHistoryLow {
        limit: Duration,
    },
    RetainHistoryRequired,
    UntilReadyTimeoutRequired,
    SubsourceResolutionError(ExternalReferenceResolutionError),
    Replan(String),
    NetworkPolicyLockoutError,
    NetworkPolicyInUse,
    ConstantExpressionSimplificationFailed(String),
    InvalidOffset(String),
    UnknownCursor(String),
    CopyFromTargetTableDropped {
        target_name: String,
    },
    InvalidAsOfUpTo,
    Unstructured(String),
}

Variants

Unsupported

This feature is not yet supported, but may be supported at some point in the future.

Fields

feature: String

discussion_no: Option<usize>

NeverSupported

This feature is not supported, and will likely never be supported.

Fields

feature: String

documentation_link: Option<String>

details: Option<String>

UnknownColumn

Fields

table: Option<PartialItemName>

column: ColumnName

similar: Box<[ColumnName]>

UngroupedColumn

Fields

table: Option<PartialItemName>

column: ColumnName

WrongJoinTypeForLateralColumn

Fields

table: Option<PartialItemName>

column: ColumnName

AmbiguousColumn(ColumnName)

TooManyColumns

Fields

max_num_columns: usize

req_num_columns: usize

ColumnAlreadyExists

Fields

column_name: ColumnName

object_name: String

AmbiguousTable(PartialItemName)

UnknownColumnInUsingClause

Fields

column: ColumnName

join_side: JoinSide

AmbiguousColumnInUsingClause

Fields

column: ColumnName

join_side: JoinSide

MisqualifiedName(String)

OverqualifiedDatabaseName(String)

OverqualifiedSchemaName(String)

UnderqualifiedColumnName(String)

SubqueriesDisallowed

Fields

context: String

UnknownParameter(usize)

ParameterNotAllowed(String)

WrongParameterType(usize, String, String)

RecursionLimit(RecursionLimitError)

StrconvParse(ParseError)

Catalog(CatalogError)

UpsertSinkWithoutKey

UpsertSinkWithInvalidKey

Fields

name: String

desired_key: Vec<String>

valid_keys: Vec<Vec<String>>

InvalidWmrRecursionLimit(String)

InvalidNumericMaxScale(InvalidNumericMaxScaleError)

InvalidCharLength(InvalidCharLengthError)

InvalidId(CatalogItemId)

InvalidIdent(IdentError)

InvalidObject(Box<ResolvedItemName>)

InvalidObjectType

Fields

expected_type: SystemObjectType

actual_type: SystemObjectType

object_name: String

InvalidPrivilegeTypes

Fields

invalid_privileges: AclMode

object_description: ErrorMessageObjectDescription

InvalidVarCharMaxLength(InvalidVarCharMaxLengthError)

InvalidTimestampPrecision(InvalidTimestampPrecisionError)

InvalidSecret(Box<ResolvedItemName>)

InvalidTemporarySchema

InvalidCast

Fields

name: String

ccx: CastContext

from: String

to: String

InvalidTable

Fields

name: String

InvalidVersion

Fields

name: String

version: String

MangedReplicaName(String)

ParserStatement(ParserStatementError)

Parser(ParserError)

DropViewOnMaterializedView(String)

DependentObjectsStillExist

Fields

object_type: String

object_name: String

dependents: Vec<(String, String)>

AlterViewOnMaterializedView(String)

ShowCreateViewOnMaterializedView(String)

ExplainViewOnMaterializedView(String)

UnacceptableTimelineName(String)

FetchingCsrSchemaFailed

Fields

schema_lookup: String

cause: Arc<dyn Error + Send + Sync>

PostgresConnectionErr

Fields

cause: Arc<PostgresError>

MySqlConnectionErr

Fields

cause: Arc<MySqlError>

SqlServerConnectionErr

Fields

cause: Arc<SqlServerError>

SubsourceNameConflict

Fields

name: UnresolvedItemName

upstream_references: Vec<UnresolvedItemName>

SubsourceDuplicateReference

Fields

name: UnresolvedItemName

target_names: Vec<UnresolvedItemName>

NoTablesFoundForSchemas(Vec<String>)

InvalidProtobufSchema

Fields

cause: OperationFailedError

InvalidOptionValue

Fields

option_name: String

err: Box<PlanError>

UnexpectedDuplicateReference

Fields

name: UnresolvedItemName

RecursiveTypeMismatch(String, Vec<String>, Vec<String>)

Declaration of a recursive type did not match the inferred type.

UnknownFunction

Fields

name: String

arg_types: Vec<String>

IndistinctFunction

Fields

name: String

arg_types: Vec<String>

UnknownOperator

Fields

name: String

arg_types: Vec<String>

IndistinctOperator

Fields

name: String

arg_types: Vec<String>

InvalidPrivatelinkAvailabilityZone

Fields

name: String

supported_azs: BTreeSet<String>

DuplicatePrivatelinkAvailabilityZone

Fields

duplicate_azs: BTreeSet<String>

InvalidSchemaName

ItemAlreadyExists

Fields

name: String

item_type: CatalogItemType

ManagedCluster

Fields

cluster_name: String

InvalidKeysInSubscribeEnvelopeUpsert

InvalidKeysInSubscribeEnvelopeDebezium

InvalidPartitionByEnvelopeDebezium

Fields

column_name: String

InvalidOrderByInSubscribeWithinTimestampOrderBy

FromValueRequiresParen

VarError(VarError)

UnsolvablePolymorphicFunctionInput

ShowCommandInView

WebhookValidationDoesNotUseColumns

WebhookValidationNonDeterministic

InternalFunctionCall

CommentTooLong

Fields

length: usize

max_size: usize

InvalidTimestampInterval

Fields

min: Duration

max: Duration

requested: Duration

InvalidGroupSizeHints

PgSourcePurification(PgSourcePurificationError)

KafkaSourcePurification(KafkaSourcePurificationError)

KafkaSinkPurification(KafkaSinkPurificationError)

IcebergSinkPurification(IcebergSinkPurificationError)

LoadGeneratorSourcePurification(LoadGeneratorSourcePurificationError)

CsrPurification(CsrPurificationError)

MySqlSourcePurification(MySqlSourcePurificationError)

SqlServerSourcePurificationError(SqlServerSourcePurificationError)

UseTablesForSources(String)

MissingName(CatalogItemType)

InvalidRefreshAt

InvalidRefreshEveryAlignedTo

CreateReplicaFailStorageObjects

Fields

current_replica_count: usize

The current number of replicas on the cluster

internal_replica_count: usize

THe number of internal replicas on the cluster

hypothetical_replica_count: usize

The number of replicas that executing this command would have created

MismatchedObjectType

Fields

name: PartialItemName

is_type: ObjectType

expected_type: ObjectType

TableContainsUningestableTypes

MZ failed to generate cast for the data type.

Fields

name: String

type_: String

column: String

RetainHistoryLow

Fields

limit: Duration

RetainHistoryRequired

UntilReadyTimeoutRequired

SubsourceResolutionError(ExternalReferenceResolutionError)

Replan(String)

NetworkPolicyLockoutError

NetworkPolicyInUse

ConstantExpressionSimplificationFailed(String)

Expected a constant expression that evaluates without an error to a non-null value.

InvalidOffset(String)

UnknownCursor(String)

The named cursor does not exist.

CopyFromTargetTableDropped

Fields

target_name: String

InvalidAsOfUpTo

AS OF or UP TO should be an expression that is castable and simplifiable to a non-null mz_timestamp value.

Unstructured(String)

Implementations

impl PlanError

pub(crate) fn ungrouped_column(item: &ScopeItem) -> PlanError

pub fn detail(&self) -> Option<String>

pub fn hint(&self) -> Option<String>

Trait Implementations

impl Debug for PlanError

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for PlanError

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Error for PlanError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0: use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl From<CatalogError> for PlanError

fn from(e: CatalogError) -> PlanError

Converts to this type from the input type.

impl From<CsrPurificationError> for PlanError

fn from(e: CsrPurificationError) -> Self

Converts to this type from the input type.

impl From<Error> for PlanError

fn from(e: Error) -> PlanError

Converts to this type from the input type.

impl From<EvalError> for PlanError

fn from(e: EvalError) -> PlanError

Converts to this type from the input type.

impl From<ExternalReferenceResolutionError> for PlanError

fn from(e: ExternalReferenceResolutionError) -> Self

Converts to this type from the input type.

impl From<IcebergSinkPurificationError> for PlanError

fn from(e: IcebergSinkPurificationError) -> Self

Converts to this type from the input type.

impl From<IdentError> for PlanError

fn from(e: IdentError) -> Self

Converts to this type from the input type.

impl From<InvalidCharLengthError> for PlanError

fn from(e: InvalidCharLengthError) -> PlanError

Converts to this type from the input type.

impl From<InvalidNumericMaxScaleError> for PlanError

fn from(e: InvalidNumericMaxScaleError) -> PlanError

Converts to this type from the input type.

impl From<InvalidTimestampPrecisionError> for PlanError

fn from(e: InvalidTimestampPrecisionError) -> PlanError

Converts to this type from the input type.

impl From<InvalidVarCharMaxLengthError> for PlanError

fn from(e: InvalidVarCharMaxLengthError) -> PlanError

Converts to this type from the input type.

impl From<KafkaSinkPurificationError> for PlanError

fn from(e: KafkaSinkPurificationError) -> Self

Converts to this type from the input type.

impl From<KafkaSourcePurificationError> for PlanError

fn from(e: KafkaSourcePurificationError) -> Self

Converts to this type from the input type.

impl From<LoadGeneratorSourcePurificationError> for PlanError

fn from(e: LoadGeneratorSourcePurificationError) -> Self

Converts to this type from the input type.

impl From<MySqlError> for PlanError

fn from(e: MySqlError) -> PlanError

Converts to this type from the input type.

impl From<MySqlSourcePurificationError> for PlanError

fn from(e: MySqlSourcePurificationError) -> Self

Converts to this type from the input type.

impl From<ParseError> for PlanError

fn from(e: ParseError) -> PlanError

Converts to this type from the input type.

impl From<ParseIntError> for PlanError

fn from(e: ParseIntError) -> PlanError

Converts to this type from the input type.

impl From<ParserError> for PlanError

fn from(e: ParserError) -> PlanError

Converts to this type from the input type.

impl From<ParserStatementError> for PlanError

fn from(e: ParserStatementError) -> PlanError

Converts to this type from the input type.

impl From<PgSourcePurificationError> for PlanError

fn from(e: PgSourcePurificationError) -> Self

Converts to this type from the input type.

impl From<PostgresError> for PlanError

fn from(e: PostgresError) -> PlanError

Converts to this type from the input type.

impl From<RecursionLimitError> for PlanError

fn from(e: RecursionLimitError) -> PlanError

Converts to this type from the input type.

impl From<SqlServerError> for PlanError

fn from(e: SqlServerError) -> PlanError

Converts to this type from the input type.

impl From<SqlServerSourcePurificationError> for PlanError

fn from(e: SqlServerSourcePurificationError) -> Self

Converts to this type from the input type.

impl From<TryFromIntError> for PlanError

fn from(e: TryFromIntError) -> PlanError

Converts to this type from the input type.

impl From<VarError> for PlanError

fn from(e: VarError) -> Self

Converts to this type from the input type.