This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/go_modules/playground/backend/google.golang.org/grpc-1.56.3
in repository https://gitbox.apache.org/repos/asf/beam.git
omit 0a34acca1ee Bump google.golang.org/grpc from 1.54.0 to 1.56.3 in
/playground/backend
add 472ed9f8d86 [Go Docs] Remove outdated examples of anonymous functions
from pardo, partition, and filter. (#29181)
add 84e6ceb2f0c increase received message size to max for Job Management.
(#29178)
add 2f8eebb7fa7 Remove anonymous function from fileio.ReadMatches example
(#29186)
add 8a28100c47b Bump commons-cli:commons-cli from 1.5.0 to 1.6.0 (#29192)
add 28f6e3398bf Don't assume env vars are set in model handler (#29200)
add 41369a71df9 Report Outstanding Bundles and Bytes (#29041)
add d5fc02479c2 [YAML] Add a basic aggregating transform to Beam Yaml.
(#29167)
add 8648e583c84 Merge pull request #29114: Support default values in
storage-api sink
add 9a836203055 Rename --host to --fireStoreHost (#29201)
add 714badb821b Better naming and logging to investigate leaking bigtable
resources (#29203)
add ba714221d5e organize and refactor GrpcWindmillServer. (#29156)
add 524a7bfef40 [runners-spark] Do not set accTimestamp to null in
SparkCombineFn (#28256)
add 6a66b722f46 Merge pull request #29162: [runners-spark] Do not set
accTimestamp to null in SparkCombineFn (#28256)
add 181296dec2a Support DatabaseID in Datastore beam connector (#27987)
add 7d81f0a4f35 Add empty outputs to AMR notebook (#29205)
add c7dc5bd3d0d Add in missing space between dependency and comment
add 9a97ec841c1 Fix notebook installs (#29211)
add 9fcd0c91844 Add Cloud Bigtable Change Stream integration tests (#29127)
add 3f434f07053 Add Dataflow Example Java21 PreCommit (#29170)
add e8849a424e7 Inventory - Update temp files retention to 24h, run more
frequently (#29216)
add e2a7ea66fa2 [Security] Bump org.json version due to CVE-2023-5072
(#29207)
add a036a181170 Delete on exit beam-artifact temp file (#29219)
add e4bd6183b70 [YAML] Add JDBC branding transforms (#29171)
add f2f88c5f3a1 Fix launcher artifact gradle configuration name conflict
(#29224)
add aed3457d9a2 Add apache_beam[yaml] options.
add 8fcdf6a2975 Update readme to refere to new options.
add 99e16d3f65f Also include gcp for ease of use.
add 16fee7505e3 Merge pull request #29225 Add apache_beam[yaml] options.
add d329a7e9b85 [Python]Enable state cache to 100 MB (#28781)
add 96d6f2d07e8 prevent performance cdap on forks (#29194)
add b5134202a0c [YAML] Implement basic java mapping operations. (#28657)
add f5c0d16c680 Update `it` module. (#29232)
add 33a527b1d4f Declare undeclared libraries to work around BEAM-11761.
add 04b55c76dd6 Merge pull request #29234 Declare undeclared libraries to
work around BEAM-11761.
add ca21948d64d [YAML] - Kafka write and RAW format
add 400ef71e719 [YAML] - Exactly one field + fix typo
add 9e65a1035e4 Merge pull request #29160 [YAML] - Kafka write and RAW
format
add d00303ab326 add self to java reviewers to be able to merge and review
streaming worker code (#29235)
add 92a1a457efa Remove cred rotation jobs from jenkins (#29243)
add 9101dc1f842 Avoid potential null pointer exceptions in logging.
add afc499f4bf5 Merge pull request #29231 Avoid potential null pointer
exceptions in logging.
add 0d478daf760 [YAML] Java Filter and explode operations. (#29110)
add b10c7cef7c8 Less frequent reporting of potentially stuck records.
(#29222)
add 13e803a6403 [YAML] Remove redundant WithSchema transform
add 9364d7d03d8 Merge pull request #29237 [YAML] Remove redundant
WithSchema transform
add f53ebfef62d [YAML] Add yaml label to yaml transform (#29227)
add 3d3a7afe0df Bugfix/kafka nullable header coders (#29244)
add 0113befc701 Bump github.com/aws/aws-sdk-go-v2/config from 1.19.1 to
1.20.0 in /sdks (#29240)
add e20c5365cc9 add self to java reviewers to be able to merge and review
streaming worker code (#29235) (#29246)
add 5d6c1826583 Implement Cross-Bundle BatchElements (#29175)
add 4dd147dbe20 Shutdown LoadTest, PerformanceTest, and Others Category
Jenkins jobs (#29247)
add 48f3c67054e Mark JS UDFs as experimental
add f166cfbd018 [YAML] Add jsobject conversion to mapping
add 46cdcf4bf71 address initial comments
add 551544ef779 Refactor js function construction
add b9725e352a0 unpollute namespace
add ae861364dc0 Merge pull request #29169 [YAML] fix javascript UDF output
in mapping transforms
add ea8596f2df0 Add ability to run performance regression checks on Beam
IO Load tests. (#29226)
add 27ccdc9acfc Moving to 2.53.0-SNAPSHOT on master branch.
add 00a55272eaa [RRIO] [Testing] Mock API integration tests (#29236)
add 53cb14c77e0 Bump google.golang.org/grpc from 1.54.0 to 1.56.3 in
/playground/backend
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (0a34acca1ee)
\
N -- N -- N
refs/heads/dependabot/go_modules/playground/backend/google.golang.org/grpc-1.56.3
(53cb14c77e0)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
.github/REVIEWERS.yml | 1 +
.github/workflows/README.md | 4 +-
.github/workflows/beam_CancelStaleDataflowJobs.yml | 2 +-
.../workflows/beam_CleanUpDataprocResources.yml | 2 +-
.github/workflows/beam_CleanUpGCPResources.yml | 2 +-
.../workflows/beam_CleanUpPrebuiltSDKImages.yml | 2 +-
.../workflows/beam_CloudML_Benchmarks_Dataflow.yml | 2 +-
.../beam_IODatastoresCredentialsRotation.yml | 2 +-
.../beam_Inference_Python_Benchmarks_Dataflow.yml | 2 +-
.github/workflows/beam_Java_JMH.yml | 2 +-
.../beam_Java_LoadTests_Combine_Smoke.yml | 2 +-
.../beam_LoadTests_Go_CoGBK_Dataflow_Batch.yml | 2 +-
.../beam_LoadTests_Go_CoGBK_Flink_batch.yml | 2 +-
.../beam_LoadTests_Go_Combine_Dataflow_Batch.yml | 2 +-
.../beam_LoadTests_Go_Combine_Flink_Batch.yml | 2 +-
.../beam_LoadTests_Go_GBK_Dataflow_Batch.yml | 2 +-
.../beam_LoadTests_Go_GBK_Flink_Batch.yml | 2 +-
.../beam_LoadTests_Go_ParDo_Dataflow_Batch.yml | 2 +-
.../beam_LoadTests_Go_ParDo_Flink_Batch.yml | 2 +-
.../beam_LoadTests_Go_SideInput_Dataflow_Batch.yml | 2 +-
.../beam_LoadTests_Go_SideInput_Flink_Batch.yml | 2 +-
.../beam_LoadTests_Java_CoGBK_Dataflow_Batch.yml | 2 +-
...eam_LoadTests_Java_CoGBK_Dataflow_Streaming.yml | 2 +-
...s_Java_CoGBK_Dataflow_V2_Batch_JavaVersions.yml | 2 +-
...va_CoGBK_Dataflow_V2_Streaming_JavaVersions.yml | 2 +-
...s_Java_CoGBK_SparkStructuredStreaming_Batch.yml | 2 +-
.../beam_LoadTests_Java_Combine_Dataflow_Batch.yml | 2 +-
...m_LoadTests_Java_Combine_Dataflow_Streaming.yml | 2 +-
...Java_Combine_SparkStructuredStreaming_Batch.yml | 2 +-
.../beam_LoadTests_Java_GBK_Dataflow_Batch.yml | 2 +-
.../beam_LoadTests_Java_GBK_Dataflow_Streaming.yml | 2 +-
...LoadTests_Java_GBK_Dataflow_V2_Batch_Java11.yml | 2 +-
...LoadTests_Java_GBK_Dataflow_V2_Batch_Java17.yml | 2 +-
...Tests_Java_GBK_Dataflow_V2_Streaming_Java11.yml | 2 +-
...Tests_Java_GBK_Dataflow_V2_Streaming_Java17.yml | 2 +-
...sts_Java_GBK_SparkStructuredStreaming_Batch.yml | 2 +-
.../beam_LoadTests_Java_ParDo_Dataflow_Batch.yml | 2 +-
...eam_LoadTests_Java_ParDo_Dataflow_Streaming.yml | 2 +-
...s_Java_ParDo_Dataflow_V2_Batch_JavaVersions.yml | 2 +-
...va_ParDo_Dataflow_V2_Streaming_JavaVersions.yml | 2 +-
...s_Java_ParDo_SparkStructuredStreaming_Batch.yml | 2 +-
.../beam_LoadTests_Python_CoGBK_Dataflow_Batch.yml | 2 +-
...m_LoadTests_Python_CoGBK_Dataflow_Streaming.yml | 2 +-
.../beam_LoadTests_Python_CoGBK_Flink_Batch.yml | 2 +-
...eam_LoadTests_Python_Combine_Dataflow_Batch.yml | 2 +-
...LoadTests_Python_Combine_Dataflow_Streaming.yml | 2 +-
.../beam_LoadTests_Python_Combine_Flink_Batch.yml | 2 +-
...am_LoadTests_Python_Combine_Flink_Streaming.yml | 2 +-
...LoadTests_Python_FnApiRunner_Microbenchmark.yml | 2 +-
.../beam_LoadTests_Python_GBK_Dataflow_Batch.yml | 2 +-
...eam_LoadTests_Python_GBK_Dataflow_Streaming.yml | 2 +-
.../beam_LoadTests_Python_GBK_Flink_Batch.yml | 2 +-
...adTests_Python_GBK_reiterate_Dataflow_Batch.yml | 2 +-
...sts_Python_GBK_reiterate_Dataflow_Streaming.yml | 2 +-
.../beam_LoadTests_Python_ParDo_Dataflow_Batch.yml | 2 +-
...m_LoadTests_Python_ParDo_Dataflow_Streaming.yml | 2 +-
.../beam_LoadTests_Python_ParDo_Flink_Batch.yml | 2 +-
...beam_LoadTests_Python_ParDo_Flink_Streaming.yml | 2 +-
...m_LoadTests_Python_SideInput_Dataflow_Batch.yml | 2 +-
.../workflows/beam_MetricsCredentialsRotation.yml | 5 +-
.github/workflows/beam_Metrics_Report.yml | 6 +-
.../workflows/beam_PerformanceTests_AvroIOIT.yml | 2 +-
.../beam_PerformanceTests_AvroIOIT_HDFS.yml | 2 +-
...PerformanceTests_BigQueryIO_Batch_Java_Avro.yml | 2 +-
...PerformanceTests_BigQueryIO_Batch_Java_Json.yml | 2 +-
..._PerformanceTests_BigQueryIO_Streaming_Java.yml | 2 +-
...eam_PerformanceTests_BiqQueryIO_Read_Python.yml | 2 +-
...formanceTests_BiqQueryIO_Write_Python_Batch.yml | 2 +-
.github/workflows/beam_PerformanceTests_Cdap.yml | 2 +-
.../beam_PerformanceTests_Compressed_TextIOIT.yml | 2 +-
...m_PerformanceTests_Compressed_TextIOIT_HDFS.yml | 2 +-
.../beam_PerformanceTests_HadoopFormat.yml | 2 +-
.github/workflows/beam_PerformanceTests_JDBC.yml | 2 +-
.../workflows/beam_PerformanceTests_Kafka_IO.yml | 2 +-
.../beam_PerformanceTests_ManyFiles_TextIOIT.yml | 2 +-
...am_PerformanceTests_ManyFiles_TextIOIT_HDFS.yml | 2 +-
.../beam_PerformanceTests_MongoDBIO_IT.yml | 2 +-
.../beam_PerformanceTests_ParquetIOIT.yml | 2 +-
.../beam_PerformanceTests_ParquetIOIT_HDFS.yml | 2 +-
...erformanceTests_PubsubIOIT_Python_Streaming.yml | 2 +-
...m_PerformanceTests_SQLBigQueryIO_Batch_Java.yml | 2 +-
.../beam_PerformanceTests_SingleStoreIO.yml | 2 +-
..._PerformanceTests_SpannerIO_Read_2GB_Python.yml | 2 +-
...manceTests_SpannerIO_Write_2GB_Python_Batch.yml | 2 +-
.../beam_PerformanceTests_SparkReceiver_IO.yml | 2 +-
.../beam_PerformanceTests_TFRecordIOIT.yml | 2 +-
.../beam_PerformanceTests_TFRecordIOIT_HDFS.yml | 2 +-
.../workflows/beam_PerformanceTests_TextIOIT.yml | 2 +-
.../beam_PerformanceTests_TextIOIT_HDFS.yml | 2 +-
.../beam_PerformanceTests_TextIOIT_Python.yml | 2 +-
...PerformanceTests_WordCountIT_PythonVersions.yml | 2 +-
.../workflows/beam_PerformanceTests_XmlIOIT.yml | 2 +-
.../beam_PerformanceTests_XmlIOIT_HDFS.yml | 2 +-
.../beam_PerformanceTests_xlang_KafkaIO_Python.yml | 2 +-
.../beam_PostCommit_BeamMetrics_Publish.yml | 7 +-
.github/workflows/beam_PostCommit_Go.yml | 2 +-
.../workflows/beam_PostCommit_Go_Dataflow_ARM.yml | 2 +-
.github/workflows/beam_PostCommit_Go_VR_Flink.yml | 2 +-
.github/workflows/beam_PostCommit_Go_VR_Samza.yml | 2 +-
.github/workflows/beam_PostCommit_Go_VR_Spark.yml | 2 +-
.github/workflows/beam_PostCommit_Java.yml | 2 +-
.../beam_PostCommit_Java_Avro_Versions.yml | 2 +-
.../beam_PostCommit_Java_BigQueryEarlyRollout.yml | 2 +-
.../workflows/beam_PostCommit_Java_DataflowV1.yml | 2 +-
.../workflows/beam_PostCommit_Java_DataflowV2.yml | 2 +-
.../beam_PostCommit_Java_Examples_Dataflow.yml | 2 +-
.../beam_PostCommit_Java_Examples_Dataflow_ARM.yml | 2 +-
...beam_PostCommit_Java_Examples_Dataflow_Java.yml | 2 +-
.../beam_PostCommit_Java_Examples_Dataflow_V2.yml | 2 +-
...m_PostCommit_Java_Examples_Dataflow_V2_Java.yml | 2 +-
.../beam_PostCommit_Java_Examples_Direct.yml | 2 +-
.../beam_PostCommit_Java_Examples_Flink.yml | 2 +-
.../beam_PostCommit_Java_Examples_Spark.yml | 2 +-
.../beam_PostCommit_Java_Hadoop_Versions.yml | 2 +-
.../beam_PostCommit_Java_IO_Performance_Tests.yml | 2 +-
.../beam_PostCommit_Java_InfluxDbIO_IT.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Dataflow_Java11.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Dataflow_Java17.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Direct_Java11.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Direct_Java17.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Direct_Java21.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Flink_Java11.yml | 2 +-
.../beam_PostCommit_Java_Jpms_Spark_Java11.yml | 2 +-
.../beam_PostCommit_Java_Nexmark_Dataflow.yml | 2 +-
.../beam_PostCommit_Java_Nexmark_Dataflow_V2.yml | 2 +-
...am_PostCommit_Java_Nexmark_Dataflow_V2_Java.yml | 2 +-
.../beam_PostCommit_Java_Nexmark_Direct.yml | 2 +-
.../beam_PostCommit_Java_Nexmark_Flink.yml | 2 +-
.../beam_PostCommit_Java_Nexmark_Spark.yml | 2 +-
.../beam_PostCommit_Java_PVR_Flink_Streaming.yml | 2 +-
.../workflows/beam_PostCommit_Java_PVR_Samza.yml | 2 +-
.../beam_PostCommit_Java_PVR_Spark3_Streaming.yml | 2 +-
.../beam_PostCommit_Java_PVR_Spark_Batch.yml | 2 +-
.github/workflows/beam_PostCommit_Java_Sickbay.yml | 2 +-
.../beam_PostCommit_Java_SingleStoreIO_IT.yml | 2 +-
.../beam_PostCommit_Java_Tpcds_Dataflow.yml | 2 +-
.../workflows/beam_PostCommit_Java_Tpcds_Flink.yml | 2 +-
.../workflows/beam_PostCommit_Java_Tpcds_Spark.yml | 2 +-
...am_PostCommit_Java_ValidatesRunner_Dataflow.yml | 2 +-
..._Java_ValidatesRunner_Dataflow_JavaVersions.yml | 2 +-
...mit_Java_ValidatesRunner_Dataflow_Streaming.yml | 2 +-
...PostCommit_Java_ValidatesRunner_Dataflow_V2.yml | 2 +-
..._Java_ValidatesRunner_Dataflow_V2_Streaming.yml | 2 +-
...beam_PostCommit_Java_ValidatesRunner_Direct.yml | 2 +-
...it_Java_ValidatesRunner_Direct_JavaVersions.yml | 2 +-
.../beam_PostCommit_Java_ValidatesRunner_Flink.yml | 2 +-
...ostCommit_Java_ValidatesRunner_Flink_Java11.yml | 2 +-
.../beam_PostCommit_Java_ValidatesRunner_Samza.yml | 2 +-
.../beam_PostCommit_Java_ValidatesRunner_Spark.yml | 2 +-
...va_ValidatesRunner_SparkStructuredStreaming.yml | 2 +-
...ostCommit_Java_ValidatesRunner_Spark_Java11.yml | 2 +-
...am_PostCommit_Java_ValidatesRunner_Twister2.yml | 2 +-
.../beam_PostCommit_Java_ValidatesRunner_ULR.yml | 2 +-
.github/workflows/beam_PostCommit_Javadoc.yml | 2 +-
.../beam_PostCommit_PortableJar_Flink.yml | 2 +-
.../beam_PostCommit_PortableJar_Spark.yml | 2 +-
.github/workflows/beam_PostCommit_Python.yml | 2 +-
.github/workflows/beam_PostCommit_Python_Arm.yml | 2 +-
.../beam_PostCommit_Python_Examples_Dataflow.yml | 2 +-
.../beam_PostCommit_Python_Examples_Direct.yml | 2 +-
.../beam_PostCommit_Python_Examples_Flink.yml | 2 +-
.../beam_PostCommit_Python_Examples_Spark.yml | 2 +-
.../beam_PostCommit_Python_MongoDBIO_IT.yml | 2 +-
.../beam_PostCommit_Python_Nexmark_Direct.yml | 2 +-
...stCommit_Python_ValidatesContainer_Dataflow.yml | 2 +-
..._Python_ValidatesContainer_Dataflow_With_RC.yml | 2 +-
..._PostCommit_Python_ValidatesRunner_Dataflow.yml | 2 +-
...eam_PostCommit_Python_ValidatesRunner_Flink.yml | 2 +-
...eam_PostCommit_Python_ValidatesRunner_Samza.yml | 2 +-
...eam_PostCommit_Python_ValidatesRunner_Spark.yml | 2 +-
.../beam_PostCommit_Python_Xlang_Gcp_Dataflow.yml | 2 +-
.../beam_PostCommit_Python_Xlang_Gcp_Direct.yml | 2 +-
.../beam_PostCommit_Python_Xlang_IO_Dataflow.yml | 2 +-
.github/workflows/beam_PostCommit_SQL.yml | 2 +-
.../workflows/beam_PostCommit_Sickbay_Python.yml | 2 +-
.../beam_PostCommit_TransformService_Direct.yml | 2 +-
.../workflows/beam_PostCommit_Website_Publish.yml | 2 +-
.github/workflows/beam_PostCommit_Website_Test.yml | 2 +-
.github/workflows/beam_PostCommit_XVR_Direct.yml | 2 +-
.github/workflows/beam_PostCommit_XVR_Flink.yml | 2 +-
.../beam_PostCommit_XVR_GoUsingJava_Dataflow.yml | 2 +-
...eam_PostCommit_XVR_JavaUsingPython_Dataflow.yml | 2 +-
..._PostCommit_XVR_PythonUsingJavaSQL_Dataflow.yml | 2 +-
...eam_PostCommit_XVR_PythonUsingJava_Dataflow.yml | 2 +-
.github/workflows/beam_PostCommit_XVR_Samza.yml | 2 +-
.github/workflows/beam_PostCommit_XVR_Spark3.yml | 2 +-
.../workflows/beam_PreCommit_CommunityMetrics.yml | 2 +-
.github/workflows/beam_PreCommit_GHA.yml | 2 +-
.github/workflows/beam_PreCommit_Go.yml | 2 +-
.github/workflows/beam_PreCommit_GoPortable.yml | 2 +-
.github/workflows/beam_PreCommit_GoPrism.yml | 2 +-
.github/workflows/beam_PreCommit_ItFramework.yml | 2 +-
.github/workflows/beam_PreCommit_Java.yml | 2 +-
...eCommit_Java_Amazon-Web-Services2_IO_Direct.yml | 2 +-
...reCommit_Java_Amazon-Web-Services_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Amqp_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Azure_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Cassandra_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Cdap_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Clickhouse_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Csv_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Debezium_IO_Direct.yml | 2 +-
...beam_PreCommit_Java_ElasticSearch_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Examples_Dataflow.yml | 2 +-
...eam_PreCommit_Java_Examples_Dataflow_Java11.yml | 2 +-
...eam_PreCommit_Java_Examples_Dataflow_Java17.yml | 2 +-
...am_PreCommit_Java_Examples_Dataflow_Java21.yml} | 61 ++-
...Commit_Java_File-schema-transform_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Flink_Versions.yml | 2 +-
.../beam_PreCommit_Java_GCP_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Google-ads_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_HBase_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_HCatalog_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Hadoop_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_InfluxDb_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_JDBC_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Jms_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Kafka_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Kinesis_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Kudu_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_MongoDb_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Mqtt_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Neo4j_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_PVR_Flink_Batch.yml | 2 +-
.../beam_PreCommit_Java_PVR_Flink_Docker.yml | 2 +-
.../beam_PreCommit_Java_Parquet_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Pulsar_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_RabbitMq_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Redis_IO_Direct.yml | 2 +-
...am_PreCommit_Java_RequestResponse_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_SingleStore_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Snowflake_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Solr_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Spark3_Versions.yml | 2 +-
.../beam_PreCommit_Java_Splunk_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Thrift_IO_Direct.yml | 2 +-
.../beam_PreCommit_Java_Tika_IO_Direct.yml | 2 +-
.../workflows/beam_PreCommit_Kotlin_Examples.yml | 2 +-
.../workflows/beam_PreCommit_Portable_Python.yml | 2 +-
.github/workflows/beam_PreCommit_Python.yml | 2 +-
.github/workflows/beam_PreCommit_PythonDocker.yml | 2 +-
.github/workflows/beam_PreCommit_PythonDocs.yml | 2 +-
.../workflows/beam_PreCommit_PythonFormatter.yml | 2 +-
.github/workflows/beam_PreCommit_PythonLint.yml | 2 +-
.../workflows/beam_PreCommit_Python_Coverage.yml | 2 +-
.../workflows/beam_PreCommit_Python_Dataframes.yml | 2 +-
.../workflows/beam_PreCommit_Python_Examples.yml | 2 +-
.../beam_PreCommit_Python_Integration.yml | 2 +-
.../workflows/beam_PreCommit_Python_PVR_Flink.yml | 2 +-
.../workflows/beam_PreCommit_Python_Runners.yml | 2 +-
.../workflows/beam_PreCommit_Python_Transforms.yml | 2 +-
.github/workflows/beam_PreCommit_RAT.yml | 2 +-
.github/workflows/beam_PreCommit_SQL.yml | 2 +-
.github/workflows/beam_PreCommit_SQL_Java11.yml | 2 +-
.github/workflows/beam_PreCommit_SQL_Java17.yml | 2 +-
.github/workflows/beam_PreCommit_Spotless.yml | 2 +-
.github/workflows/beam_PreCommit_Typescript.yml | 2 +-
.github/workflows/beam_PreCommit_Website.yml | 2 +-
.../workflows/beam_PreCommit_Website_Stage_GCS.yml | 2 +-
.github/workflows/beam_PreCommit_Whitespace.yml | 2 +-
.github/workflows/beam_Prober_CommunityMetrics.yml | 2 +-
.../workflows/beam_Publish_Beam_SDK_Snapshots.yml | 5 +-
.../workflows/beam_Publish_Docker_Snapshots.yml | 7 +-
...beam_Python_ValidatesContainer_Dataflow_ARM.yml | 2 +-
.github/workflows/beam_Release_NightlySnapshot.yml | 5 +-
.../beam_Release_Python_NightlySnapshot.yml | 7 +-
.test-infra/jenkins/job_CleanUpGCPResources.groovy | 44 --
.../jenkins/job_CleanUpPrebuiltSDKImages.groovy | 44 --
.../job_CloudMLBenchmarkTests_Python.groovy | 67 ---
.../job_IODatastoresCredentialsRotation.groovy | 56 --
.../job_InferenceBenchmarkTests_Python.groovy | 206 -------
.test-infra/jenkins/job_Inventory.groovy | 4 +-
.../jenkins/job_LoadTests_CoGBK_Java.groovy | 215 --------
.../jenkins/job_LoadTests_Combine_Flink_Go.groovy | 139 -----
.../job_LoadTests_Combine_Flink_Python.groovy | 186 -------
.../jenkins/job_LoadTests_Combine_Python.groovy | 154 ------
.../jenkins/job_LoadTests_GBK_Flink_Go.groovy | 231 --------
.../job_LoadTests_ParDo_Flink_Python.groovy | 374 -------------
.../job_LoadTests_SideInput_Flink_Go.groovy | 105 ----
.../jenkins/job_LoadTests_coGBK_Flink_Go.groovy | 184 -------
.../jenkins/job_LoadTests_coGBK_Python.groovy | 210 -------
.../jenkins/job_MetricsCredentialsRotation.groovy | 56 --
.../jenkins/job_PerformanceTests_KafkaIO_IT.groovy | 130 -----
.../jenkins/job_Publish_Docker_Snapshots.groovy | 50 --
.../jenkins/job_Publish_SDK_Image_Snapshots.groovy | 56 --
.../jenkins/job_Release_NightlySnapshot.groovy | 78 ---
.test-infra/mock-apis/README.md | 56 +-
.test-infra/mock-apis/go.mod | 6 +-
.test-infra/mock-apis/go.sum | 12 +-
.../configmap.yaml | 24 -
.../deployment.yaml | 27 -
.../kustomization.yaml | 34 --
.../configmap.yaml | 8 +-
.../deployment.yaml | 6 +-
.../kustomization.yaml | 4 +-
.../configmap.yaml | 7 +-
.../deployment.yaml | 6 +-
.../kustomization.yaml | 4 +-
.../src/main/go/internal/service/echo/echo.go | 47 +-
.../src/main/go/test/integration/echo/echo_test.go | 220 ++++++++
.../src/main/go/test/integration/integration.go | 32 +-
.../mock-apis/src/main/go/test/integration/vars.go | 49 ++
CHANGES.md | 5 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../beam-ml/automatic_model_refresh.ipynb | 165 +++++-
.../notebooks/beam-ml/run_custom_inference.ipynb | 1 +
.../beam-ml/run_inference_windowing.ipynb | 6 +-
gradle.properties | 4 +-
.../cassandra/CassandraResourceManagerUtils.java | 2 +-
.../it/cassandra/matchers/CassandraAsserts.java | 2 +-
.../it/cassandra/CassandraResourceManagerTest.java | 3 +-
.../java/org/apache/beam/it/gcp/LoadTestBase.java | 10 +-
.../beam/it/gcp/artifacts/utils/JsonTestUtil.java | 149 +++++
.../it/gcp/dataflow/DefaultPipelineLauncher.java | 6 +-
.../beam/it/gcp/dataflow/DirectRunnerClient.java | 6 +-
.../beam/it/gcp/datagenerator/DataGenerator.java | 54 +-
.../gcp/datastore/matchers/DatastoreAsserts.java | 3 +-
.../apache/beam/it/gcp/dlp/DlpResourceManager.java | 5 +-
.../apache/beam/it/gcp/kms/KMSResourceManager.java | 5 +-
.../beam/it/gcp/monitoring/MonitoringClient.java | 12 +-
.../it/gcp/spanner/matchers/SpannerAsserts.java | 45 ++
.../apache/beam/it/gcp/bigtable/BigTableIOLT.java | 18 +-
.../apache/beam/it/gcp/spanner/SpannerIOLT.java | 285 ++++++++++
.../apache/beam/it/gcp/storage/FileBasedIOLT.java | 2 +-
.../beam/it/jdbc/AbstractJDBCResourceManager.java | 63 ++-
.../apache/beam/it/jdbc/JDBCResourceManager.java | 11 +-
.../apache/beam/it/jdbc/MSSQLResourceManager.java | 7 +-
.../apache/beam/it/jdbc/MySQLResourceManager.java | 4 +-
.../apache/beam/it/jdbc/OracleResourceManager.java | 8 +-
.../beam/it/jdbc/PostgresResourceManager.java | 20 +-
.../apache/beam/it/kafka/KafkaResourceManager.java | 11 +-
.../beam/it/mongodb/MongoDBResourceManager.java | 10 +-
.../beam/it/mongodb/matchers/MongoDBAsserts.java | 2 +-
.../apache/beam/it/neo4j/Neo4jResourceManager.java | 11 +-
.../beam/it/neo4j/conditions/Neo4jQueryCheck.java | 15 +-
.../beam/it/splunk/SplunkResourceManager.java | 10 +-
.../TestContainerResourceManager.java | 15 +-
.../beam/it/truthmatchers/RecordsSubject.java | 2 +-
release/build.gradle.kts | 4 +-
release/src/main/scripts/jenkins_jobs.txt | 36 --
.../beam/runners/core/construction/External.java | 6 +-
.../examples/build.gradle | 8 +-
.../google-cloud-dataflow-java/worker/build.gradle | 3 +
.../dataflow/worker/DataflowSystemMetrics.java | 4 +
.../worker/MetricTrackingWindmillServerStub.java | 4 +-
.../dataflow/worker/StreamingDataflowWorker.java | 30 +-
.../options/StreamingDataflowWorkerOptions.java | 2 +-
.../dataflow/worker/util/BoundedQueueExecutor.java | 16 +
.../worker/windmill/WindmillServerBase.java | 8 +-
.../worker/windmill/WindmillServerStub.java | 8 +-
.../{ => client}/AbstractWindmillStream.java | 3 +-
.../windmill/{ => client}/WindmillStream.java | 21 +-
.../windmill/{ => client}/WindmillStreamPool.java | 2 +-
.../grpc}/AppendableInputStream.java | 2 +-
.../grpc}/GetWorkTimingInfosTracker.java | 2 +-
.../grpc}/GrpcCommitWorkStream.java | 9 +-
.../grpc}/GrpcDeadlineClientInterceptor.java | 2 +-
.../windmill/client/grpc/GrpcDispatcherClient.java | 136 +++++
.../grpc}/GrpcGetDataStream.java | 13 +-
.../grpc}/GrpcGetDataStreamRequests.java | 2 +-
.../grpc}/GrpcGetWorkStream.java | 29 +-
.../grpc}/GrpcGetWorkerMetadataStream.java | 9 +-
.../windmill/client/grpc/GrpcWindmillServer.java | 355 ++++++++++++
.../client/grpc/GrpcWindmillStreamFactory.java | 227 ++++++++
.../grpc/auth/VendoredCredentialsAdapter.java | 81 +++
.../VendoredRequestMetadataCallbackAdapter.java | 51 ++
.../grpc/observers}/DirectStreamObserver.java | 2 +-
.../ForwardingClientResponseObserver.java | 2 +-
.../grpc/observers}/StreamObserverFactory.java | 2 +-
.../client/grpc/stubs/WindmillChannelFactory.java | 137 +++++
.../client/grpc/stubs/WindmillStubFactory.java | 73 +++
.../throttling/StreamingEngineThrottleTimers.java | 37 +-
.../throttling}/ThrottleTimer.java | 6 +-
.../windmill/grpcclient/GrpcWindmillServer.java | 607 ---------------------
.../worker/windmill/work/WorkItemReceiver.java | 32 +-
.../worker/windmill/work/budget/GetWorkBudget.java | 98 ++++
.../dataflow/worker/FakeWindmillServer.java | 24 +-
.../worker/StreamingDataflowWorkerTest.java | 186 ++++++-
.../{ => client}/WindmillStreamPoolTest.java | 2 +-
.../grpc}/GrpcGetWorkerMetadataStreamTest.java | 9 +-
.../grpc}/GrpcWindmillServerTest.java | 15 +-
.../windmill/work/budget/GetWorkBudgetTest.java | 72 +++
.../runners/spark/translation/SparkCombineFn.java | 18 +-
.../spark/translation/SparkCombineFnTest.java | 29 +
sdks/go.mod | 24 +-
sdks/go.sum | 37 +-
sdks/go/pkg/beam/core/core.go | 2 +-
sdks/go/pkg/beam/io/fileio/example_test.go | 12 +-
sdks/go/pkg/beam/pardo.go | 46 +-
sdks/go/pkg/beam/partition.go | 13 +
.../runners/prism/internal/jobservices/server.go | 5 +-
sdks/go/pkg/beam/transforms/filter/filter.go | 22 +-
sdks/java/container/build.gradle | 4 +-
sdks/java/container/common.gradle | 6 +-
.../transforms/providers/ErrorHandling.java | 65 +++
.../providers/JavaExplodeTransformProvider.java | 225 ++++++++
.../providers/JavaFilterTransformProvider.java | 181 ++++++
.../JavaMapToFieldsTransformProvider.java | 228 ++++++++
.../schemas/transforms/providers/JavaRowUdf.java | 346 ++++++++++++
.../transforms/providers/StringCompiler.java | 262 +++++++++
.../schemas/transforms/providers/package-info.java | 28 +-
.../JavaExplodeTransformProviderTest.java | 104 ++++
.../providers/JavaFilterTransformProviderTest.java | 119 ++++
.../JavaMapToFieldsTransformProviderTest.java | 192 +++++++
.../transforms/providers/JavaRowUdfTest.java | 158 ++++++
.../transforms/providers/StringCompilerTest.java | 71 +++
...xpansionServiceSchemaTransformProviderTest.java | 3 +-
.../schemaio-expansion-service/build.gradle | 7 +
.../fn/harness/control/ExecutionStateSampler.java | 60 +-
.../fn/harness/logging/BeamFnLoggingClient.java | 6 +-
sdks/java/io/google-cloud-platform/build.gradle | 10 +-
.../beam/sdk/io/gcp/bigquery/AppendClientInfo.java | 7 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 26 +-
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 6 +-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 7 +-
.../beam/sdk/io/gcp/bigquery/StorageApiLoads.java | 17 +-
.../StorageApiWriteRecordsInconsistent.java | 9 +-
.../bigquery/StorageApiWriteUnshardedRecords.java | 17 +-
.../bigquery/StorageApiWritesShardedRecords.java | 24 +-
.../io/gcp/bigquery/TableRowToStorageApiProto.java | 23 +-
.../BigtableChangeStreamTestOptions.java | 25 +-
.../gcp/common/GcpIoPipelineOptionsRegistrar.java | 2 +
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 349 ++++++++++--
.../sdk/io/gcp/firestore/FirestoreOptions.java | 4 +-
.../FirestoreStatefulComponentFactory.java | 2 +-
.../sdk/io/gcp/testing/FakeDatasetService.java | 6 +-
.../bigquery/StorageApiSinkDefaultValuesIT.java | 317 +++++++++++
.../sdk/io/gcp/bigtable/BigtableTestUtils.java | 27 +-
.../changestreams/it/BigtableChangeStreamIT.java | 361 ++++++++++++
.../it/BigtableClientIntegrationTestOverride.java | 83 +++
.../beam/sdk/io/gcp/datastore/DatastoreV1Test.java | 94 +++-
.../beam/sdk/io/gcp/datastore/SplitQueryFnIT.java | 17 +-
.../apache/beam/sdk/io/gcp/datastore/V1ReadIT.java | 26 +-
.../beam/sdk/io/gcp/datastore/V1TestUtil.java | 59 +-
.../beam/sdk/io/gcp/datastore/V1WriteIT.java | 11 +-
.../gcp/firestore/it/FirestoreTestingHelper.java | 2 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 4 +-
.../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 3 +-
.../kafka/KafkaWriteSchemaTransformProvider.java | 32 +-
.../beam/sdk/io/kafka/KafkaRecordCoderTest.java | 7 +
.../KafkaWriteSchemaTransformProviderTest.java | 44 ++
.../apache_beam/io/gcp/bigtableio_it_test.py | 10 +-
sdks/python/apache_beam/ml/inference/base.py | 10 +-
.../python/apache_beam/options/pipeline_options.py | 16 +
.../runners/portability/portable_runner.py | 3 +-
.../apache_beam/runners/worker/sdk_worker_main.py | 26 +-
.../runners/worker/sdk_worker_main_test.py | 13 +
.../testing/analyzers/io_tests_config.yaml | 256 +++++++++
.../testing/analyzers/load_test_perf_analysis.py | 98 ++++
.../testing/analyzers/perf_analysis_utils.py | 11 +-
sdks/python/apache_beam/transforms/core.py | 2 +-
sdks/python/apache_beam/transforms/util.py | 118 +++-
sdks/python/apache_beam/transforms/util_test.py | 160 ++++++
sdks/python/apache_beam/version.py | 2 +-
sdks/python/apache_beam/yaml/README.md | 2 +-
sdks/python/apache_beam/yaml/readme_test.py | 23 +-
sdks/python/apache_beam/yaml/standard_io.yaml | 48 ++
.../apache_beam/yaml/standard_providers.yaml | 38 ++
sdks/python/apache_beam/yaml/yaml_combine.md | 166 ++++++
sdks/python/apache_beam/yaml/yaml_combine.py | 205 +++++++
sdks/python/apache_beam/yaml/yaml_combine_test.py | 173 ++++++
sdks/python/apache_beam/yaml/yaml_mapping.py | 152 +++---
sdks/python/apache_beam/yaml/yaml_provider.py | 101 ++--
sdks/python/apache_beam/yaml/yaml_transform.py | 20 +-
sdks/python/apache_beam/yaml/yaml_udf_test.py | 121 +++-
sdks/python/container/build.gradle | 4 +-
sdks/python/container/common.gradle | 8 +-
sdks/python/setup.py | 3 +
sdks/typescript/package.json | 2 +-
470 files changed, 8309 insertions(+), 4484 deletions(-)
copy .github/workflows/{beam_PreCommit_Java_RequestResponse_IO_Direct.yml =>
beam_PreCommit_Java_Examples_Dataflow_Java21.yml} (66%)
delete mode 100644 .test-infra/jenkins/job_CleanUpGCPResources.groovy
delete mode 100644 .test-infra/jenkins/job_CleanUpPrebuiltSDKImages.groovy
delete mode 100644 .test-infra/jenkins/job_CloudMLBenchmarkTests_Python.groovy
delete mode 100644
.test-infra/jenkins/job_IODatastoresCredentialsRotation.groovy
delete mode 100644
.test-infra/jenkins/job_InferenceBenchmarkTests_Python.groovy
delete mode 100644 .test-infra/jenkins/job_LoadTests_CoGBK_Java.groovy
delete mode 100644 .test-infra/jenkins/job_LoadTests_Combine_Flink_Go.groovy
delete mode 100644
.test-infra/jenkins/job_LoadTests_Combine_Flink_Python.groovy
delete mode 100644 .test-infra/jenkins/job_LoadTests_Combine_Python.groovy
delete mode 100644 .test-infra/jenkins/job_LoadTests_GBK_Flink_Go.groovy
delete mode 100644 .test-infra/jenkins/job_LoadTests_ParDo_Flink_Python.groovy
delete mode 100644 .test-infra/jenkins/job_LoadTests_SideInput_Flink_Go.groovy
delete mode 100644 .test-infra/jenkins/job_LoadTests_coGBK_Flink_Go.groovy
delete mode 100644 .test-infra/jenkins/job_LoadTests_coGBK_Python.groovy
delete mode 100644 .test-infra/jenkins/job_MetricsCredentialsRotation.groovy
delete mode 100644 .test-infra/jenkins/job_PerformanceTests_KafkaIO_IT.groovy
delete mode 100644 .test-infra/jenkins/job_Publish_Docker_Snapshots.groovy
delete mode 100644 .test-infra/jenkins/job_Publish_SDK_Image_Snapshots.groovy
delete mode 100644 .test-infra/jenkins/job_Release_NightlySnapshot.groovy
delete mode 100644
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/123079b5-1e58-4b28-a185-66702e2b10c3/configmap.yaml
delete mode 100644
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/123079b5-1e58-4b28-a185-66702e2b10c3/deployment.yaml
delete mode 100644
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/e1064224-3671-46fe-971d-47887fac3d4c/kustomization.yaml
rename
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/{e1064224-3671-46fe-971d-47887fac3d4c
=> echo-should-exceed-quota}/configmap.yaml (87%)
rename
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/{e1064224-3671-46fe-971d-47887fac3d4c
=> echo-should-exceed-quota}/deployment.yaml (88%)
rename
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/{123079b5-1e58-4b28-a185-66702e2b10c3
=> echo-should-exceed-quota}/kustomization.yaml (92%)
rename
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/{f588787b-28f8-4e5f-8335-f862379daf59
=> echo-should-never-exceed-quota}/configmap.yaml (87%)
rename
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/{f588787b-28f8-4e5f-8335-f862379daf59
=> echo-should-never-exceed-quota}/deployment.yaml (88%)
rename
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/{f588787b-28f8-4e5f-8335-f862379daf59
=> echo-should-never-exceed-quota}/kustomization.yaml (92%)
create mode 100644
.test-infra/mock-apis/src/main/go/test/integration/echo/echo_test.go
copy sdks/go/pkg/beam/core/core.go =>
.test-infra/mock-apis/src/main/go/test/integration/integration.go (52%)
create mode 100644 .test-infra/mock-apis/src/main/go/test/integration/vars.go
create mode 100644
it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerIOLT.java
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{
=> client}/AbstractWindmillStream.java (98%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{
=> client}/WindmillStream.java (84%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{
=> client}/WindmillStreamPool.java (99%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/grpc}/AppendableInputStream.java (98%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/grpc}/GetWorkTimingInfosTracker.java (99%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/grpc}/GrpcCommitWorkStream.java (96%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/grpc}/GrpcDeadlineClientInterceptor.java (97%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcDispatcherClient.java
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/grpc}/GrpcGetDataStream.java (95%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/grpc}/GrpcGetDataStreamRequests.java (98%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/grpc}/GrpcGetWorkStream.java (89%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/grpc}/GrpcGetWorkerMetadataStream.java (93%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcWindmillServer.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcWindmillStreamFactory.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/auth/VendoredCredentialsAdapter.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/auth/VendoredRequestMetadataCallbackAdapter.java
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{
=> client/grpc/observers}/DirectStreamObserver.java (98%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{
=> client/grpc/observers}/ForwardingClientResponseObserver.java (96%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{
=> client/grpc/observers}/StreamObserverFactory.java (97%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/WindmillChannelFactory.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/WindmillStubFactory.java
rename .test-infra/jenkins/job_CancelStaleDataflowJobs.groovy =>
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/throttling/StreamingEngineThrottleTimers.java
(51%)
rename
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/throttling}/ThrottleTimer.java (94%)
delete mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/grpcclient/GrpcWindmillServer.java
rename .test-infra/jenkins/job_ReleaseCandidate_Python.groovy =>
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/WorkItemReceiver.java
(54%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/budget/GetWorkBudget.java
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/{
=> client}/WindmillStreamPoolTest.java (99%)
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/grpc}/GrpcGetWorkerMetadataStreamTest.java (96%)
rename
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/{grpcclient
=> client/grpc}/GrpcWindmillServerTest.java (98%)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/work/budget/GetWorkBudgetTest.java
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/providers/ErrorHandling.java
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/providers/JavaExplodeTransformProvider.java
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/providers/JavaFilterTransformProvider.java
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/providers/JavaMapToFieldsTransformProvider.java
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/providers/JavaRowUdf.java
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/providers/StringCompiler.java
copy .test-infra/jenkins/job_CleanUpDataprocResources.groovy =>
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/providers/package-info.java
(61%)
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/transforms/providers/JavaExplodeTransformProviderTest.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/transforms/providers/JavaFilterTransformProviderTest.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/transforms/providers/JavaMapToFieldsTransformProviderTest.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/transforms/providers/JavaRowUdfTest.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/schemas/transforms/providers/StringCompilerTest.java
rename .test-infra/jenkins/job_CleanUpDataprocResources.groovy =>
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/BigtableChangeStreamTestOptions.java
(61%)
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiSinkDefaultValuesIT.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/it/BigtableChangeStreamIT.java
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/it/BigtableClientIntegrationTestOverride.java
create mode 100644
sdks/python/apache_beam/testing/analyzers/io_tests_config.yaml
create mode 100644
sdks/python/apache_beam/testing/analyzers/load_test_perf_analysis.py
create mode 100644 sdks/python/apache_beam/yaml/yaml_combine.md
create mode 100644 sdks/python/apache_beam/yaml/yaml_combine.py
create mode 100644 sdks/python/apache_beam/yaml/yaml_combine_test.py
