Skip to content

Commit

Permalink
fix(rust): make interval parsing compatible with plural form (#2250)
Browse files Browse the repository at this point in the history
# Description
Spark-scala uses the plural form to construct intervals, so "day**s**"
instead of "day". To keep backwards compatibility, I kept the singular
form as well.

- closes #2180
- closes: #2072
  • Loading branch information
ion-elgreco committed Mar 6, 2024
1 parent 42767ff commit 7c1bc35
Showing 1 changed file with 50 additions and 10 deletions.
60 changes: 50 additions & 10 deletions crates/core/src/table/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -289,7 +289,7 @@ impl<'a> TableConfig<'a> {
/// than this value. Otherwise, the query may not be able to restart, as it must still read old files.
pub fn deleted_file_retention_duration(&self) -> Duration {
lazy_static! {
static ref DEFAULT_DURATION: Duration = parse_interval("interval 1 week").unwrap();
static ref DEFAULT_DURATION: Duration = parse_interval("interval 1 weeks").unwrap();
}
self.0
.get(DeltaConfigKey::DeletedFileRetentionDuration.as_ref())
Expand All @@ -305,7 +305,7 @@ impl<'a> TableConfig<'a> {
/// constant time. Operations on history are parallel but will become more expensive as the log size increases.
pub fn log_retention_duration(&self) -> Duration {
lazy_static! {
static ref DEFAULT_DURATION: Duration = parse_interval("interval 30 day").unwrap();
static ref DEFAULT_DURATION: Duration = parse_interval("interval 30 days").unwrap();
}
self.0
.get(DeltaConfigKey::LogRetentionDuration.as_ref())
Expand Down Expand Up @@ -525,14 +525,14 @@ fn parse_interval(value: &str) -> Result<Duration, DeltaConfigError> {
let number = number as u64;

let duration = match it.next().ok_or_else(not_an_interval)? {
"nanosecond" => Duration::from_nanos(number),
"microsecond" => Duration::from_micros(number),
"millisecond" => Duration::from_millis(number),
"second" => Duration::from_secs(number),
"minute" => Duration::from_secs(number * SECONDS_PER_MINUTE),
"hour" => Duration::from_secs(number * SECONDS_PER_HOUR),
"day" => Duration::from_secs(number * SECONDS_PER_DAY),
"week" => Duration::from_secs(number * SECONDS_PER_WEEK),
"nanosecond" | "nanoseconds" => Duration::from_nanos(number),
"microsecond" | "microseconds" => Duration::from_micros(number),
"millisecond" | "milliseconds" => Duration::from_millis(number),
"second" | "seconds" => Duration::from_secs(number),
"minute" | "minutes" => Duration::from_secs(number * SECONDS_PER_MINUTE),
"hour" | "hours" => Duration::from_secs(number * SECONDS_PER_HOUR),
"day" | "days" => Duration::from_secs(number * SECONDS_PER_DAY),
"week" | "weeks" => Duration::from_secs(number * SECONDS_PER_WEEK),
unit => {
return Err(DeltaConfigError::Validation(format!(
"Unknown unit '{unit}'"
Expand Down Expand Up @@ -620,36 +620,76 @@ mod tests {
Duration::from_nanos(123)
);

assert_eq!(
parse_interval("interval 123 nanoseconds").unwrap(),
Duration::from_nanos(123)
);

assert_eq!(
parse_interval("interval 123 microsecond").unwrap(),
Duration::from_micros(123)
);

assert_eq!(
parse_interval("interval 123 microseconds").unwrap(),
Duration::from_micros(123)
);

assert_eq!(
parse_interval("interval 123 millisecond").unwrap(),
Duration::from_millis(123)
);

assert_eq!(
parse_interval("interval 123 milliseconds").unwrap(),
Duration::from_millis(123)
);

assert_eq!(
parse_interval("interval 123 second").unwrap(),
Duration::from_secs(123)
);

assert_eq!(
parse_interval("interval 123 seconds").unwrap(),
Duration::from_secs(123)
);

assert_eq!(
parse_interval("interval 123 minute").unwrap(),
Duration::from_secs(123 * 60)
);

assert_eq!(
parse_interval("interval 123 minutes").unwrap(),
Duration::from_secs(123 * 60)
);

assert_eq!(
parse_interval("interval 123 hour").unwrap(),
Duration::from_secs(123 * 3600)
);

assert_eq!(
parse_interval("interval 123 hours").unwrap(),
Duration::from_secs(123 * 3600)
);

assert_eq!(
parse_interval("interval 123 day").unwrap(),
Duration::from_secs(123 * 86400)
);

assert_eq!(
parse_interval("interval 123 days").unwrap(),
Duration::from_secs(123 * 86400)
);

assert_eq!(
parse_interval("interval 123 week").unwrap(),
Duration::from_secs(123 * 604800)
);

assert_eq!(
parse_interval("interval 123 week").unwrap(),
Duration::from_secs(123 * 604800)
Expand Down

0 comments on commit 7c1bc35

Please sign in to comment.