anthropics / beam File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary

Number of files: 7,200
Daily file updates (only one update per file and date counted): 43069
First update: 2014-07-11
Latest update: 2026-06-01
Days between first and latest update: 4,344 (620 weeks, estimated 3,100 working days)
Active days (at least one file change): 3,622
Data:

Organized per file

File Change History Overall

File Age Distribution Overall

Days since first update

There are 7,200 files with 802,493 lines of code in files.

7,049 files that are 366+ days old (785,483 lines of code)
142 files that are 181-365 days old (16,201 lines of code)
9 files that are 91-180 days old (809 lines of code)
0 files that are 31-90 days old (0 lines of code)
0 files that are 1-30 days old (0 lines of code)

Legend:

366+

181-365

91-180

31-90

1-30

explore: grouped by folders | grouped by age

File Freshness Distribution Overall

Days since last update

There are 7,200 files with 802,493 lines of code in files.

5,872 files have been last changed 366+ days ago (479,800 lines of code)
1,214 files have been last changed 181-365 days ago (277,730 lines of code)
114 files have been last changed 91-180 days ago (44,963 lines of code)
0 files have been last changed 31-90 days ago (0 lines of code)
0 files have been last changed 1-30 days ago (0 lines of code)

Legend:

366+

181-365

91-180

31-90

1-30

explore: grouped by folders | grouped by freshness

File Change History 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 Age Distribution per Extension

Days since first update

366+

181-365

91-180

31-90

1-30

File Freshness Distribution per Extension

Days since last update

366+

181-365

91-180

31-90

1-30

File Change History per Logical Decomposition

primary

primary (file age distribution)

Days since first update

366+

181-365

91-180

31-90

1-30

primary (file freshness distribution)

Days since last update

366+

181-365

91-180

31-90

1-30

