pydoc/2.6.0/searchindex.js

Search.setIndex({docnames:["apache_beam.coders","apache_beam.coders.coders","apache_beam.coders.observable","apache_beam.coders.slow_stream","apache_beam.coders.typecoders","apache_beam.error","apache_beam.internal","apache_beam.internal.gcp","apache_beam.internal.gcp.auth","apache_beam.internal.gcp.json_value","apache_beam.internal.pickler","apache_beam.internal.util","apache_beam.io","apache_beam.io.avroio","apache_beam.io.concat_source","apache_beam.io.filebasedsink","apache_beam.io.filebasedsource","apache_beam.io.filesystem","apache_beam.io.filesystemio","apache_beam.io.filesystems","apache_beam.io.gcp","apache_beam.io.gcp.bigquery","apache_beam.io.gcp.datastore","apache_beam.io.gcp.datastore.v1","apache_beam.io.gcp.datastore.v1.adaptive_throttler","apache_beam.io.gcp.datastore.v1.datastoreio","apache_beam.io.gcp.datastore.v1.fake_datastore","apache_beam.io.gcp.datastore.v1.helper","apache_beam.io.gcp.datastore.v1.query_splitter","apache_beam.io.gcp.datastore.v1.util","apache_beam.io.gcp.gcsfilesystem","apache_beam.io.gcp.gcsio","apache_beam.io.gcp.pubsub","apache_beam.io.hadoopfilesystem","apache_beam.io.iobase","apache_beam.io.localfilesystem","apache_beam.io.range_trackers","apache_beam.io.restriction_trackers","apache_beam.io.source_test_utils","apache_beam.io.textio","apache_beam.io.tfrecordio","apache_beam.io.utils","apache_beam.io.vcfio","apache_beam.metrics","apache_beam.metrics.cells","apache_beam.metrics.metric","apache_beam.metrics.metricbase","apache_beam.options","apache_beam.options.pipeline_options","apache_beam.options.pipeline_options_validator","apache_beam.options.value_provider","apache_beam.pipeline","apache_beam.portability","apache_beam.portability.api","apache_beam.portability.api.beam_artifact_api_pb2_grpc","apache_beam.portability.api.beam_fn_api_pb2_grpc","apache_beam.portability.api.beam_job_api_pb2_grpc","apache_beam.portability.api.beam_provision_api_pb2_grpc","apache_beam.portability.api.beam_runner_api_pb2_grpc","apache_beam.portability.api.endpoints_pb2_grpc","apache_beam.portability.api.standard_window_fns_pb2_grpc","apache_beam.portability.common_urns","apache_beam.portability.python_urns","apache_beam.pvalue","apache_beam.runners","apache_beam.runners.dataflow","apache_beam.runners.dataflow.dataflow_metrics","apache_beam.runners.dataflow.dataflow_runner","apache_beam.runners.dataflow.native_io","apache_beam.runners.dataflow.native_io.iobase","apache_beam.runners.dataflow.native_io.streaming_create","apache_beam.runners.dataflow.ptransform_overrides","apache_beam.runners.dataflow.test_dataflow_runner","apache_beam.runners.direct","apache_beam.runners.direct.bundle_factory","apache_beam.runners.direct.clock","apache_beam.runners.direct.consumer_tracking_pipeline_visitor","apache_beam.runners.direct.direct_metrics","apache_beam.runners.direct.direct_runner","apache_beam.runners.direct.evaluation_context","apache_beam.runners.direct.executor","apache_beam.runners.direct.helper_transforms","apache_beam.runners.direct.sdf_direct_runner","apache_beam.runners.direct.transform_evaluator","apache_beam.runners.direct.util","apache_beam.runners.direct.watermark_manager","apache_beam.runners.interactive","apache_beam.runners.interactive.display_manager","apache_beam.runners.interactive.interactive_pipeline_graph","apache_beam.runners.interactive.interactive_runner","apache_beam.runners.interactive.pipeline_graph","apache_beam.runners.job","apache_beam.runners.job.manager","apache_beam.runners.job.utils","apache_beam.runners.pipeline_context","apache_beam.runners.runner","apache_beam.runners.sdf_common","apache_beam.testing","apache_beam.testing.benchmarks","apache_beam.testing.benchmarks.nexmark","apache_beam.testing.benchmarks.nexmark.models","apache_beam.testing.benchmarks.nexmark.models.nexmark_model","apache_beam.testing.benchmarks.nexmark.nexmark_launcher","apache_beam.testing.benchmarks.nexmark.nexmark_util","apache_beam.testing.benchmarks.nexmark.queries","apache_beam.testing.benchmarks.nexmark.queries.query0","apache_beam.testing.benchmarks.nexmark.queries.query1","apache_beam.testing.benchmarks.nexmark.queries.query2","apache_beam.testing.pipeline_verifiers","apache_beam.testing.synthetic_pipeline","apache_beam.testing.test_pipeline","apache_beam.testing.test_stream","apache_beam.testing.test_utils","apache_beam.testing.util","apache_beam.tools","apache_beam.tools.coders_microbenchmark","apache_beam.tools.distribution_counter_microbenchmark","apache_beam.tools.sideinput_microbenchmark","apache_beam.tools.utils","apache_beam.transforms","apache_beam.transforms.combiners","apache_beam.transforms.core","apache_beam.transforms.create_source","apache_beam.transforms.display","apache_beam.transforms.ptransform","apache_beam.transforms.sideinputs","apache_beam.transforms.timeutil","apache_beam.transforms.trigger","apache_beam.transforms.userstate","apache_beam.transforms.util","apache_beam.transforms.window","apache_beam.typehints","apache_beam.typehints.decorators","apache_beam.typehints.native_type_compatibility","apache_beam.typehints.opcodes","apache_beam.typehints.trivial_inference","apache_beam.typehints.typecheck","apache_beam.typehints.typehints","apache_beam.utils","apache_beam.utils.annotations","apache_beam.utils.plugin","apache_beam.utils.processes","apache_beam.utils.profiler","apache_beam.utils.proto_utils","apache_beam.utils.retry","apache_beam.utils.timestamp","apache_beam.utils.urns","apache_beam.version","index"],envversion:52,filenames:["apache_beam.coders.rst","apache_beam.coders.coders.rst","apache_beam.coders.observable.rst","apache_beam.coders.slow_stream.rst","apache_beam.coders.typecoders.rst","apache_beam.error.rst","apache_beam.internal.rst","apache_beam.internal.gcp.rst","apache_beam.internal.gcp.auth.rst","apache_beam.internal.gcp.json_value.rst","apache_beam.internal.pickler.rst","apache_beam.internal.util.rst","apache_beam.io.rst","apache_beam.io.avroio.rst","apache_beam.io.concat_source.rst","apache_beam.io.filebasedsink.rst","apache_beam.io.filebasedsource.rst","apache_beam.io.filesystem.rst","apache_beam.io.filesystemio.rst","apache_beam.io.filesystems.rst","apache_beam.io.gcp.rst","apache_beam.io.gcp.bigquery.rst","apache_beam.io.gcp.datastore.rst","apache_beam.io.gcp.datastore.v1.rst","apache_beam.io.gcp.datastore.v1.adaptive_throttler.rst","apache_beam.io.gcp.datastore.v1.datastoreio.rst","apache_beam.io.gcp.datastore.v1.fake_datastore.rst","apache_beam.io.gcp.datastore.v1.helper.rst","apache_beam.io.gcp.datastore.v1.query_splitter.rst","apache_beam.io.gcp.datastore.v1.util.rst","apache_beam.io.gcp.gcsfilesystem.rst","apache_beam.io.gcp.gcsio.rst","apache_beam.io.gcp.pubsub.rst","apache_beam.io.hadoopfilesystem.rst","apache_beam.io.iobase.rst","apache_beam.io.localfilesystem.rst","apache_beam.io.range_trackers.rst","apache_beam.io.restriction_trackers.rst","apache_beam.io.source_test_utils.rst","apache_beam.io.textio.rst","apache_beam.io.tfrecordio.rst","apache_beam.io.utils.rst","apache_beam.io.vcfio.rst","apache_beam.metrics.rst","apache_beam.metrics.cells.rst","apache_beam.metrics.metric.rst","apache_beam.metrics.metricbase.rst","apache_beam.options.rst","apache_beam.options.pipeline_options.rst","apache_beam.options.pipeline_options_validator.rst","apache_beam.options.value_provider.rst","apache_beam.pipeline.rst","apache_beam.portability.rst","apache_beam.portability.api.rst","apache_beam.portability.api.beam_artifact_api_pb2_grpc.rst","apache_beam.portability.api.beam_fn_api_pb2_grpc.rst","apache_beam.portability.api.beam_job_api_pb2_grpc.rst","apache_beam.portability.api.beam_provision_api_pb2_grpc.rst","apache_beam.portability.api.beam_runner_api_pb2_grpc.rst","apache_beam.portability.api.endpoints_pb2_grpc.rst","apache_beam.portability.api.standard_window_fns_pb2_grpc.rst","apache_beam.portability.common_urns.rst","apache_beam.portability.python_urns.rst","apache_beam.pvalue.rst","apache_beam.runners.rst","apache_beam.runners.dataflow.rst","apache_beam.runners.dataflow.dataflow_metrics.rst","apache_beam.runners.dataflow.dataflow_runner.rst","apache_beam.runners.dataflow.native_io.rst","apache_beam.runners.dataflow.native_io.iobase.rst","apache_beam.runners.dataflow.native_io.streaming_create.rst","apache_beam.runners.dataflow.ptransform_overrides.rst","apache_beam.runners.dataflow.test_dataflow_runner.rst","apache_beam.runners.direct.rst","apache_beam.runners.direct.bundle_factory.rst","apache_beam.runners.direct.clock.rst","apache_beam.runners.direct.consumer_tracking_pipeline_visitor.rst","apache_beam.runners.direct.direct_metrics.rst","apache_beam.runners.direct.direct_runner.rst","apache_beam.runners.direct.evaluation_context.rst","apache_beam.runners.direct.executor.rst","apache_beam.runners.direct.helper_transforms.rst","apache_beam.runners.direct.sdf_direct_runner.rst","apache_beam.runners.direct.transform_evaluator.rst","apache_beam.runners.direct.util.rst","apache_beam.runners.direct.watermark_manager.rst","apache_beam.runners.interactive.rst","apache_beam.runners.interactive.display_manager.rst","apache_beam.runners.interactive.interactive_pipeline_graph.rst","apache_beam.runners.interactive.interactive_runner.rst","apache_beam.runners.interactive.pipeline_graph.rst","apache_beam.runners.job.rst","apache_beam.runners.job.manager.rst","apache_beam.runners.job.utils.rst","apache_beam.runners.pipeline_context.rst","apache_beam.runners.runner.rst","apache_beam.runners.sdf_common.rst","apache_beam.testing.rst","apache_beam.testing.benchmarks.rst","apache_beam.testing.benchmarks.nexmark.rst","apache_beam.testing.benchmarks.nexmark.models.rst","apache_beam.testing.benchmarks.nexmark.models.nexmark_model.rst","apache_beam.testing.benchmarks.nexmark.nexmark_launcher.rst","apache_beam.testing.benchmarks.nexmark.nexmark_util.rst","apache_beam.testing.benchmarks.nexmark.queries.rst","apache_beam.testing.benchmarks.nexmark.queries.query0.rst","apache_beam.testing.benchmarks.nexmark.queries.query1.rst","apache_beam.testing.benchmarks.nexmark.queries.query2.rst","apache_beam.testing.pipeline_verifiers.rst","apache_beam.testing.synthetic_pipeline.rst","apache_beam.testing.test_pipeline.rst","apache_beam.testing.test_stream.rst","apache_beam.testing.test_utils.rst","apache_beam.testing.util.rst","apache_beam.tools.rst","apache_beam.tools.coders_microbenchmark.rst","apache_beam.tools.distribution_counter_microbenchmark.rst","apache_beam.tools.sideinput_microbenchmark.rst","apache_beam.tools.utils.rst","apache_beam.transforms.rst","apache_beam.transforms.combiners.rst","apache_beam.transforms.core.rst","apache_beam.transforms.create_source.rst","apache_beam.transforms.display.rst","apache_beam.transforms.ptransform.rst","apache_beam.transforms.sideinputs.rst","apache_beam.transforms.timeutil.rst","apache_beam.transforms.trigger.rst","apache_beam.transforms.userstate.rst","apache_beam.transforms.util.rst","apache_beam.transforms.window.rst","apache_beam.typehints.rst","apache_beam.typehints.decorators.rst","apache_beam.typehints.native_type_compatibility.rst","apache_beam.typehints.opcodes.rst","apache_beam.typehints.trivial_inference.rst","apache_beam.typehints.typecheck.rst","apache_beam.typehints.typehints.rst","apache_beam.utils.rst","apache_beam.utils.annotations.rst","apache_beam.utils.plugin.rst","apache_beam.utils.processes.rst","apache_beam.utils.profiler.rst","apache_beam.utils.proto_utils.rst","apache_beam.utils.retry.rst","apache_beam.utils.timestamp.rst","apache_beam.utils.urns.rst","apache_beam.version.rst","index.rst"],objects:{"":{apache_beam:[148,0,0,"-"]},"apache_beam.coders":{coders:[1,0,0,"-"],observable:[2,0,0,"-"],slow_stream:[3,0,0,"-"],typecoders:[4,0,0,"-"]},"apache_beam.coders.coders":{BytesCoder:[1,1,1,""],Coder:[1,1,1,""],DillCoder:[1,1,1,""],FastPrimitivesCoder:[1,1,1,""],FloatCoder:[1,1,1,""],IterableCoder:[1,1,1,""],PickleCoder:[1,1,1,""],ProtoCoder:[1,1,1,""],SingletonCoder:[1,1,1,""],StrUtf8Coder:[1,1,1,""],TimestampCoder:[1,1,1,""],TupleCoder:[1,1,1,""],TupleSequenceCoder:[1,1,1,""],VarIntCoder:[1,1,1,""],WindowedValueCoder:[1,1,1,""]},"apache_beam.coders.coders.BytesCoder":{as_cloud_object:[1,2,1,""],is_deterministic:[1,2,1,""],to_runner_api_parameter:[1,2,1,""]},"apache_beam.coders.coders.Coder":{as_cloud_object:[1,2,1,""],as_deterministic_coder:[1,2,1,""],decode:[1,2,1,""],encode:[1,2,1,""],estimate_size:[1,2,1,""],from_runner_api:[1,3,1,""],from_type_hint:[1,3,1,""],get_impl:[1,2,1,""],is_deterministic:[1,2,1,""],is_kv_coder:[1,2,1,""],key_coder:[1,2,1,""],register_structured_urn:[1,4,1,""],register_urn:[1,3,1,""],to_runner_api:[1,2,1,""],to_runner_api_parameter:[1,2,1,""],value_coder:[1,2,1,""]},"apache_beam.coders.coders.FastPrimitivesCoder":{as_cloud_object:[1,2,1,""],as_deterministic_coder:[1,2,1,""],is_deterministic:[1,2,1,""],is_kv_coder:[1,2,1,""],key_coder:[1,2,1,""],value_coder:[1,2,1,""]},"apache_beam.coders.coders.FloatCoder":{is_deterministic:[1,2,1,""]},"apache_beam.coders.coders.IterableCoder":{as_cloud_object:[1,2,1,""],as_deterministic_coder:[1,2,1,""],from_type_hint:[1,4,1,""],is_deterministic:[1,2,1,""],to_runner_api_parameter:[1,2,1,""],value_coder:[1,2,1,""]},"apache_beam.coders.coders.PickleCoder":{as_deterministic_coder:[1,2,1,""]},"apache_beam.coders.coders.ProtoCoder":{from_type_hint:[1,4,1,""],is_deterministic:[1,2,1,""]},"apache_beam.coders.coders.SingletonCoder":{is_deterministic:[1,2,1,""]},"apache_beam.coders.coders.StrUtf8Coder":{decode:[1,2,1,""],encode:[1,2,1,""],is_deterministic:[1,2,1,""]},"apache_beam.coders.coders.TimestampCoder":{is_deterministic:[1,2,1,""]},"apache_beam.coders.coders.TupleCoder":{as_cloud_object:[1,2,1,""],as_deterministic_coder:[1,2,1,""],coders:[1,2,1,""],from_runner_api_parameter:[1,4,1,""],from_type_hint:[1,4,1,""],is_deterministic:[1,2,1,""],is_kv_coder:[1,2,1,""],key_coder:[1,2,1,""],to_runner_api_parameter:[1,2,1,""],value_coder:[1,2,1,""]},"apache_beam.coders.coders.TupleSequenceCoder":{as_deterministic_coder:[1,2,1,""],from_type_hint:[1,4,1,""],is_deterministic:[1,2,1,""]},"apache_beam.coders.coders.VarIntCoder":{as_cloud_object:[1,2,1,""],is_deterministic:[1,2,1,""],to_runner_api_parameter:[1,2,1,""]},"apache_beam.coders.coders.WindowedValueCoder":{as_cloud_object:[1,2,1,""],is_deterministic:[1,2,1,""],is_kv_coder:[1,2,1,""],key_coder:[1,2,1,""],to_runner_api_parameter:[1,2,1,""],value_coder:[1,2,1,""]},"apache_beam.coders.observable":{ObservableMixin:[2,1,1,""]},"apache_beam.coders.observable.ObservableMixin":{notify_observers:[2,2,1,""],register_observer:[2,2,1,""]},"apache_beam.coders.slow_stream":{ByteCountingOutputStream:[3,1,1,""],InputStream:[3,1,1,""],OutputStream:[3,1,1,""],get_varint_size:[3,5,1,""]},"apache_beam.coders.slow_stream.ByteCountingOutputStream":{get:[3,2,1,""],get_count:[3,2,1,""],write:[3,2,1,""],write_byte:[3,2,1,""]},"apache_beam.coders.slow_stream.InputStream":{read:[3,2,1,""],read_all:[3,2,1,""],read_bigendian_double:[3,2,1,""],read_bigendian_int32:[3,2,1,""],read_bigendian_int64:[3,2,1,""],read_bigendian_uint64:[3,2,1,""],read_byte:[3,2,1,""],read_var_int64:[3,2,1,""],size:[3,2,1,""]},"apache_beam.coders.slow_stream.OutputStream":{get:[3,2,1,""],size:[3,2,1,""],write:[3,2,1,""],write_bigendian_double:[3,2,1,""],write_bigendian_int32:[3,2,1,""],write_bigendian_int64:[3,2,1,""],write_bigendian_uint64:[3,2,1,""],write_byte:[3,2,1,""],write_var_int64:[3,2,1,""]},"apache_beam.error":{BeamError:[5,6,1,""],PValueError:[5,6,1,""],PipelineError:[5,6,1,""],RunnerError:[5,6,1,""],RuntimeValueProviderError:[5,6,1,""],SideInputError:[5,6,1,""],TransformError:[5,6,1,""]},"apache_beam.internal":{gcp:[7,0,0,"-"],pickler:[10,0,0,"-"],util:[11,0,0,"-"]},"apache_beam.internal.gcp":{auth:[8,0,0,"-"],json_value:[9,0,0,"-"]},"apache_beam.internal.gcp.auth":{AuthenticationException:[8,6,1,""],get_service_credentials:[8,5,1,""],set_running_in_gce:[8,5,1,""]},"apache_beam.internal.gcp.json_value":{from_json_value:[9,5,1,""],get_typed_value_descriptor:[9,5,1,""],to_json_value:[9,5,1,""]},"apache_beam.internal.pickler":{dump_session:[10,5,1,""],dumps:[10,5,1,""],load_session:[10,5,1,""],loads:[10,5,1,""],new_save_module_dict:[10,5,1,""],save_module:[10,5,1,""]},"apache_beam.internal.util":{ArgumentPlaceholder:[11,1,1,""],insert_values_in_args:[11,5,1,""],remove_objects_from_args:[11,5,1,""],run_using_threadpool:[11,5,1,""]},"apache_beam.io":{avroio:[13,0,0,"-"],concat_source:[14,0,0,"-"],filebasedsink:[15,0,0,"-"],filebasedsource:[16,0,0,"-"],filesystem:[17,0,0,"-"],filesystemio:[18,0,0,"-"],filesystems:[19,0,0,"-"],gcp:[20,0,0,"-"],hadoopfilesystem:[33,0,0,"-"],iobase:[34,0,0,"-"],localfilesystem:[35,0,0,"-"],range_trackers:[36,0,0,"-"],restriction_trackers:[37,0,0,"-"],source_test_utils:[38,0,0,"-"],textio:[39,0,0,"-"],tfrecordio:[40,0,0,"-"],utils:[41,0,0,"-"],vcfio:[42,0,0,"-"]},"apache_beam.io.avroio":{ReadAllFromAvro:[13,1,1,""],ReadFromAvro:[13,1,1,""],WriteToAvro:[13,1,1,""]},"apache_beam.io.avroio.ReadAllFromAvro":{DEFAULT_DESIRED_BUNDLE_SIZE:[13,7,1,""],expand:[13,2,1,""]},"apache_beam.io.avroio.ReadFromAvro":{display_data:[13,2,1,""],expand:[13,2,1,""]},"apache_beam.io.avroio.WriteToAvro":{display_data:[13,2,1,""],expand:[13,2,1,""]},"apache_beam.io.concat_source":{ConcatRangeTracker:[14,1,1,""],ConcatSource:[14,1,1,""]},"apache_beam.io.concat_source.ConcatRangeTracker":{fraction_consumed:[14,2,1,""],global_to_local:[14,2,1,""],local_to_global:[14,2,1,""],position_at_fraction:[14,2,1,""],set_current_position:[14,2,1,""],start_position:[14,2,1,""],stop_position:[14,2,1,""],sub_range_tracker:[14,2,1,""],try_claim:[14,2,1,""],try_split:[14,2,1,""]},"apache_beam.io.concat_source.ConcatSource":{default_output_coder:[14,2,1,""],estimate_size:[14,2,1,""],get_range_tracker:[14,2,1,""],read:[14,2,1,""],sources:[14,7,1,""],split:[14,2,1,""]},"apache_beam.io.filebasedsink":{FileBasedSink:[15,1,1,""]},"apache_beam.io.filebasedsink.FileBasedSink":{close:[15,2,1,""],display_data:[15,2,1,""],finalize_write:[15,2,1,""],initialize_write:[15,2,1,""],open:[15,2,1,""],open_writer:[15,2,1,""],pre_finalize:[15,2,1,""],write_encoded_record:[15,2,1,""],write_record:[15,2,1,""]},"apache_beam.io.filebasedsource":{FileBasedSource:[16,1,1,""]},"apache_beam.io.filebasedsource.FileBasedSource":{MIN_FRACTION_OF_FILES_TO_STAT:[16,7,1,""],MIN_NUMBER_OF_FILES_TO_STAT:[16,7,1,""],display_data:[16,2,1,""],estimate_size:[16,2,1,""],get_range_tracker:[16,2,1,""],open_file:[16,2,1,""],read:[16,2,1,""],read_records:[16,2,1,""],split:[16,2,1,""],splittable:[16,7,1,""]},"apache_beam.io.filesystem":{CompressedFile:[17,1,1,""],CompressionTypes:[17,1,1,""],FileMetadata:[17,1,1,""],FileSystem:[17,1,1,""],MatchResult:[17,1,1,""]},"apache_beam.io.filesystem.CompressedFile":{close:[17,2,1,""],closed:[17,2,1,""],flush:[17,2,1,""],read:[17,2,1,""],readable:[17,2,1,""],readline:[17,2,1,""],seek:[17,2,1,""],seekable:[17,7,1,""],tell:[17,2,1,""],write:[17,2,1,""],writeable:[17,2,1,""]},"apache_beam.io.filesystem.CompressionTypes":{AUTO:[17,7,1,""],BZIP2:[17,7,1,""],GZIP:[17,7,1,""],UNCOMPRESSED:[17,7,1,""],detect_compression_type:[17,3,1,""],is_valid_compression_type:[17,3,1,""],mime_type:[17,3,1,""]},"apache_beam.io.filesystem.FileSystem":{"delete":[17,2,1,""],CHUNK_SIZE:[17,7,1,""],checksum:[17,2,1,""],copy:[17,2,1,""],create:[17,2,1,""],exists:[17,2,1,""],has_dirs:[17,2,1,""],join:[17,2,1,""],match:[17,2,1,""],mkdirs:[17,2,1,""],open:[17,2,1,""],rename:[17,2,1,""],scheme:[17,3,1,""],size:[17,2,1,""],split:[17,2,1,""]},"apache_beam.io.filesystemio":{Downloader:[18,1,1,""],DownloaderStream:[18,1,1,""],PipeStream:[18,1,1,""],Uploader:[18,1,1,""],UploaderStream:[18,1,1,""]},"apache_beam.io.filesystemio.Downloader":{get_range:[18,2,1,""],size:[18,7,1,""]},"apache_beam.io.filesystemio.DownloaderStream":{readable:[18,2,1,""],readinto:[18,2,1,""],seek:[18,2,1,""],seekable:[18,2,1,""],tell:[18,2,1,""]},"apache_beam.io.filesystemio.PipeStream":{read:[18,2,1,""],seek:[18,2,1,""],tell:[18,2,1,""]},"apache_beam.io.filesystemio.Uploader":{finish:[18,2,1,""],put:[18,2,1,""]},"apache_beam.io.filesystemio.UploaderStream":{close:[18,2,1,""],tell:[18,2,1,""],writable:[18,2,1,""],write:[18,2,1,""]},"apache_beam.io.filesystems":{FileSystems:[19,1,1,""]},"apache_beam.io.filesystems.FileSystems":{"delete":[19,4,1,""],URI_SCHEMA_PATTERN:[19,7,1,""],checksum:[19,4,1,""],copy:[19,4,1,""],create:[19,4,1,""],exists:[19,4,1,""],get_chunk_size:[19,4,1,""],get_filesystem:[19,4,1,""],get_scheme:[19,4,1,""],join:[19,4,1,""],match:[19,4,1,""],mkdirs:[19,4,1,""],open:[19,4,1,""],rename:[19,4,1,""],set_options:[19,3,1,""],split:[19,4,1,""]},"apache_beam.io.gcp":{bigquery:[21,0,0,"-"],datastore:[22,0,0,"-"],gcsfilesystem:[30,0,0,"-"],gcsio:[31,0,0,"-"],pubsub:[32,0,0,"-"]},"apache_beam.io.gcp.bigquery":{BigQueryDisposition:[21,1,1,""],BigQuerySink:[21,1,1,""],BigQuerySource:[21,1,1,""],TableRowJsonCoder:[21,1,1,""],WriteToBigQuery:[21,1,1,""]},"apache_beam.io.gcp.bigquery.BigQueryDisposition":{CREATE_IF_NEEDED:[21,7,1,""],CREATE_NEVER:[21,7,1,""],WRITE_APPEND:[21,7,1,""],WRITE_EMPTY:[21,7,1,""],WRITE_TRUNCATE:[21,7,1,""],validate_create:[21,4,1,""],validate_write:[21,4,1,""]},"apache_beam.io.gcp.bigquery.BigQuerySink":{display_data:[21,2,1,""],format:[21,7,1,""],schema_as_json:[21,2,1,""],writer:[21,2,1,""]},"apache_beam.io.gcp.bigquery.BigQuerySource":{display_data:[21,2,1,""],format:[21,7,1,""],reader:[21,2,1,""]},"apache_beam.io.gcp.bigquery.TableRowJsonCoder":{decode:[21,2,1,""],encode:[21,2,1,""]},"apache_beam.io.gcp.bigquery.WriteToBigQuery":{display_data:[21,2,1,""],expand:[21,2,1,""],get_dict_table_schema:[21,4,1,""],get_table_schema_from_string:[21,4,1,""],table_schema_to_dict:[21,4,1,""]},"apache_beam.io.gcp.datastore":{v1:[23,0,0,"-"]},"apache_beam.io.gcp.datastore.v1":{adaptive_throttler:[24,0,0,"-"],datastoreio:[25,0,0,"-"],fake_datastore:[26,0,0,"-"],helper:[27,0,0,"-"],query_splitter:[28,0,0,"-"],util:[29,0,0,"-"]},"apache_beam.io.gcp.datastore.v1.adaptive_throttler":{AdaptiveThrottler:[24,1,1,""]},"apache_beam.io.gcp.datastore.v1.adaptive_throttler.AdaptiveThrottler":{MIN_REQUESTS:[24,7,1,""],successful_request:[24,2,1,""],throttle_request:[24,2,1,""]},"apache_beam.io.gcp.datastore.v1.datastoreio":{DeleteFromDatastore:[25,1,1,""],ReadFromDatastore:[25,1,1,""],WriteToDatastore:[25,1,1,""]},"apache_beam.io.gcp.datastore.v1.datastoreio.DeleteFromDatastore":{to_delete_mutation:[25,4,1,""]},"apache_beam.io.gcp.datastore.v1.datastoreio.ReadFromDatastore":{ReadFn:[25,1,1,""],SplitQueryFn:[25,1,1,""],display_data:[25,2,1,""],expand:[25,2,1,""],get_estimated_num_splits:[25,4,1,""],get_estimated_size_bytes:[25,4,1,""],query_latest_statistics_timestamp:[25,4,1,""]},"apache_beam.io.gcp.datastore.v1.datastoreio.ReadFromDatastore.ReadFn":{display_data:[25,2,1,""],process:[25,2,1,""],start_bundle:[25,2,1,""]},"apache_beam.io.gcp.datastore.v1.datastoreio.ReadFromDatastore.SplitQueryFn":{display_data:[25,2,1,""],process:[25,2,1,""],start_bundle:[25,2,1,""]},"apache_beam.io.gcp.datastore.v1.datastoreio.WriteToDatastore":{to_upsert_mutation:[25,4,1,""]},"apache_beam.io.gcp.datastore.v1.fake_datastore":{create_commit:[26,5,1,""],create_entities:[26,5,1,""],create_response:[26,5,1,""],create_run_query:[26,5,1,""]},"apache_beam.io.gcp.datastore.v1.helper":{QueryIterator:[27,1,1,""],compare_path:[27,5,1,""],fetch_entities:[27,5,1,""],get_datastore:[27,5,1,""],is_key_valid:[27,5,1,""],key_comparator:[27,5,1,""],make_kind_stats_query:[27,5,1,""],make_latest_timestamp_query:[27,5,1,""],make_partition:[27,5,1,""],make_request:[27,5,1,""],retry_on_rpc_error:[27,5,1,""],write_mutations:[27,5,1,""]},"apache_beam.io.gcp.datastore.v1.query_splitter":{get_splits:[28,5,1,""]},"apache_beam.io.gcp.datastore.v1.util":{MovingSum:[29,1,1,""]},"apache_beam.io.gcp.datastore.v1.util.MovingSum":{add:[29,2,1,""],count:[29,2,1,""],has_data:[29,2,1,""],sum:[29,2,1,""]},"apache_beam.io.gcp.gcsfilesystem":{GCSFileSystem:[30,1,1,""]},"apache_beam.io.gcp.gcsfilesystem.GCSFileSystem":{"delete":[30,2,1,""],CHUNK_SIZE:[30,7,1,""],GCS_PREFIX:[30,7,1,""],checksum:[30,2,1,""],copy:[30,2,1,""],create:[30,2,1,""],exists:[30,2,1,""],has_dirs:[30,2,1,""],join:[30,2,1,""],mkdirs:[30,2,1,""],open:[30,2,1,""],rename:[30,2,1,""],scheme:[30,3,1,""],size:[30,2,1,""],split:[30,2,1,""]},"apache_beam.io.gcp.gcsio":{GcsIO:[31,1,1,""]},"apache_beam.io.gcp.gcsio.GcsIO":{"delete":[31,2,1,""],checksum:[31,2,1,""],copy:[31,2,1,""],copy_batch:[31,2,1,""],copytree:[31,2,1,""],delete_batch:[31,2,1,""],exists:[31,2,1,""],list_prefix:[31,2,1,""],open:[31,2,1,""],rename:[31,2,1,""],size:[31,2,1,""]},"apache_beam.io.gcp.pubsub":{PubsubMessage:[32,1,1,""],ReadFromPubSub:[32,1,1,""],ReadStringsFromPubSub:[32,1,1,""],WriteStringsToPubSub:[32,1,1,""]},"apache_beam.io.gcp.pubsub.PubsubMessage":{attributes:[32,7,1,""],payload:[32,7,1,""]},"apache_beam.io.gcp.pubsub.ReadFromPubSub":{expand:[32,2,1,""],to_runner_api_parameter:[32,2,1,""]},"apache_beam.io.gcp.pubsub.ReadStringsFromPubSub":{expand:[32,2,1,""]},"apache_beam.io.gcp.pubsub.WriteStringsToPubSub":{expand:[32,2,1,""],to_runner_api_parameter:[32,2,1,""],topic:[32,7,1,""]},"apache_beam.io.hadoopfilesystem":{HadoopFileSystem:[33,1,1,""]},"apache_beam.io.hadoopfilesystem.HadoopFileSystem":{"delete":[33,2,1,""],checksum:[33,2,1,""],copy:[33,2,1,""],create:[33,2,1,""],exists:[33,2,1,""],has_dirs:[33,2,1,""],join:[33,2,1,""],mkdirs:[33,2,1,""],open:[33,2,1,""],rename:[33,2,1,""],scheme:[33,3,1,""],size:[33,2,1,""],split:[33,2,1,""]},"apache_beam.io.iobase":{BoundedSource:[34,1,1,""],RangeTracker:[34,1,1,""],Read:[34,1,1,""],RestrictionTracker:[34,1,1,""],Sink:[34,1,1,""],Write:[34,1,1,""],Writer:[34,1,1,""]},"apache_beam.io.iobase.BoundedSource":{default_output_coder:[34,2,1,""],estimate_size:[34,2,1,""],get_range_tracker:[34,2,1,""],is_bounded:[34,2,1,""],read:[34,2,1,""],split:[34,2,1,""]},"apache_beam.io.iobase.RangeTracker":{SPLIT_POINTS_UNKNOWN:[34,7,1,""],fraction_consumed:[34,2,1,""],position_at_fraction:[34,2,1,""],set_current_position:[34,2,1,""],set_split_points_unclaimed_callback:[34,2,1,""],split_points:[34,2,1,""],start_position:[34,2,1,""],stop_position:[34,2,1,""],try_claim:[34,2,1,""],try_split:[34,2,1,""]},"apache_beam.io.iobase.Read":{display_data:[34,2,1,""],expand:[34,2,1,""],from_runner_api_parameter:[34,4,1,""],get_windowing:[34,2,1,""],to_runner_api_parameter:[34,2,1,""]},"apache_beam.io.iobase.RestrictionTracker":{check_done:[34,2,1,""],checkpoint:[34,2,1,""],current_restriction:[34,2,1,""]},"apache_beam.io.iobase.Sink":{finalize_write:[34,2,1,""],initialize_write:[34,2,1,""],open_writer:[34,2,1,""],pre_finalize:[34,2,1,""]},"apache_beam.io.iobase.Write":{display_data:[34,2,1,""],expand:[34,2,1,""]},"apache_beam.io.iobase.Writer":{close:[34,2,1,""],write:[34,2,1,""]},"apache_beam.io.localfilesystem":{LocalFileSystem:[35,1,1,""]},"apache_beam.io.localfilesystem.LocalFileSystem":{"delete":[35,2,1,""],checksum:[35,2,1,""],copy:[35,2,1,""],create:[35,2,1,""],exists:[35,2,1,""],has_dirs:[35,2,1,""],join:[35,2,1,""],mkdirs:[35,2,1,""],open:[35,2,1,""],rename:[35,2,1,""],scheme:[35,3,1,""],size:[35,2,1,""],split:[35,2,1,""]},"apache_beam.io.range_trackers":{LexicographicKeyRangeTracker:[36,1,1,""],OffsetRangeTracker:[36,1,1,""],OrderedPositionRangeTracker:[36,1,1,""],UnsplittableRangeTracker:[36,1,1,""]},"apache_beam.io.range_trackers.LexicographicKeyRangeTracker":{fraction_to_position:[36,3,1,""],position_to_fraction:[36,3,1,""]},"apache_beam.io.range_trackers.OffsetRangeTracker":{OFFSET_INFINITY:[36,7,1,""],fraction_consumed:[36,2,1,""],last_record_start:[36,7,1,""],position_at_fraction:[36,2,1,""],set_current_position:[36,2,1,""],set_split_points_unclaimed_callback:[36,2,1,""],split_points:[36,2,1,""],start_position:[36,2,1,""],stop_position:[36,2,1,""],try_claim:[36,2,1,""],try_split:[36,2,1,""]},"apache_beam.io.range_trackers.OrderedPositionRangeTracker":{UNSTARTED:[36,7,1,""],fraction_consumed:[36,2,1,""],fraction_to_position:[36,2,1,""],position_at_fraction:[36,2,1,""],position_to_fraction:[36,2,1,""],start_position:[36,2,1,""],stop_position:[36,2,1,""],try_claim:[36,2,1,""],try_split:[36,2,1,""]},"apache_beam.io.range_trackers.UnsplittableRangeTracker":{fraction_consumed:[36,2,1,""],position_at_fraction:[36,2,1,""],set_current_position:[36,2,1,""],set_split_points_unclaimed_callback:[36,2,1,""],split_points:[36,2,1,""],start_position:[36,2,1,""],stop_position:[36,2,1,""],try_claim:[36,2,1,""],try_split:[36,2,1,""]},"apache_beam.io.restriction_trackers":{OffsetRange:[37,1,1,""],OffsetRestrictionTracker:[37,1,1,""]},"apache_beam.io.restriction_trackers.OffsetRange":{new_tracker:[37,2,1,""],split:[37,2,1,""]},"apache_beam.io.restriction_trackers.OffsetRestrictionTracker":{check_done:[37,2,1,""],checkpoint:[37,2,1,""],current_restriction:[37,2,1,""],start_position:[37,2,1,""],stop_position:[37,2,1,""],try_claim:[37,2,1,""]},"apache_beam.io.source_test_utils":{assert_reentrant_reads_succeed:[38,5,1,""],assert_sources_equal_reference_source:[38,5,1,""],assert_split_at_fraction_behavior:[38,5,1,""],assert_split_at_fraction_binary:[38,5,1,""],assert_split_at_fraction_exhaustive:[38,5,1,""],assert_split_at_fraction_fails:[38,5,1,""],assert_split_at_fraction_succeeds_and_consistent:[38,5,1,""],read_from_source:[38,5,1,""]},"apache_beam.io.textio":{ReadAllFromText:[39,1,1,""],ReadFromText:[39,1,1,""],WriteToText:[39,1,1,""]},"apache_beam.io.textio.ReadAllFromText":{DEFAULT_DESIRED_BUNDLE_SIZE:[39,7,1,""],expand:[39,2,1,""]},"apache_beam.io.textio.ReadFromText":{expand:[39,2,1,""]},"apache_beam.io.textio.WriteToText":{expand:[39,2,1,""]},"apache_beam.io.tfrecordio":{ReadFromTFRecord:[40,1,1,""],WriteToTFRecord:[40,1,1,""]},"apache_beam.io.tfrecordio.ReadFromTFRecord":{expand:[40,2,1,""]},"apache_beam.io.tfrecordio.WriteToTFRecord":{expand:[40,2,1,""]},"apache_beam.io.utils":{CountingSource:[41,1,1,""]},"apache_beam.io.utils.CountingSource":{estimate_size:[41,2,1,""],get_range_tracker:[41,2,1,""],read:[41,2,1,""],split:[41,2,1,""]},"apache_beam.io.vcfio":{MalformedVcfRecord:[42,1,1,""],ReadFromVcf:[42,1,1,""],Variant:[42,1,1,""],VariantCall:[42,1,1,""],VariantInfo:[42,1,1,""]},"apache_beam.io.vcfio.MalformedVcfRecord":{file_name:[42,7,1,""],line:[42,7,1,""]},"apache_beam.io.vcfio.ReadFromVcf":{expand:[42,2,1,""]},"apache_beam.io.vcfio.VariantInfo":{data:[42,7,1,""],field_count:[42,7,1,""]},"apache_beam.metrics":{cells:[44,0,0,"-"],metric:[45,0,0,"-"],metricbase:[46,0,0,"-"]},"apache_beam.metrics.cells":{DistributionResult:[44,1,1,""],GaugeResult:[44,1,1,""]},"apache_beam.metrics.cells.DistributionResult":{count:[44,7,1,""],max:[44,7,1,""],mean:[44,7,1,""],min:[44,7,1,""],sum:[44,7,1,""]},"apache_beam.metrics.cells.GaugeResult":{timestamp:[44,7,1,""],value:[44,7,1,""]},"apache_beam.metrics.metric":{Metrics:[45,1,1,""],MetricsFilter:[45,1,1,""]},"apache_beam.metrics.metric.Metrics":{DelegatingCounter:[45,1,1,""],DelegatingDistribution:[45,1,1,""],DelegatingGauge:[45,1,1,""],counter:[45,4,1,""],distribution:[45,4,1,""],gauge:[45,4,1,""],get_namespace:[45,4,1,""]},"apache_beam.metrics.metric.Metrics.DelegatingCounter":{inc:[45,2,1,""]},"apache_beam.metrics.metric.Metrics.DelegatingDistribution":{update:[45,2,1,""]},"apache_beam.metrics.metric.Metrics.DelegatingGauge":{set:[45,2,1,""]},"apache_beam.metrics.metric.MetricsFilter":{names:[45,7,1,""],namespaces:[45,7,1,""],steps:[45,7,1,""],with_name:[45,2,1,""],with_names:[45,2,1,""],with_namespace:[45,2,1,""],with_namespaces:[45,2,1,""],with_step:[45,2,1,""],with_steps:[45,2,1,""]},"apache_beam.metrics.metricbase":{Counter:[46,1,1,""],Distribution:[46,1,1,""],Gauge:[46,1,1,""],Metric:[46,1,1,""],MetricName:[46,1,1,""]},"apache_beam.metrics.metricbase.Counter":{dec:[46,2,1,""],inc:[46,2,1,""]},"apache_beam.metrics.metricbase.Distribution":{update:[46,2,1,""]},"apache_beam.metrics.metricbase.Gauge":{set:[46,2,1,""]},"apache_beam.metrics.metricbase.MetricName":{from_runner_api:[46,4,1,""],to_runner_api:[46,2,1,""]},"apache_beam.options":{pipeline_options:[48,0,0,"-"],pipeline_options_validator:[49,0,0,"-"],value_provider:[50,0,0,"-"]},"apache_beam.options.pipeline_options":{DebugOptions:[48,1,1,""],DirectOptions:[48,1,1,""],GoogleCloudOptions:[48,1,1,""],HadoopFileSystemOptions:[48,1,1,""],PipelineOptions:[48,1,1,""],ProfilingOptions:[48,1,1,""],SetupOptions:[48,1,1,""],StandardOptions:[48,1,1,""],TestOptions:[48,1,1,""],TypeOptions:[48,1,1,""],WorkerOptions:[48,1,1,""]},"apache_beam.options.pipeline_options.GoogleCloudOptions":{BIGQUERY_API_SERVICE:[48,7,1,""],COMPUTE_API_SERVICE:[48,7,1,""],DATAFLOW_ENDPOINT:[48,7,1,""],STORAGE_API_SERVICE:[48,7,1,""],validate:[48,2,1,""]},"apache_beam.options.pipeline_options.HadoopFileSystemOptions":{validate:[48,2,1,""]},"apache_beam.options.pipeline_options.PipelineOptions":{display_data:[48,2,1,""],from_dictionary:[48,3,1,""],get_all_options:[48,2,1,""],view_as:[48,2,1,""]},"apache_beam.options.pipeline_options.StandardOptions":{DEFAULT_RUNNER:[48,7,1,""]},"apache_beam.options.pipeline_options.TestOptions":{validate:[48,2,1,""]},"apache_beam.options.pipeline_options.WorkerOptions":{validate:[48,2,1,""]},"apache_beam.options.pipeline_options_validator":{PipelineOptionsValidator:[49,1,1,""]},"apache_beam.options.pipeline_options_validator.PipelineOptionsValidator":{ENDPOINT_PATTERN:[49,7,1,""],ERR_INVALID_GCS_BUCKET:[49,7,1,""],ERR_INVALID_GCS_OBJECT:[49,7,1,""],ERR_INVALID_GCS_PATH:[49,7,1,""],ERR_INVALID_JOB_NAME:[49,7,1,""],ERR_INVALID_NOT_POSITIVE:[49,7,1,""],ERR_INVALID_PROJECT_ID:[49,7,1,""],ERR_INVALID_PROJECT_NUMBER:[49,7,1,""],ERR_INVALID_TEST_MATCHER_TYPE:[49,7,1,""],ERR_INVALID_TEST_MATCHER_UNPICKLABLE:[49,7,1,""],ERR_MISSING_GCS_PATH:[49,7,1,""],ERR_MISSING_OPTION:[49,7,1,""],GCS_BUCKET:[49,7,1,""],GCS_SCHEME:[49,7,1,""],GCS_URI:[49,7,1,""],JOB_PATTERN:[49,7,1,""],OPTIONS:[49,7,1,""],PROJECT_ID_PATTERN:[49,7,1,""],PROJECT_NUMBER_PATTERN:[49,7,1,""],is_full_string_match:[49,2,1,""],is_service_runner:[49,2,1,""],validate:[49,2,1,""],validate_cloud_options:[49,2,1,""],validate_gcs_path:[49,2,1,""],validate_optional_argument_positive:[49,2,1,""],validate_test_matcher:[49,2,1,""]},"apache_beam.options.value_provider":{RuntimeValueProvider:[50,1,1,""],StaticValueProvider:[50,1,1,""],ValueProvider:[50,1,1,""],check_accessible:[50,5,1,""]},"apache_beam.options.value_provider.RuntimeValueProvider":{experiments:[50,7,1,""],get:[50,2,1,""],get_value:[50,3,1,""],is_accessible:[50,2,1,""],runtime_options:[50,7,1,""],set_runtime_options:[50,3,1,""]},"apache_beam.options.value_provider.StaticValueProvider":{get:[50,2,1,""],is_accessible:[50,2,1,""]},"apache_beam.options.value_provider.ValueProvider":{get:[50,2,1,""],is_accessible:[50,2,1,""]},"apache_beam.pipeline":{PTransformOverride:[51,1,1,""],Pipeline:[51,1,1,""]},"apache_beam.pipeline.PTransformOverride":{get_replacement_transform:[51,2,1,""],matches:[51,2,1,""]},"apache_beam.pipeline.Pipeline":{apply:[51,2,1,""],from_runner_api:[51,4,1,""],options:[51,7,1,""],replace_all:[51,2,1,""],run:[51,2,1,""],to_runner_api:[51,2,1,""],visit:[51,2,1,""]},"apache_beam.portability":{api:[53,0,0,"-"],common_urns:[61,0,0,"-"],python_urns:[62,0,0,"-"]},"apache_beam.portability.api":{beam_artifact_api_pb2_grpc:[54,0,0,"-"],beam_fn_api_pb2_grpc:[55,0,0,"-"],beam_job_api_pb2_grpc:[56,0,0,"-"],beam_provision_api_pb2_grpc:[57,0,0,"-"],beam_runner_api_pb2_grpc:[58,0,0,"-"],endpoints_pb2_grpc:[59,0,0,"-"],standard_window_fns_pb2_grpc:[60,0,0,"-"]},"apache_beam.portability.api.beam_artifact_api_pb2_grpc":{ArtifactRetrievalServiceServicer:[54,1,1,""],ArtifactRetrievalServiceStub:[54,1,1,""],ArtifactStagingServiceServicer:[54,1,1,""],ArtifactStagingServiceStub:[54,1,1,""],add_ArtifactRetrievalServiceServicer_to_server:[54,5,1,""],add_ArtifactStagingServiceServicer_to_server:[54,5,1,""]},"apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactRetrievalServiceServicer":{GetArtifact:[54,2,1,""],GetManifest:[54,2,1,""]},"apache_beam.portability.api.beam_artifact_api_pb2_grpc.ArtifactStagingServiceServicer":{CommitManifest:[54,2,1,""],PutArtifact:[54,2,1,""]},"apache_beam.portability.api.beam_fn_api_pb2_grpc":{BeamFnControlServicer:[55,1,1,""],BeamFnControlStub:[55,1,1,""],BeamFnDataServicer:[55,1,1,""],BeamFnDataStub:[55,1,1,""],BeamFnLoggingServicer:[55,1,1,""],BeamFnLoggingStub:[55,1,1,""],BeamFnStateServicer:[55,1,1,""],BeamFnStateStub:[55,1,1,""],add_BeamFnControlServicer_to_server:[55,5,1,""],add_BeamFnDataServicer_to_server:[55,5,1,""],add_BeamFnLoggingServicer_to_server:[55,5,1,""],add_BeamFnStateServicer_to_server:[55,5,1,""]},"apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnControlServicer":{Control:[55,2,1,""]},"apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnDataServicer":{Data:[55,2,1,""]},"apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnLoggingServicer":{Logging:[55,2,1,""]},"apache_beam.portability.api.beam_fn_api_pb2_grpc.BeamFnStateServicer":{State:[55,2,1,""]},"apache_beam.portability.api.beam_job_api_pb2_grpc":{JobServiceServicer:[56,1,1,""],JobServiceStub:[56,1,1,""],add_JobServiceServicer_to_server:[56,5,1,""]},"apache_beam.portability.api.beam_job_api_pb2_grpc.JobServiceServicer":{Cancel:[56,2,1,""],GetMessageStream:[56,2,1,""],GetState:[56,2,1,""],GetStateStream:[56,2,1,""],Prepare:[56,2,1,""],Run:[56,2,1,""]},"apache_beam.portability.api.beam_provision_api_pb2_grpc":{ProvisionServiceServicer:[57,1,1,""],ProvisionServiceStub:[57,1,1,""],add_ProvisionServiceServicer_to_server:[57,5,1,""]},"apache_beam.portability.api.beam_provision_api_pb2_grpc.ProvisionServiceServicer":{GetProvisionInfo:[57,2,1,""]},"apache_beam.portability.common_urns":{PropertiesFromEnumType:[61,1,1,""],PropertiesFromEnumValue:[61,1,1,""],PropertiesFromPayloadType:[61,5,1,""]},"apache_beam.pvalue":{AsDict:[63,1,1,""],AsIter:[63,1,1,""],AsList:[63,1,1,""],AsSingleton:[63,1,1,""],EmptySideInput:[63,1,1,""],PCollection:[63,1,1,""],TaggedOutput:[63,1,1,""]},"apache_beam.pvalue.AsIter":{element_type:[63,7,1,""]},"apache_beam.pvalue.AsSingleton":{element_type:[63,7,1,""]},"apache_beam.pvalue.PCollection":{from_runner_api:[63,4,1,""],to_runner_api:[63,2,1,""],windowing:[63,7,1,""]},"apache_beam.runners":{dataflow:[65,0,0,"-"],direct:[73,0,0,"-"],interactive:[86,0,0,"-"],job:[91,0,0,"-"],pipeline_context:[94,0,0,"-"],runner:[95,0,0,"-"],sdf_common:[96,0,0,"-"]},"apache_beam.runners.dataflow":{dataflow_metrics:[66,0,0,"-"],dataflow_runner:[67,0,0,"-"],native_io:[68,0,0,"-"],ptransform_overrides:[71,0,0,"-"],test_dataflow_runner:[72,0,0,"-"]},"apache_beam.runners.dataflow.dataflow_metrics":{DataflowMetrics:[66,1,1,""]},"apache_beam.runners.dataflow.dataflow_metrics.DataflowMetrics":{query:[66,2,1,""]},"apache_beam.runners.dataflow.dataflow_runner":{DataflowRunner:[67,1,1,""]},"apache_beam.runners.dataflow.dataflow_runner.DataflowRunner":{CreatePTransformOverride:[67,1,1,""],apply_CombineValues:[67,2,1,""],apply_GroupByKey:[67,2,1,""],apply_Read:[67,2,1,""],apply_WriteToBigQuery:[67,2,1,""],byte_array_to_json_string:[67,4,1,""],deserialize_windowing_strategy:[67,3,1,""],flatten_input_visitor:[67,4,1,""],group_by_key_input_visitor:[67,4,1,""],json_string_to_byte_array:[67,4,1,""],poll_for_job_completion:[67,4,1,""],run_CombineValues:[67,2,1,""],run_Flatten:[67,2,1,""],run_GroupByKey:[67,2,1,""],run_Impulse:[67,2,1,""],run_ParDo:[67,2,1,""],run_Read:[67,2,1,""],run__NativeWrite:[67,2,1,""],run_pipeline:[67,2,1,""],serialize_windowing_strategy:[67,3,1,""],side_input_visitor:[67,4,1,""]},"apache_beam.runners.dataflow.dataflow_runner.DataflowRunner.CreatePTransformOverride":{get_replacement_transform:[67,2,1,""],matches:[67,2,1,""]},"apache_beam.runners.dataflow.native_io":{iobase:[69,0,0,"-"],streaming_create:[70,0,0,"-"]},"apache_beam.runners.dataflow.native_io.iobase":{ConcatPosition:[69,1,1,""],DynamicSplitRequest:[69,1,1,""],DynamicSplitResult:[69,1,1,""],DynamicSplitResultWithPosition:[69,1,1,""],NativeSink:[69,1,1,""],NativeSinkWriter:[69,1,1,""],NativeSource:[69,1,1,""],NativeSourceReader:[69,1,1,""],ReaderPosition:[69,1,1,""],ReaderProgress:[69,1,1,""]},"apache_beam.runners.dataflow.native_io.iobase.NativeSink":{writer:[69,2,1,""]},"apache_beam.runners.dataflow.native_io.iobase.NativeSinkWriter":{Write:[69,2,1,""],takes_windowed_values:[69,7,1,""]},"apache_beam.runners.dataflow.native_io.iobase.NativeSource":{is_bounded:[69,2,1,""],reader:[69,2,1,""]},"apache_beam.runners.dataflow.native_io.iobase.NativeSourceReader":{get_progress:[69,2,1,""],request_dynamic_split:[69,2,1,""],returns_windowed_values:[69,7,1,""]},"apache_beam.runners.dataflow.native_io.iobase.ReaderProgress":{consumed_split_points:[69,7,1,""],percent_complete:[69,7,1,""],position:[69,7,1,""],remaining_split_points:[69,7,1,""],remaining_time:[69,7,1,""]},"apache_beam.runners.dataflow.native_io.streaming_create":{StreamingCreate:[70,1,1,""]},"apache_beam.runners.dataflow.native_io.streaming_create.StreamingCreate":{DecodeAndEmitDoFn:[70,1,1,""],Impulse:[70,1,1,""],expand:[70,2,1,""]},"apache_beam.runners.dataflow.native_io.streaming_create.StreamingCreate.DecodeAndEmitDoFn":{process:[70,2,1,""]},"apache_beam.runners.dataflow.native_io.streaming_create.StreamingCreate.Impulse":{expand:[70,2,1,""],get_windowing:[70,2,1,""],infer_output_type:[70,2,1,""]},"apache_beam.runners.dataflow.ptransform_overrides":{CreatePTransformOverride:[71,1,1,""]},"apache_beam.runners.dataflow.ptransform_overrides.CreatePTransformOverride":{get_replacement_transform:[71,2,1,""],matches:[71,2,1,""]},"apache_beam.runners.dataflow.test_dataflow_runner":{TestDataflowRunner:[72,1,1,""]},"apache_beam.runners.dataflow.test_dataflow_runner.TestDataflowRunner":{build_console_url:[72,2,1,""],run_pipeline:[72,2,1,""],wait_until_in_state:[72,2,1,""]},"apache_beam.runners.direct":{bundle_factory:[74,0,0,"-"],clock:[75,0,0,"-"],consumer_tracking_pipeline_visitor:[76,0,0,"-"],direct_metrics:[77,0,0,"-"],direct_runner:[78,0,0,"-"],evaluation_context:[79,0,0,"-"],executor:[80,0,0,"-"],helper_transforms:[81,0,0,"-"],sdf_direct_runner:[82,0,0,"-"],transform_evaluator:[83,0,0,"-"],util:[84,0,0,"-"],watermark_manager:[85,0,0,"-"]},"apache_beam.runners.direct.bundle_factory":{BundleFactory:[74,1,1,""]},"apache_beam.runners.direct.bundle_factory.BundleFactory":{create_bundle:[74,2,1,""],create_empty_committed_bundle:[74,2,1,""]},"apache_beam.runners.direct.clock":{Clock:[75,1,1,""],RealClock:[75,1,1,""],TestClock:[75,1,1,""]},"apache_beam.runners.direct.clock.Clock":{advance_time:[75,2,1,""],time:[75,2,1,""]},"apache_beam.runners.direct.clock.RealClock":{time:[75,2,1,""]},"apache_beam.runners.direct.clock.TestClock":{advance_time:[75,2,1,""],time:[75,2,1,""]},"apache_beam.runners.direct.consumer_tracking_pipeline_visitor":{ConsumerTrackingPipelineVisitor:[76,1,1,""]},"apache_beam.runners.direct.consumer_tracking_pipeline_visitor.ConsumerTrackingPipelineVisitor":{visit_transform:[76,2,1,""]},"apache_beam.runners.direct.direct_metrics":{DirectMetric:[77,1,1,""],DirectMetrics:[77,1,1,""]},"apache_beam.runners.direct.direct_metrics.DirectMetric":{commit_logical:[77,2,1,""],commit_physical:[77,2,1,""],extract_committed:[77,2,1,""],extract_latest_attempted:[77,2,1,""],update_physical:[77,2,1,""]},"apache_beam.runners.direct.direct_metrics.DirectMetrics":{commit_logical:[77,2,1,""],commit_physical:[77,2,1,""],query:[77,2,1,""],update_physical:[77,2,1,""]},"apache_beam.runners.direct.direct_runner":{BundleBasedDirectRunner:[78,1,1,""],DirectRunner:[78,7,1,""],SwitchingDirectRunner:[78,1,1,""]},"apache_beam.runners.direct.direct_runner.BundleBasedDirectRunner":{run_pipeline:[78,2,1,""]},"apache_beam.runners.direct.direct_runner.SwitchingDirectRunner":{run_pipeline:[78,2,1,""]},"apache_beam.runners.direct.evaluation_context":{DirectStepContext:[79,1,1,""],DirectUnmergedState:[79,1,1,""],EvaluationContext:[79,1,1,""]},"apache_beam.runners.direct.evaluation_context.DirectStepContext":{get_keyed_state:[79,2,1,""]},"apache_beam.runners.direct.evaluation_context.EvaluationContext":{create_bundle:[79,2,1,""],create_empty_committed_bundle:[79,2,1,""],extract_all_timers:[79,2,1,""],get_aggregator_values:[79,2,1,""],get_execution_context:[79,2,1,""],get_value_or_block_until_ready:[79,2,1,""],handle_result:[79,2,1,""],is_done:[79,2,1,""],is_root_transform:[79,2,1,""],metrics:[79,2,1,""],schedule_pending_unblocked_tasks:[79,2,1,""]},"apache_beam.runners.direct.executor":{Executor:[80,1,1,""],TransformExecutor:[80,1,1,""]},"apache_beam.runners.direct.executor.Executor":{await_completion:[80,2,1,""],shutdown:[80,2,1,""],start:[80,2,1,""]},"apache_beam.runners.direct.executor.TransformExecutor":{attempt_call:[80,2,1,""],call:[80,2,1,""]},"apache_beam.runners.direct.helper_transforms":{FinishCombine:[81,1,1,""],LiftedCombinePerKey:[81,1,1,""],PartialGroupByKeyCombiningValues:[81,1,1,""]},"apache_beam.runners.direct.helper_transforms.FinishCombine":{default_type_hints:[81,2,1,""],process:[81,2,1,""]},"apache_beam.runners.direct.helper_transforms.LiftedCombinePerKey":{expand:[81,2,1,""]},"apache_beam.runners.direct.helper_transforms.PartialGroupByKeyCombiningValues":{default_type_hints:[81,2,1,""],finish_bundle:[81,2,1,""],process:[81,2,1,""],start_bundle:[81,2,1,""]},"apache_beam.runners.direct.sdf_direct_runner":{ProcessElements:[82,1,1,""],ProcessFn:[82,1,1,""],ProcessKeyedElementsViaKeyedWorkItems:[82,1,1,""],ProcessKeyedElementsViaKeyedWorkItemsOverride:[82,1,1,""],SDFProcessElementInvoker:[82,1,1,""]},"apache_beam.runners.direct.sdf_direct_runner.ProcessElements":{expand:[82,2,1,""],new_process_fn:[82,2,1,""]},"apache_beam.runners.direct.sdf_direct_runner.ProcessFn":{process:[82,2,1,""],set_process_element_invoker:[82,2,1,""],step_context:[82,7,1,""]},"apache_beam.runners.direct.sdf_direct_runner.ProcessKeyedElementsViaKeyedWorkItems":{expand:[82,2,1,""]},"apache_beam.runners.direct.sdf_direct_runner.ProcessKeyedElementsViaKeyedWorkItemsOverride":{get_replacement_transform:[82,2,1,""],matches:[82,2,1,""]},"apache_beam.runners.direct.sdf_direct_runner.SDFProcessElementInvoker":{Result:[82,1,1,""],invoke_process_element:[82,2,1,""],test_method:[82,2,1,""]},"apache_beam.runners.direct.transform_evaluator":{DefaultRootBundleProvider:[83,1,1,""],RootBundleProvider:[83,1,1,""],TransformEvaluatorRegistry:[83,1,1,""]},"apache_beam.runners.direct.transform_evaluator.DefaultRootBundleProvider":{get_root_bundles:[83,2,1,""]},"apache_beam.runners.direct.transform_evaluator.RootBundleProvider":{get_root_bundles:[83,2,1,""]},"apache_beam.runners.direct.transform_evaluator.TransformEvaluatorRegistry":{get_evaluator:[83,2,1,""],get_root_bundle_provider:[83,2,1,""],should_execute_serially:[83,2,1,""]},"apache_beam.runners.direct.util":{KeyedWorkItem:[84,1,1,""],TimerFiring:[84,1,1,""],TransformResult:[84,1,1,""]},"apache_beam.runners.direct.watermark_manager":{WatermarkManager:[85,1,1,""]},"apache_beam.runners.direct.watermark_manager.WatermarkManager":{WATERMARK_NEG_INF:[85,7,1,""],WATERMARK_POS_INF:[85,7,1,""],extract_all_timers:[85,2,1,""],get_watermarks:[85,2,1,""],update_watermarks:[85,2,1,""]},"apache_beam.runners.interactive":{display_manager:[87,0,0,"-"],interactive_pipeline_graph:[88,0,0,"-"],interactive_runner:[89,0,0,"-"],pipeline_graph:[90,0,0,"-"]},"apache_beam.runners.interactive.display_manager":{DisplayManager:[87,1,1,""]},"apache_beam.runners.interactive.display_manager.DisplayManager":{start_periodic_update:[87,2,1,""],stop_periodic_update:[87,2,1,""],update_display:[87,2,1,""]},"apache_beam.runners.interactive.interactive_pipeline_graph":{InteractivePipelineGraph:[88,1,1,""],format_sample:[88,5,1,""],nice_str:[88,5,1,""]},"apache_beam.runners.interactive.interactive_pipeline_graph.InteractivePipelineGraph":{display_graph:[88,2,1,""]},"apache_beam.runners.interactive.interactive_runner":{CacheManager:[89,1,1,""],Derivation:[89,1,1,""],InteractiveRunner:[89,1,1,""],PipelineInfo:[89,1,1,""],PipelineResult:[89,1,1,""],ReadCache:[89,1,1,""],SafeFastPrimitivesCoder:[89,1,1,""],WriteCache:[89,1,1,""],set_proto_map:[89,5,1,""]},"apache_beam.runners.interactive.interactive_runner.CacheManager":{cleanup:[89,2,1,""],exists:[89,2,1,""],glob_path:[89,2,1,""],path:[89,2,1,""],read:[89,2,1,""]},"apache_beam.runners.interactive.interactive_runner.Derivation":{cache_label:[89,2,1,""],json:[89,2,1,""]},"apache_beam.runners.interactive.interactive_runner.InteractiveRunner":{apply:[89,2,1,""],cleanup:[89,2,1,""],run_pipeline:[89,2,1,""]},"apache_beam.runners.interactive.interactive_runner.PipelineInfo":{all_pcollections:[89,2,1,""],derivation:[89,2,1,""],leaf_pcollections:[89,2,1,""],producer:[89,2,1,""]},"apache_beam.runners.interactive.interactive_runner.PipelineResult":{get:[89,2,1,""],sample:[89,2,1,""],wait_until_finish:[89,2,1,""]},"apache_beam.runners.interactive.interactive_runner.ReadCache":{expand:[89,2,1,""]},"apache_beam.runners.interactive.interactive_runner.SafeFastPrimitivesCoder":{decode:[89,2,1,""],encode:[89,2,1,""]},"apache_beam.runners.interactive.interactive_runner.WriteCache":{expand:[89,2,1,""]},"apache_beam.runners.interactive.pipeline_graph":{PipelineGraph:[90,1,1,""]},"apache_beam.runners.interactive.pipeline_graph.PipelineGraph":{get_dot:[90,2,1,""]},"apache_beam.runners.job":{manager:[92,0,0,"-"],utils:[93,0,0,"-"]},"apache_beam.runners.job.manager":{DockerRPCManager:[92,1,1,""]},"apache_beam.runners.job.utils":{dict_to_struct:[93,5,1,""],struct_to_dict:[93,5,1,""]},"apache_beam.runners.pipeline_context":{Environment:[94,1,1,""],PipelineContext:[94,1,1,""]},"apache_beam.runners.pipeline_context.Environment":{from_runner_api:[94,4,1,""],to_runner_api:[94,2,1,""]},"apache_beam.runners.pipeline_context.PipelineContext":{default_environment_id:[94,2,1,""],from_runner_api:[94,4,1,""],to_runner_api:[94,2,1,""]},"apache_beam.runners.runner":{PipelineResult:[95,1,1,""],PipelineRunner:[95,1,1,""],PipelineState:[95,1,1,""]},"apache_beam.runners.runner.PipelineResult":{aggregated_values:[95,2,1,""],cancel:[95,2,1,""],metrics:[95,2,1,""],state:[95,7,1,""],wait_until_finish:[95,2,1,""]},"apache_beam.runners.runner.PipelineRunner":{apply:[95,2,1,""],apply_PTransform:[95,2,1,""],run:[95,2,1,""],run_async:[95,2,1,""],run_pipeline:[95,2,1,""],run_transform:[95,2,1,""]},"apache_beam.runners.runner.PipelineState":{CANCELLED:[95,7,1,""],CANCELLING:[95,7,1,""],DONE:[95,7,1,""],DRAINED:[95,7,1,""],DRAINING:[95,7,1,""],FAILED:[95,7,1,""],PENDING:[95,7,1,""],RUNNING:[95,7,1,""],STARTING:[95,7,1,""],STOPPED:[95,7,1,""],UNKNOWN:[95,7,1,""],UPDATED:[95,7,1,""]},"apache_beam.runners.sdf_common":{ElementAndRestriction:[96,1,1,""],ExplodeWindowsFn:[96,1,1,""],PairWithRestrictionFn:[96,1,1,""],ProcessKeyedElements:[96,1,1,""],RandomUniqueKeyFn:[96,1,1,""],SplitRestrictionFn:[96,1,1,""],SplittableParDo:[96,1,1,""],SplittableParDoOverride:[96,1,1,""]},"apache_beam.runners.sdf_common.ExplodeWindowsFn":{process:[96,2,1,""]},"apache_beam.runners.sdf_common.PairWithRestrictionFn":{process:[96,2,1,""],start_bundle:[96,2,1,""]},"apache_beam.runners.sdf_common.ProcessKeyedElements":{expand:[96,2,1,""]},"apache_beam.runners.sdf_common.RandomUniqueKeyFn":{process:[96,2,1,""]},"apache_beam.runners.sdf_common.SplitRestrictionFn":{process:[96,2,1,""],start_bundle:[96,2,1,""]},"apache_beam.runners.sdf_common.SplittableParDo":{expand:[96,2,1,""]},"apache_beam.runners.sdf_common.SplittableParDoOverride":{get_replacement_transform:[96,2,1,""],matches:[96,2,1,""]},"apache_beam.testing":{benchmarks:[98,0,0,"-"],pipeline_verifiers:[108,0,0,"-"],synthetic_pipeline:[109,0,0,"-"],test_pipeline:[110,0,0,"-"],test_stream:[111,0,0,"-"],test_utils:[112,0,0,"-"],util:[113,0,0,"-"]},"apache_beam.testing.benchmarks":{nexmark:[99,0,0,"-"]},"apache_beam.testing.benchmarks.nexmark":{models:[100,0,0,"-"],nexmark_launcher:[102,0,0,"-"],nexmark_util:[103,0,0,"-"],queries:[104,0,0,"-"]},"apache_beam.testing.benchmarks.nexmark.models":{nexmark_model:[101,0,0,"-"]},"apache_beam.testing.benchmarks.nexmark.models.nexmark_model":{Auction:[101,1,1,""],Bid:[101,1,1,""],Person:[101,1,1,""]},"apache_beam.testing.benchmarks.nexmark.nexmark_launcher":{NexmarkLauncher:[102,1,1,""]},"apache_beam.testing.benchmarks.nexmark.nexmark_launcher.NexmarkLauncher":{cleanup:[102,2,1,""],generate_events:[102,2,1,""],parse_args:[102,2,1,""],run:[102,2,1,""],run_query:[102,2,1,""]},"apache_beam.testing.benchmarks.nexmark.nexmark_util":{Command:[103,1,1,""],ParseEventFn:[103,1,1,""],display:[103,5,1,""]},"apache_beam.testing.benchmarks.nexmark.nexmark_util.Command":{run:[103,2,1,""]},"apache_beam.testing.benchmarks.nexmark.nexmark_util.ParseEventFn":{process:[103,2,1,""]},"apache_beam.testing.benchmarks.nexmark.queries":{query0:[105,0,0,"-"],query1:[106,0,0,"-"],query2:[107,0,0,"-"]},"apache_beam.testing.benchmarks.nexmark.queries.query0":{load:[105,5,1,""]},"apache_beam.testing.benchmarks.nexmark.queries.query1":{load:[106,5,1,""]},"apache_beam.testing.benchmarks.nexmark.queries.query2":{load:[107,5,1,""]},"apache_beam.testing.pipeline_verifiers":{FileChecksumMatcher:[108,1,1,""],PipelineStateMatcher:[108,1,1,""],retry_on_io_error_and_server_error:[108,5,1,""]},"apache_beam.testing.pipeline_verifiers.FileChecksumMatcher":{describe_mismatch:[108,2,1,""],describe_to:[108,2,1,""]},"apache_beam.testing.pipeline_verifiers.PipelineStateMatcher":{describe_mismatch:[108,2,1,""],describe_to:[108,2,1,""]},"apache_beam.testing.synthetic_pipeline":{ShuffleBarrier:[109,1,1,""],SideInputBarrier:[109,1,1,""],SyntheticSource:[109,1,1,""],SyntheticStep:[109,1,1,""],div_round_up:[109,5,1,""],expand_using_gbk:[109,5,1,""],expand_using_second_output:[109,5,1,""],merge_using_gbk:[109,5,1,""],merge_using_side_input:[109,5,1,""],parse_args:[109,5,1,""],parse_byte_size:[109,5,1,""],rotate_key:[109,5,1,""],run:[109,5,1,""]},"apache_beam.testing.synthetic_pipeline.ShuffleBarrier":{expand:[109,2,1,""]},"apache_beam.testing.synthetic_pipeline.SideInputBarrier":{expand:[109,2,1,""]},"apache_beam.testing.synthetic_pipeline.SyntheticSource":{default_output_coder:[109,2,1,""],element_size:[109,7,1,""],estimate_size:[109,2,1,""],get_range_tracker:[109,2,1,""],read:[109,2,1,""],split:[109,2,1,""]},"apache_beam.testing.synthetic_pipeline.SyntheticStep":{finish_bundle:[109,2,1,""],process:[109,2,1,""],start_bundle:[109,2,1,""]},"apache_beam.testing.test_pipeline":{TestPipeline:[110,1,1,""]},"apache_beam.testing.test_pipeline.TestPipeline":{get_full_options_as_args:[110,2,1,""],get_option:[110,2,1,""],run:[110,2,1,""]},"apache_beam.testing.test_stream":{ElementEvent:[111,1,1,""],Event:[111,1,1,""],ProcessingTimeEvent:[111,1,1,""],TestStream:[111,1,1,""],WatermarkEvent:[111,1,1,""]},"apache_beam.testing.test_stream.TestStream":{add_elements:[111,2,1,""],advance_processing_time:[111,2,1,""],advance_watermark_to:[111,2,1,""],advance_watermark_to_infinity:[111,2,1,""],expand:[111,2,1,""],get_windowing:[111,2,1,""]},"apache_beam.testing.test_utils":{TempDir:[112,1,1,""],cleanup_subscriptions:[112,5,1,""],cleanup_topics:[112,5,1,""],compute_hash:[112,5,1,""],patch_retry:[112,5,1,""],wait_for_subscriptions_created:[112,5,1,""],wait_for_topics_created:[112,5,1,""]},"apache_beam.testing.test_utils.TempDir":{create_temp_file:[112,2,1,""],get_path:[112,2,1,""]},"apache_beam.testing.util":{TestWindowedValue:[113,1,1,""],assert_that:[113,5,1,""],equal_to:[113,5,1,""],is_empty:[113,5,1,""],open_shards:[113,5,1,""]},"apache_beam.testing.util.TestWindowedValue":{timestamp:[113,7,1,""],value:[113,7,1,""],windows:[113,7,1,""]},"apache_beam.tools":{coders_microbenchmark:[115,0,0,"-"],distribution_counter_microbenchmark:[116,0,0,"-"],sideinput_microbenchmark:[117,0,0,"-"],utils:[118,0,0,"-"]},"apache_beam.tools.coders_microbenchmark":{coder_benchmark_factory:[115,5,1,""],dict_int_int:[115,5,1,""],large_dict:[115,5,1,""],large_int:[115,5,1,""],large_list:[115,5,1,""],large_string:[115,5,1,""],large_tuple:[115,5,1,""],list_int:[115,5,1,""],random_string:[115,5,1,""],random_windowed_value:[115,5,1,""],run_coder_benchmarks:[115,5,1,""],small_dict:[115,5,1,""],small_int:[115,5,1,""],small_list:[115,5,1,""],small_string:[115,5,1,""],small_tuple:[115,5,1,""],wv_with_multiple_windows:[115,5,1,""],wv_with_one_window:[115,5,1,""]},"apache_beam.tools.distribution_counter_microbenchmark":{generate_input_values:[116,5,1,""],run_benchmark:[116,5,1,""]},"apache_beam.tools.sideinput_microbenchmark":{long_generator:[117,5,1,""],run_benchmark:[117,5,1,""]},"apache_beam.tools.utils":{BenchmarkConfig:[118,1,1,""],check_compiled:[118,5,1,""],run_benchmarks:[118,5,1,""]},"apache_beam.tools.utils.BenchmarkConfig":{benchmark:[118,7,1,""],num_runs:[118,7,1,""],size:[118,7,1,""]},"apache_beam.transforms":{combiners:[120,0,0,"-"],core:[121,0,0,"-"],create_source:[122,0,0,"-"],display:[123,0,0,"-"],ptransform:[124,0,0,"-"],sideinputs:[125,0,0,"-"],timeutil:[126,0,0,"-"],trigger:[127,0,0,"-"],userstate:[128,0,0,"-"],util:[129,0,0,"-"],window:[130,0,0,"-"]},"apache_beam.transforms.combiners":{Count:[120,1,1,""],Mean:[120,1,1,""],Sample:[120,1,1,""],ToDict:[120,1,1,""],ToList:[120,1,1,""],Top:[120,1,1,""]},"apache_beam.transforms.combiners.Count":{Globally:[120,1,1,""],PerElement:[120,1,1,""],PerKey:[120,1,1,""]},"apache_beam.transforms.combiners.Count.Globally":{expand:[120,2,1,""]},"apache_beam.transforms.combiners.Count.PerElement":{expand:[120,2,1,""]},"apache_beam.transforms.combiners.Count.PerKey":{expand:[120,2,1,""]},"apache_beam.transforms.combiners.Mean":{Globally:[120,1,1,""],PerKey:[120,1,1,""]},"apache_beam.transforms.combiners.Mean.Globally":{expand:[120,2,1,""]},"apache_beam.transforms.combiners.Mean.PerKey":{expand:[120,2,1,""]},"apache_beam.transforms.combiners.Sample":{FixedSizeGlobally:[120,4,1,""],FixedSizePerKey:[120,4,1,""]},"apache_beam.transforms.combiners.ToDict":{expand:[120,2,1,""]},"apache_beam.transforms.combiners.ToList":{expand:[120,2,1,""]},"apache_beam.transforms.combiners.Top":{Largest:[120,4,1,""],LargestPerKey:[120,4,1,""],Of:[120,4,1,""],PerKey:[120,4,1,""],Smallest:[120,4,1,""],SmallestPerKey:[120,4,1,""]},"apache_beam.transforms.core":{CombineFn:[121,1,1,""],CombineGlobally:[121,1,1,""],CombinePerKey:[121,1,1,""],CombineValues:[121,1,1,""],Create:[121,1,1,""],DoFn:[121,1,1,""],Filter:[121,5,1,""],FlatMap:[121,5,1,""],Flatten:[121,1,1,""],GroupByKey:[121,1,1,""],Impulse:[121,1,1,""],Map:[121,5,1,""],ParDo:[121,1,1,""],Partition:[121,1,1,""],PartitionFn:[121,1,1,""],WindowInto:[121,1,1,""],Windowing:[121,1,1,""]},"apache_beam.transforms.core.CombineFn":{add_input:[121,2,1,""],add_inputs:[121,2,1,""],apply:[121,2,1,""],create_accumulator:[121,2,1,""],default_label:[121,2,1,""],extract_output:[121,2,1,""],for_input_type:[121,2,1,""],from_callable:[121,4,1,""],get_accumulator_coder:[121,2,1,""],maybe_from_callable:[121,4,1,""],merge_accumulators:[121,2,1,""],to_runner_api_parameter:[121,2,1,""]},"apache_beam.transforms.core.CombineGlobally":{as_singleton_view:[121,2,1,""],as_view:[121,7,1,""],default_label:[121,2,1,""],display_data:[121,2,1,""],expand:[121,2,1,""],fanout:[121,7,1,""],has_defaults:[121,7,1,""],with_defaults:[121,2,1,""],with_fanout:[121,2,1,""],without_defaults:[121,2,1,""]},"apache_beam.transforms.core.CombinePerKey":{default_label:[121,2,1,""],default_type_hints:[121,2,1,""],display_data:[121,2,1,""],expand:[121,2,1,""],from_runner_api_parameter:[121,4,1,""],make_fn:[121,2,1,""],to_runner_api_parameter:[121,2,1,""],with_hot_key_fanout:[121,2,1,""]},"apache_beam.transforms.core.CombineValues":{expand:[121,2,1,""],from_runner_api_parameter:[121,4,1,""],make_fn:[121,2,1,""],to_runner_api_parameter:[121,2,1,""]},"apache_beam.transforms.core.Create":{expand:[121,2,1,""],get_output_type:[121,2,1,""],get_windowing:[121,2,1,""],infer_output_type:[121,2,1,""],to_runner_api_parameter:[121,2,1,""]},"apache_beam.transforms.core.DoFn":{DoFnProcessParams:[121,7,1,""],ElementParam:[121,7,1,""],SideInputParam:[121,7,1,""],StateParam:[121,7,1,""],TimerParam:[121,7,1,""],TimestampParam:[121,7,1,""],WatermarkReporterParam:[121,7,1,""],WindowParam:[121,7,1,""],default_label:[121,2,1,""],finish_bundle:[121,2,1,""],from_callable:[121,4,1,""],get_function_arguments:[121,2,1,""],infer_output_type:[121,2,1,""],is_process_bounded:[121,2,1,""],process:[121,2,1,""],start_bundle:[121,2,1,""],to_runner_api_parameter:[121,2,1,""]},"apache_beam.transforms.core.Flatten":{expand:[121,2,1,""],from_runner_api_parameter:[121,4,1,""],get_windowing:[121,2,1,""],to_runner_api_parameter:[121,2,1,""]},"apache_beam.transforms.core.GroupByKey":{ReifyWindows:[121,1,1,""],expand:[121,2,1,""],from_runner_api_parameter:[121,4,1,""],to_runner_api_parameter:[121,2,1,""]},"apache_beam.transforms.core.GroupByKey.ReifyWindows":{infer_output_type:[121,2,1,""],process:[121,2,1,""]},"apache_beam.transforms.core.Impulse":{expand:[121,2,1,""],from_runner_api_parameter:[121,4,1,""],get_windowing:[121,2,1,""],infer_output_type:[121,2,1,""],to_runner_api_parameter:[121,2,1,""]},"apache_beam.transforms.core.ParDo":{default_type_hints:[121,2,1,""],display_data:[121,2,1,""],expand:[121,2,1,""],from_runner_api_parameter:[121,4,1,""],infer_output_type:[121,2,1,""],make_fn:[121,2,1,""],to_runner_api_parameter:[121,2,1,""],with_outputs:[121,2,1,""]},"apache_beam.transforms.core.Partition":{ApplyPartitionFnFn:[121,1,1,""],expand:[121,2,1,""],make_fn:[121,2,1,""]},"apache_beam.transforms.core.Partition.ApplyPartitionFnFn":{process:[121,2,1,""]},"apache_beam.transforms.core.PartitionFn":{default_label:[121,2,1,""],partition_for:[121,2,1,""]},"apache_beam.transforms.core.WindowInto":{WindowIntoFn:[121,1,1,""],expand:[121,2,1,""],from_runner_api_parameter:[121,4,1,""],get_windowing:[121,2,1,""],infer_output_type:[121,2,1,""],to_runner_api_parameter:[121,2,1,""]},"apache_beam.transforms.core.WindowInto.WindowIntoFn":{process:[121,2,1,""]},"apache_beam.transforms.core.Windowing":{from_runner_api:[121,4,1,""],is_default:[121,2,1,""],to_runner_api:[121,2,1,""]},"apache_beam.transforms.display":{DisplayData:[123,1,1,""],DisplayDataItem:[123,1,1,""],HasDisplayData:[123,1,1,""]},"apache_beam.transforms.display.DisplayData":{create_from:[123,3,1,""],create_from_options:[123,3,1,""]},"apache_beam.transforms.display.DisplayDataItem":{drop_if_default:[123,2,1,""],drop_if_none:[123,2,1,""],get_dict:[123,2,1,""],is_valid:[123,2,1,""],should_drop:[123,2,1,""],typeDict:[123,7,1,""]},"apache_beam.transforms.display.HasDisplayData":{display_data:[123,2,1,""]},"apache_beam.transforms.ptransform":{PTransform:[124,1,1,""],label_from_callable:[124,5,1,""],ptransform_fn:[124,5,1,""]},"apache_beam.transforms.ptransform.PTransform":{default_label:[124,2,1,""],expand:[124,2,1,""],from_runner_api:[124,3,1,""],get_windowing:[124,2,1,""],infer_output_type:[124,2,1,""],label:[124,7,1,""],pipeline:[124,7,1,""],register_urn:[124,3,1,""],side_inputs:[124,7,1,""],to_runner_api:[124,2,1,""],to_runner_api_parameter:[124,2,1,""],to_runner_api_pickled:[124,2,1,""],type_check_inputs:[124,2,1,""],type_check_inputs_or_outputs:[124,2,1,""],type_check_outputs:[124,2,1,""],with_input_types:[124,2,1,""],with_output_types:[124,2,1,""]},"apache_beam.transforms.sideinputs":{SideInputMap:[125,1,1,""],default_window_mapping_fn:[125,5,1,""]},"apache_beam.transforms.sideinputs.SideInputMap":{is_globally_windowed:[125,2,1,""]},"apache_beam.transforms.timeutil":{TimeDomain:[126,1,1,""]},"apache_beam.transforms.timeutil.TimeDomain":{DEPENDENT_REAL_TIME:[126,7,1,""],REAL_TIME:[126,7,1,""],WATERMARK:[126,7,1,""],from_string:[126,4,1,""]},"apache_beam.transforms.trigger":{AccumulationMode:[127,1,1,""],AfterAll:[127,1,1,""],AfterAny:[127,1,1,""],AfterCount:[127,1,1,""],AfterEach:[127,1,1,""],AfterProcessingTime:[127,1,1,""],AfterWatermark:[127,1,1,""],DefaultTrigger:[127,1,1,""],OrFinally:[127,1,1,""],Repeatedly:[127,1,1,""],TriggerFn:[127,1,1,""]},"apache_beam.transforms.trigger.AccumulationMode":{ACCUMULATING:[127,7,1,""],DISCARDING:[127,7,1,""]},"apache_beam.transforms.trigger.AfterAll":{combine_op:[127,2,1,""]},"apache_beam.transforms.trigger.AfterAny":{combine_op:[127,2,1,""]},"apache_beam.transforms.trigger.AfterCount":{COUNT_TAG:[127,7,1,""],from_runner_api:[127,4,1,""],on_element:[127,2,1,""],on_fire:[127,2,1,""],on_merge:[127,2,1,""],reset:[127,2,1,""],should_fire:[127,2,1,""],to_runner_api:[127,2,1,""]},"apache_beam.transforms.trigger.AfterEach":{INDEX_TAG:[127,7,1,""],from_runner_api:[127,4,1,""],on_element:[127,2,1,""],on_fire:[127,2,1,""],on_merge:[127,2,1,""],reset:[127,2,1,""],should_fire:[127,2,1,""],to_runner_api:[127,2,1,""]},"apache_beam.transforms.trigger.AfterProcessingTime":{from_runner_api:[127,4,1,""],on_element:[127,2,1,""],on_fire:[127,2,1,""],on_merge:[127,2,1,""],reset:[127,2,1,""],should_fire:[127,2,1,""],to_runner_api:[127,2,1,""]},"apache_beam.transforms.trigger.AfterWatermark":{LATE_TAG:[127,7,1,""],from_runner_api:[127,4,1,""],is_late:[127,2,1,""],on_element:[127,2,1,""],on_fire:[127,2,1,""],on_merge:[127,2,1,""],reset:[127,2,1,""],should_fire:[127,2,1,""],to_runner_api:[127,2,1,""]},"apache_beam.transforms.trigger.DefaultTrigger":{from_runner_api:[127,4,1,""],on_element:[127,2,1,""],on_fire:[127,2,1,""],on_merge:[127,2,1,""],reset:[127,2,1,""],should_fire:[127,2,1,""],to_runner_api:[127,2,1,""]},"apache_beam.transforms.trigger.OrFinally":{from_runner_api:[127,4,1,""],to_runner_api:[127,2,1,""]},"apache_beam.transforms.trigger.Repeatedly":{from_runner_api:[127,4,1,""],on_element:[127,2,1,""],on_fire:[127,2,1,""],on_merge:[127,2,1,""],reset:[127,2,1,""],should_fire:[127,2,1,""],to_runner_api:[127,2,1,""]},"apache_beam.transforms.trigger.TriggerFn":{from_runner_api:[127,4,1,""],on_element:[127,2,1,""],on_fire:[127,2,1,""],on_merge:[127,2,1,""],reset:[127,2,1,""],should_fire:[127,2,1,""],to_runner_api:[127,2,1,""]},"apache_beam.transforms.userstate":{BagStateSpec:[128,1,1,""],CombiningValueStateSpec:[128,1,1,""],StateSpec:[128,1,1,""],TimerSpec:[128,1,1,""],UserStateUtils:[128,1,1,""],on_timer:[128,5,1,""]},"apache_beam.transforms.userstate.UserStateUtils":{validate_stateful_dofn:[128,4,1,""]},"apache_beam.transforms.util":{BatchElements:[129,1,1,""],CoGroupByKey:[129,1,1,""],Keys:[129,5,1,""],KvSwap:[129,5,1,""],RemoveDuplicates:[129,5,1,""],Reshuffle:[129,1,1,""],Values:[129,5,1,""]},"apache_beam.transforms.util.BatchElements":{expand:[129,2,1,""]},"apache_beam.transforms.util.CoGroupByKey":{expand:[129,2,1,""]},"apache_beam.transforms.util.Reshuffle":{expand:[129,2,1,""]},"apache_beam.transforms.window":{BoundedWindow:[130,1,1,""],FixedWindows:[130,1,1,""],GlobalWindow:[130,1,1,""],GlobalWindows:[130,1,1,""],IntervalWindow:[130,1,1,""],NonMergingWindowFn:[130,1,1,""],Sessions:[130,1,1,""],SlidingWindows:[130,1,1,""],TimestampCombiner:[130,1,1,""],TimestampedValue:[130,1,1,""],WindowFn:[130,1,1,""]},"apache_beam.transforms.window.BoundedWindow":{end:[130,7,1,""],max_timestamp:[130,2,1,""]},"apache_beam.transforms.window.FixedWindows":{assign:[130,2,1,""],from_runner_api_parameter:[130,4,1,""],get_window_coder:[130,2,1,""],offset:[130,7,1,""],size:[130,7,1,""],to_runner_api_parameter:[130,2,1,""]},"apache_beam.transforms.window.GlobalWindows":{assign:[130,2,1,""],from_runner_api_parameter:[130,4,1,""],get_window_coder:[130,2,1,""],to_runner_api_parameter:[130,2,1,""],windowed_value:[130,3,1,""]},"apache_beam.transforms.window.IntervalWindow":{end:[130,7,1,""],intersects:[130,2,1,""],start:[130,7,1,""],union:[130,2,1,""]},"apache_beam.transforms.window.NonMergingWindowFn":{is_merging:[130,2,1,""],merge:[130,2,1,""]},"apache_beam.transforms.window.Sessions":{assign:[130,2,1,""],from_runner_api_parameter:[130,4,1,""],gap_size:[130,7,1,""],get_window_coder:[130,2,1,""],merge:[130,2,1,""],to_runner_api_parameter:[130,2,1,""]},"apache_beam.transforms.window.SlidingWindows":{assign:[130,2,1,""],from_runner_api_parameter:[130,4,1,""],get_window_coder:[130,2,1,""],offset:[130,7,1,""],period:[130,7,1,""],size:[130,7,1,""],to_runner_api_parameter:[130,2,1,""]},"apache_beam.transforms.window.TimestampCombiner":{OUTPUT_AT_EARLIEST:[130,7,1,""],OUTPUT_AT_EARLIEST_TRANSFORMED:[130,7,1,""],OUTPUT_AT_EOW:[130,7,1,""],OUTPUT_AT_LATEST:[130,7,1,""],get_impl:[130,4,1,""]},"apache_beam.transforms.window.TimestampedValue":{timestamp:[130,7,1,""],value:[130,7,1,""]},"apache_beam.transforms.window.WindowFn":{AssignContext:[130,1,1,""],MergeContext:[130,1,1,""],assign:[130,2,1,""],get_transformed_output_time:[130,2,1,""],get_window_coder:[130,2,1,""],is_merging:[130,2,1,""],merge:[130,2,1,""],to_runner_api_parameter:[130,2,1,""]},"apache_beam.transforms.window.WindowFn.MergeContext":{merge:[130,2,1,""]},"apache_beam.typehints":{decorators:[132,0,0,"-"],native_type_compatibility:[133,0,0,"-"],opcodes:[134,0,0,"-"],trivial_inference:[135,0,0,"-"],typecheck:[136,0,0,"-"],typehints:[137,0,0,"-"]},"apache_beam.typehints.decorators":{TypeCheckError:[132,6,1,""],WithTypeHints:[132,1,1,""],with_input_types:[132,5,1,""],with_output_types:[132,5,1,""]},"apache_beam.typehints.decorators.WithTypeHints":{default_type_hints:[132,2,1,""],get_type_hints:[132,2,1,""],with_input_types:[132,2,1,""],with_output_types:[132,2,1,""]},"apache_beam.typehints.native_type_compatibility":{convert_to_beam_type:[133,5,1,""],convert_to_beam_types:[133,5,1,""]},"apache_beam.typehints.opcodes":{binary_add:[134,5,1,""],binary_and:[134,5,1,""],binary_divide:[134,5,1,""],binary_floor_divide:[134,5,1,""],binary_lshift:[134,5,1,""],binary_modulo:[134,5,1,""],binary_multiply:[134,5,1,""],binary_or:[134,5,1,""],binary_power:[134,5,1,""],binary_rshift:[134,5,1,""],binary_subscr:[134,5,1,""],binary_subtract:[134,5,1,""],binary_true_divide:[134,5,1,""],binary_xor:[134,5,1,""],build_class:[134,5,1,""],build_list:[134,5,1,""],build_map:[134,5,1,""],build_slice:[134,5,1,""],build_tuple:[134,5,1,""],call_function:[134,5,1,""],call_function_kw:[134,5,1,""],call_function_var:[134,5,1,""],call_function_var_wk:[134,5,1,""],compare_op:[134,5,1,""],delete_attr:[134,5,1,""],delete_fast:[134,5,1,""],delete_global:[134,5,1,""],delete_slice_0:[134,5,1,""],delete_slice_1:[134,5,1,""],delete_slice_2:[134,5,1,""],delete_slice_3:[134,5,1,""],dup_top:[134,5,1,""],dup_topx:[134,5,1,""],exec_stmt:[134,5,1,""],get_iter:[134,5,1,""],import_from:[134,5,1,""],import_name:[134,5,1,""],inpalce_or:[134,5,1,""],inplace_add:[134,5,1,""],inplace_and:[134,5,1,""],inplace_divide:[134,5,1,""],inplace_floor_divide:[134,5,1,""],inplace_lshift:[134,5,1,""],inplace_modulo:[134,5,1,""],inplace_multiply:[134,5,1,""],inplace_power:[134,5,1,""],inplace_rshift:[134,5,1,""],inplace_subtract:[134,5,1,""],inplace_true_divide:[134,5,1,""],inplace_xor:[134,5,1,""],list_append:[134,5,1,""],load_attr:[134,5,1,""],load_closure:[134,5,1,""],load_const:[134,5,1,""],load_deref:[134,5,1,""],load_fast:[134,5,1,""],load_global:[134,5,1,""],load_locals:[134,5,1,""],load_name:[134,5,1,""],make_closure:[134,5,1,""],make_function:[134,5,1,""],nop:[134,5,1,""],pop_one:[134,5,1,""],pop_three:[134,5,1,""],pop_top:[134,5,1,""],pop_two:[134,5,1,""],print_item:[134,5,1,""],print_newline:[134,5,1,""],push_value:[134,5,1,""],rot_four:[134,5,1,""],rot_n:[134,5,1,""],rot_three:[134,5,1,""],rot_two:[134,5,1,""],slice_0:[134,5,1,""],slice_1:[134,5,1,""],slice_2:[134,5,1,""],slice_3:[134,5,1,""],store_attr:[134,5,1,""],store_fast:[134,5,1,""],store_global:[134,5,1,""],store_map:[134,5,1,""],store_slice_0:[134,5,1,""],store_slice_1:[134,5,1,""],store_slice_2:[134,5,1,""],store_slice_3:[134,5,1,""],store_subscr:[134,5,1,""],symmetric_binary_op:[134,5,1,""],unary:[134,5,1,""],unary_convert:[134,5,1,""],unary_invert:[134,5,1,""],unary_negative:[134,5,1,""],unary_not:[134,5,1,""],unary_positive:[134,5,1,""],unpack_sequence:[134,5,1,""]},"apache_beam.typehints.trivial_inference":{BoundMethod:[135,1,1,""],Const:[135,1,1,""],FrameState:[135,1,1,""],TypeInferenceError:[135,6,1,""],element_type:[135,5,1,""],hashable:[135,5,1,""],infer_return_type:[135,5,1,""],infer_return_type_func:[135,5,1,""],instance_to_type:[135,5,1,""],key_value_types:[135,5,1,""],union:[135,5,1,""],union_list:[135,5,1,""]},"apache_beam.typehints.trivial_inference.Const":{unwrap:[135,4,1,""],unwrap_all:[135,4,1,""]},"apache_beam.typehints.trivial_inference.FrameState":{closure_type:[135,2,1,""],const_type:[135,2,1,""],copy:[135,2,1,""],get_global:[135,2,1,""],get_name:[135,2,1,""]},"apache_beam.typehints.typecheck":{AbstractDoFnWrapper:[136,1,1,""],OutputCheckWrapperDoFn:[136,1,1,""],TypeCheckCombineFn:[136,1,1,""],TypeCheckVisitor:[136,1,1,""],TypeCheckWrapperDoFn:[136,1,1,""]},"apache_beam.typehints.typecheck.AbstractDoFnWrapper":{finish_bundle:[136,2,1,""],is_process_bounded:[136,2,1,""],process:[136,2,1,""],start_bundle:[136,2,1,""],wrapper:[136,2,1,""]},"apache_beam.typehints.typecheck.OutputCheckWrapperDoFn":{wrapper:[136,2,1,""]},"apache_beam.typehints.typecheck.TypeCheckCombineFn":{add_input:[136,2,1,""],create_accumulator:[136,2,1,""],extract_output:[136,2,1,""],merge_accumulators:[136,2,1,""]},"apache_beam.typehints.typecheck.TypeCheckVisitor":{enter_composite_transform:[136,2,1,""],leave_composite_transform:[136,2,1,""],visit_transform:[136,2,1,""]},"apache_beam.typehints.typecheck.TypeCheckWrapperDoFn":{process:[136,2,1,""],wrapper:[136,2,1,""]},"apache_beam.typehints.typehints":{TypeVariable:[137,1,1,""],WindowedValue:[137,7,1,""]},"apache_beam.typehints.typehints.TypeVariable":{bind_type_variables:[137,2,1,""],match_type_variables:[137,2,1,""]},"apache_beam.utils":{annotations:[139,0,0,"-"],plugin:[140,0,0,"-"],processes:[141,0,0,"-"],profiler:[142,0,0,"-"],proto_utils:[143,0,0,"-"],retry:[144,0,0,"-"],timestamp:[145,0,0,"-"],urns:[146,0,0,"-"]},"apache_beam.utils.annotations":{annotate:[139,5,1,""]},"apache_beam.utils.plugin":{BeamPlugin:[140,1,1,""]},"apache_beam.utils.plugin.BeamPlugin":{get_all_plugin_paths:[140,3,1,""],get_all_subclasses:[140,3,1,""]},"apache_beam.utils.processes":{Popen:[141,5,1,""],call:[141,5,1,""],check_call:[141,5,1,""],check_output:[141,5,1,""]},"apache_beam.utils.profiler":{MemoryReporter:[142,1,1,""],Profile:[142,1,1,""]},"apache_beam.utils.profiler.MemoryReporter":{report_once:[142,2,1,""],start:[142,2,1,""],stop:[142,2,1,""]},"apache_beam.utils.profiler.Profile":{SORTBY:[142,7,1,""]},"apache_beam.utils.proto_utils":{from_micros:[143,5,1,""],pack_Any:[143,5,1,""],pack_Struct:[143,5,1,""],parse_Bytes:[143,5,1,""],unpack_Any:[143,5,1,""]},"apache_beam.utils.retry":{Clock:[144,1,1,""],FuzzedExponentialIntervals:[144,1,1,""],PermanentException:[144,6,1,""],no_retries:[144,5,1,""],retry_on_beam_io_error_filter:[144,5,1,""],retry_on_server_errors_and_timeout_filter:[144,5,1,""],retry_on_server_errors_filter:[144,5,1,""],with_exponential_backoff:[144,5,1,""]},"apache_beam.utils.retry.Clock":{sleep:[144,2,1,""]},"apache_beam.utils.timestamp":{Duration:[145,1,1,""],Timestamp:[145,1,1,""]},"apache_beam.utils.timestamp.Duration":{of:[145,4,1,""]},"apache_beam.utils.timestamp.Timestamp":{RFC_3339_RE:[145,7,1,""],from_rfc3339:[145,3,1,""],from_utc_datetime:[145,3,1,""],of:[145,4,1,""],predecessor:[145,2,1,""],to_rfc3339:[145,2,1,""],to_utc_datetime:[145,2,1,""]},"apache_beam.utils.urns":{RunnerApiFn:[146,1,1,""]},"apache_beam.utils.urns.RunnerApiFn":{from_runner_api:[146,3,1,""],register_pickle_urn:[146,3,1,""],register_urn:[146,3,1,""],to_runner_api:[146,2,1,""],to_runner_api_parameter:[146,2,1,""]},apache_beam:{coders:[0,0,0,"-"],error:[5,0,0,"-"],internal:[6,0,0,"-"],io:[12,0,0,"-"],metrics:[43,0,0,"-"],options:[47,0,0,"-"],pipeline:[51,0,0,"-"],portability:[52,0,0,"-"],pvalue:[63,0,0,"-"],runners:[64,0,0,"-"],testing:[97,0,0,"-"],tools:[114,0,0,"-"],transforms:[119,0,0,"-"],typehints:[131,0,0,"-"],utils:[138,0,0,"-"],version:[147,0,0,"-"]}},objnames:{"0":["py","module","Python module"],"1":["py","class","Python class"],"2":["py","method","Python method"],"3":["py","classmethod","Python class method"],"4":["py","staticmethod","Python static method"],"5":["py","function","Python function"],"6":["py","exception","Python exception"],"7":["py","attribute","Python attribute"]},objtypes:{"0":"py:module","1":"py:class","2":"py:method","3":"py:classmethod","4":"py:staticmethod","5":"py:function","6":"py:exception","7":"py:attribute"},terms:{"10log10":42,"123z":32,"29t23":32,"60s":142,"abstract":[17,36,95,130,136,146],"boolean":[16,17,19,21,30,35,40,123],"byte":[1,13,16,17,18,32,34,69,137,143],"case":[13,16,21,24,25,32,34,38,39,40,42,51,63,69,74,82,113,121,129],"catch":21,"char":39,"class":[1,2,3,4,5,10,11,13,14,15,16,17,18,19,21,24,25,27,29,30,31,32,33,34,35,36,37,39,40,41,42,44,45,46,48,49,50,51,54,55,56,57,61,63,66,67,69,70,71,72,74,75,76,77,78,79,80,81,82,83,84,85,87,88,89,90,92,94,95,96,101,102,103,108,109,110,111,112,113,118,120,121,123,124,125,126,127,128,129,130,132,135,136,137,139,140,142,144,145,146,148],"const":135,"default":[1,4,13,15,17,21,34,39,40,48,63,83,90,108,110,121,123,124,130,142,144],"enum":[17,95],"export":21,"final":[1,15,16,18,34,39,79,82,95,121,129,146],"float":[1,9,21,24,27,34,38,42,44,111,118,123,130,137,145],"function":[1,4,9,10,11,17,19,21,24,27,30,34,35,38,45,51,69,93,109,110,112,113,118,121,124,127,129,130,132,134,135,137,139,144,146],"import":[4,34,42,65,73,125,130,132,140,144,148],"int":[1,9,13,17,18,21,24,27,30,31,35,38,39,42,67,95,111,118,121,123,132,137,145],"long":[4,36,121,144,145],"new":[4,16,17,18,19,21,30,34,35,42,51,55,63,67,69,95,109,113,118,121,127],"null":13,"public":[1,48,139],"return":[1,3,4,9,11,13,15,16,17,18,19,21,24,25,26,27,28,30,31,33,34,35,36,38,40,42,44,45,48,49,51,56,63,67,69,75,78,79,82,83,85,89,95,109,110,112,113,118,121,123,124,127,129,130,132,133,135,137,139,143,144,145,146],"short":[21,123],"static":[1,19,21,25,34,45,46,50,51,63,67,94,120,121,123,126,127,128,130,132,135,137,145],"super":124,"switch":78,"throw":54,"transient":[34,144],"true":[1,9,10,13,16,17,21,24,27,33,34,38,39,40,42,48,49,51,79,83,110,113,118,121,123,127,144],"try":[16,34,38],"while":[13,16,27,34,38,69,79,142],But:21,For:[1,2,3,4,6,7,8,9,10,11,13,14,16,17,19,21,26,27,29,34,38,49,51,52,53,62,69,74,75,76,80,83,84,85,90,94,103,110,111,112,114,118,121,123,124,125,129,130,134,135,136,138,139,140,141,142,143,144,145,146],GCS:[15,21,30,31,39,49],Has:21,IDs:[87,88,89],Not:132,One:132,Such:34,TOS:134,The:[1,4,8,9,10,13,15,17,21,25,27,32,34,39,40,42,44,45,46,48,51,54,56,63,65,67,69,70,78,79,87,95,101,102,103,105,106,107,110,111,112,113,121,123,124,129,130,132,133,134,135,137,139,144,146,148],Their:83,Then:13,There:[21,70],These:[34,40,111],Use:[38,108],Used:[16,34,39,40,41,42,55,94,135],Uses:[13,121],Will:82,With:124,__all__:1,__call__:118,__init__:[48,118,124,132],__scatter__:28,__stat_kind__:25,__stat_total__:25,_add_argparse_arg:48,_avrosourc:[13,16],_groupbykeyonli:83,_match:108,_mutat:25,_namespac:123,_num_query_splits_max:25,_paralleltriggerfn:127,_paramet:51,_picklecoderbas:1,_processelementsevalu:82,_py:53,_sre:[19,145],_statedofnparam:121,_timerdofnparam:121,a12345:103,a7syug:24,abc:[48,95],abil:132,abl:[9,66,121],about:[17,34,42,46,89,95,109,139],abov:[4,34,38,48,129],absolut:[17,18],abstractdofnwrapp:136,accept:[13,21,34,39,121,129,132],access:[8,18,19,30,33,34,35,45,46,50,79,89,94,95,121,148],accessor:61,accord:[17,30,35,38,130],accordingli:34,accumul:[44,49,121,127,136],accumulation_mod:121,accumulationmod:127,accur:34,across:[1,25,34,79,129],act:83,action:134,activ:55,actual:[11,18,51,108,113,121,124,127],acycl:148,adapt:24,adaptive_throttl:[12,20,22,23,148],adaptivethrottl:[24,27],add:[21,29,48,51,89,111,121,123,124,129,132],add_argu:48,add_artifactretrievalserviceservicer_to_serv:54,add_artifactstagingserviceservicer_to_serv:54,add_beamfncontrolservicer_to_serv:55,add_beamfndataservicer_to_serv:55,add_beamfnloggingservicer_to_serv:55,add_beamfnstateservicer_to_serv:55,add_el:111,add_input:[121,136],add_jobserviceservicer_to_serv:56,add_provisionserviceservicer_to_serv:57,added:[17,19,30,33,35,39,45,111,121,127],addit:[39,42,55,79,121,124,137,139],addition:[4,13,146],additionali:132,address:34,adjust:[17,18,34],advanc:[75,111],advance_bi:[75,111],advance_processing_tim:111,advance_tim:75,advance_watermark_to:111,advance_watermark_to_infin:111,afford:121,after:[11,15,17,19,24,30,33,34,35,38,39,42,49,51,67,69,76,79,82,111,121,127,144,145,148],afteral:127,afterani:127,aftercount:127,aftereach:127,afterprocessingtim:127,afterwatermark:127,again:[24,27,51,69],against:[17,19,49,110,113,136],aggreg:[49,77,81,95,118,121],aggregated_valu:95,aggregator_or_nam:[79,95],agre:34,aka:130,alert:63,algorithm:24,alia:[42,78,113,121,137],all:[5,11,15,17,19,21,25,27,30,33,34,35,36,42,48,49,51,54,63,69,79,83,85,95,96,110,111,112,113,117,118,121,123,127,129,130,132,140,144],all_pcollect:89,allel:42,allow:[34,45,46,55,63,89,108,121,123,124,128,130,132,137,144],allow_malformed_record:42,alreadi:[17,18,19,21,30,33,34,35,51,145],also:[1,15,21,34,46,51,55,70,77,79,95,121,124,127,129,132,142,146],altern:[42,124,129,139],alternate_bas:42,although:34,alwai:[1,4,18,21,34,36,124,139,142],alyssa:13,amort:129,amount:[34,38],analys:135,analysi:89,analyz:4,ani:[1,2,11,13,17,18,19,21,25,30,32,33,34,35,42,48,79,82,85,95,115,121,123,127,130,132,137,139,140,143],annot:[110,124,132,138,148],anoth:[1,51,82],any_msg:143,anyth:[17,19,65,73],anytypeconstraint:137,apach:[29,34,36,37,67,123,127,147],apache_beam:148,api:[1,9,21,32,34,45,51,52,70,92,93,94,95,123,128,139,148],apicli:66,apitool:21,app:31,appear:[42,121,132],append:[17,19,34,55,110],append_trailing_newlin:39,appengin:31,appli:[17,24,34,51,63,80,89,95,121,124,130],applic:[13,15,17,19,30,31,33,35,83],applied_ptransform:[51,67,71,76,79,80,82,83,85,96],applied_transform:136,appliedptransform:[51,76,79,84,85],apply_combinevalu:67,apply_groupbykei:67,apply_ptransform:95,apply_read:67,apply_writetobigqueri:67,apply_xyz:95,applypartitionfnfn:121,approach:124,appropri:[9,79],approxim:[25,34,69,115],arbitrari:63,arbitrarili:34,arg1:139,arg2:139,arg:[11,15,16,25,31,40,48,80,81,82,96,103,109,113,120,121,129,133,134,136,141,144],arg_hint:132,arg_nam:49,argpars:48,args_for_invok:82,argument:[1,11,13,17,21,27,31,32,33,34,39,40,45,48,49,51,63,67,109,110,113,118,121,123,124,129,132,134,137,144,146],argumentplacehold:11,argv:[48,51,109,110],arithmet:[120,145],around:[63,94,136],arriv:[127,130],artifact:54,artifactretrievalserviceservic:54,artifactretrievalservicestub:54,artifactstagingserviceservic:54,artifactstagingservicestub:54,as_cloud_object:1,as_deterministic_cod:1,as_singleton_view:121,as_view:121,ascii:[10,39],asdict:[63,125],asit:[63,125],ask:69,aslist:[21,63,125],aspect:34,assert:38,assert_reentrant_reads_succe:38,assert_sources_equal_reference_sourc:38,assert_split_at_fraction_behavior:38,assert_split_at_fraction_binari:38,assert_split_at_fraction_exhaust:38,assert_split_at_fraction_fail:38,assert_split_at_fraction_succeeds_and_consist:38,assert_that:[110,113],assertsourcesequalreferencesourc:38,assertsplitatfract:38,assertsplitatfractionbehavior:38,assertsplitatfractionexhaust:38,assideinput:63,assign:[34,96,121,130],assign_context:130,assigncontext:130,assingleton:[63,125],associ:[4,21,34,42,55,63,69,120,121,123,124,130],assum:[25,34,38,39],assumpt:87,asynchron:79,atom:34,attempt:[24,69,80,129],attempt_cal:80,attr:110,attribut:[18,21,32,90,130],auction:[101,102,103,105,106,107],auth:[6,7,148],authent:8,authenticationexcept:8,author:[101,102],auto:[15,16,17,19,30,33,35,39,40,42],automat:53,avail:[17,21,26,31,42,46,54,63,121,123,130,148],averag:[29,116],avoid:[17,21,34,130,137],avro:13,avroio:[12,34,148],avroio_test:38,await_complet:80,awar:145,b12345:103,back:1,background:95,backoff:144,backward:[1,2,3,6,7,8,9,10,11,14,17,26,27,32,34,45,49,51,52,53,62,65,69,73,74,75,76,80,83,84,85,87,88,89,90,94,111,112,114,124,125,127,128,129,134,135,136,138,139,140,141,142,143,144,145,146],bag:128,bagstatespec:128,bar:17,barrier:109,base64:[10,69],base:[1,2,3,4,5,8,11,13,14,15,16,17,18,19,21,24,25,27,29,30,31,32,33,34,35,36,37,39,40,41,42,44,45,46,48,49,50,51,54,55,56,57,61,63,66,67,69,70,71,72,74,75,76,77,78,79,80,81,82,83,84,85,87,88,89,90,92,94,95,96,101,102,103,108,109,110,111,112,113,118,120,121,123,124,125,126,127,128,129,130,132,135,136,137,140,142,144,145,146],base_match:[49,108],base_url:33,basematch:[49,108],basepath:[17,19,30,35],basestr:9,basic:[9,120,123,130],batch:[26,27,34,78,121,129,130,148],batch_siz:[21,26],batchel:129,beam:[1,5,13,21,29,32,34,36,37,51,61,67,70,72,89,90,110,113,127,128,133,144,146,147],beam_artifact_api_pb2_grpc:[52,53,148],beam_fn_api_pb2_grpc:[52,53,148],beam_job_api_pb2_grpc:[52,53,148],beam_provision_api_pb2_grpc:[52,53,148],beam_runner_api_pb2:146,beam_runner_api_pb2_grpc:[52,53,148],beamassertexcept:113,beamerror:5,beamfncontrolservic:55,beamfncontrolstub:55,beamfndataservic:55,beamfndatastub:55,beamfnloggingservic:55,beamfnloggingstub:55,beamfnstateservic:55,beamfnstatestub:55,beamioerror:[17,19,30,33,35],beamplugin:[17,140],bean:[1,146],becaus:[34,87,121,139],becom:[13,34,121],been:[34,44,54,118,130,133],befor:[34,38,39,54,67,69,83,108,110,121,127,130,132,144,148],begin:[13,34,39,40,69],behalf:55,behav:[13,39,40],behavior:[17,38,95,109,115,121,132,134,139],behaviour:[38,109],behavor:63,behind:63,being:[34,42,69,79,113,118,121,127],belong:[51,63,78,96,121,123,124],below:[4,21,25,34,109,121,144],benchmark:[97,115,118,148],benchmark_suit:118,benchmarkconfig:118,best:[32,34,129],better:[42,139],betweeen:36,between:[17,19,21,24,27,36,38,46,55,66,69,78,129,130,142,144],beyond:[32,34],bid:[101,102,103,106],bidder:[101,103],bigqueri:[12,20,48,148],bigquery_api_servic:48,bigquerydisposit:21,bigquerysink:21,bigquerysourc:21,bigtabl:34,binari:38,binary_add:134,binary_and:134,binary_divid:134,binary_floor_divid:134,binary_lshift:134,binary_modulo:134,binary_multipli:134,binary_or:134,binary_pow:134,binary_rshift:134,binary_subscr:134,binary_subtract:134,binary_true_divid:134,binary_xor:134,bind:137,bind_type_vari:137,bit:44,blob:28,block:[13,34,67,95,110],block_until:79,bodi:146,book:24,bool:[9,13,16,21,24,38,39,42,51,87,110,118,123,127,132,137],both:[1,16,21,27,34,38,50,124,132,139,148],bother:81,bottleneck:121,bound:[17,18,121,127,130,135,148],boundari:[34,69],boundedsourc:[14,16,34,38,41,109],boundedwindow:130,boundmethod:135,bucket:[24,31,49],bucket_m:[24,29],bucketnam:49,buffer:[1,17,18,31,83],buffer_s:21,build:[51,53,72,89,109,110,148],build_class:134,build_console_url:72,build_list:134,build_map:134,build_slic:134,build_tupl:134,built:[72,124,127,129,130,132,137],builtin:121,bulk:121,bundl:[13,14,16,34,39,74,77,79,80,81,83,121,129],bundle_factori:[64,73,79,148],bundle_id:34,bundlebaseddirectrunn:[78,89],bundlefactori:74,byte_arrai:3,byte_array_to_json_str:67,byte_offset:69,bytearrai:18,bytearraytojsonstr:67,bytecod:134,bytecountingoutputstream:3,bytescod:[1,40],bzip2:17,cach:[21,67,72,81,87,88,89],cache_label:89,cache_manag:[87,89],cached_pcollect:88,cachemanag:[87,89],caches_us:87,calcul:116,call:[2,4,15,21,24,27,34,36,42,49,51,54,56,69,80,82,95,112,121,123,124,127,129,141,144,146],call_funct:134,call_function_kw:134,call_function_var:134,call_function_var_wk:134,callabl:[1,10,95,115,118,121,135,144,146],callableptransform:124,callabletask:80,callablewrappercombinefn:[121,127],callablewrapperdofn:121,callablewrapperpartitionfn:121,callback:[2,34,36,51,79,80,95],caller:[24,34,82],can:[1,4,9,10,11,13,14,16,17,19,21,25,32,34,36,38,39,40,51,55,63,79,82,84,95,108,109,110,111,115,118,121,123,124,129,130,132,133,135,137,139,142,144,145,146],cancel:[56,95],cannot:[5,32,34,69],cap:25,capabl:[34,148],capit:137,captur:124,car67:103,categori:[101,103,137],caus:[127,139],cbf:34,ceas:111,ceil:109,cell:[21,43,87,128,148],cellcommitst:44,certain:[25,34,78,103],chain:124,chanc:[121,129],chang:[32,44,55,56,79,87,139,148],channel:[17,19,30,35,54,55,56,57],chapter:24,charact:[10,39,49,89],charg:[66,77],check:[10,17,19,21,30,33,34,35,38,50,51,63,79,113,118,121,123,132,136,137],check_access:50,check_cal:141,check_compil:118,check_don:[34,37],check_output:141,checkpoint:[34,37,82,129],checksum:[17,19,30,31,33,35,108],choos:16,chosen:[25,34,144],chr20:42,chunk:[17,19,21,54,130],chunk_siz:[17,30],citi:[101,103],claim:34,classmethod:[1,17,19,30,33,35,36,48,50,67,123,124,130,140,145,146],clean:[34,112],cleanup:[89,102,112],cleanup_subscript:112,cleanup_top:112,clear:[55,82,87,127],clear_pvalu:95,client:[17,21,24,27,28,31,34],clock:[64,73,79,85,112,129,144,148],clone:51,close:[15,17,18,19,30,34,35,36],closure_typ:135,cloud:[1,21,25,27,28,31,32,48,49,65,69],cls:[1,48,143],cmd:103,co_nam:134,code:[4,11,34,38,103,118,124,137,144],codec:13,coder:[10,15,21,34,39,40,70,89,111,115,128,148],coder_benchmark_factori:115,coder_proto:1,coderbas:4,coderimpl:1,coderregistri:1,coders_microbenchmark:[114,148],coexist:139,cogroupbykei:[109,129],cold:121,collect:[1,45,46,115,118,148],collis:46,com:[10,21,24,25,28,31,48,49,103],combin:[17,19,30,33,34,35,81,83,119,121,127,128,130,148],combine_fn:81,combine_op:127,combine_payload:121,combinefn:[120,121,136],combinefnprocesscontext:121,combineglob:121,combineperkei:[81,121],combinevalu:121,combiningvaluestatespec:128,combiningvaluestatetag:127,combnin:121,come:[8,139],comma:21,command:[21,48,103,110],comment:[51,121],commit:[26,27,34,44,54,76,79],commit_log:77,commit_phys:77,commitmanifest:54,commitrespons:27,common:[13,21,32,39,40,61,77,96,121,136,145],common_urn:[52,148],commun:123,compar:[27,34,36,108],compare_op:134,compare_path:27,comparison:27,compat:[1,2,3,6,7,8,9,10,11,14,17,19,26,27,32,34,45,49,51,52,53,62,65,69,73,74,75,76,80,83,84,85,87,88,89,90,94,111,112,114,121,124,125,127,128,129,134,135,136,138,139,140,141,142,143,144,145,146],compil:[1,118],complet:[1,18,21,27,34,69,79,80,95,110],completed_bundl:79,completed_committed_bundl:85,completed_tim:[79,85],completion_callback:80,complex:[34,137],complex_operation_returning_xyz:4,compli:[13,16],complianc:21,compliant:145,complic:134,compon:[1,17,19,30,32,33,35,123],component:94,composit:[4,34,70,95,113,130,135,137],compositetypehint:[132,137],compress:[13,16,17,19,30,34,35,39,40,42],compress_point:132,compressedfil:17,compression_typ:[15,16,17,19,30,33,35,39,40,42],compressiontyp:[15,16,17,19,39,40,42],comput:[5,11,25,48,51,95,108,112,120,121,124,148],compute_api_servic:48,compute_hash:112,concat:14,concat_posit:69,concat_sourc:[12,148],concaten:69,concatposit:69,concatrangetrack:14,concatsourc:14,concept:[21,25,34,130,148],conceptu:[34,51,129],concret:[95,121],concrete_typ:137,concurr:[34,38],condens:[120,121],condit:34,configur:[25,33,48,51,82,110],conflict:[34,137],connect:[18,27,33,48],connector:[25,29],consecut:[74,130],consid:[13,24,27,34,51,121,127,129],consist:[1,10,34,38,42,46,49,67,77,79,83,94,120,121],consol:72,const_typ:135,constant:121,constrain:[13,39],constraint:[57,132],construct:[1,13,21,32,39,40,45,63,69,79,80,94,95],constructor:[1,40,54,55,56,57,87,88,89,90,124,146],consum:[34,76,129],consumed_split_point:69,consumer_tracking_pipeline_visitor:[64,73,148],consumertrackingpipelinevisitor:76,contain:[4,9,10,11,13,17,18,19,21,25,26,30,34,35,38,39,40,44,48,51,54,63,79,82,89,96,108,110,114,121,123,124,130,132,137,138,143],content:[17,19,30,35,42,54,79,88,108,112,129,143],context:[1,32,34,44,51,54,55,56,57,63,79,94,112,121,124,127,130,142,146],contian:92,continu:[34,38,130,142],control:[21,55,74,92,109,127,139,144],conveni:[9,21,29],convent:[17,130],convers:[9,133],convert:[1,9,36,106,121,123,133,146],convert_to_beam_typ:133,coordin:132,copi:[17,19,30,31,33,35,109,121,135],copy_batch:31,copytre:31,core:[25,49,70,81,82,96,103,108,109,119,136,148],correct:[17,19,25,38],correctli:[34,121],correspond:[1,9,13,21,42,89,109,129,132,134,135,137,145,146],cost:129,could:[1,25,34,51,129,142,146,148],count:[13,26,29,39,40,41,44,46,88,118,120,127],count_tag:127,countcombinefn:127,counter:[45,46,79,84,134],countingsourc:41,coverag:38,cprofil:142,creat:[10,13,14,16,17,19,21,26,28,30,32,33,34,35,42,45,46,51,63,67,70,71,74,79,83,88,90,95,102,109,112,113,115,118,121,123,124,129,130,132,134,135,136,141,143,145],create_accumul:[121,136],create_bundl:[74,79],create_commit:26,create_disposit:21,create_empty_committed_bundl:[74,79],create_ent:26,create_from:123,create_from_opt:123,create_if_need:21,create_nev:21,create_respons:26,create_run_queri:26,create_sourc:[119,148],create_temp_fil:112,createptransformoverrid:[67,71],creation:[13,16,39,40,42],credenti:8,credit_card:[101,103],criteria:82,cross:141,csv:34,cumul:142,current:[10,16,17,18,21,32,34,39,51,56,63,66,69,77,79,82,95,111,121,139],current_posit:34,current_restrict:[34,37],current_tim:75,cursor:34,custom:[4,11,15,34,51,95,108,109,110,121,124,130,132,137],custommapp:124,customtransform:124,cycl:87,dag:[51,95],data:[3,4,16,17,18,19,21,24,25,32,34,38,42,44,51,55,63,109,121,123,127,130,148],databas:34,dataflow:[1,5,8,9,21,34,48,49,63,64,95,127,148],dataflow_cli:66,dataflow_endpoint:48,dataflow_metr:[64,65,148],dataflow_runn:[64,65,72,148],dataflowapplicationcli:66,dataflowmetr:66,dataflowpipelineresult:[66,67],dataflowrunn:[65,66,67,71,72,102],dataset:21,datastor:[12,20,148],datastore_pb2:27,datastoreio:[12,20,22,23,148],datatyp:21,datetim:[123,145],deal:[34,121],debug:[102,135],debugopt:[48,49],dec:46,decid:[13,34,39,82],decod:[1,4,21,32,39,40,70,89,115],decode_from_byt:4,decodeandemitdofn:70,decomposit:34,decompress:[16,17,34],decor:[1,4,21,112,121,124,128,131,139,144,146,148],decreas:34,decrement:46,deduc:135,dedupl:[32,129],def:[4,48,118,124,128,132,139],default_desired_bundle_s:[13,39],default_edge_attr:90,default_environment_id:94,default_environment_url:94,default_label:[121,124],default_output_cod:[14,34,109],default_runn:48,default_type_hint:[81,121,132],default_valu:[50,63],default_vertex_attr:90,default_window_mapping_fn:125,defaultrootbundleprovid:83,defaulttrigg:127,defin:[1,4,12,13,16,17,19,21,25,27,34,45,48,64,69,103,109,112,121,123,124,130,131,132,134,137],definit:34,deflat:13,degre:121,delai:[24,127,144],deleg:[36,45],delegatingcount:45,delegatingdistribut:45,delegatinggaug:45,delet:[17,19,21,25,30,31,33,35],delete_attr:134,delete_batch:31,delete_fast:134,delete_glob:134,delete_slice_0:134,delete_slice_1:134,delete_slice_2:134,delete_slice_3:134,deletefromdatastor:25,delimit:39,deliv:[32,79],demand:142,demarc:69,depend:[17,18,19,34,44,123,140],dependent_real_tim:126,deprec:[32,34,69,139],depth:[51,135],deriv:[28,89,124,130],descend:[119,124],describ:[21,33,34,38,48,55,63,69,109,121,124],describe_mismatch:108,describe_to:108,descript:[1,10,32,33,34,49,67,69,101,103,108,121],deserialize_windowing_strategi:67,design:[51,129],desir:[13,21,28,34,39,121],desired_bundle_s:[13,14,16,34,39,41,109],desired_num_offsets_per_split:37,despit:121,dest:31,destin:[17,19,30,33,35],destination_file_nam:[17,19,30,33,35],detail:[4,16,25,34,39,49,51,65,73,82,109,121,124,125,132],detect:[16,34,39,40,42,121],detect_compression_typ:17,determin:[17,24,34,39,42,51,82,121,127,130],determinist:[1,4],develop:[16,25,32,49,123,148],dialect:21,dict:[9,17,21,30,32,35,42,63,87,88,89,90,95,120,123,129,137],dict_int_int:115,dict_obj:93,dict_to_struct:93,dictionari:[4,9,11,13,21,40,48,83,113,118,121,123,133],did:38,differ:[1,16,21,34,38,51,55,69,109,144],digit:32,dill:[1,10],dillcod:1,direct:[64,89,121,148],direct_metr:[64,73,148],direct_runn:[64,73,89,148],direct_runner_use_stacked_bundl:74,directli:[21,32,34,46,63,121,125],directmetr:77,directopt:48,directori:[17,19,30,31,33,34,35,51,112],directpipelineresult:78,directrunn:[48,51,77,78,79,82,84,102,103,110],directrunneropt:74,directstepcontext:79,directunmergedst:79,dirti:44,dis:134,disable_run_time_type_check:132,discard:127,discourag:139,discuss:24,disk:[21,35],displai:[34,45,48,69,87,88,103,119,121,124,148],display_data:[13,15,16,21,25,34,48,121,123],display_data_dict:123,display_graph:88,display_manag:[64,86,148],displaydata:123,displaydataitem:123,displaymanag:87,disposit:21,distinct:51,distinguish:63,distribut:[33,44,45,46,116,121],distribution_counter_microbenchmark:[114,148],distributionaccumul:116,distributionresult:44,div_round_up:109,divid:[83,130],do_fn:96,doc:[25,48,49,134],dockerrpcmanag:92,docstr:129,document:[16,34,48,82,121,127,134],doe:[21,34,39,51,81,95,123,142],doesn:[17,19,27,30,35],dofn:[4,21,25,34,63,70,81,82,96,103,109,121,123,124,128,136],dofninvok:82,dofnprocessparam:121,dofnrunn:121,dollar:106,domain:126,don:81,done:[17,19,21,33,34,51,79,95,96,108,130],donwstream:129,dooutputstupl:121,dot:[88,90],doubl:[29,144],down:34,download:18,downloaderstream:18,downstream:[34,129],drain:95,drop:[24,123],drop_default:48,drop_if_default:123,drop_if_non:123,duck:4,due:[10,34,121],dump:10,dump_sess:10,dup_top:134,dup_topx:134,duplic:32,durat:[67,95,103,111,123,130,145],dure:[5,11,13,16,18,21,31,32,39,40,42,45,46,48,54,87,88,111,121,135,144],dynam:[16,25,34,38,50,51],dynamic_split_request:69,dynamicsplitrequest:69,dynamicsplitresult:69,dynamicsplitresultwithposit:69,e2e:72,each:[1,13,21,24,27,34,38,39,40,42,51,76,96,103,109,111,118,120,121,123,129,130,132,134,137],earli:[21,127,148],earliest:130,easi:121,easier:17,ec_point:132,edg:[51,90],effect:[18,124,129],effici:[1,4,16,34,93,121],effort:32,either:[15,17,18,21,27,34,38,42,51,82,84,110,121,124,132,133,137],elantra:103,elem:[34,103],elem_cod:1,element:[1,4,21,27,32,34,38,39,44,63,70,81,82,84,85,96,109,111,113,115,117,118,120,121,123,127,129,130,135,136],element_and_restrict:96,element_cod:96,element_s:109,element_typ:[63,135],elementandrestrict:[82,96],elementev:111,elementparam:121,elm:103,els:[69,132],elsewher:69,email:[101,103],emb:10,emit:[55,63,70,111,127,129],empti:[16,21,34,63,79,83,121,127],emptysideinput:63,enable_run_time_type_check:132,enable_trac:10,encapsul:69,encod:[1,3,4,9,10,15,21,34,39,40,69,70,89,115,146],encode_to_byt:4,encoded_:15,encoded_kei:84,encoded_str:67,encoded_table_row:21,encoded_valu:[15,70],encount:18,end:[13,14,17,18,19,34,36,39,40,42,48,49,69,81,82,108,111,127,130],end_cursor:26,endpoint_pattern:49,endpoints_pb2_grpc:[52,53,148],enforc:132,engin:[31,34],ensur:[25,34],entail:21,enter:72,enter_composite_transform:136,entir:[21,25,34,63,67,69,78,95,113,121,130],entiti:[25,26,27,61],entri:[1,29,55,63],enum_typ:61,enumer:62,environ:[82,94],eof:[17,18],epoch:[24,32,75,130,145],equal:[18,25,34,38,48,123,129],equal_to:[110,113],equival:[17,34,38,124,129],err_invalid_gcs_bucket:49,err_invalid_gcs_object:49,err_invalid_gcs_path:49,err_invalid_job_nam:49,err_invalid_not_posit:49,err_invalid_project_id:49,err_invalid_project_numb:49,err_invalid_test_matcher_typ:49,err_invalid_test_matcher_unpickl:49,err_missing_gcs_path:49,err_missing_opt:49,error:[1,18,21,33,34,49,54,108,121,130,132,135,136,144,148],error_messag:1,escap:89,especi:[130,145],essenti:[48,121],estim:[1,25,34,69],estimate_s:[1,14,16,34,41,109],etc:[25,34,45,95,124,148],euro:106,evalu:[11,74,79,80,82,83,84,115,127,145],evaluation_context:[64,73,80,83,148],evaluationcontext:79,even:[16,27,34,132,139,144],event:[34,101,102,103,105,106,107,111,127,130],event_count:21,everi:[4,21,34,38,51,67,87,95,144],everyth:[17,19,30,35,87,130],evolv:31,exact:[109,121],exactli:[1,25,34,48,51,63,127],exampl:[1,4,13,16,21,32,34,38,42,69,83,88,103,110,118,121,123,124,129,130,132,139,145,146,148],exce:31,exceed:27,except:[5,8,17,27,31,34,108,121,132,135,144],excess:21,exclus:[18,34],exec_stmt:134,execut:[1,11,21,32,34,45,46,48,49,51,54,56,63,64,65,67,72,73,78,79,80,82,83,87,88,95,110,111,118,121,124,135,148],executor:[64,73,83,148],executor_servic:79,exhaust:38,exist:[13,16,17,19,21,30,31,32,33,34,35,39,40,42,89,110,112,121,139],existing_keyed_st:79,exp_multipli:139,expand:[13,21,25,32,34,39,40,42,70,81,82,89,96,109,111,120,121,124,129],expand_using_gbk:109,expand_using_second_output:109,expans:121,expect:[1,15,21,33,36,38,48,51,108,110,113,146,148],expected_checksum:108,expected_item:38,expected_outcom:38,expected_st:[72,108],expectedsplitoutcom:38,experi:50,experiment:[32,34,45,87,88,89,90,124,127,128,129,139,140],expir:[101,103,128],explain:34,explod:96,explodewindowsfn:96,exponenti:144,expos:[21,29,46],extend:[15,34,49,108,140],extens:[13,16,34,39,40,42],extent:121,extern:[34,121,148],extra:[101,103,108,110],extra_messag:139,extra_opt:110,extra_typ:[9,21],extract:[51,76,85],extract_all_tim:[79,85],extract_commit:77,extract_latest_attempt:77,extract_output:[121,136],extrem:120,face:[45,128],fact:139,factor:144,factori:74,fail:[17,19,21,27,30,31,34,35,38,42,95,135],failur:[27,34],fake:26,fake_datastor:[12,20,22,23,148],fake_run_queri:26,fakesourc:117,fall:[1,34],fallback:4,fallback_cod:1,fals:[3,9,13,16,17,21,26,34,42,48,51,67,87,89,110,113,121,123,124,127,134,135,142,144],famili:38,fanin:109,fanout:[109,121],far:[69,133],fast:1,fastavro:13,fastcod:1,faster:[4,13],fastprimitivescod:[1,111],fault:34,favorite_color:13,favorite_numb:13,fetch:[17,18,19,25,27,30,33,35,87,108,117],fetch_ent:27,feth:25,few:[38,124],field1:21,field2:21,field3:21,field:[13,21,27,34,42,113,123,139],field_count:42,file:[13,15,16,17,18,19,21,30,31,33,34,35,39,40,42,44,45,46,51,89,108,112,113,148],file_copy_fn:142,file_handl:15,file_nam:[16,42],file_name_suffix:[13,15,39,40],file_path:[10,17,39,40,42,108],file_path_prefix:[13,15,39,40],file_pattern:[13,16,39,40,42],filebasedsink:[12,34,108,148],filebasedsourc:[12,39,148],filechecksummatch:108,filemetadata:17,filenam:[13,31,39,40,112],fileobj:17,filepath:17,filesystem:[12,13,18,30,33,34,35,140,148],filesystemio:[12,148],fill:123,filter:[25,27,42,45,66,77,107,108,121,139,144],finalize_writ:[15,34],find:[5,17,19,120,129,144],finish:[18,26,67,95,127,142],finish_bundl:[81,109,121,136],finish_st:80,finishcombin:81,finit:[34,130],fire:[84,85,127,128],fired_tim:80,first:[4,10,17,19,30,32,33,34,35,38,42,51,54,56,109,121,124,129,134,137,144,148],fix:[1,121,129,130],fixed_cost:129,fixedsizeglob:120,fixedsizeperkei:120,fixedwindow:130,flag:[13,16,17,19,30,35,39,40,42,48],flat:129,flatmap:[10,63,121,124,148],flatten:[14,21,121],flatten_input_visitor:67,flatten_result:21,flavor:139,floatcod:1,flush:[17,81],fn_paramet:130,fn_proto:146,fn_to_execut:11,fnapirunn:78,fnmatch:[17,19],fold:121,follow:[13,21,27,34,38,39,40,82,103,110,121,130,132,137,139,142],foo:[1,17,19,132,146],foo_from_proto:[1,146],foopayload:[1,146],footer:15,footprint:95,for_input_typ:121,forc:[63,87,96],form:[13,17,18,21,31,32,33,63,118,129,130,132,139,145],formal:132,format:[15,17,19,21,32,34,38,42,49,103],format_sampl:88,former:63,formula:[24,129,130],forward:83,found:110,frac:14,fraction:[14,34,36,38,69,144],fraction_consum:[14,34,36],fraction_to_posit:36,frame:[134,135],framest:[134,135],framework:[4,16,21,34,69],fresh:121,from:[1,4,8,13,15,16,17,18,19,21,25,27,28,30,31,32,34,35,36,38,39,40,42,48,49,51,56,63,67,69,76,87,88,89,95,103,106,108,109,110,112,117,121,123,124,127,129,130,132,139,144,145,146,148],from_cal:121,from_dictionari:48,from_json_valu:9,from_micro:143,from_rfc3339:145,from_runner_api:[1,46,51,63,94,121,124,127,146],from_runner_api_paramet:[1,34,121,130],from_str:126,from_type_hint:1,from_utc_datetim:145,fronend:87,frontend:87,full:[17,19,24,30,33,34,35,38,51,108,110,130,140],full_label:136,fulli:[18,21,34,69,132],fun:144,func:[121,132,135],functiontyp:135,furnish:63,further:[55,124,144],fuse:129,fusion:129,futur:[1,2,3,11,17,18,19,21,24,27,29,31,32,34,37,42,44,45,46,49,50,51,54,61,63,69,74,75,77,79,80,82,83,84,85,92,94,95,96,111,112,132,135,139,140,142,144,145,146],future_output_watermark:82,fuzz:144,fuzzedexponentialinterv:144,gap:130,gap_siz:130,gather:28,gaug:[45,46],gaugeresult:44,gce:8,gcp:[6,12,148],gcs:31,gcs_bucket:49,gcs_prefix:30,gcs_scheme:49,gcs_uri:49,gcsfilesystem:[12,20,148],gcsio:[12,20,148],gener:[1,13,16,34,39,40,53,90,101,102,105,109,110,111,115,121,137],generate_bundle_id:34,generate_ev:102,generate_fn:115,generate_input_valu:116,genom:42,genotyp:42,get:[3,8,16,17,19,21,25,30,34,35,38,50,54,55,56,57,63,69,85,89,95,109,110,121,127,140,144,146],get_accumulator_cod:121,get_aggregator_valu:79,get_all_opt:48,get_all_plugin_path:140,get_all_subclass:140,get_chunk_s:19,get_count:3,get_datastor:27,get_dict:123,get_dict_table_schema:21,get_dot:[88,90],get_estimated_num_split:25,get_estimated_size_byt:25,get_evalu:83,get_execution_context:79,get_filesystem:19,get_full_options_as_arg:110,get_function_argu:121,get_glob:135,get_impl:[1,130],get_it:134,get_keyed_st:79,get_nam:135,get_namespac:45,get_opt:110,get_output_typ:121,get_path:112,get_progress:69,get_rang:18,get_range_track:[14,16,34,38,41,109],get_replacement_transform:[51,67,71,82,96],get_root_bundl:83,get_root_bundle_provid:83,get_schem:19,get_service_credenti:8,get_split:28,get_table_schema_from_str:21,get_transformed_output_tim:130,get_type_hint:132,get_typed_value_descriptor:9,get_valu:50,get_value_or_block_until_readi:79,get_varint_s:3,get_watermark:85,get_window:[34,70,111,121,124],get_window_cod:130,getartifact:54,getattr:134,getmanifest:54,getmessagestream:56,getprovisioninfo:57,getrangetrack:38,getstat:56,getstatestream:56,github:[10,28,31,42],give:[16,17,19,30,34,35,38,45,51,69,82,109],given:[1,3,11,13,16,17,18,19,21,25,26,27,28,30,31,34,35,36,38,39,40,48,49,51,63,82,83,95,108,109,111,113,118,121,127,129,130,133,135,144,145,146],glob:[13,16,39,40,42,108,113],glob_path:89,global:[1,34,79,83,120,130],global_to_loc:14,globalwindow:130,goe:49,going:[25,66],gone:63,good:25,googl:[1,8,21,24,25,27,28,31,32,48,49,65],googleapi:[48,49],googlecloudopt:[48,49],googlecloudplatform:[28,31],googledatastor:27,gracefulli:82,granular:[24,130,145],graph:[51,63,67,76,78,83,87,88,90,124,148],greater:[25,121,132],greater_than:25,group:[4,14,46,48,121,124,129,130],group_by_key_input_visitor:67,groupbykei:[1,95,109,121,124,129,130,148],grpc:[54,55,56,57],guarante:[1,2,3,4,6,7,8,9,10,11,14,26,27,32,34,45,49,51,52,53,62,65,69,73,74,75,76,80,83,84,85,87,88,89,90,94,111,112,114,124,125,127,128,129,134,135,136,138,139,140,141,142,143,144,145,146],guid:127,gzip:[17,34],had:[1,121,146],hadoop:33,hadoopfilesystem:[12,48,148],hadoopfilesystemopt:[33,48],halfwai:38,hamcrest:[49,108],hand:21,handl:[15,16,17,19,24,30,34,35,39,40,42,79,134],handle_result:79,happen:[21,28,34,38,51,87,112,144],har:[38,55,57],has:[1,9,18,21,25,27,34,42,48,49,63,69,76,78,85,103,110,113,118,120,121,123,132,148],has_data:29,has_default:121,has_dir:[17,30,33,35],has_display_data:123,has_kw:134,has_part:124,has_var:134,hasdisplaydata:[34,48,69,121,123,124],hash:[108,112],hashabl:135,hashing_alg:112,have:[4,8,10,11,17,19,21,25,27,34,42,44,51,54,63,107,121,123,127,130,132,133,134,144],hdf:33,head:[17,19,30,35],header:[15,39,42],heap:142,heavi:38,heavyweight:38,help:[38,121],helper:[12,20,22,23,38,88,89,125,148],helper_transform:[64,73,148],henc:[25,34,69],here:[1,21,27,34,65,73,121,130,134],hidden:63,hierarch:9,hierarchi:51,high:[78,121],higher:[39,42],hint:[4,124,131,132,135,137],histori:24,hold:[21,34,51,82,121],holder:[11,96],homogen:1,honor:69,hour:144,how:[21,25,34,63,69,94,109,115,120,121,124,130,139,148],howev:[1,25,28,34,42],html:[24,48,134],hts:42,http:[10,21,24,25,28,31,34,42,48,49,123,127,134,144],httperror:144,huge:63,hypothet:34,hyundai:103,id_label:32,id_or_nam:26,idempot:34,ident:132,identifi:[13,21,32,34,39,40,121,123],ids:27,iff:15,ignor:[21,25,32,36,111,113],illustr:[34,106,107,139],imagin:34,immedi:[56,95],immut:34,impact:[25,39],implement:[1,3,15,16,17,18,21,24,28,30,33,34,35,36,37,38,39,45,49,50,51,65,66,67,69,70,73,75,77,78,79,81,95,118,121,123,124,125,137,144,146],implementor:[17,34,121],impli:[42,139],implicitli:130,import_from:134,import_nam:134,imposs:34,improv:[1,21],impuls:[70,121],inc:[29,45,46],includ:[17,19,21,30,34,38,42,79,82,101,103,130],inclus:[34,36],incom:32,incompat:139,inconsist:10,incorrect:38,increas:144,increment:[46,132],indefinit:[67,95],independ:[34,67,132],index:[42,63,69,121,127,132,137],index_tag:127,indic:[17,19,30,34,35,39,42,51,63,129,143,144],individu:[16,34,38,121,130],inequ:25,inf:36,infer:[4,135],infer_output_typ:[70,121,124],infer_return_typ:135,infer_return_type_func:135,infin:[34,130],info:[42,89,95,103,128],inform:[8,16,34,42,57,66,67,69,79,82,89,95,121,129,135,147],infrastructur:105,inherit:[34,69,123,146],init_result:[15,34],initi:[13,14,16,18,21,24,25,32,33,34,36,39,40,42,46,48,51,57,63,66,69,82,83,96,108,109,110,118,121],initial_bid:[101,103],initial_delay_sec:144,initialize_writ:[15,34],inject:[16,124],inlin:134,inmemoryunmergedst:79,inner:[69,132,137],inpalce_or:134,inplace_add:134,inplace_and:134,inplace_divid:134,inplace_floor_divid:134,inplace_lshift:134,inplace_modulo:134,inplace_multipli:134,inplace_pow:134,inplace_rshift:134,inplace_subtract:134,inplace_true_divid:134,inplace_xor:134,inprocess:73,input:[5,11,12,13,21,34,39,40,42,48,51,63,69,70,76,79,80,82,83,85,89,95,96,109,115,116,117,118,121,124,125,129,130,135,136,143,145,148],input_bundl:80,input_committed_bundl:83,input_or_input:124,input_or_output:124,input_pcol:124,input_per_sourc:117,input_s:115,input_spec:109,input_timestamp:130,input_typ:[121,135],input_type_hint:124,inputstream:3,insert:21,insert_values_in_arg:11,insid:110,inspect:135,instanc:[1,4,11,17,19,21,30,35,42,49,51,57,63,66,67,69,83,84,112,113,118,121,123,124,127,130,132,135,137,144,145],instance_to_typ:135,instanti:[69,135,140],instead:[10,21,34,42,51,125,139,144],instruct:55,instrument:118,int_to_str:132,integ:[1,3,19,21,34,37,45,115,121,123,130,134],integr:[110,144],intend:[24,29,34,46,63,132,144],interact:[17,64,66,148],interactive_pipeline_graph:[64,86,148],interactive_runn:[64,86,87,148],interactivepipelinegraph:88,interactiverunn:89,interchang:21,interest:38,interfac:[18,19,32,46,63,123,128],intermedi:[21,121],intern:[1,2,3,14,26,27,34,45,49,51,52,53,62,65,66,69,73,74,75,76,80,83,84,85,94,111,112,114,123,125,130,134,135,136,138,139,141,142,143,144,145,146,148],interpol:36,interpret:[21,69],intersect:130,interv:[36,130,142,144,145],interval_second:142,intervalwindow:130,introduc:[34,113],introduct:21,invalid:[17,18,31,48,49,109,132],invalid_argu:54,invoc:[34,82],invok:[34,82,121,127],invoke_process_el:82,involv:21,iobas:[12,14,15,16,21,36,37,38,41,64,65,68,109,121,148],ioerror:[16,17,19,30,35,95],ipython:88,is_access:50,is_bound:[34,69],is_default:121,is_determinist:1,is_don:79,is_empti:113,is_full_string_match:49,is_globally_window:125,is_integration_test:110,is_key_valid:27,is_kv_cod:1,is_lat:127,is_merg:130,is_pair_lik:1,is_process_bound:[121,136],is_root_transform:79,is_service_runn:49,is_valid:123,is_valid_compression_typ:17,isn:[17,19,30,35,132],issu:10,item:[38,84,101,102,107,109,123],item_nam:[101,103],items_before_split:38,iter:[1,2,16,27,33,34,38,48,63,69,117,121,125,127,129,130,133,137,144],iterablecod:1,its:[1,4,11,17,21,27,34,118,121,123,124,129,135,143,146,148],itself:[34,69,145],java:28,job:[25,51,54,55,56,57,64,66,67,72,78,95,103,108,110,148],job_graph:66,job_nam:[49,110],job_pattern:49,job_result:66,jobapi:92,jobserviceservic:56,jobservicestub:56,jobstat:95,join:[17,19,30,33,35],json:[9,10,21,67,89,109],json_string_to_byte_arrai:67,json_valu:[6,7,148],jsonarrai:9,jsonobject:9,jsonstringtobytearrai:67,jsonvalu:[9,21],just:[25,34,63,124],keep:[29,34,69,77,83],kei:[1,4,9,13,25,26,27,34,36,42,63,69,79,81,82,83,84,96,109,118,120,121,123,124,129,130,133,135,148],kept:123,key1:123,key2:123,key3:123,key4:123,key5:123,key_cod:1,key_compar:27,key_value_typ:135,keyed_earliest_hold:85,keyed_watermark_hold:84,keyedworkitem:[82,84],keyspac:36,keyword:[11,63,121,132],keyword_hint:132,kind:[25,27,34,121,139],know:135,known:[17,49,79],kv_type:135,kvswap:129,kwarg:[2,11,15,16,25,31,39,40,42,48,80,81,82,96,113,120,121,129,132,136,141,143],kwarg_hint:132,kwargs_for_invok:82,label:[13,51,63,70,89,109,113,120,121,123,124,129,136,139],label_from_cal:124,lambda:[21,124,127],land:24,languag:148,larg:[25,38,39,63],large_dict:115,large_int:115,large_list:115,large_str:115,large_tupl:115,larger:34,largest:[34,120,129,145],largestperkei:120,last:[17,19,27,30,34,35,42,82],last_record_start:36,late:127,late_tag:127,latenc:[27,121],later:[82,110,111,121],latest:[25,27,46,87],latest_timestamp:27,latter:63,launch:103,launcher:[102,105],lead:[87,88],leaf:[17,19,30,35],leaf_pcollect:89,least:[38,127],leave_composite_transform:136,left:[38,45,121],left_fract:38,left_result:38,len:18,length:[1,24,28,31,115,132,144],less:[28,36,121],less_than:25,let:[4,34,45],letter:[13,21,39,40,49,137],level:[13,51,121],lexicograph:36,lexicographickeyrangetrack:36,librari:[1,8,10,13,31,41,42,48,120,134],lift:121,liftedcombineperkei:81,lightweight:38,like:[4,13,17,19,25,30,33,34,35,39,63,121,132,135,137],limit:[17,19,25,27,144],line:[21,34,39,42,48,103,110,112],linearli:36,link:5,list:[1,9,11,14,17,19,21,26,27,28,30,31,35,38,42,49,50,51,63,84,109,110,112,113,115,118,120,121,129,132,133,137],list_append:134,list_int:115,list_prefix:31,load:[10,105,106,107],load_attr:134,load_closur:134,load_const:134,load_deref:134,load_fast:134,load_glob:134,load_loc:134,load_nam:134,load_sess:10,local:[15,17,19,35,39,51,73,78,89,121],local_to_glob:14,local_var:135,localfilesystem:[12,17,148],locat:34,lock:34,log:[55,128,142,144],log_result:142,logger:[112,144],logic:[16,34,45,77,82,96,130,144],loglevel:102,long_gener:117,look:132,lookup:63,loop:[34,121],lose:145,lower:[127,132],lower_bound:116,machin:[34,78],machineari:82,made:[4,21,34,54,56,63],magic:96,mai:[1,4,16,17,21,28,32,34,42,45,55,63,69,82,83,95,121,129,139],main:[21,28,34,63,121],main_kw:121,main_tabl:21,mainli:82,make:[21,26,27,34,36,49,70,82,96,101,108,144],make_closur:134,make_fn:121,make_funct:134,make_http_request:144,make_kind_stats_queri:27,make_latest_timestamp_queri:27,make_partit:27,make_request:27,makexyz:4,malform:133,malformedvcfrecord:42,manag:[21,34,51,64,85,87,91,112,127,142,148],mandatori:[121,129],mani:[9,25,34,120,121],manifest:54,manner:[13,34,38,129],map:[1,13,21,32,36,42,63,70,87,88,89,106,121,125,129],mapfn:124,mapper:81,maria:103,mark:139,marker:63,massiv:21,master:28,match:[1,17,19,21,45,49,51,67,71,82,96,113],match_type_vari:137,matcher:[49,51,72,108,113],matchresult:[17,19],materi:[63,89,95,113],matter:34,max:[28,44,121,129],max_batch_operation_s:31,max_batch_s:129,max_delay_sec:144,max_dur:82,max_num_output:82,max_timestamp:130,maximum:[17,19,129,135,144],maybe_from_cal:121,mean:[34,44,120,139],mean_temp:21,meant:[55,95],measur:[115,116,117,129],member:[15,54],memori:[44,81,83,142],memoryreport:142,memoryview:18,merg:[34,81,109,121,127,130],merge_accumul:[121,136],merge_context:130,merge_result:[127,130],merge_using_gbk:109,merge_using_side_input:109,mergecontext:130,messag:[1,32,34,56,139],met:113,metadata:[8,17,19,30,35,57,89,107],metadata_list:17,method:[1,4,16,17,18,19,25,26,27,33,34,36,38,46,48,49,51,67,82,95,109,110,112,121,123,124,125,128,135,136,137,139,144,146],metric:[55,66,77,79,95,118,148],metric_nam:45,metricbas:[43,45,148],metricnam:46,metricresult:[66,77,95],metrics_contain:80,metricsenviron:45,metricsfilt:45,micro:[143,145],microbenchmark:[115,116,117,118],microsecond:[25,116,130,145],might:[34,39,69,123,139],millisecond:[27,32,67,95],mime:[13,17,19,30,31,35],mime_typ:[13,15,17,19,30,31,33,35],min:[44,129],min_batch_s:129,min_bundle_s:[13,16,39],min_fraction_of_files_to_stat:16,min_num_offsets_per_split:37,min_number_of_files_to_stat:16,min_request:24,minimim:129,minimum:[13,16,39,85],mirror:132,mismatch_descript:108,miss:49,mix:132,mixin:[123,132],mkdir:[17,19,30,33,35],mock:112,mode:[17,18,21,31,34,67,70,71,121,130],model:[97,98,99,102,148],modifi:[11,34,124,134],modul:[0,6,7,12,20,22,23,43,47,52,53,64,65,68,73,86,91,97,98,99,100,104,114,119,131,138,148],moment:11,month:21,more:[4,16,17,19,21,25,30,33,34,35,39,49,51,82,109,121,123,124,127,129,130,134],moreov:34,most:[13,21,34,38,39,124,144],mostli:[51,129,144],move:[17,19,29,30,35,83],movingfunct:29,movingsum:29,msg:143,msg_class:143,much:9,multi:[34,38],multipl:[16,25,34,42,46,63,83,117,120,121,127,129,132],multipli:139,muss:34,must:[1,11,16,18,21,24,32,33,34,39,49,51,54,63,69,95,110,111,118,121,124,130,132,144],mutabl:[34,134],mutat:[26,27,34],my_side_input:63,my_timer_expiry_callback:128,my_tranform:51,myavrofil:13,mybenchmark:118,mydofn:128,myjobnam:110,mypath:13,myptransform:63,mysink:34,name:[13,16,21,27,31,34,42,45,46,49,51,54,66,69,84,89,95,101,103,109,110,112,118,121,128,129,132,137],namespac:[13,25,27,45,46,123,137],nativ:[21,34,69,92,124,133],native_io:[21,64,65,148],native_type_compat:[131,148],nativesink:[21,34,69],nativesinkwrit:69,nativesourc:[21,69],nativesourceread:69,necessari:[4,63,118,123,145],necessarili:69,need:[2,4,15,17,19,21,26,30,34,35,36,49,51,55,57,82,112,113,124,144],neg:[17,18,36],negat:132,neither:[21,123],nest:[3,21,137],never:[11,34,63,127,130,142],new_process_fn:82,new_save_module_dict:10,new_track:37,new_valu:89,new_watermark:111,newlin:39,newobject:[1,2,3,11,17,18,19,21,24,27,29,31,32,34,37,42,44,45,46,49,50,51,61,63,69,74,75,77,79,80,82,83,84,85,92,94,95,96,111,112,132,135,140,142,144,145,146],nexmark:[97,98,148],nexmark_launch:[97,98,99,103,148],nexmark_model:[97,98,99,100,148],nexmark_util:[97,98,99,148],nexmarklaunch:102,next:130,nice_str:88,nnnnn:[13,39,40],no_retri:144,node:[51,63,67,95,124],non:[10,34,36,63,95,121,123,144],none:[1,9,13,14,15,16,17,19,21,25,27,28,31,32,34,36,38,39,40,41,42,44,48,50,51,63,66,67,69,70,72,77,79,82,84,88,89,90,92,94,95,101,105,106,107,108,109,110,112,120,121,123,124,127,129,130,135,136,137,142,143,146],nonmergingwindowfn:130,nonzero:144,nop:134,nor:21,normal:[25,42,123,130],nosetest:110,notabl:38,notbig:21,note:[1,10,17,18,21,25,26,28,34,51,70,113,121,124,132,137,139,142],noth:[69,139],notic:132,notifi:24,notify_observ:2,notimplementederror:95,notion:[34,69,120],now:[24,29,144],nth:129,nullabl:21,num_byt:17,num_el:129,num_input:116,num_items_to_read_before_split:38,num_partit:121,num_retri:144,num_run:[115,116,117,118],num_shard:[13,15,39,40],num_sourc:117,num_split:[25,28],num_window:115,num_work:110,number:[11,13,17,18,19,21,25,26,28,32,34,38,39,40,42,49,75,82,102,108,113,118,120,121,129,144,145],numer:[32,145],obei:34,obj:[9,10],object:[1,2,4,5,9,10,11,13,15,16,17,18,19,21,30,31,33,34,35,36,40,42,45,46,48,49,50,51,54,55,56,57,63,64,66,69,76,82,83,87,89,90,92,94,95,96,101,102,103,108,110,111,115,118,120,121,123,124,125,126,127,128,130,132,134,135,137,142,144,145,146],observ:[0,148],observablemixin:2,obtain:[17,21,34,45,48,110,120,121,124,129],occupi:34,occur:[28,33,38,42,120,130],octet:[15,17,19,30,31,33,35],offer:[51,109],offici:34,offset:[17,18,34,37,69,130,145],offset_infin:36,offset_range_track:16,offsetrang:37,offsetrangetrack:[16,36],offsetrestrictiontrack:37,oflong:29,often:[129,139],okai:34,old:[34,139],old_multipli:139,on_el:127,on_fir:127,on_merg:127,on_success_match:49,on_tim:128,onc:[17,24,34,63,83,121,127,130,132],one:[1,4,13,21,24,26,27,32,34,38,39,40,42,48,49,51,63,69,82,83,87,118,120,121,124,129,130,132,137,146],ones:[38,48,74],onli:[1,2,3,6,7,8,9,10,11,13,14,17,21,26,27,32,34,36,38,39,40,42,45,49,51,52,53,62,63,69,74,75,76,77,80,83,84,85,87,94,110,111,112,113,114,120,121,123,125,129,132,134,135,136,138,139,140,141,142,143,144,145,146],opaqu:15,opcod:[131,148],open:[15,16,17,19,30,31,33,34,35],open_fil:16,open_shard:113,open_writ:[15,34],oper:[1,4,5,17,19,21,30,31,34,35,51,95,115,116,121,124,129,130,145],operation:129,opt_nam:110,optim:[13,39,127],option:[8,17,19,25,30,32,33,34,35,40,51,57,72,74,95,102,109,110,113,121,124,129,132,137,139,148],option_nam:50,orchestr:102,order:[1,4,21,25,31,34,36,42,51,95,110,112,121,132,137],orderedpositionrangetrack:36,ordinari:63,ordinarili:[121,129],orfin:127,org:[29,34,48,67,123,127,134],orient:34,origin:[34,38,132],original_range_track:38,original_read:38,original_stop_posit:38,other:[14,17,19,21,27,34,36,39,42,51,57,69,94,109,115,121,123,129,130,132,137],otherwis:[1,9,17,34,38,51,110,111,121,124],our:51,out:[17,18,95,121],outer:[26,34],output:[12,13,15,16,17,32,34,39,40,42,51,63,74,76,79,82,83,85,87,89,108,109,111,121,124,129,130,136,148],output_at_earliest:130,output_at_earliest_transform:130,output_at_eow:130,output_at_latest:130,output_filter_ratio:109,output_pcollect:[74,79],output_records_per_input_record:109,output_tag:89,outputcheckwrapperdofn:136,outputstream:3,over:[48,121,129,144],overhead:17,overlap:34,overload:24,overload_ratio:24,overrid:[15,21,48,51,70,71,82,95,96,108,121,123,124,146],overridden:34,overwrit:15,own:[121,129],p12345:103,pack_ani:143,pack_struct:143,packag:[11,148],pad:[13,39,40],pair:[17,19,30,34,35,37,48,63,69,96,109,120,121,123],pairwithrestrictionfn:96,pane:127,parallel:[5,11,16,19,21,25,34,121,124,148],param:[38,118],paramet:[1,8,9,11,13,14,15,16,17,18,19,21,24,25,26,27,28,30,31,32,33,34,35,36,38,39,40,42,45,46,48,51,54,55,56,57,63,66,67,69,74,79,82,83,85,87,88,89,90,95,108,109,110,112,113,115,118,121,124,127,129,130,132,133,135,137,139,144,145,146],parameter:137,parameter_typ:[1,124,146],pardo:[21,34,63,82,95,96,121,124],pardo_payload:121,parent:[40,142],pars:[13,39,42,48,102,103,105,109,110,143],parse_arg:[102,109],parse_byt:143,parse_byte_s:109,parse_int:132,parseeventfn:103,parser:48,part:[1,16,17,19,21,30,34,35,45,48,67,69,82,121],partial:[27,34,81,121],partialgroupbykeycombiningvalu:81,particular:[13,34,38,39,40,42,107,124,129,135],partit:[21,27,28,34,121,137],partition_for:121,partitionfn:121,partitionid:27,pass:[1,13,15,17,19,21,30,33,34,35,40,42,48,67,82,102,105,109,113,121,124,127,130,132,146],past:[34,69],patch:112,patch_retri:112,path:[13,15,16,17,19,27,30,31,33,34,35,39,40,42,49,89,108,112,121,140],pathnam:[17,19,30,33,35],pattern:[13,16,17,19,31,39,40,42,49,113,124,144],payload:[32,146],payload_typ:61,pbegin:[34,67,70,89,111,121],pc1:[109,129],pc2:[109,129],pc3:129,pcoll1:129,pcoll:[13,21,25,32,34,39,40,51,63,67,81,82,89,96,110,120,121,124,129],pcoll_id:89,pcollect:[1,4,13,15,21,25,34,39,42,51,63,79,82,85,87,88,89,95,96,109,111,113,115,120,121,124,129,130,148],pcollection_stat:88,pcolls_to_pcoll_id:89,pcolls_to_writ:89,pdf:42,peform:121,pend:95,per:[21,63,79,81,116,118,121,129,144],per_bundle_delay_sec:109,per_element_cost:129,per_element_delay_sec:109,percent_complet:69,percentag:69,perel:120,perfectli:34,perform:[1,13,16,17,19,25,29,34,38,39,82,96,101,102,103,105,106,107,109,115,116,117,121,129,130,136,139],perform_multi_threaded_test:38,perhap:69,period:[25,87,130],perkei:120,permanentexcept:[8,144],permit:137,persist:[95,121],person:[101,102,103],phase:[34,42,112],phaseset:42,phred:42,physic:77,pick:[1,123],pickl:[1,4,10,34,110,146],picklabl:34,pickle_urn:146,picklecod:[1,10,34],pickler:[6,148],piec:83,pipe:[18,124],pipelin:[1,5,11,13,16,21,32,33,34,39,40,42,45,46,48,49,56,57,63,64,65,67,71,72,73,76,78,79,82,87,88,89,90,94,95,96,101,102,103,105,106,107,108,109,110,111,113,121,123,124,125,129,136,148],pipeline_context:[64,148],pipeline_graph:[64,86,88,148],pipeline_info:[87,89],pipeline_opt:[17,19,30,33,35,47,49,50,79,123,148],pipeline_options_valid:[47,148],pipeline_proto:[87,88,90],pipeline_result:108,pipeline_verifi:[97,148],pipelinecontext:[1,94,146],pipelineerror:[5,51],pipelinegraph:[88,90],pipelineinfo:[87,89],pipelineopt:[17,19,30,35,48,49,51,110,123],pipelineoptionsvalid:49,pipelineresult:[89,95],pipelinerunn:[51,67,78,89,95,110,148],pipelinest:[95,108],pipelinestatematch:108,pipelinevisitor:[51,76,136],pipestream:18,place:[9,11,63,121,124,130,144],placehold:[11,13,16,39,40],plain:63,plane:55,platform:141,pleas:[16,34,49,109],plugin:[17,138,148],pobject:121,point:[1,13,28,34,79,83,130,135,144,145],poll:67,poll_for_job_complet:67,pool:[11,48],pool_siz:11,pop_on:134,pop_thre:134,pop_top:134,pop_two:134,popen:141,popul:[51,123],portabl:148,portion:121,pos:[14,36],posit:[11,14,17,18,34,36,37,38,42,49,69,111,121,132],position_at_fract:[14,34,36],position_for_fract:38,position_to_fract:36,positional_hint:132,possibl:[1,16,19,21,34,38,49,88,121],potenti:[63,79],power:148,practic:34,pre:[34,81,121],pre_fin:[15,34],pre_finalize_result:34,preced:129,precis:[130,145],predecessor:145,prefer:[1,17,146],prefix:[13,17,19,30,39,40,89],prepar:[21,56],preparationid:56,presenc:139,present:[18,21,42,54,120],preserv:[38,51],prespecifi:109,prevent:[16,34,46,129],previou:[21,34,82,111],previous:24,price:[101,103,106],primari:[34,69],primarii:109,primarili:14,primary_range_track:38,primit:[1,70,78,82,96,121,130,137],print:[88,118,135,139],print_item:134,print_newlin:134,prior:34,prob:42,problem:95,proce:121,proces:96,process:[1,4,17,21,25,34,63,69,70,73,75,79,81,82,83,85,92,93,96,103,109,111,115,121,124,127,128,129,130,136,138,142,148],process_continu:82,process_element_invok:82,process_keyed_elements_transform:82,process_st:80,process_to_termin:103,processcontinu:82,processdata:21,processel:82,processfn:82,processingtimeev:111,processkeyedel:96,processkeyedelementsviakeyedworkitem:82,processkeyedelementsviakeyedworkitemsoverrid:82,produc:[1,13,34,38,39,51,63,76,79,82,89,109,111,121,129,139],profil:[129,138,148],profile_id:142,profile_loc:142,profilingopt:48,program:[21,127,134,148],progress:[36,55,69,95,121],project:[8,21,25,27,32,49,102],project_id_pattern:49,project_number_pattern:49,promis:34,proper:[124,132],properli:[34,82,132],properti:[28,34,38],propertiesfromenumtyp:61,propertiesfromenumvalu:61,propertiesfrompayloadtyp:61,proto:[27,46,51,63,87,88,89,90,94,121,124,127],proto_map:89,proto_message_typ:1,proto_util:[138,148],protobuf:[1,143],protoc:1,protocod:1,protocol:[1,34],provid:[1,11,13,17,18,19,21,25,28,30,32,34,35,36,37,50,51,57,79,83,85,89,94,95,110,111,121,124,129,132,146,148],provis:57,provisionserviceservic:57,provisionservicestub:57,pseudo:34,pseudocod:38,ptransform:[4,5,13,21,25,32,34,39,40,42,51,63,67,70,71,76,79,80,81,82,87,88,89,96,109,111,113,119,120,121,123,129,137,148],ptransform_arg:96,ptransform_fn:124,ptransform_kwarg:96,ptransform_overrid:[64,65,148],ptransform_side_input:96,ptransform_test:41,ptransformoverrid:[51,67,71,82,96],ptransformwithsideinput:121,pub:32,publish:32,pubsub:[12,20,103,112,148],pubsubmessag:32,pull:63,pure:3,purpos:110,push_valu:134,put:[10,18,95],putartifact:54,pvalu:[5,11,13,32,34,39,40,42,51,76,95,121,124,125,148],pvalue_class:11,pvalueerror:5,pvalueish:[51,89,124],python:[1,3,5,9,10,13,18,33,34,48,62,70,89,102,103,110,115,116,117,121,132,133,134,135,137,144],python_urn:[52,148],pyvcf:42,pyx:3,qualiti:[42,139],queri:[21,25,26,27,28,66,77,87,95,97,98,99,101,102,103,148],query0:[97,98,99,102,104,148],query1:[97,98,99,104,148],query2:[97,98,99,104,148],query_arg:[102,105,106],query_error:102,query_latest_statistics_timestamp:25,query_result:21,query_splitt:[12,20,22,23,148],queryiter:27,querysplitt:28,querysplitterimpl:28,question:[30,35,118,139],quickstart:21,quit:9,quot:89,race:34,rais:[1,5,9,15,16,17,18,19,21,27,30,31,33,34,35,38,48,51,95,109,110,113,121,123,124,132,133,135,144],random:[1,18,26,28,115,116,129,144],random_str:115,random_windowed_valu:115,randomli:144,randomuniquekeyfn:96,rang:[14,16,18,34,36,37,38,69,130],range_track:[12,14,16,34,38,41,109,148],rangetrack:[14,16,34,36,38],rather:[1,21,42,132,134,146],ratio:24,raw:[34,103,111],raw_byt:67,raw_ev:[105,106,107],rawiobas:18,reach:[18,144],reachabl:[67,95],read:[1,3,13,14,16,17,18,19,21,25,27,30,31,32,34,35,38,39,40,41,42,69,79,89,109,148],read_al:3,read_bigendian_doubl:3,read_bigendian_int32:3,read_bigendian_int64:3,read_bigendian_uint64:3,read_buffer_s:31,read_byt:3,read_from_sourc:38,read_record:16,read_siz:17,read_var_int64:3,readabl:[17,18],readallfil:13,readallfromavro:13,readallfromtext:39,readcach:89,reader:[21,34,69],readerposit:69,readerprogress:69,readfn:25,readfromavro:13,readfromdatastor:25,readfrompubsub:32,readfromsourc:38,readfromtext:[39,148],readfromtfrecord:40,readfromvcf:42,readi:[108,148],readinto:18,readlin:17,readstringsfrompubsub:32,real:[11,75],real_tim:[126,127],realclock:75,realiti:121,realli:4,reason:[4,121,144],rebalanc:[34,38],receiv:[34,38,83,102,103,105,121,132],recent:29,recommend:[13,38,39,110,139],record:[13,15,16,27,32,34,38,40,42,69,89],record_current_posit:34,record_index:69,record_start:36,recurs:[17,19,30,31,35],recv_pip:18,redefinit:48,reduc:[13,39,95,121],reduct:121,redund:34,reentrant:[34,38],refer:[21,34,38,42,46,51,124],referenc:[87,88,94],reference_bas:42,reference_nam:42,reference_source_info:38,referenced_pcollect:[87,88],refsnp:42,refus:34,regist:[1,4,19,51,80,110,146],register_cod:4,register_observ:2,register_pickle_urn:146,register_structured_urn:1,register_urn:[1,124,146],registr:[4,146],registri:[1,4],regular:137,reify_window:113,reifywindow:121,reimplement:123,reject:123,rel:[17,18,69],relat:[5,34,46,55,76,124],releas:[82,83,139],relev:31,reli:[21,113],remain:[18,34,69],remaining_split_point:69,remaining_tim:69,remot:[21,32,67,144],remov:[39,129,139],remove_objects_from_arg:11,removedupl:129,renam:[17,19,30,31,33,34,35],render:88,repeat:21,repeatedli:[121,127],replac:[11,13,39,40,51,96,112,120,121,134,139],replace_al:51,report:[34,55,85,121,142,144],report_current_posit:34,report_onc:142,repres:[11,16,17,21,32,34,37,38,42,44,48,63,69,95,121,123,125,127,145,148],represent:[21,69,88,90,123,130],request:[17,18,24,25,26,27,36,45,54,55,56,57,69,79,82,144],request_dynamic_split:69,request_iter:[54,55],requir:[1,4,9,13,21,34,39,48,49,121,139],required_transform:[87,88],reserv:137,reserve_pric:[101,103],reset:127,reshuffl:129,reshuffleperkei:129,residu:[34,69,82],residual_range_track:38,residual_restrict:82,resolut:95,resourc:[34,57,110],respect:[13,21,34,38,39,40,42],respond:[66,77],respons:[4,17,19,26,27,55,56,80,82],rest:34,restrain:121,restrict:[34,45,82,96],restriction_cod:96,restriction_track:[12,148],restrictionprovid:121,restrictiontrack:[34,37,82,121],result:[1,10,11,16,17,21,25,28,34,38,42,44,45,48,67,69,79,80,81,82,84,87,88,95,108,118,120,121,124,129,130,132,139,142],result_pcol:124,resum:82,retri:[8,27,34,108,112,138,148],retriev:[11,18,54,87,132],retry_filt:144,retry_on_beam_io_error_filt:144,retry_on_io_error_and_server_error:108,retry_on_rpc_error:27,retry_on_server_errors_and_timeout_filt:144,retry_on_server_errors_filt:144,return_context:51,return_type_hint:132,returns_windowed_valu:69,revers:129,rewind:17,rfc3339:145,rfc:[32,145],rfc_3339_re:145,right:[38,51,144],right_fract:38,right_result:38,role:101,roll:29,root:[79,80,83],root_transform:[79,85],rootbundleprovid:83,rot_four:134,rot_n:134,rot_thre:134,rot_two:134,rotate_kei:109,row:21,rowasdictjsoncod:21,rpc:[24,27,45,144],rpc_stats_callback:27,rpcerror:27,rule:27,run:[5,8,10,11,28,34,51,53,56,67,72,79,80,83,88,89,95,102,103,109,110,115,116,117,118,121,123,137],run__nativewrit:67,run_abc:95,run_async:95,run_benchmark:[116,117,118],run_coder_benchmark:115,run_combinevalu:67,run_command:92,run_flatten:67,run_groupbykei:67,run_impuls:67,run_pardo:67,run_pipelin:[67,72,78,89,95],run_queri:[26,102],run_read:67,run_transform:95,run_using_threadpool:11,runner:[5,21,25,34,45,49,51,55,110,111,121,124,148],runnerapi:56,runnerapifn:[1,121,130,146],runnererror:5,runtim:[1,5,16,25,57,132,136],runtime_opt:[17,30,35,50],runtimeerror:[5,51],runtimevalueprovid:[17,30,35,50],runtimevalueprovidererror:5,safe:[34,77,88,90],safefastprimitivescod:89,safeti:34,sai:[4,34],same:[1,4,16,17,19,21,27,30,31,34,35,38,39,42,46,51,63,69,74,95,109,113,120,121,130,133,139,144],sampl:[1,21,89,120,128],samtool:42,satisfi:[34,135],save:142,save_modul:10,scale:42,scatter:26,scenario:[21,34],schedul:[76,80],schedule_pending_unblocked_task:79,schema:[13,21,42],schema_as_json:21,scheme:[17,19,30,33,34,35,49],scope:26,score:42,sdf:[70,82,96],sdf_common:[64,148],sdf_direct_runn:[64,73,148],sdf_invok:82,sdfprocesselementinvok:82,sdist:53,sdk:[29,34,55,57,62,67,132,137,147],sdk_locat:102,sdkfunctionspec:[1,146],search:144,second:[4,27,32,38,75,108,109,111,118,124,129,130,134,142,144,145],section:34,see:[4,13,16,19,24,25,33,34,38,39,40,48,49,51,82,95,109,121,124,127,129,130],seed:[115,116],seek:[17,18],seek_cur:[17,18],seek_end:[17,18],seek_set:[17,18],seekabl:[16,17,18],select:[21,27,63,107],self:[1,2,34,118,121,123,124,128,132,145,146],seller:[101,103],semant:[25,34,111,124,127,131,137],send:[24,55,102,105],sens:4,sent:[24,55,121],separ:[21,42,109,121,130,132],sequenc:[34,42,115,116,135],sequenti:[18,34,54],seri:[101,102,103,105,106,107,109,130],serial:[4,21,34,51,83,94,146],serializ:[111,129],serialize_windowing_strategi:67,serialized_data:67,serv:105,server:[54,55,56,57,144],servic:[8,13,21,34,39,48,49,54,55,56,57,66,67,69,108,144],session:[10,130],set:[4,13,14,16,17,18,19,21,24,25,31,34,38,39,40,42,45,46,48,49,50,63,67,79,82,85,87,88,95,108,109,121,127,129,130,132,137,139,144],set_current_posit:[14,34,36],set_opt:19,set_process_element_invok:82,set_proto_map:89,set_running_in_gc:8,set_runtime_opt:50,set_split_points_unclaimed_callback:[34,36],setup:[34,53,82,110],setupopt:[48,49],sever:[12,14,21,69,113,118,121,124,129],sha1:112,shape:109,shard:[13,15,28,39,40,113],shard_name_templ:[13,15,39,40],share:[21,74,79],shift:51,shortvalu:123,should:[10,11,16,17,18,19,21,24,30,32,34,35,39,46,51,63,69,82,83,95,96,108,110,111,113,116,120,121,123,125,127,129,132,137,142,144,146,148],should_drop:123,should_execute_seri:83,should_fir:127,shown:123,shuffl:[69,121],shuffle_posit:69,shufflebarri:109,shuffler:4,shutdown:80,side:[5,11,21,24,63,79,81,109,117,121,125,129],side_input:[21,79,83,124],side_input_valu:80,side_input_visitor:67,side_inputs_contain:85,side_t:21,sideinput:[119,148],sideinput_microbenchmark:[114,148],sideinputbarri:109,sideinputerror:5,sideinputmap:125,sideinputparam:121,signal:[18,21,34],signatur:[95,121,144],signifi:139,signific:[25,148],significantli:[13,34,129],similar:29,similarli:21,simpl:[1,13,45,106,107,118,121,129,130,132,135,137,144,148],simplefilt:139,simpler:[9,34,124],simpli:[48,105,121,142],simul:[101,102,103,105,106,107],sinc:[1,4,21,24,25,32,34,75,113,130,139,145],singl:[13,15,16,18,21,25,34,42,44,73,77,78,84,120,121,129,130,132],singleton:63,singletoncod:1,sink:[12,15,17,21,32,34,39,40,69,148],sinkwrit:69,size:[1,3,11,13,16,17,18,19,25,30,31,33,34,35,39,81,109,115,118,129,130,148],size_in_byt:17,skip:[38,39,112,121],skip_header_lin:39,sleep:[27,112,144],sleep_sec:108,slice_0:134,slice_1:134,slice_2:134,slice_3:134,slide:130,slidingwindow:130,slot:130,slow_stream:[0,148],small:[21,28],small_dict:115,small_int:115,small_list:115,small_str:115,small_tupl:115,smaller:[27,32,129,145],smallest:[120,129],smallestperkei:120,snapshot:85,solut:124,some:[21,34,38,80,83,95,121,124,129,142,148],somefn:124,someth:[69,142],sometim:[4,121],soon:34,sortbi:142,sourc:[1,2,3,5,8,9,10,11,12,13,14,15,16,17,18,19,21,24,25,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41,42,44,45,46,48,49,50,51,54,55,56,57,61,63,66,67,69,70,71,72,74,75,76,77,78,79,80,81,82,83,84,85,87,88,89,90,92,93,94,95,96,101,102,103,105,106,107,108,109,110,111,112,113,115,116,117,118,120,121,123,124,125,126,127,128,129,130,132,133,134,135,136,137,139,140,141,142,143,144,145,146,148],source_bundl:14,source_file_nam:[17,19,30,33,35],source_frac:14,source_index:14,source_info:38,source_ix:14,source_posit:14,source_test_util:[12,148],source_test_utils_test:38,sourcebas:[34,69],sourcebundl:34,sourcereaderprogress:69,sources_info:38,space:[4,144],speak:92,spec:42,special:[21,70,89,121],specif:[13,34,39,44,48,51,62,63,69,70,79,82,83,96,109,121,128],specifi:[4,9,13,16,17,19,21,25,30,32,34,35,39,42,48,49,51,63,67,69,79,82,109,110,111,118,121,124,127,128,129,130,132,135,137,139,148],specul:127,spent:27,split:[13,14,16,17,19,21,25,28,30,33,34,35,36,37,38,39,41,55,66,69,96,109,121],split_fract:[34,38],split_offset:36,split_point:[34,36],split_points_unknown:34,split_posit:[34,38],split_result:38,splitfractionstatist:38,splitqueryfn:25,splitrestrictionfn:96,splittabl:[16,34,82,96,121],splittabledofn:[70,96],splittablepardo:96,splittablepardooverrid:96,splitter:28,sql:21,src:[28,31],src_dest_pair:31,sre:24,sre_pattern:[19,145],sssss:[13,39,40],stabl:[55,148],stack:[74,134,135],stage:[34,54],staging_loc:102,stai:[34,69],stand:34,standard:[17,21,48,124,144],standard_window_fns_pb2_grpc:[52,53,148],standardopt:[48,49],star:142,start:[14,18,33,34,36,37,38,42,48,49,80,87,92,95,101,103,108,130,142],start_bundl:[25,81,96,109,121,136],start_periodic_upd:87,start_posit:[14,16,34,36,37,38,41,109],start_stat:80,startup:[8,140],stat:[25,38,87],state:[34,55,56,66,67,72,77,79,82,83,95,101,103,108,127,128,134,135],state_sampl:80,statement:148,stateparam:121,statespec:128,staticvalueprovid:50,statist:[25,27,46],statu:[87,95,144],stdout:118,step:[1,4,21,34,45,66,79,82,89,95,109],step_context:82,step_label:1,step_nam:79,still:[16,34,55,148],sting:21,stop:[34,37,38,87,95,142],stop_periodic_upd:87,stop_posit:[14,16,34,36,37,38,41,69,109],storag:[31,34,48,49,121],storage_api_servic:48,storage_cli:31,store:[17,19,24,38,42,51,55,70,130,135,145],store_attr:134,store_fast:134,store_glob:134,store_map:134,store_slice_0:134,store_slice_1:134,store_slice_2:134,store_slice_3:134,store_subscr:134,str:[1,9,13,15,16,18,21,27,31,32,38,39,42,51,87,88,89,90,110,112,123,132,137],straight:9,strategi:145,stream:[3,15,17,18,19,21,30,31,32,33,35,56,67,70,71,78,101,102,103,105,106,107,111,121,126,148],streaming_cr:[64,65,68,148],streamingcr:70,stress:38,strictli:[4,32],string:[1,9,13,16,17,18,19,21,30,32,33,35,36,39,40,42,45,46,49,63,69,108,109,112,113,115,118,123,143,145],string_valu:123,stringutil:67,strip_trailing_newlin:39,strongli:38,struct:143,struct_obj:93,struct_to_dict:93,structur:[9,17,19,30,35],strutf8cod:[1,39],style:17,sub:[16,25,32,34,69,95,112,121],sub_range_track:14,subclass:[2,4,34,36,38,41,46,48,49,120,121,123,124,130,140],subclassess:49,subcompon:123,subdirectori:148,subject:[32,139],submit:[56,67],submodul:[22,98],subprocess:141,subscrib:56,subscript:[32,112],subsequ:[34,69,144],subset:137,subsystem:4,subtrigg:127,succe:[34,38],succeed:[24,31,34],success:[24,27,34,69],successful_request:24,successfulli:[34,54,67],suffici:69,suffix:[13,17,39,40,112],suggest:[34,139],suggested_split_posit:38,suit:[101,102,103,105,106,107],suitabl:[1,83,121],sum:[29,44,121],sunnyval:103,suppli:[51,63,110],support:[1,9,13,17,18,21,30,32,33,34,35,39,51,69,78,95,121,123,124,127,132,136],suppos:26,sure:[49,82,96,108],surround:129,switchingdirectrunn:78,symmetric_binary_op:134,sync:83,syntax:[1,9,21,121,131,137],synthet:109,synthetic_pipelin:[97,148],syntheticsourc:109,syntheticstep:109,sys:[48,51,110],system:[17,19,25,30,33,34,35,110,127],tabl:[21,25,34],table_row:21,table_schema:21,table_schema_to_dict:21,tablecel:21,tablefieldschema:21,tablerefer:21,tablerow:21,tablerowjsoncod:21,tableschema:21,tag1:129,tag2:129,tag:[63,110,121,129],taggedoutput:63,tail:[17,19,30,35],take:[11,34,51,69,113,118,121],taken:129,takes_windowed_valu:69,tar:102,target:[24,129],target_batch_duration_sec:129,target_batch_overhead:129,target_window_fn:125,task:[34,79],techniqu:21,tell:[17,18],temp_dir:89,temp_loc:102,temp_path:15,tempdir:112,templat:[13,39,40,50],temporari:[32,34,112,129],temporarili:144,term:[21,34],termin:[34,72,82,103,108],test:[21,26,38,49,72,75,129,144,148],test_bigquery_cli:21,test_client:21,test_dataflow_runn:[64,65,148],test_method:82,test_pipelin:[97,148],test_read_metr:41,test_runner_api:[51,110],test_stream:[97,148],test_util:[97,148],testcas:112,testclock:75,testdataflowrunn:72,testopt:[48,49],testpipelin:110,testrunn:110,teststream:111,testwindowedvalu:113,text:[34,39,51,148],textio:[12,148],tfrecord:40,tfrecordio:[12,148],than:[1,17,19,21,25,28,32,34,36,42,111,121,129,132,134,145,146],thei:[17,34,38,46,63,83,113,121,130],them:[10,34,67,121],themselv:[45,63,137],therebi:121,therefor:17,thi:[1,4,8,11,13,15,16,17,18,19,21,24,25,27,28,29,30,31,32,34,35,36,38,39,40,42,44,45,46,48,51,54,55,63,64,65,69,70,73,74,76,78,79,82,83,87,88,89,90,95,96,103,105,106,107,108,109,110,112,113,115,116,121,123,124,125,127,128,129,130,132,135,137,139,142,144,145,146,148],thing:[34,142],those:[1,13,21,34,70,87,88,110,121,123],thread:[11,34,38,77,87,88,90],three:[4,32,34,38,45,101],throttl:[24,27],throttle_delai:27,throttle_request:24,throttled_sec:27,throttler:[24,27],through:[25,34,36,40,49,51,102,105,109,121,144],throughout:[11,21],throughput:78,thu:129,till:82,time:[4,11,13,16,21,24,27,32,34,39,40,42,67,69,75,82,83,95,108,111,116,117,118,120,121,126,127,129,130,137,140,144,145],time_domain:[84,127,128],time_in_m:102,timedelta:123,timedomain:[126,128],timeout:[72,95,103,112,144],timer:[79,82,84,85,126,127,128],timer_fir:84,timer_spec:128,timerfir:84,timerparam:121,timerspec:128,timestamp:[1,25,27,32,44,74,82,84,85,101,103,111,113,121,123,126,127,130,138,148],timestamp_attribut:32,timestamp_combin:[121,130],timestampcod:1,timestampcombin:130,timestamped_valu:111,timestampedvalu:[111,130],timestampparam:[82,121],timeutil:[1,119,130,148],timezon:32,to_be_merg:[127,130],to_delete_mut:25,to_json_valu:9,to_low:132,to_rfc3339:145,to_runner_api:[1,46,51,63,94,121,124,127,146],to_runner_api_paramet:[1,32,34,121,124,130,146],to_runner_api_pickl:124,to_upsert_mut:25,to_utc_datetim:145,todict:120,todo:[51,70],togeth:[46,121],toggl:132,toler:[34,42],tolist:120,too:[28,38,121],took:[1,146],tool:[21,148],top:[51,120,132,134,148],topic:[32,112],tostringcod:39,total:[34,38,69,120,129,132,144],track:[29,34,36,44,46,76,77,79,83,85],tracker:[14,29,34,36,38,82],transform:[4,13,14,21,25,32,34,39,40,41,42,45,48,51,63,67,69,70,74,76,78,79,81,82,83,85,87,88,89,95,96,103,109,111,113,136,148],transform_evalu:[64,73,82,84,148],transform_evaluation_st:80,transform_evaluator_registri:80,transform_keyed_st:85,transform_nod:[67,95],transform_proto:89,transformerror:5,transformevalu:[80,83,84],transformevaluatorregistri:83,transformexecutor:80,transformresult:[79,84],transformss:96,transformwatermark:85,translat:[51,66],travers:[48,51],treat:145,treatment:121,tree:[17,30,35,109],tri:144,trigger:[79,119,121,148],triggercontext:127,triggerfn:[121,127],trivial:[38,121,135],trivial_infer:[131,148],try_claim:[14,34,36,37],try_split:[14,34,36,38],tupl:[1,9,11,14,27,31,34,38,42,63,109,113,120,121,129,132,137,146],tuplecod:1,tuplesequencecod:1,turn:[21,144],twice:[10,34],two:[4,13,17,19,30,32,33,34,35,38,69,109,121,132,135,137,139],txt:112,typ:133,type1:21,type2:21,type3:21,type:[1,2,3,4,9,11,13,16,17,18,19,21,24,27,29,30,31,32,34,35,36,37,38,42,44,45,46,49,50,51,55,61,63,69,74,75,77,79,80,82,83,84,85,92,94,95,96,110,111,112,121,123,124,129,131,132,133,135,136,137,140,142,144,145,146],type_1:132,type_2:132,type_check:137,type_check_input:124,type_check_inputs_or_output:124,type_check_output:124,type_hint:[124,132,136],typecheck:[131,148],typecheckcombinefn:136,typecheckerror:132,typecheckvisitor:136,typecheckwrapperdofn:136,typecod:[0,148],typeconstraint:[124,132,135,137],typedict:123,typeerror:[9,15,16,21,51,121,124],typehint:[1,4,121,124,148],typeinferenceerror:135,typeopt:[48,49],typevari:137,typic:[16,39,40,42,51,95,116,121,124,139],uid:34,ultim:132,unabl:25,unari:134,unary_convert:134,unary_invert:134,unary_neg:134,unary_not:134,unary_posit:134,unavail:28,unbound:[69,70,111,130,148],unclaim:34,uncommit:79,uncommitted_output_bundl:84,uncommittedbundl:74,uncompress:17,unconsum:34,undeclar:121,undeclared_tag_valu:84,under:[25,32,102,121,129],underli:[17,19,28,39,42,79,124,127,130,135],underlying_result:89,underlying_runn:89,underscor:21,undesir:4,unfinish:34,unicod:[32,123],union:[14,38,95,130,135,137],union_list:135,uniqu:[32,34,45,63,96,120,129],unit:[26,32,38,123,130],unittest:112,unix:[17,32,111,130,145],unknown:[1,34,95,109],unless:[13,18,39,63,130],unmergedst:79,unpack:[132,143],unpack_ani:143,unpack_sequ:134,unpickl:[49,110],unprocess:[34,82],unprocessed_bundl:[84,85],unquot:89,unsplitt:[34,36],unsplittablerangetrack:36,unstart:36,until:[56,67,72,81,83,95,110,121],unused_arg:[96,103,121,132,134],unused_context:[1,121,124,127,130,146],unused_el:70,unused_fn_paramet:130,unused_input:[34,111,121],unused_input_typ:[70,121,124],unused_kwarg:[96,103,121,132],unused_paramet:121,unused_payload:[1,121],unused_registri:1,unused_st:134,unused_transform:67,unused_typehint:1,unwrap:[111,135],unwrap_al:135,updat:[21,25,34,44,45,46,51,67,77,79,85,87,95,116],update_displai:87,update_phys:77,update_watermark:85,upload:[18,54],uploaderstream:18,upon:18,upper:[13,39,40,132],upper_bound:116,upstream:[76,121],upto:27,uqfound:10,uri:[17,30,35,49],uri_schema_pattern:19,url:[17,33,72,123],urn:[1,51,61,62,121,124,130,138,148],usabl:13,usag:[1,34,38,51,102,103,124,128,132,139,140,142],use:[1,2,3,4,6,7,8,9,10,11,13,14,17,19,21,24,25,26,27,29,30,31,32,34,35,38,39,45,46,48,49,51,52,53,54,62,63,67,69,74,75,76,80,83,84,85,94,109,110,111,112,114,115,121,125,132,134,135,136,138,139,141,142,143,144,145,146],use_fastavro:13,use_global_window:113,use_standard_sql:21,used:[1,4,10,11,13,16,17,19,21,26,30,32,34,35,36,39,40,42,44,45,46,48,51,63,64,67,69,74,75,76,79,82,83,84,87,88,95,103,108,109,110,111,113,115,121,123,124,125,127,129,130,132,137,144,146],useful:[1,79,121],user:[11,13,16,17,19,21,25,30,32,34,35,45,46,63,66,69,123,125,128,139,140],userst:[119,148],userstateutil:128,uses:[4,28,32,83,112],using:[1,4,8,9,11,17,19,25,34,39,42,51,69,78,80,96,109,111,121,124,130,132,137,139],utc:[32,145],utf:[1,32,39],util:[6,8,9,12,17,18,20,22,23,38,64,67,73,82,91,94,97,103,109,110,111,112,114,119,121,126,130,132,147,148],v31:129,v32:129,v33:129,val:3,valid:[13,16,17,21,27,39,40,42,48,49,82,110,113,121,123,124,132,137],validate_cloud_opt:49,validate_composite_type_param:124,validate_cr:21,validate_gcs_path:49,validate_optional_argument_posit:49,validate_stateful_dofn:128,validate_test_match:49,validate_writ:21,validatesrunn:110,valu:[1,2,3,5,9,10,11,13,15,16,17,19,21,25,30,32,34,35,38,39,40,42,44,45,46,48,49,50,51,63,69,70,76,81,85,89,95,109,110,111,112,113,115,116,117,118,120,121,123,125,127,128,129,130,132,133,135,143,144,145],value_cod:1,value_descriptor:61,value_provid:[47,148],value_provider_list:50,value_to_consum:[79,85],value_typ:50,valueerror:[15,16,17,18,21,31,34,38,48,51,109,110,121,123,132,133,135],valueprovid:[5,15,16,50],vari:1,variabl:[1,46],variant:42,variantcal:42,variantinfo:42,varint:3,varintcod:1,variou:[21,38,115,134],vcf:42,vcfio:[12,148],vcfv4:42,vehicl:103,verbos:[115,118,135],veri:[63,81],verif:108,verifi:[13,16,34,38,39,40,42,72,105,108,110,111,136],version:[1,42,70,139,148],vertex:90,verybig:21,vet:55,via:[51,82,88,94,130,137,146],view:[49,79],view_a:48,view_class:125,view_opt:125,violat:132,visibl:[87,88],visit:[51,95],visit_transform:[76,136],visitor:[51,76],volum:121,voluntarili:82,wai:[4,25,34,36,38,69,109,121,124,129,139],wait:[27,67,72,95,108,110,112],wait_for_subscriptions_cr:112,wait_for_topics_cr:112,wait_until_finish:[89,95],wait_until_finish_dur:102,wait_until_in_st:72,want:[4,25,34,63,95,115,144],warn:[139,144],watermark:[79,82,85,111,121,126,127,128],watermark_manag:[64,73,148],watermark_neg_inf:85,watermark_pos_inf:85,watermarkev:111,watermarkmanag:85,watermarkreporterparam:121,weather_st:21,weight:38,well:[29,34,38],were:[34,79,124,129],what:[1,21,34,109,127,130,139],whatev:[25,51,129],when:[3,8,13,16,17,18,21,25,27,32,34,38,39,40,51,53,63,79,82,87,88,111,112,121,123,124,127,135,137,145],whenc:[17,18],whenev:[4,121],where:[1,16,31,34,51,63,109,121,129,130,132,133,144,146,148],whether:[1,16,17,21,24,30,34,35,39,44,51,63,69,74,87,118,123,127,130,135],which:[1,11,13,14,16,17,21,24,25,28,32,34,36,39,40,42,55,63,64,69,70,78,82,95,109,110,121,127,129,130,132,133,136,142,144,148],who:[101,110],whole:[16,17,21,34,49,132],whose:[1,34,36,51,63,87,88,121,127,129],width:130,window:[1,29,63,67,69,74,81,82,84,96,111,113,115,119,121,124,125,127,129,148],window_cod:1,window_fn:130,window_m:[24,29],windowed_valu:130,windowedtypeconstraint:137,windowedvalu:[74,111,121,137],windowedvaluecod:1,windowfn:[121,130],windowing_strategi:96,windowinto:[121,130],windowintofn:121,windowparam:[81,82,96,121],wipe:95,wish:123,with_default:121,with_exponential_backoff:144,with_fanout:121,with_hot_key_fanout:121,with_input_typ:[4,124,132],with_nam:45,with_namespac:45,with_output:121,with_output_typ:[4,124,132],with_step:45,with_typ:9,within:[34,38,54,69,74,79,109,130],without:[16,34,120,142],without_default:121,withtypehint:[121,124,132],work:[21,27,34,38,46,51,55,69,129,132],worker:[8,10,25,34,48,57,67,69,121,140],worker_executing_project:8,workeropt:[48,49],workflow:[8,10,34,109],workitem:69,would:[1,34,63,129,130,132,146],wrap:[9,18,63,70,121,124,144],wrapped_value_cod:1,wrapper:[17,21,48,63,72,94,110,124,132,136,142],writabl:18,write:[1,3,4,13,15,17,18,19,21,25,26,27,30,31,32,34,35,39,40,51,69,79,89,109,146,148],write_:15,write_append:21,write_bigendian_doubl:3,write_bigendian_int32:3,write_bigendian_int64:3,write_bigendian_uint64:3,write_byt:3,write_disposit:21,write_empti:21,write_encoded_record:15,write_mut:27,write_record:15,write_result:34,write_trunc:21,write_var_int64:3,writeabl:17,writecach:89,writeimpl:34,writer:[21,34,45,69,125],writer_result:[15,34],writestringstopubsub:32,writetoavro:13,writetobigqueri:21,writetodatastor:25,writetotext:[39,51,148],writetotfrecord:40,writetrunc:21,written:[13,15,17,18,19,21,30,34,35,39,40,112],wrong:42,wrote:34,wv_with_multiple_window:115,wv_with_one_window:115,xrang:139,xyz:[4,48,95],xyzcod:4,xyzopt:48,year:21,yet:[34,78],yield:[2,16,34,121,144],you:[13,25,39,48,49,123],your:[38,49,148],zero:[34,121]},titles:["apache_beam.coders package","apache_beam.coders.coders module","apache_beam.coders.observable module","apache_beam.coders.slow_stream module","apache_beam.coders.typecoders module","apache_beam.error module","apache_beam.internal package","apache_beam.internal.gcp package","apache_beam.internal.gcp.auth module","apache_beam.internal.gcp.json_value module","apache_beam.internal.pickler module","apache_beam.internal.util module","apache_beam.io package","apache_beam.io.avroio module","apache_beam.io.concat_source module","apache_beam.io.filebasedsink module","apache_beam.io.filebasedsource module","apache_beam.io.filesystem module","apache_beam.io.filesystemio module","apache_beam.io.filesystems module","apache_beam.io.gcp package","apache_beam.io.gcp.bigquery module","apache_beam.io.gcp.datastore package","apache_beam.io.gcp.datastore.v1 package","apache_beam.io.gcp.datastore.v1.adaptive_throttler module","apache_beam.io.gcp.datastore.v1.datastoreio module","apache_beam.io.gcp.datastore.v1.fake_datastore module","apache_beam.io.gcp.datastore.v1.helper module","apache_beam.io.gcp.datastore.v1.query_splitter module","apache_beam.io.gcp.datastore.v1.util module","apache_beam.io.gcp.gcsfilesystem module","apache_beam.io.gcp.gcsio module","apache_beam.io.gcp.pubsub module","apache_beam.io.hadoopfilesystem module","apache_beam.io.iobase module","apache_beam.io.localfilesystem module","apache_beam.io.range_trackers module","apache_beam.io.restriction_trackers module","apache_beam.io.source_test_utils module","apache_beam.io.textio module","apache_beam.io.tfrecordio module","apache_beam.io.utils module","apache_beam.io.vcfio module","apache_beam.metrics package","apache_beam.metrics.cells module","apache_beam.metrics.metric module","apache_beam.metrics.metricbase module","apache_beam.options package","apache_beam.options.pipeline_options module","apache_beam.options.pipeline_options_validator module","apache_beam.options.value_provider module","apache_beam.pipeline module","apache_beam.portability package","apache_beam.portability.api package","apache_beam.portability.api.beam_artifact_api_pb2_grpc module","apache_beam.portability.api.beam_fn_api_pb2_grpc module","apache_beam.portability.api.beam_job_api_pb2_grpc module","apache_beam.portability.api.beam_provision_api_pb2_grpc module","apache_beam.portability.api.beam_runner_api_pb2_grpc module","apache_beam.portability.api.endpoints_pb2_grpc module","apache_beam.portability.api.standard_window_fns_pb2_grpc module","apache_beam.portability.common_urns module","apache_beam.portability.python_urns module","apache_beam.pvalue module","apache_beam.runners package","apache_beam.runners.dataflow package","apache_beam.runners.dataflow.dataflow_metrics module","apache_beam.runners.dataflow.dataflow_runner module","apache_beam.runners.dataflow.native_io package","apache_beam.runners.dataflow.native_io.iobase module","apache_beam.runners.dataflow.native_io.streaming_create module","apache_beam.runners.dataflow.ptransform_overrides module","apache_beam.runners.dataflow.test_dataflow_runner module","apache_beam.runners.direct package","apache_beam.runners.direct.bundle_factory module","apache_beam.runners.direct.clock module","apache_beam.runners.direct.consumer_tracking_pipeline_visitor module","apache_beam.runners.direct.direct_metrics module","apache_beam.runners.direct.direct_runner module","apache_beam.runners.direct.evaluation_context module","apache_beam.runners.direct.executor module","apache_beam.runners.direct.helper_transforms module","apache_beam.runners.direct.sdf_direct_runner module","apache_beam.runners.direct.transform_evaluator module","apache_beam.runners.direct.util module","apache_beam.runners.direct.watermark_manager module","apache_beam.runners.interactive package","apache_beam.runners.interactive.display_manager module","apache_beam.runners.interactive.interactive_pipeline_graph module","apache_beam.runners.interactive.interactive_runner module","apache_beam.runners.interactive.pipeline_graph module","apache_beam.runners.job package","apache_beam.runners.job.manager module","apache_beam.runners.job.utils module","apache_beam.runners.pipeline_context module","apache_beam.runners.runner module","apache_beam.runners.sdf_common module","apache_beam.testing package","apache_beam.testing.benchmarks package","apache_beam.testing.benchmarks.nexmark package","apache_beam.testing.benchmarks.nexmark.models package","apache_beam.testing.benchmarks.nexmark.models.nexmark_model module","apache_beam.testing.benchmarks.nexmark.nexmark_launcher module","apache_beam.testing.benchmarks.nexmark.nexmark_util module","apache_beam.testing.benchmarks.nexmark.queries package","apache_beam.testing.benchmarks.nexmark.queries.query0 module","apache_beam.testing.benchmarks.nexmark.queries.query1 module","apache_beam.testing.benchmarks.nexmark.queries.query2 module","apache_beam.testing.pipeline_verifiers module","apache_beam.testing.synthetic_pipeline module","apache_beam.testing.test_pipeline module","apache_beam.testing.test_stream module","apache_beam.testing.test_utils module","apache_beam.testing.util module","apache_beam.tools package","apache_beam.tools.coders_microbenchmark module","apache_beam.tools.distribution_counter_microbenchmark module","apache_beam.tools.sideinput_microbenchmark module","apache_beam.tools.utils module","apache_beam.transforms package","apache_beam.transforms.combiners module","apache_beam.transforms.core module","apache_beam.transforms.create_source module","apache_beam.transforms.display module","apache_beam.transforms.ptransform module","apache_beam.transforms.sideinputs module","apache_beam.transforms.timeutil module","apache_beam.transforms.trigger module","apache_beam.transforms.userstate module","apache_beam.transforms.util module","apache_beam.transforms.window module","apache_beam.typehints package","apache_beam.typehints.decorators module","apache_beam.typehints.native_type_compatibility module","apache_beam.typehints.opcodes module","apache_beam.typehints.trivial_inference module","apache_beam.typehints.typecheck module","apache_beam.typehints.typehints module","apache_beam.utils package","apache_beam.utils.annotations module","apache_beam.utils.plugin module","apache_beam.utils.processes module","apache_beam.utils.profiler module","apache_beam.utils.proto_utils module","apache_beam.utils.retry module","apache_beam.utils.timestamp module","apache_beam.utils.urns module","apache_beam.version module","Apache Beam SDK for Python"],titleterms:{adaptive_throttl:24,annot:139,apach:148,apache_beam:[0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,21,22,23,24,25,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41,42,43,44,45,46,47,48,49,50,51,52,53,54,55,56,57,58,59,60,61,62,63,64,65,66,67,68,69,70,71,72,73,74,75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96,97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113,114,115,116,117,118,119,120,121,122,123,124,125,126,127,128,129,130,131,132,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147],api:[53,54,55,56,57,58,59,60],auth:8,avroio:13,beam:148,beam_artifact_api_pb2_grpc:54,beam_fn_api_pb2_grpc:55,beam_job_api_pb2_grpc:56,beam_provision_api_pb2_grpc:57,beam_runner_api_pb2_grpc:58,benchmark:[98,99,100,101,102,103,104,105,106,107],bigqueri:21,bundle_factori:74,cell:44,clock:75,coder:[0,1,2,3,4],coders_microbenchmark:115,combin:120,common_urn:61,concat_sourc:14,consumer_tracking_pipeline_visitor:76,core:121,create_sourc:122,dataflow:[65,66,67,68,69,70,71,72],dataflow_metr:66,dataflow_runn:67,datastor:[22,23,24,25,26,27,28,29],datastoreio:25,decor:132,direct:[73,74,75,76,77,78,79,80,81,82,83,84,85],direct_metr:77,direct_runn:78,displai:123,display_manag:87,distribution_counter_microbenchmark:116,endpoints_pb2_grpc:59,error:5,evaluation_context:79,executor:80,fake_datastor:26,filebasedsink:15,filebasedsourc:16,filesystem:[17,19],filesystemio:18,gcp:[7,8,9,20,21,22,23,24,25,26,27,28,29,30,31,32],gcsfilesystem:30,gcsio:31,hadoopfilesystem:33,helper:27,helper_transform:81,interact:[86,87,88,89,90],interactive_pipeline_graph:88,interactive_runn:89,intern:[6,7,8,9,10,11],iobas:[34,69],job:[91,92,93],json_valu:9,localfilesystem:35,manag:92,metric:[43,44,45,46],metricbas:46,model:[100,101],modul:[1,2,3,4,5,8,9,10,11,13,14,15,16,17,18,19,21,24,25,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,41,42,44,45,46,48,49,50,51,54,55,56,57,58,59,60,61,62,63,66,67,69,70,71,72,74,75,76,77,78,79,80,81,82,83,84,85,87,88,89,90,92,93,94,95,96,101,102,103,105,106,107,108,109,110,111,112,113,115,116,117,118,120,121,122,123,124,125,126,127,128,129,130,132,133,134,135,136,137,139,140,141,142,143,144,145,146,147],native_io:[68,69,70],native_type_compat:133,nexmark:[99,100,101,102,103,104,105,106,107],nexmark_launch:102,nexmark_model:101,nexmark_util:103,observ:2,opcod:134,option:[47,48,49,50],overview:148,packag:[0,6,7,12,20,22,23,43,47,52,53,64,65,68,73,86,91,97,98,99,100,104,114,119,131,138],pickler:10,pipelin:51,pipeline_context:94,pipeline_graph:90,pipeline_opt:48,pipeline_options_valid:49,pipeline_verifi:108,plugin:140,portabl:[52,53,54,55,56,57,58,59,60,61,62],process:141,profil:142,proto_util:143,ptransform:124,ptransform_overrid:71,pubsub:32,pvalu:63,python:148,python_urn:62,queri:[104,105,106,107],query0:105,query1:106,query2:107,query_splitt:28,range_track:36,restriction_track:37,retri:144,runner:[64,65,66,67,68,69,70,71,72,73,74,75,76,77,78,79,80,81,82,83,84,85,86,87,88,89,90,91,92,93,94,95,96],sdf_common:96,sdf_direct_runn:82,sdk:148,sideinput:125,sideinput_microbenchmark:117,slow_stream:3,source_test_util:38,standard_window_fns_pb2_grpc:60,statu:148,streaming_cr:70,submodul:[0,6,7,12,20,23,43,47,52,53,64,65,68,73,86,91,97,99,100,104,114,119,131,138,148],subpackag:[6,12,20,22,52,64,65,97,98,99,148],synthetic_pipelin:109,test:[97,98,99,100,101,102,103,104,105,106,107,108,109,110,111,112,113],test_dataflow_runn:72,test_pipelin:110,test_stream:111,test_util:112,textio:39,tfrecordio:40,timestamp:145,timeutil:126,tool:[114,115,116,117,118],transform:[119,120,121,122,123,124,125,126,127,128,129,130],transform_evalu:83,trigger:127,trivial_infer:135,typecheck:136,typecod:4,typehint:[131,132,133,134,135,136,137],typic:148,urn:146,usag:148,userst:128,util:[11,29,41,84,93,113,118,129,138,139,140,141,142,143,144,145,146],value_provid:50,vcfio:42,version:147,watermark_manag:85,window:130}})