apache_beam.transforms package

PTransform and descendants.

Subpackages

• apache_beam.transforms.enrichment_handlers package
  • Submodules
    • apache_beam.transforms.enrichment_handlers.bigquery module
      • BigQueryEnrichmentHandler
    • apache_beam.transforms.enrichment_handlers.bigtable module
      • BigTableEnrichmentHandler
    • apache_beam.transforms.enrichment_handlers.feast_feature_store module
      • FeastFeatureStoreEnrichmentHandler
    • apache_beam.transforms.enrichment_handlers.utils module
      • ExceptionLevel
    • apache_beam.transforms.enrichment_handlers.vertex_ai_feature_store module
      • VertexAIFeatureStoreEnrichmentHandler
      • VertexAIFeatureStoreLegacyEnrichmentHandler
• apache_beam.transforms.xlang package
  • Submodules
    • apache_beam.transforms.xlang.io module
      • GenerateSequence
      • TfrecordRead
      • TfrecordWrite

Submodules

• apache_beam.transforms.combinefn_lifecycle_pipeline module
  • CallSequenceEnforcingCombineFn
    • CallSequenceEnforcingCombineFn.instances
    • CallSequenceEnforcingCombineFn.setup()
    • CallSequenceEnforcingCombineFn.create_accumulator()
    • CallSequenceEnforcingCombineFn.add_input()
    • CallSequenceEnforcingCombineFn.add_inputs()
    • CallSequenceEnforcingCombineFn.merge_accumulators()
    • CallSequenceEnforcingCombineFn.extract_output()
    • CallSequenceEnforcingCombineFn.teardown()
  • IndexAssigningDoFn
    • IndexAssigningDoFn.state_param
    • IndexAssigningDoFn.process()
  • run_combine()
  • run_combine_uncopyable_attr()
  • run_pardo()
• apache_beam.transforms.combiners module
  • Count
    • Count.Globally
      • Count.Globally.expand()
    • Count.PerKey
      • Count.PerKey.expand()
    • Count.PerElement
      • Count.PerElement.expand()
  • Mean
    • Mean.Globally
      • Mean.Globally.expand()
    • Mean.PerKey
      • Mean.PerKey.expand()
  • Sample
    • Sample.FixedSizeGlobally
      • Sample.FixedSizeGlobally.expand()
      • Sample.FixedSizeGlobally.display_data()
      • Sample.FixedSizeGlobally.default_label()
    • Sample.FixedSizePerKey
      • Sample.FixedSizePerKey.expand()
      • Sample.FixedSizePerKey.display_data()
      • Sample.FixedSizePerKey.default_label()
  • Top
    • Top.Of
      • Top.Of.default_label()
      • Top.Of.expand()
    • Top.PerKey
      • Top.PerKey.default_label()
      • Top.PerKey.expand()
    • Top.Largest()
    • Top.Smallest()
    • Top.LargestPerKey()
    • Top.SmallestPerKey()
  • ToDict
    • ToDict.expand()
  • ToList
    • ToList.expand()
  • ToSet
    • ToSet.expand()
  • Latest
    • Latest.Globally
      • Latest.Globally.add_timestamp()
      • Latest.Globally.expand()
    • Latest.PerKey
      • Latest.PerKey.add_timestamp()
      • Latest.PerKey.expand()
  • CountCombineFn
    • CountCombineFn.create_accumulator()
    • CountCombineFn.add_input()
    • CountCombineFn.add_inputs()
    • CountCombineFn.merge_accumulators()
    • CountCombineFn.extract_output()
  • MeanCombineFn
    • MeanCombineFn.create_accumulator()
    • MeanCombineFn.add_input()
    • MeanCombineFn.merge_accumulators()
    • MeanCombineFn.extract_output()
    • MeanCombineFn.for_input_type()
  • SampleCombineFn
    • SampleCombineFn.setup()
    • SampleCombineFn.create_accumulator()
    • SampleCombineFn.add_input()
    • SampleCombineFn.merge_accumulators()
    • SampleCombineFn.compact()
    • SampleCombineFn.extract_output()
    • SampleCombineFn.teardown()
  • TopCombineFn
    • TopCombineFn.display_data()
    • TopCombineFn.create_accumulator()
    • TopCombineFn.add_input()
    • TopCombineFn.merge_accumulators()
    • TopCombineFn.compact()
    • TopCombineFn.extract_output()
  • ToDictCombineFn
    • ToDictCombineFn.create_accumulator()
    • ToDictCombineFn.add_input()
    • ToDictCombineFn.merge_accumulators()
    • ToDictCombineFn.extract_output()
  • ToListCombineFn
    • ToListCombineFn.create_accumulator()
    • ToListCombineFn.add_input()
    • ToListCombineFn.merge_accumulators()
    • ToListCombineFn.extract_output()
  • ToSetCombineFn
    • ToSetCombineFn.create_accumulator()
    • ToSetCombineFn.add_input()
    • ToSetCombineFn.merge_accumulators()
    • ToSetCombineFn.extract_output()
  • LatestCombineFn
    • LatestCombineFn.create_accumulator()
    • LatestCombineFn.add_input()
    • LatestCombineFn.merge_accumulators()
    • LatestCombineFn.extract_output()
