anthropics / beam
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 7,200 files with 802,493 lines of code.
    • 183 files changed more than 100 times (138,976 lines of code)
    • 473 files changed 51-100 times (146,651 lines of code)
    • 1,266 files changed 21-50 times (188,756 lines of code)
    • 2,530 files changed 6-20 times (205,858 lines of code)
    • 2,748 files changed 1-5 times (122,252 lines of code)
17% | 18% | 23% | 25% | 15%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 7,200 files with 802,493 lines of code.
    • 937 files changed by more than 25 contributors (326,181 lines of code)
    • 1,724 files changed by 11-25 contributors (189,487 lines of code)
    • 1,399 files changed by 6-10 contributors (118,954 lines of code)
    • 2,827 files changed by 2-5 contributors (145,135 lines of code)
    • 313 files changed by 1 contributor (22,736 lines of code)
40% | 23% | 14% | 18% | 2%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, py, go, md, yaml, dart, txt, gradle, json, svg, ts, sh, tf, kt, sql, scss, html, ipynb, js, properties, xml, proto, groovy, tsx, sass, pxd, kts, css, mod, tfvars, toml, avsc, pyx, hcl, bat, gitignore, p8, cfg, ini, tpl, pb, ps1, rs, gitattributes, thrift, cc, dockerfile, h, prettierignore, pyi, htaccess, editorconfig, in, g4, gitmodules, eslintignore, scala, ftl, rdf
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java17% | 20% | 26% | 23% | 11%
py36% | 19% | 17% | 17% | 8%
go8% | 21% | 27% | 32% | 9%
groovy58% | 6% | 10% | 15% | 9%
kts45% | 0% | 8% | 39% | 6%
pxd17% | 37% | 17% | 21% | 6%
toml100% | 0% | 0% | 0% | 0%
yaml<1% | 4% | 12% | 50% | 32%
proto0% | 18% | 49% | 23% | 7%
html0% | 18% | 23% | 40% | 17%
ts0% | 0% | 23% | 25% | 50%
scss0% | 0% | 9% | 34% | 55%
ftl0% | 0% | 100% | 0% | 0%
pyx0% | 0% | 61% | 20% | 17%
dart0% | 0% | 1% | 57% | 40%
sass0% | 0% | 25% | 53% | 20%
xml0% | 0% | 5% | 5% | 88%
in0% | 0% | 100% | 0% | 0%
tsx0% | 0% | 0% | 36% | 63%
js0% | 0% | 0% | 16% | 83%
pyi0% | 0% | 0% | 100% | 0%
ipynb0% | 0% | 0% | 59% | 40%
css0% | 0% | 0% | 49% | 50%
tpl0% | 0% | 0% | 81% | 18%
scala0% | 0% | 0% | 100% | 0%
cfg0% | 0% | 0% | 10% | 89%
sql0% | 0% | 0% | 0% | 100%
kt0% | 0% | 0% | 0% | 100%
hcl0% | 0% | 0% | 0% | 100%
ps10% | 0% | 0% | 0% | 100%
h0% | 0% | 0% | 0% | 100%
rdf0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
sdks20% | 20% | 24% | 22% | 12%
runners18% | 22% | 31% | 19% | 7%
buildSrc71% | 7% | 3% | 9% | 7%
ROOT88% | 0% | 9% | 1% | 0%
website<1% | 3% | 19% | 34% | 41%
playground0% | 11% | 13% | 53% | 22%
model0% | 7% | 55% | 27% | 8%
release0% | 10% | 53% | 26% | 9%
scripts0% | 0% | 10% | 89% | 0%
learning0% | 0% | <1% | 39% | 60%
.test-infra0% | 0% | <1% | 70% | 28%
it0% | 0% | 0% | 79% | 20%
.github0% | 0% | 0% | 31% | 68%
plugins0% | 0% | 0% | 59% | 40%
infra0% | 0% | 0% | 0% | 100%
contributor-docs0% | 0% | 0% | 0% | 100%
.gemini0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
BeamModulePlugin.groovy
in buildSrc/src/main/groovy/org/apache/beam/gradle
 2377 7 2018-06-19 2026-01-14 954 261 kenn@apache.org dannymccormick@google.com
