This is an automated email from the ASF dual-hosted git repository.
jonah pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/datafusion.git
The following commit(s) were added to refs/heads/main by this push:
new 9fb7aee95c Minor: Add debug log message for creating GroupValuesRows
(#13506)
9fb7aee95c is described below
commit 9fb7aee95c5fcf177609963cedadf443ba6fe1b7
Author: Andrew Lamb <[email protected]>
AuthorDate: Thu Nov 21 01:05:57 2024 -0500
Minor: Add debug log message for creating GroupValuesRows (#13506)
* Minor: Add debug log message for creating GroupValuesRows
* fmt
---
datafusion/physical-plan/src/aggregates/group_values/row.rs | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/datafusion/physical-plan/src/aggregates/group_values/row.rs
b/datafusion/physical-plan/src/aggregates/group_values/row.rs
index de0ae2e07d..8e0f0a3d65 100644
--- a/datafusion/physical-plan/src/aggregates/group_values/row.rs
+++ b/datafusion/physical-plan/src/aggregates/group_values/row.rs
@@ -27,6 +27,7 @@ use datafusion_common::Result;
use datafusion_execution::memory_pool::proxy::{RawTableAllocExt, VecAllocExt};
use datafusion_expr::EmitTo;
use hashbrown::raw::RawTable;
+use log::debug;
use std::mem::size_of;
use std::sync::Arc;
@@ -80,6 +81,9 @@ pub struct GroupValuesRows {
impl GroupValuesRows {
pub fn try_new(schema: SchemaRef) -> Result<Self> {
+ // Print a debugging message, so it is clear when the (slower) fallback
+ // GroupValuesRows is used.
+ debug!("Creating GroupValuesRows for schema: {}", schema);
let row_converter = RowConverter::new(
schema
.fields()
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
