spotify / 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
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 4,769 files with 497,850 lines of code in files.
    • 4,769 files that are 366+ days old (497,850 lines of code)
    • 0 files that are 181-365 days old (0 lines of code)
    • 0 files that are 91-180 days old (0 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)
100% | 0% | 0% | 0% | 0%
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 4,769 files with 497,850 lines of code in files.
    • 4,769 files have been last changed 366+ days ago (497,850 lines of code)
    • 0 files have been last changed 181-365 days ago (0 lines of code)
    • 0 files have been last changed 91-180 days ago (0 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)
100% | 0% | 0% | 0% | 0%
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, gradle, groovy, svg, kt, sql, scss, sh, html, json, js, properties, txt, xml, proto, ipynb, tsx, pxd, sass, ts, css, kts, ini, pyx, bat, avsc, p8, gitattributes, thrift, cc, cfg, h, mod, htaccess, in, g4, gitmodules, eslintignore, ftl, gitignore, toml, pb, rdf, prettierignore
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
go100% | 0% | 0% | 0% | 0%
scss100% | 0% | 0% | 0% | 0%
yaml100% | 0% | 0% | 0% | 0%
proto100% | 0% | 0% | 0% | 0%
sql100% | 0% | 0% | 0% | 0%
html100% | 0% | 0% | 0% | 0%
groovy100% | 0% | 0% | 0% | 0%
js100% | 0% | 0% | 0% | 0%
kt100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
pxd100% | 0% | 0% | 0% | 0%
tsx100% | 0% | 0% | 0% | 0%
kts100% | 0% | 0% | 0% | 0%
sass100% | 0% | 0% | 0% | 0%
ts100% | 0% | 0% | 0% | 0%
pyx100% | 0% | 0% | 0% | 0%
ftl100% | 0% | 0% | 0% | 0%
toml100% | 0% | 0% | 0% | 0%
css100% | 0% | 0% | 0% | 0%
h100% | 0% | 0% | 0% | 0%
cfg100% | 0% | 0% | 0% | 0%
rdf100% | 0% | 0% | 0% | 0%
in100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
go100% | 0% | 0% | 0% | 0%
scss100% | 0% | 0% | 0% | 0%
yaml100% | 0% | 0% | 0% | 0%
proto100% | 0% | 0% | 0% | 0%
sql100% | 0% | 0% | 0% | 0%
html100% | 0% | 0% | 0% | 0%
groovy100% | 0% | 0% | 0% | 0%
js100% | 0% | 0% | 0% | 0%
kt100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
pxd100% | 0% | 0% | 0% | 0%
tsx100% | 0% | 0% | 0% | 0%
kts100% | 0% | 0% | 0% | 0%
sass100% | 0% | 0% | 0% | 0%
ts100% | 0% | 0% | 0% | 0%
pyx100% | 0% | 0% | 0% | 0%
ftl100% | 0% | 0% | 0% | 0%
toml100% | 0% | 0% | 0% | 0%
css100% | 0% | 0% | 0% | 0%
h100% | 0% | 0% | 0% | 0%
cfg100% | 0% | 0% | 0% | 0%
rdf100% | 0% | 0% | 0% | 0%
in100% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
sdks100% | 0% | 0% | 0% | 0%
runners100% | 0% | 0% | 0% | 0%
website100% | 0% | 0% | 0% | 0%
learning100% | 0% | 0% | 0% | 0%
model100% | 0% | 0% | 0% | 0%
buildSrc100% | 0% | 0% | 0% | 0%
release100% | 0% | 0% | 0% | 0%
ownership100% | 0% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
sdks100% | 0% | 0% | 0% | 0%
runners100% | 0% | 0% | 0% | 0%
website100% | 0% | 0% | 0% | 0%
learning100% | 0% | 0% | 0% | 0%
model100% | 0% | 0% | 0% | 0%
buildSrc100% | 0% | 0% | 0% | 0%
release100% | 0% | 0% | 0% | 0%
ownership100% | 0% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
setup.py
in sdks/python
246 6 2016-02-25 2021-05-01 365 122 silviuc@google.com baetensmatthias@gmail.com
cfg
setup.cfg
in sdks/python
36 - 2016-02-25 2021-01-12 38 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
1324 92 2016-03-02 2021-03-11 89 51 mxm@apache.org sruthiskumar92@gmail.com
UnboundedSourceWrapper.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io
368 15 2016-03-02 2021-03-11 94 46 mxm@apache.org sruthiskumar92@gmail.com
FlinkDoFnFunction.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions
199 8 2016-03-02 2021-04-15 71 36 mxm@apache.org xinyuliu.us@gmail.com
FlinkPipelineOptions.java
in runners/flink/src/main/java/org/apache/beam/runners/flink
187 1 2016-03-02 2021-04-05 84 43 mxm@apache.org iemejia@gmail.com
FlinkPipelineRunner.java
in runners/flink/src/main/java/org/apache/beam/runners/flink
181 6 2016-03-02 2021-04-08 56 33 mxm@apache.org iemejia@gmail.com
CoderTypeSerializer.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types
133 19 2016-03-02 2021-04-08 22 13 mxm@apache.org iemejia@gmail.com
SourceInputFormat.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers
117 8 2016-03-02 2021-03-11 37 23 mxm@apache.org sruthiskumar92@gmail.com
CoderTypeInformation.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types
87 15 2016-03-02 2021-03-11 29 20 mxm@apache.org sruthiskumar92@gmail.com
FlinkPipelineExecutionEnvironment.java
in runners/flink/src/main/java/org/apache/beam/runners/flink
81 6 2016-03-02 2021-04-19 72 43 mxm@apache.org elharo@google.com
FlinkReduceFunction.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions
71 4 2016-03-02 2021-03-15 37 23 mxm@apache.org mackenzieclark@google.com
FlinkPartialReduceFunction.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions
71 4 2016-03-02 2021-03-15 37 23 mxm@apache.org mackenzieclark@google.com
FlinkRunnerResult.java
in runners/flink/src/main/java/org/apache/beam/runners/flink
50 7 2016-03-02 2021-03-11 37 27 mxm@apache.org sruthiskumar92@gmail.com
FlinkMultiOutputPruningFunction.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions
34 3 2016-03-02 2019-10-18 10 7 mxm@apache.org mzobii.baig@gmail.com
DataInputViewWrapper.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers
23 3 2016-03-02 2019-07-01 13 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 2021-03-11 14 11 mxm@apache.org sruthiskumar92@gmail.com
DataOutputViewWrapper.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers
18 3 2016-03-02 2019-07-01 11 7 mxm@apache.org dcrhodes@google.com
DoFnTester.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
575 43 2016-03-04 2021-04-15 161 52 swegner@google.com xinyuliu.us@gmail.com
ParDo.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
531 33 2016-03-04 2021-03-11 176 59 swegner@google.com sruthiskumar92@gmail.com
SparkPipelineRunner.java
in runners/spark/src/main/java/org/apache/beam/runners/spark
227 4 2016-03-11 2021-04-22 84 41 ansela@paypal.com kcweaver@google.com
CreateStream.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/io
124 14 2016-03-11 2021-03-11 54 30 ansela@paypal.com sruthiskumar92@gmail.com
CoderHelpers.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/coders
121 9 2016-03-11 2021-03-11 51 38 ansela@paypal.com sruthiskumar92@gmail.com
SparkPipelineOptions.java
in runners/spark/src/main/java/org/apache/beam/runners/spark
56 - 2016-03-11 2021-04-03 101 47 ansela@paypal.com iemejia@gmail.com
NamedAggregators.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators
49 6 2016-03-11 2021-03-11 50 32 ansela@paypal.com sruthiskumar92@gmail.com
ConsoleIO.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/io
31 6 2016-03-11 2018-11-20 26 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 2021-01-12 17 14 ansela@paypal.com elharo@users.noreply.github...
ApiSurface.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/util
522 46 2016-03-12 2021-03-11 57 32 klk@google.com sruthiskumar92@gmail.com
TransformTranslator.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/translation
669 28 2016-03-14 2021-03-11 192 67 ansela@paypal.com sruthiskumar92@gmail.com
StreamingTransformTranslator.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming
525 25 2016-03-14 2021-03-11 173 59 ansela@paypal.com sruthiskumar92@gmail.com
MultiDoFnFunction.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/translation
199 7 2016-03-14 2021-04-15 113 54 ansela@paypal.com xinyuliu.us@gmail.com
EvaluationContext.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/translation
181 23 2016-03-14 2021-03-11 123 54 ansela@paypal.com sruthiskumar92@gmail.com
SparkProcessContext.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/translation
125 8 2016-03-14 2021-01-12 98 45 ansela@paypal.com elharo@users.noreply.github...
SparkContextFactory.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/translation
66 4 2016-03-14 2021-03-11 61 35 ansela@paypal.com sruthiskumar92@gmail.com
SparkPipelineTranslator.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/translation
9 - 2016-03-14 2018-11-20 15 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 17 17 ansela@paypal.com millsd@google.com
TestPipeline.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/testing
370 34 2016-03-15 2021-03-11 102 46 owenzhang1990@gmail.com sruthiskumar92@gmail.com
StarterPipeline.java
in sdks/java/maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java
32 1 2016-03-24 2021-01-12 22 15 peihe0@gmail.com elharo@users.noreply.github...
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...
AfterWatermark.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing
110 20 2016-03-31 2021-03-11 62 36 tgroh@google.com sruthiskumar92@gmail.com
IdentityWindowFn.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/util
63 7 2016-03-31 2021-04-14 38 18 tgroh@google.com kenn@apache.org
TestPipelineOptions.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/testing
49 3 2016-03-31 2021-03-11 36 24 jason@google.com sruthiskumar92@gmail.com
Never.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing
26 4 2016-03-31 2021-03-11 34 18 tgroh@google.com sruthiskumar92@gmail.com
PipelineOptionsFactory.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/options
1322 60 2016-04-05 2021-03-11 115 51 swegner@google.com sruthiskumar92@gmail.com
ProxyInvocationHandler.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/options
528 24 2016-04-05 2021-03-11 86 41 swegner@google.com sruthiskumar92@gmail.com
DisplayData.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/display
506 59 2016-04-05 2021-03-11 88 36 swegner@google.com sruthiskumar92@gmail.com
PipelineOptions.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/options
128 3 2016-04-05 2019-11-20 95 36 swegner@google.com rehman.muradali@venturedive...
BucketingFunction.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/util
78 10 2016-04-05 2019-08-07 22 19 markshields@google.com lukecwik@gmail.com
MovingFunction.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/util
69 5 2016-04-05 2019-08-07 32 25 markshields@google.com lukecwik@gmail.com
PipelineOptionsReflector.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/options
57 4 2016-04-05 2019-08-07 16 12 swegner@google.com lukecwik@gmail.com
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
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/spark/src/main/java/org/apache/beam/runners/spark/aggregators
1 - 2016-07-19 2016-08-25 4 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 4 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 4 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 4 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 4 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 6 5 bchambers@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-26 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
pxd
counters.pxd
in sdks/python/apache_beam/utils
8 - 2016-06-14 2017-03-17 7 6 silviuc@google.com klk@google.com
37 2 2017-03-14 2017-04-21 4 4 tibor.kiss@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-25 2017-05-04 4 3 lcwik@google.com klk@google.com
ValueState.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/state
9 - 2017-05-02 2017-05-18 5 2 klk@google.com owenzhang1990@gmail.com
WatermarkHoldState.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/state
10 - 2017-05-02 2017-05-18 5 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-28 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
in
MANIFEST.in
in sdks/python
20 - 2016-08-15 2017-06-05 14 9 dhalperi@google.com owenzhang1990@gmail.com
__init__.py
in sdks/python/apache_beam/portability/api
1 - 2017-06-14 2017-06-17 2 3 robertwb@gmail.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-05 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-05 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
ReadableFileCoder.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/io
26 2 2017-09-01 2017-09-04 2 2 kirpichov@google.com ekirpichov@gmail.com
exec.go
in sdks/go/pkg/beam/util/execx
12 1 2017-10-01 2017-10-12 3 3 herohde@google.com rezarokni@google.com
main.go
in sdks/go/cmd/beamctl
12 1 2017-10-01 2017-10-12 3 4 herohde@google.com rezarokni@google.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
guarded.go
in sdks/go/pkg/beam/util/errorx
20 2 2017-10-01 2017-10-12 3 3 herohde@google.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/control
1 - 2017-11-07 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-07 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-13 2018-04-10 7 7 tgroh@google.com 7542791+rezarokni@users.nor...
BagState.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/state
12 - 2017-05-02 2018-04-10 7 4 klk@google.com 7542791+rezarokni@users.nor...
CombiningState.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/state
16 - 2017-05-02 2018-04-10 7 4 klk@google.com 7542791+rezarokni@users.nor...
syscall_linux.go
in sdks/go/pkg/beam/util/syscallx
16 2 2017-10-23 2018-04-10 3 3 herohde@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/artifact
1 - 2018-01-13 2018-05-30 5 7 tgroh@google.com xiliu@linkedin.com
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 3 4 sidhom@google.com xiliu@linkedin.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 4 5 axelmagn@gmail.com xiliu@linkedin.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 3 4 sidhom@google.com xiliu@linkedin.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 5 5 xumingmingv@gmail.com xiliu@linkedin.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 7 7 xumingmingv@gmail.com xiliu@linkedin.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 7 7 xumingmingv@gmail.com xiliu@linkedin.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 7 7 xumingmingv@gmail.com xiliu@linkedin.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 7 7 xumingmingv@gmail.com xiliu@linkedin.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 11 9 xumingmingv@gmail.com xiliu@linkedin.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 6 4 apilloud@google.com xiliu@linkedin.com
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
recommendations_ai.py
in sdks/python/apache_beam/ml/gcp
359 28 2021-05-01 2021-05-01 1 1 baetensmatthias@gmail.com baetensmatthias@gmail.com
recommendations_ai_test_it.py
in sdks/python/apache_beam/ml/gcp
63 6 2021-05-01 2021-05-01 1 1 baetensmatthias@gmail.com baetensmatthias@gmail.com
MultiOutputCoder.java
in runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers
55 3 2021-04-25 2021-04-26 2 2 iemejia@gmail.com 33895511+aromanenko-dev@use...
RowCoderCloudObjectTranslator.java
in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util
52 4 2021-04-24 2021-04-29 2 1 relax@google.com relax@google.com
payload.go
in sdks/go/pkg/beam/core/runtime/xlangx
38 1 2021-04-24 2021-04-30 2 1 daniel.o.programmer@gmail.com daniel.o.programmer@gmail.com
resources.py
in sdks/python/apache_beam/transforms
137 14 2021-04-21 2021-04-22 2 1 tvalentyn@users.noreply.git... tvalentyn@users.noreply.git...
SamzaJobInvoker.java
in runners/samza/src/main/java/org/apache/beam/runners/samza
53 3 2021-04-21 2021-04-21 1 1 kwu@linkedin.com kwu@linkedin.com
SamzaExecutableStageContextFactory.java
in runners/samza/src/main/java/org/apache/beam/runners/samza/runtime
28 3 2021-04-21 2021-04-21 1 1 kwu@linkedin.com kwu@linkedin.com
query14b.sql
in sdks/java/testing/tpcds/src/main/resources/queries
94 - 2021-04-20 2021-04-21 2 2 aromanenko.dev@gmail.com 33895511+aromanenko-dev@use...
query14a.sql
in sdks/java/testing/tpcds/src/main/resources/queries
78 - 2021-04-20 2021-04-21 2 2 aromanenko.dev@gmail.com 33895511+aromanenko-dev@use...
LazyAggregateCombineFn.java
in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl
69 8 2021-04-20 2021-04-30 3 1 kcweaver@google.com kcweaver@google.com
query23b.sql
in sdks/java/testing/tpcds/src/main/resources/queries
55 - 2021-04-20 2021-04-28 3 3 aromanenko.dev@gmail.com aromanenko.dev@gmail.com
query23a.sql
in sdks/java/testing/tpcds/src/main/resources/queries
49 - 2021-04-20 2021-04-28 3 3 aromanenko.dev@gmail.com aromanenko.dev@gmail.com
query39b.sql
in sdks/java/testing/tpcds/src/main/resources/queries
25 - 2021-04-20 2021-04-21 2 2 aromanenko.dev@gmail.com 33895511+aromanenko-dev@use...
query39a.sql
in sdks/java/testing/tpcds/src/main/resources/queries
24 - 2021-04-20 2021-04-21 2 2 aromanenko.dev@gmail.com 33895511+aromanenko-dev@use...
ResourceHintsOptions.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints
21 - 2021-04-20 2021-04-28 3 3 robertwb@gmail.com tvalentyn@users.noreply.git...
query24a.sql
in sdks/java/testing/tpcds/src/main/resources/queries
19 - 2021-04-20 2021-04-21 2 2 aromanenko.dev@gmail.com 33895511+aromanenko-dev@use...
query24b.sql
in sdks/java/testing/tpcds/src/main/resources/queries
19 - 2021-04-20 2021-04-21 2 2 aromanenko.dev@gmail.com 33895511+aromanenko-dev@use...
ResourceHints.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints
219 22 2021-04-16 2021-04-28 5 3 robertwb@gmail.com tvalentyn@users.noreply.git...
MetricsLogger.java
in runners/core-java/src/main/java/org/apache/beam/runners/core/metrics
60 5 2021-04-16 2021-04-19 3 3 iemejia@gmail.com elharo@google.com
ResourceHint.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints
12 1 2021-04-16 2021-04-28 4 3 robertwb@gmail.com tvalentyn@users.noreply.git...
package-info.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints
1 - 2021-04-16 2021-04-28 2 2 robertwb@gmail.com tvalentyn@users.noreply.git...
BeamCalcSplittingRule.java
in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule
43 3 2021-04-15 2021-04-21 3 1 kcweaver@google.com kcweaver@google.com
BeamZetaSqlCalcSplittingRule.java
in sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql
16 1 2021-04-15 2021-04-21 2 1 kcweaver@google.com kcweaver@google.com
CalcRelSplitter.java
in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel
571 27 2021-04-14 2021-04-21 3 1 kcweaver@google.com kcweaver@google.com
ShortIdMap.java
in runners/core-java/src/main/java/org/apache/beam/runners/core/metrics
26 2 2021-04-14 2021-04-14 1 1 robertwb@google.com robertwb@google.com
MemoryMonitor.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status
401 22 2021-04-13 2021-04-13 1 1 kileysok@google.com kileysok@google.com
BeamFnStatusClient.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status
186 13 2021-04-13 2021-04-13 1 1 kileysok@google.com kileysok@google.com
BeamCalcRelType.java
in sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql
120 6 2021-04-13 2021-04-21 4 1 kcweaver@google.com kcweaver@google.com
BeamZetaSqlRelType.java
in sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql
60 5 2021-04-13 2021-04-21 3 1 kcweaver@google.com kcweaver@google.com
package-info.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status
1 - 2021-04-13 2021-04-13 1 1 kileysok@google.com kileysok@google.com
stringSlice.go
in sdks/go/pkg/beam/options/jobopts
15 3 2021-04-06 2021-04-21 3 2 daniel.o.programmer@gmail.com daniel.o.programmer@gmail.com
Query13.java
in sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries
76 3 2021-04-05 2021-04-05 1 1 amaliujia@163.com amaliujia@163.com
FileStagingOptions.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/options
11 - 2021-04-03 2021-04-05 2 1 iemejia@gmail.com iemejia@gmail.com
SparkCommon.java
in runners/spark/src/main/java/org/apache/beam/runners/spark/util
51 - 2021-04-02 2021-04-02 1 1 iemejia@gmail.com iemejia@gmail.com
PubSubPayloadTranslation.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub
126 2 2021-03-31 2021-04-09 2 2 boyuanz@google.com 36090911+boyuanzz@users.nor...
ZetaSqlException.java
in sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql
11 2 2021-03-31 2021-04-01 2 1 kcweaver@google.com kcweaver@google.com
trigger_manager.py
in sdks/python/apache_beam/runners/portability/fn_api_runner
352 29 2021-03-30 2021-03-30 1 1 pabloem@users.noreply.githu... pabloem@users.noreply.githu...
package-info.java
in sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds
1 - 2021-03-30 2021-04-13 2 2 aromanenko.dev@gmail.com iemejia@gmail.com
StorageApiWritesShardedRecords.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
420 11 2021-03-20 2021-04-19 5 2 relax@google.com elharo@google.com
StorageApiWriteUnshardedRecords.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
262 16 2021-03-20 2021-04-19 6 4 relax@google.com elharo@google.com
RetryManager.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
225 21 2021-03-20 2021-03-24 2 1 relax@google.com relax@google.com
StorageApiFlushAndFinalizeDoFn.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
163 7 2021-03-20 2021-03-24 2 1 relax@google.com relax@google.com
StorageApiFinalizeWritesDoFn.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
139 5 2021-03-20 2021-03-24 2 1 relax@google.com relax@google.com
StorageApiLoads.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
120 5 2021-03-20 2021-03-24 2 1 relax@google.com relax@google.com
StorageApiDynamicDestinations.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
48 4 2021-03-20 2021-03-24 2 1 relax@google.com relax@google.com
StorageApiDynamicDestinationsTableRow.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
46 1 2021-03-20 2021-03-24 2 1 relax@google.com relax@google.com
StorageApiDynamicDestinationsBeamRow.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
41 1 2021-03-20 2021-03-24 2 1 relax@google.com relax@google.com
TwoLevelMessageConverterCache.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
30 1 2021-03-20 2021-03-24 2 1 relax@google.com relax@google.com
BeamZetaSqlCalcMergeRule.java
in sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql
19 2 2021-03-18 2021-03-19 2 1 kcweaver@google.com kcweaver@google.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
Combine.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
1332 158 2016-04-11 2021-05-03 165 53 swegner@google.com kenn@apache.org
PCollectionViews.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/values
996 80 2017-05-04 2021-05-03 54 29 klk@google.com kenn@apache.org
IsmSideInputReader.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker
772 47 2018-10-08 2021-05-03 32 24 36090911+boyuanzz@users.nor... kenn@apache.org
View.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
361 28 2016-04-13 2021-05-03 98 45 bchambers@google.com kenn@apache.org
UnboundedEventSource.java
in sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources
239 20 2018-10-15 2021-05-03 14 11 lukasz.gajowy@gmail.com samuelw@google.com
pipeline.py
in sdks/python/apache_beam
803 56 2016-06-14 2021-05-01 229 85 silviuc@google.com chamikara@apache.org
recommendations_ai.py
in sdks/python/apache_beam/ml/gcp
359 28 2021-05-01 2021-05-01 1 1 baetensmatthias@gmail.com baetensmatthias@gmail.com
external.py
in sdks/python/apache_beam/transforms
349 35 2018-12-03 2021-05-01 74 32 robertwb@gmail.com chamikara@apache.org
setup.py
in sdks/python
246 6 2016-02-25 2021-05-01 365 122 silviuc@google.com baetensmatthias@gmail.com
recommendations_ai_test_it.py
in sdks/python/apache_beam/ml/gcp
63 6 2021-05-01 2021-05-01 1 1 baetensmatthias@gmail.com baetensmatthias@gmail.com
frames.py
in sdks/python/apache_beam/dataframe
2272 115 2020-02-03 2021-04-30 84 15 robertwb@gmail.com 61989986+roger-mike@users.n...
JdbcIO.java
in sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc
1016 102 2016-09-05 2021-04-30 146 66 jbonofre@apache.org 2bnp4gukr5@snkmail.com
ParquetIO.java
in sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet
898 82 2016-10-03 2021-04-30 63 37 jbonofre@apache.org 49611069+ernvalentino@users...
xlang.go
in sdks/go/pkg/beam
88 9 2020-08-18 2021-04-30 14 10 25983646+pskevin@users.nore... daniel.o.programmer@gmail.com
LazyAggregateCombineFn.java
in sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl
69 8 2021-04-20 2021-04-30 3 1 kcweaver@google.com kcweaver@google.com
payload.go
in sdks/go/pkg/beam/core/runtime/xlangx
38 1 2021-04-24 2021-04-30 2 1 daniel.o.programmer@gmail.com daniel.o.programmer@gmail.com
dataflow_v1b3_messages.py
in sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow
2067 - 2017-02-23 2021-04-29 47 36 altay@google.com tvalentyn@users.noreply.git...
BeamModulePlugin.groovy
in buildSrc/src/main/groovy/org/apache/beam/gradle
1680 3 2018-06-19 2021-04-29 502 153 kenn@apache.org heejong@gmail.com
schema.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
1614 170 2020-06-23 2021-04-29 8 6 lostluck@users.noreply.gith... lostluck@users.noreply.gith...
proto
beam_runner_api.proto
in model/pipeline/src/main/proto
1567 - 2017-09-29 2021-04-29 182 71 klk@google.com heejong@gmail.com
v1.pb.go
in sdks/go/pkg/beam/core/runtime/graphx/v1
1503 140 2017-11-30 2021-04-29 14 10 herohde@google.com lostluck@users.noreply.gith...
dataflow_runner.py
in sdks/python/apache_beam/runners/dataflow
1152 57 2017-02-16 2021-04-29 296 93 pabloem@google.com tvalentyn@users.noreply.git...
metrics.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
1119 63 2019-05-03 2021-04-29 28 21 robert@frantil.com lostluck@users.noreply.gith...
dataflow_v1b3_client.py
in sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow
1016 71 2017-02-23 2021-04-29 32 29 altay@google.com tvalentyn@users.noreply.git...
Schema.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/schemas
984 124 2018-03-17 2021-04-29 111 50 relax@relax-macbookpro2.roa... relax@google.com
apiclient.py
in sdks/python/apache_beam/runners/dataflow/internal
918 51 2017-02-16 2021-04-29 219 91 pabloem@google.com heejong@gmail.com
schema.go
in sdks/go/pkg/beam/core/runtime/graphx/schema
610 28 2020-08-05 2021-04-29 14 8 13907733+lostluck@users.nor... daniel.o.programmer@gmail.com
Row.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/values
529 41 2018-02-07 2021-04-29 100 49 kenn@kennknowles.com relax@google.com
RowUtils.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/values
506 32 2020-03-28 2021-04-29 16 14 relax@google.com iemejia@gmail.com
pipeline_instrument.py
in sdks/python/apache_beam/runners/interactive
493 27 2019-10-05 2021-04-29 48 30 kawaigin@gmail.com tvalentyn@users.noreply.git...
DoFnOp.java
in runners/samza/src/main/java/org/apache/beam/runners/samza/runtime
493 22 2018-01-02 2021-04-29 61 36 xiliu@xiliu-ld1.linkedin.biz kwu@linkedin.com
SchemaTranslation.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/schemas
457 12 2019-12-01 2021-04-29 27 18 alex@vanboxel.be relax@google.com
beam_provision_api.pb.go
in sdks/go/pkg/beam/model/fnexecution_v1
430 33 2017-10-12 2021-04-29 55 42 herohde@google.com lostluck@users.noreply.gith...
RowCoderGenerator.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/coders
316 11 2018-06-27 2021-04-29 51 34 relax@google.com relax@google.com
interactive_environment.py
in sdks/python/apache_beam/runners/interactive
305 44 2019-08-22 2021-04-29 53 32 kawaigin@gmail.com tvalentyn@users.noreply.git...
streaming_cache.py
in sdks/python/apache_beam/runners/interactive/caching
286 31 2019-11-20 2021-04-29 33 20 rehman.muradali@venturedive... tvalentyn@users.noreply.git...
recording_manager.py
in sdks/python/apache_beam/runners/interactive
259 25 2020-08-24 2021-04-29 24 15 rohde.samuel@gmail.com tvalentyn@users.noreply.git...
pcoll_visualization.py
in sdks/python/apache_beam/runners/interactive/display
244 12 2019-11-02 2021-04-29 33 25 kawaigin@gmail.com tvalentyn@users.noreply.git...
interactive_beam.py
in sdks/python/apache_beam/runners/interactive
243 20 2019-08-22 2021-04-29 38 26 kawaigin@gmail.com tvalentyn@users.noreply.git...
InMemoryTimerInternals.java
in runners/core-java/src/main/java/org/apache/beam/runners/core
242 14 2016-12-16 2021-04-29 43 24 klk@google.com iemejia@gmail.com
proto
v1.proto
in sdks/go/pkg/beam/core/runtime/graphx/v1
213 - 2017-11-30 2021-04-29 14 10 herohde@google.com lostluck@users.noreply.gith...
dataflow_metrics.py
in sdks/python/apache_beam/runners/dataflow
211 12 2017-02-02 2021-04-29 54 39 pabloem@google.com tvalentyn@users.noreply.git...
ptransform_overrides.py
in sdks/python/apache_beam/runners/dataflow
211 17 2017-06-13 2021-04-29 49 37 vikasrk@google.com tvalentyn@users.noreply.git...
QueueingBeamFnDataClient.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data
203 14 2018-12-07 2021-04-29 35 25 ajamato@google.com scwhittle@users.noreply.git...
SchemaCoder.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/schemas
187 24 2018-03-17 2021-04-29 45 27 relax@relax-macbookpro2.roa... relax@google.com
background_caching_job.py
in sdks/python/apache_beam/runners/interactive
164 16 2019-12-20 2021-04-29 47 27 kawaigin@gmail.com tvalentyn@users.noreply.git...
StateBackedIterable.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state
164 7 2020-05-21 2021-04-29 11 9 lukecwik@gmail.com robertwb@google.com
cache_manager.py
in sdks/python/apache_beam/runners/interactive
158 35 2018-07-20 2021-04-29 45 35 qinyeli@umich.edu tvalentyn@users.noreply.git...
ZipFiles.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/util
155 13 2016-04-13 2021-04-29 41 31 bchambers@google.com bhulette@google.com
pipeline_graph.py
in sdks/python/apache_beam/runners/interactive/display
149 9 2018-09-08 2021-04-29 29 25 qinyeli@umich.edu tvalentyn@users.noreply.git...