DataflowRunner.java
in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow
 2215 86 2016-05-10 2025-11-24 505 145 klk@google.com tom.j.stepp@gmail.com
core.py
in sdks/python/apache_beam/transforms
 2413 286 2016-06-14 2025-12-29 449 128 davor@google.com tvalentyn@users.noreply.git...
BigQueryIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 2664 168 2016-07-18 2025-12-22 412 150 dhalperi@google.com 33973061+claudevdm@users.no...
dataflow_runner.py
in sdks/python/apache_beam/runners/dataflow
 554 36 2017-02-15 2025-11-05 396 123 pabloem@google.com 34928439+jrmccluskey@users....
pipeline_options.py
in sdks/python/apache_beam/options
 1719 71 2017-05-07 2025-12-15 368 142 sourabhbajaj@google.com yathu@google.com
bigquery.py
in sdks/python/apache_beam/io/gcp
 1953 95 2017-02-22 2025-11-05 335 127 sourabhbajaj@google.com 34928439+jrmccluskey@users....
apiclient.py
in sdks/python/apache_beam/runners/dataflow/internal
 975 47 2017-02-15 2025-11-05 320 122 pabloem@google.com 34928439+jrmccluskey@users....
KafkaIO.java
in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka
 2191 169 2016-04-07 2025-11-24 319 117 dhalperi@google.com tom.j.stepp@gmail.com
pipeline.py
in sdks/python/apache_beam
 971 67 2016-06-14 2025-11-13 311 110 davor@google.com 33973061+claudevdm@users.no...
DataflowPipelineTranslator.java
in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow
 1017 49 2016-04-12 2025-09-22 302 96 markshields@google.com kenn@apache.org
bundle_processor.py
in sdks/python/apache_beam/runners/worker
 1786 128 2017-06-05 2025-11-17 292 96 tgroh@google.com dannymccormick@google.com
names.py
in sdks/python/apache_beam/runners/dataflow/internal
 6 - 2017-02-23 2026-01-06 276 99 altay@google.com apanich@google.com
DoFnOperator.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming
 1253 86 2017-03-18 2026-01-07 267 89 aljoscha.krettek@gmail.com yathu@google.com
coders.py
in sdks/python/apache_beam/coders
 1101 323 2016-06-14 2025-11-05 263 106 davor@google.com 34928439+jrmccluskey@users....
BigQueryServicesImpl.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 1656 67 2016-07-18 2025-11-04 262 108 dhalperi@google.com huxiangqian@gmail.com
common.py
in sdks/python/apache_beam/runners
 1311 97 2016-06-14 2025-11-05 257 94 davor@google.com 34928439+jrmccluskey@users....
FnApiDoFnRunner.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness
 2428 156 2017-06-05 2025-10-15 255 84 tgroh@google.com radoslaws@google.com
sdk_worker.py
in sdks/python/apache_beam/runners/worker
 986 91 2017-04-20 2025-10-16 253 101 robertwb@gmail.com tvalentyn@users.noreply.git...
339 - 2020-09-02 2025-12-18 249 105 niels@basjes.nl 34928439+jrmccluskey@users....
util.py
in sdks/python/apache_beam/transforms
 1457 117 2016-06-14 2025-12-02 244 101 davor@google.com dannymccormick@google.com
JdbcIO.java
in sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc
 1931 153 2016-09-05 2025-09-02 243 104 jbonofre@apache.org yathu@google.com
StreamingDataflowWorker.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker
 1066 35 2018-10-08 2025-12-02 242 99 36090911+boyuanzz@users.nor... radoslaws@google.com
TransformTranslator.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/translation
 755 29 2016-03-14 2025-09-02 237 84 ansela@paypal.com yathu@google.com
BigtableIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable
 1473 132 2016-04-20 2025-01-14 234 95 jbonofre@apache.org tonycantang@gmail.com