Oldest Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
FlinkStateInternals.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state	1587	121	2016-03-02	2025-02-03	118	61	mxm@apache.org	boudhevil@gmail.com
UnboundedSourceWrapper.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io	367	15	2016-03-02	2025-06-06	122	57	mxm@apache.org	kenn@apache.org
FlinkPipelineOptions.java in runners/flink/src/main/java/org/apache/beam/runners/flink	262	3	2016-03-02	2025-02-03	110	56	mxm@apache.org	boudhevil@gmail.com
FlinkDoFnFunction.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions	200	8	2016-03-02	2025-09-23	91	44	mxm@apache.org	kenn@apache.org
FlinkPipelineRunner.java in runners/flink/src/main/java/org/apache/beam/runners/flink	165	6	2016-03-02	2026-01-07	85	42	mxm@apache.org	yathu@google.com
FlinkPipelineExecutionEnvironment.java in runners/flink/src/main/java/org/apache/beam/runners/flink	162	9	2016-03-02	2025-11-06	101	57	mxm@apache.org	abdoibrahim1017@gmail.com
SourceInputFormat.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers	135	9	2016-03-02	2025-06-06	55	31	mxm@apache.org	kenn@apache.org
CoderTypeSerializer.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types	119	16	2016-03-02	2025-11-25	41	22	mxm@apache.org	yathu@google.com
CoderTypeInformation.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types	90	16	2016-03-02	2024-02-26	46	29	mxm@apache.org	je.ik@seznam.cz
FlinkPartialReduceFunction.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions	71	4	2016-03-02	2025-06-06	50	29	mxm@apache.org	kenn@apache.org
FlinkReduceFunction.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions	71	4	2016-03-02	2025-06-06	45	24	mxm@apache.org	kenn@apache.org
FlinkRunnerResult.java in runners/flink/src/main/java/org/apache/beam/runners/flink	50	7	2016-03-02	2024-01-19	48	34	mxm@apache.org	svetaksundhar@google.com
FlinkMultiOutputPruningFunction.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions	34	3	2016-03-02	2025-06-06	17	9	mxm@apache.org	kenn@apache.org
DataInputViewWrapper.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers	23	3	2016-03-02	2019-07-01	14	7	mxm@apache.org	dcrhodes@google.com
SourceInputSplit.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers	22	4	2016-03-02	2023-07-25	20	16	mxm@apache.org	svetaksundhar@google.com
DataOutputViewWrapper.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers	18	3	2016-03-02	2019-07-01	12	7	mxm@apache.org	dcrhodes@google.com
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
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
SparkPipelineRunner.java in runners/spark/src/main/java/org/apache/beam/runners/spark	209	4	2016-03-11	2025-05-06	116	56	ansela@paypal.com	yathu@google.com
CoderHelpers.java in runners/spark/src/main/java/org/apache/beam/runners/spark/coders	130	10	2016-03-11	2025-04-30	65	46	ansela@paypal.com	72733442+twosom@users.norep...
CreateStream.java in runners/spark/src/main/java/org/apache/beam/runners/spark/io	124	14	2016-03-11	2024-01-19	68	37	ansela@paypal.com	svetaksundhar@google.com
SparkPipelineOptions.java in runners/spark/src/main/java/org/apache/beam/runners/spark	50	-	2016-03-11	2023-07-25	108	51	ansela@paypal.com	svetaksundhar@google.com
ConsoleIO.java in runners/spark/src/main/java/org/apache/beam/runners/spark/io	31	6	2016-03-11	2018-11-20	28	20	ansela@paypal.com	millsd@google.com
ByteArray.java in runners/spark/src/main/java/org/apache/beam/runners/spark/util	30	4	2016-03-11	2024-01-19	24	18	ansela@paypal.com	svetaksundhar@google.com
ApiSurface.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util	530	46	2016-03-12	2024-01-19	78	44	klk@google.com	svetaksundhar@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
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
EvaluationContext.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	214	29	2016-03-14	2025-06-06	148	64	ansela@paypal.com	kenn@apache.org
MultiDoFnFunction.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	200	7	2016-03-14	2025-06-06	136	65	ansela@paypal.com	kenn@apache.org
SparkContextFactory.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	87	6	2016-03-14	2024-01-19	77	45	ansela@paypal.com	svetaksundhar@google.com
SparkProcessContext.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	39	6	2016-03-14	2024-12-18	105	49	ansela@paypal.com	72733442+twosom@users.norep...
SparkPipelineTranslator.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	9	-	2016-03-14	2018-11-20	16	12	ansela@paypal.com	millsd@google.com
TransformEvaluator.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	7	-	2016-03-14	2018-11-20	19	17	ansela@paypal.com	millsd@google.com
TestPipeline.java in sdks/java/core/src/main/java/org/apache/beam/sdk/testing	382	36	2016-03-15	2025-09-25	130	63	owenzhang1990@gmail.com	yathu@google.com
StarterPipeline.java in sdks/java/maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java	31	1	2016-03-24	2021-11-26	25	18	peihe0@gmail.com	marco.robles@wizeline.com
archetype-metadata.xml in sdks/java/maven-archetypes/starter/src/main/resources/META-INF/maven	20	-	2016-03-24	2018-04-10	12	12	peihe0@gmail.com	7542791+rezarokni@users.nor...
TestPipelineOptions.java in sdks/java/core/src/main/java/org/apache/beam/sdk/testing	49	3	2016-03-30	2023-07-25	41	26	jason@google.com	svetaksundhar@google.com
AfterWatermark.java in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing	107	20	2016-03-31	2024-01-19	77	43	tgroh@google.com	svetaksundhar@google.com
IdentityWindowFn.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util	63	7	2016-03-31	2021-04-14	40	18	tgroh@google.com	kenn@apache.org
Never.java in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing	26	4	2016-03-31	2023-07-25	42	23	tgroh@google.com	svetaksundhar@google.com
PipelineOptionsFactory.java in sdks/java/core/src/main/java/org/apache/beam/sdk/options	1521	67	2016-04-05	2025-09-02	149	67	swegner@google.com	yathu@google.com
ProxyInvocationHandler.java in sdks/java/core/src/main/java/org/apache/beam/sdk/options	620	28	2016-04-05	2024-01-19	109	54	swegner@google.com	svetaksundhar@google.com
DisplayData.java in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/display	509	59	2016-04-05	2024-01-19	111	51	swegner@google.com	svetaksundhar@google.com
PipelineOptions.java in sdks/java/core/src/main/java/org/apache/beam/sdk/options	145	3	2016-04-05	2025-10-08	114	48	swegner@google.com	dannymccormick@google.com
BucketingFunction.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util	78	10	2016-04-05	2024-01-19	31	23	markshields@google.com	svetaksundhar@google.com
MovingFunction.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util	69	5	2016-04-05	2024-01-19	41	29	markshields@google.com	svetaksundhar@google.com
PipelineOptionsReflector.java in sdks/java/core/src/main/java/org/apache/beam/sdk/options	57	4	2016-04-05	2024-01-19	24	16	swegner@google.com	svetaksundhar@google.com
PipelineOptionSpec.java in sdks/java/core/src/main/java/org/apache/beam/sdk/options	16	2	2016-04-05	2018-06-28	12	9	swegner@google.com	iemejia@gmail.com
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
KafkaRecordCoder.java in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka	108	8	2016-04-07	2024-01-19	68	40	dhalperi@google.com	svetaksundhar@google.com

