rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-05 21:02:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: skip wal for user table

Browse Source
This commit is contained in:
Lei, HUANG
2023-03-13 20:13:17 +08:00
parent e7daf1226f
commit a4ebd03a61
2 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/storage/src/region/writer.rs
View File

@@ -375,11 +375,16 @@ impl WriterInner {
let next_sequence = committed_sequence + 1;
let version = version_control.current();
let wal_header = WalHeader::with_last_manifest_version(version.manifest_version());
writer_ctx
.wal
.write_to_wal(next_sequence, wal_header, Some(request.payload()))
.await?;
// table with id less than MIN_USER_TABLE_ID is system table
if (region_id >> 32) < 1024 {
let wal_header = WalHeader::with_last_manifest_version(version.manifest_version());
writer_ctx
.wal
.write_to_wal(next_sequence, wal_header, Some(request.payload()))
.await?;
}
// Insert batch into memtable.
let mut inserter = Inserter::new(next_sequence);

4
src/storage/src/sst/parquet.rs
View File

@@ -96,10 +96,6 @@ impl<'a> ParquetWriter<'a> {
.set_column_encoding(ColumnPath::new(vec![ts_col_name]), Encoding::DELTA_BINARY_PACKED)
.set_column_dictionary_enabled(ColumnPath::new(vec!["__sequence".to_string()]), false)
.set_column_encoding(ColumnPath::new(vec!["__sequence".to_string()]), Encoding::DELTA_BINARY_PACKED)
.set_column_dictionary_enabled(ColumnPath::new(vec![ts_col_name.clone()]), false)
.set_column_encoding(ColumnPath::new(vec![ts_col_name]), Encoding::DELTA_BINARY_PACKED)
.set_column_dictionary_enabled(ColumnPath::new(vec!["__sequence".to_string()]), false)
.set_column_encoding(ColumnPath::new(vec!["__sequence".to_string()]), Encoding::DELTA_BINARY_PACKED)
.set_max_row_group_size(self.max_row_group_size)
.set_key_value_metadata(extra_meta.map(|map| {
map.iter()