• apache_beam.transforms.core module
  • DoFn
    • DoFn.ElementParam
    • DoFn.SideInputParam
    • DoFn.TimestampParam
    • DoFn.WindowParam
    • DoFn.WindowedValueParam
    • DoFn.PaneInfoParam
    • DoFn.WatermarkEstimatorParam
    • DoFn.BundleFinalizerParam
    • DoFn.KeyParam
    • DoFn.BundleContextParam
    • DoFn.SetupContextParam
    • DoFn.StateParam
    • DoFn.TimerParam
    • DoFn.DynamicTimerTagParam
    • DoFn.DoFnProcessParams
    • DoFn.RestrictionParam
    • DoFn.from_callable()
    • DoFn.unbounded_per_element()
    • DoFn.yields_elements()
    • DoFn.yields_batches()
    • DoFn.default_label()
    • DoFn.process()
    • DoFn.process_batch()
    • DoFn.setup()
    • DoFn.start_bundle()
    • DoFn.finish_bundle()
    • DoFn.teardown()
    • DoFn.get_function_arguments()
    • DoFn.default_type_hints()
    • DoFn.infer_output_type()
    • DoFn.get_input_batch_type()
    • DoFn.get_output_batch_type()
    • DoFn.to_runner_api_parameter()
  • CombineFn
    • CombineFn.default_label()
    • CombineFn.setup()
    • CombineFn.create_accumulator()
    • CombineFn.add_input()
    • CombineFn.add_inputs()
    • CombineFn.merge_accumulators()
    • CombineFn.compact()
    • CombineFn.extract_output()
    • CombineFn.teardown()
    • CombineFn.apply()
    • CombineFn.for_input_type()
    • CombineFn.from_callable()
    • CombineFn.maybe_from_callable()
    • CombineFn.get_accumulator_coder()
    • CombineFn.to_runner_api_parameter()
  • PartitionFn
    • PartitionFn.default_label()
    • PartitionFn.partition_for()
  • ParDo
    • ParDo.with_exception_handling()
    • ParDo.with_error_handler()
    • ParDo.default_type_hints()
    • ParDo.infer_output_type()
    • ParDo.infer_batch_converters()
    • ParDo.make_fn()
    • ParDo.display_data()
    • ParDo.expand()
    • ParDo.with_outputs()
    • ParDo.to_runner_api_parameter()
    • ParDo.from_runner_api_parameter()
    • ParDo.runner_api_requires_keyed_input()
    • ParDo.get_restriction_coder()
  • FlatMap()
  • FlatMapTuple()
  • Map()
  • MapTuple()
  • Filter()
  • CombineGlobally
    • CombineGlobally.has_defaults
    • CombineGlobally.as_view
    • CombineGlobally.fanout
    • CombineGlobally.display_data()
    • CombineGlobally.default_label()
    • CombineGlobally.with_fanout()
    • CombineGlobally.with_defaults()
    • CombineGlobally.without_defaults()
    • CombineGlobally.as_singleton_view()
    • CombineGlobally.expand()
    • CombineGlobally.from_runner_api_parameter()
  • CombinePerKey
    • CombinePerKey.with_hot_key_fanout()
    • CombinePerKey.display_data()
    • CombinePerKey.make_fn()
    • CombinePerKey.default_label()
    • CombinePerKey.expand()
    • CombinePerKey.default_type_hints()
    • CombinePerKey.to_runner_api_parameter()
    • CombinePerKey.from_runner_api_parameter()
    • CombinePerKey.runner_api_requires_keyed_input()
  • CombineValues
    • CombineValues.make_fn()
    • CombineValues.expand()
    • CombineValues.to_runner_api_parameter()
    • CombineValues.from_runner_api_parameter()
  • GroupBy
    • GroupBy.aggregate_field()
    • GroupBy.force_tuple_keys()
    • GroupBy.default_label()
    • GroupBy.expand()
  • GroupByKey
    • GroupByKey.ReifyWindows
      • GroupByKey.ReifyWindows.process()
      • GroupByKey.ReifyWindows.infer_output_type()
    • GroupByKey.expand()
    • GroupByKey.infer_output_type()
    • GroupByKey.to_runner_api_parameter()
    • GroupByKey.from_runner_api_parameter()
    • GroupByKey.runner_api_requires_keyed_input()
  • Select
    • Select.with_exception_handling()
    • Select.default_label()
    • Select.expand()
    • Select.infer_output_type()
  • Partition
    • Partition.ApplyPartitionFnFn
      • Partition.ApplyPartitionFnFn.process()
    • Partition.make_fn()
    • Partition.expand()
  • Windowing
    • Windowing.is_default()
    • Windowing.to_runner_api()
    • Windowing.from_runner_api()
  • WindowInto
    • WindowInto.WindowIntoFn
      • WindowInto.WindowIntoFn.process()
      • WindowInto.WindowIntoFn.infer_output_type()
    • WindowInto.get_windowing()
    • WindowInto.infer_output_type()
    • WindowInto.expand()
    • WindowInto.to_runner_api_parameter()
    • WindowInto.from_runner_api_parameter()
  • Flatten
    • Flatten.expand()
    • Flatten.infer_output_type()
    • Flatten.to_runner_api_parameter()
    • Flatten.from_runner_api_parameter()
  • FlattenWith
    • FlattenWith.expand()
  • Create
    • Create.to_runner_api_parameter()
    • Create.infer_output_type()
    • Create.get_output_type()
    • Create.expand()
    • Create.as_read()
    • Create.get_windowing()
  • Impulse
    • Impulse.expand()
    • Impulse.get_windowing()
    • Impulse.infer_output_type()
    • Impulse.to_runner_api_parameter()
    • Impulse.from_runner_api_parameter()
  • RestrictionProvider
    • RestrictionProvider.create_tracker()
    • RestrictionProvider.initial_restriction()
    • RestrictionProvider.split()
    • RestrictionProvider.restriction_coder()
    • RestrictionProvider.restriction_size()
    • RestrictionProvider.split_and_size()
    • RestrictionProvider.truncate()
  • WatermarkEstimatorProvider
    • WatermarkEstimatorProvider.initial_estimator_state()
    • WatermarkEstimatorProvider.create_watermark_estimator()
    • WatermarkEstimatorProvider.estimator_state_coder()
