Path	Lines of Code
CHANGES.md	1490
CI.md	160
CONTRIBUTING.md	235
README.md	102
buildSrc/greclipse.properties	21
contributor-docs/code-change-guide.md	456
contributor-docs/committer-guide.md	120
contributor-docs/committer-onboarding.md	29
contributor-docs/discussion-docs/2016.md	47
contributor-docs/discussion-docs/2017.md	87
contributor-docs/discussion-docs/2018.md	113
contributor-docs/discussion-docs/2019.md	100
contributor-docs/discussion-docs/2020.md	77
contributor-docs/discussion-docs/2021.md	66
contributor-docs/discussion-docs/2022.md	86
contributor-docs/discussion-docs/2023.md	59
contributor-docs/discussion-docs/2024.md	48
contributor-docs/discussion-docs/2025.md	26
contributor-docs/java-dependency-upgrades.md	91
contributor-docs/rc-testing-guide.md	40
contributor-docs/release-guide.md	966
examples/java/README.md	43
examples/java/build.gradle	135
examples/java/cdap/README.md	24
examples/java/cdap/build.gradle	21
examples/java/cdap/hubspot/build.gradle	78
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/CdapHubspotStreamingToTxt.java	58
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/CdapHubspotToTxt.java	55
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/README.md	86
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/TxtToCdapHubspot.java	39
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options/CdapHubspotOptions.java	17
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options/CdapHubspotSinkOptions.java	17
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options/CdapHubspotSourceOptions.java	11
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options/CdapHubspotStreamingSourceOptions.java	11
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options/package-info.java	1
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/package-info.java	1
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/transforms/FormatInputTransform.java	52
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/transforms/FormatOutputTransform.java	23
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/transforms/package-info.java	1
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/utils/GetOffsetUtils.java	39
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/utils/PluginConfigOptionsConverter.java	26
examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/utils/package-info.java	1
examples/java/cdap/hubspot/src/test/resources/example-txt-to-cdap-hubspot-companies.txt	20
examples/java/cdap/salesforce/build.gradle	74
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/CdapSalesforceStreamingToTxt.java	60
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/CdapSalesforceToTxt.java	46
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/README.md	102
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/TxtToCdapSalesforce.java	53
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/options/CdapSalesforceOptions.java	31
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/options/CdapSalesforceSinkOptions.java	49
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/options/CdapSalesforceSourceOptions.java	17
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/options/CdapSalesforceStreamingSourceOptions.java	16
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/options/package-info.java	1
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/package-info.java	1
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/transforms/FormatInputTransform.java	63
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/transforms/FormatOutputTransform.java	24
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/transforms/package-info.java	1
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/utils/CsvRecordCoder.java	24
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/utils/GetOffsetUtils.java	45
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/utils/PluginConfigOptionsConverter.java	70
examples/java/cdap/salesforce/src/main/java/org/apache/beam/examples/complete/cdap/salesforce/utils/package-info.java	1
examples/java/cdap/salesforce/src/test/resources/example-txt-to-cdap-salesforce-custom.txt	20
examples/java/cdap/servicenow/build.gradle	72
examples/java/cdap/servicenow/src/main/java/org/apache/beam/examples/complete/cdap/servicenow/CdapServiceNowToTxt.java	51
examples/java/cdap/servicenow/src/main/java/org/apache/beam/examples/complete/cdap/servicenow/README.md	46
examples/java/cdap/servicenow/src/main/java/org/apache/beam/examples/complete/cdap/servicenow/options/CdapServiceNowOptions.java	55
examples/java/cdap/servicenow/src/main/java/org/apache/beam/examples/complete/cdap/servicenow/options/package-info.java	1
examples/java/cdap/servicenow/src/main/java/org/apache/beam/examples/complete/cdap/servicenow/package-info.java	1
examples/java/cdap/servicenow/src/main/java/org/apache/beam/examples/complete/cdap/servicenow/transforms/FormatInputTransform.java	23
examples/java/cdap/servicenow/src/main/java/org/apache/beam/examples/complete/cdap/servicenow/transforms/package-info.java	1
examples/java/cdap/servicenow/src/main/java/org/apache/beam/examples/complete/cdap/servicenow/utils/PluginConfigOptionsConverter.java	21
examples/java/cdap/servicenow/src/main/java/org/apache/beam/examples/complete/cdap/servicenow/utils/package-info.java	1
examples/java/cdap/src/main/java/org/apache/beam/examples/complete/cdap/options/BaseCdapOptions.java	11
examples/java/cdap/src/main/java/org/apache/beam/examples/complete/cdap/options/package-info.java	1
examples/java/cdap/src/main/java/org/apache/beam/examples/complete/cdap/package-info.java	1
examples/java/cdap/src/main/java/org/apache/beam/examples/complete/cdap/utils/JsonElementCoder.java	26
examples/java/cdap/src/main/java/org/apache/beam/examples/complete/cdap/utils/StructuredRecordUtils.java	12
examples/java/cdap/src/main/java/org/apache/beam/examples/complete/cdap/utils/package-info.java	1
examples/java/cdap/zendesk/build.gradle	72
examples/java/cdap/zendesk/src/main/java/org/apache/beam/examples/complete/cdap/zendesk/CdapZendeskToTxt.java	51
examples/java/cdap/zendesk/src/main/java/org/apache/beam/examples/complete/cdap/zendesk/README.md	47
examples/java/cdap/zendesk/src/main/java/org/apache/beam/examples/complete/cdap/zendesk/options/CdapZendeskOptions.java	54
examples/java/cdap/zendesk/src/main/java/org/apache/beam/examples/complete/cdap/zendesk/options/package-info.java	1
examples/java/cdap/zendesk/src/main/java/org/apache/beam/examples/complete/cdap/zendesk/package-info.java	1
examples/java/cdap/zendesk/src/main/java/org/apache/beam/examples/complete/cdap/zendesk/transforms/FormatInputTransform.java	23
examples/java/cdap/zendesk/src/main/java/org/apache/beam/examples/complete/cdap/zendesk/transforms/package-info.java	1
examples/java/cdap/zendesk/src/main/java/org/apache/beam/examples/complete/cdap/zendesk/utils/PluginConfigOptionsConverter.java	26
examples/java/cdap/zendesk/src/main/java/org/apache/beam/examples/complete/cdap/zendesk/utils/package-info.java	1
examples/java/sql/README.md	33
examples/java/sql/build.gradle	79
examples/java/sql/src/main/java/org/apache/beam/examples/sql/SchemaTransformExample.java	56
examples/java/sql/src/main/java/org/apache/beam/examples/sql/SqlTransformExample.java	48
examples/java/src/main/java/org/apache/beam/examples/ApproximateQuantilesExample.java	37
examples/java/src/main/java/org/apache/beam/examples/CoCombineTransformExample.java	131
examples/java/src/main/java/org/apache/beam/examples/CoGroupByKeyExample.java	48
examples/java/src/main/java/org/apache/beam/examples/CombineExample.java	34
examples/java/src/main/java/org/apache/beam/examples/CountExample.java	33
examples/java/src/main/java/org/apache/beam/examples/CountPerKeyExample.java	36
examples/java/src/main/java/org/apache/beam/examples/CreateExample.java	46
examples/java/src/main/java/org/apache/beam/examples/DebuggingWordCount.java	64
examples/java/src/main/java/org/apache/beam/examples/DistinctExample.java	34
examples/java/src/main/java/org/apache/beam/examples/FlatMapElementsExample.java	45
examples/java/src/main/java/org/apache/beam/examples/GroupIntoBatchesExample.java	42
examples/java/src/main/java/org/apache/beam/examples/KafkaPassengerCountJson.java	109
examples/java/src/main/java/org/apache/beam/examples/KafkaStreaming.java	242
examples/java/src/main/java/org/apache/beam/examples/KafkaWordCountAvro.java	77
examples/java/src/main/java/org/apache/beam/examples/KafkaWordCountJson.java	77
examples/java/src/main/java/org/apache/beam/examples/KeysExample.java	38
examples/java/src/main/java/org/apache/beam/examples/KvSwapExample.java	37
examples/java/src/main/java/org/apache/beam/examples/LatestExample.java	42
examples/java/src/main/java/org/apache/beam/examples/MapElementsExample.java	44
examples/java/src/main/java/org/apache/beam/examples/MaxExample.java	33
examples/java/src/main/java/org/apache/beam/examples/MaxPerKeyExample.java	36
examples/java/src/main/java/org/apache/beam/examples/MeanExample.java	33
examples/java/src/main/java/org/apache/beam/examples/MeanPerKeyExample.java	36
examples/java/src/main/java/org/apache/beam/examples/MinExample.java	33
examples/java/src/main/java/org/apache/beam/examples/MinPerKeyExample.java	36
examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java	31
examples/java/src/main/java/org/apache/beam/examples/PartitionExample.java	136
examples/java/src/main/java/org/apache/beam/examples/RegexExample.java	42
examples/java/src/main/java/org/apache/beam/examples/SampleExample.java	43
examples/java/src/main/java/org/apache/beam/examples/SumExample.java	33
examples/java/src/main/java/org/apache/beam/examples/SumPerKeyExample.java	36
examples/java/src/main/java/org/apache/beam/examples/ToStringExample.java	43
examples/java/src/main/java/org/apache/beam/examples/TopExample.java	34
examples/java/src/main/java/org/apache/beam/examples/ValuesExample.java	38
examples/java/src/main/java/org/apache/beam/examples/ViewExample.java	74
examples/java/src/main/java/org/apache/beam/examples/WindowExample.java	48
examples/java/src/main/java/org/apache/beam/examples/WindowedWordCount.java	100
examples/java/src/main/java/org/apache/beam/examples/WordCount.java	78
examples/java/src/main/java/org/apache/beam/examples/common/ExampleBigQueryTableOptions.java	26
examples/java/src/main/java/org/apache/beam/examples/common/ExampleOptions.java	14
examples/java/src/main/java/org/apache/beam/examples/common/ExamplePubsubTopicAndSubscriptionOptions.java	21
examples/java/src/main/java/org/apache/beam/examples/common/ExamplePubsubTopicOptions.java	21
examples/java/src/main/java/org/apache/beam/examples/common/ExampleUtils.java	323
examples/java/src/main/java/org/apache/beam/examples/common/WriteOneFilePerWindow.java	76
examples/java/src/main/java/org/apache/beam/examples/complete/AutoComplete.java	393
examples/java/src/main/java/org/apache/beam/examples/complete/README.md	61
examples/java/src/main/java/org/apache/beam/examples/complete/StreamingWordExtract.java	85
examples/java/src/main/java/org/apache/beam/examples/complete/TfIdf.java	278
examples/java/src/main/java/org/apache/beam/examples/complete/TopWikipediaSessions.java	151
examples/java/src/main/java/org/apache/beam/examples/complete/TrafficMaxLaneFlow.java	274
examples/java/src/main/java/org/apache/beam/examples/complete/TrafficRoutes.java	283
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/DataTokenization.java	163
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/README.md	134
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/options/DataTokenizationOptions.java	31
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/options/package-info.java	1
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/package-info.java	1
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/transforms/DataProtectors.java	214
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/transforms/JsonToBeamRow.java	47
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/transforms/SerializableFunctions.java	26
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/transforms/io/TokenizationBigQueryIO.java	59
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/transforms/io/TokenizationBigTableIO.java	108
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/transforms/io/TokenizationFileSystemIO.java	183
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/transforms/io/package-info.java	1
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/transforms/package-info.java	1
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/utils/CsvConverters.java	354
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/utils/DurationUtils.java	28
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/utils/ErrorConverters.java	181
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/utils/FailsafeElement.java	59
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/utils/FailsafeElementCoder.java	66
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/utils/RowToCsv.java	15
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/utils/SchemasUtils.java	149
examples/java/src/main/java/org/apache/beam/examples/complete/datatokenization/utils/package-info.java	1
examples/java/src/main/java/org/apache/beam/examples/complete/game/GameStats.java	218
examples/java/src/main/java/org/apache/beam/examples/complete/game/HourlyTeamScore.java	87
examples/java/src/main/java/org/apache/beam/examples/complete/game/LeaderBoard.java	192
examples/java/src/main/java/org/apache/beam/examples/complete/game/StatefulTeamScore.java	104
examples/java/src/main/java/org/apache/beam/examples/complete/game/UserScore.java	151
examples/java/src/main/java/org/apache/beam/examples/complete/game/injector/Injector.java	301
examples/java/src/main/java/org/apache/beam/examples/complete/game/injector/InjectorUtils.java	56
examples/java/src/main/java/org/apache/beam/examples/complete/game/injector/RetryHttpInitializerWrapper.java	44
examples/java/src/main/java/org/apache/beam/examples/complete/game/utils/GameConstants.java	11
examples/java/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToBigQuery.java	99
examples/java/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToText.java	123
examples/java/src/main/java/org/apache/beam/examples/complete/game/utils/WriteWindowedToBigQuery.java	43
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaPubsubConstants.java	8
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsub.java	87
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/README.md	148
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/avro/AvroDataClass.java	32
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/avro/AvroDataClassKafkaAvroDeserializer.java	18
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/avro/package-info.java	1
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/kafka/consumer/SslConsumerFactoryFn.java	97
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/kafka/consumer/Utils.java	96
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/kafka/consumer/package-info.java	1
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/options/KafkaToPubsubOptions.java	56
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/options/package-info.java	1
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/package-info.java	1
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/transforms/FormatTransform.java	81
examples/java/src/main/java/org/apache/beam/examples/complete/kafkatopubsub/transforms/package-info.java	1
examples/java/src/main/java/org/apache/beam/examples/cookbook/BigQueryTornadoes.java	128
examples/java/src/main/java/org/apache/beam/examples/cookbook/CombinePerKeyExamples.java	107
examples/java/src/main/java/org/apache/beam/examples/cookbook/DistinctExample.java	43
examples/java/src/main/java/org/apache/beam/examples/cookbook/FilterExamples.java	141
examples/java/src/main/java/org/apache/beam/examples/cookbook/IcebergTaxiExamples.java	72
examples/java/src/main/java/org/apache/beam/examples/cookbook/JoinExamples.java	106
examples/java/src/main/java/org/apache/beam/examples/cookbook/MaxPerKeyExamples.java	81
examples/java/src/main/java/org/apache/beam/examples/cookbook/MinimalBigQueryTornadoes.java	71
examples/java/src/main/java/org/apache/beam/examples/cookbook/README.md	65
examples/java/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java	272
examples/java/src/main/java/org/apache/beam/examples/multilanguage/PythonDataframeWordCount.java	88
examples/java/src/main/java/org/apache/beam/examples/multilanguage/SklearnMnistClassification.java	99
examples/java/src/main/java/org/apache/beam/examples/snippets/Snippets.java	1029
examples/java/src/main/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQueryMyData.java	67
examples/java/src/main/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQueryReadFromQuery.java	23
examples/java/src/main/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQueryReadFromQueryWithBigQueryStorageAPI.java	25
examples/java/src/main/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQueryReadFromTable.java	21
examples/java/src/main/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQueryReadFromTableWithBigQueryStorageAPI.java	40
examples/java/src/main/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQuerySchemaCreate.java	46
examples/java/src/main/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQueryTableRowCreate.java	45
examples/java/src/main/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQueryWriteToTable.java	23
examples/java/src/main/java/org/apache/beam/examples/subprocess/Echo.cc	16
examples/java/src/main/java/org/apache/beam/examples/subprocess/EchoAgain.cc	16
examples/java/src/main/java/org/apache/beam/examples/subprocess/ExampleEchoPipeline.java	63
examples/java/src/main/java/org/apache/beam/examples/subprocess/SubProcessPipelineOptions.java	52
examples/java/src/main/java/org/apache/beam/examples/subprocess/configuration/SubProcessConfiguration.java	40
examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessCommandLineArgs.java	40
examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessIOFiles.java	75
examples/java/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessKernel.java	206
examples/java/src/main/java/org/apache/beam/examples/subprocess/utils/CallingSubProcessUtils.java	64
examples/java/src/main/java/org/apache/beam/examples/subprocess/utils/ExecutableFile.java	45
examples/java/src/main/java/org/apache/beam/examples/subprocess/utils/FileUtils.java	115
examples/java/src/test/java/org/apache/beam/examples/DebuggingWordCountTest.java	32
examples/java/src/test/java/org/apache/beam/examples/MinimalWordCountTest.java	57
examples/java/src/test/java/org/apache/beam/examples/WindowedWordCountIT.java	182
examples/java/src/test/java/org/apache/beam/examples/WordCountIT.java	43
examples/java/src/test/java/org/apache/beam/examples/WordCountTest.java	46
examples/java/src/test/java/org/apache/beam/examples/complete/AutoCompleteIT.java	31
examples/java/src/test/java/org/apache/beam/examples/complete/AutoCompleteTest.java	112
examples/java/src/test/java/org/apache/beam/examples/complete/TfIdfIT.java	45
examples/java/src/test/java/org/apache/beam/examples/complete/TfIdfTest.java	34
examples/java/src/test/java/org/apache/beam/examples/complete/TopWikipediaSessionsIT.java	44
examples/java/src/test/java/org/apache/beam/examples/complete/TopWikipediaSessionsTest.java	41
examples/java/src/test/java/org/apache/beam/examples/complete/TrafficMaxLaneFlowIT.java	67
examples/java/src/test/java/org/apache/beam/examples/complete/TrafficRoutesIT.java	66
examples/java/src/test/java/org/apache/beam/examples/complete/datatokenization/DataTokenizationTest.java	160
examples/java/src/test/java/org/apache/beam/examples/complete/game/GameStatsTest.java	49
examples/java/src/test/java/org/apache/beam/examples/complete/game/HourlyTeamScoreTest.java	80
examples/java/src/test/java/org/apache/beam/examples/complete/game/LeaderBoardTest.java	267
examples/java/src/test/java/org/apache/beam/examples/complete/game/StatefulTeamScoreTest.java	120
examples/java/src/test/java/org/apache/beam/examples/complete/game/UserScoreTest.java	114
examples/java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubE2ETest.java	100
examples/java/src/test/java/org/apache/beam/examples/complete/kafkatopubsub/KafkaToPubsubTest.java	57
examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesIT.java	73
examples/java/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesTest.java	56
examples/java/src/test/java/org/apache/beam/examples/cookbook/CombinePerKeyExamplesIT.java	68
examples/java/src/test/java/org/apache/beam/examples/cookbook/CombinePerKeyExamplesTest.java	57
examples/java/src/test/java/org/apache/beam/examples/cookbook/DistinctExampleIT.java	43
examples/java/src/test/java/org/apache/beam/examples/cookbook/DistinctExampleTest.java	33
examples/java/src/test/java/org/apache/beam/examples/cookbook/FilterExamplesIT.java	68
examples/java/src/test/java/org/apache/beam/examples/cookbook/FilterExamplesTest.java	58
examples/java/src/test/java/org/apache/beam/examples/cookbook/JoinExamplesIT.java	43
examples/java/src/test/java/org/apache/beam/examples/cookbook/JoinExamplesTest.java	84
examples/java/src/test/java/org/apache/beam/examples/cookbook/MaxPerKeyExamplesIT.java	70
examples/java/src/test/java/org/apache/beam/examples/cookbook/MaxPerKeyExamplesTest.java	66
examples/java/src/test/java/org/apache/beam/examples/cookbook/MinimalBigQueryTornadoesTest.java	52
examples/java/src/test/java/org/apache/beam/examples/cookbook/TriggerExampleTest.java	124
examples/java/src/test/java/org/apache/beam/examples/snippets/SnippetsTest.java	194
examples/java/src/test/java/org/apache/beam/examples/snippets/transforms/io/gcp/bigquery/BigQuerySamplesIT.java	151
examples/java/src/test/java/org/apache/beam/examples/subprocess/ExampleEchoPipelineTest.java	135
examples/java/src/test/resources/schema.txt	19
examples/java/src/test/resources/testInput.txt	3
examples/java/twitter/build.gradle	64
examples/java/twitter/src/main/java/org/apache/beam/examples/twitterstreamgenerator/README.md	35
examples/java/twitter/src/main/java/org/apache/beam/examples/twitterstreamgenerator/ReadFromTwitterDoFn.java	169
examples/java/twitter/src/main/java/org/apache/beam/examples/twitterstreamgenerator/TwitterConfig.java	121
examples/java/twitter/src/main/java/org/apache/beam/examples/twitterstreamgenerator/TwitterConnection.java	74
examples/java/twitter/src/main/java/org/apache/beam/examples/twitterstreamgenerator/TwitterIO.java	34
examples/java/twitter/src/main/java/org/apache/beam/examples/twitterstreamgenerator/TwitterStream.java	56
examples/java/twitter/src/main/java/org/apache/beam/examples/twitterstreamgenerator/package-info.java	1
examples/java/twitter/src/test/java/org/apache/beam/examples/twitterstreamgenerator/ReadFromTwitterDoFnTest.java	113
examples/java/webapis/README.md	17
examples/java/webapis/build.gradle	26
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/AdditionalSnippets.java	20
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/GeminiAIClient.java	74
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/GeminiAIExample.java	91
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/GeminiAIOptions.java	10
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/GenerateContentRequestCoder.java	21
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/GenerateContentResponseCoder.java	21
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/HttpImageClient.java	61
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/ImageRequest.java	41
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/ImageRequestCoder.java	25
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/ImageResponse.java	21
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/ImageResponseCoder.java	29
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/Images.java	48
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/Log.java	29
examples/java/webapis/src/main/java/org/apache/beam/examples/webapis/UsingHttpClientExample.java	22
examples/java/webapis/src/test/java/org/apache/beam/examples/webapis/GeminiAIExampleTest.java	30
examples/java/webapis/src/test/java/org/apache/beam/examples/webapis/UsingHttpClientExampleTest.java	24
examples/kotlin/README.md	41
examples/kotlin/build.gradle	95
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/DebuggingWordCount.kt	54
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/MinimalWordCount.kt	28
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/WindowedWordCount.kt	77
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/WordCount.kt	65
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/common/ExampleBigQueryTableOptions.kt	20
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/common/ExampleOptions.kt	12
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/common/ExamplePubsubTopicAndSubscriptionOptions.kt	19
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/common/ExamplePubsubTopicOptions.kt	17
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/common/ExampleUtils.kt	289
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/common/WriteOneFilePerWindow.kt	51
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/cookbook/BigQueryTornadoes.kt	90
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/cookbook/CombinePerKeyExamples.kt	88
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/cookbook/DistinctExample.kt	34
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/cookbook/FilterExamples.kt	108
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/cookbook/JoinExamples.kt	97
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/cookbook/MaxPerKeyExamples.kt	71
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/cookbook/README.md	65
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/cookbook/TriggerExample.kt	235
examples/kotlin/src/main/java/org/apache/beam/examples/kotlin/snippets/Snippets.kt	265
examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/DistinctExampleTest.kt	34
examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/FilterExamplesTest.kt	55
examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/JoinExamplesTest.kt	77
examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/MaxPerKeyExamplesTest.kt	58
examples/multi-language/README.md	144
examples/multi-language/build.gradle	33
examples/multi-language/python/addprefix.py	47
examples/multi-language/python/javacount.py	52
examples/multi-language/python/javadatagenerator.py	40
examples/multi-language/python/wordcount_external.py	50
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaCount.java	11
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaCountBuilder.java	14
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaCountConfiguration.java	2
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaCountRegistrar.java	14
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaDataGenerator.java	66
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaPrefix.java	21
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaPrefixBuilder.java	13
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaPrefixConfiguration.java	11
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/JavaPrefixRegistrar.java	14
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/schematransforms/ExtractWordsProvider.java	75
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/schematransforms/JavaCountProvider.java	55
examples/multi-language/src/main/java/org/apache/beam/examples/multilanguage/schematransforms/WriteWordsProvider.java	56
examples/notebooks/README.md	69
examples/notebooks/beam-ml/README.md	73
examples/notebooks/beam-ml/alloydb_product_catalog_embeddings.ipynb	2771
examples/notebooks/beam-ml/bigquery_enrichment_transform.ipynb	771
examples/notebooks/beam-ml/bigquery_vector_ingestion_and_search.ipynb	1648
examples/notebooks/beam-ml/bigtable_enrichment_transform.ipynb	898
examples/notebooks/beam-ml/data_preprocessing/compute_and_apply_vocab.ipynb	419
examples/notebooks/beam-ml/data_preprocessing/huggingface_text_embeddings.ipynb	399
examples/notebooks/beam-ml/data_preprocessing/scale_data.ipynb	504
examples/notebooks/beam-ml/data_preprocessing/vertex_ai_text_embeddings.ipynb	309
examples/notebooks/beam-ml/mltransform_basic.ipynb	667
examples/notebooks/beam-ml/nlp_tensorflow_streaming.ipynb	1087
examples/notebooks/beam-ml/per_key_models.ipynb	603
examples/notebooks/beam-ml/rag_usecase/chunks_generation.py	69
examples/notebooks/beam-ml/rag_usecase/opensearch_connector.py	218
examples/notebooks/beam-ml/rag_usecase/opensearch_enrichment.py	61
examples/notebooks/beam-ml/rag_usecase/opensearch_rag_pipeline.ipynb	1719
examples/notebooks/beam-ml/rag_usecase/redis_connector.py	189
examples/notebooks/beam-ml/rag_usecase/redis_enrichment.py	41
examples/notebooks/beam-ml/run_inference_generative_ai.ipynb	308
examples/notebooks/beam-ml/run_inference_huggingface.ipynb	555
examples/notebooks/beam-ml/run_inference_pytorch.ipynb	1019
examples/notebooks/beam-ml/run_inference_sklearn.ipynb	494
examples/notebooks/beam-ml/run_inference_vllm.ipynb	645
examples/notebooks/beam-ml/run_inference_windowing.ipynb	419
examples/notebooks/beam-ml/run_inference_xgboost.ipynb	375
examples/notebooks/blog/unittests_in_beam.ipynb	370
examples/notebooks/documentation/transforms/python/elementwise/filter-py.ipynb	569
examples/notebooks/documentation/transforms/python/elementwise/flatmap-py.ipynb	684
examples/notebooks/documentation/transforms/python/elementwise/keys-py.ipynb	194
examples/notebooks/documentation/transforms/python/elementwise/kvswap-py.ipynb	195
examples/notebooks/documentation/transforms/python/elementwise/map-py.ipynb	620
examples/notebooks/documentation/transforms/python/elementwise/pardo-py.ipynb	417
examples/notebooks/documentation/transforms/python/elementwise/partition-py.ipynb	387
examples/notebooks/documentation/transforms/python/elementwise/regex-py.ipynb	710
examples/notebooks/documentation/transforms/python/elementwise/tostring-py.ipynb	311
examples/notebooks/documentation/transforms/python/elementwise/values-py.ipynb	194
examples/notebooks/documentation/transforms/python/elementwise/withtimestamps-py.ipynb	369
examples/notebooks/get-started/learn_beam_basics_by_doing.ipynb	1105
examples/notebooks/get-started/learn_beam_transforms_by_doing.ipynb	782
examples/notebooks/get-started/learn_beam_windowing_by_doing.ipynb	879
examples/notebooks/get-started/try-apache-beam-go.ipynb	595
examples/notebooks/get-started/try-apache-beam-java.ipynb	1109
examples/notebooks/get-started/try-apache-beam-py.ipynb	420
examples/notebooks/get-started/try-apache-beam-yaml.ipynb	740
examples/notebooks/interactive-overview/reading-and-writing-data.ipynb	747
examples/notebooks/notebook_test_scripts/__init__.py	1
examples/notebooks/notebook_test_scripts/runner.py	92
examples/notebooks/notebook_test_scripts/testlib.py	20
examples/notebooks/patch.py	42
gradle.properties	40
it/google-cloud-platform/src/main/resources/test-artifact.json	1
learning/katas/README.md	23
learning/katas/go/README.md	50
learning/katas/go/common_transforms/aggregation/count/task.md	26
learning/katas/go/common_transforms/aggregation/max/task.md	23
learning/katas/go/common_transforms/aggregation/mean/task.md	23
learning/katas/go/common_transforms/aggregation/min/task.md	23
learning/katas/go/common_transforms/aggregation/sum/task.md	26
learning/katas/go/common_transforms/filter/filter/task.md	25
learning/katas/go/common_transforms/filter/pardo/task.md	27
learning/katas/go/core_transforms/additional_outputs/additional_outputs/task.md	41
learning/katas/go/core_transforms/branching/branching/task.md	30
learning/katas/go/core_transforms/cogroupbykey/cogroupbykey/task.md	85
learning/katas/go/core_transforms/combine/combine_perkey/task.md	38
learning/katas/go/core_transforms/combine/combinefn/task.md	43
learning/katas/go/core_transforms/combine/simple_function/task.md	37
learning/katas/go/core_transforms/composite/composite/task.md	47
learning/katas/go/core_transforms/flatten/flatten/task.md	33
learning/katas/go/core_transforms/groupbykey/groupbykey/task.md	45
learning/katas/go/core_transforms/map/pardo/task.md	33
learning/katas/go/core_transforms/map/pardo_onetomany/task.md	26
learning/katas/go/core_transforms/map/pardo_struct/task.md	29
learning/katas/go/core_transforms/partition/partition/task.md	36
learning/katas/go/core_transforms/side_input/side_input/task.md	57
learning/katas/go/go.mod	22
learning/katas/go/introduction/hello_beam/hello_beam/task.md	41
learning/katas/go/introduction/hello_beam/hello_beam_test/task.md	32
learning/katas/go/io/textio/read/task.md	35
learning/katas/go/windowing/adding_timestamp/pardo/task.md	37
learning/katas/go/windowing/fixed_time_window/fixed_time_window/task.md	66
learning/katas/java/Common Transforms/Aggregation/Count/task.md	24
learning/katas/java/Common Transforms/Aggregation/Max/task.md	24
learning/katas/java/Common Transforms/Aggregation/Mean/task.md	24
learning/katas/java/Common Transforms/Aggregation/Min/task.md	24
learning/katas/java/Common Transforms/Aggregation/Sum/task.md	24
learning/katas/java/Common Transforms/Filter/Filter/task.md	26
learning/katas/java/Common Transforms/Filter/ParDo/task.md	27
learning/katas/java/Common Transforms/WithKeys/WithKeys/task.md	29
learning/katas/java/Core Transforms/Branching/Branching/task.md	28
learning/katas/java/Core Transforms/CoGroupByKey/CoGroupByKey/task.md	38
learning/katas/java/Core Transforms/Combine/BinaryCombineFn Lambda/task.md	34
learning/katas/java/Core Transforms/Combine/BinaryCombineFn/task.md	39
learning/katas/java/Core Transforms/Combine/Combine PerKey/task.md	40
learning/katas/java/Core Transforms/Combine/CombineFn/task.md	41
learning/katas/java/Core Transforms/Combine/Simple Function/task.md	38
learning/katas/java/Core Transforms/Composite Transform/Composite Transform/task.md	41
learning/katas/java/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/task.md	35
learning/katas/java/Core Transforms/Flatten/Flatten/task.md	34
learning/katas/java/Core Transforms/FlattenWith/FlattenWith/task.md	36
learning/katas/java/Core Transforms/GroupByKey/GroupByKey/task.md	38
learning/katas/java/Core Transforms/Map/FlatMapElements/task.md	33
learning/katas/java/Core Transforms/Map/MapElements/task.md	32
learning/katas/java/Core Transforms/Map/ParDo OneToMany/task.md	33
learning/katas/java/Core Transforms/Map/ParDo/task.md	35
learning/katas/java/Core Transforms/Partition/Partition/task.md	38
learning/katas/java/Core Transforms/Side Input/Side Input/task.md	45
learning/katas/java/Core Transforms/Side Output/Side Output/task.md	37
learning/katas/java/Core Transforms/Tee/Tee/task.md	34
learning/katas/java/Examples/Word Count/Word Count/src/org/apache/beam/learning/katas/examples/wordcount/Task.java	42
learning/katas/java/Examples/Word Count/Word Count/task-info.yaml	10
learning/katas/java/Examples/Word Count/Word Count/task-remote-info.yaml	2
learning/katas/java/Examples/Word Count/Word Count/task.md	29
learning/katas/java/Examples/Word Count/Word Count/test/org/apache/beam/learning/katas/examples/wordcount/TaskTest.java	29
learning/katas/java/Examples/Word Count/lesson-info.yaml	2
learning/katas/java/Examples/Word Count/lesson-remote-info.yaml	3
learning/katas/java/Examples/section-info.yaml	2
learning/katas/java/Examples/section-remote-info.yaml	2
learning/katas/java/IO/Built-in IOs/Built-in IOs/task.md	24
learning/katas/java/IO/TextIO/TextIO Read/countries.txt	10
learning/katas/java/IO/TextIO/TextIO Read/task.md	38
learning/katas/java/Introduction/Hello Beam/Hello Beam/task.md	42
learning/katas/java/README.md	27
learning/katas/java/Triggers/Early Triggers/Early Triggers/task.md	52
learning/katas/java/Triggers/Event Time Triggers/Event Time Triggers/task.md	61
learning/katas/java/Triggers/Window Accumulation Mode/Window Accumulation Mode/task.md	56
learning/katas/java/Windowing/Adding Timestamp/ParDo/task.md	39
learning/katas/java/Windowing/Adding Timestamp/WithTimestamps/task.md	33
learning/katas/java/Windowing/Fixed Time Window/Fixed Time Window/task.md	45
learning/katas/kotlin/Common Transforms/Aggregation/Count/task.md	24
learning/katas/kotlin/Common Transforms/Aggregation/Max/task.md	24
learning/katas/kotlin/Common Transforms/Aggregation/Mean/task.md	24
learning/katas/kotlin/Common Transforms/Aggregation/Min/task.md	24
learning/katas/kotlin/Common Transforms/Aggregation/Sum/task.md	24
learning/katas/kotlin/Common Transforms/Filter/Filter/task.md	26
learning/katas/kotlin/Common Transforms/Filter/ParDo/task.md	27
learning/katas/kotlin/Common Transforms/WithKeys/WithKeys/task.md	29
learning/katas/kotlin/Core Transforms/Branching/Branching/task.md	28
learning/katas/kotlin/Core Transforms/CoGroupByKey/CoGroupByKey/task.md	38
learning/katas/kotlin/Core Transforms/Combine/BinaryCombineFn Lambda/task.md	34
learning/katas/kotlin/Core Transforms/Combine/BinaryCombineFn/task.md	39
learning/katas/kotlin/Core Transforms/Combine/Combine PerKey/task.md	40
learning/katas/kotlin/Core Transforms/Combine/CombineFn/task.md	41
learning/katas/kotlin/Core Transforms/Combine/Simple Function/task.md	38
learning/katas/kotlin/Core Transforms/Composite Transform/Composite Transform/task.md	41
learning/katas/kotlin/Core Transforms/DoFn Additional Parameters/DoFn Additional Parameters/task.md	34
learning/katas/kotlin/Core Transforms/Flatten/Flatten/task.md	34
learning/katas/kotlin/Core Transforms/GroupByKey/GroupByKey/task.md	38
learning/katas/kotlin/Core Transforms/Map/FlatMapElements/task.md	33
learning/katas/kotlin/Core Transforms/Map/MapElements/task.md	32
learning/katas/kotlin/Core Transforms/Map/ParDo OneToMany/task.md	33
learning/katas/kotlin/Core Transforms/Map/ParDo/task.md	35
learning/katas/kotlin/Core Transforms/Partition/Partition/task.md	38
learning/katas/kotlin/Core Transforms/Side Input/Side Input/src/task.md	45
learning/katas/kotlin/Core Transforms/Side Input/Side Input/task.md	45
learning/katas/kotlin/Core Transforms/Side Output/Side Output/src/task.md	37
learning/katas/kotlin/Core Transforms/Side Output/Side Output/task.md	37
learning/katas/kotlin/Examples/Word Count/Word Count/src/org/apache/beam/learning/katas/examples/wordcount/Task.kt	41
learning/katas/kotlin/Examples/Word Count/Word Count/task-info.yaml	10
learning/katas/kotlin/Examples/Word Count/Word Count/task-remote-info.yaml	2
learning/katas/kotlin/Examples/Word Count/Word Count/task.md	29
learning/katas/kotlin/Examples/Word Count/Word Count/test/org/apache/beam/learning/katas/examples/wordcount/TaskTest.kt	29
learning/katas/kotlin/Examples/Word Count/lesson-info.yaml	2
learning/katas/kotlin/Examples/Word Count/lesson-remote-info.yaml	3
learning/katas/kotlin/Examples/section-info.yaml	2
learning/katas/kotlin/Examples/section-remote-info.yaml	2
learning/katas/kotlin/IO/Built-in IOs/Built-in IOs/task.md	24
learning/katas/kotlin/IO/TextIO/TextIO Read/countries.txt	10
learning/katas/kotlin/IO/TextIO/TextIO Read/task.md	38
learning/katas/kotlin/Introduction/Hello Beam/Hello Beam/task.md	42
learning/katas/kotlin/README.md	27
learning/katas/kotlin/Triggers/Early Triggers/Early Triggers/task.md	52
learning/katas/kotlin/Triggers/Event Time Triggers/Event Time Triggers/task.md	61
learning/katas/kotlin/Triggers/Window Accumulation Mode/Window Accumulation Mode/task.md	56
learning/katas/kotlin/Windowing/Adding Timestamp/ParDo/task.md	39
learning/katas/kotlin/Windowing/Adding Timestamp/WithTimestamps/task.md	33
learning/katas/kotlin/Windowing/Fixed Time Window/Fixed Time Window/task.md	45
learning/katas/python/Common Transforms/Aggregation/Count/task.md	24
learning/katas/python/Common Transforms/Aggregation/Largest/task.md	24
learning/katas/python/Common Transforms/Aggregation/Mean/task.md	24
learning/katas/python/Common Transforms/Aggregation/Smallest/task.md	24
learning/katas/python/Common Transforms/Aggregation/Sum/task.md	25
learning/katas/python/Common Transforms/Filter/Filter/task.md	26
learning/katas/python/Common Transforms/Filter/ParDo/task.md	25
learning/katas/python/Common Transforms/WithKeys/WithKeys/task.md	25
learning/katas/python/Core Transforms/Branching/Branching/task.md	28
learning/katas/python/Core Transforms/CoGroupByKey/CoGroupByKey/task.md	35
learning/katas/python/Core Transforms/Combine/Combine PerKey/task.md	40
learning/katas/python/Core Transforms/Combine/CombineFn/task.md	41
learning/katas/python/Core Transforms/Combine/Simple Function/task.md	36
learning/katas/python/Core Transforms/Composite Transform/Composite Transform/task.md	40
learning/katas/python/Core Transforms/Flatten/Flatten/task.md	33
learning/katas/python/Core Transforms/FlattenWith/FlattenWith/task.md	35
learning/katas/python/Core Transforms/GroupByKey/GroupByKey/task.md	37
learning/katas/python/Core Transforms/Map/FlatMap/task.md	33
learning/katas/python/Core Transforms/Map/Map/task.md	31
learning/katas/python/Core Transforms/Map/ParDo OneToMany/task.md	38
learning/katas/python/Core Transforms/Map/ParDo/task.md	38
learning/katas/python/Core Transforms/Partition/Partition/task.md	37
learning/katas/python/Core Transforms/Side Input/Side Input/task.md	44
learning/katas/python/Core Transforms/Side Output/Side Output/task.md	37
learning/katas/python/Core Transforms/Tee/Tee/task.md	34
learning/katas/python/Examples/Word Count/Word Count/__init__.py	1
learning/katas/python/Examples/Word Count/Word Count/task-info.yaml	14
learning/katas/python/Examples/Word Count/Word Count/task.md	33
learning/katas/python/Examples/Word Count/Word Count/task.py	11
learning/katas/python/Examples/Word Count/Word Count/tests/__init__.py	1
learning/katas/python/Examples/Word Count/Word Count/tests/test_task.py	16
learning/katas/python/Examples/Word Count/lesson-info.yaml	2
learning/katas/python/Examples/section-info.yaml	2
learning/katas/python/IO/TextIO/ReadFromText/countries.txt	10
learning/katas/python/IO/TextIO/ReadFromText/task.md	42
learning/katas/python/Introduction/Hello Beam/Hello Beam/task.md	42
learning/katas/python/README.md	28
learning/katas/python/Streaming/Timestamps/Add Timestamps/task.md	38
learning/katas/python/Streaming/Triggers/Early Triggers/task.md	51
learning/katas/python/Streaming/Triggers/Event Time Triggers/task.md	59
learning/katas/python/Streaming/Triggers/Window Accumulation Modes/task.md	55
learning/katas/python/Streaming/Windows/Fixed Windows/task.md	45
learning/katas/python/requirements.txt	18
learning/prompts/README.md	65
learning/prompts/code-explanation/01_io_kafka.md	56
learning/prompts/code-explanation/02_io_pubsub.md	24
learning/prompts/code-explanation/03_io_bigquery.md	30
learning/prompts/code-explanation/04_io_bigtable.md	37
learning/prompts/code-explanation/05_io_spanner.md	82
learning/prompts/code-explanation/06_io_tfrecord.md	47
learning/prompts/code-explanation/07_io_json.md	42
learning/prompts/code-explanation/08_io_csv.md	36
learning/prompts/code-explanation/09_io_avro.md	32
learning/prompts/code-explanation/10_io_parquet.md	32
learning/prompts/code-explanation/11_io_jdbc.md	92
learning/prompts/code-explanation/java/01_io_kafka.md	94
learning/prompts/code-explanation/java/02_io_pubsub.md	59
learning/prompts/code-explanation/java/03_io_bigquery.md	59
learning/prompts/code-explanation/java/04_io_bigtable.md	124
learning/prompts/code-explanation/java/05_io_spanner.md	112
learning/prompts/code-explanation/java/06_io_tfrecord.md	93
learning/prompts/code-explanation/java/07_io_json.md	107
learning/prompts/code-explanation/java/08_io_csv.md	105
learning/prompts/code-explanation/java/09_io_avro.md	70
learning/prompts/code-explanation/java/10_io_parquet.md	124
learning/prompts/code-explanation/java/11_io_jdbc.md	198
learning/prompts/code-generation/01_io_kafka.md	39
learning/prompts/code-generation/02_io_pubsub.md	37
learning/prompts/code-generation/03_io_bigquery.md	42
learning/prompts/code-generation/04_io_bigtable.md	53
learning/prompts/code-generation/05_io_spanner.md	52
learning/prompts/code-generation/06_io_tfrecord.md	42
learning/prompts/code-generation/07_io_json.md	34
learning/prompts/code-generation/08_io_csv.md	33
learning/prompts/code-generation/09_io_avro.md	27
learning/prompts/code-generation/10_io_parquet.md	27
learning/prompts/code-generation/11_io_jdbc.md	60
learning/prompts/code-generation/java/01_io_kafka.md	62
learning/prompts/code-generation/java/02_io_pubsub.md	48
learning/prompts/code-generation/java/03_io_bigquery.md	82
learning/prompts/code-generation/java/04_io_bigtable.md	107
learning/prompts/code-generation/java/05_io_spanner.md	90
learning/prompts/code-generation/java/06_io_tfrecord.md	66
learning/prompts/code-generation/java/07_io_json.md	69
learning/prompts/code-generation/java/08_io_csv.md	62
learning/prompts/code-generation/java/09_io_avro.md	54
learning/prompts/code-generation/java/10_io_parquet.md	107
learning/prompts/code-generation/java/11_io_jdbc.md	102
learning/prompts/documentation-lookup-nolinks/01_basic_learning_apache_beam.md	12
learning/prompts/documentation-lookup-nolinks/02_basic_pipelines.md	12
learning/prompts/documentation-lookup-nolinks/03_basic_configuring_pipelines.md	21
learning/prompts/documentation-lookup-nolinks/04_basic_pcollections.md	18
learning/prompts/documentation-lookup-nolinks/05_basic_ptransforms.md	26
learning/prompts/documentation-lookup-nolinks/06_basic_schema.md	18
learning/prompts/documentation-lookup-nolinks/07_basic_runners.md	18
learning/prompts/documentation-lookup-nolinks/08_basic_windowing.md	21
learning/prompts/documentation-lookup-nolinks/09_basic_triggers.md	23
learning/prompts/documentation-lookup-nolinks/10_basic_metrics.md	18
learning/prompts/documentation-lookup-nolinks/11_basic_state.md	14
learning/prompts/documentation-lookup-nolinks/12_basic_timers.md	7
learning/prompts/documentation-lookup-nolinks/13_advanced_splittable_dofn.md	13
learning/prompts/documentation-lookup-nolinks/14_advanced_pipeline_patterns.md	11
learning/prompts/documentation-lookup-nolinks/15_advanced_xlang.md	7
learning/prompts/documentation-lookup-nolinks/16_advanced_pipeline_lifecycle.md	23
learning/prompts/documentation-lookup-nolinks/17_advanced_ai_ml.md	12
learning/prompts/documentation-lookup-nolinks/18_io_kafka.md	22
learning/prompts/documentation-lookup-nolinks/19_io_pubsub.md	17
learning/prompts/documentation-lookup-nolinks/20_io_biguery.md	32
learning/prompts/documentation-lookup-nolinks/21_io_bigtable.md	22
learning/prompts/documentation-lookup-nolinks/22_io_spanner.md	26
learning/prompts/documentation-lookup-nolinks/23_io_gcs.md	9
learning/prompts/documentation-lookup-nolinks/24_io_json.md	23
learning/prompts/documentation-lookup-nolinks/25_io_csv.md	23
learning/prompts/documentation-lookup-nolinks/26_io_avro.md	19
learning/prompts/documentation-lookup-nolinks/27_io_parquet.md	15
learning/prompts/documentation-lookup-nolinks/28_io_jdbc.md	33
learning/prompts/documentation-lookup-nolinks/29_advanced_side_inputs.md	27
learning/prompts/documentation-lookup-nolinks/30_advanced_additional_outputs.md	81
learning/prompts/documentation-lookup-nolinks/31_advanced_batched_dofn.md	26
learning/prompts/documentation-lookup-nolinks/32_data_encoding.md	9
learning/prompts/documentation-lookup-nolinks/33_ai_ml_pipelines.md	11
learning/prompts/documentation-lookup-nolinks/34_change_coders_data_encoding.md	76
learning/prompts/documentation-lookup-nolinks/35_coders_data_encoding.md	27
learning/prompts/documentation-lookup-nolinks/36_ai_kfp_orchestration.md	38
learning/prompts/documentation-lookup-nolinks/37_ai_tfx_orchestration.md	13
learning/prompts/documentation-lookup-nolinks/38_ai_runinference.md	26
learning/prompts/documentation-lookup-nolinks/39_ai_runinference_metrics.md	29
learning/prompts/documentation-lookup-nolinks/40_ai_bigquery_ml.md	36
learning/prompts/documentation-lookup-nolinks/41_ai_model_refresh.md	27
learning/prompts/documentation-lookup-nolinks/42_ai_custom_inference.md	37
learning/prompts/documentation-lookup-nolinks/43_ai_llm_inference.md	47
learning/prompts/documentation-lookup-nolinks/44_batching_for_external_calls.md	52
learning/prompts/documentation-lookup-nolinks/46_ml_data_exploration.md	39
learning/prompts/documentation-lookup-nolinks/47_resource_hints.md	49
learning/prompts/documentation-lookup-nolinks/48_sdk_harness.md	13
learning/prompts/documentation-lookup-nolinks/49_container_environments.md	75
learning/prompts/documentation-lookup-nolinks/50_beam_yaml.md	56
learning/prompts/documentation-lookup-nolinks/51_ml_data_preprocessing.md	66
learning/prompts/documentation-lookup-nolinks/52_transform_service.md	23
learning/prompts/documentation-lookup-nolinks/53_dataflow_runner.md	56
learning/prompts/documentation-lookup-nolinks/54_spark_runner.md	102
learning/prompts/documentation-lookup-nolinks/55_direct_runner.md	46
learning/prompts/documentation-lookup-nolinks/56_unit_test_your_pipeline.md	108
learning/prompts/documentation-lookup/01_basic_learning_apache_beam.md	14
learning/prompts/documentation-lookup/02_basic_pipelines.md	13
learning/prompts/documentation-lookup/03_basic_configuring_pipelines.md	21
learning/prompts/documentation-lookup/04_basic_pcollections.md	18
learning/prompts/documentation-lookup/05_basic_ptransforms.md	26
learning/prompts/documentation-lookup/06_basic_schema.md	18
learning/prompts/documentation-lookup/07_basic_runners.md	18
learning/prompts/documentation-lookup/08_basic_windowing.md	22
learning/prompts/documentation-lookup/09_basic_triggers.md	22
learning/prompts/documentation-lookup/10_basic_metrics.md	18
learning/prompts/documentation-lookup/11_basic_state.md	15
learning/prompts/documentation-lookup/12_basic_timers.md	8
learning/prompts/documentation-lookup/13_advanced_splittable_dofn.md	13
learning/prompts/documentation-lookup/14_advanced_pipeline_patterns.md	11
learning/prompts/documentation-lookup/15_advanced_xlang.md	8
learning/prompts/documentation-lookup/16_advanced_pipeline_lifecycle.md	24
learning/prompts/documentation-lookup/17_advanced_ai_ml.md	13
learning/prompts/documentation-lookup/18_io_kafka.md	21
learning/prompts/documentation-lookup/19_io_pubsub.md	18
learning/prompts/documentation-lookup/20_io_biguery.md	31
learning/prompts/documentation-lookup/21_io_bigtable.md	23
learning/prompts/documentation-lookup/22_io_spanner.md	25
learning/prompts/documentation-lookup/23_io_gcs.md	16
learning/prompts/documentation-lookup/24_io_json.md	27
learning/prompts/documentation-lookup/25_io_csv.md	26
learning/prompts/documentation-lookup/26_io_avro.md	23
learning/prompts/documentation-lookup/27_io_parquet.md	22
learning/prompts/documentation-lookup/28_io_jdbc.md	42
learning/prompts/documentation-lookup/29_advanced_side_inputs.md	27
learning/prompts/documentation-lookup/30_advanced_additional_outputs.md	85
learning/prompts/documentation-lookup/31_advanced_batched_dofn.md	28
learning/prompts/documentation-lookup/33_ai_ml_pipelines.md	9
learning/prompts/documentation-lookup/36_ai_kfp_orchestration.md	38
learning/prompts/documentation-lookup/37_ai_tfx_orchestration.md	13
learning/prompts/documentation-lookup/38_ai_runinference.md	27
learning/prompts/documentation-lookup/39_ai_runinference_metrics.md	29
learning/prompts/documentation-lookup/40_ai_bigquery_ml.md	36
learning/prompts/documentation-lookup/41_ai_model_refresh.md	27
learning/prompts/documentation-lookup/42_ai_custom_inference.md	37
learning/prompts/documentation-lookup/43_ai_llm_inference.md	47
learning/prompts/documentation-lookup/48_sdk_harness.md	14
learning/prompts/documentation-lookup/52_transform_service.md	23
learning/prompts/documentation-lookup/53_dataflow_runner.md	55
learning/prompts/documentation-lookup/54_spark_runner.md	101
learning/prompts/documentation-lookup/55_direct_runner.md	45
learning/tour-of-beam/README.md	21
learning/tour-of-beam/backend/README.md	148
learning/tour-of-beam/backend/go.mod	28
learning/tour-of-beam/backend/integration_tests/emulators/firebase/firebase.json	12
learning/tour-of-beam/backend/samples/api/get_content_tree.json	42
learning/tour-of-beam/backend/samples/api/get_sdk_list.json	7
learning/tour-of-beam/backend/samples/api/get_unit_content.json	11
learning/tour-of-beam/backend/samples/api/get_unit_content_full.json	13
learning/tour-of-beam/backend/samples/api/get_user_progress.json	12
learning/tour-of-beam/backend/samples/learning-content/content-info.yaml	6
learning/tour-of-beam/backend/samples/learning-content/module 1/group/group-info.yaml	8
learning/tour-of-beam/backend/samples/learning-content/module 1/group/unit-challenge/description.md	2
learning/tour-of-beam/backend/samples/learning-content/module 1/group/unit-challenge/hint1.md	2
learning/tour-of-beam/backend/samples/learning-content/module 1/group/unit-challenge/hint2.md	2
learning/tour-of-beam/backend/samples/learning-content/module 1/group/unit-challenge/unit-info.yaml	7
learning/tour-of-beam/backend/samples/learning-content/module 1/group/unit-example/unit-info.yaml	5
learning/tour-of-beam/backend/samples/learning-content/module 1/intro-unit/unit-info.yaml	5
learning/tour-of-beam/backend/samples/learning-content/module 1/module-info.yaml	11
learning/tour-of-beam/backend/samples/learning-content/module 1/unit-challenge/description.md	2
learning/tour-of-beam/backend/samples/learning-content/module 1/unit-challenge/hint1.md	2
learning/tour-of-beam/backend/samples/learning-content/module 1/unit-challenge/hint2.md	2
learning/tour-of-beam/backend/samples/learning-content/module 1/unit-challenge/unit-info.yaml	7
learning/tour-of-beam/backend/samples/learning-content/module 1/unit-example/unit-info.yaml	5
learning/tour-of-beam/backend/samples/learning-content/module 2/module-info.yaml	8
learning/tour-of-beam/backend/samples/learning-content/module 2/unit-challenge/description.md	2
learning/tour-of-beam/backend/samples/learning-content/module 2/unit-challenge/hint1.md	2
learning/tour-of-beam/backend/samples/learning-content/module 2/unit-challenge/hint2.md	2
learning/tour-of-beam/backend/samples/learning-content/module 2/unit-challenge/unit-info.yaml	7
learning/tour-of-beam/backend/samples/learning-content/module 2/unit-example/unit-info.yaml	5
learning/tour-of-beam/backend/samples/learning-content_empty/java/content-info.yaml	2
learning/tour-of-beam/backend/samples/learning-content_empty/python/content-info.yaml	2
learning/tour-of-beam/cloudbuild/README.md	115
learning/tour-of-beam/frontend/README.md	72
learning/tour-of-beam/frontend/assets/svg/google-logo.svg	19
learning/tour-of-beam/frontend/assets/svg/profile-about.svg	18
learning/tour-of-beam/frontend/assets/svg/profile-logout.svg	16
learning/tour-of-beam/frontend/assets/svg/solution.svg	17
learning/tour-of-beam/frontend/assets/svg/unit-progress-0.svg	16
learning/tour-of-beam/frontend/assets/svg/unit-progress-100.svg	16
learning/tour-of-beam/frontend/assets/svg/welcome-progress-0.svg	16
learning/tour-of-beam/frontend/firebase.json	16
learning/tour-of-beam/frontend/web/manifest.json	18
learning/tour-of-beam/learning-content/README.md	205
learning/tour-of-beam/learning-content/common-transforms/aggregation/count/description.md	239
learning/tour-of-beam/learning-content/common-transforms/aggregation/max/description.md	151
learning/tour-of-beam/learning-content/common-transforms/aggregation/mean/description.md	109
learning/tour-of-beam/learning-content/common-transforms/aggregation/min/description.md	145
learning/tour-of-beam/learning-content/common-transforms/aggregation/sum/description.md	145
learning/tour-of-beam/learning-content/common-transforms/filter/description.md	326
learning/tour-of-beam/learning-content/common-transforms/filter/hint1.md	69
learning/tour-of-beam/learning-content/common-transforms/motivating-challenge/description.md	20
learning/tour-of-beam/learning-content/common-transforms/motivating-challenge/hint1.md	27
learning/tour-of-beam/learning-content/common-transforms/with-keys/description.md	68
learning/tour-of-beam/learning-content/core-transforms/additional-outputs/description.md	253
learning/tour-of-beam/learning-content/core-transforms/branching/description.md	101
learning/tour-of-beam/learning-content/core-transforms/combine/binary-combine-fn/description.md	33
learning/tour-of-beam/learning-content/core-transforms/combine/combine-fn/description.md	191
learning/tour-of-beam/learning-content/core-transforms/combine/combine-per-key/description.md	110
learning/tour-of-beam/learning-content/core-transforms/combine/simple-function/description.md	91
learning/tour-of-beam/learning-content/core-transforms/composite/description.md	214
learning/tour-of-beam/learning-content/core-transforms/flatten/description.md	79
learning/tour-of-beam/learning-content/core-transforms/map/co-group-by-key/description.md	255
learning/tour-of-beam/learning-content/core-transforms/map/flat-map-elements/description.md	54
learning/tour-of-beam/learning-content/core-transforms/map/group-by-key/description.md	127
learning/tour-of-beam/learning-content/core-transforms/map/map-elements/description.md	80
learning/tour-of-beam/learning-content/core-transforms/map/pardo-one-to-many/description.md	57
learning/tour-of-beam/learning-content/core-transforms/map/pardo-one-to-one/description.md	337
learning/tour-of-beam/learning-content/core-transforms/motivating-challenge-1/description.md	13
learning/tour-of-beam/learning-content/core-transforms/motivating-challenge-1/hint1.md	50
learning/tour-of-beam/learning-content/core-transforms/motivating-challenge-2/description.md	19
learning/tour-of-beam/learning-content/core-transforms/motivating-challenge-2/hint1.md	26
learning/tour-of-beam/learning-content/core-transforms/motivating-challenge-3/description.md	13
learning/tour-of-beam/learning-content/core-transforms/motivating-challenge-3/hint1.md	117
learning/tour-of-beam/learning-content/core-transforms/motivating-challenge-4/description.md	16
learning/tour-of-beam/learning-content/core-transforms/motivating-challenge-4/hint1.md	71
learning/tour-of-beam/learning-content/core-transforms/partition/description.md	122
learning/tour-of-beam/learning-content/core-transforms/side-inputs/description.md	242
learning/tour-of-beam/learning-content/cross-language/multi-pipeline/description.md	315
learning/tour-of-beam/learning-content/cross-language/multi-pipeline/python-example/input.txt	21
learning/tour-of-beam/learning-content/cross-language/sql-transform/description.md	103
learning/tour-of-beam/learning-content/final-challenge/final-challenge-1/description.md	22
learning/tour-of-beam/learning-content/final-challenge/final-challenge-1/hint1.md	136
learning/tour-of-beam/learning-content/final-challenge/final-challenge-2/description.md	19
learning/tour-of-beam/learning-content/final-challenge/final-challenge-2/hint1.md	165
learning/tour-of-beam/learning-content/introduction/introduction-concepts/creating-collections/from-memory/description.md	67
learning/tour-of-beam/learning-content/introduction/introduction-concepts/creating-collections/reading-from-csv/description.md	25
learning/tour-of-beam/learning-content/introduction/introduction-concepts/creating-collections/reading-from-text/description.md	51
learning/tour-of-beam/learning-content/introduction/introduction-concepts/pipeline-concepts/creating-pipeline/description.md	68
learning/tour-of-beam/learning-content/introduction/introduction-concepts/pipeline-concepts/overview-pipeline/description.md	28
learning/tour-of-beam/learning-content/introduction/introduction-concepts/pipeline-concepts/setting-pipeline/description.md	146
learning/tour-of-beam/learning-content/introduction/introduction-concepts/runner-concepts/description.md	493
learning/tour-of-beam/learning-content/introduction/introduction-guide/description.md	27
learning/tour-of-beam/learning-content/introduction/introduction-terms/description.md	24
learning/tour-of-beam/learning-content/io/big-query-io/beam-schema/description.md	22
learning/tour-of-beam/learning-content/io/big-query-io/read-query/description.md	38
learning/tour-of-beam/learning-content/io/big-query-io/read-table/description.md	40
learning/tour-of-beam/learning-content/io/big-query-io/table-schema/description.md	104
learning/tour-of-beam/learning-content/io/kafka-io/kafka-read/description.md	60
learning/tour-of-beam/learning-content/io/kafka-io/kafka-write/description.md	52
learning/tour-of-beam/learning-content/io/rest-api/description.md	100
learning/tour-of-beam/learning-content/io/text-io/text-io-gcs-read/description.md	48
learning/tour-of-beam/learning-content/io/text-io/text-io-gcs-write/description.md	73
learning/tour-of-beam/learning-content/io/text-io/text-io-local-read/description.md	78
learning/tour-of-beam/learning-content/io/text-io/text-io-local-read/go-example/myfile.txt	1
learning/tour-of-beam/learning-content/io/text-io/text-io-local-read/java-example/myfile.txt	1
learning/tour-of-beam/learning-content/io/text-io/text-io-local-read/python-example/myfile.txt	1
learning/tour-of-beam/learning-content/io/text-io/text-io-local-write/description.md	78
learning/tour-of-beam/learning-content/io/text-io/text-io-local-write/go-example/myfile.txt	1
learning/tour-of-beam/learning-content/io/text-io/text-io-local-write/java-example/myfile.txt	1
learning/tour-of-beam/learning-content/io/text-io/text-io-local-write/python-example/myfile.txt	1
learning/tour-of-beam/learning-content/schema-based-transforms/co-group/description.md	76
learning/tour-of-beam/learning-content/schema-based-transforms/coder/description.md	114
learning/tour-of-beam/learning-content/schema-based-transforms/convert/description.md	27
learning/tour-of-beam/learning-content/schema-based-transforms/filter/description.md	57
learning/tour-of-beam/learning-content/schema-based-transforms/group/description.md	47
learning/tour-of-beam/learning-content/schema-based-transforms/join/description.md	36
learning/tour-of-beam/learning-content/schema-based-transforms/motivating-challenge/description.md	28
learning/tour-of-beam/learning-content/schema-based-transforms/motivating-challenge/hint1.md	23
learning/tour-of-beam/learning-content/schema-based-transforms/rename/description.md	28
learning/tour-of-beam/learning-content/schema-based-transforms/schema-concept/creating-schema/description.md	145
learning/tour-of-beam/learning-content/schema-based-transforms/schema-concept/logical-type/description.md	80
learning/tour-of-beam/learning-content/schema-based-transforms/select/description.md	88
learning/tour-of-beam/learning-content/splittable-dofn/splittable/description.md	103
learning/tour-of-beam/learning-content/triggers/composite-trigger/description.md	62
learning/tour-of-beam/learning-content/triggers/concept/description.md	118
learning/tour-of-beam/learning-content/triggers/data-driven-trigger/description.md	37
learning/tour-of-beam/learning-content/triggers/event-time-trigger/description.md	46
learning/tour-of-beam/learning-content/triggers/motivating-challenge/description.md	19
learning/tour-of-beam/learning-content/triggers/motivating-challenge/hint1.md	32
learning/tour-of-beam/learning-content/triggers/processing-trigger/description.md	41
learning/tour-of-beam/learning-content/windowing/adding-timestamp/description.md	48
learning/tour-of-beam/learning-content/windowing/fixed-time-window/description.md	55
learning/tour-of-beam/learning-content/windowing/global-window/description.md	85
learning/tour-of-beam/learning-content/windowing/motivating-challenge/description.md	20
learning/tour-of-beam/learning-content/windowing/motivating-challenge/hint1.md	35
learning/tour-of-beam/learning-content/windowing/session-window/description.md	65
learning/tour-of-beam/learning-content/windowing/sliding-time-window/description.md	59
learning/tour-of-beam/learning-content/windowing/windowing-concept/description.md	32
learning/tour-of-beam/terraform/README.md	202
playground/README.md	197
playground/TASKS.md	204
playground/backend/CONTRIBUTE.md	142
playground/backend/README.md	117
playground/backend/SCHEMA.md	158
playground/backend/configs/SDK_GO.json	16
playground/backend/configs/SDK_JAVA.json	21
playground/backend/configs/SDK_PYTHON.json	8
playground/backend/configs/SDK_SCIO.json	10
playground/backend/datasets/CountWordsJson.json	22
playground/backend/datasets/NYCTaxi1000_simpleJson.json	3994
playground/backend/go.mod	86
playground/backend/logging.properties	19
playground/frontend/CONTRIBUTE.md	66
playground/frontend/README.md	257
playground/frontend/assets/colab.svg	23
playground/frontend/assets/copy.svg	24
playground/frontend/assets/github.svg	21
playground/frontend/assets/link.svg	25
playground/frontend/assets/output_bottom.svg	23
playground/frontend/assets/output_left.svg	23
playground/frontend/assets/output_right.svg	23
playground/frontend/assets/thumb_down.svg	21
playground/frontend/assets/thumb_down_filled.svg	21
playground/frontend/assets/thumb_up.svg	21
playground/frontend/assets/thumb_up_filled.svg	21
playground/frontend/gradle.properties	23
playground/frontend/lib/modules/examples/components/description_popover/description_popover.dart	40
playground/frontend/lib/modules/examples/components/description_popover/description_popover_button.dart	72
playground/frontend/lib/modules/examples/components/example_actions.dart	30
playground/frontend/lib/modules/examples/components/example_list/category_expansion_panel.dart	64
playground/frontend/lib/modules/examples/components/example_list/example_item_actions.dart	70
playground/frontend/lib/modules/examples/components/example_list/example_list.dart	44
playground/frontend/lib/modules/examples/components/example_list/expansion_panel_item.dart	63
playground/frontend/lib/modules/examples/components/examples_components.dart	6
playground/frontend/lib/modules/examples/components/filter/filter.dart	80
playground/frontend/lib/modules/examples/components/filter/tag_bubble.dart	31
playground/frontend/lib/modules/examples/components/filter/type_bubble.dart	31
playground/frontend/lib/modules/examples/components/multi_file_icon.dart	18
playground/frontend/lib/modules/examples/components/outside_click_handler.dart	23
playground/frontend/lib/modules/examples/components/search_field/search_field.dart	71
playground/frontend/lib/modules/examples/components/web_scroll_converter.dart	26
playground/frontend/lib/modules/examples/example_selector.dart	129
playground/frontend/lib/modules/examples/examples_dropdown_content.dart	73
playground/frontend/lib/modules/examples/models/example_loading_descriptors/examples_loading_descriptor_factory.dart	82
playground/frontend/lib/modules/examples/models/example_loading_descriptors/no_url_example_loading_descriptor.dart	12
playground/frontend/lib/modules/examples/models/popover_state.dart	10
playground/frontend/playground_components/README.md	19
playground/frontend/playground_components/assets/buttons/reset.svg	21
playground/frontend/playground_components/assets/buttons/theme-mode.svg	17
playground/frontend/playground_components/assets/notification_icons/error.svg	24
playground/frontend/playground_components/assets/notification_icons/info.svg	24
playground/frontend/playground_components/assets/notification_icons/success.svg	24
playground/frontend/playground_components/assets/notification_icons/warning.svg	24
playground/frontend/playground_components/assets/svg/drag-horizontal.svg	20
playground/frontend/playground_components/assets/svg/drag-vertical.svg	20
playground/frontend/playground_components/assets/svg/thumb_down.svg	21
playground/frontend/playground_components/assets/svg/thumb_down_filled.svg	21
playground/frontend/playground_components/assets/svg/thumb_up.svg	21
playground/frontend/playground_components/assets/svg/thumb_up_filled.svg	21
playground/frontend/playground_components/test/tools/extract_symbols_go/sdk_mock/directory/ignore.txt	16
playground/frontend/playground_components/tools/extract_symbols_go/go.mod	17
playground/frontend/playground_components_dev/README.md	19
playground/frontend/playground_components_dev/lib/src/examples/example_descriptor.dart	75
playground/frontend/playground_components_dev/lib/src/examples/go/content/example.go	17
playground/frontend/playground_components_dev/lib/src/examples/go/example.dart	72
playground/frontend/playground_components_dev/lib/src/examples/go/minimal_word_count.dart	13
playground/frontend/playground_components_dev/lib/src/examples/go/word_count.dart	8
playground/frontend/playground_components_dev/lib/src/examples/java/aggregation_max.dart	10
playground/frontend/playground_components_dev/lib/src/examples/java/content/example.java	15
playground/frontend/playground_components_dev/lib/src/examples/java/example.dart	70
playground/frontend/playground_components_dev/lib/src/examples/java/minimal_word_count.dart	11
playground/frontend/playground_components_dev/lib/src/examples/python/aggregation_mean.dart	9
playground/frontend/playground_components_dev/lib/src/examples/python/word_count_with_metrics.dart	10
playground/frontend/playground_components_dev/lib/src/examples/scio/common.dart	1
playground/frontend/playground_components_dev/lib/src/examples/scio/minimal_word_count.dart	13
playground/frontend/test/modules/examples/models/example_loading_descriptors/examples_loading_descriptor_factory_test.dart	58
playground/frontend/web/manifest.json	11
playground/infrastructure/requirements.txt	28
playground/load_your_code.md	444
playground/terraform/README.md	220
playground/terraform/infrastructure/cloudbuild-manual-setup/README.md	123
plugins/beam-code-completion-plugin/README.md	28
plugins/beam-code-completion-plugin/src/main/resources/META-INF/pluginIcon.svg	26
release/go-licenses/go.mod	16
release/src/main/scripts/github_actions_jobs.txt	25
release/src/main/scripts/jenkins_jobs.txt	115
runners/flink/src/main/resources/log4j.properties	22
runners/flink/src/test/resources/log4j-test.properties	25
runners/google-cloud-dataflow-java/examples/build.gradle	135
runners/google-cloud-dataflow-java/src/main/resources/org/apache/beam/runners/dataflow/dataflow.properties	22
runners/samza/src/main/resources/log4j.properties	22
runners/samza/src/main/resources/samza-conf.properties	33
runners/samza/src/test/resources/ExpectedDag.json	373
runners/samza/src/test/resources/log4j-test.properties	24
runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/examples/WordCount.java	68
runners/spark/src/main/java/org/apache/beam/runners/spark/examples/WordCount.java	68
runners/spark/src/main/resources/log4j.properties	35
runners/spark/src/test/resources/log4j-test.properties	35
scripts/ci/issue-report/package-lock.json	394
scripts/ci/issue-report/package.json	6
scripts/ci/pr-bot/Commands.md	27
scripts/ci/pr-bot/README.md	34
scripts/ci/pr-bot/package-lock.json	2708
scripts/ci/pr-bot/package.json	29
scripts/ci/pr-bot/tsconfig.json	12
scripts/ci/release/test/resources/jenkins_trigger_phrases.txt	19
scripts/ci/release/test/resources/mass_comment.txt	106
sdks/go.mod	200
sdks/go/BUILD.md	63
sdks/go/README.md	120
sdks/go/cmd/prism/README.md	31
sdks/go/data/fhir_bundles/batch-success-failure.json	44
sdks/go/data/fhir_bundles/transaction-failure.json	44
sdks/go/data/fhir_bundles/transaction-success.json	112
sdks/go/data/haiku/old_pond.txt	3
sdks/go/data/shakespeare/hamlet.txt	4376
sdks/go/data/shakespeare/kinglear-hashtag.txt	3862
sdks/go/data/shakespeare/kinglear.txt	3862
sdks/go/data/shakespeare/romeoandjuliet.txt	3412
sdks/go/examples/build.gradle	13
sdks/go/examples/complete/autocomplete/autocomplete.go	50
sdks/go/examples/contains/contains.go	67
sdks/go/examples/cookbook/combine/combine.go	73
sdks/go/examples/cookbook/filter/filter.go	70
sdks/go/examples/cookbook/join/join.go	83
sdks/go/examples/cookbook/max/max.go	59
sdks/go/examples/cookbook/tornadoes/tornadoes.go	63
sdks/go/examples/debugging_wordcount/debugging_wordcount.go	75
sdks/go/examples/fhirio/import/import.go	25
sdks/go/examples/fhirio/read_write_pubsub/read_write_pubsub.go	73
sdks/go/examples/forest/forest.go	42
sdks/go/examples/grades/grades.go	75
sdks/go/examples/kafka/taxi.go	47
sdks/go/examples/large_wordcount/large_wordcount.go	241
sdks/go/examples/large_wordcount/large_wordcount_test.go	79
sdks/go/examples/minimal_wordcount/minimal_wordcount.go	38
sdks/go/examples/multiout/multiout.go	56
sdks/go/examples/native_wordcap/nativepubsubio/native.go	167
sdks/go/examples/native_wordcap/nativepubsubio/subscriptiontracker.go	38
sdks/go/examples/native_wordcap/wordcap.go	47
sdks/go/examples/pingpong/pingpong.go	93
sdks/go/examples/readavro/readavro.go	52
sdks/go/examples/slowly_updating_side_input/slowly_updating_side_input.go	92
sdks/go/examples/snippets/01_03intro.go	38
sdks/go/examples/snippets/04transforms.go	704
sdks/go/examples/snippets/04transforms_test.go	177
sdks/go/examples/snippets/06schemas.go	86
sdks/go/examples/snippets/06schemas_test.go	146
sdks/go/examples/snippets/08windowing.go	44
sdks/go/examples/snippets/09triggers.go	47
sdks/go/examples/snippets/10metrics.go	43
sdks/go/examples/snippets/10metrics_test.go	22
sdks/go/examples/snippets/12splittabledofns.go	38
sdks/go/examples/snippets/doc.go	1
sdks/go/examples/streaming_wordcap/wordcap.go	48
sdks/go/examples/stringsplit/stringsplit.go	151
sdks/go/examples/timer_wordcap/wordcap.go	113
sdks/go/examples/wasm/Cargo.toml	36
sdks/go/examples/wasm/README.md	98
sdks/go/examples/wasm/greet.rs	64
sdks/go/examples/wasm/wasm.go	111
sdks/go/examples/windowed_wordcount/windowed_wordcount.go	55
sdks/go/examples/wordcount/wordcount.go	69
sdks/go/examples/xlang/bigquery/wordcount.go	85
sdks/go/examples/xlang/cogroup_by/cogroup_by.go	63
sdks/go/examples/xlang/combine/combine.go	59
sdks/go/examples/xlang/combine_globally/combine_globally.go	40
sdks/go/examples/xlang/flatten/flatten.go	41
sdks/go/examples/xlang/group_by/group_by.go	63
sdks/go/examples/xlang/multi_input_output/multi.go	34
sdks/go/examples/xlang/partition/partition.go	42
sdks/go/examples/xlang/sql/sql.go	76
sdks/go/examples/xlang/transforms.go	73
sdks/go/examples/xlang/wordcount/wordcount.go	66
sdks/go/examples/yatzy/yatzy.go	90
sdks/go/pkg/beam/model/PROTOBUF.md	39
sdks/go/pkg/beam/runners/prism/README.md	146
sdks/go/pkg/beam/runners/prism/internal/README.md	429
sdks/java/build-tools/src/main/resources/beam/checkstyle/checkstyle.xml	244
sdks/java/build-tools/src/main/resources/beam/checkstyle/suppressions.xml	84
sdks/java/container/java11/java11-security.properties	43
sdks/java/container/java11/option-jamm.json	10
sdks/java/container/java11/option-java11-security.json	9
sdks/java/container/java17/java17-security.properties	43
sdks/java/container/java17/option-jamm.json	10
sdks/java/container/java17/option-java17-security.json	9
sdks/java/container/java21/java21-security.properties	44
sdks/java/container/java21/option-jamm.json	12
sdks/java/container/java21/option-java21-security.json	9
sdks/java/container/java8/java8-security.properties	43
sdks/java/container/java8/option-java8-security.json	9
sdks/java/container/license_scripts/requirement.txt	20
sdks/java/container/test/disabled/option-disabled.json	6
sdks/java/container/test/priority/option-high.json	16
sdks/java/container/test/priority/option-low.json	16
sdks/java/core/src/main/resources/org/apache/beam/sdk/sdk.properties	21
sdks/java/core/src/test/resources/json-schema/array_nested_array_json_schema.json	18
sdks/java/core/src/test/resources/json-schema/basic_json_schema.json	16
sdks/java/core/src/test/resources/json-schema/nested_arrays_objects_json_schema.json	32
sdks/java/core/src/test/resources/json-schema/object_nested_object_and_array_json_schema.json	40
sdks/java/core/src/test/resources/json-schema/ref_with_ref_json_schema.json	43
sdks/java/core/src/test/resources/json-schema/unsupported_nested_tuple_array.json	38
sdks/java/core/src/test/resources/json-schema/unsupported_tuple_arrays.json	13
sdks/java/extensions/euphoria/README.md	26
sdks/java/extensions/protobuf/src/test/resources/README.md	35
sdks/java/extensions/protobuf/src/test/resources/org/apache/beam/sdk/extensions/protobuf/test_option_v1.pb	360
sdks/java/extensions/protobuf/src/test/resources/proto_byte/file_descriptor/proto_byte_utils.pb	12
sdks/java/extensions/sorter/src/main/resources/log4j.properties	22
sdks/java/extensions/sql/jdbc/src/main/resources/sqlline/SqlLine.properties	226
sdks/java/extensions/sql/src/main/resources/log4j.properties	22
sdks/java/extensions/sql/src/main/resources/org.apache.beam.vendor.calcite.v1_28_0.org.codehaus.commons.compiler.properties	18
sdks/java/extensions/sql/src/main/resources/saffron.properties	20
sdks/java/io/azure-cosmos/src/test/java/com/azure/cosmos/examples/common/Address.java	25
sdks/java/io/azure-cosmos/src/test/java/com/azure/cosmos/examples/common/Child.java	39
sdks/java/io/azure-cosmos/src/test/java/com/azure/cosmos/examples/common/Families.java	84
sdks/java/io/azure-cosmos/src/test/java/com/azure/cosmos/examples/common/Family.java	54
sdks/java/io/azure-cosmos/src/test/java/com/azure/cosmos/examples/common/Parent.java	22
sdks/java/io/azure-cosmos/src/test/java/com/azure/cosmos/examples/common/Pet.java	11
sdks/java/io/azure/src/test/resources/in.txt	22
sdks/java/io/cdap/README.md	117
sdks/java/io/cdap/src/test/resources/service_now_test_params.json	11
sdks/java/io/debezium/src/README.md	138
sdks/java/io/google-cloud-platform/src/test/resources/BUNDLE_PARSE_TEST/batch-success-failure.json	44
sdks/java/io/google-cloud-platform/src/test/resources/BUNDLE_PARSE_TEST/transaction-failure.json	44
sdks/java/io/google-cloud-platform/src/test/resources/BUNDLE_PARSE_TEST/transaction-success.json	44
sdks/java/io/google-cloud-platform/src/test/resources/DSTU2/Kortney212_Bosco882_8ed31d3e-7352-4055-89c4-f017db3f594e.json	9279
sdks/java/io/google-cloud-platform/src/test/resources/DSTU2/hospitalInformation1586309771387.json	825
sdks/java/io/google-cloud-platform/src/test/resources/DSTU2/practitionerInformation1586309771387.json	617
sdks/java/io/google-cloud-platform/src/test/resources/R4/hospitalInformation1586368892823.json	1182
sdks/java/io/google-cloud-platform/src/test/resources/R4/practitionerInformation1586368892823.json	978
sdks/java/io/google-cloud-platform/src/test/resources/STU3/hospitalInformation1586298239556.json	880
sdks/java/io/google-cloud-platform/src/test/resources/STU3/practitionerInformation1586298239556.json	523
sdks/java/io/hbase/src/test/resources/log4j-test.properties	25
sdks/java/io/kafka/README.md	48
sdks/java/io/kafka/src/test/resources/proto_byte/file_descriptor/proto_byte_utils.pb	12
sdks/java/io/kudu/src/test/resources/log4j-test.properties	25
sdks/java/io/parquet/src/test/resources/log4j-test.properties	28
sdks/java/io/rabbitmq/src/test/resources/org/apache/beam/sdk/io/rabbitmq/rabbitmq-io-test-config.json	30
sdks/java/io/sparkreceiver/3/README.md	54
sdks/java/io/splunk/src/test/resources/SplunkTestCerts/RecognizedCertificate.crt.txt	26
sdks/java/io/splunk/src/test/resources/SplunkTestCerts/RootCA.crt.txt	31
sdks/java/io/splunk/src/test/resources/SplunkTestCerts/RootCA_2.crt.txt	13
sdks/java/io/splunk/src/test/resources/SplunkTestCerts/UnrecognizedCertificate.crt.txt	21
sdks/java/maven-archetypes/examples/build.gradle	55
sdks/java/maven-archetypes/examples/generate-sources.sh	40
sdks/java/maven-archetypes/examples/pom.xml	107
sdks/java/maven-archetypes/examples/sample.txt	87
sdks/java/maven-archetypes/examples/src/main/resources/META-INF/maven/archetype-metadata.xml	26
sdks/java/maven-archetypes/examples/src/main/resources/archetype-resources/pom.xml	407
sdks/java/maven-archetypes/examples/src/test/resources/projects/basic/archetype.properties	21
sdks/java/maven-archetypes/examples/src/test/resources/projects/basic/goal.txt	1
sdks/java/maven-archetypes/starter/src/test/resources/projects/basic/archetype.properties	21
sdks/java/maven-archetypes/starter/src/test/resources/projects/basic/goal.txt	1
sdks/java/testing/kafka-service/src/test/resources/log4j.properties	22
sdks/java/testing/nexmark/src/main/resources/log4j.properties	42
sdks/java/testing/tpcds/README.md	43
sdks/java/testing/tpcds/src/main/resources/schemas/call_center.json	33
sdks/java/testing/tpcds/src/main/resources/schemas/catalog_page.json	11
sdks/java/testing/tpcds/src/main/resources/schemas/catalog_returns.json	29
sdks/java/testing/tpcds/src/main/resources/schemas/catalog_sales.json	36
sdks/java/testing/tpcds/src/main/resources/schemas/customer.json	20
sdks/java/testing/tpcds/src/main/resources/schemas/customer_address.json	15
sdks/java/testing/tpcds/src/main/resources/schemas/customer_demographics.json	11
sdks/java/testing/tpcds/src/main/resources/schemas/date_dim.json	30
sdks/java/testing/tpcds/src/main/resources/schemas/household_demographics.json	7
sdks/java/testing/tpcds/src/main/resources/schemas/income_band.json	5
sdks/java/testing/tpcds/src/main/resources/schemas/inventory.json	6
sdks/java/testing/tpcds/src/main/resources/schemas/item.json	24
sdks/java/testing/tpcds/src/main/resources/schemas/promotion.json	21
sdks/java/testing/tpcds/src/main/resources/schemas/reason.json	5
sdks/java/testing/tpcds/src/main/resources/schemas/ship_mode.json	8
sdks/java/testing/tpcds/src/main/resources/schemas/store.json	31
sdks/java/testing/tpcds/src/main/resources/schemas/store_returns.json	22
sdks/java/testing/tpcds/src/main/resources/schemas/store_sales.json	25
sdks/java/testing/tpcds/src/main/resources/schemas/time_dim.json	12
sdks/java/testing/tpcds/src/main/resources/schemas/warehouse.json	16
sdks/java/testing/tpcds/src/main/resources/schemas/web_page.json	16
sdks/java/testing/tpcds/src/main/resources/schemas/web_returns.json	26
sdks/java/testing/tpcds/src/main/resources/schemas/web_sales.json	36
sdks/java/testing/tpcds/src/main/resources/schemas/web_site.json	28
sdks/java/testing/tpcds/src/main/resources/schemas_avro/call_center.json	260
sdks/java/testing/tpcds/src/main/resources/schemas_avro/catalog_page.json	78
sdks/java/testing/tpcds/src/main/resources/schemas_avro/catalog_returns.json	222
sdks/java/testing/tpcds/src/main/resources/schemas_avro/catalog_sales.json	278
sdks/java/testing/tpcds/src/main/resources/schemas_avro/customer.json	150
sdks/java/testing/tpcds/src/main/resources/schemas_avro/customer_address.json	110
sdks/java/testing/tpcds/src/main/resources/schemas_avro/customer_demographics.json	78
sdks/java/testing/tpcds/src/main/resources/schemas_avro/date_dim.json	233
sdks/java/testing/tpcds/src/main/resources/schemas_avro/household_demographics.json	46
sdks/java/testing/tpcds/src/main/resources/schemas_avro/income_band.json	30
sdks/java/testing/tpcds/src/main/resources/schemas_avro/inventory.json	38
sdks/java/testing/tpcds/src/main/resources/schemas_avro/item.json	188
sdks/java/testing/tpcds/src/main/resources/schemas_avro/promotion.json	158
sdks/java/testing/tpcds/src/main/resources/schemas_avro/reason.json	30
sdks/java/testing/tpcds/src/main/resources/schemas_avro/ship_mode.json	54
sdks/java/testing/tpcds/src/main/resources/schemas_avro/store.json	244
sdks/java/testing/tpcds/src/main/resources/schemas_avro/store_returns.json	166
sdks/java/testing/tpcds/src/main/resources/schemas_avro/store_sales.json	190
sdks/java/testing/tpcds/src/main/resources/schemas_avro/time_dim.json	86
sdks/java/testing/tpcds/src/main/resources/schemas_avro/warehouse.json	118
sdks/java/testing/tpcds/src/main/resources/schemas_avro/web_page.json	124
sdks/java/testing/tpcds/src/main/resources/schemas_avro/web_returns.json	198
sdks/java/testing/tpcds/src/main/resources/schemas_avro/web_sales.json	278
sdks/java/testing/tpcds/src/main/resources/schemas_avro/web_site.json	220
sdks/python/apache_beam/examples/__init__.py	1
sdks/python/apache_beam/examples/avro_nyc_trips.py	189
sdks/python/apache_beam/examples/avro_nyc_trips_it_test.py	172
sdks/python/apache_beam/examples/avro_nyc_trips_test.py	117
sdks/python/apache_beam/examples/california_housing_clustering.py	59
sdks/python/apache_beam/examples/complete/__init__.py	1
sdks/python/apache_beam/examples/complete/autocomplete.py	45
sdks/python/apache_beam/examples/complete/autocomplete_it_test.py	59
sdks/python/apache_beam/examples/complete/autocomplete_test.py	41
sdks/python/apache_beam/examples/complete/distribopt.py	194
sdks/python/apache_beam/examples/complete/distribopt_test.py	50
sdks/python/apache_beam/examples/complete/estimate_pi.py	52
sdks/python/apache_beam/examples/complete/estimate_pi_it_test.py	24
sdks/python/apache_beam/examples/complete/estimate_pi_test.py	21
sdks/python/apache_beam/examples/complete/game/__init__.py	1
sdks/python/apache_beam/examples/complete/game/game_stats.py	197
sdks/python/apache_beam/examples/complete/game/game_stats_it_test.py	84
sdks/python/apache_beam/examples/complete/game/game_stats_test.py	53
sdks/python/apache_beam/examples/complete/game/hourly_team_score.py	154
sdks/python/apache_beam/examples/complete/game/hourly_team_score_it_test.py	60
sdks/python/apache_beam/examples/complete/game/hourly_team_score_test.py	30
sdks/python/apache_beam/examples/complete/game/leader_board.py	175
sdks/python/apache_beam/examples/complete/game/leader_board_it_test.py	94
sdks/python/apache_beam/examples/complete/game/leader_board_test.py	43
sdks/python/apache_beam/examples/complete/game/user_score.py	63
sdks/python/apache_beam/examples/complete/game/user_score_it_test.py	56
sdks/python/apache_beam/examples/complete/game/user_score_test.py	27
sdks/python/apache_beam/examples/complete/juliaset/__init__.py	1
sdks/python/apache_beam/examples/complete/juliaset/juliaset/__init__.py	1
sdks/python/apache_beam/examples/complete/juliaset/juliaset/juliaset.py	68
sdks/python/apache_beam/examples/complete/juliaset/juliaset/juliaset_test.py	50
sdks/python/apache_beam/examples/complete/juliaset/juliaset/juliaset_test_it.py	32
sdks/python/apache_beam/examples/complete/juliaset/juliaset_main.py	5
sdks/python/apache_beam/examples/complete/juliaset/setup.py	39
sdks/python/apache_beam/examples/complete/tfidf.py	97
sdks/python/apache_beam/examples/complete/tfidf_it_test.py	42
sdks/python/apache_beam/examples/complete/tfidf_test.py	25
sdks/python/apache_beam/examples/complete/top_wikipedia_sessions.py	84
sdks/python/apache_beam/examples/complete/top_wikipedia_sessions_it_test.py	65
sdks/python/apache_beam/examples/complete/top_wikipedia_sessions_test.py	50
sdks/python/apache_beam/examples/cookbook/__init__.py	1
sdks/python/apache_beam/examples/cookbook/bigquery_schema.py	81
sdks/python/apache_beam/examples/cookbook/bigquery_side_input.py	66
sdks/python/apache_beam/examples/cookbook/bigquery_side_input_it_test.py	34
sdks/python/apache_beam/examples/cookbook/bigquery_side_input_test.py	36
sdks/python/apache_beam/examples/cookbook/bigquery_tornadoes.py	44
sdks/python/apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py	35
sdks/python/apache_beam/examples/cookbook/bigquery_tornadoes_test.py	31
sdks/python/apache_beam/examples/cookbook/bigtableio_it_test.py	143
sdks/python/apache_beam/examples/cookbook/coders.py	44
sdks/python/apache_beam/examples/cookbook/coders_it_test.py	48
sdks/python/apache_beam/examples/cookbook/coders_test.py	27
sdks/python/apache_beam/examples/cookbook/combiners_test.py	30
sdks/python/apache_beam/examples/cookbook/custom_ptransform.py	59
sdks/python/apache_beam/examples/cookbook/custom_ptransform_it_test.py	36
sdks/python/apache_beam/examples/cookbook/custom_ptransform_test.py	29
sdks/python/apache_beam/examples/cookbook/datastore_wordcount.py	148
sdks/python/apache_beam/examples/cookbook/datastore_wordcount_it_test.py	42
sdks/python/apache_beam/examples/cookbook/filters.py	43
sdks/python/apache_beam/examples/cookbook/filters_test.py	76
sdks/python/apache_beam/examples/cookbook/group_with_coder.py	48
sdks/python/apache_beam/examples/cookbook/group_with_coder_test.py	69
sdks/python/apache_beam/examples/cookbook/mergecontacts.py	83
sdks/python/apache_beam/examples/cookbook/mergecontacts_test.py	135
sdks/python/apache_beam/examples/cookbook/multiple_output_pardo.py	76
sdks/python/apache_beam/examples/cookbook/multiple_output_pardo_test.py	44
sdks/python/apache_beam/examples/dataframe/README.md	154
sdks/python/apache_beam/examples/dataframe/__init__.py	1
sdks/python/apache_beam/examples/dataframe/flight_delays.py	79
sdks/python/apache_beam/examples/dataframe/flight_delays_it_test.py	102
sdks/python/apache_beam/examples/dataframe/taxiride.py	67
sdks/python/apache_beam/examples/dataframe/taxiride_it_test.py	65
sdks/python/apache_beam/examples/dataframe/taxiride_test.py	70
sdks/python/apache_beam/examples/dataframe/wordcount.py	42
sdks/python/apache_beam/examples/dataframe/wordcount_test.py	35
sdks/python/apache_beam/examples/fastavro_it_test.py	99
sdks/python/apache_beam/examples/flink/__init__.py	1
sdks/python/apache_beam/examples/flink/flink_streaming_impulse.py	55
sdks/python/apache_beam/examples/inference/__init__.py	1
sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline/__init__.py	1
sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline/config.py	26
sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline/main.py	84
sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline/pipeline/__init__.py	1
sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline/pipeline/options.py	25
sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline/pipeline/transformations.py	70
sdks/python/apache_beam/examples/inference/anomaly_detection/anomaly_detection_pipeline/setup.py	20
sdks/python/apache_beam/examples/inference/anomaly_detection/write_data_to_pubsub_pipeline/__init__.py	1
sdks/python/apache_beam/examples/inference/anomaly_detection/write_data_to_pubsub_pipeline/config.py	5
sdks/python/apache_beam/examples/inference/anomaly_detection/write_data_to_pubsub_pipeline/main.py	47
sdks/python/apache_beam/examples/inference/anomaly_detection/write_data_to_pubsub_pipeline/pipeline/__init__.py	1
sdks/python/apache_beam/examples/inference/anomaly_detection/write_data_to_pubsub_pipeline/pipeline/options.py	25
sdks/python/apache_beam/examples/inference/anomaly_detection/write_data_to_pubsub_pipeline/pipeline/utils.py	26
sdks/python/apache_beam/examples/inference/anomaly_detection/write_data_to_pubsub_pipeline/setup.py	15
sdks/python/apache_beam/examples/inference/huggingface_language_modeling.py	119
sdks/python/apache_beam/examples/inference/huggingface_question_answering.py	28
sdks/python/apache_beam/examples/inference/large_language_modeling/main.py	18
sdks/python/apache_beam/examples/inference/large_language_modeling/requirements.txt	20
sdks/python/apache_beam/examples/inference/milk_quality_prediction_windowing.py	147
sdks/python/apache_beam/examples/inference/multi_language_inference/README.md	60
sdks/python/apache_beam/examples/inference/multi_language_inference/last_word_prediction/src/main/java/org/apache/beam/examples/MultiLangRunInference.java	55
sdks/python/apache_beam/examples/inference/multi_language_inference/multi_language_custom_transform/multi_language_custom_transform/__init__.py	1
sdks/python/apache_beam/examples/inference/multi_language_inference/multi_language_custom_transform/multi_language_custom_transform/composite_transform.py	77
sdks/python/apache_beam/examples/inference/multi_language_inference/multi_language_custom_transform/setup.py	6
sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline/__init__.py	1
sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline/config.py	8
sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline/main.py	68
sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline/pipeline/__init__.py	1
sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline/pipeline/options.py	25
sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline/pipeline/transformations.py	94
sdks/python/apache_beam/examples/inference/online_clustering/clustering_pipeline/setup.py	17
sdks/python/apache_beam/examples/inference/online_clustering/write_data_to_pubsub_pipeline/__init__.py	1
sdks/python/apache_beam/examples/inference/online_clustering/write_data_to_pubsub_pipeline/config.py	4
sdks/python/apache_beam/examples/inference/online_clustering/write_data_to_pubsub_pipeline/main.py	47
sdks/python/apache_beam/examples/inference/online_clustering/write_data_to_pubsub_pipeline/pipeline/__init__.py	1
sdks/python/apache_beam/examples/inference/online_clustering/write_data_to_pubsub_pipeline/pipeline/options.py	25
sdks/python/apache_beam/examples/inference/online_clustering/write_data_to_pubsub_pipeline/pipeline/utils.py	26
sdks/python/apache_beam/examples/inference/online_clustering/write_data_to_pubsub_pipeline/setup.py	15
sdks/python/apache_beam/examples/inference/onnx_sentiment_classification.py	42
sdks/python/apache_beam/examples/inference/pytorch_image_classification.py	114
sdks/python/apache_beam/examples/inference/pytorch_image_classification_with_side_inputs.py	114
sdks/python/apache_beam/examples/inference/pytorch_image_segmentation.py	201
sdks/python/apache_beam/examples/inference/pytorch_language_modeling.py	74
sdks/python/apache_beam/examples/inference/pytorch_model_per_key_image_segmentation.py	239
sdks/python/apache_beam/examples/inference/run_inference_side_inputs.py	110
sdks/python/apache_beam/examples/inference/runinference_metrics/__init__.py	1
sdks/python/apache_beam/examples/inference/runinference_metrics/config.py	11
sdks/python/apache_beam/examples/inference/runinference_metrics/main.py	82
sdks/python/apache_beam/examples/inference/runinference_metrics/pipeline/__init__.py	1
sdks/python/apache_beam/examples/inference/runinference_metrics/pipeline/options.py	36
sdks/python/apache_beam/examples/inference/runinference_metrics/pipeline/transformations.py	35
sdks/python/apache_beam/examples/inference/runinference_metrics/setup.py	14
sdks/python/apache_beam/examples/inference/sklearn_examples_requirements.txt	22
sdks/python/apache_beam/examples/inference/sklearn_japanese_housing_regression.py	114
sdks/python/apache_beam/examples/inference/sklearn_mnist_classification.py	81
sdks/python/apache_beam/examples/inference/tensorflow_imagenet_segmentation.py	81
sdks/python/apache_beam/examples/inference/tensorflow_mnist_classification.py	78
sdks/python/apache_beam/examples/inference/tensorflow_mnist_with_weights.py	55
sdks/python/apache_beam/examples/inference/tensorrt_object_detection.py	200
sdks/python/apache_beam/examples/inference/tensorrt_text_classification.py	71
sdks/python/apache_beam/examples/inference/tfx_bsl/__init__.py	1
sdks/python/apache_beam/examples/inference/tfx_bsl/build_tensorflow_model.py	52
sdks/python/apache_beam/examples/inference/tfx_bsl/requirements.txt	18
sdks/python/apache_beam/examples/inference/tfx_bsl/tensorflow_image_classification.py	112
sdks/python/apache_beam/examples/inference/tfx_bsl/tfx_bsl_inference_it_test.py	66
sdks/python/apache_beam/examples/inference/vertex_ai_image_classification.py	113
sdks/python/apache_beam/examples/inference/vertex_ai_llm_text_classification.py	89
sdks/python/apache_beam/examples/inference/vllm_text_completion.py	114
sdks/python/apache_beam/examples/inference/xgboost_iris_classification.py	103
sdks/python/apache_beam/examples/kafkataxi/README.md	150
sdks/python/apache_beam/examples/kafkataxi/__init__.py	1
sdks/python/apache_beam/examples/kafkataxi/kafka_taxi.py	123
sdks/python/apache_beam/examples/matrix_power.py	53
sdks/python/apache_beam/examples/matrix_power_test.py	33
sdks/python/apache_beam/examples/ml-orchestration/README.md	18
sdks/python/apache_beam/examples/ml-orchestration/kfp/components/ingestion/component.yaml	21
sdks/python/apache_beam/examples/ml-orchestration/kfp/components/ingestion/requirements.txt	14
sdks/python/apache_beam/examples/ml-orchestration/kfp/components/ingestion/src/ingest.py	32
sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing/component.yaml	46
sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing/requirements.txt	20
sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing/src/preprocess.py	140
sdks/python/apache_beam/examples/ml-orchestration/kfp/components/train/component.yaml	26
sdks/python/apache_beam/examples/ml-orchestration/kfp/components/train/requirements.txt	17
sdks/python/apache_beam/examples/ml-orchestration/kfp/components/train/src/train.py	38
sdks/python/apache_beam/examples/ml-orchestration/kfp/pipeline.json	247
sdks/python/apache_beam/examples/ml-orchestration/kfp/pipeline.py	79
sdks/python/apache_beam/examples/ml-orchestration/kfp/requirements.txt	17
sdks/python/apache_beam/examples/ml-orchestration/tfx/coco_captions_local.py	89
sdks/python/apache_beam/examples/ml-orchestration/tfx/coco_captions_utils.py	33
sdks/python/apache_beam/examples/ml-orchestration/tfx/requirements.txt	16
sdks/python/apache_beam/examples/ml_transform/__init__.py	1
sdks/python/apache_beam/examples/ml_transform/ml_transform_basic.py	56
sdks/python/apache_beam/examples/ml_transform/ml_transform_it_test.py	75
sdks/python/apache_beam/examples/ml_transform/vocab_tfidf_processing.py	120
sdks/python/apache_beam/examples/online_clustering.py	203
sdks/python/apache_beam/examples/per_entity_training.py	84
sdks/python/apache_beam/examples/snippets/__init__.py	1
sdks/python/apache_beam/examples/snippets/snippets.py	988
sdks/python/apache_beam/examples/snippets/snippets_examples_wordcount_debugging.py	47
sdks/python/apache_beam/examples/snippets/snippets_examples_wordcount_minimal.py	33
sdks/python/apache_beam/examples/snippets/snippets_examples_wordcount_wordcount.py	32
sdks/python/apache_beam/examples/snippets/snippets_test.py	1030
sdks/python/apache_beam/examples/snippets/transforms/__init__.py	1
sdks/python/apache_beam/examples/snippets/transforms/aggregation/__init__.py	1
sdks/python/apache_beam/examples/snippets/transforms/aggregation/approximatequantiles.py	12
sdks/python/apache_beam/examples/snippets/transforms/aggregation/approximatequantiles_test.py	18
sdks/python/apache_beam/examples/snippets/transforms/aggregation/approximateunique.py	13
sdks/python/apache_beam/examples/snippets/transforms/aggregation/approximateunique_test.py	27
sdks/python/apache_beam/examples/snippets/transforms/aggregation/batchelements.py	23
sdks/python/apache_beam/examples/snippets/transforms/aggregation/batchelements_test.py	30
sdks/python/apache_beam/examples/snippets/transforms/aggregation/cogroupbykey.py	24
sdks/python/apache_beam/examples/snippets/transforms/aggregation/cogroupbykey_test.py	27
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineglobally_combinefn.py	33
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineglobally_function.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineglobally_lambda.py	18
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineglobally_multiple_arguments.py	21
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineglobally_side_inputs_dict.py	28
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineglobally_side_inputs_iter.py	22
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineglobally_side_inputs_singleton.py	22
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineglobally_test.py	60
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey_combinefn.py	36
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey_function.py	22
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey_lambda.py	20
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey_multiple_arguments.py	20
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey_side_inputs_dict.py	33
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey_side_inputs_iter.py	30
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey_side_inputs_singleton.py	23
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey_simple.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey_test.py	91
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues_combinefn.py	37
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues_function.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues_lambda.py	17
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues_multiple_arguments.py	17
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues_side_inputs_dict.py	30
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues_side_inputs_iter.py	27
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues_side_inputs_singleton.py	20
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues_simple.py	16
sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues_test.py	84
sdks/python/apache_beam/examples/snippets/transforms/aggregation/count_globally.py	13
sdks/python/apache_beam/examples/snippets/transforms/aggregation/count_per_element.py	13
sdks/python/apache_beam/examples/snippets/transforms/aggregation/count_per_key.py	23
sdks/python/apache_beam/examples/snippets/transforms/aggregation/count_test.py	48
sdks/python/apache_beam/examples/snippets/transforms/aggregation/distinct.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/distinct_test.py	20
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_attr.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_attr_expr.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_expr.py	13
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_expr_aggregate.py	21
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_global_aggregate.py	23
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_simple_aggregate.py	20
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_test.py	218
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_two_exprs.py	13
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupbykey.py	24
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupbykey_test.py	23
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupintobatches.py	23
sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupintobatches_test.py	24
sdks/python/apache_beam/examples/snippets/transforms/aggregation/latest_globally.py	34
sdks/python/apache_beam/examples/snippets/transforms/aggregation/latest_per_key.py	52
sdks/python/apache_beam/examples/snippets/transforms/aggregation/latest_test.py	33
sdks/python/apache_beam/examples/snippets/transforms/aggregation/max_globally.py	13
sdks/python/apache_beam/examples/snippets/transforms/aggregation/max_per_key.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/max_test.py	32
sdks/python/apache_beam/examples/snippets/transforms/aggregation/mean_globally.py	12
sdks/python/apache_beam/examples/snippets/transforms/aggregation/mean_per_key.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/mean_test.py	32
sdks/python/apache_beam/examples/snippets/transforms/aggregation/min_globally.py	13
sdks/python/apache_beam/examples/snippets/transforms/aggregation/min_per_key.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/min_test.py	32
sdks/python/apache_beam/examples/snippets/transforms/aggregation/sample_fixed_size_globally.py	18
sdks/python/apache_beam/examples/snippets/transforms/aggregation/sample_fixed_size_per_key.py	23
sdks/python/apache_beam/examples/snippets/transforms/aggregation/sample_test.py	33
sdks/python/apache_beam/examples/snippets/transforms/aggregation/sum_globally.py	12
sdks/python/apache_beam/examples/snippets/transforms/aggregation/sum_per_key.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/sum_test.py	32
sdks/python/apache_beam/examples/snippets/transforms/aggregation/tolist.py	12
sdks/python/apache_beam/examples/snippets/transforms/aggregation/tolist_test.py	30
sdks/python/apache_beam/examples/snippets/transforms/aggregation/top_largest.py	12
sdks/python/apache_beam/examples/snippets/transforms/aggregation/top_largest_per_key.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/top_of.py	23
sdks/python/apache_beam/examples/snippets/transforms/aggregation/top_per_key.py	26
sdks/python/apache_beam/examples/snippets/transforms/aggregation/top_smallest.py	12
sdks/python/apache_beam/examples/snippets/transforms/aggregation/top_smallest_per_key.py	19
sdks/python/apache_beam/examples/snippets/transforms/aggregation/top_test.py	80
sdks/python/apache_beam/examples/snippets/transforms/elementwise/__init__.py	1
sdks/python/apache_beam/examples/snippets/transforms/elementwise/enrichment.py	79
sdks/python/apache_beam/examples/snippets/transforms/elementwise/enrichment_test.py	52
sdks/python/apache_beam/examples/snippets/transforms/elementwise/filter_function.py	30
sdks/python/apache_beam/examples/snippets/transforms/elementwise/filter_lambda.py	29
sdks/python/apache_beam/examples/snippets/transforms/elementwise/filter_multiple_arguments.py	30
sdks/python/apache_beam/examples/snippets/transforms/elementwise/filter_side_inputs_dict.py	37
sdks/python/apache_beam/examples/snippets/transforms/elementwise/filter_side_inputs_iter.py	37
sdks/python/apache_beam/examples/snippets/transforms/elementwise/filter_side_inputs_singleton.py	33
sdks/python/apache_beam/examples/snippets/transforms/elementwise/filter_test.py	59
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_function.py	17
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_generator.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_lambda.py	15
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_multiple_arguments.py	17
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_nofunction.py	13
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_side_inputs_dict.py	40
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_side_inputs_iter.py	40
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_side_inputs_singleton.py	20
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_simple.py	15
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_test.py	85
sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_tuple.py	22
sdks/python/apache_beam/examples/snippets/transforms/elementwise/keys.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/keys_test.py	22
sdks/python/apache_beam/examples/snippets/transforms/elementwise/kvswap.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/kvswap_test.py	22
sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_context.py	28
sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_function.py	20
sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_lambda.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_multiple_arguments.py	20
sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_side_inputs_dict.py	39
sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_side_inputs_iter.py	23
sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_side_inputs_singleton.py	23
sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_simple.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_test.py	86
sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_tuple.py	19
sdks/python/apache_beam/examples/snippets/transforms/elementwise/mltransform.py	84
sdks/python/apache_beam/examples/snippets/transforms/elementwise/mltransform_test.py	54
sdks/python/apache_beam/examples/snippets/transforms/elementwise/pardo_dofn.py	21
sdks/python/apache_beam/examples/snippets/transforms/elementwise/pardo_dofn_methods.py	31
sdks/python/apache_beam/examples/snippets/transforms/elementwise/pardo_dofn_params.py	38
sdks/python/apache_beam/examples/snippets/transforms/elementwise/pardo_test.py	73
sdks/python/apache_beam/examples/snippets/transforms/elementwise/partition_function.py	26
sdks/python/apache_beam/examples/snippets/transforms/elementwise/partition_lambda.py	27
sdks/python/apache_beam/examples/snippets/transforms/elementwise/partition_multiple_arguments.py	30
sdks/python/apache_beam/examples/snippets/transforms/elementwise/partition_test.py	68
sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_all_matches.py	21
sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_find.py	19
sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_find_all.py	19
sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_find_kv.py	19
sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_matches.py	21
sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_matches_kv.py	21
sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_replace_all.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_replace_first.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_split.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_test.py	136
sdks/python/apache_beam/examples/snippets/transforms/elementwise/runinference.py	59
sdks/python/apache_beam/examples/snippets/transforms/elementwise/runinference_sklearn_keyed_model_handler.py	25
sdks/python/apache_beam/examples/snippets/transforms/elementwise/runinference_sklearn_unkeyed_model_handler.py	22
sdks/python/apache_beam/examples/snippets/transforms/elementwise/runinference_test.py	80
sdks/python/apache_beam/examples/snippets/transforms/elementwise/tostring_element.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/tostring_iterables.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/tostring_kvs.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/tostring_test.py	53
sdks/python/apache_beam/examples/snippets/transforms/elementwise/values.py	18
sdks/python/apache_beam/examples/snippets/transforms/elementwise/values_test.py	22
sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps.py	12
sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps_event_time.py	24
sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps_logical_clock.py	25
sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps_processing_time.py	25
sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps_test.py	65
sdks/python/apache_beam/examples/snippets/transforms/other/__init__.py	1
sdks/python/apache_beam/examples/snippets/transforms/other/create.py	11
sdks/python/apache_beam/examples/snippets/transforms/other/create_test.py	21
sdks/python/apache_beam/examples/snippets/transforms/other/flatten.py	11
sdks/python/apache_beam/examples/snippets/transforms/other/flatten_test.py	24
sdks/python/apache_beam/examples/snippets/transforms/other/window.py	23
sdks/python/apache_beam/examples/snippets/transforms/other/window_test.py	22
sdks/python/apache_beam/examples/snippets/util.py	24
sdks/python/apache_beam/examples/snippets/util_test.py	74
sdks/python/apache_beam/examples/sql_taxi.py	48
sdks/python/apache_beam/examples/streaming_wordcount.py	65
sdks/python/apache_beam/examples/streaming_wordcount_debugging.py	123
sdks/python/apache_beam/examples/streaming_wordcount_debugging_it_test.py	84
sdks/python/apache_beam/examples/streaming_wordcount_debugging_test.py	69
sdks/python/apache_beam/examples/streaming_wordcount_it_test.py	67
sdks/python/apache_beam/examples/windowed_wordcount.py	55
sdks/python/apache_beam/examples/wordcount.py	44
sdks/python/apache_beam/examples/wordcount_dataframe.py	5
sdks/python/apache_beam/examples/wordcount_debugging.py	70
sdks/python/apache_beam/examples/wordcount_debugging_test.py	35
sdks/python/apache_beam/examples/wordcount_it_test.py	117
sdks/python/apache_beam/examples/wordcount_minimal.py	40
sdks/python/apache_beam/examples/wordcount_minimal_test.py	35
sdks/python/apache_beam/examples/wordcount_test.py	36
sdks/python/apache_beam/examples/wordcount_with_metrics.py	76
sdks/python/apache_beam/examples/wordcount_xlang.py	65
sdks/python/apache_beam/examples/wordcount_xlang_sql.py	46
sdks/python/apache_beam/ml/inference/huggingface_tests_requirements.txt	19
sdks/python/apache_beam/ml/inference/tensorflow_tests_requirements.txt	22
sdks/python/apache_beam/ml/inference/torch_tests_requirements.txt	21
sdks/python/apache_beam/ml/inference/vertex_ai_tests_requirements.txt	18
sdks/python/apache_beam/ml/inference/xgboost_tests_requirements.txt	18
sdks/python/apache_beam/runners/dataflow/internal/clients/README.txt	9
sdks/python/apache_beam/runners/interactive/README.md	293
sdks/python/apache_beam/runners/interactive/examples/Interactive Beam Example.ipynb	182
sdks/python/apache_beam/runners/interactive/examples/Interactive Beam Running on Flink.ipynb	124
sdks/python/apache_beam/runners/interactive/examples/Run Beam SQL with beam_sql magic.ipynb	549
sdks/python/apache_beam/runners/interactive/examples/UsCovidDataExample.ipynb	513
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/README.md	91
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/package.json	91
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/tsconfig.json	34
sdks/python/apache_beam/testing/analyzers/README.md	87
sdks/python/apache_beam/testing/benchmarks/README.md	97
sdks/python/apache_beam/testing/benchmarks/chicago_taxi/requirements.txt	23
sdks/python/apache_beam/testing/benchmarks/cloudml/requirements.txt	18
sdks/python/apache_beam/testing/benchmarks/inference/README.md	81
sdks/python/apache_beam/testing/benchmarks/nexmark/README.md	51
sdks/python/apache_beam/testing/benchmarks/wordcount/requirements.txt	17
sdks/python/apache_beam/transforms/enrichment_handlers/feast_tests_requirements.txt	17
sdks/python/apache_beam/yaml/README.md	37
sdks/python/apache_beam/yaml/examples/README.md	47
sdks/python/apache_beam/yaml/examples/regex_matches.yaml	30
sdks/python/apache_beam/yaml/examples/simple_filter.yaml	17
sdks/python/apache_beam/yaml/examples/simple_filter_and_combine.yaml	29
sdks/python/apache_beam/yaml/examples/testing/__init__.py	1
sdks/python/apache_beam/yaml/examples/testing/examples_test.py	384
sdks/python/apache_beam/yaml/examples/transforms/aggregation/combine_count_minimal.yaml	35
sdks/python/apache_beam/yaml/examples/transforms/aggregation/combine_max_minimal.yaml	27
sdks/python/apache_beam/yaml/examples/transforms/aggregation/combine_mean_minimal.yaml	27
sdks/python/apache_beam/yaml/examples/transforms/aggregation/combine_min_minimal.yaml	27
sdks/python/apache_beam/yaml/examples/transforms/aggregation/combine_multiple_aggregations.yaml	57
sdks/python/apache_beam/yaml/examples/transforms/aggregation/combine_sum.yaml	40
sdks/python/apache_beam/yaml/examples/transforms/aggregation/combine_sum_minimal.yaml	27
sdks/python/apache_beam/yaml/examples/transforms/aggregation/combine_sum_windowed.yaml	51
sdks/python/apache_beam/yaml/examples/transforms/aggregation/group_into_batches.yaml	40
sdks/python/apache_beam/yaml/examples/transforms/aggregation/top_largest_per_key.yaml	31
sdks/python/apache_beam/yaml/examples/transforms/aggregation/top_smallest_per_key.yaml	33
sdks/python/apache_beam/yaml/examples/transforms/elementwise/explode.yaml	16
sdks/python/apache_beam/yaml/examples/transforms/elementwise/filter_callable.yaml	29
sdks/python/apache_beam/yaml/examples/transforms/elementwise/map_to_fields_callable.yaml	20
sdks/python/apache_beam/yaml/examples/transforms/elementwise/map_to_fields_with_deps.yaml	25
sdks/python/apache_beam/yaml/examples/transforms/elementwise/map_to_fields_with_java_deps.yaml	31
sdks/python/apache_beam/yaml/examples/transforms/elementwise/map_to_fields_with_resource_hints.yaml	23
sdks/python/apache_beam/yaml/examples/transforms/io/spanner_read.yaml	42
sdks/python/apache_beam/yaml/examples/transforms/io/spanner_write.yaml	26
sdks/python/apache_beam/yaml/examples/transforms/ml/bigtable_enrichment.yaml	22
sdks/python/apache_beam/yaml/examples/transforms/ml/enrich_spanner_with_bigquery.yaml	66
sdks/python/apache_beam/yaml/examples/wordcount_minimal.yaml	31
sdks/python/apache_beam/yaml/inline_python.md	19
sdks/python/apache_beam/yaml/yaml_combine.md	18
sdks/python/apache_beam/yaml/yaml_errors.md	19
sdks/python/apache_beam/yaml/yaml_mapping.md	19
sdks/python/container/base_image_requirements_manual.txt	37
sdks/python/container/py310/base_image_requirements.txt	166
sdks/python/container/py311/base_image_requirements.txt	163
sdks/python/container/py312/base_image_requirements.txt	164
sdks/python/container/py39/base_image_requirements.txt	166
sdks/python/mypy.ini	82
sdks/python/pytest.ini	72
sdks/python/test-suites/containers/tensorrt_runinference/README.md	19
sdks/python/test-suites/gradle.properties	48
sdks/python/tox.ini	483
sdks/typescript/README-dev.md	116
sdks/typescript/README.md	114
sdks/typescript/package-lock.json	7383
sdks/typescript/package.json	64
sdks/typescript/src/apache_beam/examples/wordcount.ts	28
sdks/typescript/src/apache_beam/examples/wordcount_sql.ts	25
sdks/typescript/src/apache_beam/examples/wordcount_textio.ts	24
sdks/typescript/src/apache_beam/proto/README.md	19
sdks/typescript/tsconfig.json	29
sdks/typescript/typedoc.json	24
website/ADD_CASE_STUDY.md	60
website/ADD_LOGO.md	54
website/CASE_STUDY_TEMPLATE.md	83
website/CONTRIBUTE.md	315
website/README.md	64
website/notebooks/imports/license.md	19
website/notebooks/imports/setup.md	23
website/www/package.json	19
website/www/site/archetypes/blog.md	19
website/www/site/archetypes/default.md	14
website/www/site/assets/icons/about/abstration_icon.svg	37
website/www/site/assets/icons/about/capabilities_icon.svg	28
website/www/site/assets/icons/about/flexibility_icon.svg	22
website/www/site/assets/icons/about/model_icon.svg	24
website/www/site/assets/icons/about/portability_icon.svg	25
website/www/site/assets/icons/calendar-icon.svg	21
website/www/site/assets/icons/close-icon.svg	20
website/www/site/assets/icons/commercial-icon.svg	27
website/www/site/assets/icons/community/bee-icon.svg	36
website/www/site/assets/icons/community/box-icon.svg	20
website/www/site/assets/icons/community/calendar-icon.svg	21
website/www/site/assets/icons/community/contact-us/bug.svg	20
website/www/site/assets/icons/community/contact-us/discussion.svg	21
website/www/site/assets/icons/community/contact-us/gitArrows.svg	21
website/www/site/assets/icons/community/contact-us/messages.svg	20
website/www/site/assets/icons/community/contact-us/notification.svg	20
website/www/site/assets/icons/community/contact-us/question-mark.svg	21
website/www/site/assets/icons/community/envelope-icon.svg	21
website/www/site/assets/icons/community/message-icon.svg	21
website/www/site/assets/icons/contributor/become a commiter/beam-logo-icon.svg	44
website/www/site/assets/icons/contributor/become a commiter/code-icon.svg	20
website/www/site/assets/icons/contributor/become a commiter/diamond-icon.svg	37
website/www/site/assets/icons/contributor/become a commiter/file-icon.svg	21
website/www/site/assets/icons/contributor/become a commiter/messages-icon.svg	26
website/www/site/assets/icons/contributor/become a commiter/tool-icon.svg	20
website/www/site/assets/icons/contributor/become a committer/beam-logo-icon.svg	44
website/www/site/assets/icons/contributor/become a committer/code-icon.svg	20
website/www/site/assets/icons/contributor/become a committer/diamond-icon.svg	37
website/www/site/assets/icons/contributor/become a committer/file-icon.svg	21
website/www/site/assets/icons/contributor/become a committer/messages-icon.svg	26
website/www/site/assets/icons/contributor/become a committer/tool-icon.svg	20
website/www/site/assets/icons/edit-icon.svg	20
website/www/site/assets/icons/extensible-icon.svg	24
website/www/site/assets/icons/github-icon.svg	27
website/www/site/assets/icons/install-button-icon.svg	20
website/www/site/assets/icons/navbar-arrow-icon.svg	21
website/www/site/assets/icons/navbar-documentation-icon.svg	20
website/www/site/assets/icons/open-source-icon.svg	29
website/www/site/assets/icons/portable-icon.svg	25
website/www/site/assets/icons/quote-icon.svg	20
website/www/site/assets/icons/search-icon.svg	20
website/www/site/assets/icons/twitter-icon.svg	28
website/www/site/assets/icons/unified-icon.svg	24
website/www/site/assets/icons/youtube-icon.svg	21
website/www/site/content/en/_index.md	14
website/www/site/content/en/about/_index.md	67
website/www/site/content/en/blog/ApachePlayground.md	39
website/www/site/content/en/blog/added-apex-runner.md	36
website/www/site/content/en/blog/adding-data-sources-to-sql.md	164
website/www/site/content/en/blog/apache-beam-flink-and-kubernetes-part2.md	98
website/www/site/content/en/blog/apache-beam-flink-and-kubernetes-part3.md	129
website/www/site/content/en/blog/apache-beam-flink-and-kubernetes.md	222
website/www/site/content/en/blog/apache-hop-with-dataflow.md	261
website/www/site/content/en/blog/beam-2.10.0.md	101
website/www/site/content/en/blog/beam-2.11.0.md	95
website/www/site/content/en/blog/beam-2.12.0.md	60
website/www/site/content/en/blog/beam-2.13.0.md	60
website/www/site/content/en/blog/beam-2.14.0.md	84
website/www/site/content/en/blog/beam-2.15.0.md	65
website/www/site/content/en/blog/beam-2.16.0.md	81
website/www/site/content/en/blog/beam-2.17.0.md	83
website/www/site/content/en/blog/beam-2.19.0.md	83
website/www/site/content/en/blog/beam-2.20.0.md	69
website/www/site/content/en/blog/beam-2.24.0.md	69
website/www/site/content/en/blog/beam-2.25.0.md	71
website/www/site/content/en/blog/beam-2.26.0.md	56
website/www/site/content/en/blog/beam-2.27.0.md	59
website/www/site/content/en/blog/beam-2.28.0.md	78
website/www/site/content/en/blog/beam-2.29.0.md	67
website/www/site/content/en/blog/beam-2.30.0.md	62
website/www/site/content/en/blog/beam-2.31.0.md	59
website/www/site/content/en/blog/beam-2.33.0.md	133
website/www/site/content/en/blog/beam-2.34.0.md	140
website/www/site/content/en/blog/beam-2.35.0.md	142
website/www/site/content/en/blog/beam-2.36.0.md	141
website/www/site/content/en/blog/beam-2.37.0.md	110
website/www/site/content/en/blog/beam-2.38.0.md	147
website/www/site/content/en/blog/beam-2.39.0.md	165
website/www/site/content/en/blog/beam-2.40.0.md	138
website/www/site/content/en/blog/beam-2.41.0.md	109
website/www/site/content/en/blog/beam-2.42.0.md	113
website/www/site/content/en/blog/beam-2.43.0.md	134
website/www/site/content/en/blog/beam-2.44.0.md	148
website/www/site/content/en/blog/beam-2.45.0.md	126
website/www/site/content/en/blog/beam-2.46.0.md	137
website/www/site/content/en/blog/beam-2.47.0.md	117
website/www/site/content/en/blog/beam-2.48.0.md	121
website/www/site/content/en/blog/beam-2.49.0.md	125
website/www/site/content/en/blog/beam-2.50.0.md	148
website/www/site/content/en/blog/beam-2.51.0.md	119
website/www/site/content/en/blog/beam-2.52.0.md	128
website/www/site/content/en/blog/beam-2.53.0.md	116
website/www/site/content/en/blog/beam-2.54.0.md	104
website/www/site/content/en/blog/beam-2.55.0.md	111
website/www/site/content/en/blog/beam-2.56.0.md	100
website/www/site/content/en/blog/beam-2.57.0.md	140
website/www/site/content/en/blog/beam-2.58.0.md	87
website/www/site/content/en/blog/beam-2.58.1.md	34
website/www/site/content/en/blog/beam-2.59.0.md	68
website/www/site/content/en/blog/beam-2.6.0.md	70
website/www/site/content/en/blog/beam-2.60.0.md	71
website/www/site/content/en/blog/beam-2.61.0.md	60
website/www/site/content/en/blog/beam-2.62.0.md	95
website/www/site/content/en/blog/beam-2.63.0.md	125
website/www/site/content/en/blog/beam-2.64.0.md	106
website/www/site/content/en/blog/beam-2.7.0.md	60
website/www/site/content/en/blog/beam-2.8.0.md	71
website/www/site/content/en/blog/beam-a-look-back.md	118
website/www/site/content/en/blog/beam-first-stable-release.md	110
website/www/site/content/en/blog/beam-graduates.md	69
website/www/site/content/en/blog/beam-has-a-logo.md	37
website/www/site/content/en/blog/beam-kata-release.md	47
website/www/site/content/en/blog/beam-katas-kotlin-release.md	47
website/www/site/content/en/blog/beam-kotlin.md	83
website/www/site/content/en/blog/beam-sql-with-notebooks.md	607
website/www/site/content/en/blog/beam-starter-projects.md	57
website/www/site/content/en/blog/beam-summit-2024-overview.md	43
website/www/site/content/en/blog/beam-summit-digital-2020.md	42
website/www/site/content/en/blog/beam-summit-europe.md	40
website/www/site/content/en/blog/beam-summit-site.md	29
website/www/site/content/en/blog/beam-yaml-proto.md	221
website/www/site/content/en/blog/beam-yaml-release.md	165
website/www/site/content/en/blog/beamquest.md	31
website/www/site/content/en/blog/capability-matrix.md	31
website/www/site/content/en/blog/contributor-spotlight-johanna-ojeling.md	41
website/www/site/content/en/blog/dataframe-api-preview-available.md	153
website/www/site/content/en/blog/first-release.md	46
website/www/site/content/en/blog/flink-batch-runner-milestone.md	34
website/www/site/content/en/blog/go-2.40.md	56
website/www/site/content/en/blog/go-sdk-release.md	125
website/www/site/content/en/blog/graduation-media-recap.md	58
website/www/site/content/en/blog/gsoc-19.md	71
website/www/site/content/en/blog/hop-web-cloud.md	238
website/www/site/content/en/blog/kafka-to-pubsub-example.md	69
website/www/site/content/en/blog/looping-timers.md	268
website/www/site/content/en/blog/managing-beam-dependencies-in-java.md	96
website/www/site/content/en/blog/ml-resources.md	51
website/www/site/content/en/blog/pattern-match-beam-sql.md	141
website/www/site/content/en/blog/presentation-materials.md	32
website/www/site/content/en/blog/python-improved-annotations.md	88
website/www/site/content/en/blog/python-performance-runtime-type-checking.md	121
website/www/site/content/en/blog/python-sdk-now-public.md	30
website/www/site/content/en/blog/python-sdk-release.md	63
website/www/site/content/en/blog/python-typing.md	113
website/www/site/content/en/blog/review-input-streaming-connectors.md	212
website/www/site/content/en/blog/scaling-streaming-workload.md	186
website/www/site/content/en/blog/season-of-docs.md	42
website/www/site/content/en/blog/six-months.md	45
website/www/site/content/en/blog/splittable-do-fn-is-available.md	78
website/www/site/content/en/blog/splittable-do-fn.md	439
website/www/site/content/en/blog/stateful-processing.md	523
website/www/site/content/en/blog/strata-hadoop-world-and-beam.md	33
website/www/site/content/en/blog/test-stream.md	266
website/www/site/content/en/blog/timely-processing.md	476
website/www/site/content/en/blog/unit-testing-in-beam.md	154
website/www/site/content/en/blog/upcoming-events-for-beam-in-2022.md	55
website/www/site/content/en/blog/validate-beam-release.md	118
website/www/site/content/en/case-studies/163netease.md	16
website/www/site/content/en/case-studies/Amazon.md	16
website/www/site/content/en/case-studies/ML6.md	16
website/www/site/content/en/case-studies/Strivr.md	16
website/www/site/content/en/case-studies/TrustPilot.md	16
website/www/site/content/en/case-studies/Twitter.md	16
website/www/site/content/en/case-studies/Wayfair.md	16
website/www/site/content/en/case-studies/Wizeline.md	16
website/www/site/content/en/case-studies/_index.md	16
website/www/site/content/en/case-studies/accenture.md	16
website/www/site/content/en/case-studies/accenture_baltics.md	84
website/www/site/content/en/case-studies/akvelon.md	17
website/www/site/content/en/case-studies/align.md	16
website/www/site/content/en/case-studies/aliz.md	16
website/www/site/content/en/case-studies/android.md	16
website/www/site/content/en/case-studies/arquivei.md	16
website/www/site/content/en/case-studies/bahwancybertek.md	16
website/www/site/content/en/case-studies/bbc.md	16
website/www/site/content/en/case-studies/belllabs.md	16
website/www/site/content/en/case-studies/benchsci.md	16
website/www/site/content/en/case-studies/betterup.md	16
website/www/site/content/en/case-studies/bigdatainstitute.md	16
website/www/site/content/en/case-studies/booking.md	213
website/www/site/content/en/case-studies/calico.md	16
website/www/site/content/en/case-studies/carfinance247.md	16
website/www/site/content/en/case-studies/chrome.md	16
website/www/site/content/en/case-studies/citibank.md	16
website/www/site/content/en/case-studies/cognite.md	16
website/www/site/content/en/case-studies/cruise.md	16
website/www/site/content/en/case-studies/dataflow.md	24
website/www/site/content/en/case-studies/datatonic.md	16
website/www/site/content/en/case-studies/deepmind.md	16
website/www/site/content/en/case-studies/dunbradstreet.md	16
website/www/site/content/en/case-studies/eBay.md	23
website/www/site/content/en/case-studies/ericsson.md	16
website/www/site/content/en/case-studies/evolve24.md	16
website/www/site/content/en/case-studies/fitbit.md	16
website/www/site/content/en/case-studies/goga.md	23
website/www/site/content/en/case-studies/googleplay.md	16
website/www/site/content/en/case-studies/graalsystems.md	18
website/www/site/content/en/case-studies/hazelcast.md	16
website/www/site/content/en/case-studies/hop.md	184
website/www/site/content/en/case-studies/hoxtonai.md	16
website/www/site/content/en/case-studies/ibiblio.md	16
website/www/site/content/en/case-studies/industrialtechnologyresearchinstitute.md	16
website/www/site/content/en/case-studies/ineat.md	16
website/www/site/content/en/case-studies/kio.md	37
website/www/site/content/en/case-studies/klio.md	18
website/www/site/content/en/case-studies/liveramp.md	17
website/www/site/content/en/case-studies/lumaapps.md	16
website/www/site/content/en/case-studies/mindvalley.md	16
website/www/site/content/en/case-studies/mozilla.md	23
website/www/site/content/en/case-studies/natwest.md	16
website/www/site/content/en/case-studies/neo4j.md	17
website/www/site/content/en/case-studies/nest.md	16
website/www/site/content/en/case-studies/nokia.md	16
website/www/site/content/en/case-studies/oracle.md	16
website/www/site/content/en/case-studies/orange.md	17
website/www/site/content/en/case-studies/oriel.md	24
website/www/site/content/en/case-studies/orielresearch.md	16
website/www/site/content/en/case-studies/oxfordbigdatainstitute.md	16
website/www/site/content/en/case-studies/paloalto.md	263
website/www/site/content/en/case-studies/plantix.md	16
website/www/site/content/en/case-studies/portaltelemedicina.md	16
website/www/site/content/en/case-studies/primerai.md	16
website/www/site/content/en/case-studies/prosimo.md	16
website/www/site/content/en/case-studies/ricardo.md	219
website/www/site/content/en/case-studies/schrodinger.md	17
website/www/site/content/en/case-studies/scio.md	19
website/www/site/content/en/case-studies/seznam.md	182
website/www/site/content/en/case-studies/snowflake.md	17
website/www/site/content/en/case-studies/spicule.md	16
website/www/site/content/en/case-studies/spotify.md	16
website/www/site/content/en/case-studies/talend.md	16
website/www/site/content/en/case-studies/tencent.md	16
website/www/site/content/en/case-studies/tfx.md	21
website/www/site/content/en/case-studies/theworkshop.md	16
website/www/site/content/en/case-studies/tutanota.md	16
website/www/site/content/en/case-studies/unity.md	16
website/www/site/content/en/case-studies/universityofweimar.md	16
website/www/site/content/en/case-studies/veepee.md	16
website/www/site/content/en/case-studies/venturedive.md	16
website/www/site/content/en/case-studies/veolia.md	16
website/www/site/content/en/case-studies/verily.md	16
website/www/site/content/en/case-studies/waymo.md	16
website/www/site/content/en/case-studies/xiaohongshu.md	16
website/www/site/content/en/case-studies/yahoo.md	17
website/www/site/content/en/case-studies/yelp.md	16
website/www/site/content/en/case-studies/yelp_streaming.md	102
website/www/site/content/en/case-studies/youtube.md	16
website/www/site/content/en/case-studies/zillow.md	17
website/www/site/content/en/community/_index.md	22
website/www/site/content/en/community/case-study.md	25
website/www/site/content/en/community/contact-us.md	33
website/www/site/content/en/community/in-person.md	39
website/www/site/content/en/community/integrations.md	23
website/www/site/content/en/community/join-beam.md	33
website/www/site/content/en/community/logos.md	34
website/www/site/content/en/community/mascot.md	33
website/www/site/content/en/community/policies.md	20
website/www/site/content/en/community/presentation-materials.md	33
website/www/site/content/en/community/twitter-handle.md	32
website/www/site/content/en/community/youtube-channel.md	34
website/www/site/content/en/contribute/_index.md	224
website/www/site/content/en/contribute/attributes.md	50
website/www/site/content/en/contribute/become-a-committer.md	39
website/www/site/content/en/contribute/design-documents.md	17
website/www/site/content/en/contribute/get-help.md	19
website/www/site/content/en/contribute/get-started-contributing.md	19
website/www/site/content/en/contribute/issue-priorities.md	53
website/www/site/content/en/contribute/postcommits-guides.md	54
website/www/site/content/en/contribute/postcommits-policies-details.md	76
website/www/site/content/en/contribute/postcommits-policies.md	73
website/www/site/content/en/contribute/precommit-policies.md	43
website/www/site/content/en/contribute/precommit-triage-guide.md	84
website/www/site/content/en/contribute/ptransform-style-guide.md	398
website/www/site/content/en/contribute/release-blocking.md	29
website/www/site/content/en/contribute/runner-guide.md	599
website/www/site/content/en/contribute/team.md	17
website/www/site/content/en/contribute/testing.md	21
website/www/site/content/en/documentation/_index.md	67
website/www/site/content/en/documentation/basics.md	487
website/www/site/content/en/documentation/dsls/dataframes/differences-from-pandas.md	74
website/www/site/content/en/documentation/dsls/dataframes/overview.md	75
website/www/site/content/en/documentation/dsls/sql/calcite/aggregate-functions.md	27
website/www/site/content/en/documentation/dsls/sql/calcite/data-types.md	38
website/www/site/content/en/documentation/dsls/sql/calcite/lexical-structure.md	958
website/www/site/content/en/documentation/dsls/sql/calcite/overview.md	58
website/www/site/content/en/documentation/dsls/sql/calcite/query-syntax.md	510
website/www/site/content/en/documentation/dsls/sql/calcite/scalar-functions.md	120
website/www/site/content/en/documentation/dsls/sql/extensions/create-external-table.md	567
website/www/site/content/en/documentation/dsls/sql/extensions/joins.md	52
website/www/site/content/en/documentation/dsls/sql/extensions/set.md	41
website/www/site/content/en/documentation/dsls/sql/extensions/user-defined-functions.md	106
website/www/site/content/en/documentation/dsls/sql/extensions/windowing-and-triggering.md	54
website/www/site/content/en/documentation/dsls/sql/overview.md	39
website/www/site/content/en/documentation/dsls/sql/shell.md	103
website/www/site/content/en/documentation/dsls/sql/walkthrough.md	127
website/www/site/content/en/documentation/dsls/sql/zetasql/aggregate-functions.md	139
website/www/site/content/en/documentation/dsls/sql/zetasql/conditional-expressions.md	106
website/www/site/content/en/documentation/dsls/sql/zetasql/conversion-rules.md	149
website/www/site/content/en/documentation/dsls/sql/zetasql/data-types.md	460
website/www/site/content/en/documentation/dsls/sql/zetasql/lexical.md	479
website/www/site/content/en/documentation/dsls/sql/zetasql/math-functions.md	108
website/www/site/content/en/documentation/dsls/sql/zetasql/operators.md	552
website/www/site/content/en/documentation/dsls/sql/zetasql/overview.md	27
website/www/site/content/en/documentation/dsls/sql/zetasql/query-syntax.md	999
website/www/site/content/en/documentation/dsls/sql/zetasql/string-functions.md	489
website/www/site/content/en/documentation/dsls/sql/zetasql/syntax.md	26
website/www/site/content/en/documentation/glossary.md	281
website/www/site/content/en/documentation/io/built-in/cdap.md	311
website/www/site/content/en/documentation/io/built-in/google-bigquery.md	835
website/www/site/content/en/documentation/io/built-in/hadoop.md	335
website/www/site/content/en/documentation/io/built-in/hcatalog.md	137
website/www/site/content/en/documentation/io/built-in/parquet.md	125
website/www/site/content/en/documentation/io/built-in/singlestore.md	191
website/www/site/content/en/documentation/io/built-in/snowflake.md	761
website/www/site/content/en/documentation/io/built-in/sparkreceiver.md	77
website/www/site/content/en/documentation/io/built-in/webapis.md	407
website/www/site/content/en/documentation/io/connectors.md	1270
website/www/site/content/en/documentation/io/developing-io-java.md	284
website/www/site/content/en/documentation/io/developing-io-overview.md	149
website/www/site/content/en/documentation/io/developing-io-python.md	194
website/www/site/content/en/documentation/io/io-standards.md	1397
website/www/site/content/en/documentation/io/managed-io.md	738
website/www/site/content/en/documentation/io/testing.md	318
website/www/site/content/en/documentation/ml/about-ml.md	348
website/www/site/content/en/documentation/ml/anomaly-detection.md	171
website/www/site/content/en/documentation/ml/data-processing.md	88
website/www/site/content/en/documentation/ml/inference-overview.md	53
website/www/site/content/en/documentation/ml/large-language-modeling.md	152
website/www/site/content/en/documentation/ml/ml-dependency-extras.md	32
website/www/site/content/en/documentation/ml/model-evaluation.md	62
website/www/site/content/en/documentation/ml/multi-language-inference.md	101
website/www/site/content/en/documentation/ml/multi-model-pipelines.md	122
website/www/site/content/en/documentation/ml/online-clustering.md	148
website/www/site/content/en/documentation/ml/orchestration.md	153
website/www/site/content/en/documentation/ml/overview.md	103
website/www/site/content/en/documentation/ml/per-entity-training.md	50
website/www/site/content/en/documentation/ml/preprocess-data.md	163
website/www/site/content/en/documentation/ml/runinference-metrics.md	69
website/www/site/content/en/documentation/ml/side-input-updates.md	106
website/www/site/content/en/documentation/ml/tensorrt-runinference.md	110
website/www/site/content/en/documentation/patterns/ai-platform.md	164
website/www/site/content/en/documentation/patterns/bigqueryio.md	36
website/www/site/content/en/documentation/patterns/bqml.md	79
website/www/site/content/en/documentation/patterns/custom-io.md	23
website/www/site/content/en/documentation/patterns/custom-windows.md	77
website/www/site/content/en/documentation/patterns/file-processing.md	77
website/www/site/content/en/documentation/patterns/grouping-elements-for-efficient-external-service-calls.md	39
website/www/site/content/en/documentation/patterns/overview.md	49
website/www/site/content/en/documentation/patterns/pipeline-options.md	26
website/www/site/content/en/documentation/patterns/schema.md	39
website/www/site/content/en/documentation/patterns/shared-class.md	71
website/www/site/content/en/documentation/patterns/side-inputs.md	55
website/www/site/content/en/documentation/pipelines/create-your-pipeline.md	67
website/www/site/content/en/documentation/pipelines/design-your-pipeline.md	148
website/www/site/content/en/documentation/pipelines/test-your-pipeline.md	298
website/www/site/content/en/documentation/runners/capability-matrix/_index.md	30
website/www/site/content/en/documentation/runners/capability-matrix/additional-common-features-not-yet-part-of-the-beam-model.md	18
website/www/site/content/en/documentation/runners/capability-matrix/bounded-splittable-dofn-support-status.md	18
website/www/site/content/en/documentation/runners/capability-matrix/how-do-refinements-relate.md	18
website/www/site/content/en/documentation/runners/capability-matrix/unbounded-splittable-dofn-support-status.md	18
website/www/site/content/en/documentation/runners/capability-matrix/what-is-being-computed.md	18
website/www/site/content/en/documentation/runners/capability-matrix/when-in-processing-time.md	18
website/www/site/content/en/documentation/runners/capability-matrix/where-in-event-time.md	18
website/www/site/content/en/documentation/runners/dataflow.md	196
website/www/site/content/en/documentation/runners/direct.md	93
website/www/site/content/en/documentation/runners/flink.md	356
website/www/site/content/en/documentation/runners/jet.md	197
website/www/site/content/en/documentation/runners/nemo.md	136
website/www/site/content/en/documentation/runners/prism.md	100
website/www/site/content/en/documentation/runners/samza.md	175
website/www/site/content/en/documentation/runners/spark.md	446
website/www/site/content/en/documentation/runners/twister2.md	131
website/www/site/content/en/documentation/runtime/environments.md	271
website/www/site/content/en/documentation/runtime/model.md	177
website/www/site/content/en/documentation/runtime/resource-hints.md	88
website/www/site/content/en/documentation/runtime/sdk-harness-config.md	49
website/www/site/content/en/documentation/sdks/feature-comparison.md	16
website/www/site/content/en/documentation/sdks/go-cross-compilation.md	63
website/www/site/content/en/documentation/sdks/go-dependencies.md	25
website/www/site/content/en/documentation/sdks/go.md	29
website/www/site/content/en/documentation/sdks/java-dependencies.md	138
website/www/site/content/en/documentation/sdks/java-extensions.md	51
website/www/site/content/en/documentation/sdks/java-multi-language-pipelines.md	225
website/www/site/content/en/documentation/sdks/java-thirdparty.md	86
website/www/site/content/en/documentation/sdks/java.md	35
website/www/site/content/en/documentation/sdks/java/euphoria.md	521
website/www/site/content/en/documentation/sdks/java/testing/nexmark.md	528
website/www/site/content/en/documentation/sdks/java/testing/tpcds.md	169
website/www/site/content/en/documentation/sdks/python-custom-multi-language-pipelines-guide.md	235
website/www/site/content/en/documentation/sdks/python-dependencies.md	42
website/www/site/content/en/documentation/sdks/python-multi-language-pipelines.md	153
website/www/site/content/en/documentation/sdks/python-pipeline-dependencies.md	158
website/www/site/content/en/documentation/sdks/python-sdk-image-build.md	223
website/www/site/content/en/documentation/sdks/python-streaming.md	120
website/www/site/content/en/documentation/sdks/python-type-safety.md	175
website/www/site/content/en/documentation/sdks/python-unrecoverable-errors.md	55
website/www/site/content/en/documentation/sdks/python.md	43
website/www/site/content/en/documentation/sdks/scala.md	21
website/www/site/content/en/documentation/sdks/typescript.md	114
website/www/site/content/en/documentation/sdks/yaml-combine.md	138
website/www/site/content/en/documentation/sdks/yaml-errors.md	190
website/www/site/content/en/documentation/sdks/yaml-inline-python.md	170
website/www/site/content/en/documentation/sdks/yaml-join.md	157
website/www/site/content/en/documentation/sdks/yaml-providers.md	205
website/www/site/content/en/documentation/sdks/yaml-testing.md	262
website/www/site/content/en/documentation/sdks/yaml-udf.md	442
website/www/site/content/en/documentation/sdks/yaml.md	593
website/www/site/content/en/documentation/transforms/java/aggregation/approximatequantiles.md	39
website/www/site/content/en/documentation/transforms/java/aggregation/approximateunique.md	35
website/www/site/content/en/documentation/transforms/java/aggregation/cogroupbykey.md	66
website/www/site/content/en/documentation/transforms/java/aggregation/combine.md	74
website/www/site/content/en/documentation/transforms/java/aggregation/combinewithcontext.md	30
website/www/site/content/en/documentation/transforms/java/aggregation/count.md	49
website/www/site/content/en/documentation/transforms/java/aggregation/distinct.md	49
website/www/site/content/en/documentation/transforms/java/aggregation/groupbykey.md	40
website/www/site/content/en/documentation/transforms/java/aggregation/groupintobatches.md	35
website/www/site/content/en/documentation/transforms/java/aggregation/hllcount.md	63
website/www/site/content/en/documentation/transforms/java/aggregation/latest.md	47
website/www/site/content/en/documentation/transforms/java/aggregation/max.md	54
website/www/site/content/en/documentation/transforms/java/aggregation/mean.md	44
website/www/site/content/en/documentation/transforms/java/aggregation/min.md	43
website/www/site/content/en/documentation/transforms/java/aggregation/sample.md	35
website/www/site/content/en/documentation/transforms/java/aggregation/sum.md	38
website/www/site/content/en/documentation/transforms/java/aggregation/top.md	34
website/www/site/content/en/documentation/transforms/java/elementwise/filter.md	56
website/www/site/content/en/documentation/transforms/java/elementwise/flatmapelements.md	35
website/www/site/content/en/documentation/transforms/java/elementwise/keys.md	33
website/www/site/content/en/documentation/transforms/java/elementwise/kvswap.md	33
website/www/site/content/en/documentation/transforms/java/elementwise/mapelements.md	46
website/www/site/content/en/documentation/transforms/java/elementwise/pardo.md	131
website/www/site/content/en/documentation/transforms/java/elementwise/partition.md	39
website/www/site/content/en/documentation/transforms/java/elementwise/regex.md	31
website/www/site/content/en/documentation/transforms/java/elementwise/reify.md	32
website/www/site/content/en/documentation/transforms/java/elementwise/tostring.md	32
website/www/site/content/en/documentation/transforms/java/elementwise/values.md	34
website/www/site/content/en/documentation/transforms/java/elementwise/withkeys.md	38
website/www/site/content/en/documentation/transforms/java/elementwise/withtimestamps.md	31
website/www/site/content/en/documentation/transforms/java/other/create.md	33
website/www/site/content/en/documentation/transforms/java/other/flatten.md	48
website/www/site/content/en/documentation/transforms/java/other/flattenWith.md	40
website/www/site/content/en/documentation/transforms/java/other/passert.md	51
website/www/site/content/en/documentation/transforms/java/other/tee.md	33
website/www/site/content/en/documentation/transforms/java/other/view.md	32
website/www/site/content/en/documentation/transforms/java/other/window.md	35
website/www/site/content/en/documentation/transforms/java/overview.md	69
website/www/site/content/en/documentation/transforms/python/aggregation/approximatequantiles.md	24
website/www/site/content/en/documentation/transforms/python/aggregation/approximateunique.md	24
website/www/site/content/en/documentation/transforms/python/aggregation/batchelements.md	24
website/www/site/content/en/documentation/transforms/python/aggregation/cogroupbykey.md	42
website/www/site/content/en/documentation/transforms/python/aggregation/combineglobally.md	64
website/www/site/content/en/documentation/transforms/python/aggregation/combineperkey.md	72
website/www/site/content/en/documentation/transforms/python/aggregation/combinevalues.md	74
website/www/site/content/en/documentation/transforms/python/aggregation/combinewithcontext.md	18
website/www/site/content/en/documentation/transforms/python/aggregation/count.md	39
website/www/site/content/en/documentation/transforms/python/aggregation/distinct.md	27
website/www/site/content/en/documentation/transforms/python/aggregation/groupby.md	68
website/www/site/content/en/documentation/transforms/python/aggregation/groupbykey.md	35
website/www/site/content/en/documentation/transforms/python/aggregation/groupintobatches.md	29
website/www/site/content/en/documentation/transforms/python/aggregation/latest.md	34
website/www/site/content/en/documentation/transforms/python/aggregation/max.md	38
website/www/site/content/en/documentation/transforms/python/aggregation/mean.md	40
website/www/site/content/en/documentation/transforms/python/aggregation/min.md	38
website/www/site/content/en/documentation/transforms/python/aggregation/sample.md	36
website/www/site/content/en/documentation/transforms/python/aggregation/sum.md	38
website/www/site/content/en/documentation/transforms/python/aggregation/tolist.md	24
website/www/site/content/en/documentation/transforms/python/aggregation/top.md	60
website/www/site/content/en/documentation/transforms/python/elementwise/enrichment-bigtable.md	48
website/www/site/content/en/documentation/transforms/python/elementwise/enrichment-vertexai.md	67
website/www/site/content/en/documentation/transforms/python/elementwise/enrichment.md	71
website/www/site/content/en/documentation/transforms/python/elementwise/filter.md	72
website/www/site/content/en/documentation/transforms/python/elementwise/flatmap.md	99
website/www/site/content/en/documentation/transforms/python/elementwise/keys.md	28
website/www/site/content/en/documentation/transforms/python/elementwise/kvswap.md	29
website/www/site/content/en/documentation/transforms/python/elementwise/map.md	91
website/www/site/content/en/documentation/transforms/python/elementwise/mltransform.md	83
website/www/site/content/en/documentation/transforms/python/elementwise/pardo.md	99
website/www/site/content/en/documentation/transforms/python/elementwise/partition.md	78
website/www/site/content/en/documentation/transforms/python/elementwise/regex.md	142
website/www/site/content/en/documentation/transforms/python/elementwise/reify.md	20
website/www/site/content/en/documentation/transforms/python/elementwise/runinference-pytorch.md	49
website/www/site/content/en/documentation/transforms/python/elementwise/runinference-sklearn.md	49
website/www/site/content/en/documentation/transforms/python/elementwise/runinference.md	40
website/www/site/content/en/documentation/transforms/python/elementwise/tostring.md	46
website/www/site/content/en/documentation/transforms/python/elementwise/values.md	28
website/www/site/content/en/documentation/transforms/python/elementwise/withkeys.md	19
website/www/site/content/en/documentation/transforms/python/elementwise/withtimestamps.md	61
website/www/site/content/en/documentation/transforms/python/other/create.md	33
website/www/site/content/en/documentation/transforms/python/other/flatten.md	36
website/www/site/content/en/documentation/transforms/python/other/flattenwith.md	40
website/www/site/content/en/documentation/transforms/python/other/passert.md	18
website/www/site/content/en/documentation/transforms/python/other/reshuffle.md	33
website/www/site/content/en/documentation/transforms/python/other/tee.md	33
website/www/site/content/en/documentation/transforms/python/other/view.md	18
website/www/site/content/en/documentation/transforms/python/other/windowinto.md	35
website/www/site/content/en/documentation/transforms/python/overview.md	75
website/www/site/content/en/get-started/_index.md	48
website/www/site/content/en/get-started/an-interactive-overview-of-beam.md	59
website/www/site/content/en/get-started/beam-overview.md	54
website/www/site/content/en/get-started/downloads.md	465
website/www/site/content/en/get-started/from-spark.md	289
website/www/site/content/en/get-started/mobile-gaming-example.md	259
website/www/site/content/en/get-started/quickstart-go.md	62
website/www/site/content/en/get-started/quickstart-java.md	385
website/www/site/content/en/get-started/quickstart-py.md	121
website/www/site/content/en/get-started/quickstart/go.md	141
website/www/site/content/en/get-started/quickstart/java.md	145
website/www/site/content/en/get-started/quickstart/python.md	166
website/www/site/content/en/get-started/quickstart/typescript.md	137
website/www/site/content/en/get-started/resources/learning-resources.md	125
website/www/site/content/en/get-started/resources/videos-and-podcasts.md	100
website/www/site/content/en/get-started/tour-of-beam.md	16
website/www/site/content/en/get-started/try-apache-beam.md	152
website/www/site/content/en/get-started/try-beam-playground.md	35
website/www/site/content/en/get-started/wordcount-example.md	1165
website/www/site/content/en/performance/_index.md	37
website/www/site/content/en/performance/bigquery/_index.md	31
website/www/site/content/en/performance/bigtable/_index.md	31
website/www/site/content/en/performance/glossary/_index.md	30
website/www/site/content/en/performance/pytorchbertbase/_index.md	23
website/www/site/content/en/performance/pytorchbertlarge/_index.md	23
website/www/site/content/en/performance/pytorchresnet101/_index.md	23
website/www/site/content/en/performance/pytorchresnet152/_index.md	23
website/www/site/content/en/performance/pytorchresnet152tesla/_index.md	23
website/www/site/content/en/performance/tensorflowmnist/_index.md	23
website/www/site/content/en/performance/textio/_index.md	31
website/www/site/content/en/privacy_policy/_index.md	24
website/www/site/content/en/roadmap/_index.md	60
website/www/site/content/en/roadmap/connectors-go-sdk.md	23
website/www/site/content/en/roadmap/connectors-java-sdk.md	27
website/www/site/content/en/roadmap/connectors-multi-sdk.md	69
website/www/site/content/en/roadmap/connectors-python-sdk.md	23
website/www/site/content/en/roadmap/dataflow-runner.md	18
website/www/site/content/en/roadmap/euphoria.md	30
website/www/site/content/en/roadmap/flink-runner.md	18
website/www/site/content/en/roadmap/go-sdk.md	26
website/www/site/content/en/roadmap/java-sdk.md	19
website/www/site/content/en/roadmap/nemo-runner.md	18
website/www/site/content/en/roadmap/portability.md	100
website/www/site/content/en/roadmap/prism-runner.md	27
website/www/site/content/en/roadmap/python-sdk.md	25
website/www/site/content/en/roadmap/samza-runner.md	18
website/www/site/content/en/roadmap/spark-runner.md	20
website/www/site/content/en/roadmap/sql.md	18
website/www/site/content/en/roadmap/twister2-runner.md	18
website/www/site/content/en/security/CVE-2020-1929.md	14
website/www/site/content/en/security/_index.md	41
website/www/site/layouts/documentation/baseof.html	38
website/www/site/layouts/partials/documentation/capability-matrix-row.html	40
website/www/site/layouts/partials/documentation/icon-row.html	26
website/www/site/layouts/shortcodes/documentation/capability-matrix-big.html	72
website/www/site/layouts/shortcodes/documentation/capability-matrix-single.html	102
website/www/site/layouts/shortcodes/documentation/runners.html	43
website/www/site/layouts/shortcodes/documentation/sdks.html	19
website/www/site/static/images/add.svg	21
website/www/site/static/images/arrow-expandable.svg	20
website/www/site/static/images/arrow-icon_list.svg	20
website/www/site/static/images/arrow-right.svg	19
website/www/site/static/images/card_border.svg	35
website/www/site/static/images/cards_bg.svg	35
website/www/site/static/images/code-icon.svg	20
website/www/site/static/images/community/beam-logo-icon.svg	44
website/www/site/static/images/community/diamond-icon.svg	37
website/www/site/static/images/community/messages-icon.svg	26
website/www/site/static/images/copy-icon.svg	21
website/www/site/static/images/design-your-pipeline-additional-outputs.svg	87
website/www/site/static/images/design-your-pipeline-flatten.svg	113
website/www/site/static/images/design-your-pipeline-join.svg	96
website/www/site/static/images/design-your-pipeline-linear.svg	96
website/www/site/static/images/design-your-pipeline-multiple-pcollections.svg	97
website/www/site/static/images/elipse.svg	20
website/www/site/static/images/ellipse-mobile.svg	20
website/www/site/static/images/ellipse.svg	20
website/www/site/static/images/execution_model_bundling.svg	372
website/www/site/static/images/execution_model_bundling_coupled_failure.svg	75
website/www/site/static/images/execution_model_bundling_gantt.svg	66
website/www/site/static/images/execution_model_bundling_gantt_max.svg	83
website/www/site/static/images/execution_model_bundling_multi.svg	351
website/www/site/static/images/execution_model_bundling_multi_gantt.svg	68
website/www/site/static/images/execution_model_failure_retry.svg	72
website/www/site/static/images/github-icon.svg	27
website/www/site/static/images/hero_bg.svg	46
website/www/site/static/images/hero_bg_flat.svg	57
website/www/site/static/images/info_icon.svg	21
website/www/site/static/images/mascot/learning_independently.svg	3238
website/www/site/static/images/model-ellipse.svg	20
website/www/site/static/images/model-processing-icon.svg	43
website/www/site/static/images/model-sinks-icon.svg	21
website/www/site/static/images/model-sources-icon.svg	23
website/www/site/static/images/run-icon.svg	20
website/www/site/static/images/runinference_metrics_snapshot.svg	4749
website/www/site/static/images/unwindowed-pipeline-bounded.svg	93
website/www/site/static/images/windowing-pipeline-bounded.svg	113
website/www/site/static/images/windowing-pipeline-unbounded.svg	118
website/www/site/static/images/wordcount-pipeline.svg	131