rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2025-12-22 22:20:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: is file

Browse Source
This commit is contained in:
discord9
2025-03-09 19:55:12 +08:00
parent b650743785
commit ec34e8739a
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/ingester/src/main.rs
View File

@@ -91,6 +91,11 @@ async fn main() {
.await
.expect("Failed to list parquet files");
let all_parquets = all_parquets
.iter()
.filter(|parquet| parquet.name().ends_with(".parquet") && parquet.metadata().is_file())
.collect::<Vec<_>>();
let input_files = all_parquets
.iter()
.map(|parquet| {
@@ -120,6 +125,11 @@ async fn main() {
.await
.expect("Failed to list json files");
let all_jsons = all_jsons
.iter()
.filter(|json| json.name().ends_with(".json") && json.metadata().is_file())
.collect::<Vec<_>>();
let input_files = all_jsons
.iter()
.map(|entry| {