Files Not Recently Changed (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
MimeTypes.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util	5	-	2016-04-13	2016-04-14	2	2	bchambers@google.com	davor@google.com
package-info.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util/common	1	-	2016-04-13	2016-08-25	7	5	bchambers@google.com	klk@google.com
package-info.java in sdks/java/extensions/join-library/src/main/java/org/apache/beam/sdk/extensions/joinlibrary	1	-	2016-07-19	2016-08-25	5	3	dhalperi@google.com	klk@google.com
package-info.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	1	-	2016-07-18	2016-08-25	5	3	dhalperi@google.com	klk@google.com
package-info.java in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options	1	-	2016-07-19	2016-08-25	5	3	dhalperi@google.com	klk@google.com
package-info.java in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util	1	-	2016-07-19	2016-08-25	5	3	dhalperi@google.com	klk@google.com
package-info.java in sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter	1	-	2016-10-25	2016-11-22	5	6	mshanklin@google.com	mariagh@google.com
DoFnInvokerFactory.java in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect	5	-	2016-11-08	2016-11-22	5	4	klk@google.com	mariagh@google.com
package-info.java in runners/spark/src/main/java/org/apache/beam/runners/spark/metrics	1	-	2017-01-11	2017-03-17	4	4	aviemzur@gmail.com	klk@google.com
cassandra-service-for-local-dev.yaml in .test-infra/kubernetes/cassandra/LargeITCluster	12	-	2017-04-11	2017-04-21	4	4	dipti_dkulkarni@persistent....	klk@google.com
cassandra-service-for-local-dev.yaml in .test-infra/kubernetes/cassandra/SmallITCluster	13	-	2017-04-11	2017-04-21	4	4	dipti_dkulkarni@persistent....	klk@google.com
elasticsearch-service-for-local-dev.yaml in .test-infra/kubernetes/elasticsearch/LargeProductionCluster	16	-	2017-04-11	2017-04-21	4	4	dipti_dkulkarni@persistent....	klk@google.com
elasticsearch-service-for-local-dev.yaml in .test-infra/kubernetes/elasticsearch/SmallITCluster	17	-	2017-04-11	2017-04-21	4	4	dipti_dkulkarni@persistent....	klk@google.com
cassandra-svc-temp.yaml in .test-infra/kubernetes/cassandra/LargeITCluster	54	-	2017-04-11	2017-04-21	4	4	dipti_dkulkarni@persistent....	klk@google.com
cassandra-svc-rc.yaml in .test-infra/kubernetes/cassandra/SmallITCluster	55	-	2017-04-07	2017-04-21	6	6	sisk@google.com	klk@google.com
es_test_data.py in .test-infra/kubernetes/elasticsearch	214	8	2017-04-07	2017-04-21	6	6	sisk@google.com	klk@google.com
beam-codestyle.xml in sdks/java/build-tools/src/main/resources/beam	313	-	2017-03-08	2017-04-21	4	4	aviemzur@gmail.com	klk@google.com
package-info.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/common	1	-	2017-04-24	2017-05-04	4	3	lcwik@google.com	klk@google.com
WatermarkHoldState.java in sdks/java/core/src/main/java/org/apache/beam/sdk/state	10	-	2017-05-02	2017-05-18	4	2	klk@google.com	owenzhang1990@gmail.com
SourceShard.java in runners/direct-java/src/main/java/org/apache/beam/runners/direct	8	-	2017-05-20	2017-06-05	3	2	klk@google.com	owenzhang1990@gmail.com
EmptyMatchTreatment.java in sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs	7	-	2017-08-03	2017-08-04	2	1	kirpichov@google.com	kirpichov@google.com
ResourceIdCoder.java in sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs	31	4	2017-08-03	2017-08-04	2	1	kirpichov@google.com	kirpichov@google.com
JavaBinCodecCoder.java in sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr	68	6	2017-07-22	2017-08-08	2	2	datcm@apache.org	kirpichov@google.com
HBaseResultCoder.java in sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase	25	4	2017-02-23	2017-08-25	13	7	iemejia@gmail.com	iemejia@gmail.com
SchemaAndRecord.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	17	3	2017-09-22	2017-10-12	3	3	sniemitz@twitter.com	rezarokni@google.com
TriggerStateMachines.java in runners/core-java/src/main/java/org/apache/beam/runners/core/triggers	98	5	2016-10-14	2017-10-12	23	12	klk@google.com	rezarokni@google.com
package-info.java in runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/logging	1	-	2017-10-31	2018-04-10	3	3	tgroh@google.com	7542791+rezarokni@users.nor...
package-info.java in runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data	1	-	2017-11-06	2018-04-10	4	3	tgroh@google.com	7542791+rezarokni@users.nor...
package-info.java in runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control	1	-	2017-11-06	2018-04-10	4	3	tgroh@google.com	7542791+rezarokni@users.nor...
package-info.java in runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/provisioning	1	-	2018-01-12	2018-04-10	7	7	tgroh@google.com	7542791+rezarokni@users.nor...
package-info.java in runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution	1	-	2017-10-12	2018-04-10	3	2	tgroh@google.com	7542791+rezarokni@users.nor...
core-site.xml in .test-infra/kubernetes/hadoop/config-files	6	-	2018-01-12	2018-04-10	7	7	szewinho@gmail.com	7542791+rezarokni@users.nor...
hdfs-site.xml in .test-infra/kubernetes/hadoop/config-files	10	-	2018-01-12	2018-04-10	7	7	szewinho@gmail.com	7542791+rezarokni@users.nor...
archetype-metadata.xml in sdks/java/maven-archetypes/starter/src/main/resources/META-INF/maven	20	-	2016-03-24	2018-04-10	12	12	peihe0@gmail.com	7542791+rezarokni@users.nor...
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform	1	-	2017-07-31	2018-05-30	6	5	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils	1	-	2017-07-31	2018-05-30	6	5	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser	1	-	2017-09-13	2018-05-30	8	7	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl	1	-	2017-08-09	2018-05-30	6	5	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/schema	1	-	2017-08-09	2018-05-30	6	5	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model	1	-	2018-04-24	2018-05-30	5	4	kenn@kennknowles.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example	1	-	2017-07-30	2018-05-30	7	6	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/store	1	-	2017-09-13	2018-05-30	8	7	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta	1	-	2017-09-13	2018-05-30	8	7	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/text	1	-	2017-09-13	2018-05-30	8	7	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka	1	-	2017-09-13	2018-05-30	12	9	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery	1	-	2018-03-27	2018-05-30	7	4	apilloud@google.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider	1	-	2017-09-13	2018-05-30	8	7	xumingmingv@gmail.com	kenn@kennknowles.com
package-info.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql	1	-	2017-07-30	2018-05-30	6	5	xumingmingv@gmail.com	kenn@kennknowles.com
doc.go in sdks/go/pkg/beam/core/graph	1	-	2017-11-30	2018-05-30	7	6	herohde@google.com	kenn@kennknowles.com
gen.go in sdks/go/pkg/beam/core/runtime/exec/optimized	1	-	2018-01-18	2018-05-30	9	9	herohde@google.com	kenn@kennknowles.com

Most Recently Created Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
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
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
WindmillTagEncoding.java in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state	75	2	2025-12-19	2025-12-19	1	1	pandiana@google.com	pandiana@google.com
UnsplittableRestrictionTracker.java in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn	37	6	2025-12-18	2025-12-18	1	1	sjvanrossum@google.com	sjvanrossum@google.com
TimestampPrecision.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	7	-	2025-12-10	2025-12-10	1	1	33973061+claudevdm@users.no...	33973061+claudevdm@users.no...
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...
BeamSystemSchema.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl	94	8	2025-12-09	2025-12-09	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
BeamSystemTableMetadataSchema.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl	89	8	2025-12-09	2025-12-09	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
BeamSystemDbMetadataSchema.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl	77	8	2025-12-09	2025-12-09	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
RemoteInference.java in sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote	77	7	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
OpenAIModelHandler.java in sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai	76	1	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
RetryHandler.java in sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote	66	3	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
OpenAIModelParameters.java in sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai	46	10	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
PredictionResult.java in sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote	19	4	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
OpenAIModelInput.java in sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai	14	3	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
OpenAIModelResponse.java in sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai	14	3	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
BaseModelHandler.java in sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote	6	-	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
BaseInput.java in sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote	4	-	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
BaseResponse.java in sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote	4	-	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
BaseModelParameters.java in sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote	4	-	2025-12-04	2025-12-07	2	2	ganeshsivakumar85@gmail.com	33973061+claudevdm@users.no...
GcpHsmGeneratedSecret.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util	110	6	2025-12-02	2025-12-02	1	1	dannymccormick@google.com	dannymccormick@google.com
roboto.css in website/www/site/assets/css/roboto	35	-	2025-11-26	2025-12-03	2	1	shunping@google.com	shunping@google.com
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
BundleLifter.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	119	8	2025-11-25	2025-11-25	1	1	tom.j.stepp@gmail.com	tom.j.stepp@gmail.com
WriteDirectRowsToFiles.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	110	4	2025-11-25	2025-11-25	1	1	tom.j.stepp@gmail.com	tom.j.stepp@gmail.com
KafkaReadWithRedistributeOverride.java in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka	45	2	2025-11-24	2025-11-24	1	1	tom.j.stepp@gmail.com	tom.j.stepp@gmail.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
utils.py in sdks/python/apache_beam/ml/rag	101	5	2025-11-12	2025-11-12	1	1	mohamedmohey2352@gmail.com	mohamedmohey2352@gmail.com
ThreadLocalByteStringOutputStream.java in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util	51	5	2025-11-12	2025-11-12	1	1	pandiana@google.com	pandiana@google.com
Timestamp.java in sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes	101	6	2025-11-05	2025-12-03	2	1	33973061+claudevdm@users.no...	33973061+claudevdm@users.no...
BigQueryDynamicReadDescriptor.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	71	3	2025-11-05	2025-11-05	1	1	radoslaws@google.com	radoslaws@google.com
ExpiringMemoizingSerializableSupplier.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util	52	3	2025-11-05	2025-11-05	1	1	sjvanrossum@google.com	sjvanrossum@google.com
cfg .isort.cfg in sdks/python	41	-	2025-11-05	2025-11-05	1	1	34928439+jrmccluskey@users....	34928439+jrmccluskey@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...
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...
KerberosConsumerFactoryFn.java in sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories	106	4	2025-10-29	2025-10-29	1	1	134544020+fozzie15@users.no...	134544020+fozzie15@users.no...
package-info.java in sdks/java/extensions/kafka-factories/src/main/java/org/apache/beam/sdk/extensions/kafka/factories	1	-	2025-10-29	2025-10-29	1	1	134544020+fozzie15@users.no...	134544020+fozzie15@users.no...
InternedByteString.java in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker	43	5	2025-10-28	2025-10-28	1	1	pandiana@google.com	pandiana@google.com
structural.go in sdks/go/pkg/beam/log	17	1	2025-10-14	2025-10-14	1	1	shunping@google.com	shunping@google.com
logger.py in sdks/python/apache_beam/utils	53	4	2025-10-10	2025-10-10	1	1	tvalentyn@users.noreply.git...	tvalentyn@users.noreply.git...
ThrottlingSignaler.java in sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/throttling	15	3	2025-10-07	2025-10-07	1	1	34928439+jrmccluskey@users....	34928439+jrmccluskey@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
Secret.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util	82	1	2025-10-04	2025-12-02	3	1	dannymccormick@google.com	dannymccormick@google.com
GcpSecret.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util	24	2	2025-10-04	2025-10-07	2	1	dannymccormick@google.com	dannymccormick@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...
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...
IcebergMetastore.java in sdks/java/extensions/sql/iceberg/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg	122	10	2025-10-01	2025-10-01	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
KafkaReadRedistribute.java in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka	85	7	2025-09-30	2025-09-30	1	1	tom.j.stepp@gmail.com	tom.j.stepp@gmail.com
ProtoBeamConverter.java in sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf	512	22	2025-09-25	2025-10-03	2	2	49642083+baeminbo@users.nor...	yathu@google.com
FieldValueHaver.java in sdks/java/core/src/main/java/org/apache/beam/sdk/schemas	8	-	2025-09-25	2025-09-25	1	1	49642083+baeminbo@users.nor...	49642083+baeminbo@users.nor...

Most Recently Changed Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
version.py in sdks/python/apache_beam	1	-	2016-06-14	2026-01-30	131	86	davor@google.com	yilei@anthropic.com
subprocess_server.py in sdks/python/apache_beam/utils	456	30	2019-09-03	2026-01-26	84	40	robertwb@gmail.com	han@anthropic.com
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
core.go in sdks/go/pkg/beam/core	6	-	2021-01-21	2026-01-16	54	34	lostluck@users.noreply.gith...	dannymccormick@google.com
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
base.py in sdks/python/apache_beam/ml/inference	1170	142	2022-04-12	2026-01-14	72	22	ryanthompson591@gmail.com	tannapareddy@google.com
BigQueryAvroUtils.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	548	23	2016-07-18	2026-01-14	89	57	dhalperi@google.com	33973061+claudevdm@users.no...
AvroGenericRecordToStorageApiProto.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	490	17	2023-02-17	2026-01-14	21	13	prodriguezdefino@gmail.com	33973061+claudevdm@users.no...
BeamRowToStorageApiProto.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	393	12	2021-03-05	2026-01-14	24	13	relax@google.com	33973061+claudevdm@users.no...
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
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
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...
FlinkPipelineRunner.java in runners/flink/src/main/java/org/apache/beam/runners/flink	165	6	2016-03-02	2026-01-07	85	42	mxm@apache.org	yathu@google.com
yaml_io.py in sdks/python/apache_beam/yaml	362	13	2023-08-25	2026-01-06	41	11	robertwb@gmail.com	huxiangqian@gmail.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
TableRowToStorageApiProto.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	1607	38	2021-03-05	2026-01-05	69	35	relax@google.com	33973061+claudevdm@users.no...
yaml_transform.py in sdks/python/apache_beam/yaml	1049	54	2023-01-24	2026-01-05	99	15	robertwb@gmail.com	derrickaw@google.com
yaml_testing.py in sdks/python/apache_beam/yaml	444	22	2025-04-01	2026-01-05	10	4	robertwb@gmail.com	huxiangqian@gmail.com
UnboundedSolaceReader.java in sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read	191	13	2024-06-18	2026-01-05	10	5	bzablocki@google.com	radoslaws@google.com
SolaceCheckpointMark.java in sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read	57	4	2024-06-18	2026-01-05	5	2	bzablocki@google.com	radoslaws@google.com
BigQueryWriteSchemaTransformProvider.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers	60	5	2024-11-12	2026-01-03	4	4	65791736+ahmedabu98@users.n...	huxiangqian@gmail.com
quotes.yaml in website/www/site/data/en	36	-	2020-12-08	2025-12-31	38	23	bntnam.app@gmail.com	dannymccormick@google.com
dep_urls_py.yaml in sdks/python/container/license_scripts	144	-	2020-04-03	2025-12-30	54	40	hannah-jiang@users.noreply....	tannapareddy@google.com
reporterConfig.js in sdks/typescript	13	-	2025-09-18	2025-12-30	2	2	cjohnson@gradle.com	154750865+junaiddshaukat@us...
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...
PortableMetrics.java in runners/portability/java/src/main/java/org/apache/beam/runners/portability	226	10	2019-11-14	2025-12-29	33	23	michal.walenia@polidea.com	140749446+suvrat1629@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
yaml_provider.py in sdks/python/apache_beam/yaml	1141	134	2023-01-24	2025-12-26	117	20	robertwb@gmail.com	derrickaw@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...
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...
StorageApiWriteUnshardedRecords.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	1114	33	2021-03-20	2025-12-22	122	37	relax@google.com	60600679+hekk-kaori-maeda@u...
StorageApiWritesShardedRecords.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	870	16	2021-03-20	2025-12-22	97	33	relax@google.com	60600679+hekk-kaori-maeda@u...
BigQueryIOTranslation.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	867	6	2023-10-23	2025-12-22	30	13	klk@google.com	33973061+claudevdm@users.no...
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...
MetadataTableDao.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/dao	523	28	2023-01-24	2025-12-22	21	9	nflavour@gmail.com	jackdingilian@google.com
DirectRunner.java in runners/direct-java/src/main/java/org/apache/beam/runners/direct	296	19	2016-06-14	2025-12-22	179	51	dhalperi@google.com	yathu@google.com
periodicsequence.py in sdks/python/apache_beam/transforms	269	13	2020-04-14	2025-12-22	24	19	12602502+ardagan@users.nore...	tvalentyn@users.noreply.git...
BigQueryStorageQuerySource.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	214	8	2019-03-13	2025-12-22	54	40	kmj@google.com	33973061+claudevdm@users.no...
BigQuerySourceBase.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	201	7	2017-03-17	2025-12-22	96	59	relax@google.com	clairem@spotify.com
BigQueryStorageSourceBase.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	195	5	2019-03-13	2025-12-22	66	41	kmj@google.com	33973061+claudevdm@users.no...
BigQueryStorageTableSource.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	189	9	2019-02-05	2025-12-22	61	43	kmj@google.com	33973061+claudevdm@users.no...
AppendFilesToTables.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	181	9	2024-04-22	2025-12-22	14	7	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
StorageApiConvertMessages.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	172	5	2021-05-26	2025-12-22	25	15	relax@google.com	60600679+hekk-kaori-maeda@u...
RecordWriter.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	146	5	2024-04-22	2025-12-22	19	7	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
BigQueryStorageApiInsertError.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	44	7	2022-04-20	2025-12-22	7	7	relax@google.com	60600679+hekk-kaori-maeda@u...
BigQueryStorageApiInsertErrorCoder.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery	38	3	2022-04-20	2025-12-22	7	7	relax@google.com	60600679+hekk-kaori-maeda@u...
PulsarMessage.java in sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar	38	2	2021-07-21	2025-12-22	11	9	marco.robles@marroble-macbo...	65791736+ahmedabu98@users.n...
StreamingModeExecutionContext.java in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker	791	66	2018-10-08	2025-12-19	118	62	36090911+boyuanzz@users.nor...	pandiana@google.com
CachingStateTable.java in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state	265	20	2023-10-11	2025-12-19	8	4	martinkt@google.com	pandiana@google.com
WindmillKeyedWorkItem.java in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker	189	15	2018-10-08	2025-12-19	37	25	36090911+boyuanzz@users.nor...	pandiana@google.com