• apache_beam.transforms.create_source module
• apache_beam.transforms.deduplicate module
  • Deduplicate
    • Deduplicate.expand()
  • DeduplicatePerKey
    • DeduplicatePerKey.expand()
• apache_beam.transforms.display module
  • HasDisplayData
    • HasDisplayData.display_data()
  • DisplayDataItem
    • DisplayDataItem.typeDict
    • DisplayDataItem.drop_if_none()
    • DisplayDataItem.drop_if_default()
    • DisplayDataItem.should_drop()
    • DisplayDataItem.is_valid()
    • DisplayDataItem.get_dict()
  • DisplayData
    • DisplayData.to_proto()
    • DisplayData.create_from_options()
    • DisplayData.create_from()
• apache_beam.transforms.enrichment module
  • EnrichmentSourceHandler
    • EnrichmentSourceHandler.get_cache_key()
  • Enrichment
    • Enrichment.expand()
    • Enrichment.with_redis_cache()
  • cross_join()
• apache_beam.transforms.environments module
  • Environment
    • Environment.artifacts()
    • Environment.to_runner_api_parameter()
    • Environment.capabilities()
    • Environment.resource_hints()
    • Environment.register_urn()
    • Environment.get_env_cls_from_urn()
    • Environment.to_runner_api()
    • Environment.from_runner_api()
    • Environment.from_options()
  • AnyOfEnvironment
    • AnyOfEnvironment.to_runner_api_parameter()
    • AnyOfEnvironment.from_runner_api_parameter()
    • AnyOfEnvironment.create_proto()
    • AnyOfEnvironment.to_runner_api()
  • DefaultEnvironment
    • DefaultEnvironment.to_runner_api_parameter()
    • DefaultEnvironment.from_runner_api_parameter()
  • DockerEnvironment
    • DockerEnvironment.to_runner_api_parameter()
    • DockerEnvironment.from_runner_api_parameter()
    • DockerEnvironment.from_options()
    • DockerEnvironment.from_container_image()
    • DockerEnvironment.default_docker_image()
  • ProcessEnvironment
    • ProcessEnvironment.to_runner_api_parameter()
    • ProcessEnvironment.from_runner_api_parameter()
    • ProcessEnvironment.parse_environment_variables()
    • ProcessEnvironment.from_options()
  • ExternalEnvironment
    • ExternalEnvironment.to_runner_api_parameter()
    • ExternalEnvironment.from_runner_api_parameter()
    • ExternalEnvironment.from_options()
  • EmbeddedPythonEnvironment
    • EmbeddedPythonEnvironment.to_runner_api_parameter()
    • EmbeddedPythonEnvironment.from_runner_api_parameter()
    • EmbeddedPythonEnvironment.from_options()
    • EmbeddedPythonEnvironment.default()
  • EmbeddedPythonGrpcEnvironment
    • EmbeddedPythonGrpcEnvironment.to_runner_api_parameter()
    • EmbeddedPythonGrpcEnvironment.from_runner_api_parameter()
    • EmbeddedPythonGrpcEnvironment.from_options()
    • EmbeddedPythonGrpcEnvironment.parse_config()
    • EmbeddedPythonGrpcEnvironment.default()
  • SubprocessSDKEnvironment
    • SubprocessSDKEnvironment.to_runner_api_parameter()
    • SubprocessSDKEnvironment.from_runner_api_parameter()
    • SubprocessSDKEnvironment.from_options()
    • SubprocessSDKEnvironment.from_command_string()
  • PyPIArtifactRegistry
    • PyPIArtifactRegistry.register_artifact()
    • PyPIArtifactRegistry.get_artifacts()
