This is an automated email from the ASF dual-hosted git repository. apilloud pushed a commit to branch release-docs in repository https://gitbox.apache.org/repos/asf/beam-site.git
commit 74837c41c65e2a76c19b320bdd577641fa73435f Merge: c980fc2 26cf019 Author: Andrew Pilloud <[email protected]> AuthorDate: Thu Jul 8 10:17:35 2021 -0700 Merge pull request #615: Publish 2.31.0 release pydoc/2.31.0/.buildinfo | 4 + .../apache_beam.coders.avro_record.doctree | Bin 0 -> 6094 bytes .../.doctrees/apache_beam.coders.coders.doctree | Bin 0 -> 202552 bytes pydoc/2.31.0/.doctrees/apache_beam.coders.doctree | Bin 0 -> 3608 bytes .../apache_beam.coders.observable.doctree | Bin 0 -> 9653 bytes .../.doctrees/apache_beam.coders.row_coder.doctree | Bin 0 -> 17318 bytes .../apache_beam.coders.slow_stream.doctree | Bin 0 -> 44834 bytes .../apache_beam.coders.typecoders.doctree | Bin 0 -> 10173 bytes .../apache_beam.dataframe.convert.doctree | Bin 0 -> 17618 bytes .../apache_beam.dataframe.doctests.doctree | Bin 0 -> 78145 bytes .../2.31.0/.doctrees/apache_beam.dataframe.doctree | Bin 0 -> 8848 bytes .../apache_beam.dataframe.expressions.doctree | Bin 0 -> 81313 bytes .../apache_beam.dataframe.frame_base.doctree | Bin 0 -> 41240 bytes .../.doctrees/apache_beam.dataframe.frames.doctree | Bin 0 -> 4053569 bytes .../.doctrees/apache_beam.dataframe.io.doctree | Bin 0 -> 692282 bytes ...am.dataframe.pandas_top_level_functions.doctree | Bin 0 -> 46633 bytes .../apache_beam.dataframe.partitionings.doctree | Bin 0 -> 35396 bytes .../apache_beam.dataframe.schemas.doctree | Bin 0 -> 25881 bytes .../apache_beam.dataframe.transforms.doctree | Bin 0 -> 20110 bytes pydoc/2.31.0/.doctrees/apache_beam.error.doctree | Bin 0 -> 19271 bytes .../2.31.0/.doctrees/apache_beam.io.avroio.doctree | Bin 0 -> 52183 bytes .../.doctrees/apache_beam.io.aws.clients.doctree | Bin 0 -> 3524 bytes ...che_beam.io.aws.clients.s3.boto3_client.doctree | Bin 0 -> 29638 bytes .../apache_beam.io.aws.clients.s3.doctree | Bin 0 -> 3666 bytes ...ache_beam.io.aws.clients.s3.fake_client.doctree | Bin 0 -> 31204 bytes .../apache_beam.io.aws.clients.s3.messages.doctree | Bin 0 -> 44544 bytes pydoc/2.31.0/.doctrees/apache_beam.io.aws.doctree | Bin 0 -> 3891 bytes .../apache_beam.io.aws.s3filesystem.doctree | Bin 0 -> 55173 bytes .../.doctrees/apache_beam.io.aws.s3io.doctree | Bin 0 -> 71256 bytes ...che_beam.io.azure.blobstoragefilesystem.doctree | Bin 0 -> 58734 bytes .../apache_beam.io.azure.blobstorageio.doctree | Bin 0 -> 85189 bytes .../2.31.0/.doctrees/apache_beam.io.azure.doctree | Bin 0 -> 3505 bytes .../.doctrees/apache_beam.io.concat_source.doctree | Bin 0 -> 36050 bytes .../.doctrees/apache_beam.io.debezium.doctree | Bin 0 -> 29674 bytes pydoc/2.31.0/.doctrees/apache_beam.io.doctree | Bin 0 -> 5059 bytes .../.doctrees/apache_beam.io.external.doctree | Bin 0 -> 4009 bytes .../.doctrees/apache_beam.io.external.gcp.doctree | Bin 0 -> 3537 bytes .../apache_beam.io.external.gcp.pubsub.doctree | Bin 0 -> 45022 bytes ...ache_beam.io.external.generate_sequence.doctree | Bin 0 -> 10864 bytes .../apache_beam.io.external.kafka.doctree | Bin 0 -> 2957 bytes .../apache_beam.io.external.snowflake.doctree | Bin 0 -> 3001 bytes .../.doctrees/apache_beam.io.filebasedsink.doctree | Bin 0 -> 32494 bytes .../apache_beam.io.filebasedsource.doctree | Bin 0 -> 42650 bytes .../2.31.0/.doctrees/apache_beam.io.fileio.doctree | Bin 0 -> 51917 bytes .../.doctrees/apache_beam.io.filesystem.doctree | Bin 0 -> 121895 bytes .../.doctrees/apache_beam.io.filesystemio.doctree | Bin 0 -> 59462 bytes .../.doctrees/apache_beam.io.filesystems.doctree | Bin 0 -> 69220 bytes .../2.31.0/.doctrees/apache_beam.io.flink.doctree | Bin 0 -> 3470 bytes ...io.flink.flink_streaming_impulse_source.doctree | Bin 0 -> 22512 bytes ...o.gcp.big_query_query_to_table_pipeline.doctree | Bin 0 -> 6983 bytes .../.doctrees/apache_beam.io.gcp.bigquery.doctree | Bin 0 -> 226748 bytes .../apache_beam.io.gcp.bigquery_avro_tools.doctree | Bin 0 -> 17032 bytes .../apache_beam.io.gcp.bigquery_file_loads.doctree | Bin 0 -> 98526 bytes ...apache_beam.io.gcp.bigquery_io_metadata.doctree | Bin 0 -> 11082 bytes ...e_beam.io.gcp.bigquery_io_read_pipeline.doctree | Bin 0 -> 10343 bytes ...ache_beam.io.gcp.bigquery_read_internal.doctree | Bin 0 -> 14609 bytes .../apache_beam.io.gcp.bigquery_tools.doctree | Bin 0 -> 187258 bytes .../apache_beam.io.gcp.bigtableio.doctree | Bin 0 -> 12415 bytes .../.doctrees/apache_beam.io.gcp.datastore.doctree | Bin 0 -> 3553 bytes ....gcp.datastore.v1new.adaptive_throttler.doctree | Bin 0 -> 18105 bytes ...store.v1new.datastore_write_it_pipeline.doctree | Bin 0 -> 16300 bytes ...beam.io.gcp.datastore.v1new.datastoreio.doctree | Bin 0 -> 34602 bytes .../apache_beam.io.gcp.datastore.v1new.doctree | Bin 0 -> 3967 bytes ...ache_beam.io.gcp.datastore.v1new.helper.doctree | Bin 0 -> 12436 bytes ...m.io.gcp.datastore.v1new.query_splitter.doctree | Bin 0 -> 17154 bytes ...pache_beam.io.gcp.datastore.v1new.types.doctree | Bin 0 -> 38932 bytes ...apache_beam.io.gcp.datastore.v1new.util.doctree | Bin 0 -> 21165 bytes .../apache_beam.io.gcp.dicomclient.doctree | Bin 0 -> 14668 bytes .../.doctrees/apache_beam.io.gcp.dicomio.doctree | Bin 0 -> 45299 bytes pydoc/2.31.0/.doctrees/apache_beam.io.gcp.doctree | Bin 0 -> 4666 bytes .../apache_beam.io.gcp.experimental.doctree | Bin 0 -> 3592 bytes ...ache_beam.io.gcp.experimental.spannerio.doctree | Bin 0 -> 116255 bytes .../apache_beam.io.gcp.gce_metadata_util.doctree | Bin 0 -> 5131 bytes .../apache_beam.io.gcp.gcsfilesystem.doctree | Bin 0 -> 55645 bytes .../.doctrees/apache_beam.io.gcp.gcsio.doctree | Bin 0 -> 56764 bytes .../apache_beam.io.gcp.gcsio_overrides.doctree | Bin 0 -> 7360 bytes .../.doctrees/apache_beam.io.gcp.pubsub.doctree | Bin 0 -> 68880 bytes .../apache_beam.io.gcp.pubsub_it_pipeline.doctree | Bin 0 -> 5986 bytes ...apache_beam.io.gcp.resource_identifiers.doctree | Bin 0 -> 8123 bytes .../.doctrees/apache_beam.io.gcp.spanner.doctree | Bin 0 -> 133336 bytes .../apache_beam.io.hadoopfilesystem.doctree | Bin 0 -> 37396 bytes .../2.31.0/.doctrees/apache_beam.io.iobase.doctree | Bin 0 -> 293989 bytes pydoc/2.31.0/.doctrees/apache_beam.io.jdbc.doctree | Bin 0 -> 36414 bytes .../2.31.0/.doctrees/apache_beam.io.kafka.doctree | Bin 0 -> 65493 bytes .../.doctrees/apache_beam.io.kinesis.doctree | Bin 0 -> 53858 bytes .../apache_beam.io.localfilesystem.doctree | Bin 0 -> 53982 bytes .../.doctrees/apache_beam.io.mongodbio.doctree | Bin 0 -> 40503 bytes .../.doctrees/apache_beam.io.parquetio.doctree | Bin 0 -> 77102 bytes .../apache_beam.io.range_trackers.doctree | Bin 0 -> 69847 bytes .../apache_beam.io.restriction_trackers.doctree | Bin 0 -> 31962 bytes .../.doctrees/apache_beam.io.snowflake.doctree | Bin 0 -> 76295 bytes .../apache_beam.io.source_test_utils.doctree | Bin 0 -> 70315 bytes .../2.31.0/.doctrees/apache_beam.io.textio.doctree | Bin 0 -> 71698 bytes .../.doctrees/apache_beam.io.tfrecordio.doctree | Bin 0 -> 22462 bytes .../2.31.0/.doctrees/apache_beam.io.utils.doctree | Bin 0 -> 11760 bytes .../apache_beam.io.watermark_estimators.doctree | Bin 0 -> 36216 bytes .../.doctrees/apache_beam.metrics.cells.doctree | Bin 0 -> 35115 bytes pydoc/2.31.0/.doctrees/apache_beam.metrics.doctree | Bin 0 -> 3550 bytes .../.doctrees/apache_beam.metrics.metric.doctree | Bin 0 -> 45376 bytes .../apache_beam.metrics.metricbase.doctree | Bin 0 -> 37612 bytes .../apache_beam.metrics.monitoring_infos.doctree | Bin 0 -> 66989 bytes pydoc/2.31.0/.doctrees/apache_beam.ml.doctree | Bin 0 -> 3369 bytes .../.doctrees/apache_beam.ml.gcp.cloud_dlp.doctree | Bin 0 -> 28342 bytes pydoc/2.31.0/.doctrees/apache_beam.ml.gcp.doctree | Bin 0 -> 3550 bytes .../apache_beam.ml.gcp.naturallanguageml.doctree | Bin 0 -> 23119 bytes .../apache_beam.ml.gcp.videointelligenceml.doctree | Bin 0 -> 25731 bytes .../.doctrees/apache_beam.ml.gcp.visionml.doctree | Bin 0 -> 33891 bytes pydoc/2.31.0/.doctrees/apache_beam.options.doctree | Bin 0 -> 3541 bytes .../apache_beam.options.pipeline_options.doctree | Bin 0 -> 106079 bytes ...beam.options.pipeline_options_validator.doctree | Bin 0 -> 65131 bytes .../apache_beam.options.value_provider.doctree | Bin 0 -> 40548 bytes .../2.31.0/.doctrees/apache_beam.pipeline.doctree | Bin 0 -> 69638 bytes ...tability.api.beam_artifact_api_pb2_grpc.doctree | Bin 0 -> 91917 bytes ...tability.api.beam_artifact_api_pb2_urns.doctree | Bin 0 -> 9494 bytes ...ability.api.beam_expansion_api_pb2_grpc.doctree | Bin 0 -> 20453 bytes ...am.portability.api.beam_fn_api_pb2_grpc.doctree | Bin 0 -> 113135 bytes ...ility.api.beam_interactive_api_pb2_grpc.doctree | Bin 0 -> 3707 bytes ...m.portability.api.beam_job_api_pb2_grpc.doctree | Bin 0 -> 66800 bytes ...ability.api.beam_provision_api_pb2_grpc.doctree | Bin 0 -> 21677 bytes ...ortability.api.beam_runner_api_pb2_grpc.doctree | Bin 0 -> 20376 bytes ...ortability.api.beam_runner_api_pb2_urns.doctree | Bin 0 -> 170366 bytes .../.doctrees/apache_beam.portability.api.doctree | Bin 0 -> 5046 bytes ...beam.portability.api.endpoints_pb2_grpc.doctree | Bin 0 -> 3560 bytes ...bility.api.external_transforms_pb2_grpc.doctree | Bin 0 -> 3692 bytes ...e_beam.portability.api.metrics_pb2_grpc.doctree | Bin 0 -> 3534 bytes ...e_beam.portability.api.metrics_pb2_urns.doctree | Bin 0 -> 92012 bytes ...he_beam.portability.api.schema_pb2_grpc.doctree | Bin 0 -> 3521 bytes ...bility.api.standard_window_fns_pb2_grpc.doctree | Bin 0 -> 3694 bytes ...bility.api.standard_window_fns_pb2_urns.doctree | Bin 0 -> 26854 bytes .../apache_beam.portability.common_urns.doctree | Bin 0 -> 3363 bytes .../.doctrees/apache_beam.portability.doctree | Bin 0 -> 4364 bytes .../apache_beam.portability.python_urns.doctree | Bin 0 -> 3591 bytes .../apache_beam.portability.utils.doctree | Bin 0 -> 11148 bytes pydoc/2.31.0/.doctrees/apache_beam.pvalue.doctree | Bin 0 -> 48345 bytes ...flow.dataflow_exercise_metrics_pipeline.doctree | Bin 0 -> 16294 bytes ...low_exercise_streaming_metrics_pipeline.doctree | Bin 0 -> 14961 bytes ..._beam.runners.dataflow.dataflow_metrics.doctree | Bin 0 -> 15787 bytes ...e_beam.runners.dataflow.dataflow_runner.doctree | Bin 0 -> 83997 bytes .../.doctrees/apache_beam.runners.dataflow.doctree | Bin 0 -> 5044 bytes .../apache_beam.runners.dataflow.native_io.doctree | Bin 0 -> 3682 bytes ..._beam.runners.dataflow.native_io.iobase.doctree | Bin 0 -> 67105 bytes ...m.runners.dataflow.ptransform_overrides.doctree | Bin 0 -> 51823 bytes ...m.runners.dataflow.test_dataflow_runner.doctree | Bin 0 -> 12903 bytes ...ache_beam.runners.direct.bundle_factory.doctree | Bin 0 -> 11160 bytes .../apache_beam.runners.direct.clock.doctree | Bin 0 -> 17736 bytes ...rect.consumer_tracking_pipeline_visitor.doctree | Bin 0 -> 11671 bytes ...ache_beam.runners.direct.direct_metrics.doctree | Bin 0 -> 23510 bytes ...pache_beam.runners.direct.direct_runner.doctree | Bin 0 -> 18639 bytes ...he_beam.runners.direct.direct_userstate.doctree | Bin 0 -> 57115 bytes .../.doctrees/apache_beam.runners.direct.doctree | Bin 0 -> 4958 bytes ..._beam.runners.direct.evaluation_context.doctree | Bin 0 -> 43665 bytes .../apache_beam.runners.direct.executor.doctree | Bin 0 -> 19358 bytes ...e_beam.runners.direct.helper_transforms.doctree | Bin 0 -> 29285 bytes ...e_beam.runners.direct.sdf_direct_runner.doctree | Bin 0 -> 98689 bytes ..._beam.runners.direct.test_direct_runner.doctree | Bin 0 -> 8331 bytes ...he_beam.runners.direct.test_stream_impl.doctree | Bin 0 -> 4105 bytes ...beam.runners.direct.transform_evaluator.doctree | Bin 0 -> 25299 bytes .../apache_beam.runners.direct.util.doctree | Bin 0 -> 13814 bytes ...e_beam.runners.direct.watermark_manager.doctree | Bin 0 -> 18209 bytes pydoc/2.31.0/.doctrees/apache_beam.runners.doctree | Bin 0 -> 4588 bytes ....runners.interactive.augmented_pipeline.doctree | Bin 0 -> 16577 bytes ...ners.interactive.background_caching_job.doctree | Bin 0 -> 44611 bytes ..._beam.runners.interactive.cache_manager.doctree | Bin 0 -> 70553 bytes ...m.runners.interactive.caching.cacheable.doctree | Bin 0 -> 13321 bytes ...apache_beam.runners.interactive.caching.doctree | Bin 0 -> 3878 bytes ....runners.interactive.caching.read_cache.doctree | Bin 0 -> 12724 bytes ...ers.interactive.caching.streaming_cache.doctree | Bin 0 -> 55894 bytes ...runners.interactive.caching.write_cache.doctree | Bin 0 -> 12505 bytes ...ers.interactive.display.display_manager.doctree | Bin 0 -> 18217 bytes ...apache_beam.runners.interactive.display.doctree | Bin 0 -> 3978 bytes ...tive.display.interactive_pipeline_graph.doctree | Bin 0 -> 18568 bytes ...interactive.display.pcoll_visualization.doctree | Bin 0 -> 28633 bytes ...ners.interactive.display.pipeline_graph.doctree | Bin 0 -> 14635 bytes ...ractive.display.pipeline_graph_renderer.doctree | Bin 0 -> 37163 bytes .../apache_beam.runners.interactive.doctree | Bin 0 -> 4811 bytes ...am.runners.interactive.interactive_beam.doctree | Bin 0 -> 38024 bytes ...ers.interactive.interactive_environment.doctree | Bin 0 -> 105297 bytes ....runners.interactive.interactive_runner.doctree | Bin 0 -> 38792 bytes ...ache_beam.runners.interactive.messaging.doctree | Bin 0 -> 3746 bytes ...aging.interactive_environment_inspector.doctree | Bin 0 -> 29444 bytes ...ers.interactive.options.capture_control.doctree | Bin 0 -> 13037 bytes ...rs.interactive.options.capture_limiters.doctree | Bin 0 -> 36980 bytes ...apache_beam.runners.interactive.options.doctree | Bin 0 -> 3835 bytes ...interactive.options.interactive_options.doctree | Bin 0 -> 8137 bytes ...m.runners.interactive.pipeline_fragment.doctree | Bin 0 -> 13432 bytes ...runners.interactive.pipeline_instrument.doctree | Bin 0 -> 57891 bytes ...m.runners.interactive.recording_manager.doctree | Bin 0 -> 46821 bytes ...apache_beam.runners.interactive.testing.doctree | Bin 0 -> 4290 bytes ...runners.interactive.testing.integration.doctree | Bin 0 -> 3933 bytes ...e.testing.integration.notebook_executor.doctree | Bin 0 -> 22597 bytes ...ractive.testing.integration.screen_diff.doctree | Bin 0 -> 20007 bytes ...unners.interactive.testing.mock_ipython.doctree | Bin 0 -> 7376 bytes ....interactive.testing.pipeline_assertion.doctree | Bin 0 -> 18093 bytes ....interactive.testing.test_cache_manager.doctree | Bin 0 -> 36449 bytes ...nners.interactive.user_pipeline_tracker.doctree | Bin 0 -> 24758 bytes .../apache_beam.runners.interactive.utils.doctree | Bin 0 -> 31519 bytes .../.doctrees/apache_beam.runners.job.doctree | Bin 0 -> 3525 bytes .../apache_beam.runners.job.manager.doctree | Bin 0 -> 6274 bytes .../apache_beam.runners.job.utils.doctree | Bin 0 -> 6608 bytes .../apache_beam.runners.pipeline_context.doctree | Bin 0 -> 27123 bytes .../.doctrees/apache_beam.runners.runner.doctree | Bin 0 -> 63183 bytes .../apache_beam.runners.sdf_utils.doctree | Bin 0 -> 56668 bytes ...transforms.combinefn_lifecycle_pipeline.doctree | Bin 0 -> 30213 bytes .../apache_beam.transforms.combiners.doctree | Bin 0 -> 102416 bytes .../.doctrees/apache_beam.transforms.core.doctree | Bin 0 -> 440889 bytes .../apache_beam.transforms.create_source.doctree | Bin 0 -> 3036 bytes .../apache_beam.transforms.deduplicate.doctree | Bin 0 -> 14468 bytes .../apache_beam.transforms.display.doctree | Bin 0 -> 56729 bytes .../.doctrees/apache_beam.transforms.doctree | Bin 0 -> 4541 bytes .../apache_beam.transforms.environments.doctree | Bin 0 -> 99936 bytes .../apache_beam.transforms.external.doctree | Bin 0 -> 60660 bytes .../apache_beam.transforms.external_java.doctree | Bin 0 -> 13719 bytes ...apache_beam.transforms.periodicsequence.doctree | Bin 0 -> 35708 bytes .../apache_beam.transforms.ptransform.doctree | Bin 0 -> 68534 bytes .../apache_beam.transforms.resources.doctree | Bin 0 -> 33070 bytes .../apache_beam.transforms.sideinputs.doctree | Bin 0 -> 11963 bytes .../.doctrees/apache_beam.transforms.sql.doctree | Bin 0 -> 15795 bytes .../.doctrees/apache_beam.transforms.stats.doctree | Bin 0 -> 48588 bytes .../apache_beam.transforms.timeutil.doctree | Bin 0 -> 13618 bytes .../apache_beam.transforms.trigger.doctree | Bin 0 -> 173851 bytes .../apache_beam.transforms.userstate.doctree | Bin 0 -> 104285 bytes .../.doctrees/apache_beam.transforms.util.doctree | Bin 0 -> 139591 bytes .../apache_beam.transforms.window.doctree | Bin 0 -> 117843 bytes .../apache_beam.typehints.decorators.doctree | Bin 0 -> 51121 bytes .../2.31.0/.doctrees/apache_beam.typehints.doctree | Bin 0 -> 4177 bytes ...eam.typehints.native_type_compatibility.doctree | Bin 0 -> 30269 bytes .../apache_beam.typehints.opcodes.doctree | Bin 0 -> 134868 bytes .../apache_beam.typehints.row_type.doctree | Bin 0 -> 8558 bytes .../apache_beam.typehints.schemas.doctree | Bin 0 -> 70180 bytes .../apache_beam.typehints.sharded_key_type.doctree | Bin 0 -> 13091 bytes ...apache_beam.typehints.trivial_inference.doctree | Bin 0 -> 53432 bytes .../apache_beam.typehints.typecheck.doctree | Bin 0 -> 61465 bytes .../apache_beam.typehints.typehints.doctree | Bin 0 -> 17677 bytes .../apache_beam.utils.annotations.doctree | Bin 0 -> 33436 bytes pydoc/2.31.0/.doctrees/apache_beam.utils.doctree | Bin 0 -> 4446 bytes .../.doctrees/apache_beam.utils.histogram.doctree | Bin 0 -> 46717 bytes .../apache_beam.utils.interactive_utils.doctree | Bin 0 -> 11482 bytes .../.doctrees/apache_beam.utils.plugin.doctree | Bin 0 -> 9724 bytes .../.doctrees/apache_beam.utils.processes.doctree | Bin 0 -> 10154 bytes .../.doctrees/apache_beam.utils.profiler.doctree | Bin 0 -> 18078 bytes .../apache_beam.utils.proto_utils.doctree | Bin 0 -> 17186 bytes .../.doctrees/apache_beam.utils.retry.doctree | Bin 0 -> 44280 bytes .../.doctrees/apache_beam.utils.sentinel.doctree | Bin 0 -> 6382 bytes .../apache_beam.utils.sharded_key.doctree | Bin 0 -> 8561 bytes .../.doctrees/apache_beam.utils.shared.doctree | Bin 0 -> 19340 bytes .../apache_beam.utils.subprocess_server.doctree | Bin 0 -> 38032 bytes .../apache_beam.utils.thread_pool_executor.doctree | Bin 0 -> 11126 bytes .../.doctrees/apache_beam.utils.timestamp.doctree | Bin 0 -> 39891 bytes .../.doctrees/apache_beam.utils.urns.doctree | Bin 0 -> 18663 bytes pydoc/2.31.0/.doctrees/environment.pickle | Bin 0 -> 10633862 bytes pydoc/2.31.0/.doctrees/index.doctree | Bin 0 -> 18662 bytes .../_modules/apache_beam/coders/avro_record.html | 237 + .../2.31.0/_modules/apache_beam/coders/coders.html | 1711 ++ .../_modules/apache_beam/coders/observable.html | 245 + .../_modules/apache_beam/coders/row_coder.html | 452 + .../_modules/apache_beam/coders/slow_stream.html | 393 + .../_modules/apache_beam/dataframe/convert.html | 447 + .../_modules/apache_beam/dataframe/doctests.html | 955 + .../apache_beam/dataframe/expressions.html | 620 + .../_modules/apache_beam/dataframe/frame_base.html | 824 + .../_modules/apache_beam/dataframe/frames.html | 3595 ++++ .../2.31.0/_modules/apache_beam/dataframe/io.html | 857 + .../dataframe/pandas_top_level_functions.html | 394 + .../apache_beam/dataframe/partitionings.html | 406 + .../_modules/apache_beam/dataframe/schemas.html | 539 + .../_modules/apache_beam/dataframe/transforms.html | 787 + pydoc/2.31.0/_modules/apache_beam/error.html | 251 + .../apache_beam/internal/metrics/metric.html | 428 + pydoc/2.31.0/_modules/apache_beam/io/avroio.html | 821 + .../io/aws/clients/s3/boto3_client.html | 475 + .../apache_beam/io/aws/clients/s3/fake_client.html | 438 + .../apache_beam/io/aws/clients/s3/messages.html | 356 + .../_modules/apache_beam/io/aws/s3filesystem.html | 500 + pydoc/2.31.0/_modules/apache_beam/io/aws/s3io.html | 818 + .../io/azure/blobstoragefilesystem.html | 500 + .../apache_beam/io/azure/blobstorageio.html | 860 + .../_modules/apache_beam/io/concat_source.html | 475 + pydoc/2.31.0/_modules/apache_beam/io/debezium.html | 379 + .../apache_beam/io/external/gcp/pubsub.html | 377 + .../apache_beam/io/external/generate_sequence.html | 268 + .../_modules/apache_beam/io/filebasedsink.html | 616 + .../_modules/apache_beam/io/filebasedsource.html | 638 + pydoc/2.31.0/_modules/apache_beam/io/fileio.html | 948 + .../2.31.0/_modules/apache_beam/io/filesystem.html | 1096 ++ .../_modules/apache_beam/io/filesystemio.html | 509 + .../_modules/apache_beam/io/filesystems.html | 558 + .../io/flink/flink_streaming_impulse_source.html | 284 + .../io/gcp/big_query_query_to_table_pipeline.html | 307 + .../_modules/apache_beam/io/gcp/bigquery.html | 2291 +++ .../apache_beam/io/gcp/bigquery_avro_tools.html | 340 + .../apache_beam/io/gcp/bigquery_file_loads.html | 1396 ++ .../apache_beam/io/gcp/bigquery_io_metadata.html | 296 + .../io/gcp/bigquery_io_read_pipeline.html | 301 + .../apache_beam/io/gcp/bigquery_read_internal.html | 594 + .../apache_beam/io/gcp/bigquery_tools.html | 1955 ++ .../_modules/apache_beam/io/gcp/bigtableio.html | 357 + .../io/gcp/datastore/v1new/adaptive_throttler.html | 299 + .../v1new/datastore_write_it_pipeline.html | 375 + .../io/gcp/datastore/v1new/datastoreio.html | 723 + .../apache_beam/io/gcp/datastore/v1new/helper.html | 283 + .../io/gcp/datastore/v1new/query_splitter.html | 487 + .../apache_beam/io/gcp/datastore/v1new/types.html | 512 + .../apache_beam/io/gcp/datastore/v1new/util.html | 342 + .../_modules/apache_beam/io/gcp/dicomclient.html | 326 + .../_modules/apache_beam/io/gcp/dicomio.html | 780 + .../apache_beam/io/gcp/experimental/spannerio.html | 1348 ++ .../apache_beam/io/gcp/gce_metadata_util.html | 249 + .../_modules/apache_beam/io/gcp/gcsfilesystem.html | 546 + .../2.31.0/_modules/apache_beam/io/gcp/gcsio.html | 877 + .../apache_beam/io/gcp/gcsio_overrides.html | 258 + .../2.31.0/_modules/apache_beam/io/gcp/pubsub.html | 795 + .../apache_beam/io/gcp/pubsub_it_pipeline.html | 297 + .../apache_beam/io/gcp/resource_identifiers.html | 238 + .../_modules/apache_beam/io/gcp/spanner.html | 834 + .../_modules/apache_beam/io/hadoopfilesystem.html | 615 + pydoc/2.31.0/_modules/apache_beam/io/iobase.html | 1870 ++ pydoc/2.31.0/_modules/apache_beam/io/jdbc.html | 496 + pydoc/2.31.0/_modules/apache_beam/io/kafka.html | 441 + pydoc/2.31.0/_modules/apache_beam/io/kinesis.html | 527 + .../_modules/apache_beam/io/localfilesystem.html | 557 + .../2.31.0/_modules/apache_beam/io/mongodbio.html | 810 + .../2.31.0/_modules/apache_beam/io/parquetio.html | 781 + .../_modules/apache_beam/io/range_trackers.html | 628 + .../apache_beam/io/restriction_trackers.html | 378 + .../2.31.0/_modules/apache_beam/io/snowflake.html | 691 + .../_modules/apache_beam/io/source_test_utils.html | 942 + pydoc/2.31.0/_modules/apache_beam/io/textio.html | 853 + .../2.31.0/_modules/apache_beam/io/tfrecordio.html | 539 + pydoc/2.31.0/_modules/apache_beam/io/utils.html | 271 + .../apache_beam/io/watermark_estimators.html | 360 + .../2.31.0/_modules/apache_beam/metrics/cells.html | 756 + .../_modules/apache_beam/metrics/metric.html | 504 + .../_modules/apache_beam/metrics/metricbase.html | 348 + .../apache_beam/metrics/monitoring_infos.html | 645 + .../_modules/apache_beam/ml/gcp/cloud_dlp.html | 427 + .../apache_beam/ml/gcp/naturallanguageml.html | 347 + .../apache_beam/ml/gcp/videointelligenceml.html | 426 + .../_modules/apache_beam/ml/gcp/visionml.html | 490 + .../apache_beam/options/pipeline_options.html | 1664 ++ .../options/pipeline_options_validator.html | 552 + .../apache_beam/options/value_provider.html | 400 + pydoc/2.31.0/_modules/apache_beam/pipeline.html | 1687 ++ .../api/beam_artifact_api_pb2_grpc.html | 599 + .../api/beam_artifact_api_pb2_urns.html | 213 + .../api/beam_expansion_api_pb2_grpc.html | 274 + .../portability/api/beam_fn_api_pb2_grpc.html | 688 + .../portability/api/beam_job_api_pb2_grpc.html | 582 + .../api/beam_provision_api_pb2_grpc.html | 281 + .../portability/api/beam_runner_api_pb2_grpc.html | 272 + .../portability/api/beam_runner_api_pb2_urns.html | 355 + .../portability/api/metrics_pb2_urns.html | 270 + .../api/standard_window_fns_pb2_urns.html | 231 + .../_modules/apache_beam/portability/utils.html | 235 + pydoc/2.31.0/_modules/apache_beam/pvalue.html | 883 + .../dataflow_exercise_metrics_pipeline.html | 381 + ...taflow_exercise_streaming_metrics_pipeline.html | 309 + .../runners/dataflow/dataflow_metrics.html | 531 + .../runners/dataflow/dataflow_runner.html | 1868 ++ .../runners/dataflow/native_io/iobase.html | 545 + .../runners/dataflow/ptransform_overrides.html | 582 + .../runners/dataflow/test_dataflow_runner.html | 304 + .../apache_beam/runners/direct/bundle_factory.html | 425 + .../_modules/apache_beam/runners/direct/clock.html | 256 + .../direct/consumer_tracking_pipeline_visitor.html | 279 + .../apache_beam/runners/direct/direct_metrics.html | 335 + .../apache_beam/runners/direct/direct_runner.html | 812 + .../runners/direct/direct_userstate.html | 517 + .../runners/direct/evaluation_context.html | 681 + .../apache_beam/runners/direct/executor.html | 954 + .../runners/direct/helper_transforms.html | 323 + .../runners/direct/sdf_direct_runner.html | 759 + .../runners/direct/test_direct_runner.html | 259 + .../runners/direct/transform_evaluator.html | 1481 ++ .../_modules/apache_beam/runners/direct/util.html | 296 + .../runners/direct/watermark_manager.html | 538 + .../runners/interactive/augmented_pipeline.html | 333 + .../interactive/background_caching_job.html | 547 + .../runners/interactive/cache_manager.html | 545 + .../runners/interactive/caching/cacheable.html | 279 + .../runners/interactive/caching/read_cache.html | 349 + .../interactive/caching/streaming_cache.html | 721 + .../runners/interactive/caching/write_cache.html | 389 + .../interactive/display/display_manager.html | 388 + .../display/interactive_pipeline_graph.html | 362 + .../interactive/display/pcoll_visualization.html | 689 + .../interactive/display/pipeline_graph.html | 490 + .../display/pipeline_graph_renderer.html | 342 + .../runners/interactive/interactive_beam.html | 816 + .../interactive/interactive_environment.html | 839 + .../runners/interactive/interactive_runner.html | 463 + .../interactive_environment_inspector.html | 386 + .../interactive/options/capture_control.html | 277 + .../interactive/options/capture_limiters.html | 354 + .../interactive/options/interactive_options.html | 249 + .../runners/interactive/pipeline_fragment.html | 426 + .../runners/interactive/pipeline_instrument.html | 1122 ++ .../runners/interactive/recording_manager.html | 672 + .../testing/integration/notebook_executor.html | 367 + .../testing/integration/screen_diff.html | 442 + .../runners/interactive/testing/mock_ipython.html | 268 + .../interactive/testing/pipeline_assertion.html | 319 + .../interactive/testing/test_cache_manager.html | 330 + .../runners/interactive/user_pipeline_tracker.html | 353 + .../apache_beam/runners/interactive/utils.html | 470 + .../_modules/apache_beam/runners/job/manager.html | 260 + .../_modules/apache_beam/runners/job/utils.html | 244 + .../apache_beam/runners/pipeline_context.html | 519 + .../_modules/apache_beam/runners/runner.html | 628 + .../_modules/apache_beam/runners/sdf_utils.html | 451 + .../transforms/combinefn_lifecycle_pipeline.html | 336 + .../_modules/apache_beam/transforms/combiners.html | 1109 ++ .../_modules/apache_beam/transforms/core.html | 3231 ++++ .../apache_beam/transforms/deduplicate.html | 334 + .../_modules/apache_beam/transforms/display.html | 628 + .../apache_beam/transforms/environments.html | 1009 + .../_modules/apache_beam/transforms/external.html | 730 + .../apache_beam/transforms/external_java.html | 384 + .../apache_beam/transforms/periodicsequence.html | 376 + .../apache_beam/transforms/ptransform.html | 1292 ++ .../_modules/apache_beam/transforms/resources.html | 421 + .../apache_beam/transforms/sideinputs.html | 320 + .../_modules/apache_beam/transforms/sql.html | 295 + .../_modules/apache_beam/transforms/stats.html | 1197 ++ .../_modules/apache_beam/transforms/timeutil.html | 334 + .../_modules/apache_beam/transforms/trigger.html | 1855 ++ .../_modules/apache_beam/transforms/userstate.html | 618 + .../_modules/apache_beam/transforms/util.html | 1471 ++ .../_modules/apache_beam/transforms/window.html | 807 + .../_modules/apache_beam/typehints/decorators.html | 1181 ++ .../typehints/native_type_compatibility.html | 578 + .../_modules/apache_beam/typehints/opcodes.html | 642 + .../_modules/apache_beam/typehints/row_type.html | 253 + .../_modules/apache_beam/typehints/schemas.html | 681 + .../apache_beam/typehints/sharded_key_type.html | 291 + .../apache_beam/typehints/trivial_inference.html | 733 + .../_modules/apache_beam/typehints/typecheck.html | 549 + .../_modules/apache_beam/typehints/typehints.html | 1439 ++ .../_modules/apache_beam/utils/annotations.html | 367 + .../_modules/apache_beam/utils/histogram.html | 456 + .../apache_beam/utils/interactive_utils.html | 303 + .../2.31.0/_modules/apache_beam/utils/plugin.html | 247 + .../_modules/apache_beam/utils/processes.html | 310 + .../_modules/apache_beam/utils/profiler.html | 383 + .../_modules/apache_beam/utils/proto_utils.html | 348 + pydoc/2.31.0/_modules/apache_beam/utils/retry.html | 488 + .../_modules/apache_beam/utils/sentinel.html | 231 + .../_modules/apache_beam/utils/sharded_key.html | 259 + .../2.31.0/_modules/apache_beam/utils/shared.html | 514 + .../apache_beam/utils/subprocess_server.html | 524 + .../apache_beam/utils/thread_pool_executor.html | 337 + .../_modules/apache_beam/utils/timestamp.html | 642 + pydoc/2.31.0/_modules/apache_beam/utils/urns.html | 389 + pydoc/2.31.0/_modules/index.html | 403 + .../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.31.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.31.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.31.0/_sources/apache_beam.error.rst.txt | 7 + .../2.31.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.31.0/_sources/apache_beam.io.aws.rst.txt | 23 + .../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.31.0/_sources/apache_beam.io.azure.rst.txt | 16 + .../_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 | 24 + .../apache_beam.io.external.snowflake.rst.txt | 7 + .../_sources/apache_beam.io.filebasedsink.rst.txt | 7 + .../apache_beam.io.filebasedsource.rst.txt | 7 + .../2.31.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.31.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 + .../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 + ....gcp.datastore.v1new.adaptive_throttler.rst.txt | 7 + ...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 + .../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_overrides.rst.txt | 7 + .../_sources/apache_beam.io.gcp.pubsub.rst.txt | 7 + .../apache_beam.io.gcp.pubsub_it_pipeline.rst.txt | 7 + ...apache_beam.io.gcp.resource_identifiers.rst.txt | 7 + pydoc/2.31.0/_sources/apache_beam.io.gcp.rst.txt | 41 + .../_sources/apache_beam.io.gcp.spanner.rst.txt | 7 + .../apache_beam.io.hadoopfilesystem.rst.txt | 7 + .../2.31.0/_sources/apache_beam.io.iobase.rst.txt | 7 + pydoc/2.31.0/_sources/apache_beam.io.jdbc.rst.txt | 7 + pydoc/2.31.0/_sources/apache_beam.io.kafka.rst.txt | 7 + .../2.31.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.restriction_trackers.rst.txt | 7 + pydoc/2.31.0/_sources/apache_beam.io.rst.txt | 50 + .../_sources/apache_beam.io.snowflake.rst.txt | 7 + .../apache_beam.io.source_test_utils.rst.txt | 7 + .../2.31.0/_sources/apache_beam.io.textio.rst.txt | 7 + .../_sources/apache_beam.io.tfrecordio.rst.txt | 7 + pydoc/2.31.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.31.0/_sources/apache_beam.metrics.rst.txt | 18 + .../_sources/apache_beam.ml.gcp.cloud_dlp.rst.txt | 7 + .../apache_beam.ml.gcp.naturallanguageml.rst.txt | 7 + pydoc/2.31.0/_sources/apache_beam.ml.gcp.rst.txt | 18 + .../apache_beam.ml.gcp.videointelligenceml.rst.txt | 7 + .../_sources/apache_beam.ml.gcp.visionml.rst.txt | 7 + pydoc/2.31.0/_sources/apache_beam.ml.rst.txt | 15 + .../apache_beam.options.pipeline_options.rst.txt | 7 + ...beam.options.pipeline_options_validator.rst.txt | 7 + pydoc/2.31.0/_sources/apache_beam.options.rst.txt | 17 + .../apache_beam.options.value_provider.rst.txt | 7 + pydoc/2.31.0/_sources/apache_beam.pipeline.rst.txt | 7 + ...tability.api.beam_artifact_api_pb2_grpc.rst.txt | 7 + ...tability.api.beam_artifact_api_pb2_urns.rst.txt | 7 + ...ability.api.beam_expansion_api_pb2_grpc.rst.txt | 7 + ...am.portability.api.beam_fn_api_pb2_grpc.rst.txt | 7 + ...ility.api.beam_interactive_api_pb2_grpc.rst.txt | 7 + ...m.portability.api.beam_job_api_pb2_grpc.rst.txt | 7 + ...ability.api.beam_provision_api_pb2_grpc.rst.txt | 7 + ...ortability.api.beam_runner_api_pb2_grpc.rst.txt | 7 + ...ortability.api.beam_runner_api_pb2_urns.rst.txt | 7 + ...beam.portability.api.endpoints_pb2_grpc.rst.txt | 7 + ...bility.api.external_transforms_pb2_grpc.rst.txt | 7 + ...e_beam.portability.api.metrics_pb2_grpc.rst.txt | 7 + ...e_beam.portability.api.metrics_pb2_urns.rst.txt | 7 + .../_sources/apache_beam.portability.api.rst.txt | 30 + ...he_beam.portability.api.schema_pb2_grpc.rst.txt | 7 + ...bility.api.standard_window_fns_pb2_grpc.rst.txt | 7 + ...bility.api.standard_window_fns_pb2_urns.rst.txt | 7 + .../apache_beam.portability.common_urns.rst.txt | 7 + .../apache_beam.portability.python_urns.rst.txt | 7 + .../_sources/apache_beam.portability.rst.txt | 24 + .../_sources/apache_beam.portability.utils.rst.txt | 7 + pydoc/2.31.0/_sources/apache_beam.pvalue.rst.txt | 7 + ...flow.dataflow_exercise_metrics_pipeline.rst.txt | 7 + ...low_exercise_streaming_metrics_pipeline.rst.txt | 7 + ..._beam.runners.dataflow.dataflow_metrics.rst.txt | 7 + ...e_beam.runners.dataflow.dataflow_runner.rst.txt | 7 + ..._beam.runners.dataflow.native_io.iobase.rst.txt | 7 + .../apache_beam.runners.dataflow.native_io.rst.txt | 15 + ...m.runners.dataflow.ptransform_overrides.rst.txt | 7 + .../_sources/apache_beam.runners.dataflow.rst.txt | 27 + ...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 + ....runners.interactive.caching.read_cache.rst.txt | 7 + ...apache_beam.runners.interactive.caching.rst.txt | 18 + ...ers.interactive.caching.streaming_cache.rst.txt | 7 + ...runners.interactive.caching.write_cache.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 | 36 + ...e.testing.integration.notebook_executor.rst.txt | 7 + ...runners.interactive.testing.integration.rst.txt | 16 + ...ractive.testing.integration.screen_diff.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 | 24 + ....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 + pydoc/2.31.0/_sources/apache_beam.runners.rst.txt | 27 + .../_sources/apache_beam.runners.runner.rst.txt | 7 + .../_sources/apache_beam.runners.sdf_utils.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.environments.rst.txt | 7 + .../apache_beam.transforms.external.rst.txt | 7 + .../apache_beam.transforms.external_java.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.31.0/_sources/apache_beam.transforms.rst.txt | 34 + .../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.typehints.decorators.rst.txt | 7 + ...eam.typehints.native_type_compatibility.rst.txt | 7 + .../_sources/apache_beam.typehints.opcodes.rst.txt | 7 + .../apache_beam.typehints.row_type.rst.txt | 7 + .../2.31.0/_sources/apache_beam.typehints.rst.txt | 23 + .../_sources/apache_beam.typehints.schemas.rst.txt | 7 + .../apache_beam.typehints.sharded_key_type.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 + .../_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 + .../_sources/apache_beam.utils.retry.rst.txt | 7 + pydoc/2.31.0/_sources/apache_beam.utils.rst.txt | 29 + .../_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 + .../2.31.0/_sources/apache_beam.utils.urns.rst.txt | 7 + pydoc/2.31.0/_sources/index.rst.txt | 2 + pydoc/2.31.0/_static/ajax-loader.gif | Bin 0 -> 673 bytes pydoc/2.31.0/_static/basic.css | 676 + pydoc/2.31.0/_static/comment-bright.png | Bin 0 -> 756 bytes pydoc/2.31.0/_static/comment-close.png | Bin 0 -> 829 bytes pydoc/2.31.0/_static/comment.png | Bin 0 -> 641 bytes pydoc/2.31.0/_static/css/badge_only.css | 1 + pydoc/2.31.0/_static/css/theme.css | 6 + pydoc/2.31.0/_static/doctools.js | 315 + pydoc/2.31.0/_static/documentation_options.js | 10 + pydoc/2.31.0/_static/down-pressed.png | Bin 0 -> 222 bytes pydoc/2.31.0/_static/down.png | Bin 0 -> 202 bytes pydoc/2.31.0/_static/file.png | Bin 0 -> 286 bytes pydoc/2.31.0/_static/fonts/Inconsolata-Bold.ttf | Bin 0 -> 109948 bytes pydoc/2.31.0/_static/fonts/Inconsolata-Regular.ttf | Bin 0 -> 96964 bytes pydoc/2.31.0/_static/fonts/Inconsolata.ttf | Bin 0 -> 63184 bytes pydoc/2.31.0/_static/fonts/Lato-Bold.ttf | Bin 0 -> 656544 bytes pydoc/2.31.0/_static/fonts/Lato-Regular.ttf | Bin 0 -> 656568 bytes pydoc/2.31.0/_static/fonts/Lato/lato-bold.eot | Bin 0 -> 256056 bytes pydoc/2.31.0/_static/fonts/Lato/lato-bold.ttf | Bin 0 -> 600856 bytes pydoc/2.31.0/_static/fonts/Lato/lato-bold.woff | Bin 0 -> 309728 bytes pydoc/2.31.0/_static/fonts/Lato/lato-bold.woff2 | Bin 0 -> 184912 bytes .../2.31.0/_static/fonts/Lato/lato-bolditalic.eot | Bin 0 -> 266158 bytes .../2.31.0/_static/fonts/Lato/lato-bolditalic.ttf | Bin 0 -> 622572 bytes .../2.31.0/_static/fonts/Lato/lato-bolditalic.woff | Bin 0 -> 323344 bytes .../_static/fonts/Lato/lato-bolditalic.woff2 | Bin 0 -> 193308 bytes pydoc/2.31.0/_static/fonts/Lato/lato-italic.eot | Bin 0 -> 268604 bytes pydoc/2.31.0/_static/fonts/Lato/lato-italic.ttf | Bin 0 -> 639388 bytes pydoc/2.31.0/_static/fonts/Lato/lato-italic.woff | Bin 0 -> 328412 bytes pydoc/2.31.0/_static/fonts/Lato/lato-italic.woff2 | Bin 0 -> 195704 bytes pydoc/2.31.0/_static/fonts/Lato/lato-regular.eot | Bin 0 -> 253461 bytes pydoc/2.31.0/_static/fonts/Lato/lato-regular.ttf | Bin 0 -> 607720 bytes pydoc/2.31.0/_static/fonts/Lato/lato-regular.woff | Bin 0 -> 309192 bytes pydoc/2.31.0/_static/fonts/Lato/lato-regular.woff2 | Bin 0 -> 182708 bytes pydoc/2.31.0/_static/fonts/RobotoSlab-Bold.ttf | Bin 0 -> 170616 bytes pydoc/2.31.0/_static/fonts/RobotoSlab-Regular.ttf | Bin 0 -> 169064 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.31.0/_static/fonts/fontawesome-webfont.eot | Bin 0 -> 165742 bytes pydoc/2.31.0/_static/fonts/fontawesome-webfont.svg | 2671 +++ pydoc/2.31.0/_static/fonts/fontawesome-webfont.ttf | Bin 0 -> 165548 bytes .../2.31.0/_static/fonts/fontawesome-webfont.woff | Bin 0 -> 98024 bytes .../2.31.0/_static/fonts/fontawesome-webfont.woff2 | Bin 0 -> 77160 bytes pydoc/2.31.0/_static/jquery-3.2.1.js | 10253 ++++++++++ pydoc/2.31.0/_static/jquery.js | 4 + pydoc/2.31.0/_static/js/modernizr.min.js | 4 + pydoc/2.31.0/_static/js/theme.js | 3 + pydoc/2.31.0/_static/language_data.js | 297 + pydoc/2.31.0/_static/minus.png | Bin 0 -> 90 bytes pydoc/2.31.0/_static/plus.png | Bin 0 -> 90 bytes pydoc/2.31.0/_static/pygments.css | 74 + pydoc/2.31.0/_static/searchtools.js | 481 + pydoc/2.31.0/_static/underscore-1.3.1.js | 999 + pydoc/2.31.0/_static/underscore.js | 31 + pydoc/2.31.0/_static/up-pressed.png | Bin 0 -> 214 bytes pydoc/2.31.0/_static/up.png | Bin 0 -> 203 bytes pydoc/2.31.0/_static/websupport.js | 808 + pydoc/2.31.0/apache_beam.coders.avro_record.html | 239 + pydoc/2.31.0/apache_beam.coders.coders.html | 917 + pydoc/2.31.0/apache_beam.coders.html | 242 + pydoc/2.31.0/apache_beam.coders.observable.html | 252 + pydoc/2.31.0/apache_beam.coders.row_coder.html | 280 + pydoc/2.31.0/apache_beam.coders.slow_stream.html | 374 + pydoc/2.31.0/apache_beam.coders.typecoders.html | 279 + pydoc/2.31.0/apache_beam.dataframe.convert.html | 295 + pydoc/2.31.0/apache_beam.dataframe.doctests.html | 468 + .../2.31.0/apache_beam.dataframe.expressions.html | 526 + pydoc/2.31.0/apache_beam.dataframe.frame_base.html | 362 + pydoc/2.31.0/apache_beam.dataframe.frames.html | 19338 +++++++++++++++++++ pydoc/2.31.0/apache_beam.dataframe.html | 266 + pydoc/2.31.0/apache_beam.dataframe.io.html | 2337 +++ ..._beam.dataframe.pandas_top_level_functions.html | 375 + .../apache_beam.dataframe.partitionings.html | 341 + pydoc/2.31.0/apache_beam.dataframe.schemas.html | 326 + pydoc/2.31.0/apache_beam.dataframe.transforms.html | 290 + pydoc/2.31.0/apache_beam.error.html | 268 + pydoc/2.31.0/apache_beam.io.avroio.html | 442 + pydoc/2.31.0/apache_beam.io.aws.clients.html | 253 + ...apache_beam.io.aws.clients.s3.boto3_client.html | 367 + .../apache_beam.io.aws.clients.s3.fake_client.html | 340 + pydoc/2.31.0/apache_beam.io.aws.clients.s3.html | 249 + .../apache_beam.io.aws.clients.s3.messages.html | 335 + pydoc/2.31.0/apache_beam.io.aws.html | 266 + pydoc/2.31.0/apache_beam.io.aws.s3filesystem.html | 507 + pydoc/2.31.0/apache_beam.io.aws.s3io.html | 564 + ...apache_beam.io.azure.blobstoragefilesystem.html | 517 + .../2.31.0/apache_beam.io.azure.blobstorageio.html | 592 + pydoc/2.31.0/apache_beam.io.azure.html | 243 + pydoc/2.31.0/apache_beam.io.concat_source.html | 365 + pydoc/2.31.0/apache_beam.io.debezium.html | 371 + pydoc/2.31.0/apache_beam.io.external.gcp.html | 245 + .../2.31.0/apache_beam.io.external.gcp.pubsub.html | 400 + .../apache_beam.io.external.generate_sequence.html | 264 + pydoc/2.31.0/apache_beam.io.external.html | 259 + pydoc/2.31.0/apache_beam.io.external.kafka.html | 237 + .../2.31.0/apache_beam.io.external.snowflake.html | 237 + pydoc/2.31.0/apache_beam.io.filebasedsink.html | 336 + pydoc/2.31.0/apache_beam.io.filebasedsource.html | 382 + pydoc/2.31.0/apache_beam.io.fileio.html | 412 + pydoc/2.31.0/apache_beam.io.filesystem.html | 791 + pydoc/2.31.0/apache_beam.io.filesystemio.html | 527 + pydoc/2.31.0/apache_beam.io.filesystems.html | 579 + ...am.io.flink.flink_streaming_impulse_source.html | 292 + pydoc/2.31.0/apache_beam.io.flink.html | 242 + ...m.io.gcp.big_query_query_to_table_pipeline.html | 254 + pydoc/2.31.0/apache_beam.io.gcp.bigquery.html | 1037 + .../apache_beam.io.gcp.bigquery_avro_tools.html | 284 + .../apache_beam.io.gcp.bigquery_file_loads.html | 526 + .../apache_beam.io.gcp.bigquery_io_metadata.html | 259 + ...ache_beam.io.gcp.bigquery_io_read_pipeline.html | 255 + .../apache_beam.io.gcp.bigquery_read_internal.html | 277 + .../2.31.0/apache_beam.io.gcp.bigquery_tools.html | 939 + pydoc/2.31.0/apache_beam.io.gcp.bigtableio.html | 280 + pydoc/2.31.0/apache_beam.io.gcp.datastore.html | 257 + ....io.gcp.datastore.v1new.adaptive_throttler.html | 309 + ...atastore.v1new.datastore_write_it_pipeline.html | 279 + ...he_beam.io.gcp.datastore.v1new.datastoreio.html | 349 + .../apache_beam.io.gcp.datastore.v1new.helper.html | 267 + .../2.31.0/apache_beam.io.gcp.datastore.v1new.html | 253 + ...beam.io.gcp.datastore.v1new.query_splitter.html | 292 + .../apache_beam.io.gcp.datastore.v1new.types.html | 373 + .../apache_beam.io.gcp.datastore.v1new.util.html | 305 + pydoc/2.31.0/apache_beam.io.gcp.dicomclient.html | 271 + pydoc/2.31.0/apache_beam.io.gcp.dicomio.html | 479 + pydoc/2.31.0/apache_beam.io.gcp.experimental.html | 245 + .../apache_beam.io.gcp.experimental.spannerio.html | 714 + .../apache_beam.io.gcp.gce_metadata_util.html | 243 + pydoc/2.31.0/apache_beam.io.gcp.gcsfilesystem.html | 513 + pydoc/2.31.0/apache_beam.io.gcp.gcsio.html | 486 + .../2.31.0/apache_beam.io.gcp.gcsio_overrides.html | 249 + pydoc/2.31.0/apache_beam.io.gcp.html | 308 + pydoc/2.31.0/apache_beam.io.gcp.pubsub.html | 510 + .../apache_beam.io.gcp.pubsub_it_pipeline.html | 244 + .../apache_beam.io.gcp.resource_identifiers.html | 254 + pydoc/2.31.0/apache_beam.io.gcp.spanner.html | 821 + pydoc/2.31.0/apache_beam.io.hadoopfilesystem.html | 401 + pydoc/2.31.0/apache_beam.io.html | 435 + pydoc/2.31.0/apache_beam.io.iobase.html | 1480 ++ pydoc/2.31.0/apache_beam.io.jdbc.html | 415 + pydoc/2.31.0/apache_beam.io.kafka.html | 506 + pydoc/2.31.0/apache_beam.io.kinesis.html | 441 + pydoc/2.31.0/apache_beam.io.localfilesystem.html | 518 + pydoc/2.31.0/apache_beam.io.mongodbio.html | 388 + pydoc/2.31.0/apache_beam.io.parquetio.html | 500 + pydoc/2.31.0/apache_beam.io.range_trackers.html | 467 + .../apache_beam.io.restriction_trackers.html | 338 + pydoc/2.31.0/apache_beam.io.snowflake.html | 572 + pydoc/2.31.0/apache_beam.io.source_test_utils.html | 505 + pydoc/2.31.0/apache_beam.io.textio.html | 448 + pydoc/2.31.0/apache_beam.io.tfrecordio.html | 328 + pydoc/2.31.0/apache_beam.io.utils.html | 280 + .../apache_beam.io.watermark_estimators.html | 358 + pydoc/2.31.0/apache_beam.metrics.cells.html | 353 + pydoc/2.31.0/apache_beam.metrics.html | 238 + pydoc/2.31.0/apache_beam.metrics.metric.html | 400 + pydoc/2.31.0/apache_beam.metrics.metricbase.html | 352 + .../apache_beam.metrics.monitoring_infos.html | 478 + pydoc/2.31.0/apache_beam.ml.gcp.cloud_dlp.html | 330 + pydoc/2.31.0/apache_beam.ml.gcp.html | 240 + .../apache_beam.ml.gcp.naturallanguageml.html | 296 + .../apache_beam.ml.gcp.videointelligenceml.html | 333 + pydoc/2.31.0/apache_beam.ml.gcp.visionml.html | 364 + pydoc/2.31.0/apache_beam.ml.html | 241 + pydoc/2.31.0/apache_beam.options.html | 236 + .../apache_beam.options.pipeline_options.html | 697 + ...he_beam.options.pipeline_options_validator.html | 439 + .../2.31.0/apache_beam.options.value_provider.html | 373 + pydoc/2.31.0/apache_beam.pipeline.html | 478 + ...portability.api.beam_artifact_api_pb2_grpc.html | 471 + ...portability.api.beam_artifact_api_pb2_urns.html | 249 + ...ortability.api.beam_expansion_api_pb2_grpc.html | 279 + ..._beam.portability.api.beam_fn_api_pb2_grpc.html | 549 + ...tability.api.beam_interactive_api_pb2_grpc.html | 233 + ...beam.portability.api.beam_job_api_pb2_grpc.html | 379 + ...ortability.api.beam_provision_api_pb2_grpc.html | 285 + ...m.portability.api.beam_runner_api_pb2_grpc.html | 279 + ...m.portability.api.beam_runner_api_pb2_urns.html | 775 + ...he_beam.portability.api.endpoints_pb2_grpc.html | 233 + ...rtability.api.external_transforms_pb2_grpc.html | 233 + pydoc/2.31.0/apache_beam.portability.api.html | 255 + ...ache_beam.portability.api.metrics_pb2_grpc.html | 233 + ...ache_beam.portability.api.metrics_pb2_urns.html | 508 + ...pache_beam.portability.api.schema_pb2_grpc.html | 233 + ...rtability.api.standard_window_fns_pb2_grpc.html | 233 + ...rtability.api.standard_window_fns_pb2_urns.html | 300 + .../apache_beam.portability.common_urns.html | 230 + pydoc/2.31.0/apache_beam.portability.html | 270 + .../apache_beam.portability.python_urns.html | 231 + pydoc/2.31.0/apache_beam.portability.utils.html | 261 + pydoc/2.31.0/apache_beam.pvalue.html | 401 + ...ataflow.dataflow_exercise_metrics_pipeline.html | 272 + ...taflow_exercise_streaming_metrics_pipeline.html | 266 + ...che_beam.runners.dataflow.dataflow_metrics.html | 283 + ...ache_beam.runners.dataflow.dataflow_runner.html | 483 + pydoc/2.31.0/apache_beam.runners.dataflow.html | 264 + .../apache_beam.runners.dataflow.native_io.html | 244 + ...che_beam.runners.dataflow.native_io.iobase.html | 481 + ...beam.runners.dataflow.ptransform_overrides.html | 362 + ...beam.runners.dataflow.test_dataflow_runner.html | 261 + .../apache_beam.runners.direct.bundle_factory.html | 264 + pydoc/2.31.0/apache_beam.runners.direct.clock.html | 283 + ....direct.consumer_tracking_pipeline_visitor.html | 266 + .../apache_beam.runners.direct.direct_metrics.html | 298 + .../apache_beam.runners.direct.direct_runner.html | 283 + ...pache_beam.runners.direct.direct_userstate.html | 381 + ...che_beam.runners.direct.evaluation_context.html | 373 + .../apache_beam.runners.direct.executor.html | 280 + ...ache_beam.runners.direct.helper_transforms.html | 312 + pydoc/2.31.0/apache_beam.runners.direct.html | 258 + ...ache_beam.runners.direct.sdf_direct_runner.html | 505 + ...che_beam.runners.direct.test_direct_runner.html | 248 + ...pache_beam.runners.direct.test_stream_impl.html | 240 + ...he_beam.runners.direct.transform_evaluator.html | 303 + pydoc/2.31.0/apache_beam.runners.direct.util.html | 258 + ...ache_beam.runners.direct.watermark_manager.html | 285 + pydoc/2.31.0/apache_beam.runners.html | 380 + ...eam.runners.interactive.augmented_pipeline.html | 285 + ...runners.interactive.background_caching_job.html | 377 + ...che_beam.runners.interactive.cache_manager.html | 479 + ...beam.runners.interactive.caching.cacheable.html | 263 + .../apache_beam.runners.interactive.caching.html | 247 + ...eam.runners.interactive.caching.read_cache.html | 271 + ...unners.interactive.caching.streaming_cache.html | 408 + ...am.runners.interactive.caching.write_cache.html | 270 + ...unners.interactive.display.display_manager.html | 296 + .../apache_beam.runners.interactive.display.html | 248 + ...ractive.display.interactive_pipeline_graph.html | 292 + ...rs.interactive.display.pcoll_visualization.html | 332 + ...runners.interactive.display.pipeline_graph.html | 280 + ...nteractive.display.pipeline_graph_renderer.html | 344 + pydoc/2.31.0/apache_beam.runners.interactive.html | 316 + ..._beam.runners.interactive.interactive_beam.html | 387 + ...unners.interactive.interactive_environment.html | 582 + ...eam.runners.interactive.interactive_runner.html | 366 + .../apache_beam.runners.interactive.messaging.html | 244 + ...essaging.interactive_environment_inspector.html | 321 + ...unners.interactive.options.capture_control.html | 269 + ...nners.interactive.options.capture_limiters.html | 332 + .../apache_beam.runners.interactive.options.html | 246 + ...rs.interactive.options.interactive_options.html | 253 + ...beam.runners.interactive.pipeline_fragment.html | 274 + ...am.runners.interactive.pipeline_instrument.html | 443 + ...beam.runners.interactive.recording_manager.html | 367 + .../apache_beam.runners.interactive.testing.html | 261 + ...am.runners.interactive.testing.integration.html | 247 + ...tive.testing.integration.notebook_executor.html | 301 + ...nteractive.testing.integration.screen_diff.html | 289 + ...m.runners.interactive.testing.mock_ipython.html | 266 + ...ers.interactive.testing.pipeline_assertion.html | 285 + ...ers.interactive.testing.test_cache_manager.html | 334 + ....runners.interactive.user_pipeline_tracker.html | 306 + .../apache_beam.runners.interactive.utils.html | 325 + pydoc/2.31.0/apache_beam.runners.job.html | 242 + pydoc/2.31.0/apache_beam.runners.job.manager.html | 243 + pydoc/2.31.0/apache_beam.runners.job.utils.html | 246 + .../apache_beam.runners.pipeline_context.html | 296 + pydoc/2.31.0/apache_beam.runners.runner.html | 487 + pydoc/2.31.0/apache_beam.runners.sdf_utils.html | 413 + ...am.transforms.combinefn_lifecycle_pipeline.html | 317 + pydoc/2.31.0/apache_beam.transforms.combiners.html | 574 + pydoc/2.31.0/apache_beam.transforms.core.html | 1908 ++ .../apache_beam.transforms.create_source.html | 245 + .../2.31.0/apache_beam.transforms.deduplicate.html | 282 + pydoc/2.31.0/apache_beam.transforms.display.html | 454 + .../apache_beam.transforms.environments.html | 505 + pydoc/2.31.0/apache_beam.transforms.external.html | 453 + .../apache_beam.transforms.external_java.html | 277 + pydoc/2.31.0/apache_beam.transforms.html | 271 + .../apache_beam.transforms.periodicsequence.html | 366 + .../2.31.0/apache_beam.transforms.ptransform.html | 504 + pydoc/2.31.0/apache_beam.transforms.resources.html | 343 + .../2.31.0/apache_beam.transforms.sideinputs.html | 272 + pydoc/2.31.0/apache_beam.transforms.sql.html | 301 + pydoc/2.31.0/apache_beam.transforms.stats.html | 423 + pydoc/2.31.0/apache_beam.transforms.timeutil.html | 283 + pydoc/2.31.0/apache_beam.transforms.trigger.html | 853 + pydoc/2.31.0/apache_beam.transforms.userstate.html | 583 + pydoc/2.31.0/apache_beam.transforms.util.html | 799 + pydoc/2.31.0/apache_beam.transforms.window.html | 677 + pydoc/2.31.0/apache_beam.typehints.decorators.html | 477 + pydoc/2.31.0/apache_beam.typehints.html | 249 + ...e_beam.typehints.native_type_compatibility.html | 348 + pydoc/2.31.0/apache_beam.typehints.opcodes.html | 672 + pydoc/2.31.0/apache_beam.typehints.row_type.html | 250 + pydoc/2.31.0/apache_beam.typehints.schemas.html | 463 + .../apache_beam.typehints.sharded_key_type.html | 265 + .../apache_beam.typehints.trivial_inference.html | 408 + pydoc/2.31.0/apache_beam.typehints.typecheck.html | 412 + pydoc/2.31.0/apache_beam.typehints.typehints.html | 303 + pydoc/2.31.0/apache_beam.utils.annotations.html | 410 + pydoc/2.31.0/apache_beam.utils.histogram.html | 410 + pydoc/2.31.0/apache_beam.utils.html | 262 + .../apache_beam.utils.interactive_utils.html | 269 + pydoc/2.31.0/apache_beam.utils.plugin.html | 262 + pydoc/2.31.0/apache_beam.utils.processes.html | 262 + pydoc/2.31.0/apache_beam.utils.profiler.html | 297 + pydoc/2.31.0/apache_beam.utils.proto_utils.html | 285 + pydoc/2.31.0/apache_beam.utils.retry.html | 390 + pydoc/2.31.0/apache_beam.utils.sentinel.html | 252 + pydoc/2.31.0/apache_beam.utils.sharded_key.html | 265 + pydoc/2.31.0/apache_beam.utils.shared.html | 361 + .../apache_beam.utils.subprocess_server.html | 360 + .../apache_beam.utils.thread_pool_executor.html | 263 + pydoc/2.31.0/apache_beam.utils.timestamp.html | 389 + pydoc/2.31.0/apache_beam.utils.urns.html | 293 + pydoc/2.31.0/doctest/output.txt | 38 + .../apache_beam.coders.avro_record.doctree | Bin 0 -> 6094 bytes .../doctrees/apache_beam.coders.coders.doctree | Bin 0 -> 202552 bytes pydoc/2.31.0/doctrees/apache_beam.coders.doctree | Bin 0 -> 3608 bytes .../doctrees/apache_beam.coders.observable.doctree | Bin 0 -> 9653 bytes .../doctrees/apache_beam.coders.row_coder.doctree | Bin 0 -> 17318 bytes .../apache_beam.coders.slow_stream.doctree | Bin 0 -> 44834 bytes .../doctrees/apache_beam.coders.typecoders.doctree | Bin 0 -> 10173 bytes .../doctrees/apache_beam.dataframe.convert.doctree | Bin 0 -> 17618 bytes .../apache_beam.dataframe.doctests.doctree | Bin 0 -> 78145 bytes .../2.31.0/doctrees/apache_beam.dataframe.doctree | Bin 0 -> 8848 bytes .../apache_beam.dataframe.expressions.doctree | Bin 0 -> 81313 bytes .../apache_beam.dataframe.frame_base.doctree | Bin 0 -> 41240 bytes .../doctrees/apache_beam.dataframe.frames.doctree | Bin 0 -> 4053569 bytes .../doctrees/apache_beam.dataframe.io.doctree | Bin 0 -> 692282 bytes ...am.dataframe.pandas_top_level_functions.doctree | Bin 0 -> 46633 bytes .../apache_beam.dataframe.partitionings.doctree | Bin 0 -> 35396 bytes .../doctrees/apache_beam.dataframe.schemas.doctree | Bin 0 -> 25881 bytes .../apache_beam.dataframe.transforms.doctree | Bin 0 -> 20110 bytes pydoc/2.31.0/doctrees/apache_beam.error.doctree | Bin 0 -> 19271 bytes .../2.31.0/doctrees/apache_beam.io.avroio.doctree | Bin 0 -> 52183 bytes .../doctrees/apache_beam.io.aws.clients.doctree | Bin 0 -> 3524 bytes ...che_beam.io.aws.clients.s3.boto3_client.doctree | Bin 0 -> 29638 bytes .../doctrees/apache_beam.io.aws.clients.s3.doctree | Bin 0 -> 3666 bytes ...ache_beam.io.aws.clients.s3.fake_client.doctree | Bin 0 -> 31204 bytes .../apache_beam.io.aws.clients.s3.messages.doctree | Bin 0 -> 44544 bytes pydoc/2.31.0/doctrees/apache_beam.io.aws.doctree | Bin 0 -> 3891 bytes .../apache_beam.io.aws.s3filesystem.doctree | Bin 0 -> 55173 bytes .../doctrees/apache_beam.io.aws.s3io.doctree | Bin 0 -> 71256 bytes ...che_beam.io.azure.blobstoragefilesystem.doctree | Bin 0 -> 58734 bytes .../apache_beam.io.azure.blobstorageio.doctree | Bin 0 -> 85189 bytes pydoc/2.31.0/doctrees/apache_beam.io.azure.doctree | Bin 0 -> 3505 bytes .../doctrees/apache_beam.io.concat_source.doctree | Bin 0 -> 36050 bytes .../doctrees/apache_beam.io.debezium.doctree | Bin 0 -> 29674 bytes pydoc/2.31.0/doctrees/apache_beam.io.doctree | Bin 0 -> 5059 bytes .../doctrees/apache_beam.io.external.doctree | Bin 0 -> 4009 bytes .../doctrees/apache_beam.io.external.gcp.doctree | Bin 0 -> 3537 bytes .../apache_beam.io.external.gcp.pubsub.doctree | Bin 0 -> 45022 bytes ...ache_beam.io.external.generate_sequence.doctree | Bin 0 -> 10864 bytes .../doctrees/apache_beam.io.external.kafka.doctree | Bin 0 -> 2957 bytes .../apache_beam.io.external.snowflake.doctree | Bin 0 -> 3001 bytes .../doctrees/apache_beam.io.filebasedsink.doctree | Bin 0 -> 32494 bytes .../apache_beam.io.filebasedsource.doctree | Bin 0 -> 42650 bytes .../2.31.0/doctrees/apache_beam.io.fileio.doctree | Bin 0 -> 51917 bytes .../doctrees/apache_beam.io.filesystem.doctree | Bin 0 -> 121895 bytes .../doctrees/apache_beam.io.filesystemio.doctree | Bin 0 -> 59462 bytes .../doctrees/apache_beam.io.filesystems.doctree | Bin 0 -> 69220 bytes pydoc/2.31.0/doctrees/apache_beam.io.flink.doctree | Bin 0 -> 3470 bytes ...io.flink.flink_streaming_impulse_source.doctree | Bin 0 -> 22512 bytes ...o.gcp.big_query_query_to_table_pipeline.doctree | Bin 0 -> 6983 bytes .../doctrees/apache_beam.io.gcp.bigquery.doctree | Bin 0 -> 226748 bytes .../apache_beam.io.gcp.bigquery_avro_tools.doctree | Bin 0 -> 17032 bytes .../apache_beam.io.gcp.bigquery_file_loads.doctree | Bin 0 -> 98526 bytes ...apache_beam.io.gcp.bigquery_io_metadata.doctree | Bin 0 -> 11082 bytes ...e_beam.io.gcp.bigquery_io_read_pipeline.doctree | Bin 0 -> 10343 bytes ...ache_beam.io.gcp.bigquery_read_internal.doctree | Bin 0 -> 14609 bytes .../apache_beam.io.gcp.bigquery_tools.doctree | Bin 0 -> 187258 bytes .../doctrees/apache_beam.io.gcp.bigtableio.doctree | Bin 0 -> 12415 bytes .../doctrees/apache_beam.io.gcp.datastore.doctree | Bin 0 -> 3553 bytes ....gcp.datastore.v1new.adaptive_throttler.doctree | Bin 0 -> 18105 bytes ...store.v1new.datastore_write_it_pipeline.doctree | Bin 0 -> 16300 bytes ...beam.io.gcp.datastore.v1new.datastoreio.doctree | Bin 0 -> 34602 bytes .../apache_beam.io.gcp.datastore.v1new.doctree | Bin 0 -> 3967 bytes ...ache_beam.io.gcp.datastore.v1new.helper.doctree | Bin 0 -> 12436 bytes ...m.io.gcp.datastore.v1new.query_splitter.doctree | Bin 0 -> 17154 bytes ...pache_beam.io.gcp.datastore.v1new.types.doctree | Bin 0 -> 38932 bytes ...apache_beam.io.gcp.datastore.v1new.util.doctree | Bin 0 -> 21165 bytes .../apache_beam.io.gcp.dicomclient.doctree | Bin 0 -> 14668 bytes .../doctrees/apache_beam.io.gcp.dicomio.doctree | Bin 0 -> 45299 bytes pydoc/2.31.0/doctrees/apache_beam.io.gcp.doctree | Bin 0 -> 4666 bytes .../apache_beam.io.gcp.experimental.doctree | Bin 0 -> 3592 bytes ...ache_beam.io.gcp.experimental.spannerio.doctree | Bin 0 -> 116255 bytes .../apache_beam.io.gcp.gce_metadata_util.doctree | Bin 0 -> 5131 bytes .../apache_beam.io.gcp.gcsfilesystem.doctree | Bin 0 -> 55645 bytes .../doctrees/apache_beam.io.gcp.gcsio.doctree | Bin 0 -> 56764 bytes .../apache_beam.io.gcp.gcsio_overrides.doctree | Bin 0 -> 7360 bytes .../doctrees/apache_beam.io.gcp.pubsub.doctree | Bin 0 -> 68880 bytes .../apache_beam.io.gcp.pubsub_it_pipeline.doctree | Bin 0 -> 5986 bytes ...apache_beam.io.gcp.resource_identifiers.doctree | Bin 0 -> 8123 bytes .../doctrees/apache_beam.io.gcp.spanner.doctree | Bin 0 -> 133336 bytes .../apache_beam.io.hadoopfilesystem.doctree | Bin 0 -> 37396 bytes .../2.31.0/doctrees/apache_beam.io.iobase.doctree | Bin 0 -> 293989 bytes pydoc/2.31.0/doctrees/apache_beam.io.jdbc.doctree | Bin 0 -> 36414 bytes pydoc/2.31.0/doctrees/apache_beam.io.kafka.doctree | Bin 0 -> 65493 bytes .../2.31.0/doctrees/apache_beam.io.kinesis.doctree | Bin 0 -> 53858 bytes .../apache_beam.io.localfilesystem.doctree | Bin 0 -> 53982 bytes .../doctrees/apache_beam.io.mongodbio.doctree | Bin 0 -> 40503 bytes .../doctrees/apache_beam.io.parquetio.doctree | Bin 0 -> 77102 bytes .../doctrees/apache_beam.io.range_trackers.doctree | Bin 0 -> 69847 bytes .../apache_beam.io.restriction_trackers.doctree | Bin 0 -> 31962 bytes .../doctrees/apache_beam.io.snowflake.doctree | Bin 0 -> 76295 bytes .../apache_beam.io.source_test_utils.doctree | Bin 0 -> 70315 bytes .../2.31.0/doctrees/apache_beam.io.textio.doctree | Bin 0 -> 71698 bytes .../doctrees/apache_beam.io.tfrecordio.doctree | Bin 0 -> 22462 bytes pydoc/2.31.0/doctrees/apache_beam.io.utils.doctree | Bin 0 -> 11760 bytes .../apache_beam.io.watermark_estimators.doctree | Bin 0 -> 36216 bytes .../doctrees/apache_beam.metrics.cells.doctree | Bin 0 -> 35115 bytes pydoc/2.31.0/doctrees/apache_beam.metrics.doctree | Bin 0 -> 3550 bytes .../doctrees/apache_beam.metrics.metric.doctree | Bin 0 -> 45376 bytes .../apache_beam.metrics.metricbase.doctree | Bin 0 -> 37612 bytes .../apache_beam.metrics.monitoring_infos.doctree | Bin 0 -> 66989 bytes pydoc/2.31.0/doctrees/apache_beam.ml.doctree | Bin 0 -> 3369 bytes .../doctrees/apache_beam.ml.gcp.cloud_dlp.doctree | Bin 0 -> 28342 bytes pydoc/2.31.0/doctrees/apache_beam.ml.gcp.doctree | Bin 0 -> 3550 bytes .../apache_beam.ml.gcp.naturallanguageml.doctree | Bin 0 -> 23119 bytes .../apache_beam.ml.gcp.videointelligenceml.doctree | Bin 0 -> 25731 bytes .../doctrees/apache_beam.ml.gcp.visionml.doctree | Bin 0 -> 33891 bytes pydoc/2.31.0/doctrees/apache_beam.options.doctree | Bin 0 -> 3541 bytes .../apache_beam.options.pipeline_options.doctree | Bin 0 -> 106079 bytes ...beam.options.pipeline_options_validator.doctree | Bin 0 -> 65131 bytes .../apache_beam.options.value_provider.doctree | Bin 0 -> 40548 bytes pydoc/2.31.0/doctrees/apache_beam.pipeline.doctree | Bin 0 -> 69638 bytes ...tability.api.beam_artifact_api_pb2_grpc.doctree | Bin 0 -> 91917 bytes ...tability.api.beam_artifact_api_pb2_urns.doctree | Bin 0 -> 9494 bytes ...ability.api.beam_expansion_api_pb2_grpc.doctree | Bin 0 -> 20453 bytes ...am.portability.api.beam_fn_api_pb2_grpc.doctree | Bin 0 -> 113135 bytes ...ility.api.beam_interactive_api_pb2_grpc.doctree | Bin 0 -> 3707 bytes ...m.portability.api.beam_job_api_pb2_grpc.doctree | Bin 0 -> 66800 bytes ...ability.api.beam_provision_api_pb2_grpc.doctree | Bin 0 -> 21677 bytes ...ortability.api.beam_runner_api_pb2_grpc.doctree | Bin 0 -> 20376 bytes ...ortability.api.beam_runner_api_pb2_urns.doctree | Bin 0 -> 170366 bytes .../doctrees/apache_beam.portability.api.doctree | Bin 0 -> 5046 bytes ...beam.portability.api.endpoints_pb2_grpc.doctree | Bin 0 -> 3560 bytes ...bility.api.external_transforms_pb2_grpc.doctree | Bin 0 -> 3692 bytes ...e_beam.portability.api.metrics_pb2_grpc.doctree | Bin 0 -> 3534 bytes ...e_beam.portability.api.metrics_pb2_urns.doctree | Bin 0 -> 92012 bytes ...he_beam.portability.api.schema_pb2_grpc.doctree | Bin 0 -> 3521 bytes ...bility.api.standard_window_fns_pb2_grpc.doctree | Bin 0 -> 3694 bytes ...bility.api.standard_window_fns_pb2_urns.doctree | Bin 0 -> 26854 bytes .../apache_beam.portability.common_urns.doctree | Bin 0 -> 3363 bytes .../doctrees/apache_beam.portability.doctree | Bin 0 -> 4364 bytes .../apache_beam.portability.python_urns.doctree | Bin 0 -> 3591 bytes .../doctrees/apache_beam.portability.utils.doctree | Bin 0 -> 11148 bytes pydoc/2.31.0/doctrees/apache_beam.pvalue.doctree | Bin 0 -> 48345 bytes ...flow.dataflow_exercise_metrics_pipeline.doctree | Bin 0 -> 16294 bytes ...low_exercise_streaming_metrics_pipeline.doctree | Bin 0 -> 14961 bytes ..._beam.runners.dataflow.dataflow_metrics.doctree | Bin 0 -> 15787 bytes ...e_beam.runners.dataflow.dataflow_runner.doctree | Bin 0 -> 83997 bytes .../doctrees/apache_beam.runners.dataflow.doctree | Bin 0 -> 5044 bytes .../apache_beam.runners.dataflow.native_io.doctree | Bin 0 -> 3682 bytes ..._beam.runners.dataflow.native_io.iobase.doctree | Bin 0 -> 67105 bytes ...m.runners.dataflow.ptransform_overrides.doctree | Bin 0 -> 51823 bytes ...m.runners.dataflow.test_dataflow_runner.doctree | Bin 0 -> 12903 bytes ...ache_beam.runners.direct.bundle_factory.doctree | Bin 0 -> 11160 bytes .../apache_beam.runners.direct.clock.doctree | Bin 0 -> 17736 bytes ...rect.consumer_tracking_pipeline_visitor.doctree | Bin 0 -> 11671 bytes ...ache_beam.runners.direct.direct_metrics.doctree | Bin 0 -> 23510 bytes ...pache_beam.runners.direct.direct_runner.doctree | Bin 0 -> 18639 bytes ...he_beam.runners.direct.direct_userstate.doctree | Bin 0 -> 57115 bytes .../doctrees/apache_beam.runners.direct.doctree | Bin 0 -> 4958 bytes ..._beam.runners.direct.evaluation_context.doctree | Bin 0 -> 43665 bytes .../apache_beam.runners.direct.executor.doctree | Bin 0 -> 19358 bytes ...e_beam.runners.direct.helper_transforms.doctree | Bin 0 -> 29285 bytes ...e_beam.runners.direct.sdf_direct_runner.doctree | Bin 0 -> 98689 bytes ..._beam.runners.direct.test_direct_runner.doctree | Bin 0 -> 8331 bytes ...he_beam.runners.direct.test_stream_impl.doctree | Bin 0 -> 4105 bytes ...beam.runners.direct.transform_evaluator.doctree | Bin 0 -> 25299 bytes .../apache_beam.runners.direct.util.doctree | Bin 0 -> 13814 bytes ...e_beam.runners.direct.watermark_manager.doctree | Bin 0 -> 18209 bytes pydoc/2.31.0/doctrees/apache_beam.runners.doctree | Bin 0 -> 4588 bytes ....runners.interactive.augmented_pipeline.doctree | Bin 0 -> 16577 bytes ...ners.interactive.background_caching_job.doctree | Bin 0 -> 44611 bytes ..._beam.runners.interactive.cache_manager.doctree | Bin 0 -> 70553 bytes ...m.runners.interactive.caching.cacheable.doctree | Bin 0 -> 13321 bytes ...apache_beam.runners.interactive.caching.doctree | Bin 0 -> 3878 bytes ....runners.interactive.caching.read_cache.doctree | Bin 0 -> 12724 bytes ...ers.interactive.caching.streaming_cache.doctree | Bin 0 -> 55894 bytes ...runners.interactive.caching.write_cache.doctree | Bin 0 -> 12505 bytes ...ers.interactive.display.display_manager.doctree | Bin 0 -> 18217 bytes ...apache_beam.runners.interactive.display.doctree | Bin 0 -> 3978 bytes ...tive.display.interactive_pipeline_graph.doctree | Bin 0 -> 18568 bytes ...interactive.display.pcoll_visualization.doctree | Bin 0 -> 28633 bytes ...ners.interactive.display.pipeline_graph.doctree | Bin 0 -> 14635 bytes ...ractive.display.pipeline_graph_renderer.doctree | Bin 0 -> 37163 bytes .../apache_beam.runners.interactive.doctree | Bin 0 -> 4811 bytes ...am.runners.interactive.interactive_beam.doctree | Bin 0 -> 38024 bytes ...ers.interactive.interactive_environment.doctree | Bin 0 -> 105297 bytes ....runners.interactive.interactive_runner.doctree | Bin 0 -> 38792 bytes ...ache_beam.runners.interactive.messaging.doctree | Bin 0 -> 3746 bytes ...aging.interactive_environment_inspector.doctree | Bin 0 -> 29444 bytes ...ers.interactive.options.capture_control.doctree | Bin 0 -> 13037 bytes ...rs.interactive.options.capture_limiters.doctree | Bin 0 -> 36980 bytes ...apache_beam.runners.interactive.options.doctree | Bin 0 -> 3835 bytes ...interactive.options.interactive_options.doctree | Bin 0 -> 8137 bytes ...m.runners.interactive.pipeline_fragment.doctree | Bin 0 -> 13432 bytes ...runners.interactive.pipeline_instrument.doctree | Bin 0 -> 57891 bytes ...m.runners.interactive.recording_manager.doctree | Bin 0 -> 46821 bytes ...apache_beam.runners.interactive.testing.doctree | Bin 0 -> 4290 bytes ...runners.interactive.testing.integration.doctree | Bin 0 -> 3933 bytes ...e.testing.integration.notebook_executor.doctree | Bin 0 -> 22597 bytes ...ractive.testing.integration.screen_diff.doctree | Bin 0 -> 20007 bytes ...unners.interactive.testing.mock_ipython.doctree | Bin 0 -> 7376 bytes ....interactive.testing.pipeline_assertion.doctree | Bin 0 -> 18093 bytes ....interactive.testing.test_cache_manager.doctree | Bin 0 -> 36449 bytes ...nners.interactive.user_pipeline_tracker.doctree | Bin 0 -> 24758 bytes .../apache_beam.runners.interactive.utils.doctree | Bin 0 -> 31519 bytes .../doctrees/apache_beam.runners.job.doctree | Bin 0 -> 3525 bytes .../apache_beam.runners.job.manager.doctree | Bin 0 -> 6274 bytes .../doctrees/apache_beam.runners.job.utils.doctree | Bin 0 -> 6608 bytes .../apache_beam.runners.pipeline_context.doctree | Bin 0 -> 27123 bytes .../doctrees/apache_beam.runners.runner.doctree | Bin 0 -> 63183 bytes .../doctrees/apache_beam.runners.sdf_utils.doctree | Bin 0 -> 56668 bytes ...transforms.combinefn_lifecycle_pipeline.doctree | Bin 0 -> 30213 bytes .../apache_beam.transforms.combiners.doctree | Bin 0 -> 102416 bytes .../doctrees/apache_beam.transforms.core.doctree | Bin 0 -> 440889 bytes .../apache_beam.transforms.create_source.doctree | Bin 0 -> 3036 bytes .../apache_beam.transforms.deduplicate.doctree | Bin 0 -> 14468 bytes .../apache_beam.transforms.display.doctree | Bin 0 -> 56729 bytes .../2.31.0/doctrees/apache_beam.transforms.doctree | Bin 0 -> 4541 bytes .../apache_beam.transforms.environments.doctree | Bin 0 -> 99936 bytes .../apache_beam.transforms.external.doctree | Bin 0 -> 60660 bytes .../apache_beam.transforms.external_java.doctree | Bin 0 -> 13719 bytes ...apache_beam.transforms.periodicsequence.doctree | Bin 0 -> 35708 bytes .../apache_beam.transforms.ptransform.doctree | Bin 0 -> 68534 bytes .../apache_beam.transforms.resources.doctree | Bin 0 -> 33070 bytes .../apache_beam.transforms.sideinputs.doctree | Bin 0 -> 11963 bytes .../doctrees/apache_beam.transforms.sql.doctree | Bin 0 -> 15795 bytes .../doctrees/apache_beam.transforms.stats.doctree | Bin 0 -> 48588 bytes .../apache_beam.transforms.timeutil.doctree | Bin 0 -> 13618 bytes .../apache_beam.transforms.trigger.doctree | Bin 0 -> 173851 bytes .../apache_beam.transforms.userstate.doctree | Bin 0 -> 104285 bytes .../doctrees/apache_beam.transforms.util.doctree | Bin 0 -> 139591 bytes .../doctrees/apache_beam.transforms.window.doctree | Bin 0 -> 117843 bytes .../apache_beam.typehints.decorators.doctree | Bin 0 -> 51121 bytes .../2.31.0/doctrees/apache_beam.typehints.doctree | Bin 0 -> 4177 bytes ...eam.typehints.native_type_compatibility.doctree | Bin 0 -> 30269 bytes .../doctrees/apache_beam.typehints.opcodes.doctree | Bin 0 -> 134868 bytes .../apache_beam.typehints.row_type.doctree | Bin 0 -> 8558 bytes .../doctrees/apache_beam.typehints.schemas.doctree | Bin 0 -> 70180 bytes .../apache_beam.typehints.sharded_key_type.doctree | Bin 0 -> 13091 bytes ...apache_beam.typehints.trivial_inference.doctree | Bin 0 -> 53432 bytes .../apache_beam.typehints.typecheck.doctree | Bin 0 -> 61465 bytes .../apache_beam.typehints.typehints.doctree | Bin 0 -> 17677 bytes .../doctrees/apache_beam.utils.annotations.doctree | Bin 0 -> 33436 bytes pydoc/2.31.0/doctrees/apache_beam.utils.doctree | Bin 0 -> 4446 bytes .../doctrees/apache_beam.utils.histogram.doctree | Bin 0 -> 46717 bytes .../apache_beam.utils.interactive_utils.doctree | Bin 0 -> 11482 bytes .../doctrees/apache_beam.utils.plugin.doctree | Bin 0 -> 9724 bytes .../doctrees/apache_beam.utils.processes.doctree | Bin 0 -> 10154 bytes .../doctrees/apache_beam.utils.profiler.doctree | Bin 0 -> 18078 bytes .../doctrees/apache_beam.utils.proto_utils.doctree | Bin 0 -> 17186 bytes .../doctrees/apache_beam.utils.retry.doctree | Bin 0 -> 44280 bytes .../doctrees/apache_beam.utils.sentinel.doctree | Bin 0 -> 6382 bytes .../doctrees/apache_beam.utils.sharded_key.doctree | Bin 0 -> 8561 bytes .../doctrees/apache_beam.utils.shared.doctree | Bin 0 -> 19340 bytes .../apache_beam.utils.subprocess_server.doctree | Bin 0 -> 38032 bytes .../apache_beam.utils.thread_pool_executor.doctree | Bin 0 -> 11126 bytes .../doctrees/apache_beam.utils.timestamp.doctree | Bin 0 -> 39891 bytes .../2.31.0/doctrees/apache_beam.utils.urns.doctree | Bin 0 -> 18663 bytes pydoc/2.31.0/doctrees/environment.pickle | Bin 0 -> 10633861 bytes pydoc/2.31.0/doctrees/index.doctree | Bin 0 -> 18662 bytes pydoc/2.31.0/genindex.html | 9307 +++++++++ pydoc/2.31.0/index.html | 755 + pydoc/2.31.0/objects.inv | Bin 0 -> 34988 bytes pydoc/2.31.0/py-modindex.html | 1461 ++ pydoc/2.31.0/search.html | 222 + pydoc/2.31.0/searchindex.js | 1 + 1269 files changed, 266365 insertions(+)
