Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
yezizp2012 committed Jan 16, 2024
1 parent 5b75f2e commit e523f7e
Show file tree
Hide file tree
Showing 5 changed files with 11 additions and 7 deletions.
2 changes: 1 addition & 1 deletion src/common/src/catalog/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ pub const DEFAULT_SUPER_USER_FOR_PG_ID: u32 = 2;
pub const NON_RESERVED_USER_ID: i32 = 11;
pub const NON_RESERVED_SYS_CATALOG_ID: i32 = 1001;

pub const OBJECT_ID_PLACEHOLDER: u32 = OBJECT_ID_PLACEHOLDER;
pub const OBJECT_ID_PLACEHOLDER: u32 = u32::MAX - 1;

pub const SYSTEM_SCHEMAS: [&str; 3] = [
PG_CATALOG_SCHEMA_NAME,
Expand Down
5 changes: 4 additions & 1 deletion src/connector/src/sink/catalog/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,10 @@ use std::collections::{BTreeMap, HashMap};

use anyhow::anyhow;
use itertools::Itertools;
use risingwave_common::catalog::{ColumnCatalog, ConnectionId, DatabaseId, Field, OBJECT_ID_PLACEHOLDER, Schema, SchemaId, TableId, UserId};
use risingwave_common::catalog::{
ColumnCatalog, ConnectionId, DatabaseId, Field, Schema, SchemaId, TableId, UserId,
OBJECT_ID_PLACEHOLDER,
};
use risingwave_common::util::epoch::Epoch;
use risingwave_common::util::sort_util::ColumnOrder;
use risingwave_pb::catalog::{PbSink, PbSinkFormatDesc, PbSinkType, PbStreamJobStatus};
Expand Down
3 changes: 1 addition & 2 deletions src/frontend/src/optimizer/plan_node/stream_materialize.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ use std::assert_matches::assert_matches;
use fixedbitset::FixedBitSet;
use itertools::Itertools;
use pretty_xmlish::{Pretty, XmlNode};
use risingwave_common::catalog::{ColumnCatalog, ConflictBehavior, OBJECT_ID_PLACEHOLDER, TableId};
use risingwave_common::catalog::{ColumnCatalog, ConflictBehavior, TableId, OBJECT_ID_PLACEHOLDER};
use risingwave_common::error::Result;
use risingwave_common::util::iter_util::ZipEqFast;
use risingwave_common::util::sort_util::{ColumnOrder, OrderType};
Expand All @@ -29,7 +29,6 @@ use super::stream::StreamPlanRef;
use super::utils::{childless_record, Distill};
use super::{reorganize_elements_id, ExprRewritable, PlanRef, PlanTreeNodeUnary, StreamNode};
use crate::catalog::table_catalog::{CreateType, TableCatalog, TableType, TableVersion};
use crate::catalog::FragmentId;
use crate::optimizer::plan_node::derive::derive_pk;
use crate::optimizer::plan_node::expr_visitable::ExprVisitable;
use crate::optimizer::plan_node::generic::GenericPlanRef;
Expand Down
6 changes: 4 additions & 2 deletions src/frontend/src/optimizer/plan_node/utils.rs
Original file line number Diff line number Diff line change
Expand Up @@ -19,11 +19,13 @@ use std::vec;
use fixedbitset::FixedBitSet;
use itertools::Itertools;
use pretty_xmlish::{Pretty, Str, StrAssocArr, XmlNode};
use risingwave_common::catalog::{ColumnCatalog, ColumnDesc, ConflictBehavior, Field, FieldDisplay, OBJECT_ID_PLACEHOLDER, Schema};
use risingwave_common::catalog::{
ColumnCatalog, ColumnDesc, ConflictBehavior, Field, FieldDisplay, Schema, OBJECT_ID_PLACEHOLDER,
};
use risingwave_common::util::sort_util::{ColumnOrder, OrderType};

use crate::catalog::table_catalog::{CreateType, TableType};
use crate::catalog::{ColumnId, FragmentId, TableCatalog, TableId};
use crate::catalog::{ColumnId, TableCatalog, TableId};
use crate::optimizer::property::Cardinality;
use crate::utils::WithOptions;

Expand Down
2 changes: 1 addition & 1 deletion src/meta/model_v2/src/table.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,8 @@
// See the License for the specific language governing permissions and
// limitations under the License.

use risingwave_pb::catalog::table::{OptionalAssociatedSourceId, PbTableType};
use risingwave_common::catalog::OBJECT_ID_PLACEHOLDER;
use risingwave_pb::catalog::table::{OptionalAssociatedSourceId, PbTableType};
use risingwave_pb::catalog::{PbHandleConflictBehavior, PbTable};
use sea_orm::entity::prelude::*;
use sea_orm::ActiveValue::Set;
Expand Down

0 comments on commit e523f7e

Please sign in to comment.