• apache_beam.transforms.error_handling module
  • ErrorHandler
    • ErrorHandler.close()
    • ErrorHandler.output()
    • ErrorHandler.add_error_pcollection()
    • ErrorHandler.verify_closed()
  • CollectingErrorHandler
    • CollectingErrorHandler.output()
    • CollectingErrorHandler.verify_closed()
• apache_beam.transforms.external module
  • convert_to_typing_type()
  • iter_urns()
  • PayloadBuilder
    • PayloadBuilder.build()
    • PayloadBuilder.payload()
  • SchemaBasedPayloadBuilder
    • SchemaBasedPayloadBuilder.build()
  • ImplicitSchemaPayloadBuilder
  • NamedTupleBasedPayloadBuilder
  • SchemaTransformPayloadBuilder
    • SchemaTransformPayloadBuilder.identifier()
    • SchemaTransformPayloadBuilder.build()
  • ExplicitSchemaTransformPayloadBuilder
    • ExplicitSchemaTransformPayloadBuilder.build()
  • JavaClassLookupPayloadBuilder
    • JavaClassLookupPayloadBuilder.IGNORED_ARG_FORMAT
    • JavaClassLookupPayloadBuilder.build()
    • JavaClassLookupPayloadBuilder.with_constructor()
    • JavaClassLookupPayloadBuilder.with_constructor_method()
    • JavaClassLookupPayloadBuilder.add_builder_method()
  • SchemaTransformsConfig
    • SchemaTransformsConfig.configuration_schema
    • SchemaTransformsConfig.description
    • SchemaTransformsConfig.identifier
    • SchemaTransformsConfig.inputs
    • SchemaTransformsConfig.outputs
  • ManagedReplacement
    • ManagedReplacement.underlying_transform_identifier
    • ManagedReplacement.update_compatibility_version
  • SchemaAwareExternalTransform
    • SchemaAwareExternalTransform.expand()
    • SchemaAwareExternalTransform.discover()
    • SchemaAwareExternalTransform.discover_iter()
    • SchemaAwareExternalTransform.discover_config()
  • JavaExternalTransform
    • JavaExternalTransform.expand()
  • AnnotationBasedPayloadBuilder
  • DataclassBasedPayloadBuilder
  • ExternalTransform
    • ExternalTransform.with_output_types()
    • ExternalTransform.replace_named_inputs()
    • ExternalTransform.replace_named_outputs()
    • ExternalTransform.default_label()
    • ExternalTransform.get_local_namespace()
    • ExternalTransform.outer_namespace()
    • ExternalTransform.expand()
    • ExternalTransform.service()
    • ExternalTransform.to_runner_api_transform()
  • ExpansionAndArtifactRetrievalStub
    • ExpansionAndArtifactRetrievalStub.artifact_service()
    • ExpansionAndArtifactRetrievalStub.ready()
  • JavaJarExpansionService
    • JavaJarExpansionService.is_existing_service()
  • BeamJarExpansionService
  • memoize()