ProcessBundleHandler.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control
 1052 38 2017-01-19 2025-10-30 230 83 lcwik@google.com scwhittle@users.noreply.git...
ptransform.py
in sdks/python/apache_beam/transforms
 739 85 2016-06-14 2025-11-05 225 91 davor@google.com 34928439+jrmccluskey@users....
769 - 2021-01-22 2025-12-07 222 88 iemejia@gmail.com 33973061+claudevdm@users.no...
iobase.py
in sdks/python/apache_beam/io
 750 113 2016-06-14 2025-06-17 220 82 davor@google.com 40352446+razvanculea@users....
DoFn.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
 296 13 2016-04-13 2025-11-19 216 68 bchambers@google.com kenn@apache.org
SimpleDoFnRunner.java
in runners/core-java/src/main/java/org/apache/beam/runners/core
 1254 137 2016-08-25 2025-11-19 216 75 klk@google.com kenn@apache.org
TextIO.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/io
 806 105 2016-04-13 2025-06-12 215 75 bchambers@google.com 53229637+tanusharma2511@use...
StreamingTransformTranslator.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming
 621 29 2016-03-14 2025-09-02 212 71 ansela@paypal.com yathu@google.com
ExecutableStageDoFnOperator.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming
 1032 54 2018-05-13 2025-06-06 208 75 thw@apache.org kenn@apache.org
portable_runner.py
in sdks/python/apache_beam/runners/portability
 461 29 2018-05-08 2025-10-16 204 84 ankurgoenka@gmail.com 136421644+jh1231223@users.n...
ElasticsearchIO.java
in sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch
 1831 174 2016-10-20 2025-12-26 202 91 echauchot@gmail.com+jbonofr... ewal@pointpro.nl
FlinkStreamingTransformTranslators.java
in runners/flink/src/main/java/org/apache/beam/runners/flink
 1156 45 2017-03-19 2025-09-23 198 76 aljoscha.krettek@gmail.com kenn@apache.org
SpannerIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner
 1709 170 2017-05-04 2026-01-16 198 88 dhalperi@google.com dannymccormick@google.com
direct_runner.py
in sdks/python/apache_beam/runners/direct
 427 30 2016-10-28 2025-11-05 196 74 altay@google.com 34928439+jrmccluskey@users....
ParDo.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
 541 32 2016-03-04 2024-01-19 196 76 swegner@google.com svetaksundhar@google.com
coder_impl.py
in sdks/python/apache_beam/coders
 1409 191 2016-06-14 2025-12-22 195 91 davor@google.com 59060206+assaf127@users.nor...
SparkRunner.java
in runners/spark/src/main/java/org/apache/beam/runners/spark
 309 18 2016-06-17 2025-03-05 194 71 tgroh@google.com jozovilcek@users.noreply.gi...
Combine.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
 1359 160 2016-04-11 2025-10-08 194 65 swegner@google.com dannymccormick@google.com
operations.py
in sdks/python/apache_beam/runners/worker
 1028 99 2017-04-20 2025-11-25 193 79 robertwb@gmail.com 53406781+ktalluri456@users....
FileBasedSink.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/io
 761 58 2016-04-13 2024-10-17 191 67 bchambers@google.com robertwb@gmail.com
DoFnSignatures.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect
 2091 67 2016-08-10 2025-09-02 191 78 kirpichov@google.com yathu@google.com
bigquery_tools.py
in sdks/python/apache_beam/io/gcp
 1267 78 2019-01-26 2025-11-03 190 90 pabloem@users.noreply.githu... dannymccormick@google.com
gcsio.py
in sdks/python/apache_beam/io/gcp
 432 34 2017-02-22 2025-10-22 184 78 sourabhbajaj@google.com tvalentyn@users.noreply.git...
transform_evaluator.py
in sdks/python/apache_beam/runners/direct
 849 72 2016-10-28 2025-11-05 184 77 altay@google.com 34928439+jrmccluskey@users....
DoFnTester.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
 618 47 2016-03-04 2025-10-15 183 59 swegner@google.com radoslaws@google.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
