MANIFEST.in
gen_protos.py
setup.cfg
setup.py
apache_beam/__init__.py
apache_beam/error.py
apache_beam/pipeline.py
apache_beam/pipeline_test.py
apache_beam/pvalue.py
apache_beam/pvalue_test.py
apache_beam/version.py
apache_beam.egg-info/PKG-INFO
apache_beam.egg-info/SOURCES.txt
apache_beam.egg-info/dependency_links.txt
apache_beam.egg-info/not-zip-safe
apache_beam.egg-info/requires.txt
apache_beam.egg-info/top_level.txt
apache_beam/coders/__init__.py
apache_beam/coders/avro_record.py
apache_beam/coders/coder_impl.pxd
apache_beam/coders/coder_impl.py
apache_beam/coders/coder_impl_row_encoders.pyx
apache_beam/coders/coders.py
apache_beam/coders/coders_property_based_test.py
apache_beam/coders/coders_test.py
apache_beam/coders/coders_test_common.py
apache_beam/coders/fast_coders_test.py
apache_beam/coders/observable.py
apache_beam/coders/observable_test.py
apache_beam/coders/proto2_coder_test_messages_pb2.py
apache_beam/coders/row_coder.py
apache_beam/coders/row_coder_test.py
apache_beam/coders/slow_coders_test.py
apache_beam/coders/slow_stream.py
apache_beam/coders/standard_coders_test.py
apache_beam/coders/stream.pxd
apache_beam/coders/stream.pyx
apache_beam/coders/stream_test.py
apache_beam/coders/typecoders.py
apache_beam/coders/typecoders_test.py
apache_beam/dataframe/__init__.py
apache_beam/dataframe/convert.py
apache_beam/dataframe/convert_test.py
apache_beam/dataframe/doctests.py
apache_beam/dataframe/doctests_test.py
apache_beam/dataframe/expressions.py
apache_beam/dataframe/expressions_test.py
apache_beam/dataframe/frame_base.py
apache_beam/dataframe/frame_base_test.py
apache_beam/dataframe/frames.py
apache_beam/dataframe/frames_test.py
apache_beam/dataframe/io.py
apache_beam/dataframe/io_it_test.py
apache_beam/dataframe/io_test.py
apache_beam/dataframe/pandas_docs_test.py
apache_beam/dataframe/pandas_doctests_test.py
apache_beam/dataframe/pandas_top_level_functions.py
apache_beam/dataframe/partitionings.py
apache_beam/dataframe/partitionings_test.py
apache_beam/dataframe/schemas.py
apache_beam/dataframe/schemas_test.py
apache_beam/dataframe/transforms.py
apache_beam/dataframe/transforms_test.py
apache_beam/examples/__init__.py
apache_beam/examples/avro_nyc_trips.py
apache_beam/examples/avro_nyc_trips_it_test.py
apache_beam/examples/avro_nyc_trips_test.py
apache_beam/examples/california_housing_clustering.py
apache_beam/examples/fastavro_it_test.py
apache_beam/examples/matrix_power.py
apache_beam/examples/matrix_power_test.py
apache_beam/examples/online_clustering.py
apache_beam/examples/per_entity_training.py
apache_beam/examples/sql_taxi.py
apache_beam/examples/streaming_wordcount.py
apache_beam/examples/streaming_wordcount_debugging.py
apache_beam/examples/streaming_wordcount_debugging_it_test.py
apache_beam/examples/streaming_wordcount_debugging_test.py
apache_beam/examples/streaming_wordcount_it_test.py
apache_beam/examples/windowed_wordcount.py
apache_beam/examples/wordcount.py
apache_beam/examples/wordcount_dataframe.py
apache_beam/examples/wordcount_debugging.py
apache_beam/examples/wordcount_debugging_test.py
apache_beam/examples/wordcount_it_test.py
apache_beam/examples/wordcount_minimal.py
apache_beam/examples/wordcount_minimal_test.py
apache_beam/examples/wordcount_test.py
apache_beam/examples/wordcount_with_metrics.py
apache_beam/examples/wordcount_xlang.py
apache_beam/examples/wordcount_xlang_sql.py
apache_beam/examples/complete/__init__.py
apache_beam/examples/complete/autocomplete.py
apache_beam/examples/complete/autocomplete_it_test.py
apache_beam/examples/complete/autocomplete_test.py
apache_beam/examples/complete/distribopt.py
apache_beam/examples/complete/distribopt_test.py
apache_beam/examples/complete/estimate_pi.py
apache_beam/examples/complete/estimate_pi_it_test.py
apache_beam/examples/complete/estimate_pi_test.py
apache_beam/examples/complete/tfidf.py
apache_beam/examples/complete/tfidf_it_test.py
apache_beam/examples/complete/tfidf_test.py
apache_beam/examples/complete/top_wikipedia_sessions.py
apache_beam/examples/complete/top_wikipedia_sessions_it_test.py
apache_beam/examples/complete/top_wikipedia_sessions_test.py
apache_beam/examples/complete/game/__init__.py
apache_beam/examples/complete/game/game_stats.py
apache_beam/examples/complete/game/game_stats_it_test.py
apache_beam/examples/complete/game/game_stats_test.py
apache_beam/examples/complete/game/hourly_team_score.py
apache_beam/examples/complete/game/hourly_team_score_it_test.py
apache_beam/examples/complete/game/hourly_team_score_test.py
apache_beam/examples/complete/game/leader_board.py
apache_beam/examples/complete/game/leader_board_it_test.py
apache_beam/examples/complete/game/leader_board_test.py
apache_beam/examples/complete/game/user_score.py
apache_beam/examples/complete/game/user_score_it_test.py
apache_beam/examples/complete/game/user_score_test.py
apache_beam/examples/complete/juliaset/__init__.py
apache_beam/examples/complete/juliaset/juliaset_main.py
apache_beam/examples/complete/juliaset/setup.py
apache_beam/examples/complete/juliaset/juliaset/__init__.py
apache_beam/examples/complete/juliaset/juliaset/juliaset.py
apache_beam/examples/complete/juliaset/juliaset/juliaset_test.py
apache_beam/examples/complete/juliaset/juliaset/juliaset_test_it.py
apache_beam/examples/cookbook/__init__.py
apache_beam/examples/cookbook/bigquery_schema.py
apache_beam/examples/cookbook/bigquery_side_input.py
apache_beam/examples/cookbook/bigquery_side_input_it_test.py
apache_beam/examples/cookbook/bigquery_side_input_test.py
apache_beam/examples/cookbook/bigquery_tornadoes.py
apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py
apache_beam/examples/cookbook/bigquery_tornadoes_test.py
apache_beam/examples/cookbook/bigtableio_it_test.py
apache_beam/examples/cookbook/coders.py
apache_beam/examples/cookbook/coders_it_test.py
apache_beam/examples/cookbook/coders_test.py
apache_beam/examples/cookbook/combiners_test.py
apache_beam/examples/cookbook/custom_ptransform.py
apache_beam/examples/cookbook/custom_ptransform_it_test.py
apache_beam/examples/cookbook/custom_ptransform_test.py
apache_beam/examples/cookbook/datastore_wordcount.py
apache_beam/examples/cookbook/datastore_wordcount_it_test.py
apache_beam/examples/cookbook/filters.py
apache_beam/examples/cookbook/filters_test.py
apache_beam/examples/cookbook/group_with_coder.py
apache_beam/examples/cookbook/group_with_coder_test.py
apache_beam/examples/cookbook/mergecontacts.py
apache_beam/examples/cookbook/mergecontacts_test.py
apache_beam/examples/cookbook/multiple_output_pardo.py
apache_beam/examples/cookbook/multiple_output_pardo_test.py
apache_beam/examples/dataframe/__init__.py
apache_beam/examples/dataframe/flight_delays.py
apache_beam/examples/dataframe/flight_delays_it_test.py
apache_beam/examples/dataframe/taxiride.py
apache_beam/examples/dataframe/taxiride_it_test.py
apache_beam/examples/dataframe/taxiride_test.py
apache_beam/examples/dataframe/wordcount.py
apache_beam/examples/dataframe/wordcount_test.py
apache_beam/examples/flink/__init__.py
apache_beam/examples/flink/flink_streaming_impulse.py
apache_beam/examples/inference/__init__.py
apache_beam/examples/inference/huggingface_language_modeling.py
apache_beam/examples/inference/huggingface_question_answering.py
apache_beam/examples/inference/milk_quality_prediction_windowing.py
apache_beam/examples/inference/onnx_sentiment_classification.py
apache_beam/examples/inference/pytorch_image_classification.py
apache_beam/examples/inference/pytorch_image_classification_with_side_inputs.py
apache_beam/examples/inference/pytorch_image_segmentation.py
apache_beam/examples/inference/pytorch_language_modeling.py
apache_beam/examples/inference/pytorch_model_per_key_image_segmentation.py
apache_beam/examples/inference/run_inference_side_inputs.py
apache_beam/examples/inference/sklearn_japanese_housing_regression.py
apache_beam/examples/inference/sklearn_mnist_classification.py
apache_beam/examples/inference/tensorflow_imagenet_segmentation.py
apache_beam/examples/inference/tensorflow_mnist_classification.py
apache_beam/examples/inference/tensorflow_mnist_with_weights.py
apache_beam/examples/inference/tensorrt_object_detection.py
apache_beam/examples/inference/tensorrt_text_classification.py
apache_beam/examples/inference/vertex_ai_image_classification.py
apache_beam/examples/inference/vertex_ai_llm_text_classification.py
apache_beam/examples/inference/xgboost_iris_classification.py
apache_beam/examples/inference/runinference_metrics/__init__.py
apache_beam/examples/inference/runinference_metrics/config.py
apache_beam/examples/inference/runinference_metrics/main.py
apache_beam/examples/inference/runinference_metrics/setup.py
apache_beam/examples/inference/runinference_metrics/pipeline/__init__.py
apache_beam/examples/inference/runinference_metrics/pipeline/options.py
apache_beam/examples/inference/runinference_metrics/pipeline/transformations.py
apache_beam/examples/inference/tfx_bsl/__init__.py
apache_beam/examples/inference/tfx_bsl/build_tensorflow_model.py
apache_beam/examples/inference/tfx_bsl/tensorflow_image_classification.py
apache_beam/examples/inference/tfx_bsl/tfx_bsl_inference_it_test.py
apache_beam/examples/kafkataxi/__init__.py
apache_beam/examples/kafkataxi/kafka_taxi.py
apache_beam/examples/ml_transform/__init__.py
apache_beam/examples/ml_transform/ml_transform_basic.py
apache_beam/examples/ml_transform/ml_transform_it_test.py
apache_beam/examples/ml_transform/vocab_tfidf_processing.py
apache_beam/examples/snippets/__init__.py
apache_beam/examples/snippets/snippets.py
apache_beam/examples/snippets/snippets_examples_wordcount_debugging.py
apache_beam/examples/snippets/snippets_examples_wordcount_minimal.py
apache_beam/examples/snippets/snippets_examples_wordcount_wordcount.py
apache_beam/examples/snippets/snippets_test.py
apache_beam/examples/snippets/util.py
apache_beam/examples/snippets/util_test.py
apache_beam/examples/snippets/transforms/__init__.py
apache_beam/examples/snippets/transforms/aggregation/__init__.py
apache_beam/examples/snippets/transforms/aggregation/cogroupbykey.py
apache_beam/examples/snippets/transforms/aggregation/cogroupbykey_test.py
apache_beam/examples/snippets/transforms/aggregation/combineglobally_combinefn.py
apache_beam/examples/snippets/transforms/aggregation/combineglobally_function.py
apache_beam/examples/snippets/transforms/aggregation/combineglobally_lambda.py
apache_beam/examples/snippets/transforms/aggregation/combineglobally_multiple_arguments.py
apache_beam/examples/snippets/transforms/aggregation/combineglobally_side_inputs_dict.py
apache_beam/examples/snippets/transforms/aggregation/combineglobally_side_inputs_iter.py
apache_beam/examples/snippets/transforms/aggregation/combineglobally_side_inputs_singleton.py
apache_beam/examples/snippets/transforms/aggregation/combineglobally_test.py
apache_beam/examples/snippets/transforms/aggregation/combineperkey_combinefn.py
apache_beam/examples/snippets/transforms/aggregation/combineperkey_function.py
apache_beam/examples/snippets/transforms/aggregation/combineperkey_lambda.py
apache_beam/examples/snippets/transforms/aggregation/combineperkey_multiple_arguments.py
apache_beam/examples/snippets/transforms/aggregation/combineperkey_side_inputs_dict.py
apache_beam/examples/snippets/transforms/aggregation/combineperkey_side_inputs_iter.py
apache_beam/examples/snippets/transforms/aggregation/combineperkey_side_inputs_singleton.py
apache_beam/examples/snippets/transforms/aggregation/combineperkey_simple.py
apache_beam/examples/snippets/transforms/aggregation/combineperkey_test.py
apache_beam/examples/snippets/transforms/aggregation/combinevalues_combinefn.py
apache_beam/examples/snippets/transforms/aggregation/combinevalues_function.py
apache_beam/examples/snippets/transforms/aggregation/combinevalues_lambda.py
apache_beam/examples/snippets/transforms/aggregation/combinevalues_multiple_arguments.py
apache_beam/examples/snippets/transforms/aggregation/combinevalues_side_inputs_dict.py
apache_beam/examples/snippets/transforms/aggregation/combinevalues_side_inputs_iter.py
apache_beam/examples/snippets/transforms/aggregation/combinevalues_side_inputs_singleton.py
apache_beam/examples/snippets/transforms/aggregation/combinevalues_simple.py
apache_beam/examples/snippets/transforms/aggregation/combinevalues_test.py
apache_beam/examples/snippets/transforms/aggregation/count_globally.py
apache_beam/examples/snippets/transforms/aggregation/count_per_element.py
apache_beam/examples/snippets/transforms/aggregation/count_per_key.py
apache_beam/examples/snippets/transforms/aggregation/count_test.py
apache_beam/examples/snippets/transforms/aggregation/distinct.py
apache_beam/examples/snippets/transforms/aggregation/distinct_test.py
apache_beam/examples/snippets/transforms/aggregation/groupby_attr.py
apache_beam/examples/snippets/transforms/aggregation/groupby_attr_expr.py
apache_beam/examples/snippets/transforms/aggregation/groupby_expr.py
apache_beam/examples/snippets/transforms/aggregation/groupby_expr_aggregate.py
apache_beam/examples/snippets/transforms/aggregation/groupby_global_aggregate.py
apache_beam/examples/snippets/transforms/aggregation/groupby_simple_aggregate.py
apache_beam/examples/snippets/transforms/aggregation/groupby_test.py
apache_beam/examples/snippets/transforms/aggregation/groupby_two_exprs.py
apache_beam/examples/snippets/transforms/aggregation/groupbykey.py
apache_beam/examples/snippets/transforms/aggregation/groupbykey_test.py
apache_beam/examples/snippets/transforms/aggregation/groupintobatches.py
apache_beam/examples/snippets/transforms/aggregation/groupintobatches_test.py
apache_beam/examples/snippets/transforms/aggregation/latest_globally.py
apache_beam/examples/snippets/transforms/aggregation/latest_per_key.py
apache_beam/examples/snippets/transforms/aggregation/latest_test.py
apache_beam/examples/snippets/transforms/aggregation/max_globally.py
apache_beam/examples/snippets/transforms/aggregation/max_per_key.py
apache_beam/examples/snippets/transforms/aggregation/max_test.py
apache_beam/examples/snippets/transforms/aggregation/mean_globally.py
apache_beam/examples/snippets/transforms/aggregation/mean_per_key.py
apache_beam/examples/snippets/transforms/aggregation/mean_test.py
apache_beam/examples/snippets/transforms/aggregation/min_globally.py
apache_beam/examples/snippets/transforms/aggregation/min_per_key.py
apache_beam/examples/snippets/transforms/aggregation/min_test.py
apache_beam/examples/snippets/transforms/aggregation/sample_fixed_size_globally.py
apache_beam/examples/snippets/transforms/aggregation/sample_fixed_size_per_key.py
apache_beam/examples/snippets/transforms/aggregation/sample_test.py
apache_beam/examples/snippets/transforms/aggregation/sum_globally.py
apache_beam/examples/snippets/transforms/aggregation/sum_per_key.py
apache_beam/examples/snippets/transforms/aggregation/sum_test.py
apache_beam/examples/snippets/transforms/aggregation/top_largest.py
apache_beam/examples/snippets/transforms/aggregation/top_largest_per_key.py
apache_beam/examples/snippets/transforms/aggregation/top_of.py
apache_beam/examples/snippets/transforms/aggregation/top_per_key.py
apache_beam/examples/snippets/transforms/aggregation/top_smallest.py
apache_beam/examples/snippets/transforms/aggregation/top_smallest_per_key.py
apache_beam/examples/snippets/transforms/aggregation/top_test.py
apache_beam/examples/snippets/transforms/elementwise/__init__.py
apache_beam/examples/snippets/transforms/elementwise/filter_function.py
apache_beam/examples/snippets/transforms/elementwise/filter_lambda.py
apache_beam/examples/snippets/transforms/elementwise/filter_multiple_arguments.py
apache_beam/examples/snippets/transforms/elementwise/filter_side_inputs_dict.py
apache_beam/examples/snippets/transforms/elementwise/filter_side_inputs_iter.py
apache_beam/examples/snippets/transforms/elementwise/filter_side_inputs_singleton.py
apache_beam/examples/snippets/transforms/elementwise/filter_test.py
apache_beam/examples/snippets/transforms/elementwise/flatmap_function.py
apache_beam/examples/snippets/transforms/elementwise/flatmap_generator.py
apache_beam/examples/snippets/transforms/elementwise/flatmap_lambda.py
apache_beam/examples/snippets/transforms/elementwise/flatmap_multiple_arguments.py
apache_beam/examples/snippets/transforms/elementwise/flatmap_side_inputs_dict.py
apache_beam/examples/snippets/transforms/elementwise/flatmap_side_inputs_iter.py
apache_beam/examples/snippets/transforms/elementwise/flatmap_side_inputs_singleton.py
apache_beam/examples/snippets/transforms/elementwise/flatmap_simple.py
apache_beam/examples/snippets/transforms/elementwise/flatmap_test.py
apache_beam/examples/snippets/transforms/elementwise/flatmap_tuple.py
apache_beam/examples/snippets/transforms/elementwise/keys.py
apache_beam/examples/snippets/transforms/elementwise/keys_test.py
apache_beam/examples/snippets/transforms/elementwise/kvswap.py
apache_beam/examples/snippets/transforms/elementwise/kvswap_test.py
apache_beam/examples/snippets/transforms/elementwise/map_function.py
apache_beam/examples/snippets/transforms/elementwise/map_lambda.py
apache_beam/examples/snippets/transforms/elementwise/map_multiple_arguments.py
apache_beam/examples/snippets/transforms/elementwise/map_side_inputs_dict.py
apache_beam/examples/snippets/transforms/elementwise/map_side_inputs_iter.py
apache_beam/examples/snippets/transforms/elementwise/map_side_inputs_singleton.py
apache_beam/examples/snippets/transforms/elementwise/map_simple.py
apache_beam/examples/snippets/transforms/elementwise/map_test.py
apache_beam/examples/snippets/transforms/elementwise/map_tuple.py
apache_beam/examples/snippets/transforms/elementwise/mltransform.py
apache_beam/examples/snippets/transforms/elementwise/mltransform_test.py
apache_beam/examples/snippets/transforms/elementwise/pardo_dofn.py
apache_beam/examples/snippets/transforms/elementwise/pardo_dofn_methods.py
apache_beam/examples/snippets/transforms/elementwise/pardo_dofn_params.py
apache_beam/examples/snippets/transforms/elementwise/pardo_test.py
apache_beam/examples/snippets/transforms/elementwise/partition_function.py
apache_beam/examples/snippets/transforms/elementwise/partition_lambda.py
apache_beam/examples/snippets/transforms/elementwise/partition_multiple_arguments.py
apache_beam/examples/snippets/transforms/elementwise/partition_test.py
apache_beam/examples/snippets/transforms/elementwise/regex_all_matches.py
apache_beam/examples/snippets/transforms/elementwise/regex_find.py
apache_beam/examples/snippets/transforms/elementwise/regex_find_all.py
apache_beam/examples/snippets/transforms/elementwise/regex_find_kv.py
apache_beam/examples/snippets/transforms/elementwise/regex_matches.py
apache_beam/examples/snippets/transforms/elementwise/regex_matches_kv.py
apache_beam/examples/snippets/transforms/elementwise/regex_replace_all.py
apache_beam/examples/snippets/transforms/elementwise/regex_replace_first.py
apache_beam/examples/snippets/transforms/elementwise/regex_split.py
apache_beam/examples/snippets/transforms/elementwise/regex_test.py
apache_beam/examples/snippets/transforms/elementwise/runinference.py
apache_beam/examples/snippets/transforms/elementwise/runinference_sklearn_keyed_model_handler.py
apache_beam/examples/snippets/transforms/elementwise/runinference_sklearn_unkeyed_model_handler.py
apache_beam/examples/snippets/transforms/elementwise/runinference_test.py
apache_beam/examples/snippets/transforms/elementwise/tostring_element.py
apache_beam/examples/snippets/transforms/elementwise/tostring_iterables.py
apache_beam/examples/snippets/transforms/elementwise/tostring_kvs.py
apache_beam/examples/snippets/transforms/elementwise/tostring_test.py
apache_beam/examples/snippets/transforms/elementwise/values.py
apache_beam/examples/snippets/transforms/elementwise/values_test.py
apache_beam/examples/snippets/transforms/elementwise/withtimestamps.py
apache_beam/examples/snippets/transforms/elementwise/withtimestamps_event_time.py
apache_beam/examples/snippets/transforms/elementwise/withtimestamps_logical_clock.py
apache_beam/examples/snippets/transforms/elementwise/withtimestamps_processing_time.py
apache_beam/examples/snippets/transforms/elementwise/withtimestamps_test.py
apache_beam/examples/snippets/transforms/other/__init__.py
apache_beam/examples/snippets/transforms/other/create.py
apache_beam/examples/snippets/transforms/other/create_test.py
apache_beam/examples/snippets/transforms/other/flatten.py
apache_beam/examples/snippets/transforms/other/flatten_test.py
apache_beam/examples/snippets/transforms/other/window.py
apache_beam/examples/snippets/transforms/other/window_test.py
apache_beam/internal/__init__.py
apache_beam/internal/cloudpickle_pickler.py
apache_beam/internal/cloudpickle_pickler_test.py
apache_beam/internal/dill_pickler.py
apache_beam/internal/http_client.py
apache_beam/internal/http_client_test.py
apache_beam/internal/module_test.py
apache_beam/internal/pickler.py
apache_beam/internal/pickler_test.py
apache_beam/internal/util.py
apache_beam/internal/util_test.py
apache_beam/internal/azure/__init__.py
apache_beam/internal/azure/auth.py
apache_beam/internal/gcp/__init__.py
apache_beam/internal/gcp/auth.py
apache_beam/internal/gcp/json_value.py
apache_beam/internal/gcp/json_value_test.py
apache_beam/internal/metrics/__init__.py
apache_beam/internal/metrics/cells.py
apache_beam/internal/metrics/cells_test.py
apache_beam/internal/metrics/metric.py
apache_beam/internal/metrics/metric_test.py
apache_beam/io/__init__.py
apache_beam/io/avroio.py
apache_beam/io/avroio_test.py
apache_beam/io/concat_source.py
apache_beam/io/concat_source_test.py
apache_beam/io/debezium.py
apache_beam/io/filebasedio_perf_test.py
apache_beam/io/filebasedsink.py
apache_beam/io/filebasedsink_test.py
apache_beam/io/filebasedsource.py
apache_beam/io/filebasedsource_test.py
apache_beam/io/fileio.py
apache_beam/io/fileio_test.py
apache_beam/io/filesystem.py
apache_beam/io/filesystem_test.py
apache_beam/io/filesystemio.py
apache_beam/io/filesystemio_test.py
apache_beam/io/filesystems.py
apache_beam/io/filesystems_test.py
apache_beam/io/hadoopfilesystem.py
apache_beam/io/hadoopfilesystem_test.py
apache_beam/io/iobase.py
apache_beam/io/iobase_test.py
apache_beam/io/jdbc.py
apache_beam/io/kafka.py
apache_beam/io/kinesis.py
apache_beam/io/localfilesystem.py
apache_beam/io/localfilesystem_test.py
apache_beam/io/mongodbio.py
apache_beam/io/mongodbio_it_test.py
apache_beam/io/mongodbio_test.py
apache_beam/io/parquetio.py
apache_beam/io/parquetio_it_test.py
apache_beam/io/parquetio_test.py
apache_beam/io/range_trackers.py
apache_beam/io/range_trackers_test.py
apache_beam/io/restriction_trackers.py
apache_beam/io/restriction_trackers_test.py
apache_beam/io/snowflake.py
apache_beam/io/source_test_utils.py
apache_beam/io/source_test_utils_test.py
apache_beam/io/sources_test.py
apache_beam/io/textio.py
apache_beam/io/textio_test.py
apache_beam/io/tfrecordio.py
apache_beam/io/tfrecordio_test.py
apache_beam/io/utils.py
apache_beam/io/utils_test.py
apache_beam/io/watermark_estimators.py
apache_beam/io/watermark_estimators_test.py
apache_beam/io/aws/__init__.py
apache_beam/io/aws/s3filesystem.py
apache_beam/io/aws/s3filesystem_test.py
apache_beam/io/aws/s3io.py
apache_beam/io/aws/s3io_test.py
apache_beam/io/aws/clients/__init__.py
apache_beam/io/aws/clients/s3/__init__.py
apache_beam/io/aws/clients/s3/boto3_client.py
apache_beam/io/aws/clients/s3/client_test.py
apache_beam/io/aws/clients/s3/fake_client.py
apache_beam/io/aws/clients/s3/messages.py
apache_beam/io/azure/__init__.py
apache_beam/io/azure/blobstoragefilesystem.py
apache_beam/io/azure/blobstoragefilesystem_test.py
apache_beam/io/azure/blobstorageio.py
apache_beam/io/azure/blobstorageio_test.py
apache_beam/io/components/__init__.py
apache_beam/io/components/adaptive_throttler.py
apache_beam/io/components/adaptive_throttler_test.py
apache_beam/io/components/util.py
apache_beam/io/external/__init__.py
apache_beam/io/external/generate_sequence.py
apache_beam/io/external/generate_sequence_test.py
apache_beam/io/external/kafka.py
apache_beam/io/external/snowflake.py
apache_beam/io/external/xlang_bigqueryio_it_test.py
apache_beam/io/external/xlang_debeziumio_it_test.py
apache_beam/io/external/xlang_jdbcio_it_test.py
apache_beam/io/external/xlang_kafkaio_it_test.py
apache_beam/io/external/xlang_kafkaio_perf_test.py
apache_beam/io/external/xlang_kinesisio_it_test.py
apache_beam/io/external/xlang_parquetio_test.py
apache_beam/io/external/xlang_snowflakeio_it_test.py
apache_beam/io/external/gcp/__init__.py
apache_beam/io/external/gcp/pubsub.py
apache_beam/io/flink/__init__.py
apache_beam/io/flink/flink_streaming_impulse_source.py
apache_beam/io/flink/flink_streaming_impulse_source_test.py
apache_beam/io/gcp/__init__.py
apache_beam/io/gcp/big_query_query_to_table_it_test.py
apache_beam/io/gcp/big_query_query_to_table_pipeline.py
apache_beam/io/gcp/bigquery.py
apache_beam/io/gcp/bigquery_avro_tools.py
apache_beam/io/gcp/bigquery_avro_tools_test.py
apache_beam/io/gcp/bigquery_file_loads.py
apache_beam/io/gcp/bigquery_file_loads_test.py
apache_beam/io/gcp/bigquery_io_metadata.py
apache_beam/io/gcp/bigquery_io_metadata_test.py
apache_beam/io/gcp/bigquery_io_read_it_test.py
apache_beam/io/gcp/bigquery_io_read_pipeline.py
apache_beam/io/gcp/bigquery_json_it_test.py
apache_beam/io/gcp/bigquery_read_internal.py
apache_beam/io/gcp/bigquery_read_it_test.py
apache_beam/io/gcp/bigquery_read_perf_test.py
apache_beam/io/gcp/bigquery_schema_tools.py
apache_beam/io/gcp/bigquery_schema_tools_test.py
apache_beam/io/gcp/bigquery_test.py
apache_beam/io/gcp/bigquery_tools.py
apache_beam/io/gcp/bigquery_tools_test.py
apache_beam/io/gcp/bigquery_write_it_test.py
apache_beam/io/gcp/bigquery_write_perf_test.py
apache_beam/io/gcp/bigtableio.py
apache_beam/io/gcp/bigtableio_it_test.py
apache_beam/io/gcp/bigtableio_test.py
apache_beam/io/gcp/dicomclient.py
apache_beam/io/gcp/dicomio.py
apache_beam/io/gcp/gce_metadata_util.py
apache_beam/io/gcp/gcsfilesystem.py
apache_beam/io/gcp/gcsfilesystem_integration_test.py
apache_beam/io/gcp/gcsfilesystem_test.py
apache_beam/io/gcp/gcsio.py
apache_beam/io/gcp/gcsio_integration_test.py
apache_beam/io/gcp/gcsio_overrides.py
apache_beam/io/gcp/gcsio_test.py
apache_beam/io/gcp/pubsub.py
apache_beam/io/gcp/pubsub_integration_test.py
apache_beam/io/gcp/pubsub_io_perf_test.py
apache_beam/io/gcp/pubsub_it_pipeline.py
apache_beam/io/gcp/pubsub_test.py
apache_beam/io/gcp/resource_identifiers.py
apache_beam/io/gcp/spanner.py
apache_beam/io/gcp/datastore/__init__.py
apache_beam/io/gcp/datastore/v1new/__init__.py
apache_beam/io/gcp/datastore/v1new/datastore_write_it_pipeline.py
apache_beam/io/gcp/datastore/v1new/datastore_write_it_test.py
apache_beam/io/gcp/datastore/v1new/datastoreio.py
apache_beam/io/gcp/datastore/v1new/datastoreio_test.py
apache_beam/io/gcp/datastore/v1new/helper.py
apache_beam/io/gcp/datastore/v1new/query_splitter.py
apache_beam/io/gcp/datastore/v1new/query_splitter_test.py
apache_beam/io/gcp/datastore/v1new/rampup_throttling_fn.py
apache_beam/io/gcp/datastore/v1new/rampup_throttling_fn_test.py
apache_beam/io/gcp/datastore/v1new/types.py
apache_beam/io/gcp/datastore/v1new/types_test.py
apache_beam/io/gcp/datastore/v1new/util.py
apache_beam/io/gcp/datastore/v1new/util_test.py
apache_beam/io/gcp/experimental/__init__.py
apache_beam/io/gcp/experimental/spannerio.py
apache_beam/io/gcp/experimental/spannerio_read_it_test.py
apache_beam/io/gcp/experimental/spannerio_read_perf_test.py
apache_beam/io/gcp/experimental/spannerio_test.py
apache_beam/io/gcp/experimental/spannerio_write_it_test.py
apache_beam/io/gcp/experimental/spannerio_write_perf_test.py
apache_beam/io/gcp/healthcare/__init__.py
apache_beam/io/gcp/healthcare/dicomclient.py
apache_beam/io/gcp/healthcare/dicomio.py
apache_beam/io/gcp/healthcare/dicomio_integration_test.py
apache_beam/io/gcp/healthcare/dicomio_test.py
apache_beam/io/gcp/internal/__init__.py
apache_beam/io/gcp/internal/clients/__init__.py
apache_beam/io/gcp/internal/clients/bigquery/__init__.py
apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py
apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_messages.py
apache_beam/io/gcp/internal/clients/storage/__init__.py
apache_beam/io/gcp/internal/clients/storage/storage_v1_client.py
apache_beam/io/gcp/internal/clients/storage/storage_v1_messages.py
apache_beam/io/gcp/pubsublite/__init__.py
apache_beam/io/gcp/pubsublite/external.py
apache_beam/io/gcp/pubsublite/proto_api.py
apache_beam/io/gcp/tests/__init__.py
apache_beam/io/gcp/tests/bigquery_matcher.py
apache_beam/io/gcp/tests/bigquery_matcher_test.py
apache_beam/io/gcp/tests/pubsub_matcher.py
apache_beam/io/gcp/tests/pubsub_matcher_test.py
apache_beam/io/gcp/tests/utils.py
apache_beam/io/gcp/tests/utils_test.py
apache_beam/io/gcp/tests/xlang_spannerio_it_test.py
apache_beam/metrics/__init__.py
apache_beam/metrics/cells.pxd
apache_beam/metrics/cells.py
apache_beam/metrics/cells_test.py
apache_beam/metrics/execution.pxd
apache_beam/metrics/execution.py
apache_beam/metrics/execution_test.py
apache_beam/metrics/metric.py
apache_beam/metrics/metric_test.py
apache_beam/metrics/metricbase.py
apache_beam/metrics/monitoring_infos.py
apache_beam/metrics/monitoring_infos_test.py
apache_beam/ml/__init__.py
apache_beam/ml/gcp/__init__.py
apache_beam/ml/gcp/cloud_dlp.py
apache_beam/ml/gcp/cloud_dlp_it_test.py
apache_beam/ml/gcp/cloud_dlp_test.py
apache_beam/ml/gcp/naturallanguageml.py
apache_beam/ml/gcp/naturallanguageml_test.py
apache_beam/ml/gcp/naturallanguageml_test_it.py
apache_beam/ml/gcp/recommendations_ai.py
apache_beam/ml/gcp/recommendations_ai_test.py
apache_beam/ml/gcp/recommendations_ai_test_it.py
apache_beam/ml/gcp/videointelligenceml.py
apache_beam/ml/gcp/videointelligenceml_test.py
apache_beam/ml/gcp/videointelligenceml_test_it.py
apache_beam/ml/gcp/visionml.py
apache_beam/ml/gcp/visionml_test.py
apache_beam/ml/gcp/visionml_test_it.py
apache_beam/ml/inference/__init__.py
apache_beam/ml/inference/base.py
apache_beam/ml/inference/base_test.py
apache_beam/ml/inference/huggingface_inference.py
apache_beam/ml/inference/huggingface_inference_it_test.py
apache_beam/ml/inference/huggingface_inference_test.py
apache_beam/ml/inference/onnx_inference.py
apache_beam/ml/inference/onnx_inference_it_test.py
apache_beam/ml/inference/onnx_inference_test.py
apache_beam/ml/inference/pytorch_inference.py
apache_beam/ml/inference/pytorch_inference_it_test.py
apache_beam/ml/inference/pytorch_inference_test.py
apache_beam/ml/inference/sklearn_inference.py
apache_beam/ml/inference/sklearn_inference_it_test.py
apache_beam/ml/inference/sklearn_inference_test.py
apache_beam/ml/inference/tensorflow_inference.py
apache_beam/ml/inference/tensorflow_inference_it_test.py
apache_beam/ml/inference/tensorflow_inference_test.py
apache_beam/ml/inference/tensorrt_inference.py
apache_beam/ml/inference/tensorrt_inference_test.py
apache_beam/ml/inference/utils.py
apache_beam/ml/inference/utils_test.py
apache_beam/ml/inference/vertex_ai_inference.py
apache_beam/ml/inference/vertex_ai_inference_it_test.py
apache_beam/ml/inference/vertex_ai_inference_test.py
apache_beam/ml/inference/xgboost_inference.py
apache_beam/ml/inference/xgboost_inference_it_test.py
apache_beam/ml/inference/xgboost_inference_test.py
apache_beam/ml/transforms/__init__.py
apache_beam/ml/transforms/base.py
apache_beam/ml/transforms/base_test.py
apache_beam/ml/transforms/handlers.py
apache_beam/ml/transforms/handlers_test.py
apache_beam/ml/transforms/tft.py
apache_beam/ml/transforms/tft_test.py
apache_beam/ml/transforms/utils.py
apache_beam/options/__init__.py
apache_beam/options/pipeline_options.py
apache_beam/options/pipeline_options_test.py
apache_beam/options/pipeline_options_validator.py
apache_beam/options/pipeline_options_validator_test.py
apache_beam/options/value_provider.py
apache_beam/options/value_provider_test.py
apache_beam/portability/__init__.py
apache_beam/portability/common_urns.py
apache_beam/portability/python_urns.py
apache_beam/portability/utils.py
apache_beam/portability/api/__init__.py
apache_beam/portability/api/standard_coders.yaml
apache_beam/portability/api/org/__init__.py
apache_beam/portability/api/org/apache/__init__.py
apache_beam/portability/api/org/apache/beam/__init__.py
apache_beam/portability/api/org/apache/beam/model/__init__.py
apache_beam/portability/api/org/apache/beam/model/fn_execution/__init__.py
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/__init__.py
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_fn_api_pb2.py
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_fn_api_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_fn_api_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_fn_api_pb2_urns.py
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_provision_api_pb2.py
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_provision_api_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/fn_execution/v1/beam_provision_api_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/interactive/__init__.py
apache_beam/portability/api/org/apache/beam/model/interactive/v1/__init__.py
apache_beam/portability/api/org/apache/beam/model/interactive/v1/beam_interactive_api_pb2.py
apache_beam/portability/api/org/apache/beam/model/interactive/v1/beam_interactive_api_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/interactive/v1/beam_interactive_api_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/job_management/__init__.py
apache_beam/portability/api/org/apache/beam/model/job_management/v1/__init__.py
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_artifact_api_pb2.py
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_artifact_api_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_artifact_api_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_artifact_api_pb2_urns.py
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_expansion_api_pb2.py
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_expansion_api_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_expansion_api_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_job_api_pb2.py
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_job_api_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/job_management/v1/beam_job_api_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/pipeline/__init__.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/__init__.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/beam_runner_api_pb2.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/beam_runner_api_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/beam_runner_api_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/beam_runner_api_pb2_urns.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/endpoints_pb2.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/endpoints_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/endpoints_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/external_transforms_pb2.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/external_transforms_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/external_transforms_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/external_transforms_pb2_urns.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/metrics_pb2.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/metrics_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/metrics_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/metrics_pb2_urns.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/schema_pb2.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/schema_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/schema_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/schema_pb2_urns.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/standard_window_fns_pb2.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/standard_window_fns_pb2.pyi
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/standard_window_fns_pb2_grpc.py
apache_beam/portability/api/org/apache/beam/model/pipeline/v1/standard_window_fns_pb2_urns.py
apache_beam/runners/__init__.py
apache_beam/runners/common.pxd
apache_beam/runners/common.py
apache_beam/runners/common_test.py
apache_beam/runners/pipeline_context.py
apache_beam/runners/pipeline_context_test.py
apache_beam/runners/render.py
apache_beam/runners/render_test.py
apache_beam/runners/runner.py
apache_beam/runners/runner_test.py
apache_beam/runners/sdf_utils.py
apache_beam/runners/sdf_utils_test.py
apache_beam/runners/trivial_runner.py
apache_beam/runners/trivial_runner_test.py
apache_beam/runners/dask/__init__.py
apache_beam/runners/dask/dask_runner.py
apache_beam/runners/dask/dask_runner_test.py
apache_beam/runners/dask/overrides.py
apache_beam/runners/dask/transform_evaluator.py
apache_beam/runners/dataflow/__init__.py
apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline.py
apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline_test.py
apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline.py
apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py
apache_beam/runners/dataflow/dataflow_job_service.py
apache_beam/runners/dataflow/dataflow_job_service_test.py
apache_beam/runners/dataflow/dataflow_metrics.py
apache_beam/runners/dataflow/dataflow_metrics_test.py
apache_beam/runners/dataflow/dataflow_runner.py
apache_beam/runners/dataflow/dataflow_runner_test.py
apache_beam/runners/dataflow/ptransform_overrides.py
apache_beam/runners/dataflow/template_runner_test.py
apache_beam/runners/dataflow/test_dataflow_runner.py
apache_beam/runners/dataflow/internal/__init__.py
apache_beam/runners/dataflow/internal/apiclient.py
apache_beam/runners/dataflow/internal/apiclient_test.py
apache_beam/runners/dataflow/internal/names.py
apache_beam/runners/dataflow/internal/clients/__init__.py
apache_beam/runners/dataflow/internal/clients/cloudbuild/__init__.py
apache_beam/runners/dataflow/internal/clients/cloudbuild/cloudbuild_v1_client.py
apache_beam/runners/dataflow/internal/clients/cloudbuild/cloudbuild_v1_messages.py
apache_beam/runners/dataflow/internal/clients/dataflow/__init__.py
apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py
apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py
apache_beam/runners/dataflow/internal/clients/dataflow/message_matchers.py
apache_beam/runners/dataflow/internal/clients/dataflow/message_matchers_test.py
apache_beam/runners/direct/__init__.py
apache_beam/runners/direct/bundle_factory.py
apache_beam/runners/direct/clock.py
apache_beam/runners/direct/consumer_tracking_pipeline_visitor.py
apache_beam/runners/direct/consumer_tracking_pipeline_visitor_test.py
apache_beam/runners/direct/direct_metrics.py
apache_beam/runners/direct/direct_metrics_test.py
apache_beam/runners/direct/direct_runner.py
apache_beam/runners/direct/direct_runner_test.py
apache_beam/runners/direct/direct_userstate.py
apache_beam/runners/direct/evaluation_context.py
apache_beam/runners/direct/executor.py
apache_beam/runners/direct/helper_transforms.py
apache_beam/runners/direct/sdf_direct_runner.py
apache_beam/runners/direct/sdf_direct_runner_test.py
apache_beam/runners/direct/test_direct_runner.py
apache_beam/runners/direct/test_stream_impl.py
apache_beam/runners/direct/transform_evaluator.py
apache_beam/runners/direct/util.py
apache_beam/runners/direct/watermark_manager.py
apache_beam/runners/interactive/__init__.py
apache_beam/runners/interactive/augmented_pipeline.py
apache_beam/runners/interactive/augmented_pipeline_test.py
apache_beam/runners/interactive/background_caching_job.py
apache_beam/runners/interactive/background_caching_job_test.py
apache_beam/runners/interactive/cache_manager.py
apache_beam/runners/interactive/cache_manager_test.py
apache_beam/runners/interactive/interactive_beam.py
apache_beam/runners/interactive/interactive_beam_test.py
apache_beam/runners/interactive/interactive_environment.py
apache_beam/runners/interactive/interactive_environment_test.py
apache_beam/runners/interactive/interactive_runner.py
apache_beam/runners/interactive/interactive_runner_test.py
apache_beam/runners/interactive/pipeline_fragment.py
apache_beam/runners/interactive/pipeline_fragment_test.py
apache_beam/runners/interactive/pipeline_instrument.py
apache_beam/runners/interactive/pipeline_instrument_test.py
apache_beam/runners/interactive/recording_manager.py
apache_beam/runners/interactive/recording_manager_test.py
apache_beam/runners/interactive/user_pipeline_tracker.py
apache_beam/runners/interactive/user_pipeline_tracker_test.py
apache_beam/runners/interactive/utils.py
apache_beam/runners/interactive/utils_test.py
apache_beam/runners/interactive/caching/__init__.py
apache_beam/runners/interactive/caching/cacheable.py
apache_beam/runners/interactive/caching/expression_cache.py
apache_beam/runners/interactive/caching/expression_cache_test.py
apache_beam/runners/interactive/caching/read_cache.py
apache_beam/runners/interactive/caching/read_cache_test.py
apache_beam/runners/interactive/caching/reify.py
apache_beam/runners/interactive/caching/streaming_cache.py
apache_beam/runners/interactive/caching/streaming_cache_test.py
apache_beam/runners/interactive/caching/write_cache.py
apache_beam/runners/interactive/caching/write_cache_test.py
apache_beam/runners/interactive/dataproc/__init__.py
apache_beam/runners/interactive/dataproc/dataproc_cluster_manager.py
apache_beam/runners/interactive/dataproc/dataproc_cluster_manager_test.py
apache_beam/runners/interactive/dataproc/types.py
apache_beam/runners/interactive/display/__init__.py
apache_beam/runners/interactive/display/display_manager.py
apache_beam/runners/interactive/display/interactive_pipeline_graph.py
apache_beam/runners/interactive/display/pcoll_visualization.py
apache_beam/runners/interactive/display/pcoll_visualization_test.py
apache_beam/runners/interactive/display/pipeline_graph.py
apache_beam/runners/interactive/display/pipeline_graph_renderer.py
apache_beam/runners/interactive/display/pipeline_graph_test.py
apache_beam/runners/interactive/messaging/__init__.py
apache_beam/runners/interactive/messaging/interactive_environment_inspector.py
apache_beam/runners/interactive/messaging/interactive_environment_inspector_test.py
apache_beam/runners/interactive/options/__init__.py
apache_beam/runners/interactive/options/capture_control.py
apache_beam/runners/interactive/options/capture_control_test.py
apache_beam/runners/interactive/options/capture_limiters.py
apache_beam/runners/interactive/options/capture_limiters_test.py
apache_beam/runners/interactive/options/interactive_options.py
apache_beam/runners/interactive/sql/__init__.py
apache_beam/runners/interactive/sql/beam_sql_magics.py
apache_beam/runners/interactive/sql/beam_sql_magics_test.py
apache_beam/runners/interactive/sql/sql_chain.py
apache_beam/runners/interactive/sql/sql_chain_test.py
apache_beam/runners/interactive/sql/utils.py
apache_beam/runners/interactive/sql/utils_test.py
apache_beam/runners/interactive/testing/__init__.py
apache_beam/runners/interactive/testing/mock_env.py
apache_beam/runners/interactive/testing/mock_ipython.py
apache_beam/runners/interactive/testing/pipeline_assertion.py
apache_beam/runners/interactive/testing/test_cache_manager.py
apache_beam/runners/interactive/testing/integration/__init__.py
apache_beam/runners/interactive/testing/integration/notebook_executor.py
apache_beam/runners/interactive/testing/integration/screen_diff.py
apache_beam/runners/internal/__init__.py
apache_beam/runners/internal/names.py
apache_beam/runners/job/__init__.py
apache_beam/runners/job/manager.py
apache_beam/runners/job/utils.py
apache_beam/runners/portability/__init__.py
apache_beam/runners/portability/abstract_job_service.py
apache_beam/runners/portability/artifact_service.py
apache_beam/runners/portability/artifact_service_test.py
apache_beam/runners/portability/expansion_service.py
apache_beam/runners/portability/expansion_service_main.py
apache_beam/runners/portability/expansion_service_test.py
apache_beam/runners/portability/flink_runner.py
apache_beam/runners/portability/flink_runner_test.py
apache_beam/runners/portability/flink_uber_jar_job_server.py
apache_beam/runners/portability/flink_uber_jar_job_server_test.py
apache_beam/runners/portability/job_server.py
apache_beam/runners/portability/job_server_test.py
apache_beam/runners/portability/local_job_service.py
apache_beam/runners/portability/local_job_service_main.py
apache_beam/runners/portability/local_job_service_test.py
apache_beam/runners/portability/portable_metrics.py
apache_beam/runners/portability/portable_runner.py
apache_beam/runners/portability/portable_runner_test.py
apache_beam/runners/portability/requirements_cache_it_test.py
apache_beam/runners/portability/samza_runner_test.py
apache_beam/runners/portability/sdk_container_builder.py
apache_beam/runners/portability/sdk_container_builder_test.py
apache_beam/runners/portability/spark_java_job_server_test.py
apache_beam/runners/portability/spark_runner.py
apache_beam/runners/portability/spark_runner_test.py
apache_beam/runners/portability/spark_uber_jar_job_server.py
apache_beam/runners/portability/spark_uber_jar_job_server_test.py
apache_beam/runners/portability/stager.py
apache_beam/runners/portability/stager_test.py
apache_beam/runners/portability/fn_api_runner/__init__.py
apache_beam/runners/portability/fn_api_runner/execution.py
apache_beam/runners/portability/fn_api_runner/fn_runner.py
apache_beam/runners/portability/fn_api_runner/fn_runner_test.py
apache_beam/runners/portability/fn_api_runner/translations.py
apache_beam/runners/portability/fn_api_runner/translations_test.py
apache_beam/runners/portability/fn_api_runner/trigger_manager.py
apache_beam/runners/portability/fn_api_runner/trigger_manager_test.py
apache_beam/runners/portability/fn_api_runner/visualization_tools.py
apache_beam/runners/portability/fn_api_runner/watermark_manager.py
apache_beam/runners/portability/fn_api_runner/worker_handlers.py
apache_beam/runners/test/__init__.py
apache_beam/runners/worker/__init__.py
apache_beam/runners/worker/bundle_processor.py
apache_beam/runners/worker/bundle_processor_test.py
apache_beam/runners/worker/channel_factory.py
apache_beam/runners/worker/crossplatform_time.h
apache_beam/runners/worker/crossplatform_unistd.h
apache_beam/runners/worker/data_plane.py
apache_beam/runners/worker/data_plane_test.py
apache_beam/runners/worker/data_sampler.py
apache_beam/runners/worker/data_sampler_test.py
apache_beam/runners/worker/log_handler.py
apache_beam/runners/worker/log_handler_test.py
apache_beam/runners/worker/logger.py
apache_beam/runners/worker/logger_test.py
apache_beam/runners/worker/opcounters.pxd
apache_beam/runners/worker/opcounters.py
apache_beam/runners/worker/opcounters_test.py
apache_beam/runners/worker/operation_specs.py
apache_beam/runners/worker/operations.pxd
apache_beam/runners/worker/operations.py
apache_beam/runners/worker/sdk_worker.py
apache_beam/runners/worker/sdk_worker_main.py
apache_beam/runners/worker/sdk_worker_main_test.py
apache_beam/runners/worker/sdk_worker_test.py
apache_beam/runners/worker/sideinputs.py
apache_beam/runners/worker/sideinputs_test.py
apache_beam/runners/worker/statecache.py
apache_beam/runners/worker/statecache_test.py
apache_beam/runners/worker/statesampler.py
apache_beam/runners/worker/statesampler_fast.pxd
apache_beam/runners/worker/statesampler_fast.pyx
apache_beam/runners/worker/statesampler_slow.py
apache_beam/runners/worker/statesampler_test.py
apache_beam/runners/worker/worker_id_interceptor.py
apache_beam/runners/worker/worker_id_interceptor_test.py
apache_beam/runners/worker/worker_pool_main.py
apache_beam/runners/worker/worker_status.py
apache_beam/runners/worker/worker_status_test.py
apache_beam/testing/__init__.py
apache_beam/testing/datatype_inference.py
apache_beam/testing/datatype_inference_test.py
apache_beam/testing/extra_assertions.py
apache_beam/testing/extra_assertions_test.py
apache_beam/testing/fast_test_utils.pxd
apache_beam/testing/fast_test_utils.pyx
apache_beam/testing/metric_result_matchers.py
apache_beam/testing/metric_result_matchers_test.py
apache_beam/testing/pipeline_verifiers.py
apache_beam/testing/pipeline_verifiers_test.py
apache_beam/testing/synthetic_pipeline.py
apache_beam/testing/synthetic_pipeline_test.py
apache_beam/testing/test_pipeline.py
apache_beam/testing/test_pipeline_test.py
apache_beam/testing/test_stream.py
apache_beam/testing/test_stream_it_test.py
apache_beam/testing/test_stream_service.py
apache_beam/testing/test_stream_service_test.py
apache_beam/testing/test_stream_test.py
apache_beam/testing/test_utils.py
apache_beam/testing/test_utils_test.py
apache_beam/testing/util.py
apache_beam/testing/util_test.py
apache_beam/testing/analyzers/__init__.py
apache_beam/testing/analyzers/constants.py
apache_beam/testing/analyzers/github_issues_utils.py
apache_beam/testing/analyzers/perf_analysis.py
apache_beam/testing/analyzers/perf_analysis_test.py
apache_beam/testing/analyzers/perf_analysis_utils.py
apache_beam/testing/benchmarks/__init__.py
apache_beam/testing/benchmarks/chicago_taxi/__init__.py
apache_beam/testing/benchmarks/chicago_taxi/preprocess.py
apache_beam/testing/benchmarks/chicago_taxi/process_tfma.py
apache_beam/testing/benchmarks/chicago_taxi/setup.py
apache_beam/testing/benchmarks/chicago_taxi/tfdv_analyze_and_validate.py
apache_beam/testing/benchmarks/chicago_taxi/trainer/__init__.py
apache_beam/testing/benchmarks/chicago_taxi/trainer/model.py
apache_beam/testing/benchmarks/chicago_taxi/trainer/task.py
apache_beam/testing/benchmarks/chicago_taxi/trainer/taxi.py
apache_beam/testing/benchmarks/cloudml/__init__.py
apache_beam/testing/benchmarks/cloudml/cloudml_benchmark_constants_lib.py
apache_beam/testing/benchmarks/cloudml/cloudml_benchmark_test.py
apache_beam/testing/benchmarks/cloudml/criteo_tft/__init__.py
apache_beam/testing/benchmarks/cloudml/criteo_tft/criteo.py
apache_beam/testing/benchmarks/cloudml/pipelines/__init__.py
apache_beam/testing/benchmarks/cloudml/pipelines/workflow.py
apache_beam/testing/benchmarks/inference/__init__.py
apache_beam/testing/benchmarks/inference/pytorch_image_classification_benchmarks.py
apache_beam/testing/benchmarks/inference/pytorch_language_modeling_benchmarks.py
apache_beam/testing/benchmarks/nexmark/__init__.py
apache_beam/testing/benchmarks/nexmark/monitor.py
apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py
apache_beam/testing/benchmarks/nexmark/nexmark_perf.py
apache_beam/testing/benchmarks/nexmark/nexmark_util.py
apache_beam/testing/benchmarks/nexmark/models/__init__.py
apache_beam/testing/benchmarks/nexmark/models/auction_bid.py
apache_beam/testing/benchmarks/nexmark/models/field_name.py
apache_beam/testing/benchmarks/nexmark/models/nexmark_model.py
apache_beam/testing/benchmarks/nexmark/queries/__init__.py
apache_beam/testing/benchmarks/nexmark/queries/nexmark_query_util.py
apache_beam/testing/benchmarks/nexmark/queries/query0.py
apache_beam/testing/benchmarks/nexmark/queries/query1.py
apache_beam/testing/benchmarks/nexmark/queries/query10.py
apache_beam/testing/benchmarks/nexmark/queries/query11.py
apache_beam/testing/benchmarks/nexmark/queries/query12.py
apache_beam/testing/benchmarks/nexmark/queries/query2.py
apache_beam/testing/benchmarks/nexmark/queries/query3.py
apache_beam/testing/benchmarks/nexmark/queries/query4.py
apache_beam/testing/benchmarks/nexmark/queries/query5.py
apache_beam/testing/benchmarks/nexmark/queries/query6.py
apache_beam/testing/benchmarks/nexmark/queries/query7.py
apache_beam/testing/benchmarks/nexmark/queries/query8.py
apache_beam/testing/benchmarks/nexmark/queries/query9.py
apache_beam/testing/benchmarks/nexmark/queries/winning_bids.py
apache_beam/testing/data/trigger_transcripts.yaml
apache_beam/testing/load_tests/__init__.py
apache_beam/testing/load_tests/co_group_by_key_test.py
apache_beam/testing/load_tests/combine_test.py
apache_beam/testing/load_tests/group_by_key_test.py
apache_beam/testing/load_tests/load_test.py
apache_beam/testing/load_tests/load_test_metrics_utils.py
apache_beam/testing/load_tests/microbenchmarks_test.py
apache_beam/testing/load_tests/pardo_test.py
apache_beam/testing/load_tests/sideinput_test.py
apache_beam/tools/__init__.py
apache_beam/tools/coders_microbenchmark.py
apache_beam/tools/distribution_counter_microbenchmark.py
apache_beam/tools/fn_api_runner_microbenchmark.py
apache_beam/tools/map_fn_microbenchmark.py
apache_beam/tools/microbenchmarks_test.py
apache_beam/tools/runtime_type_check_microbenchmark.py
apache_beam/tools/sideinput_microbenchmark.py
apache_beam/tools/teststream_microbenchmark.py
apache_beam/tools/utils.py
apache_beam/transforms/__init__.py
apache_beam/transforms/batch_dofn_test.py
apache_beam/transforms/combinefn_lifecycle_pipeline.py
apache_beam/transforms/combinefn_lifecycle_test.py
apache_beam/transforms/combiners.py
apache_beam/transforms/combiners_test.py
apache_beam/transforms/core.py
apache_beam/transforms/core_test.py
apache_beam/transforms/create_source.py
apache_beam/transforms/create_test.py
apache_beam/transforms/cy_combiners.pxd
apache_beam/transforms/cy_combiners.py
apache_beam/transforms/cy_dataflow_distribution_counter.pxd
apache_beam/transforms/cy_dataflow_distribution_counter.pyx
apache_beam/transforms/dataflow_distribution_counter_test.py
apache_beam/transforms/deduplicate.py
apache_beam/transforms/deduplicate_test.py
apache_beam/transforms/display.py
apache_beam/transforms/display_test.py
apache_beam/transforms/dofn_lifecycle_test.py
apache_beam/transforms/environments.py
apache_beam/transforms/environments_test.py
apache_beam/transforms/external.py
apache_beam/transforms/external_it_test.py
apache_beam/transforms/external_java.py
apache_beam/transforms/external_test.py
apache_beam/transforms/fully_qualified_named_transform.py
apache_beam/transforms/fully_qualified_named_transform_test.py
apache_beam/transforms/periodicsequence.py
apache_beam/transforms/periodicsequence_it_test.py
apache_beam/transforms/periodicsequence_test.py
apache_beam/transforms/ptransform.py
apache_beam/transforms/ptransform_test.py
apache_beam/transforms/py_dataflow_distribution_counter.py
apache_beam/transforms/resources.py
apache_beam/transforms/resources_test.py
apache_beam/transforms/sideinputs.py
apache_beam/transforms/sideinputs_test.py
apache_beam/transforms/sql.py
apache_beam/transforms/sql_test.py
apache_beam/transforms/stats.pxd
apache_beam/transforms/stats.py
apache_beam/transforms/stats_test.py
apache_beam/transforms/timestamped_value_type_test.py
apache_beam/transforms/timeutil.py
apache_beam/transforms/transforms_keyword_only_args_test.py
apache_beam/transforms/trigger.py
apache_beam/transforms/trigger_test.py
apache_beam/transforms/userstate.py
apache_beam/transforms/userstate_test.py
apache_beam/transforms/util.py
apache_beam/transforms/util_test.py
apache_beam/transforms/validate_runner_xlang_test.py
apache_beam/transforms/window.py
apache_beam/transforms/window_test.py
apache_beam/transforms/write_ptransform_test.py
apache_beam/typehints/__init__.py
apache_beam/typehints/arrow_batching_microbenchmark.py
apache_beam/typehints/arrow_type_compatibility.py
apache_beam/typehints/arrow_type_compatibility_test.py
apache_beam/typehints/batch.py
apache_beam/typehints/batch_test.py
apache_beam/typehints/decorators.py
apache_beam/typehints/decorators_test.py
apache_beam/typehints/native_type_compatibility.py
apache_beam/typehints/native_type_compatibility_test.py
apache_beam/typehints/opcodes.py
apache_beam/typehints/pandas_type_compatibility.py
apache_beam/typehints/pandas_type_compatibility_test.py
apache_beam/typehints/pytorch_type_compatibility.py
apache_beam/typehints/pytorch_type_compatibility_test.py
apache_beam/typehints/row_type.py
apache_beam/typehints/schema_registry.py
apache_beam/typehints/schemas.py
apache_beam/typehints/schemas_test.py
apache_beam/typehints/sharded_key_type.py
apache_beam/typehints/sharded_key_type_test.py
apache_beam/typehints/trivial_inference.py
apache_beam/typehints/trivial_inference_test.py
apache_beam/typehints/typecheck.py
apache_beam/typehints/typecheck_test.py
apache_beam/typehints/typed_pipeline_test.py
apache_beam/typehints/typehints.py
apache_beam/typehints/typehints_test.py
apache_beam/typehints/testing/__init__.py
apache_beam/typehints/testing/strategies.py
apache_beam/utils/__init__.py
apache_beam/utils/annotations.py
apache_beam/utils/annotations_test.py
apache_beam/utils/counters.pxd
apache_beam/utils/counters.py
apache_beam/utils/counters_test.py
apache_beam/utils/histogram.py
apache_beam/utils/histogram_test.py
apache_beam/utils/interactive_utils.py
apache_beam/utils/interactive_utils_test.py
apache_beam/utils/multi_process_shared.py
apache_beam/utils/multi_process_shared_test.py
apache_beam/utils/plugin.py
apache_beam/utils/processes.py
apache_beam/utils/processes_test.py
apache_beam/utils/profiler.py
apache_beam/utils/profiler_test.py
apache_beam/utils/proto_utils.py
apache_beam/utils/python_callable.py
apache_beam/utils/python_callable_test.py
apache_beam/utils/retry.py
apache_beam/utils/retry_test.py
apache_beam/utils/sentinel.py
apache_beam/utils/sharded_key.py
apache_beam/utils/shared.py
apache_beam/utils/shared_test.py
apache_beam/utils/subprocess_server.py
apache_beam/utils/subprocess_server_test.py
apache_beam/utils/thread_pool_executor.py
apache_beam/utils/thread_pool_executor_test.py
apache_beam/utils/timestamp.py
apache_beam/utils/timestamp_test.py
apache_beam/utils/transform_service_launcher.py
apache_beam/utils/urns.py
apache_beam/utils/windowed_value.pxd
apache_beam/utils/windowed_value.py
apache_beam/utils/windowed_value_test.py
apache_beam/yaml/__init__.py
apache_beam/yaml/cache_provider_artifacts.py
apache_beam/yaml/main.py
apache_beam/yaml/pipeline.schema.yaml
apache_beam/yaml/readme_test.py
apache_beam/yaml/standard_io.yaml
apache_beam/yaml/standard_providers.yaml
apache_beam/yaml/yaml_io.py
apache_beam/yaml/yaml_mapping.py
apache_beam/yaml/yaml_mapping_test.py
apache_beam/yaml/yaml_provider.py
apache_beam/yaml/yaml_transform.py
apache_beam/yaml/yaml_transform_scope_test.py
apache_beam/yaml/yaml_transform_test.py
apache_beam/yaml/yaml_transform_unit_test.py
apache_beam/yaml/yaml_udf_test.py