File tree Expand file tree Collapse file tree
sdks/python/apache_beam/transforms Expand file tree Collapse file tree Original file line number Diff line number Diff line change 7575from apache_beam .transforms .util import GcpHsmGeneratedSecret
7676from apache_beam .transforms .util import GcpSecret
7777from apache_beam .transforms .util import Secret
78+ from apache_beam .transforms .util import _BatchSizeEstimator
79+ from apache_beam .transforms .util import _GlobalWindowsBatchingDoFn
7880from apache_beam .transforms .window import FixedWindows
7981from apache_beam .transforms .window import GlobalWindow
8082from apache_beam .transforms .window import GlobalWindows
@@ -1261,8 +1263,6 @@ def check_batch_homogeneity(batch):
12611263 def test_global_batching_dofn_single_vs_multiple_bundles (self ):
12621264 # This test directly verifies how bundling affects the batch sizes produced by
12631265 # the internal _GlobalWindowsBatchingDoFn of BatchElements.
1264- from apache_beam .transforms .util import _GlobalWindowsBatchingDoFn
1265- from apache_beam .transforms .util import _BatchSizeEstimator
12661266
12671267 # 1. Single Bundle Scenario:
12681268 # Four elements processed within the same start_bundle / finish_bundle lifecycle.
You can’t perform that action at this time.
0 commit comments