Struct ParquetbenchCommand 

pub struct ParquetbenchCommand {

    config: PathBuf,
    region_id: String,
    table_dir: String,
    file_id: String,
    scan_config: Option<PathBuf>,
    iterations: usize,
    batch_size: usize,
    path_type: String,
    verbose: bool,
    pprof_file: Option<PathBuf>,
    pprof_after_warmup: bool,
    pk_as_binary: bool,
    reader: ReaderMode,
}

Parquet benchmark command - benchmarks scanning a single parquet SST directly.

Fields

config: PathBuf

Path to config TOML file (same format as standalone/datanode config)

region_id: String

Region ID: either numeric u64 (e.g. “4398046511104”) or “table_id:region_num” (e.g. “1024:0”)

table_dir: String

Table directory relative to data home (e.g. “data/greptime/public/1024/”)

file_id: String

SST file id to benchmark.

scan_config: Option<PathBuf>

Path to scan request JSON config file (supports projection_names only)

iterations: usize

Number of iterations for benchmarking

batch_size: usize

Number of rows per record batch for the direct reader.

path_type: String

Path type for the region: bare, data, metadata

verbose: bool

Verbose output

pprof_file: Option<PathBuf>

Output pprof flamegraph

pprof_after_warmup: bool

Start pprof after the first iteration (use first iteration as warmup).

pk_as_binary: bool

Read the __primary_key column as BinaryArray instead of DictionaryArray. Only affects the direct reader.

reader: ReaderMode

Reader implementation to benchmark.

Implementations

impl ParquetbenchCommand

pub async fn run(&self) -> Result<()>

async fn load_scan_config(&self) -> Result<ParquetScanConfig>

Trait Implementations

impl Args for ParquetbenchCommand

fn group_id() -> Option<Id>

Report the [ArgGroup::id][crate::ArgGroup::id] for this set of arguments

fn augment_args<'b>(__clap_app: Command) -> Command

Append to [Command] so it can instantiate Self via [FromArgMatches::from_arg_matches_mut]

fn augment_args_for_update<'b>(__clap_app: Command) -> Command

Append to [Command] so it can instantiate self via [FromArgMatches::update_from_arg_matches_mut]

impl CommandFactory for ParquetbenchCommand

fn command<'b>() -> Command

Build a [Command] that can instantiate Self.

fn command_for_update<'b>() -> Command

Build a [Command] that can update self.

impl Debug for ParquetbenchCommand

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl FromArgMatches for ParquetbenchCommand

fn from_arg_matches(__clap_arg_matches: &ArgMatches) -> Result<Self, Error>

Instantiate Self from [ArgMatches], parsing the arguments as needed.

fn from_arg_matches_mut( __clap_arg_matches: &mut ArgMatches, ) -> Result<Self, Error>

Instantiate Self from [ArgMatches], parsing the arguments as needed.

fn update_from_arg_matches( &mut self, __clap_arg_matches: &ArgMatches, ) -> Result<(), Error>

Assign values from ArgMatches to self.

fn update_from_arg_matches_mut( &mut self, __clap_arg_matches: &mut ArgMatches, ) -> Result<(), Error>

Assign values from ArgMatches to self.

impl Parser for ParquetbenchCommand

fn parse() -> Self

Parse from std::env::args_os(), [exit][Error::exit] on error.

fn try_parse() -> Result<Self, Error>

Parse from std::env::args_os(), return Err on error.

fn parse_from<I, T>(itr: I) -> Self

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Parse from iterator, [exit][Error::exit] on error.

fn try_parse_from<I, T>(itr: I) -> Result<Self, Error>

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Parse from iterator, return Err on error.

fn update_from<I, T>(&mut self, itr: I)

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Update from iterator, [exit][Error::exit] on error.

fn try_update_from<I, T>(&mut self, itr: I) -> Result<(), Error>

where I: IntoIterator<Item = T>, T: Into<OsString> + Clone,

Update from iterator, return Err on error.