• apache_beam.transforms.external_java module
  • JavaExternalTransformTest
    • JavaExternalTransformTest.expansion_service_jar
    • JavaExternalTransformTest.expansion_service_port
    • JavaExternalTransformTest.test_java_expansion_dataflow()
    • JavaExternalTransformTest.run_pipeline_with_expansion_service()
    • JavaExternalTransformTest.run_pipeline()
• apache_beam.transforms.external_transform_provider module
  • ExternalTransform
    • ExternalTransform.default_expansion_service
    • ExternalTransform.identifier
    • ExternalTransform.configuration_schema
    • ExternalTransform.expand()
  • ExternalTransformProvider
    • ExternalTransformProvider.get_available()
    • ExternalTransformProvider.get_all()
    • ExternalTransformProvider.get()
    • ExternalTransformProvider.get_urn()
• apache_beam.transforms.fully_qualified_named_transform module
  • FullyQualifiedNamedTransform
    • FullyQualifiedNamedTransform.with_filter()
    • FullyQualifiedNamedTransform.expand()
    • FullyQualifiedNamedTransform.to_runner_api_parameter()
    • FullyQualifiedNamedTransform.from_runner_api_parameter()
• apache_beam.transforms.managed module
  • Available transforms
  • Using Managed Transforms
  • Runner specific features
  • Read
    • Read.expand()
    • Read.default_label()
  • Write
    • Write.expand()
    • Write.default_label()
• apache_beam.transforms.periodicsequence module
  • ImpulseSeqGenRestrictionProvider
    • ImpulseSeqGenRestrictionProvider.initial_restriction()
    • ImpulseSeqGenRestrictionProvider.create_tracker()
    • ImpulseSeqGenRestrictionProvider.restriction_size()
    • ImpulseSeqGenRestrictionProvider.truncate()
  • ImpulseSeqGenDoFn
    • ImpulseSeqGenDoFn.process()
  • PeriodicSequence
    • PeriodicSequence.expand()
  • PeriodicImpulse
    • PeriodicImpulse.expand()
• apache_beam.transforms.ptransform module
  • PTransform
    • PTransform.side_inputs
    • PTransform.pipeline
    • PTransform.label
    • PTransform.default_label()
    • PTransform.annotations()
    • PTransform.default_type_hints()
    • PTransform.with_input_types()
    • PTransform.with_output_types()
    • PTransform.with_resource_hints()
    • PTransform.get_resource_hints()
    • PTransform.type_check_inputs()
    • PTransform.infer_output_type()
    • PTransform.type_check_outputs()
    • PTransform.type_check_inputs_or_outputs()
    • PTransform.expand()
    • PTransform.get_windowing()
    • PTransform.register_urn()
    • PTransform.to_runner_api()
    • PTransform.from_runner_api()
    • PTransform.to_runner_api_parameter()
    • PTransform.to_runner_api_pickled()
    • PTransform.runner_api_requires_keyed_input()
  • ptransform_fn()
  • label_from_callable()
  • annotate_yaml()
