Method batch_size

datafusion/execution/src/config.rs:393–395 · view source on GitHub ↗

Get the currently configured batch size

(&self)

Source from the content-addressed store, hash-verified

391
392	/// Get the currently configured batch size
393	pub fn batch_size(&self) -> usize {
394	self.options.execution.batch_size
395	}
396
397	/// Enables or disables the coalescence of small batches into larger batches
398	pub fn with_coalesce_batches(mut self, enabled: bool) -> Self {

executeMethod · 0.45

open_with_argsMethod · 0.45

map_logical_node_to_physicalMethod · 0.45

run_limit_testFunction · 0.45

run_sort_test_with_limited_memoryFunction · 0.45

run_test_aggregate_with_high_cardinalityFunction · 0.45

consume_stream_and_simulate_other_running_memory_consumersFunction · 0.45

createMethod · 0.45

no outgoing calls

run_limit_testFunction · 0.36

run_sort_test_with_limited_memoryFunction · 0.36

run_test_aggregate_with_high_cardinalityFunction · 0.36

consume_stream_and_simulate_other_running_memory_consumersFunction · 0.36