diff --git a/q18.svg b/q18.svg
new file mode 100644
index 000000000000..5ab02c16c9e4
--- /dev/null
+++ b/q18.svg
@@ -0,0 +1,491 @@
+
\ No newline at end of file
diff --git a/q35.svg b/q35.svg
new file mode 100644
index 000000000000..968c8870da29
--- /dev/null
+++ b/q35.svg
@@ -0,0 +1,491 @@
+Flame Graph Reset ZoomSearch dfbench`dfbench::main (137 samples, 0.38%)dfbench`dfbench::main::_{{closure}} (50 samples, 0.14%)dfbench`datafusion_physical_plan::execution_plan::collect::_{{closure}} (27 samples, 0.07%)dfbench`datafusion::datasource::file_format::parquet::fetch_parquet_metadata::_{{closure}} (10 samples, 0.03%)dfbench`parquet::file::metadata::reader::ParquetMetaDataReader::decode_metadata (10 samples, 0.03%)dfbench`<parquet::format::FileMetaData as parquet::thrift::TSerializable>::read_from_in_protocol (7 samples, 0.02%)dfbench`<parquet::format::ColumnChunk as parquet::thrift::TSerializable>::read_from_in_protocol (6 samples, 0.02%)dfbench`<datafusion::execution::session_state::DefaultQueryPlanner as datafusion::execution::context::QueryPlanner>::create_physical_plan::_{{closure}} (13 samples, 0.04%)dfbench`<datafusion::physical_planner::DefaultPhysicalPlanner as datafusion::physical_planner::PhysicalPlanner>::create_physical_plan::_{{closure}} (13 samples, 0.04%)dfbench`datafusion::physical_planner::DefaultPhysicalPlanner::create_initial_plan::_{{closure}} (11 samples, 0.03%)dfbench`datafusion::physical_planner::DefaultPhysicalPlanner::map_logical_node_to_physical::_{{closure}} (11 samples, 0.03%)dfbench`<datafusion::datasource::listing::table::ListingTable as datafusion_catalog::table::TableProvider>::scan::_{{closure}} (11 samples, 0.03%)dfbench`<futures_util::stream::stream::next::Next<St> as core::future::future::Future>::poll (11 samples, 0.03%)dfbench`<datafusion::datasource::file_format::parquet::ParquetFormat as datafusion::datasource::file_format::FileFormat>::infer_stats::_{{closure}} (11 samples, 0.03%)dfbench`datafusion::dataframe::DataFrame::create_physical_plan::_{{closure}} (19 samples, 0.05%)dfbench`datafusion::execution::session_state::SessionState::create_physical_plan::_{{closure}} (19 samples, 0.05%)dfbench`datafusion::execution::session_state::SessionState::optimize (6 samples, 0.02%)dfbench`<parquet::format::FileMetaData as parquet::thrift::TSerializable>::read_from_in_protocol (7 samples, 0.02%)dfbench`<parquet::format::ColumnChunk as parquet::thrift::TSerializable>::read_from_in_protocol (5 samples, 0.01%)dfbench`datafusion::datasource::listing::table::ListingOptions::infer_schema::_{{closure}} (12 samples, 0.03%)dfbench`<datafusion::datasource::file_format::parquet::ParquetFormat as datafusion::datasource::file_format::FileFormat>::infer_schema::_{{closure}} (12 samples, 0.03%)dfbench`datafusion::datasource::file_format::parquet::fetch_parquet_metadata::_{{closure}} (11 samples, 0.03%)dfbench`parquet::file::metadata::reader::ParquetMetaDataReader::decode_metadata (11 samples, 0.03%)dfbench`datafusion_physical_plan::common::collect::_{{closure}} (20 samples, 0.06%)dfbench`<futures_util::stream::try_stream::try_collect::TryCollect<St,C> as core::future::future::Future>::poll (18 samples, 0.05%)dfbench`<datafusion_physical_plan::sorts::merge::SortPreservingMergeStream<C> as futures_core::stream::Stream>::poll_next (32 samples, 0.09%)dfbench`<alloc::collections::vec_deque::VecDeque<T,A> as core::clone::Clone>::clone (42 samples, 0.12%)dfbench`mi_malloc_aligned (99 samples, 0.27%)dfbench`<alloc::collections::vec_deque::VecDeque<T,A> as core::clone::Clone>::clone (602 samples, 1.67%)libdyld.dylib`tlv_get_addr (32 samples, 0.09%)dfbench`<datafusion_physical_plan::sorts::stream::FieldCursorStream<T> as datafusion_physical_plan::sorts::stream::PartitionedStream>::poll_next (18 samples, 0.05%)dfbench`datafusion_physical_plan::metrics::baseline::BaselineMetrics::record_poll (42 samples, 0.12%)dfbench`<datafusion_physical_plan::stream::RecordBatchStreamAdapter<S> as futures_core::stream::Stream>::poll_next (13 samples, 0.04%)dfbench`<futures_util::stream::select::Select<St1,St2> as futures_core::stream::Stream>::poll_next (25 samples, 0.07%)dfbench`<futures_util::stream::stream::filter_map::FilterMap<St,Fut,F> as futures_core::stream::Stream>::poll_next (197 samples, 0.55%)dfbench`tokio::task::join_set::JoinSet<T>::join_next::_{{closure}} (106 samples, 0.29%)dfbench`tokio::runtime::park::clone (33 samples, 0.09%)dfbench`tokio::runtime::park::drop_waker (8 samples, 0.02%)dfbench`tokio::sync::mpsc::list::Rx<T>::pop (126 samples, 0.35%)dfbench`<futures_util::stream::unfold::Unfold<T,F,Fut> as futures_core::stream::Stream>::poll_next (540 samples, 1.50%)dfbench`tokio::sync::task::atomic_waker::AtomicWaker::register_by_ref (146 samples, 0.40%)dfbench`tokio::sync::mpsc::list::Rx<T>::pop (49 samples, 0.14%)dfbench`tokio::sync::task::atomic_waker::AtomicWaker::register_by_ref (30 samples, 0.08%)dfbench`tokio::task::join_set::JoinSet<T>::join_next::_{{closure}} (31 samples, 0.09%)dfbench`<futures_util::stream::select::Select<St1,St2> as futures_core::stream::Stream>::poll_next (1,105 samples, 3.06%)dfb..libdyld.dylib`tlv_get_addr (147 samples, 0.41%)dfbench`<futures_util::stream::stream::filter_map::FilterMap<St,Fut,F> as futures_core::stream::Stream>::poll_next (36 samples, 0.10%)dfbench`<futures_util::stream::unfold::Unfold<T,F,Fut> as futures_core::stream::Stream>::poll_next (36 samples, 0.10%)dfbench`<datafusion_physical_plan::sorts::stream::FieldCursorStream<T> as datafusion_physical_plan::sorts::stream::PartitionedStream>::poll_next (1,309 samples, 3.63%)dfbe..dfbench`datafusion_physical_plan::sorts::stream::FusedStreams::poll_next (1,256 samples, 3.48%)dfb..dfbench`futures_util::stream::select::select::round_robin (11 samples, 0.03%)dfbench`datafusion_physical_plan::sorts::merge::SortPreservingMergeStream<C>::maybe_poll_stream (1,410 samples, 3.91%)dfbe..dfbench`datafusion_physical_plan::sorts::stream::FusedStreams::poll_next (46 samples, 0.13%)dfbench`<datafusion_physical_plan::sorts::merge::SortPreservingMergeStream<C> as futures_core::stream::Stream>::poll_next (2,223 samples, 6.16%)dfbench`..dfbench`tokio::runtime::park::wake_by_ref (15 samples, 0.04%)dfbench`datafusion_physical_plan::metrics::baseline::BaselineMetrics::record_poll (14 samples, 0.04%)dfbench`datafusion_physical_plan::sorts::merge::SortPreservingMergeStream<C>::maybe_poll_stream (27 samples, 0.07%)dfbench`mi_free (95 samples, 0.26%)dfbench`datafusion_physical_plan::execution_plan::collect::_{{closure}} (2,565 samples, 7.11%)dfbench`da..dfbench`datafusion_physical_plan::common::collect::_{{closure}} (2,513 samples, 6.96%)dfbench`d..dfbench`<futures_util::stream::try_stream::try_collect::TryCollect<St,C> as core::future::future::Future>::poll (2,453 samples, 6.80%)dfbench`<..dfbench`tokio::runtime::park::wake_by_ref (16 samples, 0.04%)dfbench`dfbench::main::_{{closure}} (2,792 samples, 7.74%)dfbench`dfb..dfbench`dfbench::main (2,858 samples, 7.92%)dfbench`dfb..dfbench`tokio::runtime::park::Inner::park (39 samples, 0.11%)dfbench`tokio::runtime::park::Inner::park (17 samples, 0.05%)dfbench`main (3,246 samples, 9.00%)dfbench`maindfbench`std::sys_common::backtrace::__rust_begin_short_backtrace (3,246 samples, 9.00%)dfbench`std::..libdyld.dylib`tlv_get_addr (184 samples, 0.51%)dfbench`mi_arenas_try_purge (28 samples, 0.08%)dfbench`mi_arena_purge (28 samples, 0.08%)libsystem_kernel.dylib`madvise (28 samples, 0.08%)libsystem_c.dylib`exit (30 samples, 0.08%)libsystem_c.dylib`__cxa_finalize_ranges (30 samples, 0.08%)dfbench`mi_process_done (30 samples, 0.08%)dyld`start (3,277 samples, 9.08%)dyld`startlibdyld.dylib`dyld4::LibSystemHelpers::getenv (31 samples, 0.09%)libsystem_kernel.dylib`__exit (26 samples, 0.07%)libsystem_kernel.dylib`__psynch_cvwait (9 samples, 0.02%)dfbench`parking_lot::condvar::Condvar::wait_until_internal (14 samples, 0.04%)dfbench`object_store::local::open_file (21 samples, 0.06%)dfbench`std::fs::OpenOptions::_open (21 samples, 0.06%)dfbench`std::sys::pal::unix::fs::File::open_c (21 samples, 0.06%)libsystem_kernel.dylib`__open (21 samples, 0.06%)dfbench`mi_heap_malloc_zero_aligned_at_generic (4 samples, 0.01%)dfbench`_mi_malloc_generic (4 samples, 0.01%)dfbench`_mi_free_delayed_block (4 samples, 0.01%)dfbench`_mi_page_free (4 samples, 0.01%)dfbench`mi_segment_page_clear (4 samples, 0.01%)dfbench`mi_segment_span_free_coalesce (4 samples, 0.01%)dfbench`mi_segment_span_free (4 samples, 0.01%)dfbench`mi_segment_try_purge (4 samples, 0.01%)dfbench`mi_segment_purge (4 samples, 0.01%)libsystem_kernel.dylib`madvise (4 samples, 0.01%)dfbench`object_store::local::read_range (32 samples, 0.09%)libsystem_kernel.dylib`read (27 samples, 0.07%)dfbench`<object_store::local::LocalFileSystem as object_store::ObjectStore>::get_range::_{{closure}}::_{{closure}} (54 samples, 0.15%)dfbench`object_store::local::open_file (156 samples, 0.43%)dfbench`std::fs::OpenOptions::_open (156 samples, 0.43%)dfbench`std::sys::pal::unix::fs::File::open_c (156 samples, 0.43%)libsystem_kernel.dylib`__open (155 samples, 0.43%)dfbench`_mi_free_delayed_block (118 samples, 0.33%)dfbench`_mi_page_free (118 samples, 0.33%)dfbench`mi_segment_page_clear (118 samples, 0.33%)dfbench`mi_segment_span_free_coalesce (118 samples, 0.33%)dfbench`mi_segment_span_free (118 samples, 0.33%)dfbench`mi_segment_try_purge (118 samples, 0.33%)dfbench`mi_segment_purge (117 samples, 0.32%)libsystem_kernel.dylib`madvise (116 samples, 0.32%)dfbench`mi_heap_malloc_zero_aligned_at_generic (130 samples, 0.36%)dfbench`_mi_malloc_generic (130 samples, 0.36%)dfbench`mi_page_fresh_alloc (6 samples, 0.02%)dfbench`mi_segments_page_alloc (6 samples, 0.02%)dfbench`mi_segment_try_purge (4 samples, 0.01%)dfbench`mi_segment_purge (4 samples, 0.01%)libsystem_kernel.dylib`madvise (4 samples, 0.01%)dfbench`object_store::local::read_range (341 samples, 0.94%)libsystem_kernel.dylib`read (209 samples, 0.58%)dfbench`<object_store::local::LocalFileSystem as object_store::ObjectStore>::get_ranges::_{{closure}}::_{{closure}} (512 samples, 1.42%)libsystem_kernel.dylib`fstat (10 samples, 0.03%)libsystem_kernel.dylib`mach_absolute_time (5 samples, 0.01%)dfbench`std::sys::pal::unix::time::Timespec::now (6 samples, 0.02%)libsystem_c.dylib`clock_gettime (6 samples, 0.02%)libsystem_kernel.dylib`__psynch_cvwait (47 samples, 0.13%)dfbench`parking_lot::condvar::Condvar::wait_until_internal (49 samples, 0.14%)libsystem_kernel.dylib`__psynch_cvwait (10 samples, 0.03%)dfbench`tokio::runtime::park::Inner::park (13 samples, 0.04%)dfbench`parking_lot::condvar::Condvar::wait_until_internal (13 samples, 0.04%)dfbench`tokio::runtime::time::Driver::park_internal (18 samples, 0.05%)dfbench`tokio::runtime::time::_<impl tokio::runtime::time::handle::Handle>::process_at_time::_{{closure}} (4 samples, 0.01%)dfbench`tokio::runtime::scheduler::multi_thread::worker::Context::park_timeout (72 samples, 0.20%)dfbench`parking_lot::condvar::Condvar::notify_one_slow (12 samples, 0.03%)libsystem_kernel.dylib`__psynch_cvsignal (10 samples, 0.03%)dfbench`<datafusion_physical_plan::repartition::RepartitionStream as futures_core::stream::Stream>::poll_next (5 samples, 0.01%)dfbench`<arrow_array::array::primitive_array::PrimitiveArray<T> as arrow_array::array::Array>::get_array_memory_size (6 samples, 0.02%)dfbench`<datafusion_physical_plan::repartition::RepartitionStream as futures_core::stream::Stream>::poll_next (16 samples, 0.04%)dfbench`<datafusion_physical_plan::repartition::distributor_channels::RecvFuture<T> as core::future::future::Future>::poll (8 samples, 0.02%)dfbench`<datafusion_physical_plan::stream::RecordBatchStreamAdapter<S> as futures_core::stream::Stream>::poll_next (25 samples, 0.07%)dfbench`arrow_array::array::Array::null_count (4 samples, 0.01%)dfbench`arrow_array::record_batch::RecordBatch::try_new_impl (22 samples, 0.06%)dfbench`core::ops::function::FnOnce::call_once (14 samples, 0.04%)dfbench`<arrow_schema::datatype::DataType as core::cmp::PartialEq>::eq (12 samples, 0.03%)dfbench`arrow_data::data::ArrayDataBuilder::build_impl (5 samples, 0.01%)dfbench`arrow_array::array::primitive_array::_<impl core::convert::From<arrow_array::array::primitive_array::PrimitiveArray<T>> for arrow_data::data::ArrayData>::from (19 samples, 0.05%)dfbench`<arrow_array::array::primitive_array::PrimitiveArray<T> as arrow_array::array::Array>::to_data (31 samples, 0.09%)dfbench`mi_malloc_aligned (4 samples, 0.01%)dfbench`arrow_data::transform::MutableArrayData::into_builder (10 samples, 0.03%)dfbench`mi_free (6 samples, 0.02%)dfbench`_mi_free_delayed_block (6 samples, 0.02%)dfbench`_mi_page_free (4 samples, 0.01%)dfbench`mi_segment_page_clear (4 samples, 0.01%)dfbench`mi_segment_span_free_coalesce (4 samples, 0.01%)dfbench`mi_segment_span_free (4 samples, 0.01%)dfbench`mi_segment_try_purge (4 samples, 0.01%)dfbench`mi_segment_purge (4 samples, 0.01%)libsystem_kernel.dylib`madvise (4 samples, 0.01%)dfbench`mi_page_free_list_extend (7 samples, 0.02%)dfbench`mi_heap_malloc_zero_aligned_at_generic (19 samples, 0.05%)dfbench`_mi_malloc_generic (19 samples, 0.05%)dfbench`mi_find_page (12 samples, 0.03%)dfbench`mi_page_fresh_alloc (4 samples, 0.01%)dfbench`mi_segments_page_alloc (4 samples, 0.01%)dfbench`arrow_data::transform::MutableArrayData::with_capacities (32 samples, 0.09%)dfbench`core::ptr::drop_in_place<arrow_data::data::ArrayData> (6 samples, 0.02%)dfbench`mi_segment_try_purge (23 samples, 0.06%)dfbench`mi_segment_purge (23 samples, 0.06%)libsystem_kernel.dylib`madvise (23 samples, 0.06%)dfbench`_mi_page_free (27 samples, 0.07%)dfbench`mi_segment_page_clear (27 samples, 0.07%)dfbench`mi_segment_span_free_coalesce (27 samples, 0.07%)dfbench`mi_segment_span_free (26 samples, 0.07%)dfbench`mi_segment_free (7 samples, 0.02%)dfbench`mi_arenas_try_purge (7 samples, 0.02%)dfbench`mi_arena_purge (7 samples, 0.02%)libsystem_kernel.dylib`madvise (7 samples, 0.02%)dfbench`mi_heap_malloc_zero_aligned_at_generic (68 samples, 0.19%)dfbench`_mi_malloc_generic (68 samples, 0.19%)dfbench`_mi_free_delayed_block (65 samples, 0.18%)dfbench`arrow_select::concat::concat_fallback (498 samples, 1.38%)libsystem_platform.dylib`_platform_memmove (314 samples, 0.87%)dfbench`arrow_select::concat::concat (513 samples, 1.42%)dfbench`_mi_page_free (5 samples, 0.01%)dfbench`mi_segment_page_clear (5 samples, 0.01%)dfbench`mi_segment_span_free_coalesce (5 samples, 0.01%)dfbench`mi_segment_span_free (5 samples, 0.01%)dfbench`mi_segment_try_purge (4 samples, 0.01%)dfbench`mi_segment_purge (4 samples, 0.01%)libsystem_kernel.dylib`madvise (4 samples, 0.01%)dfbench`arrow_select::concat::concat_batches (539 samples, 1.49%)dfbench`mi_heap_malloc_zero_aligned_at_generic (19 samples, 0.05%)dfbench`_mi_malloc_generic (19 samples, 0.05%)dfbench`_mi_free_delayed_block (19 samples, 0.05%)dfbench`mi_segment_free (7 samples, 0.02%)dfbench`mi_arenas_try_purge (7 samples, 0.02%)dfbench`mi_arena_purge (7 samples, 0.02%)libsystem_kernel.dylib`madvise (7 samples, 0.02%)dfbench`alloc::sync::Arc<T,A>::drop_slow (8 samples, 0.02%)dfbench`core::ptr::drop_in_place<arrow_schema::datatype::DataType> (4 samples, 0.01%)dfbench`mi_free (8 samples, 0.02%)dfbench`mi_free_block_delayed_mt (11 samples, 0.03%)dfbench`core::ptr::drop_in_place<arrow_array::array::primitive_array::PrimitiveArray<arrow_array::types::Int8Type>> (36 samples, 0.10%)dfbench`alloc::sync::Arc<T,A>::drop_slow (58 samples, 0.16%)dfbench`mi_free_generic_mt (5 samples, 0.01%)dfbench`core::ptr::drop_in_place<alloc::vec::Vec<alloc::sync::Arc<dyn arrow_array::array::Array>>> (65 samples, 0.18%)dfbench`mi_free (9 samples, 0.02%)dfbench`core::ptr::drop_in_place<[arrow_array::record_batch::RecordBatch]> (82 samples, 0.23%)dfbench`_mi_page_free (4 samples, 0.01%)dfbench`mi_segment_page_clear (4 samples, 0.01%)dfbench`mi_segment_span_free_coalesce (4 samples, 0.01%)dfbench`mi_segment_span_free (4 samples, 0.01%)dfbench`mi_segment_try_purge (4 samples, 0.01%)dfbench`mi_segment_purge (4 samples, 0.01%)libsystem_kernel.dylib`madvise (4 samples, 0.01%)dfbench`mi_heap_malloc_zero_aligned_at_generic (8 samples, 0.02%)dfbench`_mi_malloc_generic (8 samples, 0.02%)dfbench`_mi_free_delayed_block (8 samples, 0.02%)dfbench`std::sys::pal::unix::time::Timespec::now (27 samples, 0.07%)libsystem_c.dylib`clock_gettime (27 samples, 0.07%)libsystem_kernel.dylib`mach_absolute_time (27 samples, 0.07%)dfbench`<datafusion_physical_plan::coalesce_batches::CoalesceBatchesStream as futures_core::stream::Stream>::poll_next (731 samples, 2.03%)d..dfbench`arrow_array::record_batch::RecordBatch::slice (5 samples, 0.01%)dfbench`<arrow_array::array::primitive_array::PrimitiveArray<T> as arrow_array::array::Array>::slice (4 samples, 0.01%)dfbench`core::ptr::drop_in_place<alloc::vec::Vec<alloc::sync::Arc<dyn arrow_array::array::Array>>> (6 samples, 0.02%)dfbench`alloc::sync::Arc<T,A>::drop_slow (4 samples, 0.01%)dfbench`<datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupValuesColumn<_> as datafusion_physical_plan::aggregates::group_values::GroupValues>::clear_shrink (11 samples, 0.03%)dfbench`mi_free_block_mt (11 samples, 0.03%)dfbench`_mi_os_reset (11 samples, 0.03%)libsystem_kernel.dylib`madvise (11 samples, 0.03%)dfbench`datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream::clear_all (13 samples, 0.04%)dfbench`_mi_heap_realloc_zero (4 samples, 0.01%)dfbench`_mi_malloc_generic (4 samples, 0.01%)dfbench`<datafusion_functions_aggregate::count::CountGroupsAccumulator as datafusion_expr_common::groups_accumulator::GroupsAccumulator>::merge_batch (453 samples, 1.26%)dfbench`alloc::raw_vec::RawVec<T,A>::reserve::do_reserve_and_handle (55 samples, 0.15%)dfbench`alloc::raw_vec::finish_grow (55 samples, 0.15%)libsystem_platform.dylib`_platform_memmove (50 samples, 0.14%)dfbench`_mi_heap_realloc_zero (4 samples, 0.01%)dfbench`_mi_malloc_generic (4 samples, 0.01%)dfbench`<datafusion_physical_plan::aggregates::group_values::multi_group_by::primitive::PrimitiveGroupValueBuilder<T,_> as datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupColumn>::vectorized_append (509 samples, 1.41%)dfbench`alloc::raw_vec::RawVec<T,A>::grow_one (191 samples, 0.53%)dfbench`alloc::raw_vec::finish_grow (191 samples, 0.53%)libsystem_platform.dylib`_platform_memmove (187 samples, 0.52%)dfbench`<datafusion_physical_plan::aggregates::group_values::multi_group_by::primitive::PrimitiveGroupValueBuilder<T,_> as datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupColumn>::vectorized_equal_to (1,276 samples, 3.54%)dfb..dfbench`alloc::raw_vec::RawVec<T,A>::reserve::do_reserve_and_handle (4 samples, 0.01%)dfbench`alloc::raw_vec::finish_grow (4 samples, 0.01%)dfbench`datafusion_common::hash_utils::create_hashes (387 samples, 1.07%)dfbench`<datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupValuesColumn<_> as datafusion_physical_plan::aggregates::group_values::GroupValues>::intern (5,126 samples, 14.20%)dfbench`<datafusion_ph..dfbench`hashbrown::raw::inner::RawTable<T,A>::reserve_rehash (455 samples, 1.26%)libsystem_platform.dylib`_platform_memset (15 samples, 0.04%)dfbench`datafusion_physical_plan::aggregates::evaluate_group_by (4 samples, 0.01%)libsystem_platform.dylib`__bzero (27 samples, 0.07%)dfbench`datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream::group_aggregate_batch (5,635 samples, 15.62%)dfbench`datafusion_physi..libsystem_platform.dylib`_platform_memset (17 samples, 0.05%)dfbench`<datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream as futures_core::stream::Stream>::poll_next (6,400 samples, 17.74%)dfbench`<datafusion_physical..dfbench`<datafusion_physical_plan::projection::ProjectionStream as futures_core::stream::Stream>::poll_next (6,405 samples, 17.75%)dfbench`<datafusion_physical..dfbench`arrow_row::fixed::encode_not_null (56 samples, 0.16%)dfbench`_mi_malloc_generic (5 samples, 0.01%)dfbench`_mi_free_delayed_block (5 samples, 0.01%)dfbench`_mi_page_free (5 samples, 0.01%)dfbench`mi_segment_page_clear (5 samples, 0.01%)dfbench`mi_segment_span_free_coalesce (5 samples, 0.01%)dfbench`mi_segment_span_free (5 samples, 0.01%)dfbench`mi_segment_try_purge (5 samples, 0.01%)dfbench`mi_segment_purge (5 samples, 0.01%)libsystem_kernel.dylib`madvise (5 samples, 0.01%)dfbench`arrow_row::row_lengths (21 samples, 0.06%)dfbench`mi_heap_malloc_zero_aligned_at_generic (11 samples, 0.03%)libsystem_platform.dylib`__bzero (6 samples, 0.02%)dfbench`arrow_row::RowConverter::append (123 samples, 0.34%)dfbench`<datafusion_physical_plan::stream::RecordBatchStreamAdapter<S> as futures_core::stream::Stream>::poll_next (6,596 samples, 18.28%)dfbench`<datafusion_physical..dfbench`DYLD-STUB$$memcmp (14 samples, 0.04%)dfbench`datafusion_physical_plan::common::spawn_buffered::_{{closure}} (6,661 samples, 18.46%)dfbench`datafusion_physical_p..libsystem_platform.dylib`_platform_memcmp (51 samples, 0.14%)dfbench`<arrow_array::array::primitive_array::PrimitiveArray<T> as core::convert::From<arrow_data::data::ArrayData>>::from (5 samples, 0.01%)dfbench`arrow_buffer::buffer::scalar::ScalarBuffer<T>::new (5 samples, 0.01%)dfbench`<arrow_array::array::primitive_array::PrimitiveArray<arrow_array::types::UInt32Type> as core::convert::From<alloc::vec::Vec<<arrow_array::types::UInt32Type as arrow_array::types::ArrowPrimitiveType>::Native>>>::from (11 samples, 0.03%)dfbench`arrow_array::record_batch::RecordBatch::try_new_impl (10 samples, 0.03%)dfbench`mi_segment_try_purge (10 samples, 0.03%)dfbench`mi_segment_purge (10 samples, 0.03%)libsystem_kernel.dylib`madvise (10 samples, 0.03%)dfbench`_mi_page_free (13 samples, 0.04%)dfbench`mi_segment_page_clear (13 samples, 0.04%)dfbench`mi_segment_span_free_coalesce (12 samples, 0.03%)dfbench`mi_segment_span_free (12 samples, 0.03%)dfbench`_mi_free_delayed_block (37 samples, 0.10%)dfbench`_mi_page_free (6 samples, 0.02%)dfbench`mi_segment_page_clear (6 samples, 0.02%)dfbench`mi_segment_span_free_coalesce (5 samples, 0.01%)dfbench`mi_segment_span_free (5 samples, 0.01%)dfbench`mi_segment_try_purge (5 samples, 0.01%)dfbench`mi_segment_purge (5 samples, 0.01%)libsystem_kernel.dylib`madvise (5 samples, 0.01%)dfbench`mi_page_free_list_extend (8 samples, 0.02%)dfbench`mi_find_page (32 samples, 0.09%)dfbench`_mi_malloc_generic (83 samples, 0.23%)dfbench`mi_page_free_list_extend (10 samples, 0.03%)dfbench`arrow_select::take::take_native (541 samples, 1.50%)dfbench`mi_heap_malloc_zero_aligned_at_generic (84 samples, 0.23%)dfbench`arrow_select::take::take_impl (604 samples, 1.67%)dfbench`arrow_select::take::take_primitive (560 samples, 1.55%)dfbench`arrow_select::take::take (611 samples, 1.69%)dfbench`arrow_select::take::take_arrays (617 samples, 1.71%)dfbench`<core::iter::adapters::map::Map<I,F> as core::iter::traits::iterator::Iterator>::next (653 samples, 1.81%)d..dfbench`std::sys::pal::unix::time::Timespec::now (7 samples, 0.02%)libsystem_c.dylib`clock_gettime (7 samples, 0.02%)dfbench`datafusion::datasource::physical_plan::file_scan_config::FileScanConfig::project (5 samples, 0.01%)dfbench`alloc::raw_vec::RawVec<T,A>::grow_one (5 samples, 0.01%)dfbench`alloc::raw_vec::finish_grow (5 samples, 0.01%)dfbench`mi_heap_malloc_zero_aligned_at_generic (5 samples, 0.01%)dfbench`_mi_malloc_generic (5 samples, 0.01%)dfbench`_mi_free_delayed_block (5 samples, 0.01%)dfbench`_mi_page_free (5 samples, 0.01%)dfbench`mi_segment_page_clear (5 samples, 0.01%)dfbench`mi_segment_span_free_coalesce (5 samples, 0.01%)dfbench`mi_segment_span_free (5 samples, 0.01%)dfbench`mi_segment_try_purge (5 samples, 0.01%)dfbench`mi_segment_purge (5 samples, 0.01%)libsystem_kernel.dylib`madvise (5 samples, 0.01%)dfbench`<datafusion_physical_plan::projection::ProjectionExec as datafusion_physical_plan::execution_plan::ExecutionPlan>::execute (7 samples, 0.02%)dfbench`<datafusion::datasource::physical_plan::parquet::ParquetExec as datafusion_physical_plan::execution_plan::ExecutionPlan>::execute (7 samples, 0.02%)dfbench`<datafusion_physical_plan::aggregates::AggregateExec as datafusion_physical_plan::execution_plan::ExecutionPlan>::execute (8 samples, 0.02%)dfbench`_mi_free_delayed_block (6 samples, 0.02%)dfbench`_mi_page_free (6 samples, 0.02%)dfbench`mi_segment_page_clear (6 samples, 0.02%)dfbench`mi_segment_span_free_coalesce (6 samples, 0.02%)dfbench`mi_segment_span_free (6 samples, 0.02%)dfbench`mi_segment_try_purge (6 samples, 0.02%)dfbench`mi_segment_purge (6 samples, 0.02%)libsystem_kernel.dylib`madvise (6 samples, 0.02%)dfbench`mi_heap_malloc_zero_aligned_at_generic (9 samples, 0.02%)dfbench`_mi_malloc_generic (8 samples, 0.02%)dfbench`arrow_cast::cast::cast_numeric_arrays (87 samples, 0.24%)dfbench`<datafusion_physical_expr::expressions::cast::CastExpr as datafusion_physical_expr_common::physical_expr::PhysicalExpr>::evaluate (121 samples, 0.34%)dfbench`datafusion_expr_common::columnar_value::ColumnarValue::cast_to (121 samples, 0.34%)dfbench`arrow_cast::cast::cast_with_options (120 samples, 0.33%)libsystem_platform.dylib`__bzero (30 samples, 0.08%)dfbench`<datafusion_physical_expr::expressions::column::Column as datafusion_physical_expr_common::physical_expr::PhysicalExpr>::evaluate (4 samples, 0.01%)dfbench`<core::iter::adapters::GenericShunt<I,R> as core::iter::traits::iterator::Iterator>::next (128 samples, 0.35%)dfbench`mi_free (9 samples, 0.02%)dfbench`<core::iter::adapters::GenericShunt<I,R> as core::iter::traits::iterator::Iterator>::next (11 samples, 0.03%)dfbench`mi_heap_malloc_zero_aligned_at_generic (4 samples, 0.01%)dfbench`_mi_malloc_generic (4 samples, 0.01%)dfbench`mi_page_free_list_extend (4 samples, 0.01%)dfbench`mi_malloc_aligned (13 samples, 0.04%)dfbench`<parquet::thrift::TCompactSliceInputProtocol as thrift::protocol::TInputProtocol>::read_bytes (28 samples, 0.08%)dfbench`<parquet::thrift::TCompactSliceInputProtocol as thrift::protocol::TInputProtocol>::read_field_begin (17 samples, 0.05%)dfbench`thrift::protocol::compact::u8_to_type (10 samples, 0.03%)dfbench`<parquet::format::Statistics as parquet::thrift::TSerializable>::read_from_in_protocol (102 samples, 0.28%)libsystem_platform.dylib`_platform_memmove (13 samples, 0.04%)dfbench`mi_heap_malloc_zero_aligned_at_generic (4 samples, 0.01%)dfbench`_mi_malloc_generic (4 samples, 0.01%)dfbench`<parquet::thrift::TCompactSliceInputProtocol as thrift::protocol::TInputProtocol>::read_bytes (14 samples, 0.04%)dfbench`<parquet::thrift::TCompactSliceInputProtocol as thrift::protocol::TInputProtocol>::read_field_begin (81 samples, 0.22%)dfbench`<parquet::thrift::TCompactSliceInputProtocol as thrift::protocol::TInputProtocol>::read_list_begin (4 samples, 0.01%)dfbench`core::str::converts::from_utf8 (10 samples, 0.03%)dfbench`mi_heap_malloc_zero_aligned_at_generic (9 samples, 0.02%)dfbench`_mi_malloc_generic (9 samples, 0.02%)dfbench`mi_page_free_list_extend (8 samples, 0.02%)dfbench`mi_malloc_aligned (7 samples, 0.02%)dfbench`thrift::protocol::compact::u8_to_type (42 samples, 0.12%)dfbench`thrift::protocol::verify_required_field_exists (7 samples, 0.02%)dfbench`<parquet::format::ColumnChunk as parquet::thrift::TSerializable>::read_from_in_protocol (480 samples, 1.33%)libsystem_platform.dylib`_platform_memmove (14 samples, 0.04%)dfbench`<parquet::thrift::TCompactSliceInputProtocol as thrift::protocol::TInputProtocol>::read_field_begin (22 samples, 0.06%)dfbench`<parquet::thrift::TCompactSliceInputProtocol as thrift::protocol::TInputProtocol>::read_list_begin (4 samples, 0.01%)dfbench`_mi_free_delayed_block (11 samples, 0.03%)dfbench`_mi_page_free (11 samples, 0.03%)dfbench`mi_segment_page_clear (11 samples, 0.03%)dfbench`mi_segment_span_free_coalesce (11 samples, 0.03%)dfbench`mi_segment_span_free (11 samples, 0.03%)dfbench`mi_segment_try_purge (11 samples, 0.03%)dfbench`mi_segment_purge (11 samples, 0.03%)libsystem_kernel.dylib`madvise (11 samples, 0.03%)dfbench`mi_page_free_list_extend (8 samples, 0.02%)dfbench`mi_find_page (10 samples, 0.03%)dfbench`mi_heap_malloc_zero_aligned_at_generic (26 samples, 0.07%)dfbench`_mi_malloc_generic (25 samples, 0.07%)dfbench`mi_page_free_list_extend (4 samples, 0.01%)dfbench`thrift::protocol::verify_required_field_exists (4 samples, 0.01%)dfbench`<parquet::format::FileMetaData as parquet::thrift::TSerializable>::read_from_in_protocol (551 samples, 1.53%)dfbench`alloc::raw_vec::RawVec<T,A>::grow_one (20 samples, 0.06%)dfbench`alloc::raw_vec::finish_grow (20 samples, 0.06%)libsystem_platform.dylib`_platform_memmove (19 samples, 0.05%)dfbench`mi_free (7 samples, 0.02%)dfbench`mi_malloc_aligned (6 samples, 0.02%)dfbench`mi_free (4 samples, 0.01%)dfbench`parquet::file::statistics::from_thrift (27 samples, 0.07%)dfbench`parquet::file::statistics::from_thrift::_{{closure}} (5 samples, 0.01%)dfbench`parquet::file::metadata::reader::ParquetMetaDataReader::decode_metadata (743 samples, 2.06%)d..libsystem_platform.dylib`_platform_memmove (49 samples, 0.14%)dfbench`<parquet::arrow::async_reader::store::ParquetObjectReader as parquet::arrow::async_reader::AsyncFileReader>::get_metadata::_{{closure}} (816 samples, 2.26%)d..libsystem_platform.dylib`_platform_memmove (57 samples, 0.16%)dfbench`<datafusion::datasource::physical_plan::parquet::opener::ParquetOpener as datafusion::datasource::physical_plan::file_stream::FileOpener>::open::_{{closure}} (819 samples, 2.27%)d..dfbench`<arrow_array::array::primitive_array::PrimitiveArray<T> as arrow_array::array::Array>::to_data (5 samples, 0.01%)dfbench`arrow_array::array::primitive_array::_<impl core::convert::From<arrow_array::array::primitive_array::PrimitiveArray<T>> for arrow_data::data::ArrayData>::from (4 samples, 0.01%)dfbench`<core::iter::adapters::GenericShunt<I,R> as core::iter::traits::iterator::Iterator>::next (20 samples, 0.06%)dfbench`arrow_cast::cast::cast_with_options (8 samples, 0.02%)dfbench`alloc::sync::Arc<T,A>::drop_slow (11 samples, 0.03%)dfbench`core::ptr::drop_in_place<hashbrown::raw::RawTable<(alloc::string::String,alloc::string::String)>> (10 samples, 0.03%)dfbench`<datafusion::datasource::schema_adapter::SchemaMapping as datafusion::datasource::schema_adapter::SchemaMapper>::map_batch (35 samples, 0.10%)dfbench`<arrow_array::record_batch::RecordBatch as core::convert::From<arrow_array::array::struct_array::StructArray>>::from (4 samples, 0.01%)dfbench`<arrow_array::array::primitive_array::PrimitiveArray<T> as arrow_array::array::Array>::to_data (9 samples, 0.02%)dfbench`arrow_array::array::primitive_array::_<impl core::convert::From<arrow_array::array::primitive_array::PrimitiveArray<T>> for arrow_data::data::ArrayData>::from (5 samples, 0.01%)dfbench`<arrow_array::array::struct_array::StructArray as core::convert::From<arrow_data::data::ArrayData>>::from (8 samples, 0.02%)dfbench`alloc::raw_vec::RawVec<T,A>::grow_one (4 samples, 0.01%)dfbench`<arrow_array::array::primitive_array::PrimitiveArray<T> as arrow_array::array::Array>::to_data (10 samples, 0.03%)dfbench`arrow_array::array::primitive_array::_<impl core::convert::From<arrow_array::array::primitive_array::PrimitiveArray<T>> for arrow_data::data::ArrayData>::from (10 samples, 0.03%)dfbench`arrow_cast::cast::cast_with_options (13 samples, 0.04%)dfbench`arrow_data::data::ArrayDataBuilder::build_impl (4 samples, 0.01%)dfbench`<parquet::arrow::array_reader::primitive_array::PrimitiveArrayReader<T> as parquet::arrow::array_reader::ArrayReader>::consume_batch (36 samples, 0.10%)dfbench`core::ptr::drop_in_place<alloc::vec::Vec<alloc::sync::Arc<dyn arrow_array::array::Array>>> (8 samples, 0.02%)dfbench`alloc::sync::Arc<T,A>::drop_slow (8 samples, 0.02%)dfbench`core::ptr::drop_in_place<arrow_schema::datatype::DataType> (5 samples, 0.01%)dfbench`<parquet::arrow::array_reader::struct_array::StructArrayReader as parquet::arrow::array_reader::ArrayReader>::consume_batch (72 samples, 0.20%)dfbench`mi_segment_try_purge (62 samples, 0.17%)dfbench`mi_segment_purge (62 samples, 0.17%)libsystem_kernel.dylib`madvise (62 samples, 0.17%)dfbench`_mi_page_free (64 samples, 0.18%)dfbench`mi_segment_page_clear (64 samples, 0.18%)dfbench`mi_segment_span_free_coalesce (64 samples, 0.18%)dfbench`mi_segment_span_free (64 samples, 0.18%)dfbench`mi_segment_free (27 samples, 0.07%)dfbench`mi_arenas_try_purge (27 samples, 0.07%)dfbench`mi_arena_purge (27 samples, 0.07%)libsystem_kernel.dylib`madvise (27 samples, 0.07%)dfbench`_mi_free_delayed_block (100 samples, 0.28%)dfbench`alloc::raw_vec::RawVec<T,A>::reserve::do_reserve_and_handle (103 samples, 0.29%)dfbench`alloc::raw_vec::finish_grow (102 samples, 0.28%)dfbench`mi_heap_malloc_zero_aligned_at_generic (102 samples, 0.28%)dfbench`_mi_malloc_generic (102 samples, 0.28%)dfbench`<parquet::column::reader::decoder::ColumnValueDecoderImpl<T> as parquet::column::reader::decoder::ColumnValueDecoder>::set_data (9 samples, 0.02%)dfbench`<parquet::encodings::decoding::DictDecoder<T> as parquet::encodings::decoding::Decoder<T>>::set_data (9 samples, 0.02%)dfbench`bytes::bytes::shared_drop (9 samples, 0.02%)dfbench`_mi_page_free (9 samples, 0.02%)dfbench`mi_segment_page_clear (9 samples, 0.02%)dfbench`mi_segment_span_free_coalesce (9 samples, 0.02%)dfbench`mi_segment_span_free (9 samples, 0.02%)dfbench`mi_segment_try_purge (9 samples, 0.02%)dfbench`mi_segment_purge (9 samples, 0.02%)libsystem_kernel.dylib`madvise (9 samples, 0.02%)dfbench`<parquet::column::reader::decoder::ColumnValueDecoderImpl<T> as parquet::column::reader::decoder::ColumnValueDecoder>::set_dict (19 samples, 0.05%)libsystem_platform.dylib`_platform_memmove (14 samples, 0.04%)dfbench`mi_segment_purge (5 samples, 0.01%)libsystem_kernel.dylib`madvise (5 samples, 0.01%)dfbench`mi_heap_malloc_zero_aligned_at_generic (11 samples, 0.03%)dfbench`_mi_malloc_generic (11 samples, 0.03%)dfbench`mi_page_fresh_alloc (8 samples, 0.02%)dfbench`mi_segments_page_alloc (8 samples, 0.02%)dfbench`mi_segment_try_purge (6 samples, 0.02%)dfbench`<parquet::compression::snappy_codec::SnappyCodec as parquet::compression::Codec>::decompress (76 samples, 0.21%)dfbench`mi_heap_malloc_zero_aligned_at_generic (7 samples, 0.02%)dfbench`_mi_malloc_generic (7 samples, 0.02%)dfbench`mi_page_fresh_alloc (5 samples, 0.01%)dfbench`mi_segments_page_alloc (5 samples, 0.01%)dfbench`mi_segment_try_purge (5 samples, 0.01%)dfbench`mi_segment_purge (5 samples, 0.01%)libsystem_kernel.dylib`madvise (5 samples, 0.01%)libsystem_platform.dylib`__bzero (54 samples, 0.15%)dfbench`parquet::file::serialized_reader::decode_page (199 samples, 0.55%)libsystem_platform.dylib`_platform_memmove (59 samples, 0.16%)dfbench`<parquet::file::serialized_reader::SerializedPageReader<R> as parquet::column::page::PageReader>::get_next_page (212 samples, 0.59%)libsystem_platform.dylib`__bzero (94 samples, 0.26%)libsystem_platform.dylib`_platform_memmove (48 samples, 0.13%)dfbench`parquet::column::reader::GenericColumnReader<R,D,V>::read_new_page (393 samples, 1.09%)libsystem_platform.dylib`_platform_memset (9 samples, 0.02%)dfbench`DYLD-STUB$$memcpy (8 samples, 0.02%)dfbench`parquet::encodings::rle::RleDecoder::reload (135 samples, 0.37%)dfbench`parquet::util::bit_util::BitReader::get_vlq_int (44 samples, 0.12%)dfbench`DYLD-STUB$$memcpy (9 samples, 0.02%)dfbench`parquet::util::bit_pack::unpack32 (48 samples, 0.13%)dfbench`parquet::util::bit_util::BitReader::get_value (114 samples, 0.32%)dfbench`parquet::util::bit_util::BitReader::get_batch (305 samples, 0.85%)libsystem_platform.dylib`_platform_memmove (26 samples, 0.07%)dfbench`parquet::util::bit_util::BitReader::get_value (33 samples, 0.09%)dfbench`parquet::encodings::rle::RleDecoder::get_batch_with_dict (1,171 samples, 3.25%)dfb..libsystem_platform.dylib`_platform_memmove (14 samples, 0.04%)dfbench`parquet::encodings::rle::RleDecoder::reload (7 samples, 0.02%)dfbench`parquet::arrow::array_reader::read_records (1,680 samples, 4.66%)dfben..dfbench`<parquet::arrow::array_reader::struct_array::StructArrayReader as parquet::arrow::array_reader::ArrayReader>::read_records (1,737 samples, 4.81%)dfbenc..libsystem_platform.dylib`_platform_memset (57 samples, 0.16%)dfbench`<parquet::arrow::arrow_reader::ParquetRecordBatchReader as core::iter::traits::iterator::Iterator>::next (1,819 samples, 5.04%)dfbenc..dfbench`_mi_page_free (37 samples, 0.10%)dfbench`mi_segment_page_clear (37 samples, 0.10%)dfbench`mi_segment_span_free_coalesce (37 samples, 0.10%)dfbench`mi_segment_span_free (37 samples, 0.10%)dfbench`mi_segment_try_purge (37 samples, 0.10%)dfbench`mi_segment_purge (37 samples, 0.10%)libsystem_kernel.dylib`madvise (37 samples, 0.10%)dfbench`bytes::bytes::shared_drop (17 samples, 0.05%)dfbench`_mi_page_free (17 samples, 0.05%)dfbench`mi_segment_page_clear (17 samples, 0.05%)dfbench`mi_segment_span_free_coalesce (16 samples, 0.04%)dfbench`mi_segment_span_free (16 samples, 0.04%)dfbench`mi_segment_try_purge (16 samples, 0.04%)dfbench`mi_segment_purge (16 samples, 0.04%)libsystem_kernel.dylib`madvise (16 samples, 0.04%)dfbench`core::ptr::drop_in_place<alloc::vec::Vec<alloc::boxed::Box<dyn arrow_json::reader::ArrayDecoder>>> (57 samples, 0.16%)dfbench`core::ptr::drop_in_place<std::collections::hash::map::HashMap<parquet::basic::Encoding,alloc::boxed::Box<dyn parquet::encodings::decoding::Decoder<parquet::data_type::BoolType>>>> (55 samples, 0.15%)dfbench`core::ptr::drop_in_place<parquet::encodings::decoding::DictDecoder<parquet::data_type::DoubleType>> (55 samples, 0.15%)dfbench`core::ptr::drop_in_place<parquet::arrow::arrow_reader::ParquetRecordBatchReader> (58 samples, 0.16%)dfbench`core::ptr::drop_in_place<parquet::arrow::array_reader::struct_array::StructArrayReader> (58 samples, 0.16%)dfbench`_mi_free_delayed_block (17 samples, 0.05%)dfbench`mi_segment_free (14 samples, 0.04%)dfbench`mi_arenas_try_purge (14 samples, 0.04%)dfbench`mi_arena_purge (14 samples, 0.04%)libsystem_kernel.dylib`madvise (14 samples, 0.04%)dfbench`mi_heap_malloc_zero_aligned_at_generic (18 samples, 0.05%)dfbench`_mi_malloc_generic (18 samples, 0.05%)dfbench`<parquet::arrow::async_reader::InMemoryRowGroup as parquet::arrow::array_reader::RowGroups>::column_chunks (5 samples, 0.01%)dfbench`parquet::arrow::array_reader::builder::build_array_reader (30 samples, 0.08%)dfbench`parquet::arrow::array_reader::builder::build_reader (29 samples, 0.08%)dfbench`parquet::arrow::array_reader::builder::build_reader (11 samples, 0.03%)dfbench`object_store::local::LocalFileSystem::path_to_filesystem (5 samples, 0.01%)dfbench`<alloc::sync::Arc<dyn object_store::ObjectStore> as object_store::ObjectStore>::get_ranges::_{{closure}} (12 samples, 0.03%)dfbench`<object_store::local::LocalFileSystem as object_store::ObjectStore>::get_ranges::_{{closure}} (12 samples, 0.03%)dfbench`tokio::runtime::blocking::pool::Spawner::spawn_task (7 samples, 0.02%)dfbench`parking_lot::raw_mutex::RawMutex::unlock_slow (6 samples, 0.02%)libsystem_kernel.dylib`__psynch_cvsignal (6 samples, 0.02%)dfbench`<futures_util::stream::stream::map::Map<St,F> as futures_core::stream::Stream>::poll_next (1,969 samples, 5.46%)dfbench..dfbench`parquet::arrow::async_reader::ReaderFactory<T>::read_row_group::_{{closure}} (51 samples, 0.14%)dfbench`parquet::arrow::async_reader::InMemoryRowGroup::fetch::_{{closure}} (16 samples, 0.04%)dfbench`<parquet::arrow::async_reader::store::ParquetObjectReader as parquet::arrow::async_reader::AsyncFileReader>::get_byte_ranges::_{{closure}} (14 samples, 0.04%)dfbench`datafusion::datasource::physical_plan::file_scan_config::PartitionColumnProjector::project (6 samples, 0.02%)dfbench`std::sys::pal::unix::time::Timespec::now (9 samples, 0.02%)libsystem_c.dylib`clock_gettime (9 samples, 0.02%)libsystem_kernel.dylib`mach_absolute_time (7 samples, 0.02%)dfbench`<datafusion::datasource::physical_plan::file_stream::FileStream<F> as futures_core::stream::Stream>::poll_next (2,807 samples, 7.78%)dfbench`<da..dfbench`arrow_array::record_batch::RecordBatch::try_new_impl (12 samples, 0.03%)dfbench`core::ops::function::FnOnce::call_once (7 samples, 0.02%)dfbench`<datafusion_physical_plan::projection::ProjectionStream as futures_core::stream::Stream>::poll_next (2,952 samples, 8.18%)dfbench`<da..dfbench`arrow_array::array::primitive_array::PrimitiveArray<T>::slice (10 samples, 0.03%)dfbench`arrow_buffer::buffer::scalar::ScalarBuffer<T>::new (6 samples, 0.02%)dfbench`<arrow_array::array::primitive_array::PrimitiveArray<T> as arrow_array::array::Array>::slice (11 samples, 0.03%)dfbench`arrow_array::record_batch::RecordBatch::slice (13 samples, 0.04%)dfbench`core::ptr::drop_in_place<arrow_array::array::primitive_array::PrimitiveArray<arrow_array::types::Int8Type>> (7 samples, 0.02%)dfbench`core::ptr::drop_in_place<alloc::vec::Vec<alloc::sync::Arc<dyn arrow_array::array::Array>>> (11 samples, 0.03%)dfbench`alloc::sync::Arc<T,A>::drop_slow (11 samples, 0.03%)dfbench`<datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupValuesColumn<_> as datafusion_physical_plan::aggregates::group_values::GroupValues>::clear_shrink (30 samples, 0.08%)dfbench`mi_free_block_mt (30 samples, 0.08%)dfbench`_mi_os_reset (30 samples, 0.08%)libsystem_kernel.dylib`madvise (30 samples, 0.08%)dfbench`datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream::clear_all (32 samples, 0.09%)dfbench`<datafusion_functions_aggregate::count::CountGroupsAccumulator as datafusion_expr_common::groups_accumulator::GroupsAccumulator>::update_batch (1,843 samples, 5.11%)dfbenc..dfbench`alloc::raw_vec::RawVec<T,A>::reserve::do_reserve_and_handle (83 samples, 0.23%)dfbench`alloc::raw_vec::finish_grow (83 samples, 0.23%)libsystem_platform.dylib`_platform_memmove (81 samples, 0.22%)dfbench`_mi_heap_realloc_zero (5 samples, 0.01%)dfbench`<datafusion_physical_plan::aggregates::group_values::multi_group_by::primitive::PrimitiveGroupValueBuilder<T,_> as datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupColumn>::vectorized_append (928 samples, 2.57%)df..dfbench`alloc::raw_vec::RawVec<T,A>::grow_one (270 samples, 0.75%)dfbench`alloc::raw_vec::finish_grow (270 samples, 0.75%)libsystem_platform.dylib`_platform_memmove (265 samples, 0.73%)dfbench`<datafusion_physical_plan::aggregates::group_values::multi_group_by::primitive::PrimitiveGroupValueBuilder<T,_> as datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupColumn>::vectorized_equal_to (6,709 samples, 18.59%)dfbench`<datafusion_physical_..dfbench`datafusion_common::hash_utils::create_hashes (2,433 samples, 6.74%)dfbench`d..dfbench`hashbrown::raw::inner::RawTableInner::fallible_with_capacity (7 samples, 0.02%)dfbench`mi_heap_malloc_zero_aligned_at_generic (7 samples, 0.02%)dfbench`_mi_malloc_generic (7 samples, 0.02%)dfbench`mi_page_fresh_alloc (4 samples, 0.01%)dfbench`mi_free_block_mt (16 samples, 0.04%)dfbench`_mi_os_reset (16 samples, 0.04%)libsystem_kernel.dylib`madvise (16 samples, 0.04%)dfbench`mi_segment_free (6 samples, 0.02%)dfbench`mi_arenas_try_purge (6 samples, 0.02%)dfbench`mi_arena_purge (6 samples, 0.02%)libsystem_kernel.dylib`madvise (6 samples, 0.02%)dfbench`<datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupValuesColumn<_> as datafusion_physical_plan::aggregates::group_values::GroupValues>::intern (18,541 samples, 51.38%)dfbench`<datafusion_physical_plan::aggregates::group_values::multi_group_by::GroupVal..dfbench`hashbrown::raw::inner::RawTable<T,A>::reserve_rehash (792 samples, 2.19%)d..libsystem_platform.dylib`_platform_memset (26 samples, 0.07%)dfbench`core::ptr::drop_in_place<arrow_array::array::primitive_array::PrimitiveArray<arrow_array::types::Int8Type>> (7 samples, 0.02%)dfbench`core::ptr::drop_in_place<alloc::vec::Vec<alloc::sync::Arc<dyn arrow_array::array::Array>>> (13 samples, 0.04%)dfbench`alloc::sync::Arc<T,A>::drop_slow (9 samples, 0.02%)dfbench`<datafusion_physical_expr::expressions::column::Column as datafusion_physical_expr_common::physical_expr::PhysicalExpr>::evaluate (6 samples, 0.02%)dfbench`<T as core::any::Any>::type_id (11 samples, 0.03%)dfbench`core::ptr::drop_in_place<arrow_array::array::primitive_array::PrimitiveArray<arrow_array::types::Int8Type>> (5 samples, 0.01%)dfbench`alloc::sync::Arc<T,A>::drop_slow (14 samples, 0.04%)dfbench`mi_free (9 samples, 0.02%)dfbench`arrow_arith::numeric::arithmetic_op (26 samples, 0.07%)dfbench`mi_heap_malloc_zero_aligned_at_generic (7 samples, 0.02%)dfbench`_mi_malloc_generic (7 samples, 0.02%)dfbench`mi_find_page (4 samples, 0.01%)dfbench`arrow_array::array::primitive_array::PrimitiveArray<T>::unary (279 samples, 0.77%)dfbench`arrow_arith::numeric::integer_op (281 samples, 0.78%)dfbench`<datafusion_physical_expr::expressions::binary::BinaryExpr as datafusion_physical_expr_common::physical_expr::PhysicalExpr>::evaluate (364 samples, 1.01%)dfbench`datafusion_physical_expr_common::datum::apply (352 samples, 0.98%)dfbench`datafusion_common::scalar::ScalarValue::to_scalar (9 samples, 0.02%)dfbench`datafusion_common::scalar::ScalarValue::to_array_of_size (9 samples, 0.02%)dfbench`arrow_array::array::primitive_array::PrimitiveArray<T>::from_value (7 samples, 0.02%)dfbench`datafusion_physical_plan::aggregates::evaluate_group_by (378 samples, 1.05%)dfbench`<core::iter::adapters::GenericShunt<I,R> as core::iter::traits::iterator::Iterator>::next (375 samples, 1.04%)dfbench`datafusion_common::scalar::ScalarValue::to_array_of_size (80 samples, 0.22%)dfbench`arrow_array::array::primitive_array::PrimitiveArray<T>::from_value (80 samples, 0.22%)dfbench`<core::iter::adapters::GenericShunt<I,R> as core::iter::traits::iterator::Iterator>::next (84 samples, 0.23%)dfbench`datafusion_physical_plan::aggregates::evaluate_many (91 samples, 0.25%)dfbench`datafusion_physical_plan::aggregates::evaluate_optional (5 samples, 0.01%)libsystem_platform.dylib`__bzero (30 samples, 0.08%)dfbench`datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream::group_aggregate_batch (21,071 samples, 58.39%)dfbench`datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream::group_aggreg..libsystem_platform.dylib`_platform_memset (153 samples, 0.42%)dfbench`<datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream as futures_core::stream::Stream>::poll_next (24,096 samples, 66.77%)dfbench`<datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream as futures_core::stream::St..dfbench`std::sys::pal::unix::time::Timespec::now (6 samples, 0.02%)libsystem_c.dylib`clock_gettime (6 samples, 0.02%)libsystem_kernel.dylib`mach_absolute_time (4 samples, 0.01%)dfbench`parking_lot::condvar::Condvar::notify_one_slow (12 samples, 0.03%)libsystem_kernel.dylib`__psynch_cvsignal (8 samples, 0.02%)dfbench`tokio::runtime::scheduler::multi_thread::worker::_<impl tokio::runtime::scheduler::multi_thread::handle::Handle>::schedule_task::_{{closure}} (16 samples, 0.04%)dfbench`tokio::runtime::task::waker::wake_by_val (18 samples, 0.05%)dfbench`tokio::runtime::scheduler::multi_thread::worker::_<impl tokio::runtime::scheduler::multi_thread::handle::Handle>::schedule_task (18 samples, 0.05%)dfbench`<datafusion_physical_plan::repartition::distributor_channels::SendFuture<T> as core::future::future::Future>::poll (22 samples, 0.06%)dfbench`core::ptr::drop_in_place<arrow_array::array::primitive_array::PrimitiveArray<arrow_array::types::Int8Type>> (9 samples, 0.02%)dfbench`alloc::sync::Arc<T,A>::drop_slow (9 samples, 0.02%)dfbench`mi_free_block_mt (8 samples, 0.02%)dfbench`_mi_os_reset (8 samples, 0.02%)libsystem_kernel.dylib`madvise (8 samples, 0.02%)dfbench`core::ptr::drop_in_place<alloc::vec::Vec<alloc::sync::Arc<dyn arrow_array::array::Array>>> (11 samples, 0.03%)dfbench`alloc::sync::Arc<T,A>::drop_slow (10 samples, 0.03%)dfbench`core::ptr::drop_in_place<core::option::Option<parquet::file::statistics::Statistics>> (6 samples, 0.02%)dfbench`core::ptr::drop_in_place<parquet::file::metadata::ColumnChunkMetaData> (23 samples, 0.06%)dfbench`mi_free_block_mt (4 samples, 0.01%)dfbench`mi_free (5 samples, 0.01%)dfbench`mi_free_block_delayed_mt (17 samples, 0.05%)dfbench`core::ptr::drop_in_place<datafusion_physical_plan::aggregates::row_hash::GroupedHashAggregateStream> (58 samples, 0.16%)dfbench`core::ptr::drop_in_place<datafusion_physical_plan::projection::ProjectionStream> (57 samples, 0.16%)dfbench`core::ptr::drop_in_place<datafusion::datasource::physical_plan::file_stream::FileStream<datafusion::datasource::physical_plan::parquet::opener::ParquetOpener>> (57 samples, 0.16%)dfbench`core::ptr::drop_in_place<datafusion::datasource::physical_plan::file_stream::FileStreamState> (57 samples, 0.16%)dfbench`core::ptr::drop_in_place<futures_util::stream::stream::map::Map<futures_util::stream::try_stream::MapErr<parquet::arrow::async_reader::ParquetRecordBatchStream<alloc::boxed::Box<dyn parquet::arrow::async_reader::AsyncFileReader>>,<datafusion::datasource::physical_plan::parquet::opener::ParquetOpener as datafusion::datasource::physical_plan::file_stream::FileOpener>::open::{{closure}}::{{closure}}>,<datafusion::datasource::physical_plan::parquet::opener::ParquetOpener as datafusion::datasource::physical_plan::file_stream::FileOpener>::open::{{closure}}::{{closure}}>> (57 samples, 0.16%)dfbench`core::ptr::drop_in_place<parquet::arrow::async_reader::ReaderFactory<alloc::boxed::Box<dyn parquet::arrow::async_reader::AsyncFileReader>>> (57 samples, 0.16%)dfbench`alloc::sync::Arc<T,A>::drop_slow (57 samples, 0.16%)dfbench`core::ptr::drop_in_place<parquet::file::metadata::ParquetMetaData> (55 samples, 0.15%)dfbench`core::ptr::drop_in_place<parquet::file::metadata::RowGroupMetaData> (54 samples, 0.15%)dfbench`mi_free_generic_mt (4 samples, 0.01%)dfbench`datafusion_common::hash_utils::create_hashes (366 samples, 1.01%)dfbench`_mi_free_delayed_block (13 samples, 0.04%)dfbench`_mi_malloc_generic (17 samples, 0.05%)dfbench`mi_heap_malloc_zero_aligned_at_generic (18 samples, 0.05%)libsystem_kernel.dylib`mach_absolute_time (21 samples, 0.06%)dfbench`datafusion_physical_plan::repartition::RepartitionExec::pull_from_input::_{{closure}} (25,380 samples, 70.33%)dfbench`datafusion_physical_plan::repartition::RepartitionExec::pull_from_input::_{{closure}}dfbench`std::sys::pal::unix::time::Timespec::now (25 samples, 0.07%)libsystem_c.dylib`clock_gettime (25 samples, 0.07%)dfbench`tokio::runtime::scheduler::multi_thread::worker::Context::run_task (32,072 samples, 88.88%)dfbench`tokio::runtime::scheduler::multi_thread::worker::Context::run_taskdfbench`tokio::runtime::task::raw::poll (32,060 samples, 88.84%)dfbench`tokio::runtime::task::raw::polllibsystem_platform.dylib`__bzero (12 samples, 0.03%)dfbench`tokio::runtime::task::harness::Harness<T,S>::complete (4 samples, 0.01%)dfbench`tokio::runtime::scheduler::multi_thread::worker::_<impl tokio::runtime::scheduler::multi_thread::handle::Handle>::schedule_task (4 samples, 0.01%)dfbench`parking_lot::condvar::Condvar::notify_one_slow (4 samples, 0.01%)libsystem_kernel.dylib`__psynch_cvsignal (4 samples, 0.01%)libsystem_kernel.dylib`close (37 samples, 0.10%)dfbench`std::sys::pal::unix::thread::Thread::new::thread_start (32,778 samples, 90.83%)dfbench`std::sys::pal::unix::thread::Thread::new::thread_startdfbench`core::ops::function::FnOnce::call_once{{vtable.shim}} (32,778 samples, 90.83%)dfbench`core::ops::function::FnOnce::call_once{{vtable.shim}}dfbench`std::sys_common::backtrace::__rust_begin_short_backtrace (32,778 samples, 90.83%)dfbench`std::sys_common::backtrace::__rust_begin_short_backtracedfbench`tokio::runtime::task::raw::poll (32,763 samples, 90.79%)dfbench`tokio::runtime::task::raw::pollall (36,086 samples, 100%)libsystem_pthread.dylib`thread_start (32,782 samples, 90.84%)libsystem_pthread.dylib`thread_startlibsystem_pthread.dylib`_pthread_start (32,782 samples, 90.84%)libsystem_pthread.dylib`_pthread_startlibsystem_pthread.dylib`_pthread_exit (4 samples, 0.01%)libsystem_pthread.dylib`_pthread_tsd_cleanup (4 samples, 0.01%)dfbench`_mi_thread_done (4 samples, 0.01%)dfbench`mi_heap_collect_ex (4 samples, 0.01%)
\ No newline at end of file