[beam] 01/01: Merge pull request #16872: [BEAM-13959] Fix StorageApi writes when a field is named f
This is an automated email from the ASF dual-hosted git repository. reuvenlax pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git commit a78fec72d0d9198eef75144a7bdaf93ada5abf9b Merge: 895a1dd c577f4a Author: reuvenlax AuthorDate: Wed Feb 16 21:01:07 2022 -0800 Merge pull request #16872: [BEAM-13959] Fix StorageApi writes when a field is named f .../io/gcp/bigquery/TableRowToStorageApiProto.java | 46 +++- .../bigquery/TableRowToStorageApiProtoTest.java| 294 +++-- 2 files changed, 313 insertions(+), 27 deletions(-)
[beam] branch master updated (895a1dd -> a78fec7)
This is an automated email from the ASF dual-hosted git repository. reuvenlax pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 895a1dd Bump dataflow.fnapi_container_version (#16874) add c577f4a Fix TableRow conversion for the case of fields named "f" new a78fec7 Merge pull request #16872: [BEAM-13959] Fix StorageApi writes when a field is named f The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .../io/gcp/bigquery/TableRowToStorageApiProto.java | 46 +++- .../bigquery/TableRowToStorageApiProtoTest.java| 294 +++-- 2 files changed, 313 insertions(+), 27 deletions(-)
[beam] branch nightly-refs/heads/master updated (b3de798 -> 895a1dd)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch nightly-refs/heads/master in repository https://gitbox.apache.org/repos/asf/beam.git. from b3de798 Merge pull request #16735 from [BEAM-13827] - fix medium file size upload to s3 add 3fed305 Merge pull request #16753 from [BEAM-13837] [Playground] show graph on the frontend add 07378ce [BEAM-13785] playground - enable scio sdk add 879638a Merge pull request #16847 from [BEAM-13785] [Playground] enable SCIO sdk add e300702 Add test category UsesProcessingTimeTimers add c5b14de Label tests that need UsesProcessingTimeTimers add a0bdba6 Exclude UsesProcessingTimeTimers from SamzaRunner tests add b2f2128 Merge pull request #16865: Create test category for UsesProcessingTimeTimers are exclude from Samza add add7bbc [BEAM-13202] Fix typos on tests names for VarianceFnTest add 1105c34 [BEAM-13202] Add Coder to CountIfFn.Accum add cf75357 [BEAM-13202] Reuse Count transform code since CountIf is a specific case add 6e98dd4 Merge pull request #16856: [BEAM-13202] Add Coder to CountIfFn.Accum add 9cac23a [BEAM-13955] Fix pylint breakage from #16836 (#16867) add a1053d4 [adhoc] Migrate KinesisIOIT to use ITEnvironment for Localstack based IT tests add eb60a79 Merge pull request #16869: [adhoc] Migrate KinesisIOIT to use ITEnvironment for Localstack based IT tests add 7298487 Update Java LTS roadmap info on website for Java 17 add 95542f6 Merge pull request #16736: Update Java LTS roadmap info on website for Java 17 add 26c4056 [BEAM-13106] Support Flink 1.14. add d38c117 [BEAM-13106] Reuse executor instead of shutting it down mid-test. add 47486e4 [BEAM-13106] Prevent infinite wait in Flink savepoint test. add 99a0907 [BEAM-13106] A couple additional fixes to FlinkSavepointTest. add 4e5a2b4 Merge pull request #16679 from ibzib/BEAM-13106 add 895a1dd Bump dataflow.fnapi_container_version (#16874) No new revisions were added by this update. Summary of changes: CHANGES.md | 2 + gradle.properties | 2 +- playground/frontend/lib/constants/colors.dart | 2 + .../code_repository/code_client/code_client.dart | 5 + .../code_client/grpc_code_client.dart | 18 +- .../code_repository/code_repository.dart | 21 +- .../code_repository/run_code_result.dart | 5 +- .../lib/modules/examples/models/example_model.dart | 6 + .../example_client/example_client.dart | 2 + .../example_client/grpc_example_client.dart| 24 +- .../examples/repositories/example_repository.dart | 7 + .../modules/graph/graph_builder/canvas_drawer.dart | 128 +++ .../graph_builder/extractors/edge_extractor.dart | 61 + .../extractors/element_extractor.dart | 63 ++ .../graph_builder/extractors/extractor_utils.dart | 23 +- .../graph/graph_builder/extractors/extractors.dart | 13 +- .../graph_builder/extractors/label_extractor.dart | 24 +- .../modules/graph/graph_builder/graph_builder.dart | 246 + .../graph/graph_builder/painters/edge_painter.dart | 105 + .../graph_builder/painters/graph_painter.dart | 86 +++ .../graph/graph_builder/painters/node_painter.dart | 91 .../frontend/lib/modules/graph/models/graph.dart | 121 ++ .../lib/modules/graph/models/table_cell.dart | 25 ++- .../lib/modules/output/components/graph.dart | 101 + .../lib/modules/output/components/output.dart | 17 +- .../lib/modules/output/components/output_area.dart | 15 +- .../components/output_header/output_header.dart| 4 +- .../components/output_header/output_tabs.dart | 19 +- .../lib/modules/sdk/components/sdk_selector.dart | 7 +- .../embedded_playground_page.dart | 6 +- .../components/playground_page_body.dart | 13 +- .../pages/playground/states/examples_state.dart| 11 +- .../pages/playground/states/playground_state.dart | 6 + playground/frontend/pubspec.lock | 9 +- .../code_repository/code_repository_test.dart | 28 +++ .../code_repository_test.mocks.dart| 8 + .../states/example_selector_state_test.mocks.dart | 7 + .../streaming/AbstractStreamOperatorCompat.java| 31 +++ .../runners/flink/metrics/MetricGroupWrapper.java} | 19 +- .../runners/flink/streaming/StreamSources.java | 27 ++- .../streaming/AbstractStreamOperatorCompat.java| 31 +++ .../runners/flink/streaming/StreamSources.java | 27 ++- .../runners/flink/streaming/StreamSources.java | 27 ++- runners/flink/1.14/build.gradle| 34 +++ .../job-server-container/build.gradle | 0 runners/flink/1.14/job-server/build.gradle |
svn commit: r52597 - /dev/beam/2.37.0/python/
Author: bhulette Date: Thu Feb 17 00:15:46 2022 New Revision: 52597 Log: Staging Python artifacts for Apache Beam 2.37.0 RC1 Added: dev/beam/2.37.0/python/ dev/beam/2.37.0/python/apache-beam-2.37.0.zip (with props) dev/beam/2.37.0/python/apache-beam-2.37.0.zip.asc dev/beam/2.37.0/python/apache-beam-2.37.0.zip.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-macosx_10_9_x86_64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-macosx_10_9_x86_64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-macosx_10_9_x86_64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux1_i686.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux1_i686.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux1_i686.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux1_x86_64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux1_x86_64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux1_x86_64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux2010_i686.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux2010_i686.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux2010_i686.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux2010_x86_64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux2010_x86_64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux2010_x86_64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux2014_aarch64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux2014_aarch64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-manylinux2014_aarch64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-win32.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-win32.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-win32.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-win_amd64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-win_amd64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp36-cp36m-win_amd64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-macosx_10_9_x86_64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-macosx_10_9_x86_64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-macosx_10_9_x86_64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux1_i686.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux1_i686.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux1_i686.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux1_x86_64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux1_x86_64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux1_x86_64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux2010_i686.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux2010_i686.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux2010_i686.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux2010_x86_64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux2010_x86_64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux2010_x86_64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux2014_aarch64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux2014_aarch64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-manylinux2014_aarch64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-win32.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-win32.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-win32.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-win_amd64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-win_amd64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp37-cp37m-win_amd64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp38-cp38-macosx_10_9_x86_64.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp38-cp38-macosx_10_9_x86_64.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp38-cp38-macosx_10_9_x86_64.whl.sha512 dev/beam/2.37.0/python/apache_beam-2.37.0-cp38-cp38-manylinux1_i686.whl (with props) dev/beam/2.37.0/python/apache_beam-2.37.0-cp38-cp38-manylinux1_i686.whl.asc dev/beam/2.37.0/python/apache_beam-2.37.0-cp38
svn commit: r52596 - in /dev/beam/2.37.0: ./ apache-beam-2.37.0-source-release.zip apache-beam-2.37.0-source-release.zip.asc apache-beam-2.37.0-source-release.zip.sha512
Author: bhulette Date: Thu Feb 17 00:13:33 2022 New Revision: 52596 Log: Staging Java artifacts for Apache Beam 2.37.0 RC1 Added: dev/beam/2.37.0/ dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip (with props) dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip.asc dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip.sha512 Added: dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip == Binary file - no diff available. Propchange: dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip -- svn:mime-type = application/octet-stream Added: dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip.asc == --- dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip.asc (added) +++ dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip.asc Thu Feb 17 00:13:33 2022 @@ -0,0 +1,16 @@ +-BEGIN PGP SIGNATURE- + +iQIzBAABCgAdFiEEHRkMhbj2tLoSdv/JRJtqPVWNILAFAmINkwgACgkQRJtqPVWN +ILB/LA//RJy5VX+jS173xybanizxjXzyDwnH/6vJOcUdtC3C9LcsWimvhAdX5AIU +PeC8RHw0UplpKKyplRWsPncRnEu6x+lFF2EBpvJNfsudf8zHzha/dHtNMI5dbTqQ +s3DnXQjrnFdunGG9M5FyQw6Er7bSbVTtI6UOc/amHAigROk9+NOYWeg5AQ64mStc +1U7D/RzaqG6xY/F4NG+sxubM4KtMU7UhkunK2GVWhJ8ln8dSLYfir69eNactN3h6 +3slZF844CHr6umrTjwG1D0c5J81hIdTjDdMwe6i9XIT7Z75atsm1Ro8IbS1W6DPC +cfKH9Dv7nPdND8yg96eTOEyxPxOBQDF1loyhowjDdv5IpaEwiHpTq4R7MIYr8gpm +Ri+IGetaJsaMNuIdqi6P01DqeZnbi15mcoRobLYWud0VysKCZm4S7+SiVzodl3/1 +LWJadIC9sI6/VLCqvHcVkxm6FVGbaHdn0vUaPomlcPj+25EF5kSdYXSCbBjOl4+j +uHg+YHgqyFF/ABWNYOyn6IFStgeHGPTwfFTdChLZojvp3WaXdq28VvfTf8OGvl+w +oVLzEiNzbMI9Q8cIS98/CdTNNDkdQbKb4fGDYt0FEQTqJKLhg0BoaTgn4PtHtmjn +OXoVjvGoSviZJqR72oiPqso2Ivn2CN5bfsPKutJystlgxvvHn0c= +=c/qU +-END PGP SIGNATURE- Added: dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip.sha512 == --- dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip.sha512 (added) +++ dev/beam/2.37.0/apache-beam-2.37.0-source-release.zip.sha512 Thu Feb 17 00:13:33 2022 @@ -0,0 +1 @@ +acd42484438de159084b4a04a47ee0a93de13030f8ff16d212c177f3ec55b3c439e4cfecd71be63b450f32cd4622cd6c2afec83df38da9f1954d36804ea3d828 apache-beam-2.37.0-source-release.zip
[beam] branch master updated (4e5a2b4 -> 895a1dd)
This is an automated email from the ASF dual-hosted git repository. yichi pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from 4e5a2b4 Merge pull request #16679 from ibzib/BEAM-13106 add 895a1dd Bump dataflow.fnapi_container_version (#16874) No new revisions were added by this update. Summary of changes: runners/google-cloud-dataflow-java/build.gradle | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-)
[beam] annotated tag v2.37.0-RC1 updated (6adfaca -> 854903f)
This is an automated email from the ASF dual-hosted git repository. bhulette pushed a change to annotated tag v2.37.0-RC1 in repository https://gitbox.apache.org/repos/asf/beam.git. *** WARNING: tag v2.37.0-RC1 was modified! *** from 6adfaca (commit) to 854903f (tag) tagging 6adfacab5c5cfb8e0e1bed06bcbbb29dd8c5d3ef (commit) replaces jupyterlab-sidepanel-v2.0.0 by Brian Hulette on Wed Feb 16 12:51:07 2022 -0800 - Log - v2.37.0-RC1 --- No new revisions were added by this update. Summary of changes:
[beam] annotated tag sdks/v2.37.0-RC1 updated (6adfaca -> c904ac1)
This is an automated email from the ASF dual-hosted git repository. bhulette pushed a change to annotated tag sdks/v2.37.0-RC1 in repository https://gitbox.apache.org/repos/asf/beam.git. *** WARNING: tag sdks/v2.37.0-RC1 was modified! *** from 6adfaca (commit) to c904ac1 (tag) tagging 6adfacab5c5cfb8e0e1bed06bcbbb29dd8c5d3ef (commit) replaces jupyterlab-sidepanel-v2.0.0 by Brian Hulette on Wed Feb 16 12:51:07 2022 -0800 - Log - Go SDK v2.37.0-RC1 --- No new revisions were added by this update. Summary of changes:
[beam] branch master updated (95542f6 -> 4e5a2b4)
This is an automated email from the ASF dual-hosted git repository.
ibzib pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 95542f6 Merge pull request #16736: Update Java LTS roadmap info on
website for Java 17
new 26c4056 [BEAM-13106] Support Flink 1.14.
new d38c117 [BEAM-13106] Reuse executor instead of shutting it down
mid-test.
new 47486e4 [BEAM-13106] Prevent infinite wait in Flink savepoint test.
new 99a0907 [BEAM-13106] A couple additional fixes to FlinkSavepointTest.
new 4e5a2b4 Merge pull request #16679 from ibzib/BEAM-13106
The 34681 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
CHANGES.md | 2 +
gradle.properties | 2 +-
.../streaming/AbstractStreamOperatorCompat.java| 31 ++
.../runners/flink/metrics/MetricGroupWrapper.java} | 15 -
.../runners/flink/streaming/StreamSources.java | 27 +++-
.../streaming/AbstractStreamOperatorCompat.java| 31 ++
.../runners/flink/streaming/StreamSources.java | 27 +++-
.../runners/flink/streaming/StreamSources.java | 27 +++-
runners/flink/{1.13 => 1.14}/build.gradle | 9 +--
.../job-server-container/build.gradle | 0
.../flink/{1.11 => 1.14}/job-server/build.gradle | 2 +-
.../streaming/AbstractStreamOperatorCompat.java| 28 +
.../beam/runners/flink/RemoteMiniClusterImpl.java} | 20 --
.../runners/flink/metrics/MetricGroupWrapper.java} | 15 -
.../runners/flink/streaming/StreamSources.java | 15 +++--
runners/flink/flink_runner.gradle | 13 +++-
.../flink/FlinkPipelineExecutionEnvironment.java | 7 ++-
.../wrappers/streaming/DoFnOperator.java | 71 +-
.../streaming/ExecutableStageDoFnOperator.java | 8 +--
.../beam/runners/flink/FlinkSavepointTest.java | 70 +
.../flink/metrics/FlinkMetricContainerTest.java| 3 +-
.../flink/streaming/BoundedSourceRestoreTest.java | 28 +
.../wrappers/streaming/DoFnOperatorTest.java | 4 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 2 +-
.../streaming/io/UnboundedSourceWrapperTest.java | 43 -
.../python/apache_beam/options/pipeline_options.py | 2 +-
settings.gradle.kts| 4 ++
27 files changed, 343 insertions(+), 163 deletions(-)
copy
runners/flink/{src/main/java/org/apache/beam/runners/flink/metrics/package-info.java
=>
1.11/src/test/java/org/apache/beam/runners/flink/metrics/MetricGroupWrapper.java}
(67%)
copy runners/flink/{1.13 => 1.14}/build.gradle (84%)
copy runners/flink/{1.13 => 1.14}/job-server-container/build.gradle (100%)
copy runners/flink/{1.11 => 1.14}/job-server/build.gradle (95%)
copy runners/flink/{1.12 =>
1.14}/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/AbstractStreamOperatorCompat.java
(75%)
copy
runners/flink/{src/test/java/org/apache/beam/runners/flink/RemoteMiniCluster.java
=>
1.14/src/test/java/org/apache/beam/runners/flink/RemoteMiniClusterImpl.java}
(66%)
copy
runners/flink/{src/main/java/org/apache/beam/runners/flink/metrics/package-info.java
=>
1.14/src/test/java/org/apache/beam/runners/flink/metrics/MetricGroupWrapper.java}
(63%)
copy runners/flink/{1.12 =>
1.14}/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
(84%)
[beam] branch release-2.37.0 updated (4e215fd -> 90d8a6e)
This is an automated email from the ASF dual-hosted git repository. bhulette pushed a change to branch release-2.37.0 in repository https://gitbox.apache.org/repos/asf/beam.git. from 4e215fd [release-2.37.0][BEAM-13955] Fix pylint breakage from #16836 (#16868) add 90d8a6e [release-2.37.0][BEAM-13921] filter out debeziumIO test for spark runner (#16873) No new revisions were added by this update. Summary of changes: sdks/go/test/integration/integration.go | 2 ++ 1 file changed, 2 insertions(+)
[beam] branch master updated (eb60a79 -> 95542f6)
This is an automated email from the ASF dual-hosted git repository. melap pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from eb60a79 Merge pull request #16869: [adhoc] Migrate KinesisIOIT to use ITEnvironment for Localstack based IT tests add 7298487 Update Java LTS roadmap info on website for Java 17 add 95542f6 Merge pull request #16736: Update Java LTS roadmap info on website for Java 17 No new revisions were added by this update. Summary of changes: website/www/site/content/en/roadmap/_index.md | 4 ++-- website/www/site/content/en/roadmap/java-sdk.md | 6 ++ 2 files changed, 4 insertions(+), 6 deletions(-)
[beam] branch master updated (b2f2128 -> 6e98dd4)
This is an automated email from the ASF dual-hosted git repository. iemejia pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git. from b2f2128 Merge pull request #16865: Create test category for UsesProcessingTimeTimers are exclude from Samza add add7bbc [BEAM-13202] Fix typos on tests names for VarianceFnTest add 1105c34 [BEAM-13202] Add Coder to CountIfFn.Accum add cf75357 [BEAM-13202] Reuse Count transform code since CountIf is a specific case add 6e98dd4 Merge pull request #16856: [BEAM-13202] Add Coder to CountIfFn.Accum No new revisions were added by this update. Summary of changes: .../extensions/sql/impl/transform/agg/CountIf.java | 53 +++ .../sql/impl/transform/agg/CountIfTest.java| 78 ++ .../sql/impl/transform/agg/VarianceFnTest.java | 4 +- 3 files changed, 104 insertions(+), 31 deletions(-) create mode 100644 sdks/java/extensions/sql/src/test/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/CountIfTest.java
[beam] branch master updated (879638a -> b2f2128)
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 879638a Merge pull request #16847 from [BEAM-13785] [Playground]
enable SCIO sdk
add e300702 Add test category UsesProcessingTimeTimers
add c5b14de Label tests that need UsesProcessingTimeTimers
add a0bdba6 Exclude UsesProcessingTimeTimers from SamzaRunner tests
add b2f2128 Merge pull request #16865: Create test category for
UsesProcessingTimeTimers are exclude from Samza
No new revisions were added by this update.
Summary of changes:
runners/samza/build.gradle | 1 +
...UsesTimersInParDo.java => UsesProcessingTimeTimers.java} | 2 +-
.../java/org/apache/beam/sdk/transforms/GroupByKeyTest.java | 8 +++-
.../test/java/org/apache/beam/sdk/transforms/ParDoTest.java | 13 +++--
4 files changed, 20 insertions(+), 4 deletions(-)
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/{UsesTimersInParDo.java
=> UsesProcessingTimeTimers.java} (95%)
