File tree Expand file tree Collapse file tree 4 files changed +10
-4
lines changed
connector/codec/src/decoder
stream/src/executor/backfill/cdc Expand file tree Collapse file tree 4 files changed +10
-4
lines changed Original file line number Diff line number Diff line change @@ -14,6 +14,12 @@ mosquitto = "mosquitto" # This is a MQTT broker.
14
14
abd = " abd"
15
15
iy = " iy"
16
16
Pn = " Pn"
17
+ barreir = " barrier"
18
+ perhapts = " perhaps"
19
+ psrser = " parser"
20
+ extreact = " extract"
21
+ buidler = " builder"
22
+ epoches = " epochs"
17
23
18
24
[default .extend-identifiers ]
19
25
TABLE_SCHEM = " TABLE_SCHEM"
@@ -40,5 +46,5 @@ extend-exclude = [
40
46
# We don't want to fix "Divy" here, but may want in other places.
41
47
" integration_tests/deltalake-sink/spark-script/run-sql-file.sh" ,
42
48
# These files are copied from debezium connector, we don't want to fix their typos
43
- " java/connector-node/risingwave-source-cdc/src/main/java/io/debezium/connector/postgresql/*.java"
49
+ " java/connector-node/risingwave-source-cdc/src/main/java/io/debezium/connector/postgresql/*.java" ,
44
50
]
Original file line number Diff line number Diff line change @@ -550,7 +550,7 @@ pub fn debug_assert_column_ids_distinct(columns: &[ColumnCatalog]) {
550
550
) ;
551
551
}
552
552
553
- /// FIXME: perhapts we should use sth like `ColumnIdGenerator::new_alter`,
553
+ /// FIXME: Perhaps we should use sth like `ColumnIdGenerator::new_alter`,
554
554
/// However, the `SourceVersion` is problematic: It doesn't contain `next_col_id`.
555
555
/// (But for now this isn't a large problem, since drop column is not allowed for source yet..)
556
556
///
Original file line number Diff line number Diff line change @@ -73,7 +73,7 @@ pub trait Access {
73
73
/// TODO: the meaning of `path` is a little confusing and maybe over-abstracted.
74
74
/// `access` does not need to serve arbitrarily deep `path` access, but just "top-level" access.
75
75
/// The API creates an illusion that arbitrary access is supported, but it's not.
76
- /// Perhapts we should separate out another trait like `ToDatum`,
76
+ /// Perhaps we should separate out another trait like `ToDatum`,
77
77
/// which only does type mapping, without caring about the path. And `path` itself is only an `enum` instead of `&[&str]`.
78
78
///
79
79
/// What `path` to access is decided by the CDC layer, i.e., the `FORMAT ...` part (`ChangeEvent`).
Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ pub use upstream_table::external::ExternalStorageTable;
24
24
pub struct CdcScanOptions {
25
25
/// Whether to disable backfill
26
26
pub disable_backfill : bool ,
27
- /// Barreir interval to start a new snapshot read
27
+ /// Barrier interval to start a new snapshot read
28
28
pub snapshot_interval : u32 ,
29
29
/// Batch size for a snapshot read query
30
30
pub snapshot_batch_size : u32 ,
You can’t perform that action at this time.
0 commit comments