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