Path Lines of Code CHANGES.md 394 CI.md 102 buildSrc/greclipse.properties 21 examples/java/README.md 43 examples/java/build.gradle 125 examples/java/src/main/java/org/apache/beam/examples/DebuggingWordCount.java 64 examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java 31 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 394 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 275 examples/java/src/main/java/org/apache/beam/examples/complete/TrafficRoutes.java 284 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 211 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 25 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 65 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 103 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 97 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 41 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 91 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 54 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 80 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 130 examples/java/src/main/java/org/apache/beam/examples/cookbook/CombinePerKeyExamples.java 104 examples/java/src/main/java/org/apache/beam/examples/cookbook/DistinctExample.java 40 examples/java/src/main/java/org/apache/beam/examples/cookbook/FilterExamples.java 138 examples/java/src/main/java/org/apache/beam/examples/cookbook/JoinExamples.java 103 examples/java/src/main/java/org/apache/beam/examples/cookbook/MaxPerKeyExamples.java 78 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 265 examples/java/src/main/java/org/apache/beam/examples/snippets/Snippets.java 1017 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 72 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 207 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 48 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 34 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 49 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 44 examples/java/src/test/java/org/apache/beam/examples/complete/TrafficMaxLaneFlowIT.java 71 examples/java/src/test/java/org/apache/beam/examples/complete/TrafficRoutesIT.java 71 examples/java/src/test/java/org/apache/beam/examples/complete/datatokenization/DataTokenizationTest.java 161 examples/java/src/test/java/org/apache/beam/examples/complete/game/GameStatsTest.java 52 examples/java/src/test/java/org/apache/beam/examples/complete/game/HourlyTeamScoreTest.java 83 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 119 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 62 examples/java/src/test/java/org/apache/beam/examples/cookbook/CombinePerKeyExamplesTest.java 57 examples/java/src/test/java/org/apache/beam/examples/cookbook/DistinctExampleTest.java 37 examples/java/src/test/java/org/apache/beam/examples/cookbook/FilterExamplesTest.java 62 examples/java/src/test/java/org/apache/beam/examples/cookbook/JoinExamplesTest.java 87 examples/java/src/test/java/org/apache/beam/examples/cookbook/MaxPerKeyExamplesTest.java 70 examples/java/src/test/java/org/apache/beam/examples/cookbook/TriggerExampleTest.java 127 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 136 examples/java/src/test/resources/schema.txt 19 examples/java/src/test/resources/testInput.txt 3 examples/kotlin/README.md 41 examples/kotlin/build.gradle 96 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 52 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 36 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 36 examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/FilterExamplesTest.kt 57 examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/JoinExamplesTest.kt 78 examples/kotlin/src/test/java/org/apache/beam/examples/kotlin/cookbook/MaxPerKeyExamplesTest.kt 60 examples/notebooks/README.md 61 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 419 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/try-apache-beam-go.ipynb 585 examples/notebooks/get-started/try-apache-beam-java.ipynb 1099 examples/notebooks/get-started/try-apache-beam-py.ipynb 410 examples/notebooks/patch.py 42 examples/notebooks/tour-of-beam/reading-and-writing-data.ipynb 1035 gradle.properties 31 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 28 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 34 learning/katas/java/Core Transforms/Flatten/Flatten/task.md 34 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/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/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/Examples/Word Count/Word Count/task-info.yaml 10 learning/katas/python/Examples/Word Count/Word Count/task-remote-info.yaml 2 learning/katas/python/Examples/Word Count/Word Count/task.md 33 learning/katas/python/Examples/Word Count/Word Count/task.py 12 learning/katas/python/Examples/Word Count/Word Count/tests.py 17 learning/katas/python/Examples/Word Count/lesson-info.yaml 2 learning/katas/python/Examples/Word Count/lesson-remote-info.yaml 3 learning/katas/python/Examples/section-info.yaml 2 learning/katas/python/Examples/section-remote-info.yaml 2 learning/katas/python/IO/Built-in IOs/Built-in IOs/task.md 24 learning/katas/python/IO/TextIO/ReadFromText/countries.txt 10 learning/katas/python/IO/TextIO/ReadFromText/task.md 36 learning/katas/python/Introduction/Hello Beam/Hello Beam/task.md 42 learning/katas/python/README.md 28 learning/katas/python/Windowing/Adding Timestamp/ParDo/task.md 38 learning/katas/python/Windowing/Fixed Time Window/Fixed Time Window/task.md 45 learning/katas/python/requirements.txt 18 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 72 runners/google-cloud-dataflow-java/src/main/resources/org/apache/beam/runners/dataflow/dataflow.properties 21 runners/samza/src/main/resources/log4j.properties 22 runners/samza/src/main/resources/samza-conf.properties 33 runners/samza/src/test/resources/log4j-test.properties 24 runners/spark/2/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 runners/spark/src/test/resources/metrics.properties 54 sdks/go/BUILD.md 52 sdks/go/README.md 136 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 45 sdks/go/examples/complete/autocomplete/autocomplete.go 43 sdks/go/examples/contains/contains.go 64 sdks/go/examples/cookbook/combine/combine.go 66 sdks/go/examples/cookbook/filter/filter.go 63 sdks/go/examples/cookbook/join/join.go 74 sdks/go/examples/cookbook/max/max.go 54 sdks/go/examples/cookbook/tornadoes/tornadoes.go 57 sdks/go/examples/debugging_wordcount/debugging_wordcount.go 72 sdks/go/examples/forest/forest.go 42 sdks/go/examples/grades/grades.go 65 sdks/go/examples/minimal_wordcount/minimal_wordcount.go 30 sdks/go/examples/multiout/multiout.go 50 sdks/go/examples/pingpong/pingpong.go 85 sdks/go/examples/readavro/readavro.go 52 sdks/go/examples/streaming_wordcap/wordcap.go 47 sdks/go/examples/stringsplit/stringsplit.go 150 sdks/go/examples/windowed_wordcount/windowed_wordcount.go 54 sdks/go/examples/wordcount/wordcount.go 59 sdks/go/examples/xlang/cogroup_by/cogroup_by.go 62 sdks/go/examples/xlang/combine/combine.go 58 sdks/go/examples/xlang/combine_globally/combine_globally.go 39 sdks/go/examples/xlang/flatten/flatten.go 40 sdks/go/examples/xlang/group_by/group_by.go 62 sdks/go/examples/xlang/multi_input_output/multi.go 34 sdks/go/examples/xlang/partition/partition.go 41 sdks/go/examples/xlang/transforms.go 74 sdks/go/examples/xlang/wordcount/wordcount.go 64 sdks/go/examples/yatzy/yatzy.go 88 sdks/go/pkg/beam/model/PROTOBUF.md 54 sdks/java/build-tools/src/main/resources/beam/checkstyle.xml 244 sdks/java/container/license_scripts/requirement.txt 21 sdks/java/core/src/main/resources/org/apache/beam/sdk/sdk.properties 21 sdks/java/extensions/euphoria/README.md 26 sdks/java/extensions/protobuf/src/test/resources/README.md 29 sdks/java/extensions/protobuf/src/test/resources/org/apache/beam/sdk/extensions/protobuf/test_option_v1.pb 360 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_20_0.org.codehaus.commons.compiler.properties 18 sdks/java/extensions/sql/src/main/resources/saffron.properties 20 sdks/java/io/azure/README.md 16 sdks/java/io/azure/src/test/resources/in.txt 22 sdks/java/io/debezium/src/README.md 138 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 40 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/maven-archetypes/examples/build.gradle 49 sdks/java/maven-archetypes/examples/generate-sources.sh 36 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 400 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 57 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/python/apache_beam/examples/__init__.py 1 sdks/python/apache_beam/examples/avro_bitcoin.py 107 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_test.py 42 sdks/python/apache_beam/examples/complete/distribopt.py 187 sdks/python/apache_beam/examples/complete/distribopt_test.py 49 sdks/python/apache_beam/examples/complete/estimate_pi.py 53 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 79 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 41 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 88 sdks/python/apache_beam/examples/complete/game/leader_board_test.py 41 sdks/python/apache_beam/examples/complete/game/user_score.py 63 sdks/python/apache_beam/examples/complete/game/user_score_it_test.py 38 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 48 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 95 sdks/python/apache_beam/examples/complete/tfidf_test.py 55 sdks/python/apache_beam/examples/complete/top_wikipedia_sessions.py 90 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_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 142 sdks/python/apache_beam/examples/cookbook/coders.py 43 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 60 sdks/python/apache_beam/examples/cookbook/custom_ptransform_test.py 24 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 50 sdks/python/apache_beam/examples/cookbook/group_with_coder.py 49 sdks/python/apache_beam/examples/cookbook/group_with_coder_test.py 53 sdks/python/apache_beam/examples/cookbook/mergecontacts.py 83 sdks/python/apache_beam/examples/cookbook/mergecontacts_test.py 125 sdks/python/apache_beam/examples/cookbook/multiple_output_pardo.py 76 sdks/python/apache_beam/examples/cookbook/multiple_output_pardo_test.py 41 sdks/python/apache_beam/examples/dataframe/taxiride.py 68 sdks/python/apache_beam/examples/dataframe/taxiride_test.py 69 sdks/python/apache_beam/examples/dataframe/wordcount.py 42 sdks/python/apache_beam/examples/dataframe/wordcount_test.py 31 sdks/python/apache_beam/examples/fastavro_it_test.py 106 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/kafkataxi/README.md 151 sdks/python/apache_beam/examples/kafkataxi/__init__.py 1 sdks/python/apache_beam/examples/kafkataxi/kafka_taxi.py 54 sdks/python/apache_beam/examples/snippets/__init__.py 1 sdks/python/apache_beam/examples/snippets/snippets.py 1013 sdks/python/apache_beam/examples/snippets/snippets_test.py 972 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/cogroupbykey.py 22 sdks/python/apache_beam/examples/snippets/transforms/aggregation/cogroupbykey_test.py 27 sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineglobally.py 149 sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineglobally_test.py 44 sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey.py 187 sdks/python/apache_beam/examples/snippets/transforms/aggregation/combineperkey_test.py 56 sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues.py 167 sdks/python/apache_beam/examples/snippets/transforms/aggregation/combinevalues_test.py 55 sdks/python/apache_beam/examples/snippets/transforms/aggregation/count.py 43 sdks/python/apache_beam/examples/snippets/transforms/aggregation/count_test.py 39 sdks/python/apache_beam/examples/snippets/transforms/aggregation/distinct.py 17 sdks/python/apache_beam/examples/snippets/transforms/aggregation/distinct_test.py 20 sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupby_test.py 147 sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupbykey.py 21 sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupbykey_test.py 23 sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupintobatches.py 21 sdks/python/apache_beam/examples/snippets/transforms/aggregation/groupintobatches_test.py 24 sdks/python/apache_beam/examples/snippets/transforms/aggregation/latest.py 82 sdks/python/apache_beam/examples/snippets/transforms/aggregation/latest_test.py 28 sdks/python/apache_beam/examples/snippets/transforms/aggregation/max.py 28 sdks/python/apache_beam/examples/snippets/transforms/aggregation/max_test.py 27 sdks/python/apache_beam/examples/snippets/transforms/aggregation/mean.py 27 sdks/python/apache_beam/examples/snippets/transforms/aggregation/mean_test.py 27 sdks/python/apache_beam/examples/snippets/transforms/aggregation/min.py 28 sdks/python/apache_beam/examples/snippets/transforms/aggregation/min_test.py 27 sdks/python/apache_beam/examples/snippets/transforms/aggregation/sample.py 37 sdks/python/apache_beam/examples/snippets/transforms/aggregation/sample_test.py 28 sdks/python/apache_beam/examples/snippets/transforms/aggregation/sum.py 27 sdks/python/apache_beam/examples/snippets/transforms/aggregation/sum_test.py 27 sdks/python/apache_beam/examples/snippets/transforms/aggregation/top.py 99 sdks/python/apache_beam/examples/snippets/transforms/aggregation/top_test.py 60 sdks/python/apache_beam/examples/snippets/transforms/elementwise/__init__.py 1 sdks/python/apache_beam/examples/snippets/transforms/elementwise/filter.py 184 sdks/python/apache_beam/examples/snippets/transforms/elementwise/filter_test.py 38 sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap.py 186 sdks/python/apache_beam/examples/snippets/transforms/elementwise/flatmap_test.py 46 sdks/python/apache_beam/examples/snippets/transforms/elementwise/keys.py 16 sdks/python/apache_beam/examples/snippets/transforms/elementwise/keys_test.py 22 sdks/python/apache_beam/examples/snippets/transforms/elementwise/kvswap.py 16 sdks/python/apache_beam/examples/snippets/transforms/elementwise/kvswap_test.py 22 sdks/python/apache_beam/examples/snippets/transforms/elementwise/map.py 164 sdks/python/apache_beam/examples/snippets/transforms/elementwise/map_test.py 45 sdks/python/apache_beam/examples/snippets/transforms/elementwise/pardo.py 84 sdks/python/apache_beam/examples/snippets/transforms/elementwise/pardo_test.py 67 sdks/python/apache_beam/examples/snippets/transforms/elementwise/partition.py 77 sdks/python/apache_beam/examples/snippets/transforms/elementwise/partition_test.py 59 sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex.py 156 sdks/python/apache_beam/examples/snippets/transforms/elementwise/regex_test.py 103 sdks/python/apache_beam/examples/snippets/transforms/elementwise/tostring.py 48 sdks/python/apache_beam/examples/snippets/transforms/elementwise/tostring_test.py 44 sdks/python/apache_beam/examples/snippets/transforms/elementwise/values.py 16 sdks/python/apache_beam/examples/snippets/transforms/elementwise/values_test.py 22 sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps.py 80 sdks/python/apache_beam/examples/snippets/transforms/elementwise/withtimestamps_test.py 54 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 81 sdks/python/apache_beam/examples/streaming_wordcount_debugging_test.py 69 sdks/python/apache_beam/examples/streaming_wordcount_it_test.py 65 sdks/python/apache_beam/examples/windowed_wordcount.py 55 sdks/python/apache_beam/examples/wordcount.py 40 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 31 sdks/python/apache_beam/examples/wordcount_it_test.py 91 sdks/python/apache_beam/examples/wordcount_minimal.py 48 sdks/python/apache_beam/examples/wordcount_minimal_test.py 31 sdks/python/apache_beam/examples/wordcount_test.py 31 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/runners/interactive/README.md 198 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/UsCovidDataExample.ipynb 513 sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/README.md 86 sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/package.json 75 sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/tsconfig.json 32 sdks/python/apache_beam/testing/benchmarks/chicago_taxi/requirements.txt 23 sdks/python/apache_beam/testing/benchmarks/nexmark/README.md 47 sdks/python/build-requirements.txt 21 sdks/python/container/base_image_requirements.txt 64 sdks/python/mypy.ini 77 sdks/python/pytest.ini 35 sdks/python/test-suites/gradle.properties 35 sdks/python/tox.ini 221 website/CONTRIBUTE.md 277 website/README.md 45 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/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/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/beam-2.10.0.md 100 website/www/site/content/en/blog/beam-2.11.0.md 94 website/www/site/content/en/blog/beam-2.12.0.md 59 website/www/site/content/en/blog/beam-2.13.0.md 59 website/www/site/content/en/blog/beam-2.14.0.md 83 website/www/site/content/en/blog/beam-2.15.0.md 64 website/www/site/content/en/blog/beam-2.16.0.md 80 website/www/site/content/en/blog/beam-2.17.0.md 82 website/www/site/content/en/blog/beam-2.19.0.md 82 website/www/site/content/en/blog/beam-2.20.0.md 68 website/www/site/content/en/blog/beam-2.24.0.md 68 website/www/site/content/en/blog/beam-2.25.0.md 70 website/www/site/content/en/blog/beam-2.26.0.md 55 website/www/site/content/en/blog/beam-2.27.0.md 58 website/www/site/content/en/blog/beam-2.28.0.md 77 website/www/site/content/en/blog/beam-2.29.0.md 66 website/www/site/content/en/blog/beam-2.6.0.md 69 website/www/site/content/en/blog/beam-2.7.0.md 59 website/www/site/content/en/blog/beam-2.8.0.md 70 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-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/capability-matrix.md 31 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/graduation-media-recap.md 58 website/www/site/content/en/blog/gsoc-19.md 71 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/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/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 437 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/community/_index.md 22 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 31 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 35 website/www/site/content/en/contribute/_index.md 230 website/www/site/content/en/contribute/attributes.md 48 website/www/site/content/en/contribute/become-a-committer.md 38 website/www/site/content/en/contribute/committer-guide.md 103 website/www/site/content/en/contribute/design-documents.md 17 website/www/site/content/en/contribute/feature-branches.md 73 website/www/site/content/en/contribute/get-help.md 19 website/www/site/content/en/contribute/jira-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 70 website/www/site/content/en/contribute/precommit-policies.md 43 website/www/site/content/en/contribute/precommit-triage-guide.md 86 website/www/site/content/en/contribute/ptransform-style-guide.md 397 website/www/site/content/en/contribute/release-blocking.md 29 website/www/site/content/en/contribute/release-guide.md 925 website/www/site/content/en/contribute/runner-guide.md 688 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 38 website/www/site/content/en/documentation/basics.md 149 website/www/site/content/en/documentation/dsls/dataframes/overview.md 91 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 956 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 565 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 50 website/www/site/content/en/documentation/dsls/sql/shell.md 103 website/www/site/content/en/documentation/dsls/sql/walkthrough.md 128 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 438 website/www/site/content/en/documentation/dsls/sql/zetasql/lexical.md 471 website/www/site/content/en/documentation/dsls/sql/zetasql/math-functions.md 108 website/www/site/content/en/documentation/dsls/sql/zetasql/operators.md 542 website/www/site/content/en/documentation/dsls/sql/zetasql/overview.md 55 website/www/site/content/en/documentation/dsls/sql/zetasql/query-syntax.md 989 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/io/built-in.md 58 website/www/site/content/en/documentation/io/built-in/google-bigquery.md 709 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/snowflake.md 695 website/www/site/content/en/documentation/io/developing-io-java.md 284 website/www/site/content/en/documentation/io/developing-io-overview.md 141 website/www/site/content/en/documentation/io/developing-io-python.md 194 website/www/site/content/en/documentation/io/testing.md 318 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/cross-language.md 131 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/overview.md 43 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/side-inputs.md 54 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 198 website/www/site/content/en/documentation/programming-guide.md 4744 website/www/site/content/en/documentation/resources/learning-resources.md 101 website/www/site/content/en/documentation/resources/videos-and-podcasts.md 92 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 193 website/www/site/content/en/documentation/runners/direct.md 85 website/www/site/content/en/documentation/runners/flink.md 407 website/www/site/content/en/documentation/runners/jet.md 195 website/www/site/content/en/documentation/runners/jstorm.md 94 website/www/site/content/en/documentation/runners/mapreduce.md 77 website/www/site/content/en/documentation/runners/nemo.md 136 website/www/site/content/en/documentation/runners/samza.md 173 website/www/site/content/en/documentation/runners/spark.md 335 website/www/site/content/en/documentation/runners/twister2.md 129 website/www/site/content/en/documentation/runtime/environments.md 199 website/www/site/content/en/documentation/runtime/model.md 142 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.md 23 website/www/site/content/en/documentation/sdks/java-dependencies.md 54 website/www/site/content/en/documentation/sdks/java-extensions.md 51 website/www/site/content/en/documentation/sdks/java-thirdparty.md 86 website/www/site/content/en/documentation/sdks/java.md 32 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/python-dependencies.md 39 website/www/site/content/en/documentation/sdks/python-pipeline-dependencies.md 74 website/www/site/content/en/documentation/sdks/python-streaming.md 125 website/www/site/content/en/documentation/sdks/python-type-safety.md 175 website/www/site/content/en/documentation/sdks/python.md 35 website/www/site/content/en/documentation/transforms/java/aggregation/approximatequantiles.md 36 website/www/site/content/en/documentation/transforms/java/aggregation/approximateunique.md 35 website/www/site/content/en/documentation/transforms/java/aggregation/cogroupbykey.md 62 website/www/site/content/en/documentation/transforms/java/aggregation/combine.md 70 website/www/site/content/en/documentation/transforms/java/aggregation/combinewithcontext.md 30 website/www/site/content/en/documentation/transforms/java/aggregation/count.md 42 website/www/site/content/en/documentation/transforms/java/aggregation/distinct.md 35 website/www/site/content/en/documentation/transforms/java/aggregation/groupbykey.md 40 website/www/site/content/en/documentation/transforms/java/aggregation/groupintobatches.md 33 website/www/site/content/en/documentation/transforms/java/aggregation/hllcount.md 63 website/www/site/content/en/documentation/transforms/java/aggregation/latest.md 43 website/www/site/content/en/documentation/transforms/java/aggregation/max.md 46 website/www/site/content/en/documentation/transforms/java/aggregation/mean.md 47 website/www/site/content/en/documentation/transforms/java/aggregation/min.md 35 website/www/site/content/en/documentation/transforms/java/aggregation/sample.md 33 website/www/site/content/en/documentation/transforms/java/aggregation/sum.md 41 website/www/site/content/en/documentation/transforms/java/aggregation/top.md 32 website/www/site/content/en/documentation/transforms/java/elementwise/filter.md 52 website/www/site/content/en/documentation/transforms/java/elementwise/flatmapelements.md 33 website/www/site/content/en/documentation/transforms/java/elementwise/keys.md 35 website/www/site/content/en/documentation/transforms/java/elementwise/kvswap.md 35 website/www/site/content/en/documentation/transforms/java/elementwise/mapelements.md 53 website/www/site/content/en/documentation/transforms/java/elementwise/pardo.md 127 website/www/site/content/en/documentation/transforms/java/elementwise/partition.md 51 website/www/site/content/en/documentation/transforms/java/elementwise/regex.md 29 website/www/site/content/en/documentation/transforms/java/elementwise/reify.md 32 website/www/site/content/en/documentation/transforms/java/elementwise/tostring.md 30 website/www/site/content/en/documentation/transforms/java/elementwise/values.md 36 website/www/site/content/en/documentation/transforms/java/elementwise/withkeys.md 46 website/www/site/content/en/documentation/transforms/java/elementwise/withtimestamps.md 29 website/www/site/content/en/documentation/transforms/java/other/create.md 31 website/www/site/content/en/documentation/transforms/java/other/flatten.md 54 website/www/site/content/en/documentation/transforms/java/other/passert.md 51 website/www/site/content/en/documentation/transforms/java/other/view.md 30 website/www/site/content/en/documentation/transforms/java/other/window.md 33 website/www/site/content/en/documentation/transforms/java/overview.md 69 website/www/site/content/en/documentation/transforms/python/aggregation/approximatequantiles.md 18 website/www/site/content/en/documentation/transforms/python/aggregation/approximateunique.md 18 website/www/site/content/en/documentation/transforms/python/aggregation/cogroupbykey.md 42 website/www/site/content/en/documentation/transforms/python/aggregation/combineglobally.md 88 website/www/site/content/en/documentation/transforms/python/aggregation/combineperkey.md 102 website/www/site/content/en/documentation/transforms/python/aggregation/combinevalues.md 104 website/www/site/content/en/documentation/transforms/python/aggregation/combinewithcontext.md 18 website/www/site/content/en/documentation/transforms/python/aggregation/count.md 57 website/www/site/content/en/documentation/transforms/python/aggregation/distinct.md 33 website/www/site/content/en/documentation/transforms/python/aggregation/groupby.md 115 website/www/site/content/en/documentation/transforms/python/aggregation/groupbykey.md 37 website/www/site/content/en/documentation/transforms/python/aggregation/groupintobatches.md 35 website/www/site/content/en/documentation/transforms/python/aggregation/latest.md 46 website/www/site/content/en/documentation/transforms/python/aggregation/max.md 50 website/www/site/content/en/documentation/transforms/python/aggregation/mean.md 52 website/www/site/content/en/documentation/transforms/python/aggregation/min.md 50 website/www/site/content/en/documentation/transforms/python/aggregation/sample.md 48 website/www/site/content/en/documentation/transforms/python/aggregation/sum.md 50 website/www/site/content/en/documentation/transforms/python/aggregation/top.md 96 website/www/site/content/en/documentation/transforms/python/elementwise/filter.md 113 website/www/site/content/en/documentation/transforms/python/elementwise/flatmap.md 157 website/www/site/content/en/documentation/transforms/python/elementwise/keys.md 35 website/www/site/content/en/documentation/transforms/python/elementwise/kvswap.md 36 website/www/site/content/en/documentation/transforms/python/elementwise/map.md 140 website/www/site/content/en/documentation/transforms/python/elementwise/pardo.md 120 website/www/site/content/en/documentation/transforms/python/elementwise/partition.md 99 website/www/site/content/en/documentation/transforms/python/elementwise/regex.md 205 website/www/site/content/en/documentation/transforms/python/elementwise/reify.md 20 website/www/site/content/en/documentation/transforms/python/elementwise/tostring.md 67 website/www/site/content/en/documentation/transforms/python/elementwise/values.md 35 website/www/site/content/en/documentation/transforms/python/elementwise/withkeys.md 19 website/www/site/content/en/documentation/transforms/python/elementwise/withtimestamps.md 82 website/www/site/content/en/documentation/transforms/python/other/create.md 31 website/www/site/content/en/documentation/transforms/python/other/flatten.md 34 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/view.md 18 website/www/site/content/en/documentation/transforms/python/other/windowinto.md 33 website/www/site/content/en/documentation/transforms/python/overview.md 72 website/www/site/content/en/get-started/_index.md 31 website/www/site/content/en/get-started/beam-overview.md 50 website/www/site/content/en/get-started/downloads.md 250 website/www/site/content/en/get-started/from-spark.md 217 website/www/site/content/en/get-started/mobile-gaming-example.md 259 website/www/site/content/en/get-started/quickstart-go.md 71 website/www/site/content/en/get-started/quickstart-java.md 368 website/www/site/content/en/get-started/quickstart-py.md 147 website/www/site/content/en/get-started/tour-of-beam.md 49 website/www/site/content/en/get-started/try-apache-beam.md 152 website/www/site/content/en/get-started/wordcount-example.md 1137 website/www/site/content/en/powered-by/_index.md 18 website/www/site/content/en/powered-by/commercial/_index.md 16 website/www/site/content/en/powered-by/commercial/eBay.md 19 website/www/site/content/en/powered-by/commercial/goga.md 19 website/www/site/content/en/powered-by/commercial/mozilla.md 19 website/www/site/content/en/powered-by/commercial/neo4j.md 20 website/www/site/content/en/powered-by/commercial/oriel.md 20 website/www/site/content/en/powered-by/commercial/ricardo.md 20 website/www/site/content/en/powered-by/open-source/_index.md 15 website/www/site/content/en/powered-by/open-source/kio.md 35 website/www/site/content/en/powered-by/open-source/klio.md 19 website/www/site/content/en/powered-by/open-source/scio.md 18 website/www/site/content/en/privacy_policy/_index.md 23 website/www/site/content/en/roadmap/_index.md 62 website/www/site/content/en/roadmap/connectors-go-sdk.md 20 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 56 website/www/site/content/en/roadmap/java-sdk.md 20 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/python-sdk.md 27 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 38 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 98 website/www/site/layouts/shortcodes/documentation/runners.html 43 website/www/site/layouts/shortcodes/documentation/sdks.html 20 website/www/site/static/images/arrow-expandable.svg 20 website/www/site/static/images/arrow-icon_list.svg 20 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/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