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