Skip to content
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

fix @modifier for multiple partition time series. #1723

Merged
merged 2 commits into from
Feb 29, 2024

Conversation

yu-shipit
Copy link
Contributor

@yu-shipit yu-shipit commented Feb 29, 2024

Pull Request checklist

  • The commit(s) message(s) follows the contribution guidelines ?
  • Tests for the changes have been added (for bug fixes / features) ?
  • Docs have been added / updated (for bug fixes / features) ?

Current behavior : (link exiting issues here : https://help.github.com/articles/basic-writing-and-formatting-syntax/#referencing-issues-and-pull-requests)

New behavior :

BREAKING CHANGES

If this PR contains a breaking change, please describe the impact and migration
path for existing applications.
If not please remove this section.

Breaking changes may include:

  • Any schema changes to any Cassandra tables
  • The serialized format for Dataset and Column (see .toString methods)
  • Over the wire formats for Akka messages / case classes
  • Changes to the HTTP public API
  • Changes to query parsing / PromQL parsing

Other information:

Copy link
Contributor

@alextheimer alextheimer left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks @yu-shipit for the ultra-quick PR -- especially these tests as well 🙏

As discussed offline:

  • RawSeries don't contain an @mod attribute, so we can't just add the @mod string from rawSeriesLikeToQuery.
  • RawSeries are the only case where an @mod timestamp will be baked into the plan range.

@@ -64,7 +65,8 @@ object LogicalPlanParser {

private def periodicSeriesToQuery(periodicSeries: PeriodicSeries): String = {
// Queries like sum(foo) should not have window even though stale lookback is present
s"${rawSeriesLikeToQuery(periodicSeries.rawSeries, false)}"
val at = periodicSeries.atMs.fold("")(atMs => s" $At${atMs / 1000}")
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

What do you think about using map and orElse here? fold implies atMs is a sequence, I think.

@yu-shipit yu-shipit merged commit 3450204 into filodb:develop Feb 29, 2024
1 check passed
sandeep6189 pushed a commit to sandeep6189/FiloDB that referenced this pull request Feb 29, 2024
* fix @modifier for multiple partition time series.
---------

Co-authored-by: Yu Zhang <[email protected]>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants