-
Notifications
You must be signed in to change notification settings - Fork 28.9k
[SPARK-21590][SS]Window start time should support negative values #18903
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
Conversation
|
ok to test |
| } | ||
| } | ||
|
|
||
| test("SPARK-21590: Start time works with negative values and return microseconds") { |
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.
could you also add a DataFrame test for this with a negative value? then I'll feel a lot more comfortable that we don't have to have the start offset as a positive number in the window calculation.
Look for DataFrameTimeWindowingSuite.scala
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 thanks, I added some tests in DataFrameTimeWindowingSuite
|
test this please |
|
test this please |
|
Test build #4154 has finished for PR 18903 at commit
|
|
Test build #4175 has finished for PR 18903 at commit
|
|
Test build #4178 has finished for PR 18903 at commit
|
|
retest this please |
|
ok to test |
|
Test build #93048 has finished for PR 18903 at commit
|
|
Merged to master |
What changes were proposed in this pull request?
Remove the non-negative checks of window start time to make window support negative start time, and add a check to guarantee the absolute value of start time is less than slide duration.
How was this patch tested?
New unit tests.