apache / 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,108
Daily file updates (only one update per file and date counted): 42546
First update: 2014-07-11
Latest update: 2025-05-07
Days between first and latest update: 3,954 (564 weeks, estimated 2,820 working days)
Active days (at least one file change): 3,409
Data:

Organized per file

File Change History Overall

File Age Distribution Overall

Days since first update

There are 7,108 files with 774,010 lines of code in files.

6,780 files that are 366+ days old (748,780 lines of code)
162 files that are 181-365 days old (13,186 lines of code)
93 files that are 91-180 days old (5,724 lines of code)
52 files that are 31-90 days old (4,726 lines of code)
21 files that are 1-30 days old (1,594 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,108 files with 774,010 lines of code in files.

5,640 files have been last changed 366+ days ago (433,255 lines of code)
398 files have been last changed 181-365 days ago (70,895 lines of code)
664 files have been last changed 91-180 days ago (143,026 lines of code)
187 files have been last changed 31-90 days ago (46,270 lines of code)
219 files have been last changed 1-30 days ago (80,564 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, yaml, go, md, dart, txt, gradle, json, svg, ts, sh, tf, kt, sql, scss, html, ipynb, groovy, js, properties, xml, proto, tsx, sass, pxd, kts, mod, css, tfvars, avsc, pyx, bat, hcl, ini, toml, p8, gitignore, tpl, pb, ps1, gitattributes, thrift, cc, cfg, dockerfile, h, prettierignore, pyi, htaccess, in, g4, gitmodules, eslintignore, rs, 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
setup.py in sdks/python	440	11	2016-02-25	2025-04-23	617	189	silviuc@google.com	shunping@google.com
cfg setup.cfg in sdks/python	36	-	2016-02-25	2021-01-12	40	30	silviuc@google.com	elharo@users.noreply.github...
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	366	15	2016-03-02	2024-05-30	120	57	mxm@apache.org	robertwb@gmail.com
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	199	8	2016-03-02	2024-02-26	86	44	mxm@apache.org	je.ik@seznam.cz
FlinkPipelineRunner.java in runners/flink/src/main/java/org/apache/beam/runners/flink	163	6	2016-03-02	2025-01-24	84	42	mxm@apache.org	dannymccormick@google.com
SourceInputFormat.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers	134	9	2016-03-02	2024-02-26	53	31	mxm@apache.org	je.ik@seznam.cz
FlinkPipelineExecutionEnvironment.java in runners/flink/src/main/java/org/apache/beam/runners/flink	126	8	2016-03-02	2024-03-04	100	56	mxm@apache.org	bzablocki@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
FlinkReduceFunction.java in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions	71	4	2016-03-02	2024-02-26	43	24	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	2024-02-26	48	29	mxm@apache.org	je.ik@seznam.cz
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	2024-02-26	15	9	mxm@apache.org	je.ik@seznam.cz
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	595	45	2016-03-04	2024-01-19	177	58	swegner@google.com	svetaksundhar@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	751	29	2016-03-14	2025-04-30	232	84	ansela@paypal.com	72733442+twosom@users.norep...
StreamingTransformTranslator.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming	620	29	2016-03-14	2025-04-30	209	71	ansela@paypal.com	72733442+twosom@users.norep...
EvaluationContext.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	213	29	2016-03-14	2025-04-30	146	64	ansela@paypal.com	72733442+twosom@users.norep...
MultiDoFnFunction.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	200	7	2016-03-14	2025-04-30	134	65	ansela@paypal.com	72733442+twosom@users.norep...
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	373	33	2016-03-15	2024-10-23	128	62	owenzhang1990@gmail.com	xqhu@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	1522	67	2016-04-05	2024-03-04	148	67	swegner@google.com	bzablocki@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	129	3	2016-04-05	2024-01-19	112	47	swegner@google.com	svetaksundhar@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	2032	162	2016-04-07	2025-04-30	307	113	dhalperi@google.com	134544020+fozzie15@users.no...

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 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 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 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/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/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 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
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
AbstractModelEnforcement.java in runners/direct-java/src/main/java/org/apache/beam/runners/direct	13	3	2016-04-27	2017-05-18	13	5	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	1	-	2017-10-12	2018-04-10	3	2	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/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/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...
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 runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/testing	1	-	2018-04-19	2018-05-30	4	4	sidhom@google.com	kenn@kennknowles.com
package-info.java in runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact	1	-	2018-01-12	2018-05-30	7	7	tgroh@google.com	kenn@kennknowles.com
package-info.java in runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/wire	1	-	2018-04-24	2018-05-30	4	4	sidhom@google.com	kenn@kennknowles.com
package-info.java in runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state	1	-	2018-03-15	2018-05-30	5	5	axelmagn@gmail.com	kenn@kennknowles.com
doc.go in sdks/go/pkg/beam/core/funcx	1	-	2017-11-30	2018-05-30	7	6	herohde@google.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
doc.go in sdks/go/pkg/beam/core/runtime/graphx	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
doc.go in sdks/go/pkg/beam	1	-	2017-11-30	2018-05-30	11	9	herohde@google.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
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/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/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/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/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/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/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/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/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/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/example/model	1	-	2018-04-24	2018-05-30	5	4	kenn@kennknowles.com	kenn@kennknowles.com
NeedsDocker.java in runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/testing	2	-	2018-04-19	2018-05-30	4	4	sidhom@google.com	kenn@kennknowles.com

Most Recently Created Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
CreateStreamingSparkView.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming	99	6	2025-04-30	2025-04-30	1	1	72733442+twosom@users.norep...	72733442+twosom@users.norep...
PubsubMessageSchemaCoder.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub	46	1	2025-04-30	2025-04-30	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
SideInputMetadata.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	24	2	2025-04-30	2025-04-30	1	1	72733442+twosom@users.norep...	72733442+twosom@users.norep...
SideInputReaderFactory.java in runners/spark/src/main/java/org/apache/beam/runners/spark/util	15	1	2025-04-30	2025-04-30	1	1	72733442+twosom@users.norep...	72733442+twosom@users.norep...
gen_managed_doc.py in sdks/python	208	12	2025-04-29	2025-04-30	2	2	65791736+ahmedabu98@users.n...	chamikaramj@gmail.com
available_configs.yaml in sdks/java/managed/src/main/resources	16	-	2025-04-29	2025-04-29	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
config_aliases.yaml in sdks/java/managed/src/main/resources	3	-	2025-04-29	2025-04-29	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
set_pickler.py in sdks/python/apache_beam/internal	95	6	2025-04-25	2025-04-25	1	1	adrs@users.noreply.github.com	adrs@users.noreply.github.com
pyod_adapter.py in sdks/python/apache_beam/ml/anomaly/detectors	58	4	2025-04-23	2025-04-29	2	2	shunping@google.com	34928439+jrmccluskey@users....
ClickHouseRowsCheck.java in it/clickhouse/src/main/java/org/apache/beam/it/clickhouse/conditions	60	5	2025-04-22	2025-04-22	1	1	bentsi.leviav@clickhouse.com	bentsi.leviav@clickhouse.com
package-info.java in it/clickhouse/src/main/java/org/apache/beam/it/clickhouse/conditions	1	-	2025-04-22	2025-04-22	1	1	bentsi.leviav@clickhouse.com	bentsi.leviav@clickhouse.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
TFRecordWriteSchemaTransformProvider.java in sdks/java/core/src/main/java/org/apache/beam/sdk/io	184	10	2025-04-14	2025-04-14	1	1	derrickaw@google.com	derrickaw@google.com
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
TFRecordReadSchemaTransformConfiguration.java in sdks/java/core/src/main/java/org/apache/beam/sdk/io	57	1	2025-04-14	2025-04-14	1	1	derrickaw@google.com	derrickaw@google.com
TFRecordWriteSchemaTransformConfiguration.java in sdks/java/core/src/main/java/org/apache/beam/sdk/io	57	1	2025-04-14	2025-04-14	1	1	derrickaw@google.com	derrickaw@google.com
TFRecordSchemaTransformTranslation.java in sdks/java/core/src/main/java/org/apache/beam/sdk/io	55	4	2025-04-14	2025-04-14	1	1	derrickaw@google.com	derrickaw@google.com
YamlTransform.java in sdks/java/extensions/yaml/src/main/java/org/apache/beam/sdk/extensions/yaml	119	4	2025-04-11	2025-04-11	1	1	robertwb@gmail.com	robertwb@gmail.com
package-info.java in sdks/java/extensions/yaml/src/main/java/org/apache/beam/sdk/extensions/yaml	1	-	2025-04-11	2025-04-11	1	1	robertwb@gmail.com	robertwb@gmail.com
SqlQueryUtils.java in sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql	34	1	2025-04-10	2025-04-10	1	1	yathu@google.com	yathu@google.com
pipeline_utils.py in sdks/python/apache_beam/runners	175	9	2025-04-08	2025-04-09	2	1	robertwb@gmail.com	robertwb@gmail.com
GoogleAdsV19.java in sdks/java/io/google-ads/src/main/java/org/apache/beam/sdk/io/googleads	292	24	2025-04-02	2025-04-09	2	2	yathu@google.com	robertwb@gmail.com
cloudpickle.py in sdks/python/apache_beam/internal/cloudpickle	784	77	2025-04-01	2025-04-09	2	2	33973061+claudevdm@users.no...	robertwb@gmail.com
yaml_testing.py in sdks/python/apache_beam/yaml	420	22	2025-04-01	2025-04-10	6	1	robertwb@gmail.com	robertwb@gmail.com
__init__.py in sdks/python/apache_beam/internal/cloudpickle	15	-	2025-04-01	2025-04-09	2	2	33973061+claudevdm@users.no...	robertwb@gmail.com
cloudpickle_fast.py in sdks/python/apache_beam/internal/cloudpickle	3	1	2025-04-01	2025-04-09	2	2	33973061+claudevdm@users.no...	robertwb@gmail.com
IcebergCdcReadSchemaTransformProvider.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	152	7	2025-03-20	2025-03-20	1	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	144	3	2025-03-20	2025-03-20	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
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...
CreateReadTasksDoFn.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	77	3	2025-03-20	2025-03-20	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
IncrementalScanSource.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	67	1	2025-03-20	2025-03-20	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
ReadTask.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	63	5	2025-03-20	2025-03-20	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
ReadFromTasks.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	62	4	2025-03-20	2025-03-20	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
TableCache.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	60	5	2025-03-20	2025-03-20	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
ReadTaskDescriptor.java in sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg	32	2	2025-03-20	2025-03-20	1	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
KafkaIOUtilsBenchmark.java in sdks/java/io/kafka/jmh/src/main/java/org/apache/beam/sdk/io/kafka/jmh	181	25	2025-03-18	2025-03-18	1	1	sjvanrossum@google.com	sjvanrossum@google.com
offline.py in sdks/python/apache_beam/ml/anomaly/detectors	44	5	2025-03-18	2025-04-29	3	2	shunping@google.com	34928439+jrmccluskey@users....
build.gradle.kts in sdks/java/io/kafka/jmh	14	-	2025-03-18	2025-03-18	1	1	sjvanrossum@google.com	sjvanrossum@google.com
package-info.java in sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/providers	1	-	2025-03-18	2025-03-19	2	2	prodriguezdefino@gmail.com	chamikaramj@gmail.com
package-info.java in sdks/java/io/kafka/jmh/src/main/java/org/apache/beam/sdk/io/kafka/jmh	1	-	2025-03-18	2025-03-18	1	1	sjvanrossum@google.com	sjvanrossum@google.com
SqsReadSchemaTransformProvider.java in sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/providers	87	6	2025-03-17	2025-03-19	3	2	prodriguezdefino@gmail.com	chamikaramj@gmail.com
SqsReadConfiguration.java in sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/providers	30	2	2025-03-17	2025-03-19	3	2	prodriguezdefino@gmail.com	chamikaramj@gmail.com
transforms.py in sdks/python/apache_beam/ml/anomaly	319	25	2025-03-11	2025-04-29	8	2	shunping@google.com	34928439+jrmccluskey@users....
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
iqr.py in sdks/python/apache_beam/ml/anomaly/detectors	55	3	2025-03-10	2025-03-10	1	1	shunping@google.com	shunping@google.com
zscore.py in sdks/python/apache_beam/ml/anomaly/detectors	47	3	2025-03-10	2025-03-10	1	1	shunping@google.com	shunping@google.com
robust_zscore.py in sdks/python/apache_beam/ml/anomaly/detectors	38	3	2025-03-10	2025-03-10	1	1	shunping@google.com	shunping@google.com
ClickHouseUtils.java in it/clickhouse/src/main/java/org/apache/beam/it/clickhouse	24	2	2025-03-10	2025-03-10	1	1	bentsi.leviav@clickhouse.com	bentsi.leviav@clickhouse.com
mad.py in sdks/python/apache_beam/ml/anomaly/univariate	20	4	2025-03-10	2025-03-10	1	1	shunping@google.com	shunping@google.com
median.py in sdks/python/apache_beam/ml/anomaly/univariate	17	3	2025-03-10	2025-03-10	1	1	shunping@google.com	shunping@google.com

Most Recently Changed Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
findPrsNeedingAttention.ts in scripts/ci/pr-bot	190	6	2022-03-10	2025-05-07	9	7	dannymccormick@google.com	vitaly.terentyev.akv@gmail.com
FnApiDoFnRunner.java in sdks/java/harness/src/main/java/org/apache/beam/fn/harness	3120	182	2017-06-05	2025-05-06	237	83	tgroh@google.com	kenn@apache.org
ProcessBundleHandler.java in sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control	1043	38	2017-01-19	2025-05-06	225	83	lcwik@google.com	kenn@apache.org
BeamFnDataReadRunner.java in sdks/java/harness/src/main/java/org/apache/beam/fn/harness	268	14	2017-06-05	2025-05-06	124	53	tgroh@google.com	kenn@apache.org
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
CombineRunners.java in sdks/java/harness/src/main/java/org/apache/beam/fn/harness	203	6	2018-06-12	2025-05-06	82	46	daniel.o.programmer@gmail.com	kenn@apache.org
SpannerSchema.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner	192	15	2017-10-18	2025-05-06	67	41	mairbek@google.com	nielm@users.noreply.github.com
LazyAggregateCombineFn.java in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl	123	14	2021-04-20	2025-05-06	13	5	kcweaver@google.com	yathu@google.com
MapFnRunners.java in sdks/java/harness/src/main/java/org/apache/beam/fn/harness	86	10	2018-05-10	2025-05-06	64	44	tgroh@google.com	kenn@apache.org
PTransformRunnerFactory.java in sdks/java/harness/src/main/java/org/apache/beam/fn/harness	63	1	2017-07-07	2025-05-06	73	40	lcwik@google.com	kenn@apache.org
BeamFnDataWriteRunner.java in sdks/java/harness/src/main/java/org/apache/beam/fn/harness	60	3	2017-06-05	2025-05-06	112	54	tgroh@google.com	kenn@apache.org
FlattenRunner.java in sdks/java/harness/src/main/java/org/apache/beam/fn/harness	31	3	2017-12-23	2025-05-06	73	42	daniel.o.programmer@gmail.com	kenn@apache.org
coders.py in sdks/python/apache_beam/coders	1028	309	2016-06-14	2025-05-05	255	105	davor@google.com	33973061+claudevdm@users.no...
coders_test_common.py in sdks/python/apache_beam/coders	622	52	2016-06-14	2025-05-05	155	78	davor@google.com	33973061+claudevdm@users.no...
gcsio.py in sdks/python/apache_beam/io/gcp	433	34	2017-02-22	2025-05-05	182	77	sourabhbajaj@google.com	huxiangqian@gmail.com
KafkaReadSchemaTransformProvider.java in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka	308	14	2022-12-05	2025-05-05	36	15	pabloem@users.noreply.githu...	134544020+fozzie15@users.no...
typecoders.py in sdks/python/apache_beam/coders	108	10	2016-06-14	2025-05-05	92	60	davor@google.com	33973061+claudevdm@users.no...
Environments.java in sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction	504	27	2023-10-23	2025-05-04	7	8	klk@google.com	huxiangqian@gmail.com
coders.go in sdks/go/pkg/beam/runners/prism/internal	273	10	2023-02-15	2025-05-04	24	7	lostluck@users.noreply.gith...	shunping@google.com
gcsio_retry.py in sdks/python/apache_beam/io/gcp	56	3	2024-09-18	2025-05-02	2	2	shunping@google.com	70029317+akashorabek@users....
bigquery_file_loads.py in sdks/python/apache_beam/io/gcp	934	47	2019-02-17	2025-05-01	118	55	pabloem@users.noreply.githu...	33973061+claudevdm@users.no...
trivial_inference.py in sdks/python/apache_beam/typehints	508	28	2016-06-14	2025-05-01	84	55	davor@google.com	34928439+jrmccluskey@users....
ManagedSchemaTransformProvider.java in sdks/java/managed/src/main/java/org/apache/beam/sdk/managed	210	11	2024-04-08	2025-05-01	13	4	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
Managed.java in sdks/java/managed/src/main/java/org/apache/beam/sdk/managed	122	7	2024-04-08	2025-05-01	17	6	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
managed.py in sdks/python/apache_beam/transforms	95	7	2024-10-15	2025-05-01	12	7	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
TestSchemaTransformProvider.java in sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/testing	73	3	2024-04-22	2025-05-01	3	1	65791736+ahmedabu98@users.n...	65791736+ahmedabu98@users.n...
DataflowRunner.java in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow	2216	85	2016-05-10	2025-04-30	493	144	klk@google.com	65791736+ahmedabu98@users.n...
KafkaIO.java in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka	2032	162	2016-04-07	2025-04-30	307	113	dhalperi@google.com	134544020+fozzie15@users.no...
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-04-30	151	80	dhalperi@google.com	65791736+ahmedabu98@users.n...
yaml_provider.py in sdks/python/apache_beam/yaml	1047	132	2023-01-24	2025-04-30	106	16	robertwb@gmail.com	chamikaramj@gmail.com
StreamingDataflowWorker.java in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker	867	28	2018-10-08	2025-04-30	238	97	36090911+boyuanzz@users.nor...	pandiana@google.com
external.py in sdks/python/apache_beam/transforms	839	66	2018-12-03	2025-04-30	161	59	robertwb@gmail.com	chamikaramj@gmail.com
TransformTranslator.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	751	29	2016-03-14	2025-04-30	232	84	ansela@paypal.com	72733442+twosom@users.norep...
StreamingTransformTranslator.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming	620	29	2016-03-14	2025-04-30	209	71	ansela@paypal.com	72733442+twosom@users.norep...
ReadFromKafkaDoFn.java in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka	585	17	2020-05-18	2025-04-30	78	37	boyuanz@google.com	sjvanrossum@google.com
Row.java in sdks/java/core/src/main/java/org/apache/beam/sdk/values	585	49	2018-02-07	2025-04-30	135	66	kenn@kennknowles.com	65791736+ahmedabu98@users.n...
KafkaIOTranslation.java in sdks/java/io/kafka/upgrade/src/main/java/org/apache/beam/sdk/io/kafka/upgrade	575	7	2023-10-23	2025-04-30	23	11	klk@google.com	134544020+fozzie15@users.no...
PubsubUnboundedSink.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub	539	19	2017-04-12	2025-04-30	79	50	dhalperi@google.com	65791736+ahmedabu98@users.n...
PubsubTestClient.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub	523	34	2017-04-12	2025-04-30	65	47	dhalperi@google.com	65791736+ahmedabu98@users.n...
PubsubJsonClient.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub	332	24	2017-04-12	2025-04-30	86	63	dhalperi@google.com	65791736+ahmedabu98@users.n...
standard_io.yaml in sdks/python/apache_beam/yaml	317	-	2023-08-25	2025-04-30	51	14	robertwb@gmail.com	chamikaramj@gmail.com
BoundedQueueExecutor.java in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util	218	17	2018-10-08	2025-04-30	49	30	36090911+boyuanzz@users.nor...	pandiana@google.com
EvaluationContext.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	213	29	2016-03-14	2025-04-30	146	64	ansela@paypal.com	72733442+twosom@users.norep...
KafkaUnboundedSource.java in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka	211	7	2018-02-02	2025-04-30	46	32	rangadi@google.com	134544020+fozzie15@users.no...
gen_managed_doc.py in sdks/python	208	12	2025-04-29	2025-04-30	2	2	65791736+ahmedabu98@users.n...	chamikaramj@gmail.com
ParDoStateUpdateFn.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming	205	3	2024-12-18	2025-04-30	2	1	72733442+twosom@users.norep...	72733442+twosom@users.norep...
MultiDoFnFunction.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation	200	7	2016-03-14	2025-04-30	134	65	ansela@paypal.com	72733442+twosom@users.norep...
PreparePubsubWriteDoFn.java in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub	190	2	2023-04-22	2025-04-30	10	8	relax@google.com	65791736+ahmedabu98@users.n...
KafkaIOReadImplementationCompatibility.java in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka	188	18	2022-04-18	2025-04-30	23	16	nbali@users.noreply.github.com	134544020+fozzie15@users.no...
StatefulStreamingParDoEvaluator.java in runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming	177	3	2024-12-18	2025-04-30	2	1	72733442+twosom@users.norep...	72733442+twosom@users.norep...