• apache_beam.transforms.resources module
  • ResourceHint
    • ResourceHint.urn
    • ResourceHint.parse()
    • ResourceHint.get_merged_value()
    • ResourceHint.get_by_urn()
    • ResourceHint.get_by_name()
    • ResourceHint.is_registered()
    • ResourceHint.register_resource_hint()
  • AcceleratorHint
    • AcceleratorHint.urn
  • MinRamHint
    • MinRamHint.urn
    • MinRamHint.parse()
    • MinRamHint.get_merged_value()
  • CpuCountHint
    • CpuCountHint.urn
    • CpuCountHint.get_merged_value()
  • MaxActiveBundlesPerWorkerHint
    • MaxActiveBundlesPerWorkerHint.urn
    • MaxActiveBundlesPerWorkerHint.get_merged_value()
  • merge_resource_hints()
  • parse_resource_hints()
  • resource_hints_from_options()
• apache_beam.transforms.sideinputs module
  • default_window_mapping_fn()
  • get_sideinput_index()
  • SideInputMap
    • SideInputMap.is_globally_windowed()
• apache_beam.transforms.sql module
  • SqlTransform
    • SqlTransform.URN
• apache_beam.transforms.stats module
  • ApproximateQuantiles
    • ApproximateQuantiles.Globally
      • ApproximateQuantiles.Globally.display_data()
      • ApproximateQuantiles.Globally.expand()
    • ApproximateQuantiles.PerKey
      • ApproximateQuantiles.PerKey.display_data()
      • ApproximateQuantiles.PerKey.expand()
  • ApproximateUnique
    • ApproximateUnique.Globally
      • ApproximateUnique.Globally.expand()
    • ApproximateUnique.PerKey
      • ApproximateUnique.PerKey.expand()
    • ApproximateUnique.parse_input_params()
• apache_beam.transforms.timeutil module
  • TimeDomain
    • TimeDomain.WATERMARK
    • TimeDomain.REAL_TIME
    • TimeDomain.DEPENDENT_REAL_TIME
    • TimeDomain.from_string()
    • TimeDomain.to_runner_api()
    • TimeDomain.is_event_time()
