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 6d24c3dec3b [Prism] Fix a distribution metric problem when count is
zero (#36723)
add 1e40f0663e2 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#36724)
add 0448a5b8062 Bump google.golang.org/api from 0.252.0 to 0.255.0 in
/sdks (#36726)
add 2d617c04bc8 Remove Python 3.9 support from Apache Beam (#36665)
add 9ec41f89932 fix pip intall command (#36734)
add 11f9b0ce909 Extract expiring memoizing supplier as a separate utility
and run end offset refreshes in the current thread. (#36075)
add c2e72ac2dab Streaming read for BigQuery (#36668)
add ff1d6bb62fe feat(typehints): add Python 3.12 TypeAliasType support
(#36709)
add d1327b774cb update beam master tag (#36733)
add bf19899d221 Add timestamp logicaltype (#36705)
add 1d33741c035 Fix Flink IllegalThreadStateException on Java 8 (#36730)
No new revisions were added by this update.
Summary of changes:
.../test-properties.json | 16 +-
.../actions/setup-environment-action/action.yml | 8 +-
.../workflows/beam_CloudML_Benchmarks_Dataflow.yml | 4 +-
.../beam_LoadTests_Python_CoGBK_Dataflow_Batch.yml | 8 +-
...m_LoadTests_Python_CoGBK_Dataflow_Streaming.yml | 8 +-
.../beam_LoadTests_Python_CoGBK_Flink_Batch.yml | 6 +-
...eam_LoadTests_Python_Combine_Dataflow_Batch.yml | 6 +-
...LoadTests_Python_Combine_Dataflow_Streaming.yml | 6 +-
.../beam_LoadTests_Python_Combine_Flink_Batch.yml | 6 +-
...am_LoadTests_Python_Combine_Flink_Streaming.yml | 4 +-
...LoadTests_Python_FnApiRunner_Microbenchmark.yml | 2 +-
.../beam_LoadTests_Python_GBK_Dataflow_Batch.yml | 10 +-
...eam_LoadTests_Python_GBK_Dataflow_Streaming.yml | 2 +-
...adTests_Python_GBK_reiterate_Dataflow_Batch.yml | 4 +-
...sts_Python_GBK_reiterate_Dataflow_Streaming.yml | 4 +-
.../beam_LoadTests_Python_ParDo_Dataflow_Batch.yml | 8 +-
...m_LoadTests_Python_ParDo_Dataflow_Streaming.yml | 8 +-
.../beam_LoadTests_Python_ParDo_Flink_Batch.yml | 6 +-
...beam_LoadTests_Python_ParDo_Flink_Streaming.yml | 10 +-
...m_LoadTests_Python_SideInput_Dataflow_Batch.yml | 20 +-
.github/workflows/beam_LoadTests_Python_Smoke.yml | 4 +-
...eam_PerformanceTests_BiqQueryIO_Read_Python.yml | 2 +-
...formanceTests_BiqQueryIO_Write_Python_Batch.yml | 2 +-
...erformanceTests_PubsubIOIT_Python_Streaming.yml | 2 +-
..._PerformanceTests_SpannerIO_Read_2GB_Python.yml | 2 +-
...manceTests_SpannerIO_Write_2GB_Python_Batch.yml | 2 +-
.../beam_PerformanceTests_TextIOIT_Python.yml | 2 +-
...PerformanceTests_WordCountIT_PythonVersions.yml | 2 +-
.../beam_PerformanceTests_xlang_KafkaIO_Python.yml | 2 +-
.github/workflows/beam_Playground_Precommit.yml | 2 +-
.../beam_PostCommit_PortableJar_Flink.yml | 4 +-
.../beam_PostCommit_PortableJar_Spark.yml | 4 +-
.github/workflows/beam_PostCommit_Python.yml | 2 +-
.github/workflows/beam_PostCommit_Python_Arm.yml | 2 +-
.../beam_PostCommit_Python_Dependency.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_Nexmark_Direct.yml | 2 +-
.../beam_PostCommit_Python_Portable_Flink.yml | 6 +-
...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 +-
.../beam_PostCommit_Python_Xlang_IO_Direct.yml | 2 +-
.../beam_PostCommit_TransformService_Direct.yml | 4 +-
.github/workflows/beam_PostCommit_XVR_Direct.yml | 4 +-
.github/workflows/beam_PostCommit_XVR_Flink.yml | 4 +-
...eam_PostCommit_XVR_JavaUsingPython_Dataflow.yml | 4 +-
...eam_PostCommit_XVR_PythonUsingJava_Dataflow.yml | 4 +-
.github/workflows/beam_PostCommit_XVR_Samza.yml | 4 +-
.github/workflows/beam_PostCommit_XVR_Spark3.yml | 4 +-
.../workflows/beam_PreCommit_Flink_Container.yml | 4 +-
.../workflows/beam_PreCommit_Portable_Python.yml | 4 +-
.github/workflows/beam_PreCommit_Prism_Python.yml | 4 +-
.github/workflows/beam_PreCommit_Python.yml | 2 +-
.github/workflows/beam_PreCommit_PythonDocker.yml | 2 +-
.../workflows/beam_PreCommit_Python_Coverage.yml | 4 +-
.../workflows/beam_PreCommit_Python_Dataframes.yml | 2 +-
.../workflows/beam_PreCommit_Python_Examples.yml | 2 +-
.../beam_PreCommit_Python_Integration.yml | 2 +-
.github/workflows/beam_PreCommit_Python_ML.yml | 6 +-
.../workflows/beam_PreCommit_Python_Runners.yml | 2 +-
.../workflows/beam_PreCommit_Python_Transforms.yml | 2 +-
.../beam_PreCommit_Xlang_Generated_Transforms.yml | 2 +-
.../workflows/beam_Publish_Beam_SDK_Snapshots.yml | 3 -
...beam_Python_ValidatesContainer_Dataflow_ARM.yml | 2 +-
.github/workflows/build_release_candidate.yml | 12 +-
.github/workflows/build_wheels.yml | 8 +-
.github/workflows/dask_runner_tests.yml | 3 +-
...python_CoGBK_Flink_Batch_100b_Multiple_Keys.txt | 2 +-
.../python_CoGBK_Flink_Batch_100b_Single_Key.txt | 2 +-
.../python_CoGBK_Flink_Batch_10kB.txt | 2 +-
...hon_Combine_Flink_Batch_2GB_10_byte_records.txt | 2 +-
.../python_Combine_Flink_Batch_2GB_Fanout_4.txt | 2 +-
.../python_Combine_Flink_Batch_2GB_Fanout_8.txt | 2 +-
...Combine_Flink_Streaming_2GB_10_byte_records.txt | 2 +-
...python_Combine_Flink_Streaming_2GB_Fanout_4.txt | 2 +-
...python_Combine_Flink_Streaming_2GB_Fanout_8.txt | 2 +-
...thon_Combine_Flink_Streaming_small_Fanout_1.txt | 2 +-
...thon_Combine_Flink_Streaming_small_Fanout_2.txt | 2 +-
.../python_GBK_Flink_Batch_2GB_of_100B_records.txt | 2 +-
.../python_GBK_Flink_Batch_2GB_of_10B_records.txt | 2 +-
...nout_4_times_with_2GB_10-byte_records_total.txt | 2 +-
...nout_8_times_with_2GB_10-byte_records_total.txt | 2 +-
...K_Flink_Batch_reiterate_4_times_10kB_values.txt | 2 +-
.../python_ParDo_Flink_Batch_10_Counters.txt | 2 +-
.../python_ParDo_Flink_Batch_10_Iterations.txt | 2 +-
.../python_ParDo_Flink_Batch_200_Iterations.txt | 2 +-
.../python_ParDo_Flink_Streaming_100_Counters.txt | 2 +-
.../python_ParDo_Flink_Streaming_10_Counters.txt | 2 +-
.../python_ParDo_Flink_Streaming_10_Iterations.txt | 2 +-
...python_ParDo_Flink_Streaming_200_Iterations.txt | 2 +-
.../python_ParDo_Flink_Streaming_5_Iterations.txt | 2 +-
.github/workflows/python_dependency_tests.yml | 1 -
.github/workflows/python_tests.yml | 3 +-
.../republish_released_docker_containers.yml | 4 +-
.github/workflows/run_perf_alert_tool.yml | 2 +-
.../run_rc_validation_python_mobile_gaming.yml | 2 +-
.github/workflows/typescript_tests.yml | 4 +-
.github/workflows/update_python_dependencies.yml | 1 -
.pre-commit-config.yaml | 2 +-
.test-infra/jenkins/PythonTestProperties.groovy | 12 +-
.test-infra/jenkins/build.gradle | 4 +-
.test-infra/jenkins/metrics_report/tox.ini | 6 +-
.test-infra/metrics/influxdb/Dockerfile | 2 +-
.test-infra/metrics/influxdb/gsutil/Dockerfile | 2 +-
.test-infra/metrics/sync/github/Dockerfile | 2 +-
.test-infra/metrics/sync/jenkins/Dockerfile | 2 +-
.test-infra/mock-apis/poetry.lock | 6 +-
.test-infra/mock-apis/pyproject.toml | 2 +-
.test-infra/tools/python_installer.sh | 2 +-
CHANGES.md | 1 +
build.gradle.kts | 29 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 8 +-
contributor-docs/code-change-guide.md | 2 +-
contributor-docs/python-tips.md | 18 +-
contributor-docs/release-guide.md | 2 +-
dev-support/docker/pkglist | 7 +-
...nadoes.java => BigQueryStreamingTornadoes.java} | 93 +--
gradle.properties | 2 +-
local-env-setup.sh | 4 +-
.../cloudbuild/playground_cd_examples.sh | 8 +-
.../cloudbuild/playground_ci_examples.sh | 8 +-
release/src/main/Dockerfile | 3 +-
.../python-release/python_release_automation.sh | 2 +-
.../flink/FlinkPipelineExecutionEnvironment.java | 43 ++
sdks/go.mod | 38 +-
sdks/go.sum | 76 +-
.../beam/sdk/schemas/logicaltypes/Timestamp.java | 166 +++++
.../ExpiringMemoizingSerializableSupplier.java | 101 +++
.../sdk/schemas/logicaltypes/LogicalTypesTest.java | 267 +++++++
.../ExpiringMemoizingSerializableSupplierTest.java | 166 +++++
sdks/java/io/google-cloud-platform/build.gradle | 3 +
.../bigquery/BigQueryDynamicReadDescriptor.java | 101 +++
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 232 ++++++
.../gcp/bigquery/BigQueryStorageStreamSource.java | 21 +
...eQueryIT.java => BigQueryIODynamicQueryIT.java} | 55 +-
...geQueryIT.java => BigQueryIODynamicReadIT.java} | 99 ++-
...T.java => BigQueryIODynamicReadTableRowIT.java} | 27 +-
.../io/gcp/bigquery/BigQueryIODynamicReadTest.java | 786 +++++++++++++++++++++
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 104 +--
sdks/python/.isort.cfg | 58 ++
sdks/python/.pylintrc | 15 +-
sdks/python/apache_beam/__init__.py | 5 +-
sdks/python/apache_beam/coders/coder_impl.py | 6 +-
sdks/python/apache_beam/coders/coders.py | 1 +
.../coders/coders_property_based_test.py | 2 +-
sdks/python/apache_beam/coders/coders_test.py | 2 +-
.../apache_beam/coders/coders_test_common.py | 3 +-
sdks/python/apache_beam/dataframe/expressions.py | 3 +-
sdks/python/apache_beam/dataframe/io.py | 1 +
.../internal/cloudpickle/cloudpickle.py | 1 -
.../apache_beam/internal/cloudpickle_pickler.py | 24 +
sdks/python/apache_beam/internal/gcp/auth.py | 2 +-
sdks/python/apache_beam/io/__init__.py | 1 +
.../io/azure/blobstoragefilesystem_test.py | 2 +-
sdks/python/apache_beam/io/azure/blobstorageio.py | 6 +-
.../io/external/xlang_jdbcio_it_test.py | 2 +-
sdks/python/apache_beam/io/filebasedsource_test.py | 2 +-
sdks/python/apache_beam/io/filesystem_test.py | 1 +
sdks/python/apache_beam/io/gcp/__init__.py | 1 +
sdks/python/apache_beam/io/gcp/bigquery.py | 3 +-
.../apache_beam/io/gcp/bigquery_file_loads_test.py | 2 +-
sdks/python/apache_beam/io/gcp/bigquery_test.py | 13 +-
.../apache_beam/io/gcp/bigquery_tools_test.py | 6 +-
sdks/python/apache_beam/io/gcp/bigtableio.py | 3 +-
.../apache_beam/io/gcp/bigtableio_it_test.py | 4 +-
sdks/python/apache_beam/io/gcp/bigtableio_test.py | 9 +-
.../io/gcp/datastore/v1new/datastoreio.py | 3 +-
.../io/gcp/datastore/v1new/query_splitter_test.py | 3 +-
.../io/gcp/datastore/v1new/types_test.py | 1 +
.../apache_beam/io/gcp/experimental/spannerio.py | 5 +-
.../io/gcp/experimental/spannerio_read_it_test.py | 5 +-
.../gcp/experimental/spannerio_read_perf_test.py | 1 +
.../io/gcp/experimental/spannerio_test.py | 9 +-
.../io/gcp/experimental/spannerio_write_it_test.py | 5 +-
.../gcp/experimental/spannerio_write_perf_test.py | 1 +
.../apache_beam/io/gcp/gcsio_integration_test.py | 1 +
sdks/python/apache_beam/io/gcp/gcsio_retry_test.py | 6 +-
sdks/python/apache_beam/io/gcp/gcsio_test.py | 8 +-
.../io/gcp/healthcare/dicomio_integration_test.py | 9 +-
.../io/gcp/internal/clients/bigquery/__init__.py | 1 +
.../apache_beam/io/gcp/pubsub_io_perf_test.py | 1 +
.../apache_beam/io/gcp/pubsublite/__init__.py | 3 +-
sdks/python/apache_beam/io/mongodbio.py | 1 -
sdks/python/apache_beam/io/parquetio.py | 1 +
.../apache_beam/io/requestresponse_it_test.py | 1 +
sdks/python/apache_beam/io/requestresponse_test.py | 1 +
sdks/python/apache_beam/io/textio_test.py | 4 +-
sdks/python/apache_beam/io/tfrecordio.py | 1 +
sdks/python/apache_beam/metrics/metric.py | 2 +-
.../apache_beam/ml/anomaly/detectors/__init__.py | 4 +-
.../ml/anomaly/detectors/pyod_adapter.py | 2 +-
.../ml/anomaly/detectors/pyod_adapter_test.py | 3 +-
sdks/python/apache_beam/ml/gcp/cloud_dlp_test.py | 3 +-
.../apache_beam/ml/gcp/recommendations_ai_test.py | 1 +
.../ml/gcp/recommendations_ai_test_it.py | 1 +
.../apache_beam/ml/gcp/videointelligenceml_test.py | 3 +-
.../ml/gcp/videointelligenceml_test_it.py | 4 +-
sdks/python/apache_beam/ml/gcp/visionml_test.py | 3 +-
sdks/python/apache_beam/ml/gcp/visionml_test_it.py | 4 +-
.../apache_beam/ml/inference/gemini_inference.py | 2 +-
.../ml/inference/gemini_inference_test.py | 5 +-
.../ml/inference/huggingface_inference.py | 9 +-
.../ml/inference/huggingface_inference_test.py | 1 +
.../apache_beam/ml/inference/onnx_inference.py | 2 +-
.../ml/inference/onnx_inference_it_test.py | 1 +
.../ml/inference/onnx_inference_test.py | 9 +-
.../apache_beam/ml/inference/pytorch_inference.py | 1 +
.../ml/inference/pytorch_inference_it_test.py | 3 +-
.../ml/inference/pytorch_inference_test.py | 7 +-
.../ml/inference/tensorflow_inference.py | 2 +-
.../ml/inference/tensorflow_inference_it_test.py | 1 +
.../ml/inference/tensorflow_inference_test.py | 6 +-
.../apache_beam/ml/inference/tensorrt_inference.py | 2 +-
.../ml/inference/tensorrt_inference_test.py | 7 +-
.../ml/inference/vertex_ai_inference_test.py | 5 +-
.../apache_beam/ml/inference/vllm_inference.py | 5 +-
.../apache_beam/ml/inference/xgboost_inference.py | 4 +-
.../ml/inference/xgboost_inference_it_test.py | 3 +-
.../apache_beam/ml/rag/chunking/langchain_test.py | 7 +-
.../ml/rag/embeddings/vertex_ai_test.py | 1 +
.../enrichment/bigquery_vector_search_it_test.py | 6 +-
.../apache_beam/ml/rag/enrichment/milvus_search.py | 3 +-
.../ml/rag/enrichment/milvus_search_it_test.py | 35 +-
.../ml/rag/enrichment/milvus_search_test.py | 21 +-
.../ml/transforms/embeddings/huggingface_test.py | 8 +-
.../ml/transforms/embeddings/open_ai.py | 7 +-
.../ml/transforms/embeddings/tensorflow_hub.py | 3 +-
.../transforms/embeddings/tensorflow_hub_test.py | 4 +-
.../ml/transforms/embeddings/vertex_ai.py | 18 +-
.../ml/transforms/embeddings/vertex_ai_test.py | 9 +-
sdks/python/apache_beam/ml/transforms/handlers.py | 18 +-
.../apache_beam/ml/transforms/handlers_test.py | 7 +-
sdks/python/apache_beam/ml/transforms/tft.py | 5 +-
sdks/python/apache_beam/ml/transforms/utils.py | 2 +-
.../apache_beam/options/pipeline_options_test.py | 3 +-
sdks/python/apache_beam/pipeline.py | 1 +
sdks/python/apache_beam/pipeline_test.py | 2 +-
sdks/python/apache_beam/pvalue.py | 6 +-
sdks/python/apache_beam/runners/__init__.py | 3 +-
sdks/python/apache_beam/runners/common.py | 6 +-
.../runners/dask/transform_evaluator.py | 3 +-
.../runners/dataflow/dataflow_runner.py | 5 +-
.../runners/dataflow/internal/apiclient.py | 2 +-
.../runners/dataflow/internal/apiclient_test.py | 4 +-
.../internal/clients/cloudbuild/__init__.py | 1 +
.../dataflow/internal/clients/dataflow/__init__.py | 3 +-
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
.../runners/dataflow/ptransform_overrides.py | 2 +-
.../apache_beam/runners/direct/direct_runner.py | 13 +-
.../runners/direct/evaluation_context.py | 3 +-
.../runners/direct/transform_evaluator.py | 5 +-
.../runners/interactive/augmented_pipeline.py | 2 +-
.../interactive/background_caching_job_test.py | 1 +
.../runners/interactive/caching/cacheable.py | 1 +
.../dataproc/dataproc_cluster_manager.py | 3 +-
.../runners/interactive/display/display_manager.py | 1 +
.../interactive/display/pcoll_visualization.py | 3 +-
.../runners/interactive/interactive_environment.py | 3 +-
.../runners/interactive/interactive_runner.py | 2 +-
.../runners/interactive/pipeline_instrument.py | 2 +-
.../interactive/pipeline_instrument_test.py | 4 +-
.../runners/interactive/sql/beam_sql_magics.py | 7 +-
.../interactive/sql/beam_sql_magics_test.py | 2 +-
.../apache_beam/runners/interactive/utils.py | 4 +
.../apache_beam/runners/interactive/utils_test.py | 3 +-
.../portability/fn_api_runner/worker_handlers.py | 9 +-
sdks/python/apache_beam/runners/runner.py | 4 +-
.../apache_beam/runners/worker/bundle_processor.py | 1 +
.../apache_beam/runners/worker/operations.py | 2 +-
.../testing/analyzers/perf_analysis_test.py | 4 +-
.../testing/analyzers/perf_analysis_utils.py | 2 +-
.../benchmarks/cloudml/pipelines/workflow.py | 5 +-
.../pytorch_image_classification_benchmarks.py | 3 +-
.../testing/metric_result_matchers_test.py | 2 +-
.../apache_beam/testing/pipeline_verifiers_test.py | 1 +
.../apache_beam/tools/coders_microbenchmark.py | 2 +-
sdks/python/apache_beam/transforms/core.py | 11 +-
.../enrichment_handlers/bigquery_it_test.py | 6 +-
.../enrichment_handlers/bigtable_it_test.py | 1 +
.../enrichment_handlers/cloudsql_it_test.py | 31 +-
.../enrichment_handlers/cloudsql_test.py | 21 +-
.../enrichment_handlers/feast_feature_store.py | 3 +-
.../feast_feature_store_it_test.py | 6 +-
.../feast_feature_store_test.py | 6 +-
.../vertex_ai_feature_store_it_test.py | 6 +-
.../vertex_ai_feature_store_test.py | 7 +-
sdks/python/apache_beam/transforms/ptransform.py | 7 +-
.../apache_beam/transforms/ptransform_test.py | 32 +
sdks/python/apache_beam/transforms/trigger_test.py | 1 +
sdks/python/apache_beam/transforms/userstate.py | 1 +
sdks/python/apache_beam/typehints/__init__.py | 4 +-
sdks/python/apache_beam/typehints/decorators.py | 2 +-
.../typehints/native_type_compatibility.py | 16 +
.../typehints/native_type_compatibility_test.py | 18 +
.../typehints/pytorch_type_compatibility.py | 1 +
.../typehints/pytorch_type_compatibility_test.py | 1 +
sdks/python/apache_beam/utils/interactive_utils.py | 1 +
sdks/python/apache_beam/yaml/integration_tests.py | 2 +-
sdks/python/apache_beam/yaml/yaml_ml.py | 1 +
sdks/python/apache_beam/yaml/yaml_provider.py | 7 +-
sdks/python/expansion-service-container/Dockerfile | 4 +-
sdks/python/gen_managed_doc.py | 3 +-
sdks/python/gen_xlang_wrappers.py | 1 -
sdks/python/mypy.ini | 2 +-
sdks/python/scripts/run_pylint.sh | 5 +-
sdks/python/setup.cfg | 3 -
sdks/python/setup.py | 1 -
sdks/python/test-suites/gradle.properties | 26 +-
sdks/python/test-suites/tox/py310/build.gradle | 206 ++++++
sdks/python/tox.ini | 50 +-
.../en/documentation/runtime/environments.md | 3 +-
319 files changed, 3161 insertions(+), 869 deletions(-)
copy
examples/java/src/main/java/org/apache/beam/examples/cookbook/{BigQueryTornadoes.java
=> BigQueryStreamingTornadoes.java} (72%)
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/Timestamp.java
create mode 100644
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ExpiringMemoizingSerializableSupplier.java
create mode 100644
sdks/java/core/src/test/java/org/apache/beam/sdk/util/ExpiringMemoizingSerializableSupplierTest.java
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryDynamicReadDescriptor.java
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/{BigQueryIOStorageQueryIT.java
=> BigQueryIODynamicQueryIT.java} (77%)
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/{BigQueryIOStorageQueryIT.java
=> BigQueryIODynamicReadIT.java} (63%)
copy
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/{BigQueryIOStorageReadTableRowIT.java
=> BigQueryIODynamicReadTableRowIT.java} (89%)
create mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIODynamicReadTest.java
create mode 100644 sdks/python/.isort.cfg