BeamModulePlugin.groovy
in buildSrc/src/main/groovy/org/apache/beam/gradle
 2377 7 2018-06-19 2026-01-14 954 261 kenn@apache.org dannymccormick@google.com
BigQueryIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 2664 168 2016-07-18 2025-12-22 412 150 dhalperi@google.com 33973061+claudevdm@users.no...
DataflowRunner.java
in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow
 2215 86 2016-05-10 2025-11-24 505 145 klk@google.com tom.j.stepp@gmail.com
pipeline_options.py
in sdks/python/apache_beam/options
 1719 71 2017-05-07 2025-12-15 368 142 sourabhbajaj@google.com yathu@google.com
core.py
in sdks/python/apache_beam/transforms
 2413 286 2016-06-14 2025-12-29 449 128 davor@google.com tvalentyn@users.noreply.git...
bigquery.py
in sdks/python/apache_beam/io/gcp
 1953 95 2017-02-22 2025-11-05 335 127 sourabhbajaj@google.com 34928439+jrmccluskey@users....
dataflow_runner.py
in sdks/python/apache_beam/runners/dataflow
 554 36 2017-02-15 2025-11-05 396 123 pabloem@google.com 34928439+jrmccluskey@users....
apiclient.py
in sdks/python/apache_beam/runners/dataflow/internal
 975 47 2017-02-15 2025-11-05 320 122 pabloem@google.com 34928439+jrmccluskey@users....
KafkaIO.java
in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka
 2191 169 2016-04-07 2025-11-24 319 117 dhalperi@google.com tom.j.stepp@gmail.com
pipeline.py
in sdks/python/apache_beam
 971 67 2016-06-14 2025-11-13 311 110 davor@google.com 33973061+claudevdm@users.no...
BigQueryServicesImpl.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 1656 67 2016-07-18 2025-11-04 262 108 dhalperi@google.com huxiangqian@gmail.com
coders.py
in sdks/python/apache_beam/coders
 1101 323 2016-06-14 2025-11-05 263 106 davor@google.com 34928439+jrmccluskey@users....
339 - 2020-09-02 2025-12-18 249 105 niels@basjes.nl 34928439+jrmccluskey@users....
JdbcIO.java
in sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc
 1931 153 2016-09-05 2025-09-02 243 104 jbonofre@apache.org yathu@google.com
sdk_worker.py
in sdks/python/apache_beam/runners/worker
 986 91 2017-04-20 2025-10-16 253 101 robertwb@gmail.com tvalentyn@users.noreply.git...
util.py
in sdks/python/apache_beam/transforms
 1457 117 2016-06-14 2025-12-02 244 101 davor@google.com dannymccormick@google.com
names.py
in sdks/python/apache_beam/runners/dataflow/internal
 6 - 2017-02-23 2026-01-06 276 99 altay@google.com apanich@google.com
StreamingDataflowWorker.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker
 1066 35 2018-10-08 2025-12-02 242 99 36090911+boyuanzz@users.nor... radoslaws@google.com
DataflowPipelineTranslator.java
in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow
 1017 49 2016-04-12 2025-09-22 302 96 markshields@google.com kenn@apache.org
bundle_processor.py
in sdks/python/apache_beam/runners/worker
 1786 128 2017-06-05 2025-11-17 292 96 tgroh@google.com dannymccormick@google.com
BigtableIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable
 1473 132 2016-04-20 2025-01-14 234 95 jbonofre@apache.org tonycantang@gmail.com
common.py
in sdks/python/apache_beam/runners
 1311 97 2016-06-14 2025-11-05 257 94 davor@google.com 34928439+jrmccluskey@users....
ptransform.py
in sdks/python/apache_beam/transforms
 739 85 2016-06-14 2025-11-05 225 91 davor@google.com 34928439+jrmccluskey@users....
ElasticsearchIO.java
in sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch
 1831 174 2016-10-20 2025-12-26 202 91 echauchot@gmail.com+jbonofr... ewal@pointpro.nl