• apache_beam.transforms.trigger module
  • AccumulationMode
    • AccumulationMode.DISCARDING
    • AccumulationMode.ACCUMULATING
  • TriggerFn
    • TriggerFn.on_element()
    • TriggerFn.on_merge()
    • TriggerFn.should_fire()
    • TriggerFn.has_ontime_pane()
    • TriggerFn.on_fire()
    • TriggerFn.reset()
    • TriggerFn.may_lose_data()
    • TriggerFn.from_runner_api()
    • TriggerFn.to_runner_api()
  • DefaultTrigger
    • DefaultTrigger.on_element()
    • DefaultTrigger.on_merge()
    • DefaultTrigger.should_fire()
    • DefaultTrigger.on_fire()
    • DefaultTrigger.reset()
    • DefaultTrigger.may_lose_data()
    • DefaultTrigger.from_runner_api()
    • DefaultTrigger.to_runner_api()
    • DefaultTrigger.has_ontime_pane()
  • AfterWatermark
    • AfterWatermark.LATE_TAG
    • AfterWatermark.is_late()
    • AfterWatermark.on_element()
    • AfterWatermark.on_merge()
    • AfterWatermark.should_fire()
    • AfterWatermark.on_fire()
    • AfterWatermark.reset()
    • AfterWatermark.may_lose_data()
    • AfterWatermark.from_runner_api()
    • AfterWatermark.to_runner_api()
    • AfterWatermark.has_ontime_pane()
  • AfterProcessingTime
    • AfterProcessingTime.STATE_TAG
    • AfterProcessingTime.on_element()
    • AfterProcessingTime.on_merge()
    • AfterProcessingTime.should_fire()
    • AfterProcessingTime.on_fire()
    • AfterProcessingTime.reset()
    • AfterProcessingTime.may_lose_data()
    • AfterProcessingTime.from_runner_api()
    • AfterProcessingTime.to_runner_api()
    • AfterProcessingTime.has_ontime_pane()
  • AfterCount
    • AfterCount.COUNT_TAG
    • AfterCount.on_element()
    • AfterCount.on_merge()
    • AfterCount.should_fire()
    • AfterCount.on_fire()
    • AfterCount.reset()
    • AfterCount.may_lose_data()
    • AfterCount.from_runner_api()
    • AfterCount.to_runner_api()
    • AfterCount.has_ontime_pane()
  • Repeatedly
    • Repeatedly.on_element()
    • Repeatedly.on_merge()
    • Repeatedly.should_fire()
    • Repeatedly.on_fire()
    • Repeatedly.reset()
    • Repeatedly.may_lose_data()
    • Repeatedly.from_runner_api()
    • Repeatedly.to_runner_api()
    • Repeatedly.has_ontime_pane()
  • AfterAny
    • AfterAny.combine_op()
  • AfterAll
    • AfterAll.combine_op()
  • AfterEach
    • AfterEach.INDEX_TAG
    • AfterEach.on_element()
    • AfterEach.on_merge()
    • AfterEach.should_fire()
    • AfterEach.on_fire()
    • AfterEach.reset()
    • AfterEach.may_lose_data()
    • AfterEach.from_runner_api()
    • AfterEach.to_runner_api()
    • AfterEach.has_ontime_pane()
  • OrFinally
    • OrFinally.from_runner_api()
    • OrFinally.to_runner_api()
• apache_beam.transforms.userstate module
  • StateSpec
    • StateSpec.to_runner_api()
  • ReadModifyWriteStateSpec
    • ReadModifyWriteStateSpec.to_runner_api()
  • BagStateSpec
    • BagStateSpec.to_runner_api()
  • SetStateSpec
    • SetStateSpec.to_runner_api()
  • CombiningValueStateSpec
    • CombiningValueStateSpec.to_runner_api()
  • OrderedListStateSpec
    • OrderedListStateSpec.to_runner_api()
  • Timer
    • Timer.clear_bit
    • Timer.dynamic_timer_tag
    • Timer.fire_timestamp
    • Timer.hold_timestamp
    • Timer.paneinfo
    • Timer.user_key
    • Timer.windows
  • TimerSpec
    • TimerSpec.prefix
    • TimerSpec.to_runner_api()
  • on_timer()
  • get_dofn_specs()
  • is_stateful_dofn()
  • validate_stateful_dofn()
  • BaseTimer
    • BaseTimer.clear()
    • BaseTimer.set()
  • RuntimeTimer
    • RuntimeTimer.clear()
    • RuntimeTimer.set()
  • RuntimeState
    • RuntimeState.prefetch()
    • RuntimeState.finalize()
  • ReadModifyWriteRuntimeState
    • ReadModifyWriteRuntimeState.read()
    • ReadModifyWriteRuntimeState.write()
    • ReadModifyWriteRuntimeState.clear()
    • ReadModifyWriteRuntimeState.commit()
  • AccumulatingRuntimeState
    • AccumulatingRuntimeState.read()
    • AccumulatingRuntimeState.add()
    • AccumulatingRuntimeState.clear()
    • AccumulatingRuntimeState.commit()
  • BagRuntimeState
  • SetRuntimeState
  • CombiningValueRuntimeState
  • OrderedListRuntimeState
    • OrderedListRuntimeState.read()
    • OrderedListRuntimeState.add()
    • OrderedListRuntimeState.read_range()
    • OrderedListRuntimeState.clear_range()
  • UserStateContext
    • UserStateContext.get_timer()
    • UserStateContext.get_state()
    • UserStateContext.commit()
