This is an automated email from the ASF dual-hosted git repository. vterentev pushed a commit to branch release-docs in repository https://gitbox.apache.org/repos/asf/beam-site.git
commit f9a1e3b79cd50475525c9a1d0cec0966a2af2d6c Merge: c6f105df2f 7b57efa0e5 Author: Vitaly Terentyev <[email protected]> AuthorDate: Tue Jul 1 19:50:26 2025 +0400 Publish docs for 2.66.0 release (#685) Publish docs for 2.66.0 release javadoc/current | 2 +- pydoc/2.66.0/.buildinfo | 4 + .../_modules/apache_beam/coders/avro_record.html | 154 + .../2.66.0/_modules/apache_beam/coders/coders.html | 2285 ++ .../_modules/apache_beam/coders/observable.html | 168 + .../_modules/apache_beam/coders/row_coder.html | 350 + .../_modules/apache_beam/coders/slow_stream.html | 412 + .../_modules/apache_beam/dataframe/convert.html | 456 + .../_modules/apache_beam/dataframe/doctests.html | 937 + .../apache_beam/dataframe/expressions.html | 631 + .../_modules/apache_beam/dataframe/frame_base.html | 917 + .../_modules/apache_beam/dataframe/frames.html | 5854 ++++++ .../2.66.0/_modules/apache_beam/dataframe/io.html | 1009 + .../dataframe/pandas_top_level_functions.html | 310 + .../apache_beam/dataframe/partitionings.html | 431 + .../_modules/apache_beam/dataframe/schemas.html | 347 + .../_modules/apache_beam/dataframe/transforms.html | 749 + pydoc/2.66.0/_modules/apache_beam/error.html | 186 + pydoc/2.66.0/_modules/apache_beam/io/avroio.html | 917 + .../io/aws/clients/s3/boto3_client.html | 457 + .../apache_beam/io/aws/clients/s3/fake_client.html | 399 + .../apache_beam/io/aws/clients/s3/messages.html | 312 + .../_modules/apache_beam/io/aws/s3filesystem.html | 496 + pydoc/2.66.0/_modules/apache_beam/io/aws/s3io.html | 874 + .../io/azure/blobstoragefilesystem.html | 499 + .../apache_beam/io/azure/blobstorageio.html | 913 + .../io/components/adaptive_throttler.html | 222 + .../_modules/apache_beam/io/components/util.html | 228 + .../_modules/apache_beam/io/concat_source.html | 440 + pydoc/2.66.0/_modules/apache_beam/io/debezium.html | 302 + .../apache_beam/io/external/gcp/pubsub.html | 303 + .../apache_beam/io/external/generate_sequence.html | 185 + .../_modules/apache_beam/io/filebasedsink.html | 613 + .../_modules/apache_beam/io/filebasedsource.html | 615 + pydoc/2.66.0/_modules/apache_beam/io/fileio.html | 1108 + .../2.66.0/_modules/apache_beam/io/filesystem.html | 1171 ++ .../_modules/apache_beam/io/filesystemio.html | 486 + .../_modules/apache_beam/io/filesystems.html | 585 + .../io/flink/flink_streaming_impulse_source.html | 222 + .../io/gcp/big_query_query_to_table_pipeline.html | 224 + .../_modules/apache_beam/io/gcp/bigquery.html | 3298 +++ .../apache_beam/io/gcp/bigquery_avro_tools.html | 266 + .../apache_beam/io/gcp/bigquery_file_loads.html | 1553 ++ .../apache_beam/io/gcp/bigquery_io_metadata.html | 219 + .../io/gcp/bigquery_io_read_pipeline.html | 224 + .../apache_beam/io/gcp/bigquery_read_internal.html | 597 + .../apache_beam/io/gcp/bigquery_schema_tools.html | 264 + .../apache_beam/io/gcp/bigquery_tools.html | 2165 ++ .../_modules/apache_beam/io/gcp/bigtableio.html | 519 + .../v1new/datastore_write_it_pipeline.html | 301 + .../io/gcp/datastore/v1new/datastoreio.html | 749 + .../apache_beam/io/gcp/datastore/v1new/helper.html | 217 + .../io/gcp/datastore/v1new/query_splitter.html | 410 + .../gcp/datastore/v1new/rampup_throttling_fn.html | 224 + .../apache_beam/io/gcp/datastore/v1new/types.html | 451 + .../apache_beam/io/gcp/datastore/v1new/util.html | 280 + .../apache_beam/io/gcp/experimental/spannerio.html | 1495 ++ .../apache_beam/io/gcp/gce_metadata_util.html | 166 + .../_modules/apache_beam/io/gcp/gcsfilesystem.html | 548 + .../2.66.0/_modules/apache_beam/io/gcp/gcsio.html | 900 + .../apache_beam/io/gcp/healthcare/dicomclient.html | 255 + .../apache_beam/io/gcp/healthcare/dicomio.html | 715 + .../2.66.0/_modules/apache_beam/io/gcp/pubsub.html | 835 + .../apache_beam/io/gcp/pubsub_it_pipeline.html | 214 + .../apache_beam/io/gcp/pubsublite/proto_api.html | 235 + .../apache_beam/io/gcp/resource_identifiers.html | 194 + .../_modules/apache_beam/io/gcp/spanner.html | 804 + .../apache_beam/io/gcp/spanner_wrapper.html | 196 + .../_modules/apache_beam/io/hadoopfilesystem.html | 610 + pydoc/2.66.0/_modules/apache_beam/io/iobase.html | 1949 ++ pydoc/2.66.0/_modules/apache_beam/io/jdbc.html | 599 + pydoc/2.66.0/_modules/apache_beam/io/kafka.html | 423 + pydoc/2.66.0/_modules/apache_beam/io/kinesis.html | 481 + .../_modules/apache_beam/io/localfilesystem.html | 539 + .../2.66.0/_modules/apache_beam/io/mongodbio.html | 939 + .../2.66.0/_modules/apache_beam/io/parquetio.html | 957 + .../_modules/apache_beam/io/range_trackers.html | 674 + .../_modules/apache_beam/io/requestresponse.html | 989 + .../apache_beam/io/restriction_trackers.html | 337 + .../2.66.0/_modules/apache_beam/io/snowflake.html | 628 + .../_modules/apache_beam/io/source_test_utils.html | 880 + pydoc/2.66.0/_modules/apache_beam/io/textio.html | 1226 ++ .../2.66.0/_modules/apache_beam/io/tfrecordio.html | 488 + pydoc/2.66.0/_modules/apache_beam/io/utils.html | 200 + .../apache_beam/io/watermark_estimators.html | 317 + .../_modules/apache_beam/metrics/metric.html | 674 + .../_modules/apache_beam/metrics/metricbase.html | 335 + .../apache_beam/metrics/monitoring_infos.html | 745 + .../apache_beam/ml/anomaly/aggregations.html | 467 + .../_modules/apache_beam/ml/anomaly/base.html | 377 + .../apache_beam/ml/anomaly/detectors/iqr.html | 255 + .../apache_beam/ml/anomaly/detectors/offline.html | 250 + .../ml/anomaly/detectors/robust_zscore.html | 242 + .../apache_beam/ml/anomaly/detectors/zscore.html | 252 + .../apache_beam/ml/anomaly/specifiable.html | 584 + .../apache_beam/ml/anomaly/thresholds.html | 313 + .../apache_beam/ml/anomaly/transforms.html | 813 + .../apache_beam/ml/anomaly/univariate/base.html | 228 + .../apache_beam/ml/anomaly/univariate/mad.html | 216 + .../apache_beam/ml/anomaly/univariate/mean.html | 287 + .../apache_beam/ml/anomaly/univariate/median.html | 193 + .../ml/anomaly/univariate/quantile.html | 364 + .../apache_beam/ml/anomaly/univariate/stdev.html | 297 + .../_modules/apache_beam/ml/gcp/cloud_dlp.html | 356 + .../apache_beam/ml/gcp/naturallanguageml.html | 264 + .../apache_beam/ml/gcp/recommendations_ai.html | 740 + .../apache_beam/ml/gcp/videointelligenceml.html | 353 + .../_modules/apache_beam/ml/gcp/visionml.html | 424 + .../_modules/apache_beam/ml/inference/base.html | 2315 ++ .../apache_beam/ml/inference/gemini_inference.html | 301 + .../ml/inference/huggingface_inference.html | 950 + .../apache_beam/ml/inference/onnx_inference.html | 319 + .../ml/inference/pytorch_inference.html | 779 + .../ml/inference/sklearn_inference.html | 507 + .../ml/inference/tensorflow_inference.html | 550 + .../ml/inference/tensorrt_inference.html | 496 + .../_modules/apache_beam/ml/inference/utils.html | 286 + .../ml/inference/vertex_ai_inference.html | 346 + .../apache_beam/ml/inference/vllm_inference.html | 487 + .../ml/inference/xgboost_inference.html | 523 + .../_modules/apache_beam/ml/rag/chunking/base.html | 218 + .../apache_beam/ml/rag/chunking/langchain.html | 243 + .../apache_beam/ml/rag/embeddings/base.html | 175 + .../apache_beam/ml/rag/embeddings/huggingface.html | 200 + .../apache_beam/ml/rag/embeddings/vertex_ai.html | 223 + .../ml/rag/enrichment/bigquery_vector_search.html | 520 + .../apache_beam/ml/rag/ingestion/alloydb.html | 336 + .../apache_beam/ml/rag/ingestion/base.html | 243 + .../apache_beam/ml/rag/ingestion/bigquery.html | 306 + .../apache_beam/ml/rag/ingestion/cloudsql.html | 349 + .../apache_beam/ml/rag/ingestion/jdbc_common.html | 201 + .../apache_beam/ml/rag/ingestion/postgres.html | 332 + .../ml/rag/ingestion/postgres_common.html | 658 + .../apache_beam/ml/rag/ingestion/test_utils.html | 255 + .../2.66.0/_modules/apache_beam/ml/rag/types.html | 199 + .../_modules/apache_beam/ml/transforms/base.html | 958 + .../ml/transforms/embeddings/huggingface.html | 400 + .../ml/transforms/embeddings/open_ai.html | 299 + .../ml/transforms/embeddings/tensorflow_hub.html | 308 + .../ml/transforms/embeddings/vertex_ai.html | 483 + .../apache_beam/ml/transforms/handlers.html | 626 + .../_modules/apache_beam/ml/transforms/tft.html | 946 + .../_modules/apache_beam/ml/transforms/utils.html | 222 + .../apache_beam/options/pipeline_options.html | 2204 ++ .../options/pipeline_options_validator.html | 584 + .../apache_beam/options/value_provider.html | 359 + pydoc/2.66.0/_modules/apache_beam/pipeline.html | 1848 ++ .../fn_execution/v1/beam_fn_api_pb2_grpc.html | 720 + .../fn_execution/v1/beam_fn_api_pb2_urns.html | 134 + .../v1/beam_provision_api_pb2_grpc.html | 211 + .../v1/beam_interactive_api_pb2_grpc.html | 203 + .../v1/beam_artifact_api_pb2_grpc.html | 601 + .../v1/beam_artifact_api_pb2_urns.html | 133 + .../v1/beam_expansion_api_pb2_grpc.html | 245 + .../job_management/v1/beam_job_api_pb2_grpc.html | 606 + .../pipeline/v1/beam_runner_api_pb2_urns.html | 386 + .../pipeline/v1/external_transforms_pb2_urns.html | 167 + .../beam/model/pipeline/v1/metrics_pb2_urns.html | 221 + .../beam/model/pipeline/v1/schema_pb2_urns.html | 140 + .../pipeline/v1/standard_window_fns_pb2_urns.html | 169 + pydoc/2.66.0/_modules/apache_beam/pvalue.html | 860 + .../apache_beam/runners/dask/dask_runner.html | 397 + .../apache_beam/runners/dask/overrides.html | 275 + .../dataflow_exercise_metrics_pipeline.html | 307 + ...taflow_exercise_streaming_metrics_pipeline.html | 238 + .../runners/dataflow/dataflow_job_service.html | 210 + .../runners/dataflow/dataflow_metrics.html | 469 + .../runners/dataflow/dataflow_runner.html | 1004 + .../runners/dataflow/ptransform_overrides.html | 186 + .../runners/dataflow/test_dataflow_runner.html | 235 + .../apache_beam/runners/direct/bundle_factory.html | 348 + .../_modules/apache_beam/runners/direct/clock.html | 194 + .../direct/consumer_tracking_pipeline_visitor.html | 194 + .../apache_beam/runners/direct/direct_metrics.html | 406 + .../apache_beam/runners/direct/direct_runner.html | 812 + .../runners/direct/direct_userstate.html | 508 + .../runners/direct/evaluation_context.html | 622 + .../apache_beam/runners/direct/executor.html | 860 + .../runners/direct/helper_transforms.html | 279 + .../runners/direct/sdf_direct_runner.html | 773 + .../runners/direct/test_direct_runner.html | 179 + .../runners/direct/transform_evaluator.html | 1341 ++ .../_modules/apache_beam/runners/direct/util.html | 219 + .../runners/direct/watermark_manager.html | 454 + .../runners/interactive/augmented_pipeline.html | 255 + .../interactive/background_caching_job.html | 507 + .../runners/interactive/cache_manager.html | 612 + .../runners/interactive/caching/cacheable.html | 240 + .../interactive/caching/expression_cache.html | 232 + .../runners/interactive/caching/read_cache.html | 263 + .../runners/interactive/caching/reify.html | 246 + .../interactive/caching/streaming_cache.html | 713 + .../runners/interactive/caching/write_cache.html | 292 + .../dataproc/dataproc_cluster_manager.html | 515 + .../runners/interactive/dataproc/types.html | 210 + .../interactive/display/display_manager.html | 314 + .../display/interactive_pipeline_graph.html | 288 + .../interactive/display/pcoll_visualization.html | 682 + .../interactive/display/pipeline_graph.html | 410 + .../display/pipeline_graph_renderer.html | 283 + .../runners/interactive/interactive_beam.html | 1188 ++ .../interactive/interactive_environment.html | 955 + .../runners/interactive/interactive_runner.html | 504 + .../interactive_environment_inspector.html | 354 + .../interactive/options/capture_control.html | 205 + .../interactive/options/capture_limiters.html | 306 + .../interactive/options/interactive_options.html | 167 + .../runners/interactive/pipeline_fragment.html | 398 + .../runners/interactive/pipeline_instrument.html | 942 + .../runners/interactive/recording_manager.html | 662 + .../runners/interactive/sql/beam_sql_magics.html | 622 + .../runners/interactive/sql/sql_chain.html | 366 + .../apache_beam/runners/interactive/sql/utils.html | 596 + .../testing/integration/notebook_executor.html | 295 + .../testing/integration/screen_diff.html | 368 + .../runners/interactive/testing/mock_env.html | 214 + .../runners/interactive/testing/mock_ipython.html | 187 + .../interactive/testing/pipeline_assertion.html | 244 + .../interactive/testing/test_cache_manager.html | 299 + .../runners/interactive/user_pipeline_tracker.html | 293 + .../apache_beam/runners/interactive/utils.html | 649 + .../_modules/apache_beam/runners/job/manager.html | 177 + .../_modules/apache_beam/runners/job/utils.html | 162 + .../apache_beam/runners/pipeline_context.html | 479 + .../apache_beam/runners/pipeline_utils.html | 391 + .../_modules/apache_beam/runners/render.html | 767 + .../_modules/apache_beam/runners/runner.html | 496 + .../_modules/apache_beam/runners/sdf_utils.html | 422 + .../apache_beam/runners/trivial_runner.html | 587 + .../benchmarks/nexmark/models/auction_bid.html | 196 + .../benchmarks/nexmark/models/field_name.html | 160 + .../benchmarks/nexmark/models/nexmark_model.html | 399 + .../testing/benchmarks/nexmark/monitor.html | 200 + .../benchmarks/nexmark/nexmark_launcher.html | 682 + .../testing/benchmarks/nexmark/nexmark_perf.html | 175 + .../testing/benchmarks/nexmark/nexmark_util.html | 460 + .../nexmark/queries/nexmark_query_util.html | 265 + .../testing/benchmarks/nexmark/queries/query0.html | 170 + .../testing/benchmarks/nexmark/queries/query1.html | 162 + .../benchmarks/nexmark/queries/query10.html | 299 + .../benchmarks/nexmark/queries/query11.html | 174 + .../benchmarks/nexmark/queries/query12.html | 169 + .../testing/benchmarks/nexmark/queries/query2.html | 162 + .../testing/benchmarks/nexmark/queries/query3.html | 288 + .../testing/benchmarks/nexmark/queries/query4.html | 206 + .../testing/benchmarks/nexmark/queries/query5.html | 231 + .../testing/benchmarks/nexmark/queries/query6.html | 224 + .../testing/benchmarks/nexmark/queries/query7.html | 183 + .../testing/benchmarks/nexmark/queries/query8.html | 199 + .../testing/benchmarks/nexmark/queries/query9.html | 152 + .../benchmarks/nexmark/queries/winning_bids.html | 370 + .../apache_beam/testing/datatype_inference.html | 259 + .../apache_beam/testing/extra_assertions.html | 176 + .../testing/load_tests/dataflow_cost_consts.html | 179 + .../load_tests/load_test_metrics_utils.html | 907 + .../testing/metric_result_matchers.html | 335 + .../apache_beam/testing/pipeline_verifiers.html | 297 + .../apache_beam/testing/synthetic_pipeline.html | 1228 ++ .../apache_beam/testing/test_pipeline.html | 335 + .../_modules/apache_beam/testing/test_stream.html | 893 + .../apache_beam/testing/test_stream_service.html | 215 + .../_modules/apache_beam/testing/test_utils.html | 466 + .../2.66.0/_modules/apache_beam/testing/util.html | 568 + .../transforms/combinefn_lifecycle_pipeline.html | 320 + .../_modules/apache_beam/transforms/combiners.html | 1380 ++ .../_modules/apache_beam/transforms/core.html | 4598 ++++ .../apache_beam/transforms/deduplicate.html | 260 + .../_modules/apache_beam/transforms/display.html | 602 + .../apache_beam/transforms/enrichment.html | 345 + .../transforms/enrichment_handlers/bigquery.html | 392 + .../transforms/enrichment_handlers/bigtable.html | 291 + .../enrichment_handlers/feast_feature_store.html | 322 + .../transforms/enrichment_handlers/utils.html | 158 + .../vertex_ai_feature_store.html | 459 + .../apache_beam/transforms/environments.html | 1206 ++ .../apache_beam/transforms/error_handling.html | 267 + .../_modules/apache_beam/transforms/external.html | 1503 ++ .../apache_beam/transforms/external_java.html | 311 + .../transforms/external_transform_provider.html | 432 + .../fully_qualified_named_transform.html | 277 + .../_modules/apache_beam/transforms/managed.html | 322 + .../apache_beam/transforms/periodicsequence.html | 354 + .../apache_beam/transforms/ptransform.html | 1397 ++ .../_modules/apache_beam/transforms/resources.html | 434 + .../apache_beam/transforms/sideinputs.html | 240 + .../_modules/apache_beam/transforms/sql.html | 215 + .../_modules/apache_beam/transforms/timeutil.html | 260 + .../_modules/apache_beam/transforms/trigger.html | 1993 ++ .../_modules/apache_beam/transforms/userstate.html | 686 + .../_modules/apache_beam/transforms/util.html | 2123 ++ .../_modules/apache_beam/transforms/window.html | 842 + .../_modules/apache_beam/transforms/xlang/io.html | 264 + .../typehints/arrow_batching_microbenchmark.html | 201 + .../_modules/apache_beam/typehints/batch.html | 437 + .../_modules/apache_beam/typehints/decorators.html | 1125 + .../apache_beam/typehints/intrinsic_one_ops.html | 253 + .../typehints/native_type_compatibility.html | 741 + .../_modules/apache_beam/typehints/opcodes.html | 1031 + .../typehints/pytorch_type_compatibility.html | 290 + .../_modules/apache_beam/typehints/row_type.html | 391 + .../apache_beam/typehints/schema_registry.html | 191 + .../_modules/apache_beam/typehints/schemas.html | 1600 ++ .../apache_beam/typehints/sharded_key_type.html | 212 + .../apache_beam/typehints/testing/strategies.html | 228 + .../apache_beam/typehints/trivial_inference.html | 937 + .../_modules/apache_beam/typehints/typecheck.html | 569 + .../_modules/apache_beam/typehints/typehints.html | 1745 ++ .../_modules/apache_beam/utils/annotations.html | 317 + .../_modules/apache_beam/utils/histogram.html | 442 + .../apache_beam/utils/interactive_utils.html | 223 + .../apache_beam/utils/multi_process_shared.html | 471 + .../2.66.0/_modules/apache_beam/utils/plugin.html | 167 + .../_modules/apache_beam/utils/processes.html | 236 + .../_modules/apache_beam/utils/profiler.html | 306 + .../_modules/apache_beam/utils/proto_utils.html | 298 + .../apache_beam/utils/python_callable.html | 264 + pydoc/2.66.0/_modules/apache_beam/utils/retry.html | 485 + .../_modules/apache_beam/utils/sentinel.html | 148 + .../_modules/apache_beam/utils/sharded_key.html | 175 + .../2.66.0/_modules/apache_beam/utils/shared.html | 412 + .../apache_beam/utils/subprocess_server.html | 696 + .../apache_beam/utils/thread_pool_executor.html | 263 + .../_modules/apache_beam/utils/timestamp.html | 589 + .../utils/transform_service_launcher.html | 410 + pydoc/2.66.0/_modules/apache_beam/utils/urns.html | 317 + .../apache_beam/yaml/cache_provider_artifacts.html | 168 + .../2.66.0/_modules/apache_beam/yaml/conftest.html | 157 + .../yaml/examples/testing/input_data.html | 305 + .../apache_beam/yaml/generate_yaml_docs.html | 764 + .../_modules/apache_beam/yaml/json_utils.html | 476 + pydoc/2.66.0/_modules/apache_beam/yaml/main.html | 421 + .../2.66.0/_modules/apache_beam/yaml/options.html | 159 + .../_modules/apache_beam/yaml/yaml_combine.html | 352 + .../_modules/apache_beam/yaml/yaml_enrichment.html | 228 + .../_modules/apache_beam/yaml/yaml_errors.html | 220 + .../2.66.0/_modules/apache_beam/yaml/yaml_io.html | 817 + .../_modules/apache_beam/yaml/yaml_join.html | 427 + .../_modules/apache_beam/yaml/yaml_mapping.html | 1139 + .../2.66.0/_modules/apache_beam/yaml/yaml_ml.html | 655 + .../_modules/apache_beam/yaml/yaml_provider.html | 1963 ++ .../apache_beam/yaml/yaml_specifiable.html | 188 + .../_modules/apache_beam/yaml/yaml_testing.html | 695 + .../_modules/apache_beam/yaml/yaml_transform.html | 1260 ++ .../_modules/apache_beam/yaml/yaml_utils.html | 388 + pydoc/2.66.0/_modules/index.html | 461 + .../apache_beam.coders.avro_record.rst.txt | 7 + .../_sources/apache_beam.coders.coders.rst.txt | 7 + .../_sources/apache_beam.coders.observable.rst.txt | 7 + .../_sources/apache_beam.coders.row_coder.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.coders.rst.txt | 20 + .../apache_beam.coders.slow_stream.rst.txt | 7 + .../_sources/apache_beam.coders.typecoders.rst.txt | 7 + .../_sources/apache_beam.dataframe.convert.rst.txt | 7 + .../apache_beam.dataframe.doctests.rst.txt | 7 + .../apache_beam.dataframe.expressions.rst.txt | 7 + .../apache_beam.dataframe.frame_base.rst.txt | 7 + .../_sources/apache_beam.dataframe.frames.rst.txt | 8 + .../_sources/apache_beam.dataframe.io.rst.txt | 7 + ...am.dataframe.pandas_top_level_functions.rst.txt | 7 + .../apache_beam.dataframe.partitionings.rst.txt | 7 + .../2.66.0/_sources/apache_beam.dataframe.rst.txt | 24 + .../_sources/apache_beam.dataframe.schemas.rst.txt | 7 + .../apache_beam.dataframe.transforms.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.error.rst.txt | 7 + .../2.66.0/_sources/apache_beam.io.avroio.rst.txt | 7 + .../_sources/apache_beam.io.aws.clients.rst.txt | 15 + ...che_beam.io.aws.clients.s3.boto3_client.rst.txt | 7 + ...ache_beam.io.aws.clients.s3.fake_client.rst.txt | 7 + .../apache_beam.io.aws.clients.s3.messages.rst.txt | 7 + .../_sources/apache_beam.io.aws.clients.s3.rst.txt | 17 + pydoc/2.66.0/_sources/apache_beam.io.aws.rst.txt | 24 + .../apache_beam.io.aws.s3filesystem.rst.txt | 7 + .../_sources/apache_beam.io.aws.s3io.rst.txt | 7 + ...che_beam.io.azure.blobstoragefilesystem.rst.txt | 7 + .../apache_beam.io.azure.blobstorageio.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.io.azure.rst.txt | 16 + ...e_beam.io.components.adaptive_throttler.rst.txt | 7 + .../_sources/apache_beam.io.components.rst.txt | 16 + .../apache_beam.io.components.util.rst.txt | 7 + .../_sources/apache_beam.io.concat_source.rst.txt | 7 + .../_sources/apache_beam.io.debezium.rst.txt | 7 + .../apache_beam.io.external.gcp.pubsub.rst.txt | 7 + .../_sources/apache_beam.io.external.gcp.rst.txt | 15 + ...ache_beam.io.external.generate_sequence.rst.txt | 7 + .../_sources/apache_beam.io.external.kafka.rst.txt | 7 + .../_sources/apache_beam.io.external.rst.txt | 25 + .../apache_beam.io.external.snowflake.rst.txt | 7 + .../_sources/apache_beam.io.filebasedsink.rst.txt | 7 + .../apache_beam.io.filebasedsource.rst.txt | 7 + .../2.66.0/_sources/apache_beam.io.fileio.rst.txt | 7 + .../_sources/apache_beam.io.filesystem.rst.txt | 7 + .../_sources/apache_beam.io.filesystemio.rst.txt | 7 + .../_sources/apache_beam.io.filesystems.rst.txt | 7 + ...io.flink.flink_streaming_impulse_source.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.io.flink.rst.txt | 15 + ...o.gcp.big_query_query_to_table_pipeline.rst.txt | 7 + .../_sources/apache_beam.io.gcp.bigquery.rst.txt | 7 + .../apache_beam.io.gcp.bigquery_avro_tools.rst.txt | 7 + .../apache_beam.io.gcp.bigquery_file_loads.rst.txt | 7 + ...apache_beam.io.gcp.bigquery_io_metadata.rst.txt | 7 + ...e_beam.io.gcp.bigquery_io_read_pipeline.rst.txt | 7 + ...ache_beam.io.gcp.bigquery_read_internal.rst.txt | 7 + ...pache_beam.io.gcp.bigquery_schema_tools.rst.txt | 7 + .../apache_beam.io.gcp.bigquery_tools.rst.txt | 7 + .../_sources/apache_beam.io.gcp.bigtableio.rst.txt | 7 + .../_sources/apache_beam.io.gcp.datastore.rst.txt | 15 + ...store.v1new.datastore_write_it_pipeline.rst.txt | 7 + ...beam.io.gcp.datastore.v1new.datastoreio.rst.txt | 7 + ...ache_beam.io.gcp.datastore.v1new.helper.rst.txt | 7 + ...m.io.gcp.datastore.v1new.query_splitter.rst.txt | 7 + ...cp.datastore.v1new.rampup_throttling_fn.rst.txt | 7 + .../apache_beam.io.gcp.datastore.v1new.rst.txt | 21 + ...pache_beam.io.gcp.datastore.v1new.types.rst.txt | 7 + ...apache_beam.io.gcp.datastore.v1new.util.rst.txt | 7 + .../apache_beam.io.gcp.dicomclient.rst.txt | 7 + .../_sources/apache_beam.io.gcp.dicomio.rst.txt | 7 + .../apache_beam.io.gcp.experimental.rst.txt | 15 + ...ache_beam.io.gcp.experimental.spannerio.rst.txt | 7 + .../apache_beam.io.gcp.gce_metadata_util.rst.txt | 7 + .../apache_beam.io.gcp.gcsfilesystem.rst.txt | 7 + .../_sources/apache_beam.io.gcp.gcsio.rst.txt | 7 + .../apache_beam.io.gcp.gcsio_retry.rst.txt | 7 + ...ache_beam.io.gcp.healthcare.dicomclient.rst.txt | 7 + .../apache_beam.io.gcp.healthcare.dicomio.rst.txt | 7 + .../_sources/apache_beam.io.gcp.healthcare.rst.txt | 16 + .../_sources/apache_beam.io.gcp.pubsub.rst.txt | 7 + .../apache_beam.io.gcp.pubsub_it_pipeline.rst.txt | 7 + .../apache_beam.io.gcp.pubsublite.external.rst.txt | 7 + ...apache_beam.io.gcp.pubsublite.proto_api.rst.txt | 7 + .../_sources/apache_beam.io.gcp.pubsublite.rst.txt | 16 + ...apache_beam.io.gcp.resource_identifiers.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.io.gcp.rst.txt | 46 + .../_sources/apache_beam.io.gcp.spanner.rst.txt | 7 + .../apache_beam.io.gcp.spanner_wrapper.rst.txt | 7 + .../apache_beam.io.hadoopfilesystem.rst.txt | 7 + .../2.66.0/_sources/apache_beam.io.iobase.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.io.jdbc.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.io.kafka.rst.txt | 7 + .../2.66.0/_sources/apache_beam.io.kinesis.rst.txt | 7 + .../apache_beam.io.localfilesystem.rst.txt | 7 + .../_sources/apache_beam.io.mongodbio.rst.txt | 7 + .../_sources/apache_beam.io.parquetio.rst.txt | 7 + .../_sources/apache_beam.io.range_trackers.rst.txt | 7 + .../apache_beam.io.requestresponse.rst.txt | 7 + .../apache_beam.io.restriction_trackers.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.io.rst.txt | 53 + .../_sources/apache_beam.io.snowflake.rst.txt | 7 + .../apache_beam.io.source_test_utils.rst.txt | 7 + .../2.66.0/_sources/apache_beam.io.textio.rst.txt | 7 + .../_sources/apache_beam.io.tfrecordio.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.io.utils.rst.txt | 7 + .../apache_beam.io.watermark_estimators.rst.txt | 7 + .../_sources/apache_beam.metrics.cells.rst.txt | 7 + .../_sources/apache_beam.metrics.metric.rst.txt | 7 + .../apache_beam.metrics.metricbase.rst.txt | 7 + .../apache_beam.metrics.monitoring_infos.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.metrics.rst.txt | 18 + .../apache_beam.ml.anomaly.aggregations.rst.txt | 7 + .../_sources/apache_beam.ml.anomaly.base.rst.txt | 7 + .../apache_beam.ml.anomaly.detectors.iqr.rst.txt | 7 + ...pache_beam.ml.anomaly.detectors.offline.rst.txt | 7 + ..._beam.ml.anomaly.detectors.pyod_adapter.rst.txt | 7 + ...beam.ml.anomaly.detectors.robust_zscore.rst.txt | 7 + .../apache_beam.ml.anomaly.detectors.rst.txt | 19 + ...apache_beam.ml.anomaly.detectors.zscore.rst.txt | 7 + .../2.66.0/_sources/apache_beam.ml.anomaly.rst.txt | 28 + .../apache_beam.ml.anomaly.specifiable.rst.txt | 7 + .../apache_beam.ml.anomaly.thresholds.rst.txt | 7 + .../apache_beam.ml.anomaly.transforms.rst.txt | 7 + .../apache_beam.ml.anomaly.univariate.base.rst.txt | 7 + .../apache_beam.ml.anomaly.univariate.mad.rst.txt | 7 + .../apache_beam.ml.anomaly.univariate.mean.rst.txt | 7 + ...pache_beam.ml.anomaly.univariate.median.rst.txt | 7 + ...che_beam.ml.anomaly.univariate.quantile.rst.txt | 7 + .../apache_beam.ml.anomaly.univariate.rst.txt | 20 + ...apache_beam.ml.anomaly.univariate.stdev.rst.txt | 7 + .../_sources/apache_beam.ml.gcp.cloud_dlp.rst.txt | 7 + .../apache_beam.ml.gcp.naturallanguageml.rst.txt | 7 + .../apache_beam.ml.gcp.recommendations_ai.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.ml.gcp.rst.txt | 19 + .../apache_beam.ml.gcp.videointelligenceml.rst.txt | 7 + .../_sources/apache_beam.ml.gcp.visionml.rst.txt | 7 + .../_sources/apache_beam.ml.inference.base.rst.txt | 7 + ...ache_beam.ml.inference.gemini_inference.rst.txt | 7 + ...beam.ml.inference.huggingface_inference.rst.txt | 7 + ...apache_beam.ml.inference.onnx_inference.rst.txt | 7 + ...che_beam.ml.inference.pytorch_inference.rst.txt | 7 + .../_sources/apache_beam.ml.inference.rst.txt | 26 + ...che_beam.ml.inference.sklearn_inference.rst.txt | 7 + ..._beam.ml.inference.tensorflow_inference.rst.txt | 7 + ...he_beam.ml.inference.tensorrt_inference.rst.txt | 7 + .../apache_beam.ml.inference.utils.rst.txt | 7 + ...e_beam.ml.inference.vertex_ai_inference.rst.txt | 7 + ...apache_beam.ml.inference.vllm_inference.rst.txt | 7 + ...che_beam.ml.inference.xgboost_inference.rst.txt | 7 + .../apache_beam.ml.rag.chunking.base.rst.txt | 7 + .../apache_beam.ml.rag.chunking.langchain.rst.txt | 7 + .../_sources/apache_beam.ml.rag.chunking.rst.txt | 16 + .../apache_beam.ml.rag.embeddings.base.rst.txt | 7 + ...ache_beam.ml.rag.embeddings.huggingface.rst.txt | 7 + .../_sources/apache_beam.ml.rag.embeddings.rst.txt | 17 + ...apache_beam.ml.rag.embeddings.vertex_ai.rst.txt | 7 + ...l.rag.enrichment.bigquery_vector_search.rst.txt | 7 + .../_sources/apache_beam.ml.rag.enrichment.rst.txt | 15 + .../apache_beam.ml.rag.ingestion.alloydb.rst.txt | 7 + .../apache_beam.ml.rag.ingestion.base.rst.txt | 7 + .../apache_beam.ml.rag.ingestion.bigquery.rst.txt | 7 + .../apache_beam.ml.rag.ingestion.cloudsql.rst.txt | 7 + ...pache_beam.ml.rag.ingestion.jdbc_common.rst.txt | 7 + .../apache_beam.ml.rag.ingestion.postgres.rst.txt | 7 + ...e_beam.ml.rag.ingestion.postgres_common.rst.txt | 7 + .../_sources/apache_beam.ml.rag.ingestion.rst.txt | 22 + ...apache_beam.ml.rag.ingestion.test_utils.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.ml.rag.rst.txt | 26 + .../_sources/apache_beam.ml.rag.types.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.ml.rst.txt | 19 + .../apache_beam.ml.transforms.base.rst.txt | 7 + ...am.ml.transforms.embeddings.huggingface.rst.txt | 7 + ...e_beam.ml.transforms.embeddings.open_ai.rst.txt | 7 + .../apache_beam.ml.transforms.embeddings.rst.txt | 18 + ...ml.transforms.embeddings.tensorflow_hub.rst.txt | 7 + ...beam.ml.transforms.embeddings.vertex_ai.rst.txt | 7 + .../apache_beam.ml.transforms.handlers.rst.txt | 7 + .../_sources/apache_beam.ml.transforms.rst.txt | 26 + .../_sources/apache_beam.ml.transforms.tft.rst.txt | 7 + .../apache_beam.ml.transforms.utils.rst.txt | 7 + .../apache_beam.options.pipeline_options.rst.txt | 7 + ...beam.options.pipeline_options_validator.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.options.rst.txt | 17 + .../apache_beam.options.value_provider.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.pipeline.rst.txt | 7 + ....api.org.apache.beam.model.fn_execution.rst.txt | 15 + ...el.fn_execution.v1.beam_fn_api_pb2_grpc.rst.txt | 7 + ...el.fn_execution.v1.beam_fn_api_pb2_urns.rst.txt | 7 + ...xecution.v1.beam_provision_api_pb2_grpc.rst.txt | 7 + ...i.org.apache.beam.model.fn_execution.v1.rst.txt | 17 + ...y.api.org.apache.beam.model.interactive.rst.txt | 15 + ...active.v1.beam_interactive_api_pb2_grpc.rst.txt | 7 + ...pi.org.apache.beam.model.interactive.v1.rst.txt | 15 + ...pi.org.apache.beam.model.job_management.rst.txt | 15 + ...anagement.v1.beam_artifact_api_pb2_grpc.rst.txt | 7 + ...anagement.v1.beam_artifact_api_pb2_urns.rst.txt | 7 + ...nagement.v1.beam_expansion_api_pb2_grpc.rst.txt | 7 + ...job_management.v1.beam_job_api_pb2_grpc.rst.txt | 7 + ...org.apache.beam.model.job_management.v1.rst.txt | 18 + ...lity.api.org.apache.beam.model.pipeline.rst.txt | 15 + ...el.pipeline.v1.beam_runner_api_pb2_grpc.rst.txt | 7 + ...el.pipeline.v1.beam_runner_api_pb2_urns.rst.txt | 7 + ...am.model.pipeline.v1.endpoints_pb2_grpc.rst.txt | 7 + ...ipeline.v1.external_transforms_pb2_grpc.rst.txt | 7 + ...ipeline.v1.external_transforms_pb2_urns.rst.txt | 7 + ...beam.model.pipeline.v1.metrics_pb2_grpc.rst.txt | 7 + ...beam.model.pipeline.v1.metrics_pb2_urns.rst.txt | 7 + ...y.api.org.apache.beam.model.pipeline.v1.rst.txt | 25 + ....beam.model.pipeline.v1.schema_pb2_grpc.rst.txt | 7 + ....beam.model.pipeline.v1.schema_pb2_urns.rst.txt | 7 + ...ipeline.v1.standard_window_fns_pb2_grpc.rst.txt | 7 + ...ipeline.v1.standard_window_fns_pb2_urns.rst.txt | 7 + ...m.portability.api.org.apache.beam.model.rst.txt | 18 + ...he_beam.portability.api.org.apache.beam.rst.txt | 15 + .../apache_beam.portability.api.org.apache.rst.txt | 15 + .../apache_beam.portability.api.org.rst.txt | 15 + .../_sources/apache_beam.portability.api.rst.txt | 15 + .../apache_beam.portability.common_urns.rst.txt | 7 + .../apache_beam.portability.python_urns.rst.txt | 7 + .../_sources/apache_beam.portability.rst.txt | 25 + .../_sources/apache_beam.portability.utils.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.pvalue.rst.txt | 7 + .../apache_beam.runners.dask.dask_runner.rst.txt | 7 + .../apache_beam.runners.dask.overrides.rst.txt | 7 + .../_sources/apache_beam.runners.dask.rst.txt | 16 + ...flow.dataflow_exercise_metrics_pipeline.rst.txt | 7 + ...low_exercise_streaming_metrics_pipeline.rst.txt | 7 + ...m.runners.dataflow.dataflow_job_service.rst.txt | 7 + ..._beam.runners.dataflow.dataflow_metrics.rst.txt | 7 + ...e_beam.runners.dataflow.dataflow_runner.rst.txt | 7 + ...m.runners.dataflow.ptransform_overrides.rst.txt | 7 + .../_sources/apache_beam.runners.dataflow.rst.txt | 21 + ...m.runners.dataflow.test_dataflow_runner.rst.txt | 7 + ...ache_beam.runners.direct.bundle_factory.rst.txt | 7 + .../apache_beam.runners.direct.clock.rst.txt | 7 + ...rect.consumer_tracking_pipeline_visitor.rst.txt | 7 + ...ache_beam.runners.direct.direct_metrics.rst.txt | 7 + ...pache_beam.runners.direct.direct_runner.rst.txt | 7 + ...he_beam.runners.direct.direct_userstate.rst.txt | 7 + ..._beam.runners.direct.evaluation_context.rst.txt | 7 + .../apache_beam.runners.direct.executor.rst.txt | 7 + ...e_beam.runners.direct.helper_transforms.rst.txt | 7 + .../_sources/apache_beam.runners.direct.rst.txt | 29 + ...e_beam.runners.direct.sdf_direct_runner.rst.txt | 7 + ..._beam.runners.direct.test_direct_runner.rst.txt | 7 + ...he_beam.runners.direct.test_stream_impl.rst.txt | 7 + ...beam.runners.direct.transform_evaluator.rst.txt | 7 + .../apache_beam.runners.direct.util.rst.txt | 7 + ...e_beam.runners.direct.watermark_manager.rst.txt | 7 + ....runners.interactive.augmented_pipeline.rst.txt | 7 + ...ners.interactive.background_caching_job.rst.txt | 7 + ..._beam.runners.interactive.cache_manager.rst.txt | 7 + ...m.runners.interactive.caching.cacheable.rst.txt | 7 + ...rs.interactive.caching.expression_cache.rst.txt | 7 + ....runners.interactive.caching.read_cache.rst.txt | 7 + ..._beam.runners.interactive.caching.reify.rst.txt | 7 + ...apache_beam.runners.interactive.caching.rst.txt | 20 + ...ers.interactive.caching.streaming_cache.rst.txt | 7 + ...runners.interactive.caching.write_cache.rst.txt | 7 + ...ctive.dataproc.dataproc_cluster_manager.rst.txt | 7 + ...pache_beam.runners.interactive.dataproc.rst.txt | 16 + ...beam.runners.interactive.dataproc.types.rst.txt | 7 + ...ers.interactive.display.display_manager.rst.txt | 7 + ...tive.display.interactive_pipeline_graph.rst.txt | 7 + ...interactive.display.pcoll_visualization.rst.txt | 7 + ...ners.interactive.display.pipeline_graph.rst.txt | 7 + ...ractive.display.pipeline_graph_renderer.rst.txt | 7 + ...apache_beam.runners.interactive.display.rst.txt | 19 + ...am.runners.interactive.interactive_beam.rst.txt | 7 + ...ers.interactive.interactive_environment.rst.txt | 7 + ....runners.interactive.interactive_runner.rst.txt | 7 + ...aging.interactive_environment_inspector.rst.txt | 7 + ...ache_beam.runners.interactive.messaging.rst.txt | 15 + ...ers.interactive.options.capture_control.rst.txt | 7 + ...rs.interactive.options.capture_limiters.rst.txt | 7 + ...interactive.options.interactive_options.rst.txt | 7 + ...apache_beam.runners.interactive.options.rst.txt | 17 + ...m.runners.interactive.pipeline_fragment.rst.txt | 7 + ...runners.interactive.pipeline_instrument.rst.txt | 7 + ...m.runners.interactive.recording_manager.rst.txt | 7 + .../apache_beam.runners.interactive.rst.txt | 39 + ...runners.interactive.sql.beam_sql_magics.rst.txt | 7 + .../apache_beam.runners.interactive.sql.rst.txt | 17 + ..._beam.runners.interactive.sql.sql_chain.rst.txt | 7 + ...ache_beam.runners.interactive.sql.utils.rst.txt | 7 + ...e.testing.integration.notebook_executor.rst.txt | 7 + ...runners.interactive.testing.integration.rst.txt | 16 + ...ractive.testing.integration.screen_diff.rst.txt | 7 + ...am.runners.interactive.testing.mock_env.rst.txt | 7 + ...unners.interactive.testing.mock_ipython.rst.txt | 7 + ....interactive.testing.pipeline_assertion.rst.txt | 7 + ...apache_beam.runners.interactive.testing.rst.txt | 26 + ....interactive.testing.test_cache_manager.rst.txt | 7 + ...nners.interactive.user_pipeline_tracker.rst.txt | 7 + .../apache_beam.runners.interactive.utils.rst.txt | 7 + .../apache_beam.runners.job.manager.rst.txt | 7 + .../_sources/apache_beam.runners.job.rst.txt | 16 + .../_sources/apache_beam.runners.job.utils.rst.txt | 7 + .../apache_beam.runners.pipeline_context.rst.txt | 7 + .../apache_beam.runners.pipeline_utils.rst.txt | 7 + .../_sources/apache_beam.runners.render.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.runners.rst.txt | 32 + .../_sources/apache_beam.runners.runner.rst.txt | 7 + .../_sources/apache_beam.runners.sdf_utils.rst.txt | 7 + .../apache_beam.runners.trivial_runner.rst.txt | 7 + ...g.benchmarks.nexmark.models.auction_bid.rst.txt | 7 + ...ng.benchmarks.nexmark.models.field_name.rst.txt | 7 + ...benchmarks.nexmark.models.nexmark_model.rst.txt | 7 + ..._beam.testing.benchmarks.nexmark.models.rst.txt | 17 + ...beam.testing.benchmarks.nexmark.monitor.rst.txt | 7 + ...ing.benchmarks.nexmark.nexmark_launcher.rst.txt | 7 + ...testing.benchmarks.nexmark.nexmark_perf.rst.txt | 7 + ...testing.benchmarks.nexmark.nexmark_util.rst.txt | 7 + ...arks.nexmark.queries.nexmark_query_util.rst.txt | 7 + ...sting.benchmarks.nexmark.queries.query0.rst.txt | 7 + ...sting.benchmarks.nexmark.queries.query1.rst.txt | 7 + ...ting.benchmarks.nexmark.queries.query10.rst.txt | 7 + ...ting.benchmarks.nexmark.queries.query11.rst.txt | 7 + ...ting.benchmarks.nexmark.queries.query12.rst.txt | 7 + ...sting.benchmarks.nexmark.queries.query2.rst.txt | 7 + ...sting.benchmarks.nexmark.queries.query3.rst.txt | 7 + ...sting.benchmarks.nexmark.queries.query4.rst.txt | 7 + ...sting.benchmarks.nexmark.queries.query5.rst.txt | 7 + ...sting.benchmarks.nexmark.queries.query6.rst.txt | 7 + ...sting.benchmarks.nexmark.queries.query7.rst.txt | 7 + ...sting.benchmarks.nexmark.queries.query8.rst.txt | 7 + ...sting.benchmarks.nexmark.queries.query9.rst.txt | 7 + ...beam.testing.benchmarks.nexmark.queries.rst.txt | 29 + ...benchmarks.nexmark.queries.winning_bids.rst.txt | 7 + .../apache_beam.testing.benchmarks.nexmark.rst.txt | 27 + .../apache_beam.testing.benchmarks.rst.txt | 16 + ...pache_beam.testing.benchmarks.wordcount.rst.txt | 15 + ....testing.benchmarks.wordcount.wordcount.rst.txt | 7 + .../apache_beam.testing.datatype_inference.rst.txt | 7 + .../apache_beam.testing.extra_assertions.rst.txt | 7 + ...ting.load_tests.dataflow_cost_benchmark.rst.txt | 7 + ...testing.load_tests.dataflow_cost_consts.rst.txt | 7 + ...ting.load_tests.load_test_metrics_utils.rst.txt | 7 + .../apache_beam.testing.load_tests.rst.txt | 17 + ...che_beam.testing.metric_result_matchers.rst.txt | 7 + .../apache_beam.testing.pipeline_verifiers.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.testing.rst.txt | 33 + .../apache_beam.testing.synthetic_pipeline.rst.txt | 7 + .../apache_beam.testing.test_pipeline.rst.txt | 7 + .../apache_beam.testing.test_stream.rst.txt | 7 + ...apache_beam.testing.test_stream_service.rst.txt | 7 + .../apache_beam.testing.test_utils.rst.txt | 7 + .../_sources/apache_beam.testing.util.rst.txt | 7 + ...transforms.combinefn_lifecycle_pipeline.rst.txt | 7 + .../apache_beam.transforms.combiners.rst.txt | 7 + .../_sources/apache_beam.transforms.core.rst.txt | 7 + .../apache_beam.transforms.create_source.rst.txt | 7 + .../apache_beam.transforms.deduplicate.rst.txt | 7 + .../apache_beam.transforms.display.rst.txt | 7 + .../apache_beam.transforms.enrichment.rst.txt | 7 + ...transforms.enrichment_handlers.bigquery.rst.txt | 7 + ...transforms.enrichment_handlers.bigtable.rst.txt | 7 + ...enrichment_handlers.feast_feature_store.rst.txt | 7 + ...che_beam.transforms.enrichment_handlers.rst.txt | 19 + ...am.transforms.enrichment_handlers.utils.rst.txt | 7 + ...chment_handlers.vertex_ai_feature_store.rst.txt | 7 + .../apache_beam.transforms.environments.rst.txt | 7 + .../apache_beam.transforms.error_handling.rst.txt | 7 + .../apache_beam.transforms.external.rst.txt | 7 + .../apache_beam.transforms.external_java.rst.txt | 7 + ....transforms.external_transform_provider.rst.txt | 7 + ...nsforms.fully_qualified_named_transform.rst.txt | 7 + .../apache_beam.transforms.managed.rst.txt | 7 + ...apache_beam.transforms.periodicsequence.rst.txt | 7 + .../apache_beam.transforms.ptransform.rst.txt | 7 + .../apache_beam.transforms.resources.rst.txt | 7 + .../2.66.0/_sources/apache_beam.transforms.rst.txt | 48 + .../apache_beam.transforms.sideinputs.rst.txt | 7 + .../_sources/apache_beam.transforms.sql.rst.txt | 7 + .../_sources/apache_beam.transforms.stats.rst.txt | 7 + .../apache_beam.transforms.timeutil.rst.txt | 7 + .../apache_beam.transforms.trigger.rst.txt | 7 + .../apache_beam.transforms.userstate.rst.txt | 7 + .../_sources/apache_beam.transforms.util.rst.txt | 7 + .../_sources/apache_beam.transforms.window.rst.txt | 7 + .../apache_beam.transforms.xlang.io.rst.txt | 7 + .../_sources/apache_beam.transforms.xlang.rst.txt | 15 + ...typehints.arrow_batching_microbenchmark.rst.txt | 7 + ...beam.typehints.arrow_type_compatibility.rst.txt | 7 + .../_sources/apache_beam.typehints.batch.rst.txt | 7 + .../apache_beam.typehints.decorators.rst.txt | 7 + ...apache_beam.typehints.intrinsic_one_ops.rst.txt | 7 + ...eam.typehints.native_type_compatibility.rst.txt | 7 + .../_sources/apache_beam.typehints.opcodes.rst.txt | 7 + ...eam.typehints.pandas_type_compatibility.rst.txt | 7 + ...am.typehints.pytorch_type_compatibility.rst.txt | 7 + .../apache_beam.typehints.row_type.rst.txt | 7 + .../2.66.0/_sources/apache_beam.typehints.rst.txt | 38 + .../apache_beam.typehints.schema_registry.rst.txt | 7 + .../_sources/apache_beam.typehints.schemas.rst.txt | 7 + .../apache_beam.typehints.sharded_key_type.rst.txt | 7 + .../_sources/apache_beam.typehints.testing.rst.txt | 15 + ...pache_beam.typehints.testing.strategies.rst.txt | 7 + ...apache_beam.typehints.trivial_inference.rst.txt | 7 + .../apache_beam.typehints.typecheck.rst.txt | 7 + .../apache_beam.typehints.typehints.rst.txt | 7 + .../_sources/apache_beam.utils.annotations.rst.txt | 7 + .../_sources/apache_beam.utils.histogram.rst.txt | 7 + .../apache_beam.utils.interactive_utils.rst.txt | 7 + .../apache_beam.utils.multi_process_shared.rst.txt | 7 + .../_sources/apache_beam.utils.plugin.rst.txt | 7 + .../_sources/apache_beam.utils.processes.rst.txt | 7 + .../_sources/apache_beam.utils.profiler.rst.txt | 7 + .../_sources/apache_beam.utils.proto_utils.rst.txt | 7 + .../apache_beam.utils.python_callable.rst.txt | 7 + .../_sources/apache_beam.utils.retry.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.utils.rst.txt | 32 + .../_sources/apache_beam.utils.sentinel.rst.txt | 7 + .../_sources/apache_beam.utils.sharded_key.rst.txt | 7 + .../_sources/apache_beam.utils.shared.rst.txt | 7 + .../apache_beam.utils.subprocess_server.rst.txt | 7 + .../apache_beam.utils.thread_pool_executor.rst.txt | 7 + .../_sources/apache_beam.utils.timestamp.rst.txt | 7 + ...e_beam.utils.transform_service_launcher.rst.txt | 7 + .../2.66.0/_sources/apache_beam.utils.urns.rst.txt | 7 + ...ache_beam.yaml.cache_provider_artifacts.rst.txt | 7 + .../_sources/apache_beam.yaml.conftest.rst.txt | 7 + .../_sources/apache_beam.yaml.examples.rst.txt | 15 + ...e_beam.yaml.examples.testing.input_data.rst.txt | 7 + .../apache_beam.yaml.examples.testing.rst.txt | 15 + .../apache_beam.yaml.generate_yaml_docs.rst.txt | 7 + .../_sources/apache_beam.yaml.json_utils.rst.txt | 7 + .../2.66.0/_sources/apache_beam.yaml.main.rst.txt | 7 + .../_sources/apache_beam.yaml.options.rst.txt | 7 + pydoc/2.66.0/_sources/apache_beam.yaml.rst.txt | 40 + .../_sources/apache_beam.yaml.yaml_combine.rst.txt | 7 + .../apache_beam.yaml.yaml_enrichment.rst.txt | 7 + .../_sources/apache_beam.yaml.yaml_errors.rst.txt | 7 + .../_sources/apache_beam.yaml.yaml_io.rst.txt | 7 + .../_sources/apache_beam.yaml.yaml_join.rst.txt | 7 + .../_sources/apache_beam.yaml.yaml_mapping.rst.txt | 7 + .../_sources/apache_beam.yaml.yaml_ml.rst.txt | 7 + .../apache_beam.yaml.yaml_provider.rst.txt | 7 + .../apache_beam.yaml.yaml_specifiable.rst.txt | 7 + .../_sources/apache_beam.yaml.yaml_testing.rst.txt | 7 + .../apache_beam.yaml.yaml_transform.rst.txt | 7 + .../_sources/apache_beam.yaml.yaml_utils.rst.txt | 7 + pydoc/2.66.0/_sources/index.rst.txt | 2 + .../_sphinx_javascript_frameworks_compat.js | 123 + pydoc/2.66.0/_static/basic.css | 925 + pydoc/2.66.0/_static/css/badge_only.css | 1 + .../2.66.0/_static/css/fonts/Roboto-Slab-Bold.woff | Bin 0 -> 87624 bytes .../_static/css/fonts/Roboto-Slab-Bold.woff2 | Bin 0 -> 67312 bytes .../_static/css/fonts/Roboto-Slab-Regular.woff | Bin 0 -> 86288 bytes .../_static/css/fonts/Roboto-Slab-Regular.woff2 | Bin 0 -> 66444 bytes .../_static/css/fonts/fontawesome-webfont.eot | Bin 0 -> 165742 bytes .../_static/css/fonts/fontawesome-webfont.svg | 2671 +++ .../_static/css/fonts/fontawesome-webfont.ttf | Bin 0 -> 165548 bytes .../_static/css/fonts/fontawesome-webfont.woff | Bin 0 -> 98024 bytes .../_static/css/fonts/fontawesome-webfont.woff2 | Bin 0 -> 77160 bytes .../2.66.0/_static/css/fonts/lato-bold-italic.woff | Bin 0 -> 323344 bytes .../_static/css/fonts/lato-bold-italic.woff2 | Bin 0 -> 193308 bytes pydoc/2.66.0/_static/css/fonts/lato-bold.woff | Bin 0 -> 309728 bytes pydoc/2.66.0/_static/css/fonts/lato-bold.woff2 | Bin 0 -> 184912 bytes .../_static/css/fonts/lato-normal-italic.woff | Bin 0 -> 328412 bytes .../_static/css/fonts/lato-normal-italic.woff2 | Bin 0 -> 195704 bytes pydoc/2.66.0/_static/css/fonts/lato-normal.woff | Bin 0 -> 309192 bytes pydoc/2.66.0/_static/css/fonts/lato-normal.woff2 | Bin 0 -> 182708 bytes pydoc/2.66.0/_static/css/theme.css | 4 + pydoc/2.66.0/_static/doctools.js | 156 + pydoc/2.66.0/_static/documentation_options.js | 13 + pydoc/2.66.0/_static/file.png | Bin 0 -> 286 bytes pydoc/2.66.0/_static/fonts/Lato/lato-bold.eot | Bin 0 -> 256056 bytes pydoc/2.66.0/_static/fonts/Lato/lato-bold.ttf | Bin 0 -> 600856 bytes pydoc/2.66.0/_static/fonts/Lato/lato-bold.woff | Bin 0 -> 309728 bytes pydoc/2.66.0/_static/fonts/Lato/lato-bold.woff2 | Bin 0 -> 184912 bytes .../2.66.0/_static/fonts/Lato/lato-bolditalic.eot | Bin 0 -> 266158 bytes .../2.66.0/_static/fonts/Lato/lato-bolditalic.ttf | Bin 0 -> 622572 bytes .../2.66.0/_static/fonts/Lato/lato-bolditalic.woff | Bin 0 -> 323344 bytes .../_static/fonts/Lato/lato-bolditalic.woff2 | Bin 0 -> 193308 bytes pydoc/2.66.0/_static/fonts/Lato/lato-italic.eot | Bin 0 -> 268604 bytes pydoc/2.66.0/_static/fonts/Lato/lato-italic.ttf | Bin 0 -> 639388 bytes pydoc/2.66.0/_static/fonts/Lato/lato-italic.woff | Bin 0 -> 328412 bytes pydoc/2.66.0/_static/fonts/Lato/lato-italic.woff2 | Bin 0 -> 195704 bytes pydoc/2.66.0/_static/fonts/Lato/lato-regular.eot | Bin 0 -> 253461 bytes pydoc/2.66.0/_static/fonts/Lato/lato-regular.ttf | Bin 0 -> 607720 bytes pydoc/2.66.0/_static/fonts/Lato/lato-regular.woff | Bin 0 -> 309192 bytes pydoc/2.66.0/_static/fonts/Lato/lato-regular.woff2 | Bin 0 -> 182708 bytes .../fonts/RobotoSlab/roboto-slab-v7-bold.eot | Bin 0 -> 79520 bytes .../fonts/RobotoSlab/roboto-slab-v7-bold.ttf | Bin 0 -> 170616 bytes .../fonts/RobotoSlab/roboto-slab-v7-bold.woff | Bin 0 -> 87624 bytes .../fonts/RobotoSlab/roboto-slab-v7-bold.woff2 | Bin 0 -> 67312 bytes .../fonts/RobotoSlab/roboto-slab-v7-regular.eot | Bin 0 -> 78331 bytes .../fonts/RobotoSlab/roboto-slab-v7-regular.ttf | Bin 0 -> 169064 bytes .../fonts/RobotoSlab/roboto-slab-v7-regular.woff | Bin 0 -> 86288 bytes .../fonts/RobotoSlab/roboto-slab-v7-regular.woff2 | Bin 0 -> 66444 bytes pydoc/2.66.0/_static/jquery.js | 2 + pydoc/2.66.0/_static/js/badge_only.js | 1 + pydoc/2.66.0/_static/js/theme.js | 1 + pydoc/2.66.0/_static/js/versions.js | 224 + pydoc/2.66.0/_static/language_data.js | 199 + pydoc/2.66.0/_static/minus.png | Bin 0 -> 90 bytes pydoc/2.66.0/_static/plus.png | Bin 0 -> 90 bytes pydoc/2.66.0/_static/pygments.css | 75 + pydoc/2.66.0/_static/searchtools.js | 620 + pydoc/2.66.0/_static/sphinx_highlight.js | 154 + pydoc/2.66.0/apache_beam.coders.avro_record.html | 148 + pydoc/2.66.0/apache_beam.coders.coders.html | 953 + pydoc/2.66.0/apache_beam.coders.html | 397 + pydoc/2.66.0/apache_beam.coders.observable.html | 161 + pydoc/2.66.0/apache_beam.coders.row_coder.html | 191 + pydoc/2.66.0/apache_beam.coders.slow_stream.html | 316 + pydoc/2.66.0/apache_beam.coders.typecoders.html | 184 + pydoc/2.66.0/apache_beam.dataframe.convert.html | 259 + pydoc/2.66.0/apache_beam.dataframe.doctests.html | 383 + .../2.66.0/apache_beam.dataframe.expressions.html | 433 + pydoc/2.66.0/apache_beam.dataframe.frame_base.html | 296 + pydoc/2.66.0/apache_beam.dataframe.frames.html | 20903 +++++++++++++++++++ pydoc/2.66.0/apache_beam.dataframe.html | 738 + pydoc/2.66.0/apache_beam.dataframe.io.html | 2582 +++ ..._beam.dataframe.pandas_top_level_functions.html | 286 + .../apache_beam.dataframe.partitionings.html | 290 + pydoc/2.66.0/apache_beam.dataframe.schemas.html | 205 + pydoc/2.66.0/apache_beam.dataframe.transforms.html | 195 + pydoc/2.66.0/apache_beam.error.html | 184 + pydoc/2.66.0/apache_beam.io.avroio.html | 379 + pydoc/2.66.0/apache_beam.io.aws.clients.html | 183 + ...apache_beam.io.aws.clients.s3.boto3_client.html | 285 + .../apache_beam.io.aws.clients.s3.fake_client.html | 240 + pydoc/2.66.0/apache_beam.io.aws.clients.s3.html | 207 + .../apache_beam.io.aws.clients.s3.messages.html | 239 + pydoc/2.66.0/apache_beam.io.aws.html | 223 + pydoc/2.66.0/apache_beam.io.aws.s3filesystem.html | 387 + pydoc/2.66.0/apache_beam.io.aws.s3io.html | 456 + ...apache_beam.io.azure.blobstoragefilesystem.html | 389 + .../2.66.0/apache_beam.io.azure.blobstorageio.html | 492 + pydoc/2.66.0/apache_beam.io.azure.html | 209 + ...ache_beam.io.components.adaptive_throttler.html | 201 + pydoc/2.66.0/apache_beam.io.components.html | 167 + pydoc/2.66.0/apache_beam.io.components.util.html | 174 + pydoc/2.66.0/apache_beam.io.concat_source.html | 272 + pydoc/2.66.0/apache_beam.io.debezium.html | 278 + pydoc/2.66.0/apache_beam.io.external.gcp.html | 177 + .../2.66.0/apache_beam.io.external.gcp.pubsub.html | 297 + .../apache_beam.io.external.generate_sequence.html | 170 + pydoc/2.66.0/apache_beam.io.external.html | 178 + pydoc/2.66.0/apache_beam.io.external.kafka.html | 143 + .../2.66.0/apache_beam.io.external.snowflake.html | 143 + pydoc/2.66.0/apache_beam.io.filebasedsink.html | 242 + pydoc/2.66.0/apache_beam.io.filebasedsource.html | 284 + pydoc/2.66.0/apache_beam.io.fileio.html | 417 + pydoc/2.66.0/apache_beam.io.filesystem.html | 682 + pydoc/2.66.0/apache_beam.io.filesystemio.html | 404 + pydoc/2.66.0/apache_beam.io.filesystems.html | 456 + ...am.io.flink.flink_streaming_impulse_source.html | 198 + pydoc/2.66.0/apache_beam.io.flink.html | 163 + ...m.io.gcp.big_query_query_to_table_pipeline.html | 157 + pydoc/2.66.0/apache_beam.io.gcp.bigquery.html | 1102 + .../apache_beam.io.gcp.bigquery_avro_tools.html | 185 + .../apache_beam.io.gcp.bigquery_file_loads.html | 450 + .../apache_beam.io.gcp.bigquery_io_metadata.html | 165 + ...ache_beam.io.gcp.bigquery_io_read_pipeline.html | 161 + .../apache_beam.io.gcp.bigquery_read_internal.html | 183 + .../apache_beam.io.gcp.bigquery_schema_tools.html | 189 + .../2.66.0/apache_beam.io.gcp.bigquery_tools.html | 850 + pydoc/2.66.0/apache_beam.io.gcp.bigtableio.html | 238 + pydoc/2.66.0/apache_beam.io.gcp.datastore.html | 196 + ...atastore.v1new.datastore_write_it_pipeline.html | 183 + ...he_beam.io.gcp.datastore.v1new.datastoreio.html | 256 + .../apache_beam.io.gcp.datastore.v1new.helper.html | 171 + .../2.66.0/apache_beam.io.gcp.datastore.v1new.html | 223 + ...beam.io.gcp.datastore.v1new.query_splitter.html | 192 + ...o.gcp.datastore.v1new.rampup_throttling_fn.html | 167 + .../apache_beam.io.gcp.datastore.v1new.types.html | 262 + .../apache_beam.io.gcp.datastore.v1new.util.html | 205 + pydoc/2.66.0/apache_beam.io.gcp.dicomclient.html | 143 + pydoc/2.66.0/apache_beam.io.gcp.dicomio.html | 143 + pydoc/2.66.0/apache_beam.io.gcp.experimental.html | 182 + .../apache_beam.io.gcp.experimental.spannerio.html | 579 + .../apache_beam.io.gcp.gce_metadata_util.html | 149 + pydoc/2.66.0/apache_beam.io.gcp.gcsfilesystem.html | 388 + pydoc/2.66.0/apache_beam.io.gcp.gcsio.html | 414 + pydoc/2.66.0/apache_beam.io.gcp.gcsio_retry.html | 144 + .../apache_beam.io.gcp.healthcare.dicomclient.html | 180 + .../apache_beam.io.gcp.healthcare.dicomio.html | 388 + pydoc/2.66.0/apache_beam.io.gcp.healthcare.html | 179 + pydoc/2.66.0/apache_beam.io.gcp.html | 685 + pydoc/2.66.0/apache_beam.io.gcp.pubsub.html | 435 + .../apache_beam.io.gcp.pubsub_it_pipeline.html | 150 + .../apache_beam.io.gcp.pubsublite.external.html | 146 + pydoc/2.66.0/apache_beam.io.gcp.pubsublite.html | 211 + .../apache_beam.io.gcp.pubsublite.proto_api.html | 193 + .../apache_beam.io.gcp.resource_identifiers.html | 185 + pydoc/2.66.0/apache_beam.io.gcp.spanner.html | 728 + .../2.66.0/apache_beam.io.gcp.spanner_wrapper.html | 154 + pydoc/2.66.0/apache_beam.io.hadoopfilesystem.html | 333 + pydoc/2.66.0/apache_beam.io.html | 1168 ++ pydoc/2.66.0/apache_beam.io.iobase.html | 1357 ++ pydoc/2.66.0/apache_beam.io.jdbc.html | 366 + pydoc/2.66.0/apache_beam.io.kafka.html | 480 + pydoc/2.66.0/apache_beam.io.kinesis.html | 354 + pydoc/2.66.0/apache_beam.io.localfilesystem.html | 400 + pydoc/2.66.0/apache_beam.io.mongodbio.html | 289 + pydoc/2.66.0/apache_beam.io.parquetio.html | 473 + pydoc/2.66.0/apache_beam.io.range_trackers.html | 384 + pydoc/2.66.0/apache_beam.io.requestresponse.html | 311 + .../apache_beam.io.restriction_trackers.html | 250 + pydoc/2.66.0/apache_beam.io.snowflake.html | 470 + pydoc/2.66.0/apache_beam.io.source_test_utils.html | 393 + pydoc/2.66.0/apache_beam.io.textio.html | 1191 ++ pydoc/2.66.0/apache_beam.io.tfrecordio.html | 258 + pydoc/2.66.0/apache_beam.io.utils.html | 190 + .../apache_beam.io.watermark_estimators.html | 270 + pydoc/2.66.0/apache_beam.metrics.cells.html | 237 + pydoc/2.66.0/apache_beam.metrics.html | 273 + pydoc/2.66.0/apache_beam.metrics.metric.html | 439 + pydoc/2.66.0/apache_beam.metrics.metricbase.html | 290 + .../apache_beam.metrics.monitoring_infos.html | 434 + .../apache_beam.ml.anomaly.aggregations.html | 651 + pydoc/2.66.0/apache_beam.ml.anomaly.base.html | 358 + pydoc/2.66.0/apache_beam.ml.anomaly.detectors.html | 208 + .../apache_beam.ml.anomaly.detectors.iqr.html | 269 + .../apache_beam.ml.anomaly.detectors.offline.html | 273 + ...che_beam.ml.anomaly.detectors.pyod_adapter.html | 142 + ...he_beam.ml.anomaly.detectors.robust_zscore.html | 282 + .../apache_beam.ml.anomaly.detectors.zscore.html | 281 + pydoc/2.66.0/apache_beam.ml.anomaly.html | 390 + .../2.66.0/apache_beam.ml.anomaly.specifiable.html | 260 + .../2.66.0/apache_beam.ml.anomaly.thresholds.html | 425 + .../2.66.0/apache_beam.ml.anomaly.transforms.html | 289 + .../apache_beam.ml.anomaly.univariate.base.html | 234 + .../2.66.0/apache_beam.ml.anomaly.univariate.html | 317 + .../apache_beam.ml.anomaly.univariate.mad.html | 282 + .../apache_beam.ml.anomaly.univariate.mean.html | 438 + .../apache_beam.ml.anomaly.univariate.median.html | 251 + ...apache_beam.ml.anomaly.univariate.quantile.html | 561 + .../apache_beam.ml.anomaly.univariate.stdev.html | 436 + pydoc/2.66.0/apache_beam.ml.gcp.cloud_dlp.html | 231 + pydoc/2.66.0/apache_beam.ml.gcp.html | 212 + .../apache_beam.ml.gcp.naturallanguageml.html | 194 + .../apache_beam.ml.gcp.recommendations_ai.html | 347 + .../apache_beam.ml.gcp.videointelligenceml.html | 235 + pydoc/2.66.0/apache_beam.ml.gcp.visionml.html | 265 + pydoc/2.66.0/apache_beam.ml.html | 388 + pydoc/2.66.0/apache_beam.ml.inference.base.html | 903 + .../apache_beam.ml.inference.gemini_inference.html | 215 + pydoc/2.66.0/apache_beam.ml.inference.html | 468 + ...he_beam.ml.inference.huggingface_inference.html | 519 + .../apache_beam.ml.inference.onnx_inference.html | 236 + ...apache_beam.ml.inference.pytorch_inference.html | 427 + ...apache_beam.ml.inference.sklearn_inference.html | 354 + ...che_beam.ml.inference.tensorflow_inference.html | 377 + ...pache_beam.ml.inference.tensorrt_inference.html | 275 + pydoc/2.66.0/apache_beam.ml.inference.utils.html | 186 + ...ache_beam.ml.inference.vertex_ai_inference.html | 223 + .../apache_beam.ml.inference.vllm_inference.html | 277 + ...apache_beam.ml.inference.xgboost_inference.html | 596 + pydoc/2.66.0/apache_beam.ml.rag.chunking.base.html | 191 + pydoc/2.66.0/apache_beam.ml.rag.chunking.html | 166 + .../apache_beam.ml.rag.chunking.langchain.html | 198 + .../2.66.0/apache_beam.ml.rag.embeddings.base.html | 157 + pydoc/2.66.0/apache_beam.ml.rag.embeddings.html | 170 + .../apache_beam.ml.rag.embeddings.huggingface.html | 173 + .../apache_beam.ml.rag.embeddings.vertex_ai.html | 177 + ...m.ml.rag.enrichment.bigquery_vector_search.html | 395 + pydoc/2.66.0/apache_beam.ml.rag.enrichment.html | 171 + pydoc/2.66.0/apache_beam.ml.rag.html | 276 + .../apache_beam.ml.rag.ingestion.alloydb.html | 440 + .../2.66.0/apache_beam.ml.rag.ingestion.base.html | 242 + .../apache_beam.ml.rag.ingestion.bigquery.html | 260 + .../apache_beam.ml.rag.ingestion.cloudsql.html | 413 + pydoc/2.66.0/apache_beam.ml.rag.ingestion.html | 343 + .../apache_beam.ml.rag.ingestion.jdbc_common.html | 321 + .../apache_beam.ml.rag.ingestion.postgres.html | 208 + ...ache_beam.ml.rag.ingestion.postgres_common.html | 617 + .../apache_beam.ml.rag.ingestion.test_utils.html | 234 + pydoc/2.66.0/apache_beam.ml.rag.types.html | 231 + pydoc/2.66.0/apache_beam.ml.transforms.base.html | 296 + .../apache_beam.ml.transforms.embeddings.html | 200 + ..._beam.ml.transforms.embeddings.huggingface.html | 224 + ...ache_beam.ml.transforms.embeddings.open_ai.html | 173 + ...am.ml.transforms.embeddings.tensorflow_hub.html | 209 + ...he_beam.ml.transforms.embeddings.vertex_ai.html | 217 + .../2.66.0/apache_beam.ml.transforms.handlers.html | 222 + pydoc/2.66.0/apache_beam.ml.transforms.html | 288 + pydoc/2.66.0/apache_beam.ml.transforms.tft.html | 555 + pydoc/2.66.0/apache_beam.ml.transforms.utils.html | 167 + pydoc/2.66.0/apache_beam.options.html | 276 + .../apache_beam.options.pipeline_options.html | 722 + ...he_beam.options.pipeline_options_validator.html | 381 + .../2.66.0/apache_beam.options.value_provider.html | 276 + pydoc/2.66.0/apache_beam.pipeline.html | 336 + pydoc/2.66.0/apache_beam.portability.api.html | 155 + ...pache_beam.portability.api.org.apache.beam.html | 168 + ...ity.api.org.apache.beam.model.fn_execution.html | 192 + ...model.fn_execution.v1.beam_fn_api_pb2_grpc.html | 442 + ...model.fn_execution.v1.beam_fn_api_pb2_urns.html | 165 + ...n_execution.v1.beam_provision_api_pb2_grpc.html | 193 + ....api.org.apache.beam.model.fn_execution.v1.html | 240 + ...beam.portability.api.org.apache.beam.model.html | 187 + ...lity.api.org.apache.beam.model.interactive.html | 161 + ...teractive.v1.beam_interactive_api_pb2_grpc.html | 187 + ...y.api.org.apache.beam.model.interactive.v1.html | 162 + ...y.api.org.apache.beam.model.job_management.html | 191 + ...b_management.v1.beam_artifact_api_pb2_grpc.html | 370 + ...b_management.v1.beam_artifact_api_pb2_urns.html | 160 + ..._management.v1.beam_expansion_api_pb2_grpc.html | 199 + ...el.job_management.v1.beam_job_api_pb2_grpc.html | 298 + ...pi.org.apache.beam.model.job_management.v1.html | 256 + ...ability.api.org.apache.beam.model.pipeline.html | 198 + ...model.pipeline.v1.beam_runner_api_pb2_grpc.html | 144 + ...model.pipeline.v1.beam_runner_api_pb2_urns.html | 808 + ....beam.model.pipeline.v1.endpoints_pb2_grpc.html | 144 + ...l.pipeline.v1.external_transforms_pb2_grpc.html | 144 + ...l.pipeline.v1.external_transforms_pb2_urns.html | 244 + ...lity.api.org.apache.beam.model.pipeline.v1.html | 515 + ...he.beam.model.pipeline.v1.metrics_pb2_grpc.html | 144 + ...he.beam.model.pipeline.v1.metrics_pb2_urns.html | 514 + ...che.beam.model.pipeline.v1.schema_pb2_grpc.html | 144 + ...che.beam.model.pipeline.v1.schema_pb2_urns.html | 195 + ...l.pipeline.v1.standard_window_fns_pb2_grpc.html | 144 + ...l.pipeline.v1.standard_window_fns_pb2_urns.html | 211 + .../apache_beam.portability.api.org.apache.html | 155 + pydoc/2.66.0/apache_beam.portability.api.org.html | 154 + .../apache_beam.portability.common_urns.html | 136 + pydoc/2.66.0/apache_beam.portability.html | 174 + .../apache_beam.portability.python_urns.html | 137 + pydoc/2.66.0/apache_beam.portability.utils.html | 170 + pydoc/2.66.0/apache_beam.pvalue.html | 388 + .../apache_beam.runners.dask.dask_runner.html | 226 + pydoc/2.66.0/apache_beam.runners.dask.html | 169 + .../2.66.0/apache_beam.runners.dask.overrides.html | 146 + ...ataflow.dataflow_exercise_metrics_pipeline.html | 177 + ...taflow_exercise_streaming_metrics_pipeline.html | 171 + ...beam.runners.dataflow.dataflow_job_service.html | 158 + ...che_beam.runners.dataflow.dataflow_metrics.html | 184 + ...ache_beam.runners.dataflow.dataflow_runner.html | 231 + pydoc/2.66.0/apache_beam.runners.dataflow.html | 224 + ...beam.runners.dataflow.ptransform_overrides.html | 161 + ...beam.runners.dataflow.test_dataflow_runner.html | 166 + .../apache_beam.runners.direct.bundle_factory.html | 167 + pydoc/2.66.0/apache_beam.runners.direct.clock.html | 189 + ....direct.consumer_tracking_pipeline_visitor.html | 169 + .../apache_beam.runners.direct.direct_metrics.html | 277 + .../apache_beam.runners.direct.direct_runner.html | 189 + ...pache_beam.runners.direct.direct_userstate.html | 287 + ...che_beam.runners.direct.evaluation_context.html | 273 + .../apache_beam.runners.direct.executor.html | 186 + ...ache_beam.runners.direct.helper_transforms.html | 218 + pydoc/2.66.0/apache_beam.runners.direct.html | 438 + ...ache_beam.runners.direct.sdf_direct_runner.html | 403 + ...che_beam.runners.direct.test_direct_runner.html | 154 + ...pache_beam.runners.direct.test_stream_impl.html | 146 + ...he_beam.runners.direct.transform_evaluator.html | 207 + pydoc/2.66.0/apache_beam.runners.direct.util.html | 164 + ...ache_beam.runners.direct.watermark_manager.html | 189 + pydoc/2.66.0/apache_beam.runners.html | 628 + ...eam.runners.interactive.augmented_pipeline.html | 187 + ...runners.interactive.background_caching_job.html | 283 + ...che_beam.runners.interactive.cache_manager.html | 412 + ...beam.runners.interactive.caching.cacheable.html | 229 + ...nners.interactive.caching.expression_cache.html | 174 + .../apache_beam.runners.interactive.caching.html | 239 + ...eam.runners.interactive.caching.read_cache.html | 176 + ...che_beam.runners.interactive.caching.reify.html | 204 + ...unners.interactive.caching.streaming_cache.html | 313 + ...am.runners.interactive.caching.write_cache.html | 175 + ...eractive.dataproc.dataproc_cluster_manager.html | 232 + .../apache_beam.runners.interactive.dataproc.html | 180 + ...he_beam.runners.interactive.dataproc.types.html | 208 + ...unners.interactive.display.display_manager.html | 194 + .../apache_beam.runners.interactive.display.html | 213 + ...ractive.display.interactive_pipeline_graph.html | 190 + ...rs.interactive.display.pcoll_visualization.html | 258 + ...runners.interactive.display.pipeline_graph.html | 181 + ...nteractive.display.pipeline_graph_renderer.html | 244 + pydoc/2.66.0/apache_beam.runners.interactive.html | 641 + ..._beam.runners.interactive.interactive_beam.html | 549 + ...unners.interactive.interactive_environment.html | 511 + ...eam.runners.interactive.interactive_runner.html | 271 + .../apache_beam.runners.interactive.messaging.html | 166 + ...essaging.interactive_environment_inspector.html | 237 + ...unners.interactive.options.capture_control.html | 174 + ...nners.interactive.options.capture_limiters.html | 237 + .../apache_beam.runners.interactive.options.html | 194 + ...rs.interactive.options.interactive_options.html | 158 + ...beam.runners.interactive.pipeline_fragment.html | 183 + ...am.runners.interactive.pipeline_instrument.html | 303 + ...beam.runners.interactive.recording_manager.html | 288 + ...am.runners.interactive.sql.beam_sql_magics.html | 278 + .../apache_beam.runners.interactive.sql.html | 242 + ...che_beam.runners.interactive.sql.sql_chain.html | 385 + .../apache_beam.runners.interactive.sql.utils.html | 333 + .../apache_beam.runners.interactive.testing.html | 216 + ...am.runners.interactive.testing.integration.html | 180 + ...tive.testing.integration.notebook_executor.html | 205 + ...nteractive.testing.integration.screen_diff.html | 193 + ..._beam.runners.interactive.testing.mock_env.html | 158 + ...m.runners.interactive.testing.mock_ipython.html | 171 + ...ers.interactive.testing.pipeline_assertion.html | 186 + ...ers.interactive.testing.test_cache_manager.html | 239 + ....runners.interactive.user_pipeline_tracker.html | 212 + .../apache_beam.runners.interactive.utils.html | 310 + pydoc/2.66.0/apache_beam.runners.job.html | 156 + pydoc/2.66.0/apache_beam.runners.job.manager.html | 149 + pydoc/2.66.0/apache_beam.runners.job.utils.html | 152 + .../apache_beam.runners.pipeline_context.html | 214 + .../2.66.0/apache_beam.runners.pipeline_utils.html | 175 + pydoc/2.66.0/apache_beam.runners.render.html | 336 + pydoc/2.66.0/apache_beam.runners.runner.html | 381 + pydoc/2.66.0/apache_beam.runners.sdf_utils.html | 327 + .../2.66.0/apache_beam.runners.trivial_runner.html | 246 + pydoc/2.66.0/apache_beam.testing.benchmarks.html | 199 + .../apache_beam.testing.benchmarks.nexmark.html | 349 + ...ting.benchmarks.nexmark.models.auction_bid.html | 184 + ...sting.benchmarks.nexmark.models.field_name.html | 237 + ...che_beam.testing.benchmarks.nexmark.models.html | 232 + ...ng.benchmarks.nexmark.models.nexmark_model.html | 283 + ...he_beam.testing.benchmarks.nexmark.monitor.html | 198 + ...esting.benchmarks.nexmark.nexmark_launcher.html | 262 + ...am.testing.benchmarks.nexmark.nexmark_perf.html | 163 + ...am.testing.benchmarks.nexmark.nexmark_util.html | 316 + ...he_beam.testing.benchmarks.nexmark.queries.html | 340 + ...chmarks.nexmark.queries.nexmark_query_util.html | 309 + ....testing.benchmarks.nexmark.queries.query0.html | 162 + ....testing.benchmarks.nexmark.queries.query1.html | 150 + ...testing.benchmarks.nexmark.queries.query10.html | 216 + ...testing.benchmarks.nexmark.queries.query11.html | 150 + ...testing.benchmarks.nexmark.queries.query12.html | 149 + ....testing.benchmarks.nexmark.queries.query2.html | 149 + ....testing.benchmarks.nexmark.queries.query3.html | 212 + ....testing.benchmarks.nexmark.queries.query4.html | 178 + ....testing.benchmarks.nexmark.queries.query5.html | 185 + ....testing.benchmarks.nexmark.queries.query6.html | 184 + ....testing.benchmarks.nexmark.queries.query7.html | 167 + ....testing.benchmarks.nexmark.queries.query8.html | 165 + ....testing.benchmarks.nexmark.queries.query9.html | 147 + ...ng.benchmarks.nexmark.queries.winning_bids.html | 252 + .../apache_beam.testing.benchmarks.wordcount.html | 146 + ...eam.testing.benchmarks.wordcount.wordcount.html | 139 + .../apache_beam.testing.datatype_inference.html | 209 + .../apache_beam.testing.extra_assertions.html | 158 + pydoc/2.66.0/apache_beam.testing.html | 422 + ...testing.load_tests.dataflow_cost_benchmark.html | 138 + ...am.testing.load_tests.dataflow_cost_consts.html | 180 + pydoc/2.66.0/apache_beam.testing.load_tests.html | 229 + ...testing.load_tests.load_test_metrics_utils.html | 530 + ...apache_beam.testing.metric_result_matchers.html | 209 + .../apache_beam.testing.pipeline_verifiers.html | 208 + .../apache_beam.testing.synthetic_pipeline.html | 529 + .../2.66.0/apache_beam.testing.test_pipeline.html | 244 + pydoc/2.66.0/apache_beam.testing.test_stream.html | 286 + .../apache_beam.testing.test_stream_service.html | 169 + pydoc/2.66.0/apache_beam.testing.test_utils.html | 323 + pydoc/2.66.0/apache_beam.testing.util.html | 284 + ...am.transforms.combinefn_lifecycle_pipeline.html | 241 + pydoc/2.66.0/apache_beam.transforms.combiners.html | 757 + pydoc/2.66.0/apache_beam.transforms.core.html | 1926 ++ .../apache_beam.transforms.create_source.html | 157 + .../2.66.0/apache_beam.transforms.deduplicate.html | 198 + pydoc/2.66.0/apache_beam.transforms.display.html | 356 + .../2.66.0/apache_beam.transforms.enrichment.html | 262 + ...am.transforms.enrichment_handlers.bigquery.html | 227 + ...am.transforms.enrichment_handlers.bigtable.html | 181 + ...ms.enrichment_handlers.feast_feature_store.html | 187 + ...apache_beam.transforms.enrichment_handlers.html | 187 + ..._beam.transforms.enrichment_handlers.utils.html | 171 + ...nrichment_handlers.vertex_ai_feature_store.html | 229 + .../apache_beam.transforms.environments.html | 458 + .../apache_beam.transforms.error_handling.html | 235 + pydoc/2.66.0/apache_beam.transforms.external.html | 692 + .../apache_beam.transforms.external_java.html | 192 + ...eam.transforms.external_transform_provider.html | 293 + ...transforms.fully_qualified_named_transform.html | 186 + pydoc/2.66.0/apache_beam.transforms.html | 1395 ++ pydoc/2.66.0/apache_beam.transforms.managed.html | 246 + .../apache_beam.transforms.periodicsequence.html | 283 + .../2.66.0/apache_beam.transforms.ptransform.html | 435 + pydoc/2.66.0/apache_beam.transforms.resources.html | 305 + .../2.66.0/apache_beam.transforms.sideinputs.html | 189 + pydoc/2.66.0/apache_beam.transforms.sql.html | 217 + pydoc/2.66.0/apache_beam.transforms.stats.html | 327 + pydoc/2.66.0/apache_beam.transforms.timeutil.html | 198 + pydoc/2.66.0/apache_beam.transforms.trigger.html | 731 + pydoc/2.66.0/apache_beam.transforms.userstate.html | 550 + pydoc/2.66.0/apache_beam.transforms.util.html | 766 + pydoc/2.66.0/apache_beam.transforms.window.html | 602 + pydoc/2.66.0/apache_beam.transforms.xlang.html | 165 + pydoc/2.66.0/apache_beam.transforms.xlang.io.html | 233 + ...am.typehints.arrow_batching_microbenchmark.html | 165 + ...he_beam.typehints.arrow_type_compatibility.html | 150 + pydoc/2.66.0/apache_beam.typehints.batch.html | 209 + pydoc/2.66.0/apache_beam.typehints.decorators.html | 391 + pydoc/2.66.0/apache_beam.typehints.html | 646 + .../apache_beam.typehints.intrinsic_one_ops.html | 229 + ...e_beam.typehints.native_type_compatibility.html | 331 + pydoc/2.66.0/apache_beam.typehints.opcodes.html | 875 + ...e_beam.typehints.pandas_type_compatibility.html | 178 + ..._beam.typehints.pytorch_type_compatibility.html | 206 + pydoc/2.66.0/apache_beam.typehints.row_type.html | 245 + .../apache_beam.typehints.schema_registry.html | 179 + pydoc/2.66.0/apache_beam.typehints.schemas.html | 844 + .../apache_beam.typehints.sharded_key_type.html | 183 + pydoc/2.66.0/apache_beam.typehints.testing.html | 150 + .../apache_beam.typehints.testing.strategies.html | 158 + .../apache_beam.typehints.trivial_inference.html | 325 + pydoc/2.66.0/apache_beam.typehints.typecheck.html | 330 + pydoc/2.66.0/apache_beam.typehints.typehints.html | 221 + pydoc/2.66.0/apache_beam.utils.annotations.html | 254 + pydoc/2.66.0/apache_beam.utils.histogram.html | 315 + pydoc/2.66.0/apache_beam.utils.html | 386 + .../apache_beam.utils.interactive_utils.html | 182 + .../apache_beam.utils.multi_process_shared.html | 230 + pydoc/2.66.0/apache_beam.utils.plugin.html | 173 + pydoc/2.66.0/apache_beam.utils.processes.html | 177 + pydoc/2.66.0/apache_beam.utils.profiler.html | 205 + pydoc/2.66.0/apache_beam.utils.proto_utils.html | 215 + .../2.66.0/apache_beam.utils.python_callable.html | 206 + pydoc/2.66.0/apache_beam.utils.retry.html | 307 + pydoc/2.66.0/apache_beam.utils.sentinel.html | 164 + pydoc/2.66.0/apache_beam.utils.sharded_key.html | 177 + pydoc/2.66.0/apache_beam.utils.shared.html | 262 + .../apache_beam.utils.subprocess_server.html | 300 + .../apache_beam.utils.thread_pool_executor.html | 176 + pydoc/2.66.0/apache_beam.utils.timestamp.html | 311 + ...ache_beam.utils.transform_service_launcher.html | 184 + pydoc/2.66.0/apache_beam.utils.urns.html | 211 + .../apache_beam.yaml.cache_provider_artifacts.html | 158 + pydoc/2.66.0/apache_beam.yaml.conftest.html | 164 + pydoc/2.66.0/apache_beam.yaml.examples.html | 159 + .../2.66.0/apache_beam.yaml.examples.testing.html | 154 + ...ache_beam.yaml.examples.testing.input_data.html | 175 + .../apache_beam.yaml.generate_yaml_docs.html | 234 + pydoc/2.66.0/apache_beam.yaml.html | 513 + pydoc/2.66.0/apache_beam.yaml.json_utils.html | 219 + pydoc/2.66.0/apache_beam.yaml.main.html | 182 + pydoc/2.66.0/apache_beam.yaml.options.html | 186 + pydoc/2.66.0/apache_beam.yaml.yaml_combine.html | 207 + pydoc/2.66.0/apache_beam.yaml.yaml_enrichment.html | 198 + pydoc/2.66.0/apache_beam.yaml.yaml_errors.html | 196 + pydoc/2.66.0/apache_beam.yaml.yaml_io.html | 459 + pydoc/2.66.0/apache_beam.yaml.yaml_join.html | 159 + pydoc/2.66.0/apache_beam.yaml.yaml_mapping.html | 245 + pydoc/2.66.0/apache_beam.yaml.yaml_ml.html | 464 + pydoc/2.66.0/apache_beam.yaml.yaml_provider.html | 935 + .../2.66.0/apache_beam.yaml.yaml_specifiable.html | 176 + pydoc/2.66.0/apache_beam.yaml.yaml_testing.html | 247 + pydoc/2.66.0/apache_beam.yaml.yaml_transform.html | 164 + pydoc/2.66.0/apache_beam.yaml.yaml_utils.html | 209 + pydoc/2.66.0/doctest/output.txt | 880 + .../apache_beam.coders.avro_record.doctree | Bin 0 -> 6335 bytes .../doctrees/apache_beam.coders.coders.doctree | Bin 0 -> 285643 bytes pydoc/2.66.0/doctrees/apache_beam.coders.doctree | Bin 0 -> 3665 bytes .../doctrees/apache_beam.coders.observable.doctree | Bin 0 -> 9961 bytes .../doctrees/apache_beam.coders.row_coder.doctree | Bin 0 -> 21367 bytes .../apache_beam.coders.slow_stream.doctree | Bin 0 -> 59396 bytes .../doctrees/apache_beam.coders.typecoders.doctree | Bin 0 -> 9475 bytes .../doctrees/apache_beam.dataframe.convert.doctree | Bin 0 -> 49715 bytes .../apache_beam.dataframe.doctests.doctree | Bin 0 -> 84075 bytes .../2.66.0/doctrees/apache_beam.dataframe.doctree | Bin 0 -> 9444 bytes .../apache_beam.dataframe.expressions.doctree | Bin 0 -> 99399 bytes .../apache_beam.dataframe.frame_base.doctree | Bin 0 -> 48982 bytes .../doctrees/apache_beam.dataframe.frames.doctree | Bin 0 -> 4265039 bytes .../doctrees/apache_beam.dataframe.io.doctree | Bin 0 -> 845392 bytes ...am.dataframe.pandas_top_level_functions.doctree | Bin 0 -> 65055 bytes .../apache_beam.dataframe.partitionings.doctree | Bin 0 -> 48762 bytes .../doctrees/apache_beam.dataframe.schemas.doctree | Bin 0 -> 24017 bytes .../apache_beam.dataframe.transforms.doctree | Bin 0 -> 20027 bytes pydoc/2.66.0/doctrees/apache_beam.error.doctree | Bin 0 -> 19119 bytes .../2.66.0/doctrees/apache_beam.io.avroio.doctree | Bin 0 -> 64940 bytes .../doctrees/apache_beam.io.aws.clients.doctree | Bin 0 -> 3562 bytes ...che_beam.io.aws.clients.s3.boto3_client.doctree | Bin 0 -> 34642 bytes .../doctrees/apache_beam.io.aws.clients.s3.doctree | Bin 0 -> 3698 bytes ...ache_beam.io.aws.clients.s3.fake_client.doctree | Bin 0 -> 31531 bytes .../apache_beam.io.aws.clients.s3.messages.doctree | Bin 0 -> 48090 bytes pydoc/2.66.0/doctrees/apache_beam.io.aws.doctree | Bin 0 -> 3941 bytes .../apache_beam.io.aws.s3filesystem.doctree | Bin 0 -> 61009 bytes .../doctrees/apache_beam.io.aws.s3io.doctree | Bin 0 -> 79272 bytes ...che_beam.io.azure.blobstoragefilesystem.doctree | Bin 0 -> 64067 bytes .../apache_beam.io.azure.blobstorageio.doctree | Bin 0 -> 94459 bytes pydoc/2.66.0/doctrees/apache_beam.io.azure.doctree | Bin 0 -> 3555 bytes ...e_beam.io.components.adaptive_throttler.doctree | Bin 0 -> 17808 bytes .../doctrees/apache_beam.io.components.doctree | Bin 0 -> 3603 bytes .../apache_beam.io.components.util.doctree | Bin 0 -> 12326 bytes .../doctrees/apache_beam.io.concat_source.doctree | Bin 0 -> 37172 bytes .../doctrees/apache_beam.io.debezium.doctree | Bin 0 -> 32638 bytes pydoc/2.66.0/doctrees/apache_beam.io.doctree | Bin 0 -> 5184 bytes .../doctrees/apache_beam.io.external.doctree | Bin 0 -> 4049 bytes .../doctrees/apache_beam.io.external.gcp.doctree | Bin 0 -> 3573 bytes .../apache_beam.io.external.gcp.pubsub.doctree | Bin 0 -> 55444 bytes ...ache_beam.io.external.generate_sequence.doctree | Bin 0 -> 12496 bytes .../doctrees/apache_beam.io.external.kafka.doctree | Bin 0 -> 2983 bytes .../apache_beam.io.external.snowflake.doctree | Bin 0 -> 3019 bytes .../doctrees/apache_beam.io.filebasedsink.doctree | Bin 0 -> 34141 bytes .../apache_beam.io.filebasedsource.doctree | Bin 0 -> 43433 bytes .../2.66.0/doctrees/apache_beam.io.fileio.doctree | Bin 0 -> 92210 bytes .../doctrees/apache_beam.io.filesystem.doctree | Bin 0 -> 157045 bytes .../doctrees/apache_beam.io.filesystemio.doctree | Bin 0 -> 60506 bytes .../doctrees/apache_beam.io.filesystems.doctree | Bin 0 -> 79966 bytes pydoc/2.66.0/doctrees/apache_beam.io.flink.doctree | Bin 0 -> 3520 bytes ...io.flink.flink_streaming_impulse_source.doctree | Bin 0 -> 26559 bytes ...o.gcp.big_query_query_to_table_pipeline.doctree | Bin 0 -> 7238 bytes .../doctrees/apache_beam.io.gcp.bigquery.doctree | Bin 0 -> 311693 bytes .../apache_beam.io.gcp.bigquery_avro_tools.doctree | Bin 0 -> 23669 bytes .../apache_beam.io.gcp.bigquery_file_loads.doctree | Bin 0 -> 123364 bytes ...apache_beam.io.gcp.bigquery_io_metadata.doctree | Bin 0 -> 12210 bytes ...e_beam.io.gcp.bigquery_io_read_pipeline.doctree | Bin 0 -> 11568 bytes ...ache_beam.io.gcp.bigquery_read_internal.doctree | Bin 0 -> 19146 bytes ...pache_beam.io.gcp.bigquery_schema_tools.doctree | Bin 0 -> 19639 bytes .../apache_beam.io.gcp.bigquery_tools.doctree | Bin 0 -> 220567 bytes .../doctrees/apache_beam.io.gcp.bigtableio.doctree | Bin 0 -> 30725 bytes .../doctrees/apache_beam.io.gcp.datastore.doctree | Bin 0 -> 3587 bytes ...store.v1new.datastore_write_it_pipeline.doctree | Bin 0 -> 16982 bytes ...beam.io.gcp.datastore.v1new.datastoreio.doctree | Bin 0 -> 37696 bytes .../apache_beam.io.gcp.datastore.v1new.doctree | Bin 0 -> 3994 bytes ...ache_beam.io.gcp.datastore.v1new.helper.doctree | Bin 0 -> 12955 bytes ...m.io.gcp.datastore.v1new.query_splitter.doctree | Bin 0 -> 16746 bytes ...cp.datastore.v1new.rampup_throttling_fn.doctree | Bin 0 -> 11212 bytes ...pache_beam.io.gcp.datastore.v1new.types.doctree | Bin 0 -> 47426 bytes ...apache_beam.io.gcp.datastore.v1new.util.doctree | Bin 0 -> 21188 bytes .../apache_beam.io.gcp.dicomclient.doctree | Bin 0 -> 2992 bytes .../doctrees/apache_beam.io.gcp.dicomio.doctree | Bin 0 -> 2956 bytes pydoc/2.66.0/doctrees/apache_beam.io.gcp.doctree | Bin 0 -> 4879 bytes .../apache_beam.io.gcp.experimental.doctree | Bin 0 -> 3620 bytes ...ache_beam.io.gcp.experimental.spannerio.doctree | Bin 0 -> 120079 bytes .../apache_beam.io.gcp.gce_metadata_util.doctree | Bin 0 -> 5135 bytes .../apache_beam.io.gcp.gcsfilesystem.doctree | Bin 0 -> 62794 bytes .../doctrees/apache_beam.io.gcp.gcsio.doctree | Bin 0 -> 76496 bytes .../apache_beam.io.gcp.gcsio_retry.doctree | Bin 0 -> 3282 bytes ...ache_beam.io.gcp.healthcare.dicomclient.doctree | Bin 0 -> 18098 bytes .../apache_beam.io.gcp.healthcare.dicomio.doctree | Bin 0 -> 47601 bytes .../doctrees/apache_beam.io.gcp.healthcare.doctree | Bin 0 -> 3647 bytes .../doctrees/apache_beam.io.gcp.pubsub.doctree | Bin 0 -> 95883 bytes .../apache_beam.io.gcp.pubsub_it_pipeline.doctree | Bin 0 -> 6276 bytes .../doctrees/apache_beam.io.gcp.pubsublite.doctree | Bin 0 -> 19318 bytes .../apache_beam.io.gcp.pubsublite.external.doctree | Bin 0 -> 3612 bytes ...apache_beam.io.gcp.pubsublite.proto_api.doctree | Bin 0 -> 18905 bytes ...apache_beam.io.gcp.resource_identifiers.doctree | Bin 0 -> 17916 bytes .../doctrees/apache_beam.io.gcp.spanner.doctree | Bin 0 -> 157954 bytes .../apache_beam.io.gcp.spanner_wrapper.doctree | Bin 0 -> 7892 bytes .../apache_beam.io.hadoopfilesystem.doctree | Bin 0 -> 47035 bytes .../2.66.0/doctrees/apache_beam.io.iobase.doctree | Bin 0 -> 352931 bytes pydoc/2.66.0/doctrees/apache_beam.io.jdbc.doctree | Bin 0 -> 54625 bytes pydoc/2.66.0/doctrees/apache_beam.io.kafka.doctree | Bin 0 -> 105799 bytes .../2.66.0/doctrees/apache_beam.io.kinesis.doctree | Bin 0 -> 64670 bytes .../apache_beam.io.localfilesystem.doctree | Bin 0 -> 59959 bytes .../doctrees/apache_beam.io.mongodbio.doctree | Bin 0 -> 41819 bytes .../doctrees/apache_beam.io.parquetio.doctree | Bin 0 -> 100961 bytes .../doctrees/apache_beam.io.range_trackers.doctree | Bin 0 -> 86230 bytes .../apache_beam.io.requestresponse.doctree | Bin 0 -> 75199 bytes .../apache_beam.io.restriction_trackers.doctree | Bin 0 -> 34429 bytes .../doctrees/apache_beam.io.snowflake.doctree | Bin 0 -> 82394 bytes .../apache_beam.io.source_test_utils.doctree | Bin 0 -> 68946 bytes .../2.66.0/doctrees/apache_beam.io.textio.doctree | Bin 0 -> 379870 bytes .../doctrees/apache_beam.io.tfrecordio.doctree | Bin 0 -> 31356 bytes pydoc/2.66.0/doctrees/apache_beam.io.utils.doctree | Bin 0 -> 12521 bytes .../apache_beam.io.watermark_estimators.doctree | Bin 0 -> 36245 bytes .../doctrees/apache_beam.metrics.cells.doctree | Bin 0 -> 37710 bytes pydoc/2.66.0/doctrees/apache_beam.metrics.doctree | Bin 0 -> 3602 bytes .../doctrees/apache_beam.metrics.metric.doctree | Bin 0 -> 125270 bytes .../apache_beam.metrics.metricbase.doctree | Bin 0 -> 56770 bytes .../apache_beam.metrics.monitoring_infos.doctree | Bin 0 -> 92765 bytes .../apache_beam.ml.anomaly.aggregations.doctree | Bin 0 -> 174277 bytes .../doctrees/apache_beam.ml.anomaly.base.doctree | Bin 0 -> 103115 bytes .../apache_beam.ml.anomaly.detectors.doctree | Bin 0 -> 3829 bytes .../apache_beam.ml.anomaly.detectors.iqr.doctree | Bin 0 -> 38377 bytes ...pache_beam.ml.anomaly.detectors.offline.doctree | Bin 0 -> 51438 bytes ..._beam.ml.anomaly.detectors.pyod_adapter.doctree | Bin 0 -> 2673 bytes ...beam.ml.anomaly.detectors.robust_zscore.doctree | Bin 0 -> 43156 bytes ...apache_beam.ml.anomaly.detectors.zscore.doctree | Bin 0 -> 41802 bytes .../2.66.0/doctrees/apache_beam.ml.anomaly.doctree | Bin 0 -> 4162 bytes .../apache_beam.ml.anomaly.specifiable.doctree | Bin 0 -> 51789 bytes .../apache_beam.ml.anomaly.thresholds.doctree | Bin 0 -> 85512 bytes .../apache_beam.ml.anomaly.transforms.doctree | Bin 0 -> 122730 bytes .../apache_beam.ml.anomaly.univariate.base.doctree | Bin 0 -> 27162 bytes .../apache_beam.ml.anomaly.univariate.doctree | Bin 0 -> 3878 bytes .../apache_beam.ml.anomaly.univariate.mad.doctree | Bin 0 -> 38665 bytes .../apache_beam.ml.anomaly.univariate.mean.doctree | Bin 0 -> 92772 bytes ...pache_beam.ml.anomaly.univariate.median.doctree | Bin 0 -> 33510 bytes ...che_beam.ml.anomaly.univariate.quantile.doctree | Bin 0 -> 129248 bytes ...apache_beam.ml.anomaly.univariate.stdev.doctree | Bin 0 -> 93674 bytes pydoc/2.66.0/doctrees/apache_beam.ml.doctree | Bin 0 -> 3886 bytes .../doctrees/apache_beam.ml.gcp.cloud_dlp.doctree | Bin 0 -> 29585 bytes pydoc/2.66.0/doctrees/apache_beam.ml.gcp.doctree | Bin 0 -> 3649 bytes .../apache_beam.ml.gcp.naturallanguageml.doctree | Bin 0 -> 35787 bytes .../apache_beam.ml.gcp.recommendations_ai.doctree | Bin 0 -> 101401 bytes .../apache_beam.ml.gcp.videointelligenceml.doctree | Bin 0 -> 26219 bytes .../doctrees/apache_beam.ml.gcp.visionml.doctree | Bin 0 -> 35309 bytes .../doctrees/apache_beam.ml.inference.base.doctree | Bin 0 -> 317114 bytes .../doctrees/apache_beam.ml.inference.doctree | Bin 0 -> 5492 bytes ...ache_beam.ml.inference.gemini_inference.doctree | Bin 0 -> 45690 bytes ...beam.ml.inference.huggingface_inference.doctree | Bin 0 -> 176797 bytes ...apache_beam.ml.inference.onnx_inference.doctree | Bin 0 -> 37793 bytes ...che_beam.ml.inference.pytorch_inference.doctree | Bin 0 -> 106109 bytes ...che_beam.ml.inference.sklearn_inference.doctree | Bin 0 -> 77618 bytes ..._beam.ml.inference.tensorflow_inference.doctree | Bin 0 -> 91107 bytes ...he_beam.ml.inference.tensorrt_inference.doctree | Bin 0 -> 51217 bytes .../apache_beam.ml.inference.utils.doctree | Bin 0 -> 16286 bytes ...e_beam.ml.inference.vertex_ai_inference.doctree | Bin 0 -> 43819 bytes ...apache_beam.ml.inference.vllm_inference.doctree | Bin 0 -> 61638 bytes ...che_beam.ml.inference.xgboost_inference.doctree | Bin 0 -> 139555 bytes .../apache_beam.ml.rag.chunking.base.doctree | Bin 0 -> 23000 bytes .../doctrees/apache_beam.ml.rag.chunking.doctree | Bin 0 -> 4096 bytes .../apache_beam.ml.rag.chunking.langchain.doctree | Bin 0 -> 26105 bytes pydoc/2.66.0/doctrees/apache_beam.ml.rag.doctree | Bin 0 -> 4681 bytes .../apache_beam.ml.rag.embeddings.base.doctree | Bin 0 -> 7500 bytes .../doctrees/apache_beam.ml.rag.embeddings.doctree | Bin 0 -> 4163 bytes ...ache_beam.ml.rag.embeddings.huggingface.doctree | Bin 0 -> 18713 bytes ...apache_beam.ml.rag.embeddings.vertex_ai.doctree | Bin 0 -> 25584 bytes ...l.rag.enrichment.bigquery_vector_search.doctree | Bin 0 -> 83557 bytes .../doctrees/apache_beam.ml.rag.enrichment.doctree | Bin 0 -> 4091 bytes .../apache_beam.ml.rag.ingestion.alloydb.doctree | Bin 0 -> 94591 bytes .../apache_beam.ml.rag.ingestion.base.doctree | Bin 0 -> 26567 bytes .../apache_beam.ml.rag.ingestion.bigquery.doctree | Bin 0 -> 34520 bytes .../apache_beam.ml.rag.ingestion.cloudsql.doctree | Bin 0 -> 87971 bytes .../doctrees/apache_beam.ml.rag.ingestion.doctree | Bin 0 -> 4398 bytes ...pache_beam.ml.rag.ingestion.jdbc_common.doctree | Bin 0 -> 55192 bytes .../apache_beam.ml.rag.ingestion.postgres.doctree | Bin 0 -> 20124 bytes ...e_beam.ml.rag.ingestion.postgres_common.doctree | Bin 0 -> 150087 bytes ...apache_beam.ml.rag.ingestion.test_utils.doctree | Bin 0 -> 42251 bytes .../doctrees/apache_beam.ml.rag.types.doctree | Bin 0 -> 41651 bytes .../apache_beam.ml.transforms.base.doctree | Bin 0 -> 82721 bytes .../doctrees/apache_beam.ml.transforms.doctree | Bin 0 -> 4107 bytes .../apache_beam.ml.transforms.embeddings.doctree | Bin 0 -> 4294 bytes ...am.ml.transforms.embeddings.huggingface.doctree | Bin 0 -> 38533 bytes ...e_beam.ml.transforms.embeddings.open_ai.doctree | Bin 0 -> 23834 bytes ...ml.transforms.embeddings.tensorflow_hub.doctree | Bin 0 -> 31019 bytes ...beam.ml.transforms.embeddings.vertex_ai.doctree | Bin 0 -> 44586 bytes .../apache_beam.ml.transforms.handlers.doctree | Bin 0 -> 47717 bytes .../doctrees/apache_beam.ml.transforms.tft.doctree | Bin 0 -> 213493 bytes .../apache_beam.ml.transforms.utils.doctree | Bin 0 -> 14968 bytes pydoc/2.66.0/doctrees/apache_beam.options.doctree | Bin 0 -> 3593 bytes .../apache_beam.options.pipeline_options.doctree | Bin 0 -> 165308 bytes ...beam.options.pipeline_options_validator.doctree | Bin 0 -> 87293 bytes .../apache_beam.options.value_provider.doctree | Bin 0 -> 41931 bytes pydoc/2.66.0/doctrees/apache_beam.pipeline.doctree | Bin 0 -> 87399 bytes .../doctrees/apache_beam.portability.api.doctree | Bin 0 -> 4042 bytes ...he_beam.portability.api.org.apache.beam.doctree | Bin 0 -> 3752 bytes ...m.portability.api.org.apache.beam.model.doctree | Bin 0 -> 4034 bytes ....api.org.apache.beam.model.fn_execution.doctree | Bin 0 -> 3960 bytes ...el.fn_execution.v1.beam_fn_api_pb2_grpc.doctree | Bin 0 -> 148582 bytes ...el.fn_execution.v1.beam_fn_api_pb2_urns.doctree | Bin 0 -> 12410 bytes ...xecution.v1.beam_provision_api_pb2_grpc.doctree | Bin 0 -> 27120 bytes ...i.org.apache.beam.model.fn_execution.v1.doctree | Bin 0 -> 4204 bytes ...y.api.org.apache.beam.model.interactive.doctree | Bin 0 -> 3947 bytes ...active.v1.beam_interactive_api_pb2_grpc.doctree | Bin 0 -> 26070 bytes ...pi.org.apache.beam.model.interactive.v1.doctree | Bin 0 -> 4003 bytes ...pi.org.apache.beam.model.job_management.doctree | Bin 0 -> 3982 bytes ...anagement.v1.beam_artifact_api_pb2_grpc.doctree | Bin 0 -> 122090 bytes ...anagement.v1.beam_artifact_api_pb2_urns.doctree | Bin 0 -> 11241 bytes ...nagement.v1.beam_expansion_api_pb2_grpc.doctree | Bin 0 -> 35064 bytes ...job_management.v1.beam_job_api_pb2_grpc.doctree | Bin 0 -> 108449 bytes ...org.apache.beam.model.job_management.v1.doctree | Bin 0 -> 4339 bytes ...lity.api.org.apache.beam.model.pipeline.doctree | Bin 0 -> 3914 bytes ...el.pipeline.v1.beam_runner_api_pb2_grpc.doctree | Bin 0 -> 3986 bytes ...el.pipeline.v1.beam_runner_api_pb2_urns.doctree | Bin 0 -> 258128 bytes ...y.api.org.apache.beam.model.pipeline.v1.doctree | Bin 0 -> 4886 bytes ...am.model.pipeline.v1.endpoints_pb2_grpc.doctree | Bin 0 -> 3916 bytes ...ipeline.v1.external_transforms_pb2_grpc.doctree | Bin 0 -> 4028 bytes ...ipeline.v1.external_transforms_pb2_urns.doctree | Bin 0 -> 43072 bytes ...beam.model.pipeline.v1.metrics_pb2_grpc.doctree | Bin 0 -> 3894 bytes ...beam.model.pipeline.v1.metrics_pb2_urns.doctree | Bin 0 -> 151323 bytes ....beam.model.pipeline.v1.schema_pb2_grpc.doctree | Bin 0 -> 3883 bytes ....beam.model.pipeline.v1.schema_pb2_urns.doctree | Bin 0 -> 22218 bytes ...ipeline.v1.standard_window_fns_pb2_grpc.doctree | Bin 0 -> 4030 bytes ...ipeline.v1.standard_window_fns_pb2_urns.doctree | Bin 0 -> 31537 bytes .../apache_beam.portability.api.org.apache.doctree | Bin 0 -> 3696 bytes .../apache_beam.portability.api.org.doctree | Bin 0 -> 3621 bytes .../apache_beam.portability.common_urns.doctree | Bin 0 -> 3367 bytes .../doctrees/apache_beam.portability.doctree | Bin 0 -> 4394 bytes .../apache_beam.portability.python_urns.doctree | Bin 0 -> 3591 bytes .../doctrees/apache_beam.portability.utils.doctree | Bin 0 -> 13939 bytes pydoc/2.66.0/doctrees/apache_beam.pvalue.doctree | Bin 0 -> 80755 bytes .../apache_beam.runners.dask.dask_runner.doctree | Bin 0 -> 33180 bytes .../doctrees/apache_beam.runners.dask.doctree | Bin 0 -> 3589 bytes .../apache_beam.runners.dask.overrides.doctree | Bin 0 -> 5550 bytes ...flow.dataflow_exercise_metrics_pipeline.doctree | Bin 0 -> 15806 bytes ...low_exercise_streaming_metrics_pipeline.doctree | Bin 0 -> 15014 bytes ...m.runners.dataflow.dataflow_job_service.doctree | Bin 0 -> 14449 bytes ..._beam.runners.dataflow.dataflow_metrics.doctree | Bin 0 -> 16714 bytes ...e_beam.runners.dataflow.dataflow_runner.doctree | Bin 0 -> 34096 bytes .../doctrees/apache_beam.runners.dataflow.doctree | Bin 0 -> 4677 bytes ...m.runners.dataflow.ptransform_overrides.doctree | Bin 0 -> 10870 bytes ...m.runners.dataflow.test_dataflow_runner.doctree | Bin 0 -> 13713 bytes ...ache_beam.runners.direct.bundle_factory.doctree | Bin 0 -> 14843 bytes .../apache_beam.runners.direct.clock.doctree | Bin 0 -> 17724 bytes ...rect.consumer_tracking_pipeline_visitor.doctree | Bin 0 -> 12975 bytes ...ache_beam.runners.direct.direct_metrics.doctree | Bin 0 -> 52124 bytes ...pache_beam.runners.direct.direct_runner.doctree | Bin 0 -> 18846 bytes ...he_beam.runners.direct.direct_userstate.doctree | Bin 0 -> 58238 bytes .../doctrees/apache_beam.runners.direct.doctree | Bin 0 -> 4982 bytes ..._beam.runners.direct.evaluation_context.doctree | Bin 0 -> 55009 bytes .../apache_beam.runners.direct.executor.doctree | Bin 0 -> 22525 bytes ...e_beam.runners.direct.helper_transforms.doctree | Bin 0 -> 29481 bytes ...e_beam.runners.direct.sdf_direct_runner.doctree | Bin 0 -> 102899 bytes ..._beam.runners.direct.test_direct_runner.doctree | Bin 0 -> 8499 bytes ...he_beam.runners.direct.test_stream_impl.doctree | Bin 0 -> 4089 bytes ...beam.runners.direct.transform_evaluator.doctree | Bin 0 -> 26448 bytes .../apache_beam.runners.direct.util.doctree | Bin 0 -> 15872 bytes ...e_beam.runners.direct.watermark_manager.doctree | Bin 0 -> 24809 bytes pydoc/2.66.0/doctrees/apache_beam.runners.doctree | Bin 0 -> 4772 bytes ....runners.interactive.augmented_pipeline.doctree | Bin 0 -> 21694 bytes ...ners.interactive.background_caching_job.doctree | Bin 0 -> 46773 bytes ..._beam.runners.interactive.cache_manager.doctree | Bin 0 -> 88423 bytes ...m.runners.interactive.caching.cacheable.doctree | Bin 0 -> 39305 bytes ...apache_beam.runners.interactive.caching.doctree | Bin 0 -> 4010 bytes ...rs.interactive.caching.expression_cache.doctree | Bin 0 -> 13804 bytes ....runners.interactive.caching.read_cache.doctree | Bin 0 -> 15725 bytes ..._beam.runners.interactive.caching.reify.doctree | Bin 0 -> 36736 bytes ...ers.interactive.caching.streaming_cache.doctree | Bin 0 -> 61425 bytes ...runners.interactive.caching.write_cache.doctree | Bin 0 -> 14746 bytes ...ctive.dataproc.dataproc_cluster_manager.doctree | Bin 0 -> 37592 bytes ...pache_beam.runners.interactive.dataproc.doctree | Bin 0 -> 3790 bytes ...beam.runners.interactive.dataproc.types.doctree | Bin 0 -> 31079 bytes ...ers.interactive.display.display_manager.doctree | Bin 0 -> 18112 bytes ...apache_beam.runners.interactive.display.doctree | Bin 0 -> 3990 bytes ...tive.display.interactive_pipeline_graph.doctree | Bin 0 -> 19098 bytes ...interactive.display.pcoll_visualization.doctree | Bin 0 -> 43653 bytes ...ners.interactive.display.pipeline_graph.doctree | Bin 0 -> 16746 bytes ...ractive.display.pipeline_graph_renderer.doctree | Bin 0 -> 43955 bytes .../apache_beam.runners.interactive.doctree | Bin 0 -> 4929 bytes ...am.runners.interactive.interactive_beam.doctree | Bin 0 -> 126039 bytes ...ers.interactive.interactive_environment.doctree | Bin 0 -> 115955 bytes ....runners.interactive.interactive_runner.doctree | Bin 0 -> 43812 bytes ...ache_beam.runners.interactive.messaging.doctree | Bin 0 -> 3754 bytes ...aging.interactive_environment_inspector.doctree | Bin 0 -> 36531 bytes ...ers.interactive.options.capture_control.doctree | Bin 0 -> 15518 bytes ...rs.interactive.options.capture_limiters.doctree | Bin 0 -> 38346 bytes ...apache_beam.runners.interactive.options.doctree | Bin 0 -> 3847 bytes ...interactive.options.interactive_options.doctree | Bin 0 -> 8533 bytes ...m.runners.interactive.pipeline_fragment.doctree | Bin 0 -> 17659 bytes ...runners.interactive.pipeline_instrument.doctree | Bin 0 -> 49611 bytes ...m.runners.interactive.recording_manager.doctree | Bin 0 -> 79176 bytes ...runners.interactive.sql.beam_sql_magics.doctree | Bin 0 -> 58868 bytes .../apache_beam.runners.interactive.sql.doctree | Bin 0 -> 3774 bytes ..._beam.runners.interactive.sql.sql_chain.doctree | Bin 0 -> 89583 bytes ...ache_beam.runners.interactive.sql.utils.doctree | Bin 0 -> 75614 bytes ...apache_beam.runners.interactive.testing.doctree | Bin 0 -> 4354 bytes ...runners.interactive.testing.integration.doctree | Bin 0 -> 3921 bytes ...e.testing.integration.notebook_executor.doctree | Bin 0 -> 24642 bytes ...ractive.testing.integration.screen_diff.doctree | Bin 0 -> 23739 bytes ...am.runners.interactive.testing.mock_env.doctree | Bin 0 -> 9147 bytes ...unners.interactive.testing.mock_ipython.doctree | Bin 0 -> 7141 bytes ....interactive.testing.pipeline_assertion.doctree | Bin 0 -> 18370 bytes ....interactive.testing.test_cache_manager.doctree | Bin 0 -> 39211 bytes ...nners.interactive.user_pipeline_tracker.doctree | Bin 0 -> 28939 bytes .../apache_beam.runners.interactive.utils.doctree | Bin 0 -> 78684 bytes .../doctrees/apache_beam.runners.job.doctree | Bin 0 -> 3569 bytes .../apache_beam.runners.job.manager.doctree | Bin 0 -> 6788 bytes .../doctrees/apache_beam.runners.job.utils.doctree | Bin 0 -> 8413 bytes .../apache_beam.runners.pipeline_context.doctree | Bin 0 -> 56491 bytes .../apache_beam.runners.pipeline_utils.doctree | Bin 0 -> 14465 bytes .../doctrees/apache_beam.runners.render.doctree | Bin 0 -> 58006 bytes .../doctrees/apache_beam.runners.runner.doctree | Bin 0 -> 82010 bytes .../doctrees/apache_beam.runners.sdf_utils.doctree | Bin 0 -> 64206 bytes .../apache_beam.runners.trivial_runner.doctree | Bin 0 -> 49520 bytes .../apache_beam.testing.benchmarks.doctree | Bin 0 -> 3661 bytes .../apache_beam.testing.benchmarks.nexmark.doctree | Bin 0 -> 4381 bytes ...g.benchmarks.nexmark.models.auction_bid.doctree | Bin 0 -> 19844 bytes ..._beam.testing.benchmarks.nexmark.models.doctree | Bin 0 -> 3909 bytes ...ng.benchmarks.nexmark.models.field_name.doctree | Bin 0 -> 32313 bytes ...benchmarks.nexmark.models.nexmark_model.doctree | Bin 0 -> 59069 bytes ...beam.testing.benchmarks.nexmark.monitor.doctree | Bin 0 -> 23356 bytes ...ing.benchmarks.nexmark.nexmark_launcher.doctree | Bin 0 -> 42295 bytes ...testing.benchmarks.nexmark.nexmark_perf.doctree | Bin 0 -> 12759 bytes ...testing.benchmarks.nexmark.nexmark_util.doctree | Bin 0 -> 65243 bytes ...beam.testing.benchmarks.nexmark.queries.doctree | Bin 0 -> 4662 bytes ...arks.nexmark.queries.nexmark_query_util.doctree | Bin 0 -> 69200 bytes ...sting.benchmarks.nexmark.queries.query0.doctree | Bin 0 -> 11880 bytes ...sting.benchmarks.nexmark.queries.query1.doctree | Bin 0 -> 7090 bytes ...ting.benchmarks.nexmark.queries.query10.doctree | Bin 0 -> 33758 bytes ...ting.benchmarks.nexmark.queries.query11.doctree | Bin 0 -> 7025 bytes ...ting.benchmarks.nexmark.queries.query12.doctree | Bin 0 -> 6939 bytes ...sting.benchmarks.nexmark.queries.query2.doctree | Bin 0 -> 6901 bytes ...sting.benchmarks.nexmark.queries.query3.doctree | Bin 0 -> 30335 bytes ...sting.benchmarks.nexmark.queries.query4.doctree | Bin 0 -> 15151 bytes ...sting.benchmarks.nexmark.queries.query5.doctree | Bin 0 -> 17816 bytes ...sting.benchmarks.nexmark.queries.query6.doctree | Bin 0 -> 17588 bytes ...sting.benchmarks.nexmark.queries.query7.doctree | Bin 0 -> 12550 bytes ...sting.benchmarks.nexmark.queries.query8.doctree | Bin 0 -> 12118 bytes ...sting.benchmarks.nexmark.queries.query9.doctree | Bin 0 -> 6622 bytes ...benchmarks.nexmark.queries.winning_bids.doctree | Bin 0 -> 46339 bytes ...pache_beam.testing.benchmarks.wordcount.doctree | Bin 0 -> 3719 bytes ....testing.benchmarks.wordcount.wordcount.doctree | Bin 0 -> 2696 bytes .../apache_beam.testing.datatype_inference.doctree | Bin 0 -> 19218 bytes pydoc/2.66.0/doctrees/apache_beam.testing.doctree | Bin 0 -> 4354 bytes .../apache_beam.testing.extra_assertions.doctree | Bin 0 -> 7922 bytes ...ting.load_tests.dataflow_cost_benchmark.doctree | Bin 0 -> 2722 bytes ...testing.load_tests.dataflow_cost_consts.doctree | Bin 0 -> 16198 bytes .../apache_beam.testing.load_tests.doctree | Bin 0 -> 3748 bytes ...ting.load_tests.load_test_metrics_utils.doctree | Bin 0 -> 155187 bytes ...che_beam.testing.metric_result_matchers.doctree | Bin 0 -> 26206 bytes .../apache_beam.testing.pipeline_verifiers.doctree | Bin 0 -> 23294 bytes .../apache_beam.testing.synthetic_pipeline.doctree | Bin 0 -> 136582 bytes .../apache_beam.testing.test_pipeline.doctree | Bin 0 -> 35388 bytes .../apache_beam.testing.test_stream.doctree | Bin 0 -> 48951 bytes ...apache_beam.testing.test_stream_service.doctree | Bin 0 -> 12802 bytes .../apache_beam.testing.test_utils.doctree | Bin 0 -> 53409 bytes .../doctrees/apache_beam.testing.util.doctree | Bin 0 -> 40247 bytes ...transforms.combinefn_lifecycle_pipeline.doctree | Bin 0 -> 38548 bytes .../apache_beam.transforms.combiners.doctree | Bin 0 -> 199931 bytes .../doctrees/apache_beam.transforms.core.doctree | Bin 0 -> 528848 bytes .../apache_beam.transforms.create_source.doctree | Bin 0 -> 3048 bytes .../apache_beam.transforms.deduplicate.doctree | Bin 0 -> 15694 bytes .../apache_beam.transforms.display.doctree | Bin 0 -> 60597 bytes .../2.66.0/doctrees/apache_beam.transforms.doctree | Bin 0 -> 5303 bytes .../apache_beam.transforms.enrichment.doctree | Bin 0 -> 51763 bytes ...transforms.enrichment_handlers.bigquery.doctree | Bin 0 -> 51366 bytes ...transforms.enrichment_handlers.bigtable.doctree | Bin 0 -> 23059 bytes ...che_beam.transforms.enrichment_handlers.doctree | Bin 0 -> 4003 bytes ...enrichment_handlers.feast_feature_store.doctree | Bin 0 -> 34142 bytes ...am.transforms.enrichment_handlers.utils.doctree | Bin 0 -> 12542 bytes ...chment_handlers.vertex_ai_feature_store.doctree | Bin 0 -> 52051 bytes .../apache_beam.transforms.environments.doctree | Bin 0 -> 227512 bytes .../apache_beam.transforms.error_handling.doctree | Bin 0 -> 24046 bytes .../apache_beam.transforms.external.doctree | Bin 0 -> 149510 bytes .../apache_beam.transforms.external_java.doctree | Bin 0 -> 17380 bytes ....transforms.external_transform_provider.doctree | Bin 0 -> 41005 bytes ...nsforms.fully_qualified_named_transform.doctree | Bin 0 -> 14233 bytes .../apache_beam.transforms.managed.doctree | Bin 0 -> 31872 bytes ...apache_beam.transforms.periodicsequence.doctree | Bin 0 -> 39477 bytes .../apache_beam.transforms.ptransform.doctree | Bin 0 -> 95652 bytes .../apache_beam.transforms.resources.doctree | Bin 0 -> 71391 bytes .../apache_beam.transforms.sideinputs.doctree | Bin 0 -> 15908 bytes .../doctrees/apache_beam.transforms.sql.doctree | Bin 0 -> 16884 bytes .../doctrees/apache_beam.transforms.stats.doctree | Bin 0 -> 50749 bytes .../apache_beam.transforms.timeutil.doctree | Bin 0 -> 15149 bytes .../apache_beam.transforms.trigger.doctree | Bin 0 -> 178456 bytes .../apache_beam.transforms.userstate.doctree | Bin 0 -> 170130 bytes .../doctrees/apache_beam.transforms.util.doctree | Bin 0 -> 184773 bytes .../doctrees/apache_beam.transforms.window.doctree | Bin 0 -> 176595 bytes .../doctrees/apache_beam.transforms.xlang.doctree | Bin 0 -> 5046 bytes .../apache_beam.transforms.xlang.io.doctree | Bin 0 -> 33357 bytes ...typehints.arrow_batching_microbenchmark.doctree | Bin 0 -> 9225 bytes ...beam.typehints.arrow_type_compatibility.doctree | Bin 0 -> 3730 bytes .../doctrees/apache_beam.typehints.batch.doctree | Bin 0 -> 28001 bytes .../apache_beam.typehints.decorators.doctree | Bin 0 -> 56082 bytes .../2.66.0/doctrees/apache_beam.typehints.doctree | Bin 0 -> 4997 bytes ...apache_beam.typehints.intrinsic_one_ops.doctree | Bin 0 -> 26502 bytes ...eam.typehints.native_type_compatibility.doctree | Bin 0 -> 44393 bytes .../doctrees/apache_beam.typehints.opcodes.doctree | Bin 0 -> 205824 bytes ...eam.typehints.pandas_type_compatibility.doctree | Bin 0 -> 8393 bytes ...am.typehints.pytorch_type_compatibility.doctree | Bin 0 -> 26290 bytes .../apache_beam.typehints.row_type.doctree | Bin 0 -> 74737 bytes .../apache_beam.typehints.schema_registry.doctree | Bin 0 -> 12101 bytes .../doctrees/apache_beam.typehints.schemas.doctree | Bin 0 -> 280319 bytes .../apache_beam.typehints.sharded_key_type.doctree | Bin 0 -> 13236 bytes .../doctrees/apache_beam.typehints.testing.doctree | Bin 0 -> 3929 bytes ...pache_beam.typehints.testing.strategies.doctree | Bin 0 -> 8889 bytes ...apache_beam.typehints.trivial_inference.doctree | Bin 0 -> 54486 bytes .../apache_beam.typehints.typecheck.doctree | Bin 0 -> 65454 bytes .../apache_beam.typehints.typehints.doctree | Bin 0 -> 18448 bytes .../doctrees/apache_beam.utils.annotations.doctree | Bin 0 -> 23192 bytes pydoc/2.66.0/doctrees/apache_beam.utils.doctree | Bin 0 -> 4627 bytes .../doctrees/apache_beam.utils.histogram.doctree | Bin 0 -> 44354 bytes .../apache_beam.utils.interactive_utils.doctree | Bin 0 -> 10727 bytes .../apache_beam.utils.multi_process_shared.doctree | Bin 0 -> 27264 bytes .../doctrees/apache_beam.utils.plugin.doctree | Bin 0 -> 9701 bytes .../doctrees/apache_beam.utils.processes.doctree | Bin 0 -> 11101 bytes .../doctrees/apache_beam.utils.profiler.doctree | Bin 0 -> 29575 bytes .../doctrees/apache_beam.utils.proto_utils.doctree | Bin 0 -> 35545 bytes .../apache_beam.utils.python_callable.doctree | Bin 0 -> 20720 bytes .../doctrees/apache_beam.utils.retry.doctree | Bin 0 -> 44328 bytes .../doctrees/apache_beam.utils.sentinel.doctree | Bin 0 -> 7221 bytes .../doctrees/apache_beam.utils.sharded_key.doctree | Bin 0 -> 9795 bytes .../doctrees/apache_beam.utils.shared.doctree | Bin 0 -> 20722 bytes .../apache_beam.utils.subprocess_server.doctree | Bin 0 -> 55589 bytes .../apache_beam.utils.thread_pool_executor.doctree | Bin 0 -> 11691 bytes .../doctrees/apache_beam.utils.timestamp.doctree | Bin 0 -> 60737 bytes ...e_beam.utils.transform_service_launcher.doctree | Bin 0 -> 14013 bytes .../2.66.0/doctrees/apache_beam.utils.urns.doctree | Bin 0 -> 43936 bytes ...ache_beam.yaml.cache_provider_artifacts.doctree | Bin 0 -> 4865 bytes .../doctrees/apache_beam.yaml.conftest.doctree | Bin 0 -> 6145 bytes pydoc/2.66.0/doctrees/apache_beam.yaml.doctree | Bin 0 -> 4512 bytes .../doctrees/apache_beam.yaml.examples.doctree | Bin 0 -> 3556 bytes .../apache_beam.yaml.examples.testing.doctree | Bin 0 -> 3643 bytes ...e_beam.yaml.examples.testing.input_data.doctree | Bin 0 -> 13589 bytes .../apache_beam.yaml.generate_yaml_docs.doctree | Bin 0 -> 25942 bytes .../doctrees/apache_beam.yaml.json_utils.doctree | Bin 0 -> 41017 bytes .../2.66.0/doctrees/apache_beam.yaml.main.doctree | Bin 0 -> 13300 bytes .../doctrees/apache_beam.yaml.options.doctree | Bin 0 -> 13591 bytes .../doctrees/apache_beam.yaml.yaml_combine.doctree | Bin 0 -> 20700 bytes .../apache_beam.yaml.yaml_enrichment.doctree | Bin 0 -> 20058 bytes .../doctrees/apache_beam.yaml.yaml_errors.doctree | Bin 0 -> 16110 bytes .../doctrees/apache_beam.yaml.yaml_io.doctree | Bin 0 -> 142788 bytes .../doctrees/apache_beam.yaml.yaml_join.doctree | Bin 0 -> 4877 bytes .../doctrees/apache_beam.yaml.yaml_mapping.doctree | Bin 0 -> 35559 bytes .../doctrees/apache_beam.yaml.yaml_ml.doctree | Bin 0 -> 94736 bytes .../apache_beam.yaml.yaml_provider.doctree | Bin 0 -> 282575 bytes .../apache_beam.yaml.yaml_specifiable.doctree | Bin 0 -> 11159 bytes .../doctrees/apache_beam.yaml.yaml_testing.doctree | Bin 0 -> 35725 bytes .../apache_beam.yaml.yaml_transform.doctree | Bin 0 -> 7741 bytes .../doctrees/apache_beam.yaml.yaml_utils.doctree | Bin 0 -> 21423 bytes pydoc/2.66.0/doctrees/environment.pickle | Bin 0 -> 17754195 bytes pydoc/2.66.0/doctrees/index.doctree | Bin 0 -> 17280 bytes pydoc/2.66.0/genindex.html | 16911 +++++++++++++++ pydoc/2.66.0/index.html | 1773 ++ pydoc/2.66.0/objects.inv | Bin 0 -> 56338 bytes pydoc/2.66.0/py-modindex.html | 2336 +++ pydoc/2.66.0/search.html | 136 + pydoc/2.66.0/searchindex.js | 1 + pydoc/current | 2 +- typedoc/2.66.0/.nojekyll | 1 + typedoc/2.66.0/assets/highlight.css | 99 + typedoc/2.66.0/assets/main.js | 4 + typedoc/2.66.0/assets/search.js | 1 + typedoc/2.66.0/assets/style.css | 1280 ++ .../classes/coders_js_coders.BsonObjectCoder.html | 264 + .../coders_js_coders.GeneralObjectCoder.html | 325 + .../classes/coders_required_coders.BytesCoder.html | 278 + ...ers_required_coders.FullWindowedValueCoder.html | 299 + .../coders_required_coders.GlobalWindowCoder.html | 262 + .../coders_required_coders.InstantCoder.html | 262 + .../coders_required_coders.IterableCoder.html | 306 + .../classes/coders_required_coders.KVCoder.html | 301 + ...coders_required_coders.LengthPrefixedCoder.html | 279 + .../coders_required_coders.PaneInfoCoder.html | 307 + .../2.66.0/classes/coders_row_coder.RowCoder.html | 444 + .../classes/coders_standard_coders.BoolCoder.html | 247 + .../coders_standard_coders.DoubleCoder.html | 240 + ...coders_standard_coders.IntervalWindowCoder.html | 255 + .../coders_standard_coders.NullableCoder.html | 286 + .../coders_standard_coders.StrUtf8Coder.html | 279 + .../coders_standard_coders.VarIntCoder.html | 254 + typedoc/2.66.0/classes/pvalue.PCollection.html | 282 + typedoc/2.66.0/classes/pvalue.Root.html | 192 + ...ners_portable_runner_runner.PortableRunner.html | 364 + .../classes/runners_runner.PipelineResult.html | 206 + typedoc/2.66.0/classes/runners_runner.Runner.html | 255 + ..._multi_pipeline_runner.MultiPipelineRunner.html | 372 + ..._proto_printing_runner.ProtoPrintingRunner.html | 251 + .../transforms_group_and_combine.GroupBy.html | 324 + ...transforms_group_and_combine.GroupGlobally.html | 278 + .../2.66.0/classes/transforms_pardo.Counter.html | 234 + .../2.66.0/classes/transforms_pardo.Metric.html | 231 + .../classes/transforms_pardo.ParDoLookupParam.html | 184 + .../classes/transforms_pardo.ParDoParam.html | 162 + .../classes/transforms_pardo.ParDoUpdateParam.html | 189 + .../classes/transforms_pardo.SideInputParam.html | 241 + .../classes/utils_service.ExternalService.html | 206 + .../classes/utils_service.JavaJarService.html | 416 + .../classes/utils_service.PythonService.html | 357 + .../classes/utils_service.SubprocessService.html | 300 + typedoc/2.66.0/classes/values.GlobalWindow.html | 176 + typedoc/2.66.0/classes/values.IntervalWindow.html | 204 + typedoc/2.66.0/enums/coders_coders.Context.html | 172 + typedoc/2.66.0/enums/values.Timing.html | 172 + .../functions/coders_coders.globalRegistry.html | 143 + .../functions/coders_coders.writeRawByte.html | 152 + .../functions/coders_coders.writeRawBytes.html | 153 + .../coders_row_coder.registerLogicalType.html | 144 + .../2.66.0/functions/io_avroio.readFromAvro.html | 154 + .../2.66.0/functions/io_avroio.writeToAvro.html | 165 + .../functions/io_bigqueryio.readFromBigQuery.html | 149 + .../functions/io_bigqueryio.writeToBigQuery.html | 154 + .../2.66.0/functions/io_kafka.readFromKafka.html | 159 + .../io_kafka.readFromKafkaWithMetadata.html | 159 + .../2.66.0/functions/io_kafka.writeToKafka.html | 161 + .../functions/io_parquetio.readFromParquet.html | 160 + .../functions/io_parquetio.writeToParquet.html | 160 + .../2.66.0/functions/io_pubsub.readFromPubSub.html | 145 + .../io_pubsub.readFromPubSubWithAttributes.html | 145 + .../2.66.0/functions/io_pubsub.writeToPubSub.html | 158 + .../io_pubsublite.readFromPubSubLiteRaw.html | 151 + .../io_pubsublite.writeToPubSubLiteRaw.html | 149 + typedoc/2.66.0/functions/io_schemaio.schemaio.html | 156 + .../2.66.0/functions/io_textio.readFromCsv.html | 162 + .../2.66.0/functions/io_textio.readFromJson.html | 162 + .../2.66.0/functions/io_textio.readFromText.html | 148 + typedoc/2.66.0/functions/io_textio.writeToCsv.html | 164 + .../2.66.0/functions/io_textio.writeToJson.html | 164 + .../2.66.0/functions/io_textio.writeToText.html | 174 + typedoc/2.66.0/functions/pvalue.P.html | 157 + typedoc/2.66.0/functions/pvalue.flattenPValue.html | 161 + .../functions/runners_dataflow.dataflowRunner.html | 152 + .../runners_direct_runner.directRunner.html | 143 + .../functions/runners_flink.flinkRunner.html | 143 + .../functions/runners_runner.createRunner.html | 155 + .../functions/runners_runner.defaultRunner.html | 147 + .../functions/runners_runner.loopbackRunner.html | 147 + .../runners_universal.universalRunner.html | 146 + .../serialization.getRegisteredModules.html | 140 + .../serialization.requireForSerialization.html | 174 + .../testing_assert.assertContentsSatisfies.html | 165 + .../functions/testing_assert.assertDeepEqual.html | 155 + .../2.66.0/functions/transforms_create.create.html | 153 + .../transforms_external.rawExternalTransform.html | 157 + .../functions/transforms_flatten.flatten-1.html | 147 + ...ansforms_group_and_combine.binaryCombineFn.html | 172 + .../transforms_group_and_combine.coGroupBy.html | 160 + ...transforms_group_and_combine.countGlobally.html | 151 + ...ansforms_group_and_combine.countPerElement.html | 151 + .../transforms_group_and_combine.groupBy-1.html | 166 + ...ansforms_group_and_combine.groupGlobally-1.html | 158 + .../transforms_internal.combinePerKey-1.html | 168 + .../transforms_internal.groupByKey-1.html | 157 + .../functions/transforms_internal.impulse-1.html | 148 + .../transforms_internal.withCoderInternal.html | 152 + .../transforms_internal.withRowCoder.html | 160 + .../functions/transforms_pardo.counter-1.html | 161 + .../functions/transforms_pardo.distribution.html | 161 + .../transforms_pardo.iterableSideInput.html | 166 + .../functions/transforms_pardo.paneInfoParam.html | 156 + .../2.66.0/functions/transforms_pardo.parDo-1.html | 174 + .../functions/transforms_pardo.partition.html | 181 + .../transforms_pardo.singletonSideInput.html | 168 + .../2.66.0/functions/transforms_pardo.split.html | 173 + .../functions/transforms_pardo.timestampParam.html | 156 + .../functions/transforms_pardo.windowParam.html | 156 + .../functions/transforms_pardo.withContext.html | 175 + .../transforms_python.pythonCallable.html | 160 + .../transforms_python.pythonTransform.html | 163 + .../functions/transforms_sql.sqlTransform.html | 163 + .../transforms_transform.extractName.html | 157 + .../functions/transforms_transform.withName.html | 159 + .../functions/transforms_utils.reshuffle.html | 146 + .../transforms_window.assignTimestamps.html | 163 + .../functions/transforms_window.windowInto.html | 159 + .../transforms_windowings.fixedWindows.html | 148 + .../transforms_windowings.globalWindows.html | 141 + .../functions/transforms_windowings.sessions.html | 146 + .../transforms_windowings.slidingWindows.html | 150 + ...ervice.serviceProviderFromJavaGradleTarget.html | 156 + typedoc/2.66.0/index.html | 258 + typedoc/2.66.0/interfaces/coders_coders.Coder.html | 248 + .../interfaces/coders_coders.ProtoContext.html | 163 + ...forms_external.RawExternalTransformOptions.html | 167 + .../transforms_group_and_combine.CombineFn.html | 262 + .../2.66.0/interfaces/transforms_pardo.DoFn.html | 248 + .../interfaces/transforms_window.WindowFn.html | 240 + .../2.66.0/interfaces/utils_service.Service.html | 182 + typedoc/2.66.0/interfaces/values.PaneInfo.html | 183 + typedoc/2.66.0/interfaces/values.Window.html | 163 + .../2.66.0/interfaces/values.WindowedValue.html | 181 + typedoc/2.66.0/modules.html | 208 + typedoc/2.66.0/modules/coders_coders.html | 157 + typedoc/2.66.0/modules/coders_js_coders.html | 143 + typedoc/2.66.0/modules/coders_required_coders.html | 155 + typedoc/2.66.0/modules/coders_row_coder.html | 146 + typedoc/2.66.0/modules/coders_standard_coders.html | 190 + typedoc/2.66.0/modules/index.html | 443 + typedoc/2.66.0/modules/io-1.html | 211 + typedoc/2.66.0/modules/io.html | 211 + typedoc/2.66.0/modules/io_avroio-1.html | 151 + typedoc/2.66.0/modules/io_avroio.html | 143 + typedoc/2.66.0/modules/io_bigqueryio-1.html | 151 + typedoc/2.66.0/modules/io_bigqueryio.html | 143 + typedoc/2.66.0/modules/io_kafka-1.html | 163 + typedoc/2.66.0/modules/io_kafka.html | 152 + typedoc/2.66.0/modules/io_parquetio-1.html | 151 + typedoc/2.66.0/modules/io_parquetio.html | 143 + typedoc/2.66.0/modules/io_pubsub-1.html | 155 + typedoc/2.66.0/modules/io_pubsub.html | 145 + typedoc/2.66.0/modules/io_pubsublite-1.html | 151 + typedoc/2.66.0/modules/io_pubsublite.html | 143 + typedoc/2.66.0/modules/io_schemaio-1.html | 147 + typedoc/2.66.0/modules/io_schemaio.html | 141 + typedoc/2.66.0/modules/io_textio-1.html | 167 + typedoc/2.66.0/modules/io_textio.html | 151 + .../2.66.0/modules/options_pipeline_options.html | 141 + typedoc/2.66.0/modules/pvalue.html | 155 + typedoc/2.66.0/modules/runners-1.html | 151 + typedoc/2.66.0/modules/runners.html | 151 + typedoc/2.66.0/modules/runners_dataflow-1.html | 147 + typedoc/2.66.0/modules/runners_dataflow.html | 141 + .../2.66.0/modules/runners_direct_runner-1.html | 147 + typedoc/2.66.0/modules/runners_direct_runner.html | 141 + typedoc/2.66.0/modules/runners_flink-1.html | 147 + typedoc/2.66.0/modules/runners_flink.html | 141 + .../modules/runners_portable_runner_runner-1.html | 147 + .../modules/runners_portable_runner_runner.html | 141 + typedoc/2.66.0/modules/runners_runner-1.html | 163 + typedoc/2.66.0/modules/runners_runner.html | 152 + typedoc/2.66.0/modules/runners_universal-1.html | 147 + typedoc/2.66.0/modules/runners_universal.html | 141 + typedoc/2.66.0/modules/serialization.html | 148 + typedoc/2.66.0/modules/testing_assert-1.html | 155 + typedoc/2.66.0/modules/testing_assert.html | 147 + .../modules/testing_multi_pipeline_runner-1.html | 147 + .../modules/testing_multi_pipeline_runner.html | 141 + .../modules/testing_proto_printing_runner-1.html | 147 + .../modules/testing_proto_printing_runner.html | 141 + typedoc/2.66.0/modules/transforms-1.html | 315 + typedoc/2.66.0/modules/transforms.html | 315 + typedoc/2.66.0/modules/transforms_combiners-1.html | 163 + typedoc/2.66.0/modules/transforms_combiners.html | 149 + typedoc/2.66.0/modules/transforms_create-1.html | 147 + typedoc/2.66.0/modules/transforms_create.html | 141 + typedoc/2.66.0/modules/transforms_external-1.html | 151 + typedoc/2.66.0/modules/transforms_external.html | 146 + typedoc/2.66.0/modules/transforms_flatten-1.html | 147 + .../2.66.0/modules/transforms_flatten.flatten.html | 134 + typedoc/2.66.0/modules/transforms_flatten.html | 145 + .../modules/transforms_group_and_combine-1.html | 179 + .../modules/transforms_group_and_combine.html | 163 + typedoc/2.66.0/modules/transforms_internal-1.html | 163 + .../modules/transforms_internal.combinePerKey.html | 141 + .../modules/transforms_internal.groupByKey.html | 141 + typedoc/2.66.0/modules/transforms_internal.html | 155 + .../modules/transforms_internal.impulse.html | 141 + typedoc/2.66.0/modules/transforms_pardo-1.html | 219 + typedoc/2.66.0/modules/transforms_pardo.html | 190 + typedoc/2.66.0/modules/transforms_pardo.parDo.html | 152 + typedoc/2.66.0/modules/transforms_python-1.html | 155 + typedoc/2.66.0/modules/transforms_python.html | 147 + typedoc/2.66.0/modules/transforms_sql-1.html | 147 + typedoc/2.66.0/modules/transforms_sql.html | 141 + typedoc/2.66.0/modules/transforms_transform-1.html | 159 + typedoc/2.66.0/modules/transforms_transform.html | 150 + typedoc/2.66.0/modules/transforms_utils-1.html | 147 + typedoc/2.66.0/modules/transforms_utils.html | 141 + typedoc/2.66.0/modules/transforms_window-1.html | 155 + typedoc/2.66.0/modules/transforms_window.html | 148 + .../2.66.0/modules/transforms_windowings-1.html | 159 + typedoc/2.66.0/modules/transforms_windowings.html | 147 + typedoc/2.66.0/modules/utils_packageJson.html | 145 + typedoc/2.66.0/modules/utils_service.html | 157 + typedoc/2.66.0/modules/values.html | 164 + .../types/io_kafka.ReadFromKafkaOptions.html | 155 + .../2.66.0/types/io_kafka.WriteToKafkaOptions.html | 145 + .../options_pipeline_options.PipelineOptions.html | 134 + typedoc/2.66.0/types/pvalue.PValue.html | 145 + .../types/transforms_pardo.SplitOptions.html | 163 + .../transforms_transform.AsyncPTransform.html | 149 + .../types/transforms_transform.PTransform.html | 157 + typedoc/2.66.0/types/values.Instant.html | 141 + typedoc/2.66.0/types/values.KV.html | 155 + .../variables/serialization.registeredObjects.html | 136 + .../variables/transforms_combiners.count.html | 138 + .../2.66.0/variables/transforms_combiners.max.html | 138 + .../variables/transforms_combiners.mean.html | 138 + .../2.66.0/variables/transforms_combiners.min.html | 138 + .../2.66.0/variables/transforms_combiners.sum.html | 138 + .../transforms_internal.combinePerKey.urn.html | 135 + .../transforms_internal.groupByKey.urn.html | 135 + .../variables/transforms_internal.impulse.urn.html | 135 + .../variables/utils_packageJson.beamVersion.html | 136 + .../variables/utils_packageJson.packageJson.html | 136 + .../variables/utils_packageJson.packageName.html | 136 + typedoc/current | 2 +- yamldoc/2.66.0/examples.html | 1584 ++ yamldoc/2.66.0/index.html | 1878 ++ yamldoc/current | 2 +- 1984 files changed, 412641 insertions(+), 4 deletions(-)