coder_impl.py
in sdks/python/apache_beam/coders
 1409 191 2016-06-14 2025-12-22 195 91 davor@google.com 59060206+assaf127@users.nor...
bigquery_tools.py
in sdks/python/apache_beam/io/gcp
 1267 78 2019-01-26 2025-11-03 190 90 pabloem@users.noreply.githu... dannymccormick@google.com
DoFnOperator.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming
 1253 86 2017-03-18 2026-01-07 267 89 aljoscha.krettek@gmail.com yathu@google.com
769 - 2021-01-22 2025-12-07 222 88 iemejia@gmail.com 33973061+claudevdm@users.no...
SpannerIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner
 1709 170 2017-05-04 2026-01-16 198 88 dhalperi@google.com dannymccormick@google.com
version.py
in sdks/python/apache_beam
 1 - 2016-06-14 2026-01-30 131 86 davor@google.com yilei@anthropic.com
BatchLoads.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 756 21 2017-03-29 2025-10-20 174 85 relax@google.com yathu@google.com
BigQueryUtils.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 1055 44 2018-03-21 2026-01-07 163 85 apilloud@google.com 33973061+claudevdm@users.no...
FnApiDoFnRunner.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness
 2428 156 2017-06-05 2025-10-15 255 84 tgroh@google.com radoslaws@google.com
TransformTranslator.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/translation
 755 29 2016-03-14 2025-09-02 237 84 ansela@paypal.com yathu@google.com
portable_runner.py
in sdks/python/apache_beam/runners/portability
 461 29 2018-05-08 2025-10-16 204 84 ankurgoenka@gmail.com 136421644+jh1231223@users.n...
ProcessBundleHandler.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control
 1052 38 2017-01-19 2025-10-30 230 83 lcwik@google.com scwhittle@users.noreply.git...
iobase.py
in sdks/python/apache_beam/io
 750 113 2016-06-14 2025-06-17 220 82 davor@google.com 40352446+razvanculea@users....
trigger.py
in sdks/python/apache_beam/transforms
 1162 239 2016-06-14 2025-10-02 170 81 davor@google.com tannapareddy@google.com
PubsubIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub
 1081 88 2017-04-12 2025-09-11 153 81 dhalperi@google.com 95318300+johnjcasey@users.n...
operations.py
in sdks/python/apache_beam/runners/worker
 1028 99 2017-04-20 2025-11-25 193 79 robertwb@gmail.com 53406781+ktalluri456@users....
FnHarness.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness
 330 6 2017-01-19 2025-08-06 172 79 lcwik@google.com dannymccormick@google.com
coders_test_common.py
in sdks/python/apache_beam/coders
 816 56 2016-06-14 2025-12-22 164 79 davor@google.com 59060206+assaf127@users.nor...
typehints.py
in sdks/python/apache_beam/typehints
 920 130 2016-06-14 2025-11-18 156 79 davor@google.com 34928439+jrmccluskey@users....
WriteTables.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 487 14 2017-03-17 2024-11-14 149 79 relax@google.com robertwb@gmail.com
sdk_worker_main.py
in sdks/python/apache_beam/runners/worker
 271 13 2017-04-20 2025-12-07 141 79 robertwb@gmail.com 33973061+claudevdm@users.no...
DoFnSignatures.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect
 2091 67 2016-08-10 2025-09-02 191 78 kirpichov@google.com yathu@google.com
gcsio.py
in sdks/python/apache_beam/io/gcp
 432 34 2017-02-22 2025-10-22 184 78 sourabhbajaj@google.com tvalentyn@users.noreply.git...
DatastoreV1.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore
 1645 136 2016-08-19 2025-09-02 160 78 vikasrk@google.com yathu@google.com
transform_evaluator.py
in sdks/python/apache_beam/runners/direct
 849 72 2016-10-28 2025-11-05 184 77 altay@google.com 34928439+jrmccluskey@users....
textio.py
in sdks/python/apache_beam/io
 596 39 2016-08-30 2025-08-06 142 77 chamikara@google.com huxiangqian@gmail.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
