File tree Expand file tree Collapse file tree 2 files changed +4
-1
lines changed Expand file tree Collapse file tree 2 files changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -46,6 +46,7 @@ use std::{
4646use tokio:: task:: JoinSet ;
4747use tracing:: { error, info, trace, warn} ;
4848
49+ use crate :: utils:: DATASET_STATS_STREAM_NAME ;
4950use crate :: {
5051 cli:: Options ,
5152 event:: {
@@ -70,7 +71,7 @@ use super::{
7071 } ,
7172 LogStream , ARROW_FILE_EXTENSION ,
7273} ;
73- const DATASET_STATS_STREAM_NAME : & str = "pstats" ;
74+
7475const MAX_CONCURRENT_FIELD_STATS : usize = 10 ;
7576
7677#[ derive( Serialize , Debug ) ]
Original file line number Diff line number Diff line change @@ -37,6 +37,8 @@ use datafusion::common::tree_node::TreeNode;
3737use regex:: Regex ;
3838use sha2:: { Digest , Sha256 } ;
3939
40+ pub const DATASET_STATS_STREAM_NAME : & str = "pstats" ;
41+
4042pub fn get_node_id ( ) -> String {
4143 let now = Utc :: now ( ) . to_rfc3339 ( ) ;
4244 let id = get_hash ( & now) . to_string ( ) . split_at ( 15 ) . 0 . to_string ( ) ;
You can’t perform that action at this time.
0 commit comments