• apache_beam.transforms.util module
  • BatchElements
    • BatchElements.expand()
  • CoGroupByKey
    • CoGroupByKey.expand()
  • Distinct()
  • Keys()
  • KvSwap()
  • LogElements
    • LogElements.expand()
  • Regex
    • Regex.ALL
    • Regex.matches()
    • Regex.all_matches()
    • Regex.matches_kv()
    • Regex.find()
    • Regex.find_all()
    • Regex.find_kv()
    • Regex.replace_all()
    • Regex.replace_first()
    • Regex.split()
  • Reify
    • Reify.Timestamp
      • Reify.Timestamp.add_timestamp_info()
      • Reify.Timestamp.expand()
    • Reify.Window
      • Reify.Window.add_window_info()
      • Reify.Window.expand()
    • Reify.TimestampInValue
      • Reify.TimestampInValue.add_timestamp_info()
      • Reify.TimestampInValue.expand()
    • Reify.WindowInValue
      • Reify.WindowInValue.add_window_info()
      • Reify.WindowInValue.expand()
  • RemoveDuplicates()
  • Reshuffle
    • Reshuffle.expand()
    • Reshuffle.to_runner_api_parameter()
    • Reshuffle.from_runner_api_parameter()
  • ToString
    • ToString.Element()
    • ToString.Iterables()
    • ToString.Kvs()
  • Tee
    • Tee.expand()
  • Values()
  • WithKeys()
  • GroupIntoBatches
    • GroupIntoBatches.expand()
    • GroupIntoBatches.to_runner_api_parameter()
    • GroupIntoBatches.from_runner_api_parameter()
    • GroupIntoBatches.WithShardedKey
      • GroupIntoBatches.WithShardedKey.expand()
      • GroupIntoBatches.WithShardedKey.to_runner_api_parameter()
      • GroupIntoBatches.WithShardedKey.from_runner_api_parameter()
• apache_beam.transforms.window module
  • TimestampCombiner
    • TimestampCombiner.OUTPUT_AT_EOW
    • TimestampCombiner.OUTPUT_AT_EARLIEST
    • TimestampCombiner.OUTPUT_AT_LATEST
    • TimestampCombiner.OUTPUT_AT_EARLIEST_TRANSFORMED
    • TimestampCombiner.get_impl()
  • WindowFn
    • WindowFn.AssignContext
    • WindowFn.assign()
    • WindowFn.MergeContext
      • WindowFn.MergeContext.merge()
    • WindowFn.merge()
    • WindowFn.is_merging()
    • WindowFn.get_window_coder()
    • WindowFn.get_transformed_output_time()
    • WindowFn.to_runner_api_parameter()
  • BoundedWindow
    • BoundedWindow.end
    • BoundedWindow.start
    • BoundedWindow.end
    • BoundedWindow.max_timestamp()
  • IntervalWindow
    • IntervalWindow.start
    • IntervalWindow.end
    • IntervalWindow.intersects()
    • IntervalWindow.union()
  • TimestampedValue
    • TimestampedValue.value
    • TimestampedValue.timestamp
  • GlobalWindow
    • GlobalWindow.start
  • NonMergingWindowFn
    • NonMergingWindowFn.is_merging()
    • NonMergingWindowFn.merge()
  • GlobalWindows
    • GlobalWindows.windowed_batch()
    • GlobalWindows.windowed_value()
    • GlobalWindows.windowed_value_at_end_of_window()
    • GlobalWindows.assign()
    • GlobalWindows.get_window_coder()
    • GlobalWindows.to_runner_api_parameter()
    • GlobalWindows.from_runner_api_parameter()
  • FixedWindows
    • FixedWindows.size
    • FixedWindows.offset
    • FixedWindows.assign()
    • FixedWindows.get_window_coder()
    • FixedWindows.to_runner_api_parameter()
    • FixedWindows.from_runner_api_parameter()
  • SlidingWindows
    • SlidingWindows.size
    • SlidingWindows.period
    • SlidingWindows.offset
    • SlidingWindows.assign()
    • SlidingWindows.get_window_coder()
    • SlidingWindows.to_runner_api_parameter()
    • SlidingWindows.from_runner_api_parameter()
  • Sessions
    • Sessions.gap_size
    • Sessions.assign()
    • Sessions.get_window_coder()
    • Sessions.merge()
    • Sessions.to_runner_api_parameter()
    • Sessions.from_runner_api_parameter()