DoFnOperator.java
in runners/flink/1.20/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming
 1249 86 2025-11-25 2025-11-25 1 1 yathu@google.com yathu@google.com
beam_viewer.role.yaml
in infra/iam/roles
 1093 - 2025-08-26 2025-08-26 1 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
828 - 2025-08-26 2025-08-26 1 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
beam_admin.role.yaml
in infra/iam/roles
 654 - 2025-08-26 2025-08-26 1 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
secret_manager.py
in infra/keys
 466 23 2025-08-11 2025-08-11 1 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
cloudsql.py
in sdks/python/apache_beam/transforms/enrichment_handlers
 374 29 2025-08-22 2025-09-10 2 1 mohamedmohey2352@gmail.com mohamedmohey2352@gmail.com
EditablePanel.tsx
in sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml
 330 4 2025-09-06 2025-09-06 1 1 120361592+chenzo1001@users.... 120361592+chenzo1001@users....
Histogram.java
in sdks/java/extensions/combiners/src/main/java/org/apache/beam/sdk/extensions/combiners
 315 25 2024-06-26 2024-06-26 1 1 dilnaz010220@gmail.com dilnaz010220@gmail.com
account_keys.py
in infra/enforcement
 302 16 2025-08-18 2025-08-18 1 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
YamlEditor.tsx
in sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml
 293 - 2025-09-06 2025-09-06 1 1 120361592+chenzo1001@users.... 120361592+chenzo1001@users....
beam_writer.role.yaml
in infra/iam/roles
 286 - 2025-08-26 2025-08-26 1 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
ReadFromSparkReceiverWithOffsetDoFn.java
in sdks/java/io/sparkreceiver/3/src/main/java/org/apache/beam/sdk/io/sparkreceiver
 277 11 2025-02-24 2025-02-24 1 1 shunping@google.com shunping@google.com
iam.py
in infra/enforcement
 259 12 2025-08-18 2025-10-09 3 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
NaiveReadFromPulsarDoFn.java
in sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar
 253 16 2025-09-15 2025-09-15 1 1 yathu@google.com yathu@google.com
Yaml.tsx
in sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml
 251 2 2025-09-06 2025-09-06 1 1 120361592+chenzo1001@users.... 120361592+chenzo1001@users....
async_dofn.py
in sdks/python/apache_beam/transforms
 247 15 2025-06-19 2025-11-13 4 1 dcrhodes@google.com dcrhodes@google.com
keys.py
in infra/keys
 237 8 2025-08-11 2025-08-29 2 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
OrderedListUserState.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state
 236 10 2024-06-13 2024-06-13 1 1 shunping@google.com shunping@google.com
CatalogManagerSchema.java
in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl
 231 20 2025-10-01 2025-12-09 2 1 65791736+ahmedabu98@users.n... 65791736+ahmedabu98@users.n...
ClickHouseResourceManager.java
in it/clickhouse/src/main/java/org/apache/beam/it/clickhouse
 226 9 2025-03-10 2025-04-22 2 1 bentsi.leviav@clickhouse.com bentsi.leviav@clickhouse.com
service_account.py
in infra/keys
 221 16 2025-08-11 2025-08-11 1 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
stale_cleaner.py
in .test-infra/tools
 221 27 2025-05-29 2025-07-14 6 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
spanner.py
in sdks/python/apache_beam/ml/rag/ingestion
 213 18 2025-10-30 2025-10-30 1 1 33973061+claudevdm@users.no... 33973061+claudevdm@users.no...
log_analyzer.py
in infra/security
 212 10 2025-08-27 2025-08-27 1 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
migrate_roles.py
in infra/iam
 196 5 2025-08-26 2025-08-26 1 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
GroupByEncryptedKey.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
 180 8 2025-10-04 2025-10-15 4 1 dannymccormick@google.com dannymccormick@google.com
CatalogSchema.java
in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl
 174 13 2025-10-01 2025-10-01 1 1 65791736+ahmedabu98@users.n... 65791736+ahmedabu98@users.n...
