Skip to content

Move PeriodicStream into periodicsequence. #35412

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.

Sign up for GitHub

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

Merged
shunping merged 9 commits into from
Jun 27, 2025
Merged

Move PeriodicStream into periodicsequence. #35412

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
2e1a6c2
Move PeriodicStream into periodicsequence.
shunping Jun 24, 2025
30757b4
Consolidate PeriodicStream into PeriodicImpulse.
shunping Jun 26, 2025
2eb4c90
Fix fn_runner_test that used PeriodicStream.
shunping Jun 26, 2025
66f0d51
Reformat
shunping Jun 26, 2025
2991877
Merge branch 'master' into periodic-stream-2
shunping Jun 26, 2025
fd153a5
Fix some edge cases and resolve floating point precision problem.
shunping Jun 27, 2025
523e130
Fix lint and move tests for periodic impulse to its own test case.
shunping Jun 27, 2025
109b2bb
Add more docstrings. Revise stop_timestamp part as it is an exclusive…
shunping Jun 27, 2025
2c3cc51
Fix pydoc error.
shunping Jun 27, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
193 changes: 0 additions & 193 deletions sdks/python/apache_beam/ml/ts/util.py
View file
Open in desktop

This file was deleted.

93 changes: 0 additions & 93 deletions sdks/python/apache_beam/ml/ts/util_test.py
View file
Open in desktop

This file was deleted.

3 changes: 1 addition & 2 deletions sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,6 @@
from apache_beam.metrics import monitoring_infos
from apache_beam.metrics.execution import MetricKey
from apache_beam.metrics.metricbase import MetricName
from apache_beam.ml.ts.util import PeriodicStream
from apache_beam.options.pipeline_options import DebugOptions
from apache_beam.options.pipeline_options import DirectOptions
from apache_beam.options.pipeline_options import PipelineOptions
Expand Down Expand Up @@ -1264,7 +1263,7 @@ def test_sliding_windows(self):
with self.create_pipeline() as p:
ret = (
p
| PeriodicStream(data, interval=1)
| PeriodicImpulse(data=data, fire_interval=1)
| beam.WithKeys(0)
| beam.WindowInto(beam.transforms.window.SlidingWindows(6, 3))
| beam.GroupByKey())
Expand Down
Loading
Loading