-
Notifications
You must be signed in to change notification settings - Fork 1.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
minor: fix typos in comments / structure names #13879
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you for the contrbibution @zhuliquan - this looks like a great improvement ❤️ and will make the code easier to read and understand,.
datafusion-cli/src/main.rs
Outdated
@@ -209,7 +209,7 @@ async fn main_inner() -> Result<()> { | |||
if !rc.is_empty() { | |||
exec::exec_from_files(&ctx, rc, &print_options).await?; | |||
} | |||
// TODO maybe we can have thiserror for cli but for now let's keep it simple | |||
// TODO maybe we can have this error for cli but for now let's keep it simple |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think technically thiserror refers to https://crates.io/crates/thiserror
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ok, I got it, I will recover it
@@ -211,7 +211,7 @@ async fn main() -> Result<()> { | |||
// | |||
// Note: in order to prune pages, the Page Index must be loaded and the | |||
// ParquetExec will load it on demand if not present. To avoid a second IO | |||
// during query, this example loaded the Page Index pre-emptively by setting | |||
// during query, this example loaded the Page Index pre-emptily by setting |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think this is actually meant to be something different:
// during query, this example loaded the Page Index pre-emptily by setting | |
// during query, this example loaded the Page Index preemptively by setting |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yeah, I got it, I will recover it
@@ -115,7 +115,7 @@ pub trait Accumulator: Send + Sync + Debug { | |||
/// │ │ | |||
/// │ │ | |||
/// ┌─────────────────────────┐ ┌─────────────────────────┐ | |||
/// │ GroubyBy │ │ GroubyBy │ | |||
/// │ GroupBy │ │ GroupBy │ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🤦
@@ -36,7 +36,7 @@ use datafusion_expr::{ | |||
TableScan, Window, | |||
}; | |||
|
|||
use crate::optimize_projections::required_indices::RequiredIndicies; | |||
use crate::optimize_projections::required_indices::RequiredIndices; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Since this is an internal struct (not exposed publically) I think this is not an API change: https://docs.rs/datafusion/latest/datafusion/index.html?search=RequiredIndicies
@@ -35,15 +35,15 @@ use datafusion_expr::{Expr, LogicalPlan}; | |||
/// indices were added `[3, 2, 4, 3, 6, 1]`, the instance would be represented | |||
/// by `[1, 2, 3, 4, 6]`. | |||
#[derive(Debug, Clone, Default)] | |||
pub(super) struct RequiredIndicies { | |||
pub(super) struct RequiredIndices { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
See above -- this is an internal struct so renaming it is not an API change
@@ -144,8 +144,8 @@ impl DirSchema { | |||
async fn create(state: &SessionState, opts: DirSchemaOpts<'_>) -> Result<Arc<Self>> { | |||
let DirSchemaOpts { ext, dir, format } = opts; | |||
let mut tables = HashMap::new(); | |||
let direntries = std::fs::read_dir(dir).unwrap(); | |||
for res in direntries { | |||
let directories = std::fs::read_dir(dir).unwrap(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It is dir_entries
@@ -170,7 +170,7 @@ impl RepartitionExecState { | |||
/// which is commonly set to the number of CPU cores and all call execute at the same time. | |||
/// | |||
/// Thus, use a **tokio** `OnceCell` for this initialization so as not to waste CPU cycles | |||
/// in a futex lock but instead allow other threads to do something useful. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
futex word might be correct here
Thanks again @zhuliquan and @berkaysynnada 🚀 |
Which issue does this PR close?
Closes #.
Rationale for this change
fix some typo error in doc
What changes are included in this PR?
fix some typo error in doc
Are these changes tested?
Are there any user-facing changes?
no