IcebergCdcReadSchemaTransformProvider.java
in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg
 169 7 2025-03-20 2025-05-13 3 1 65791736+ahmedabu98@users.n... 65791736+ahmedabu98@users.n...
WindmillTagEncodingV1.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state
 164 7 2025-12-19 2025-12-19 1 1 pandiana@google.com pandiana@google.com
YamlFlow.tsx
in sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml
 163 - 2025-09-06 2025-09-06 1 1 120361592+chenzo1001@users.... 120361592+chenzo1001@users....
DatabaseTestHelper.java
in sdks/java/io/common/src/main/java/org/apache/beam/sdk/io/common
 161 10 2024-06-28 2025-09-02 2 1 yathu@google.com yathu@google.com
YamlUtils.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils
 161 7 2024-04-08 2025-04-29 4 1 65791736+ahmedabu98@users.n... 65791736+ahmedabu98@users.n...
ReadUtils.java
in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg
 160 4 2025-03-20 2025-07-21 4 1 65791736+ahmedabu98@users.n... 65791736+ahmedabu98@users.n...
FileAwareFactoryFn.java
in sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories
 156 7 2025-10-29 2025-10-29 1 1 134544020+fozzie15@users.no... 134544020+fozzie15@users.no...
StreamDebugMetrics.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client
 150 21 2024-11-19 2024-11-19 1 1 martinkt@google.com martinkt@google.com
generate_roles.py
in infra/iam/roles
 147 8 2025-08-26 2025-08-26 1 1 71863693+ksobrenat32@users.... 71863693+ksobrenat32@users....
TFRecordReadSchemaTransformProvider.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/io
 147 9 2025-04-14 2025-04-14 1 1 derrickaw@google.com derrickaw@google.com
JcsmpSessionService.java
in sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker
 143 13 2025-01-07 2025-01-07 1 1 bzablocki@google.com bzablocki@google.com
mysql_common.py
in sdks/python/apache_beam/ml/rag/ingestion
 141 19 2025-07-07 2025-07-07 1 1 33973061+claudevdm@users.no... 33973061+claudevdm@users.no...
IcebergTable.java
in sdks/java/extensions/sql/iceberg/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg
 141 7 2025-09-06 2025-10-01 2 1 65791736+ahmedabu98@users.n... 65791736+ahmedabu98@users.n...
GrpcVendoring_1_69_0.groovy
in buildSrc/src/main/groovy/org/apache/beam/gradle
 141 7 2025-01-15 2025-01-15 1 1 dannymccormick@google.com dannymccormick@google.com
WindmillChannels.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs
 140 10 2025-04-16 2025-04-16 1 1 martinkt@google.com martinkt@google.com
milvus_search.py
in sdks/python/apache_beam/ml/rag/ingestion
 140 16 2025-11-21 2025-11-21 1 1 mohamedmohey2352@gmail.com mohamedmohey2352@gmail.com
LazyFlinkSourceSplitEnumerator.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source
 139 8 2025-02-03 2025-02-03 1 1 boudhevil@gmail.com boudhevil@gmail.com
rate_limiter.py
in sdks/python/apache_beam/io/components
 138 8 2026-01-05 2026-01-14 2 1 tannapareddy@google.com tannapareddy@google.com
LockFreeHistogram.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker
 136 14 2024-04-09 2024-05-07 2 1 jayajp@google.com jayajp@google.com
WatchForSnapshots.java
in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg
 135 1 2025-03-20 2025-03-20 1 1 65791736+ahmedabu98@users.n... 65791736+ahmedabu98@users.n...
StreamingInsertsMetrics.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 132 7 2024-03-21 2024-04-17 3 1 jayajp@google.com jayajp@google.com
SystemTables.java
in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta
 128 14 2025-12-09 2025-12-09 1 1 65791736+ahmedabu98@users.n... 65791736+ahmedabu98@users.n...
mysql.py
in sdks/python/apache_beam/ml/rag/ingestion
 127 14 2025-07-07 2025-07-07 1 1 33973061+claudevdm@users.no... 33973061+claudevdm@users.no...