CodeCow/roapi
1
0
Fork 0
mirror of https://github.com/roapi/roapi.git synced 2026-06-05 21:04:02 +08:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

change default batch size to 8192 (#112)

Browse Source
This commit is contained in:
QP Hou 2021-11-21 19:12:25 -08:00 committed by GitHub
parent c439cf2bbd
commit ede97cb05f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
columnq/src/table/mod.rs
View File

@ -297,7 +297,7 @@ pub struct TableSource {
pub schema: Option<TableSchema>,
pub option: Option<TableLoadOption>,
#[serde(default = "TableSource::default_batch_size")]
pub batch_size: usize
pub batch_size: usize,
}
impl TableSource {
@ -306,7 +306,7 @@ impl TableSource {
name: name.into(),
io_source: source.into(),
schema: None,
option: None,
option: None,
batch_size: Self::default_batch_size(),
}
}
@ -317,7 +317,7 @@ impl TableSource {
#[inline]
pub fn default_batch_size() -> usize {
1024
8192
}
pub fn with_option(mut self, option: impl Into<TableLoadOption>) -> Self {
@ -538,12 +538,12 @@ uri: "test_data/ubuntu-ami.json"
batch_size: 512
"#,
)?;
assert_eq!(table_source.batch_size, 512);
Ok(())
}
#[test]
fn test_parse_table_uri() {
let t = parse_table_uri_arg("t=a/b/c").unwrap();