Closed discord9 closed 3 months ago
The latest modifications enhance the logging capabilities within the DfScalarFunction
implementation and related processes. By adding detailed info
and debug
statements, these changes aim to give developers improved insights into function evaluations, making debugging more straightforward and improving overall visibility into the datafusion scalar function evaluations.
Files | Change Summaries |
---|---|
src/flow/src/expr/scalar.rs |
Introduced info and debug logging, capturing important stages of function evaluation and record batch processing. |
src/flow/src/transform/expr.rs |
Added info and debug logging, a new function is_proto_literal , and updated rewrite_scalar_function for handling literals. |
sequenceDiagram
participant Client
participant DfScalarFunction
participant Logger
Client->>DfScalarFunction: Evaluate function
DfScalarFunction->>Logger: info!("Evaluating scalar function: {:?}", self)
DfScalarFunction->>DfScalarFunction: Process function
DfScalarFunction->>Logger: info!("Values: {:?}, Exprs: {:?}", values, exprs)
DfScalarFunction->>Logger: info!("Evaluated values: {:?}", values)
DfScalarFunction->>Logger: info!("Processed with record batch: {:?}", rb)
DfScalarFunction-->>Client: Return result
In the code’s forest, logs now gleam and glow,
Withinfo
anddebug
, what insights they bestow.
Scalar functions speak, their secrets to the light,
Guiding devs in darkness, making wrongs go right.
🌟✨🐰
Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media?
Attention: Patch coverage is 90.00000%
with 1 line
in your changes missing coverage. Please review.
Project coverage is 84.66%. Comparing base (
c4db9e8
) to head (16c32c5
). Report is 8 commits behind head on main.
I hereby agree to the terms of the GreptimeDB CLA.
Refer to a related PR or issue link (optional)
What's changed and what's your intention?
fix a bug where calling datafusion function from flow with literal args will cause datafusion to throw error with unmatched type
Please explain IN DETAIL what the changes are in this PR and why they are needed:
Checklist
Summary by CodeRabbit
New Features
Improvements