spotify / beam
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
15% | 16% | 28% | 18% | 21%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java10% | 16% | 29% | 19% | 22%
py23% | 25% | 27% | 13% | 8%
go34% | 9% | 27% | 14% | 14%
groovy56% | 0% | 8% | 20% | 14%
yaml23% | 21% | 12% | 2% | 39%
proto32% | 39% | 9% | 7% | 11%
scss0% | 0% | 40% | 36% | 22%
js0% | 0% | 36% | 39% | 24%
html0% | 0% | 22% | 22% | 55%
xml0% | 0% | 70% | 0% | 29%
ftl0% | 0% | 100% | 0% | 0%
kts0% | 0% | 51% | 33% | 15%
sql0% | 0% | 4% | 15% | 79%
pyx0% | 0% | 0% | 81% | 18%
ts0% | 0% | 0% | 66% | 33%
sass0% | 0% | 0% | 48% | 51%
tsx0% | 0% | 0% | 28% | 71%
pxd0% | 0% | 0% | 21% | 78%
kt0% | 0% | 0% | 0% | 100%
toml0% | 0% | 0% | 0% | 100%
css0% | 0% | 0% | 0% | 100%
h0% | 0% | 0% | 0% | 100%
cfg0% | 0% | 0% | 0% | 100%
rdf0% | 0% | 0% | 0% | 100%
in0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
sdks17% | 18% | 28% | 17% | 18%
runners11% | 13% | 30% | 21% | 23%
buildSrc72% | 0% | 10% | 11% | 5%
website9% | 3% | 30% | 28% | 28%
model37% | 32% | 12% | 8% | 9%
ownership0% | 93% | 0% | 0% | 6%
ROOT0% | 0% | 60% | 39% | 0%
release0% | 0% | 24% | 40% | 34%
learning0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
beam_fn_api.pb.go
in sdks/go/pkg/beam/model/fnexecution_v1
 5022 496
beam_job_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 2323 218
frames.py
in sdks/python/apache_beam/dataframe
 2272 115
FnApiDoFnRunner.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness
 2203 112
dataflow_v1b3_messages.py
in sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow
 2067 -
DoFnSignatures.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect
 2064 62
StreamingDataflowWorker.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker
 2053 88
beam_artifact_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 1911 185
decoders.go
in sdks/go/pkg/beam/core/runtime/exec/optimized
 1856 441
encoders.go
in sdks/go/pkg/beam/core/runtime/exec/optimized
 1772 421
DataflowRunner.java
in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow
 1751 81
WindmillStateInternals.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker
 1696 93
BeamModulePlugin.groovy
in buildSrc/src/main/groovy/org/apache/beam/gradle
 1680 3
capability_matrix.yaml
in website/www/site/data
 1669 -
BigQueryIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 1640 113
schema.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
 1614 170
core.py
in sdks/python/apache_beam/transforms
 1571 218
proto
beam_runner_api.proto
in model/pipeline/src/main/proto
 1567 -
bigquery_v2_messages.py
in sdks/python/apache_beam/io/gcp/internal/clients/bigquery
 1524 -
translations.py
in sdks/python/apache_beam/runners/portability/fn_api_runner
 1512 60
v1.pb.go
in sdks/go/pkg/beam/core/runtime/graphx/v1
 1503 140
bundle_processor.py
in sdks/python/apache_beam/runners/worker
 1487 118
GrpcWindmillServer.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill
 1378 104
KafkaIO.java
in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka
 1333 122
Combine.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
 1332 158
FlinkStateInternals.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state
 1324 92
PipelineOptionsFactory.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/options
 1322 60
FlinkStreamingTransformTranslators.java
in runners/flink/src/main/java/org/apache/beam/runners/flink
 1291 53
HadoopFormatIO.java
in sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format
 1244 86
pipeline_options.py
in sdks/python/apache_beam/options
 1237 51
BigQueryServicesImpl.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 1218 62
WatermarkManager.java
in runners/direct-java/src/main/java/org/apache/beam/runners/direct
 1197 110
ByteBuddyUtils.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils
 1164 76
bigquery_tools.py
in sdks/python/apache_beam/io/gcp
 1162 77
dataflow_runner.py
in sdks/python/apache_beam/runners/dataflow
 1152 57
SnowflakeIO.java
in sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake
 1150 106
DoFnOperator.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming
 1149 79
bigquery.py
in sdks/python/apache_beam/io/gcp
 1138 60
NexmarkLauncher.java
in sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark
 1130 45
PAssert.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/testing
 1125 122
metrics.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
 1119 63
calls.go
in sdks/go/pkg/beam/core/util/reflectx
 1058 192
trigger.py
in sdks/python/apache_beam/transforms
 1053 204
SpannerIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner
 1044 111
SimpleDoFnRunner.java
in runners/core-java/src/main/java/org/apache/beam/runners/core
 1033 130
AvroIO.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/io
 1030 119
FhirIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare
 1023 61
dataflow_v1b3_client.py
in sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow
 1016 71
JdbcIO.java
in sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc
 1016 102
ExecutableStageDoFnOperator.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming
 1012 54
Files With Most Units (Top 50)
File# lines# units
beam_fn_api.pb.go
in sdks/go/pkg/beam/model/fnexecution_v1
 5022 496
decoders.go
in sdks/go/pkg/beam/core/runtime/exec/optimized
 1856 441
encoders.go
in sdks/go/pkg/beam/core/runtime/exec/optimized
 1772 421
coders.py
in sdks/python/apache_beam/coders
 874 244
beam_job_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 2323 218
core.py
in sdks/python/apache_beam/transforms
 1571 218
trigger.py
in sdks/python/apache_beam/transforms
 1053 204
calls.go
in sdks/go/pkg/beam/core/util/reflectx
 1058 192
beam_artifact_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 1911 185
schema.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
 1614 170
Combine.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
 1332 158
v1.pb.go
in sdks/go/pkg/beam/core/runtime/graphx/v1
 1503 140
SimpleDoFnRunner.java
in runners/core-java/src/main/java/org/apache/beam/runners/core
 1033 130
coder_impl.py
in sdks/python/apache_beam/coders
 900 129
Schema.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/schemas
 984 124
PAssert.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/testing
 1125 122
KafkaIO.java
in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka
 1333 122
AvroIO.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/io
 1030 119
bundle_processor.py
in sdks/python/apache_beam/runners/worker
 1487 118
frames.py
in sdks/python/apache_beam/dataframe
 2272 115
combiners.py
in sdks/python/apache_beam/transforms
 661 113
BigQueryIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 1640 113
FnApiDoFnRunner.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness
 2203 112
callers.go
in sdks/go/pkg/beam/core/runtime/exec/optimized
 470 111
SpannerIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner
 1044 111
WatermarkManager.java
in runners/direct-java/src/main/java/org/apache/beam/runners/direct
 1197 110
SnowflakeIO.java
in sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake
 1150 106
GrpcWindmillServer.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill
 1378 104
JdbcIO.java
in sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc
 1016 102
typehints.py
in sdks/python/apache_beam/typehints
 671 101
iobase.py
in sdks/python/apache_beam/io
 559 96
CounterFactory.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/counters
 632 96
worker_handlers.py
in sdks/python/apache_beam/runners/portability/fn_api_runner
 818 95
WindmillStateInternals.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker
 1696 93
stats.shims.go
in sdks/go/pkg/beam/transforms/stats
 437 92
FlinkStateInternals.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state
 1324 92
CassandraIO.java
in sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra
 888 89
StreamingDataflowWorker.java
in runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker
 2053 88
TextIO.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/io
 689 87
HadoopFormatIO.java
in sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format
 1244 86
Watch.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
 881 85
BigtableIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable
 815 85
passert.shims.go
in sdks/go/pkg/beam/testing/passert
 455 84
operations.py
in sdks/python/apache_beam/runners/worker
 851 83
WindowedValue.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/util
 614 83
InMemoryStateInternals.java
in runners/core-java/src/main/java/org/apache/beam/runners/core
 591 83
ParquetIO.java
in sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet
 898 82
SamzaStoreStateInternals.java
in runners/samza/src/main/java/org/apache/beam/runners/samza/runtime
 912 81
DataflowRunner.java
in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow
 1751 81
PCollectionViews.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/values
 996 80
Files With Long Lines (Top 50)

There are 212 files with lines longer than 120 characters. In total, there are 1052 long lines.

File# lines# units# long lines
beam-codestyle.xml
in sdks/java/build-tools/src/main/resources/beam
 313 - 101
beam_fn_api.pb.go
in sdks/go/pkg/beam/model/fnexecution_v1
 5022 496 93
BeamModulePlugin.groovy
in buildSrc/src/main/groovy/org/apache/beam/gradle
 1680 3 53
beam_job_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 2323 218 49
beam_artifact_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 1911 185 43
capability_matrix.yaml
in website/www/site/data
 1669 - 34
capability_matrix_snapshot.yaml
in website/www/site/data
 733 - 30
io_matrix.yaml
in website/www/site/data
 368 - 18
standard_coders.yaml
in model/fn-execution/src/main/resources/org/apache/beam/model/fnexecution/v1
 285 - 17
footer.html
in website/www/site/layouts/partials
 66 - 16
header.html
in website/www/site/layouts/partials
 208 - 16
passert.shims.go
in sdks/go/pkg/beam/testing/passert
 455 84 15
flink_python_pipeline_options.html
in website/www/site/layouts/shortcodes
 162 - 15
flink_java_pipeline_options.html
in website/www/site/layouts/shortcodes
 162 - 15
decoders.go
in sdks/go/pkg/beam/core/runtime/exec/optimized
 1856 441 14
beam_provision_api.pb.go
in sdks/go/pkg/beam/model/fnexecution_v1
 430 33 14
encoders.go
in sdks/go/pkg/beam/core/runtime/exec/optimized
 1772 421 13
storage_v1_client.py
in sdks/python/apache_beam/io/gcp/internal/clients/storage
 904 57 13
join_beam.yaml
in website/www/site/data/en
 17 - 13
documentation.html
in website/www/site/layouts/partials/section-menu/en
 313 - 11
beam.shims.go
in sdks/go/pkg/beam
 272 56 10
index.html
in website/www/site/layouts
 227 - 10
fn.go
in sdks/go/pkg/beam/core/graph
 796 45 9
materialize.go
in sdks/go/pkg/beam/artifact
 402 18 9
debug.shims.go
in sdks/go/pkg/beam/x/debug
 303 51 9
sdks.html
in website/www/site/layouts/partials/section-menu/en
 106 - 9
_gradients.scss
in website/www/site/assets/scss/bootstrap/mixins
 44 - 9
coder.go
in sdks/go/pkg/beam/core/runtime/graphx
 459 19 8
edge.go
in sdks/go/pkg/beam/core/graph
 350 21 7
quantiles.go
in sdks/go/pkg/beam/transforms/stats
 549 55 7
schema.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
 1614 170 7
v1.pb.go
in sdks/go/pkg/beam/core/runtime/graphx/v1
 1503 140 6
statemgr.go
in sdks/go/pkg/beam/core/runtime/harness
 331 17 6
fn.go
in sdks/go/pkg/beam/core/runtime/exec
 256 13 6
generate.go
in sdks/go/pkg/beam/util/shimx
 356 27 6
stats.shims.go
in sdks/go/pkg/beam/transforms/stats
 437 92 6
highlight.html
in website/www/site/layouts/shortcodes
 60 - 6
capability-matrix.html
in website/www/site/layouts/shortcodes
 94 - 6
_glyphicons.scss
in website/www/site/assets/scss/bootstrap
 285 - 6
fn.go
in sdks/go/pkg/beam/core/funcx
 403 20 5
testutil.go
in sdks/go/pkg/beam/core/graph/coder/testutil
 96 3 5
schema.go
in sdks/go/pkg/beam/core/runtime/graphx/schema
 610 28 5
combine.go
in sdks/go/pkg/beam/core/runtime/exec
 378 27 5
pardo.go
in sdks/go/pkg/beam
 125 13 5
stage.go
in sdks/go/pkg/beam/artifact
 196 8 5
hive-site.xml
in sdks/java/io/hcatalog/src/main/resources
 217 - 5
boot.go
in sdks/java/container
 129 2 5
tooltip.js
in website/www/site/static/js/bootstrap
 377 33 5
community_list.yaml
in website/www/site/data/en
 15 - 5
calls.go
in sdks/go/pkg/beam/core/util/reflectx
 1058 192 4
Correlations

File Size vs. Commits (all time): 4821 points

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSideInputReader.java x: 36 commits (all time) y: 772 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java x: 219 commits (all time) y: 1332 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java x: 131 commits (all time) y: 361 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java x: 64 commits (all time) y: 996 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/UnboundedEventSource.java x: 17 commits (all time) y: 239 lines of code sdks/python/apache_beam/ml/gcp/recommendations_ai.py x: 1 commits (all time) y: 359 lines of code sdks/python/apache_beam/ml/gcp/recommendations_ai_test_it.py x: 1 commits (all time) y: 63 lines of code sdks/python/setup.py x: 498 commits (all time) y: 246 lines of code sdks/python/apache_beam/pipeline.py x: 312 commits (all time) y: 803 lines of code sdks/python/apache_beam/transforms/external.py x: 85 commits (all time) y: 349 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/LazyAggregateCombineFn.java x: 4 commits (all time) y: 69 lines of code sdks/python/apache_beam/dataframe/frames.py x: 112 commits (all time) y: 2272 lines of code sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet/ParquetIO.java x: 86 commits (all time) y: 898 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java x: 194 commits (all time) y: 1016 lines of code sdks/go/pkg/beam/core/runtime/xlangx/payload.go x: 2 commits (all time) y: 38 lines of code sdks/go/pkg/beam/xlang.go x: 16 commits (all time) y: 88 lines of code sdks/go/pkg/beam/core/runtime/graphx/v1/gen.go x: 8 commits (all time) y: 1 lines of code sdks/go/pkg/beam/core/runtime/graphx/v1/v1.pb.go x: 17 commits (all time) y: 1503 lines of code sdks/go/pkg/beam/core/runtime/graphx/v1/v1.proto x: 17 commits (all time) y: 213 lines of code sdks/go/pkg/beam/model/fnexecution_v1/beam_provision_api.pb.go x: 69 commits (all time) y: 430 lines of code sdks/go/pkg/beam/model/pipeline_v1/metrics.pb.go x: 32 commits (all time) y: 1119 lines of code sdks/go/pkg/beam/model/pipeline_v1/schema.pb.go x: 8 commits (all time) y: 1614 lines of code website/www/site/config.toml x: 29 commits (all time) y: 89 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy x: 892 commits (all time) y: 1680 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/QueueingBeamFnDataClient.java x: 38 commits (all time) y: 203 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java x: 70 commits (all time) y: 493 lines of code sdks/go/pkg/beam/core/runtime/graphx/schema/schema.go x: 16 commits (all time) y: 610 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateBackedIterable.java x: 11 commits (all time) y: 164 lines of code sdks/python/apache_beam/version.py x: 103 commits (all time) y: 1 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryTimerInternals.java x: 58 commits (all time) y: 242 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/Row.java x: 139 commits (all time) y: 529 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/RowUtils.java x: 18 commits (all time) y: 506 lines of code sdks/python/apache_beam/ml/gcp/naturallanguageml_test_it.py x: 5 commits (all time) y: 40 lines of code sdks/python/apache_beam/ml/gcp/videointelligenceml_test_it.py x: 9 commits (all time) y: 42 lines of code sdks/python/apache_beam/ml/gcp/visionml_test_it.py x: 8 commits (all time) y: 47 lines of code sdks/python/conftest.py x: 16 commits (all time) y: 17 lines of code model/pipeline/src/main/proto/schema.proto x: 19 commits (all time) y: 148 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RowCoderCloudObjectTranslator.java x: 2 commits (all time) y: 52 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/SchemaCoderCloudObjectTranslator.java x: 31 commits (all time) y: 95 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java x: 90 commits (all time) y: 43 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoderGenerator.java x: 59 commits (all time) y: 316 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java x: 147 commits (all time) y: 984 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java x: 58 commits (all time) y: 187 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaTranslation.java x: 30 commits (all time) y: 457 lines of code sdks/python/apache_beam/runners/dataflow/__init__.py x: 18 commits (all time) y: 2 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline.py x: 14 commits (all time) y: 132 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline.py x: 13 commits (all time) y: 62 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py x: 64 commits (all time) y: 211 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_runner.py x: 422 commits (all time) y: 1152 lines of code sdks/python/apache_beam/runners/dataflow/internal/__init__.py x: 9 commits (all time) y: 1 lines of code sdks/python/apache_beam/runners/dataflow/internal/apiclient.py x: 298 commits (all time) y: 918 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/cloudbuild/__init__.py x: 5 commits (all time) y: 8 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/__init__.py x: 13 commits (all time) y: 8 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py x: 38 commits (all time) y: 1016 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py x: 57 commits (all time) y: 2067 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/message_matchers.py x: 19 commits (all time) y: 65 lines of code sdks/python/apache_beam/runners/dataflow/internal/names.py x: 176 commits (all time) y: 68 lines of code sdks/python/apache_beam/runners/dataflow/native_io/iobase.py x: 47 commits (all time) y: 144 lines of code sdks/python/apache_beam/runners/dataflow/ptransform_overrides.py x: 59 commits (all time) y: 211 lines of code sdks/python/apache_beam/runners/interactive/augmented_pipeline.py x: 6 commits (all time) y: 73 lines of code sdks/python/apache_beam/runners/interactive/background_caching_job.py x: 56 commits (all time) y: 164 lines of code sdks/python/apache_beam/runners/interactive/cache_manager.py x: 52 commits (all time) y: 158 lines of code sdks/python/apache_beam/runners/interactive/caching/__init__.py x: 4 commits (all time) y: 1 lines of code sdks/python/apache_beam/runners/interactive/caching/read_cache.py x: 6 commits (all time) y: 84 lines of code sdks/python/apache_beam/runners/interactive/caching/streaming_cache.py x: 39 commits (all time) y: 286 lines of code sdks/python/apache_beam/runners/interactive/caching/write_cache.py x: 5 commits (all time) y: 116 lines of code sdks/python/apache_beam/runners/interactive/display/display_manager.py x: 23 commits (all time) y: 107 lines of code sdks/python/apache_beam/runners/interactive/display/interactive_pipeline_graph.py x: 14 commits (all time) y: 87 lines of code sdks/python/apache_beam/runners/interactive/display/pcoll_visualization.py x: 39 commits (all time) y: 244 lines of code sdks/python/apache_beam/runners/interactive/display/pipeline_graph.py x: 34 commits (all time) y: 149 lines of code sdks/python/apache_beam/runners/interactive/display/pipeline_graph_renderer.py x: 23 commits (all time) y: 55 lines of code sdks/python/apache_beam/runners/interactive/interactive_beam.py x: 46 commits (all time) y: 243 lines of code sdks/python/apache_beam/runners/interactive/interactive_environment.py x: 70 commits (all time) y: 305 lines of code sdks/python/apache_beam/runners/interactive/interactive_runner.py x: 87 commits (all time) y: 133 lines of code sdks/python/apache_beam/runners/interactive/messaging/interactive_environment_inspector.py x: 9 commits (all time) y: 88 lines of code sdks/python/apache_beam/runners/interactive/options/capture_control.py x: 19 commits (all time) y: 31 lines of code sdks/python/apache_beam/runners/interactive/options/capture_limiters.py x: 20 commits (all time) y: 67 lines of code sdks/python/apache_beam/runners/interactive/pipeline_fragment.py x: 23 commits (all time) y: 143 lines of code sdks/python/apache_beam/runners/interactive/pipeline_instrument.py x: 66 commits (all time) y: 493 lines of code sdks/python/apache_beam/runners/interactive/recording_manager.py x: 28 commits (all time) y: 259 lines of code sdks/python/apache_beam/runners/interactive/testing/integration/notebook_executor.py x: 11 commits (all time) y: 103 lines of code sdks/python/apache_beam/runners/interactive/testing/integration/screen_diff.py x: 14 commits (all time) y: 141 lines of code sdks/python/apache_beam/runners/interactive/utils.py x: 32 commits (all time) y: 146 lines of code model/pipeline/src/main/proto/beam_runner_api.proto x: 242 commits (all time) y: 1567 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/ZipFiles.java x: 57 commits (all time) y: 155 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java x: 147 commits (all time) y: 2053 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java x: 73 commits (all time) y: 650 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateCache.java x: 59 commits (all time) y: 288 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query19.sql x: 4 commits (all time) y: 22 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query23a.sql x: 4 commits (all time) y: 49 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query62.sql x: 6 commits (all time) y: 32 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query8.sql x: 4 commits (all time) y: 105 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query85.sql x: 4 commits (all time) y: 81 lines of code runners/portability/java/src/main/java/org/apache/beam/runners/portability/ExternalWorkerService.java x: 25 commits (all time) y: 68 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/WindowFn.java x: 56 commits (all time) y: 45 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java x: 338 commits (all time) y: 1005 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/External.java x: 51 commits (all time) y: 326 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java x: 166 commits (all time) y: 386 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ParDoTranslation.java x: 168 commits (all time) y: 684 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SdkComponents.java x: 111 commits (all time) y: 267 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowingStrategyTranslation.java x: 103 commits (all time) y: 322 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PropertyNames.java x: 40 commits (all time) y: 54 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/Pipeline.java x: 169 commits (all time) y: 433 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java x: 126 commits (all time) y: 392 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PTransform.java x: 83 commits (all time) y: 106 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/ResourceHints.java x: 5 commits (all time) y: 219 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/package-info.java x: 2 commits (all time) y: 1 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowClient.java x: 31 commits (all time) y: 122 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java x: 577 commits (all time) y: 1751 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TestDataflowRunner.java x: 55 commits (all time) y: 289 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClient.java x: 34 commits (all time) y: 190 lines of code model/fn-execution/src/main/proto/beam_provision_api.proto x: 48 commits (all time) y: 71 lines of code sdks/java/container/boot.go x: 50 commits (all time) y: 129 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSQLQueryPlanner.java x: 74 commits (all time) y: 210 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateSampler.java x: 19 commits (all time) y: 115 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/ExperimentalOptions.java x: 33 commits (all time) y: 54 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java x: 138 commits (all time) y: 255 lines of code sdks/go/pkg/beam/runners/universal/runnerlib/stage.go x: 24 commits (all time) y: 123 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlAnalyzer.java x: 54 commits (all time) y: 133 lines of code sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java x: 94 commits (all time) y: 399 lines of code sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java x: 75 commits (all time) y: 476 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ParDoTranslatorBatch.java x: 5 commits (all time) y: 200 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/AggregatorsAccumulator.java x: 45 commits (all time) y: 97 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkCombineFn.java x: 28 commits (all time) y: 656 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchStatefulParDoOverrides.java x: 73 commits (all time) y: 222 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TransformTranslator.java x: 73 commits (all time) y: 57 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DefaultCoderCloudObjectTranslatorRegistrar.java x: 52 commits (all time) y: 109 lines of code sdks/python/apache_beam/runners/direct/bundle_factory.py x: 49 commits (all time) y: 98 lines of code sdks/python/apache_beam/runners/direct/clock.py x: 33 commits (all time) y: 17 lines of code sdks/python/apache_beam/runners/direct/consumer_tracking_pipeline_visitor.py x: 29 commits (all time) y: 33 lines of code sdks/python/apache_beam/runners/direct/direct_metrics.py x: 28 commits (all time) y: 84 lines of code sdks/python/apache_beam/runners/direct/direct_runner.py x: 203 commits (all time) y: 401 lines of code sdks/python/apache_beam/runners/direct/direct_userstate.py x: 34 commits (all time) y: 239 lines of code sdks/python/apache_beam/runners/direct/evaluation_context.py x: 78 commits (all time) y: 258 lines of code sdks/python/apache_beam/runners/direct/executor.py x: 105 commits (all time) y: 514 lines of code sdks/python/apache_beam/runners/direct/sdf_direct_runner.py x: 56 commits (all time) y: 338 lines of code sdks/python/apache_beam/runners/direct/transform_evaluator.py x: 204 commits (all time) y: 898 lines of code sdks/python/apache_beam/runners/direct/util.py x: 37 commits (all time) y: 48 lines of code sdks/python/apache_beam/runners/direct/watermark_manager.py x: 67 commits (all time) y: 219 lines of code sdks/python/apache_beam/runners/job/manager.py x: 17 commits (all time) y: 19 lines of code sdks/python/apache_beam/runners/job/utils.py x: 24 commits (all time) y: 12 lines of code sdks/python/apache_beam/runners/portability/abstract_job_service.py x: 44 commits (all time) y: 258 lines of code sdks/python/apache_beam/runners/portability/artifact_service.py x: 58 commits (all time) y: 271 lines of code sdks/python/apache_beam/runners/portability/expansion_service.py x: 29 commits (all time) y: 66 lines of code sdks/python/apache_beam/runners/portability/flink_runner.py x: 67 commits (all time) y: 83 lines of code sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py x: 55 commits (all time) y: 182 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py x: 48 commits (all time) y: 715 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py x: 85 commits (all time) y: 831 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/translations.py x: 68 commits (all time) y: 1512 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py x: 47 commits (all time) y: 818 lines of code sdks/python/apache_beam/runners/portability/job_server.py x: 60 commits (all time) y: 104 lines of code sdks/python/apache_beam/runners/portability/local_job_service.py x: 103 commits (all time) y: 304 lines of code sdks/python/apache_beam/runners/portability/local_job_service_main.py x: 43 commits (all time) y: 126 lines of code sdks/python/apache_beam/runners/portability/portable_metrics.py x: 15 commits (all time) y: 33 lines of code sdks/python/apache_beam/runners/portability/portable_runner.py x: 212 commits (all time) y: 457 lines of code sdks/python/apache_beam/runners/portability/sdk_container_builder.py x: 24 commits (all time) y: 266 lines of code sdks/python/apache_beam/runners/portability/spark_runner.py x: 40 commits (all time) y: 67 lines of code sdks/python/apache_beam/runners/portability/spark_uber_jar_job_server.py x: 29 commits (all time) y: 199 lines of code sdks/python/apache_beam/runners/portability/stager.py x: 82 commits (all time) y: 510 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java x: 305 commits (all time) y: 1333 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java x: 8 commits (all time) y: 133 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIO.java x: 52 commits (all time) y: 1023 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BagUserState.java x: 47 commits (all time) y: 98 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/IterableSideInput.java x: 11 commits (all time) y: 43 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/MultimapSideInput.java x: 42 commits (all time) y: 69 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateFetchingIterators.java x: 48 commits (all time) y: 167 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/PCollectionConsumerRegistry.java x: 46 commits (all time) y: 284 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DirectStreamObserver.java x: 33 commits (all time) y: 78 lines of code sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbIO.java x: 137 commits (all time) y: 587 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunnerInfo.java x: 39 commits (all time) y: 100 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineWorkerPoolOptions.java x: 80 commits (all time) y: 105 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JavaUdfLoader.java x: 12 commits (all time) y: 217 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCatalog.java x: 12 commits (all time) y: 470 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroUtils.java x: 95 commits (all time) y: 993 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/BeamFnControlClient.java x: 74 commits (all time) y: 129 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineRunner.java x: 113 commits (all time) y: 227 lines of code sdks/python/apache_beam/options/pipeline_options.py x: 252 commits (all time) y: 1237 lines of code sdks/python/apache_beam/transforms/resources.py x: 2 commits (all time) y: 137 lines of code sdks/python/apache_beam/transforms/__init__.py x: 29 commits (all time) y: 11 lines of code sdks/python/apache_beam/transforms/combiners.py x: 127 commits (all time) y: 661 lines of code sdks/python/apache_beam/transforms/core.py x: 453 commits (all time) y: 1571 lines of code sdks/python/apache_beam/transforms/cy_combiners.py x: 47 commits (all time) y: 253 lines of code sdks/python/apache_beam/transforms/display.py x: 80 commits (all time) y: 199 lines of code sdks/python/apache_beam/transforms/environments.py x: 86 commits (all time) y: 597 lines of code sdks/python/apache_beam/transforms/ptransform.py x: 213 commits (all time) y: 623 lines of code sdks/python/apache_beam/transforms/sideinputs.py x: 48 commits (all time) y: 57 lines of code sdks/python/apache_beam/transforms/stats.py x: 38 commits (all time) y: 548 lines of code sdks/python/apache_beam/transforms/timeutil.py x: 61 commits (all time) y: 69 lines of code sdks/python/apache_beam/transforms/trigger.py x: 174 commits (all time) y: 1053 lines of code sdks/python/apache_beam/transforms/userstate.py x: 67 commits (all time) y: 213 lines of code sdks/python/apache_beam/transforms/util.py x: 196 commits (all time) y: 754 lines of code sdks/python/apache_beam/transforms/window.py x: 127 commits (all time) y: 330 lines of code sdks/python/apache_beam/io/gcp/bigquery_tools.py x: 124 commits (all time) y: 1162 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PublisherCache.java x: 15 commits (all time) y: 49 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PublisherOptions.java x: 20 commits (all time) y: 25 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteSink.java x: 20 commits (all time) y: 119 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscribeTransform.java x: 20 commits (all time) y: 114 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/Uuid.java x: 14 commits (all time) y: 34 lines of code sdks/python/apache_beam/options/pipeline_options_validator.py x: 46 commits (all time) y: 262 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java x: 141 commits (all time) y: 593 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchedStreamingWrite.java x: 8 commits (all time) y: 317 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryOptions.java x: 32 commits (all time) y: 67 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/AggregateScanConverter.java x: 34 commits (all time) y: 201 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/UserFunctionDefinitions.java x: 21 commits (all time) y: 43 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java x: 122 commits (all time) y: 243 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/CalcRelSplitter.java x: 3 commits (all time) y: 571 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamCalcRelType.java x: 5 commits (all time) y: 120 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamJavaUdfCalcRule.java x: 11 commits (all time) y: 18 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/BeamSqlEnvRunner.java x: 11 commits (all time) y: 153 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java x: 10 commits (all time) y: 131 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsParametersReader.java x: 8 commits (all time) y: 65 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query14a.sql x: 2 commits (all time) y: 78 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query14b.sql x: 2 commits (all time) y: 94 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query5.sql x: 4 commits (all time) y: 125 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query66.sql x: 4 commits (all time) y: 219 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaExecutionContext.java x: 30 commits (all time) y: 41 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobInvoker.java x: 1 commits (all time) y: 53 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineRunner.java x: 21 commits (all time) y: 39 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java x: 57 commits (all time) y: 138 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaExecutableStageContextFactory.java x: 1 commits (all time) y: 28 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ImpulseTranslator.java x: 17 commits (all time) y: 47 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ParDoBoundMultiTranslator.java x: 66 commits (all time) y: 315 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/PortableTranslationContext.java x: 21 commits (all time) y: 150 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/util/SamzaPipelineTranslatorUtils.java x: 24 commits (all time) y: 64 lines of code sdks/python/apache_beam/runners/pipeline_context.py x: 117 commits (all time) y: 210 lines of code sdks/python/apache_beam/runners/worker/sdk_worker_main.py x: 96 commits (all time) y: 168 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java x: 185 commits (all time) y: 697 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProvider.java x: 55 commits (all time) y: 87 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java x: 218 commits (all time) y: 1218 lines of code build.gradle.kts x: 29 commits (all time) y: 293 lines of code release/src/main/scripts/download_github_actions_artifacts.py x: 15 commits (all time) y: 256 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/DisplayDataTranslation.java x: 38 commits (all time) y: 52 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java x: 93 commits (all time) y: 426 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/SimpleExecutionState.java x: 32 commits (all time) y: 113 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/SimpleStateRegistry.java x: 28 commits (all time) y: 48 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironment.java x: 95 commits (all time) y: 81 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/data/BeamFnDataGrpcService.java x: 44 commits (all time) y: 187 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/EmbeddedEnvironmentFactory.java x: 34 commits (all time) y: 138 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunner.java x: 204 commits (all time) y: 337 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/HistogramData.java x: 7 commits (all time) y: 179 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/ReflectHelpers.java x: 89 commits (all time) y: 230 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamCalcRel.java x: 108 commits (all time) y: 660 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver.java x: 35 commits (all time) y: 65 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnDataGrpcClient.java x: 84 commits (all time) y: 69 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServices.java x: 125 commits (all time) y: 107 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java x: 10 commits (all time) y: 262 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java x: 5 commits (all time) y: 420 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java x: 36 commits (all time) y: 464 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TableSchemaJSONLoader.java x: 9 commits (all time) y: 68 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsSchemas.java x: 8 commits (all time) y: 632 lines of code sdks/python/apache_beam/dataframe/frame_base.py x: 60 commits (all time) y: 413 lines of code sdks/python/apache_beam/dataframe/io.py x: 33 commits (all time) y: 447 lines of code sdks/python/apache_beam/dataframe/pandas_top_level_functions.py x: 16 commits (all time) y: 135 lines of code sdks/python/apache_beam/dataframe/transforms.py x: 38 commits (all time) y: 346 lines of code sdks/python/apache_beam/io/gcp/bigquery.py x: 252 commits (all time) y: 1138 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/preprocess.py x: 28 commits (all time) y: 162 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/process_tfma.py x: 27 commits (all time) y: 127 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/setup.py x: 20 commits (all time) y: 19 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/tfdv_analyze_and_validate.py x: 28 commits (all time) y: 150 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/trainer/model.py x: 12 commits (all time) y: 66 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/trainer/task.py x: 17 commits (all time) y: 105 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/trainer/taxi.py x: 18 commits (all time) y: 97 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/models/nexmark_model.py x: 12 commits (all time) y: 155 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py x: 36 commits (all time) y: 314 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_util.py x: 25 commits (all time) y: 139 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query0.py x: 21 commits (all time) y: 11 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query10.py x: 8 commits (all time) y: 83 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query11.py x: 9 commits (all time) y: 22 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query12.py x: 10 commits (all time) y: 21 lines of code sdks/python/apache_beam/testing/load_tests/load_test_metrics_utils.py x: 61 commits (all time) y: 352 lines of code sdks/python/apache_beam/testing/metric_result_matchers.py x: 12 commits (all time) y: 133 lines of code sdks/python/apache_beam/testing/pipeline_verifiers.py x: 27 commits (all time) y: 85 lines of code sdks/python/apache_beam/testing/synthetic_pipeline.py x: 61 commits (all time) y: 653 lines of code sdks/python/apache_beam/testing/util.py x: 83 commits (all time) y: 165 lines of code sdks/python/apache_beam/tools/distribution_counter_microbenchmark.py x: 25 commits (all time) y: 34 lines of code sdks/python/apache_beam/tools/fn_api_runner_microbenchmark.py x: 17 commits (all time) y: 71 lines of code sdks/python/apache_beam/tools/map_fn_microbenchmark.py x: 27 commits (all time) y: 30 lines of code sdks/python/apache_beam/tools/utils.py x: 25 commits (all time) y: 83 lines of code sdks/python/apache_beam/typehints/typecheck_test_py3.py x: 10 commits (all time) y: 229 lines of code sdks/python/apache_beam/utils/annotations.py x: 49 commits (all time) y: 43 lines of code sdks/python/apache_beam/utils/counters.py x: 71 commits (all time) y: 116 lines of code sdks/python/apache_beam/utils/histogram.py x: 16 commits (all time) y: 163 lines of code sdks/python/apache_beam/utils/interactive_utils.py x: 32 commits (all time) y: 43 lines of code sdks/python/apache_beam/utils/processes.py x: 27 commits (all time) y: 72 lines of code sdks/python/apache_beam/utils/profiler.py x: 65 commits (all time) y: 117 lines of code sdks/python/apache_beam/utils/proto_utils.py x: 46 commits (all time) y: 64 lines of code sdks/python/apache_beam/utils/retry.py x: 89 commits (all time) y: 137 lines of code sdks/python/apache_beam/utils/subprocess_server.py x: 48 commits (all time) y: 236 lines of code sdks/python/apache_beam/utils/thread_pool_executor.py x: 23 commits (all time) y: 80 lines of code sdks/python/apache_beam/utils/urns.py x: 97 commits (all time) y: 90 lines of code sdks/python/apache_beam/utils/windowed_value.py x: 71 commits (all time) y: 215 lines of code sdks/python/container/boot.go x: 62 commits (all time) y: 250 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDo.java x: 125 commits (all time) y: 599 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDoNaiveBounded.java x: 71 commits (all time) y: 511 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDoViaKeyedWorkItems.java x: 78 commits (all time) y: 478 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/DoFnLifecycleManager.java x: 49 commits (all time) y: 75 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluatorFactory.java x: 108 commits (all time) y: 143 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java x: 134 commits (all time) y: 187 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/StatefulParDoEvaluatorFactory.java x: 134 commits (all time) y: 209 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java x: 90 commits (all time) y: 199 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkStatefulDoFnFunction.java x: 89 commits (all time) y: 195 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java x: 286 commits (all time) y: 1149 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/UserParDoFnFactory.java x: 27 commits (all time) y: 114 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/AbstractParDoP.java x: 17 commits (all time) y: 462 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java x: 14 commits (all time) y: 215 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/MultiDoFnFunction.java x: 142 commits (all time) y: 199 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/DoFnFunction.java x: 17 commits (all time) y: 293 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java x: 240 commits (all time) y: 575 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvoker.java x: 143 commits (all time) y: 342 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvokers.java x: 84 commits (all time) y: 44 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java x: 182 commits (all time) y: 882 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java x: 221 commits (all time) y: 2064 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java x: 203 commits (all time) y: 2203 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/WatermarkHold.java x: 92 commits (all time) y: 298 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkNonMergingReduceFunction.java x: 15 commits (all time) y: 76 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/SortingFlinkCombineRunner.java x: 48 commits (all time) y: 124 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowAndCombineFn.java x: 16 commits (all time) y: 231 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowViaIteratorsFn.java x: 26 commits (all time) y: 194 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/AggregatorCombiner.java x: 9 commits (all time) y: 212 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/GroupNonMergingWindowsFunctions.java x: 30 commits (all time) y: 190 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/WindowFnTestUtils.java x: 65 commits (all time) y: 226 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/PartitioningWindowFn.java x: 31 commits (all time) y: 29 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/SlidingWindows.java x: 49 commits (all time) y: 132 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/IdentityWindowFn.java x: 52 commits (all time) y: 63 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java x: 28 commits (all time) y: 277 lines of code sdks/python/apache_beam/coders/coder_impl.py x: 175 commits (all time) y: 900 lines of code sdks/python/apache_beam/coders/coders_test_common.py x: 144 commits (all time) y: 563 lines of code sdks/python/apache_beam/coders/coder_impl.pxd x: 67 commits (all time) y: 132 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java x: 69 commits (all time) y: 166 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunnerDebugger.java x: 42 commits (all time) y: 91 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/BeamFnStatusClient.java x: 1 commits (all time) y: 186 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java x: 1 commits (all time) y: 401 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/package-info.java x: 1 commits (all time) y: 1 lines of code sdks/python/apache_beam/coders/coders.py x: 248 commits (all time) y: 874 lines of code sdks/python/apache_beam/io/gcp/bigquery_file_loads.py x: 91 commits (all time) y: 818 lines of code sdks/python/apache_beam/runners/worker/sdk_worker.py x: 262 commits (all time) y: 891 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineOptions.java x: 121 commits (all time) y: 138 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AvroCoder.java x: 121 commits (all time) y: 468 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java x: 113 commits (all time) y: 780 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java x: 95 commits (all time) y: 904 lines of code sdks/python/apache_beam/coders/row_coder.py x: 38 commits (all time) y: 162 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsEnvironment.java x: 45 commits (all time) y: 79 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateTracker.java x: 35 commits (all time) y: 176 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java x: 25 commits (all time) y: 316 lines of code sdks/go/pkg/beam/artifact/materialize.go x: 48 commits (all time) y: 402 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSink.java x: 71 commits (all time) y: 321 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java x: 82 commits (all time) y: 1130 lines of code sdks/python/apache_beam/io/filesystem.py x: 122 commits (all time) y: 428 lines of code sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java x: 163 commits (all time) y: 973 lines of code sdks/python/apache_beam/io/iobase.py x: 231 commits (all time) y: 559 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java x: 228 commits (all time) y: 291 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/GrpcVendoring_1_26_0.groovy x: 33 commits (all time) y: 150 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslation.java x: 60 commits (all time) y: 130 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslators.java x: 59 commits (all time) y: 159 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java x: 99 commits (all time) y: 189 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CreatePCollectionViewTranslation.java x: 59 commits (all time) y: 78 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/DefaultExpansionServiceClientFactory.java x: 20 commits (all time) y: 46 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/Environments.java x: 136 commits (all time) y: 425 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ModelCoders.java x: 68 commits (all time) y: 107 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PCollectionViewTranslation.java x: 41 commits (all time) y: 64 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslation.java x: 40 commits (all time) y: 89 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java x: 79 commits (all time) y: 166 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/TestStreamTranslation.java x: 54 commits (all time) y: 161 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowIntoTranslation.java x: 76 commits (all time) y: 104 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WriteFilesTranslation.java x: 92 commits (all time) y: 259 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyPCollectionFusers.java x: 79 commits (all time) y: 233 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/QueryablePipeline.java x: 101 commits (all time) y: 328 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MonitoringInfoEncodings.java x: 7 commits (all time) y: 100 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPortablePipelineTranslator.java x: 98 commits (all time) y: 486 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java x: 93 commits (all time) y: 77 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineRunner.java x: 66 commits (all time) y: 181 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPortablePipelineTranslator.java x: 129 commits (all time) y: 828 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/utils/FlinkPortableRunnerUtils.java x: 8 commits (all time) y: 27 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperator.java x: 193 commits (all time) y: 1012 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkerHarnessHelper.java x: 42 commits (all time) y: 109 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowParDoFnFactory.java x: 34 commits (all time) y: 317 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingSideInputFetcher.java x: 31 commits (all time) y: 301 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateInternals.java x: 48 commits (all time) y: 1696 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateReader.java x: 40 commits (all time) y: 717 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimerInternals.java x: 54 commits (all time) y: 324 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSources.java x: 45 commits (all time) y: 677 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/RegisterAndProcessBundleOperation.java x: 67 commits (all time) y: 600 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/logging/BeamFnLoggingService.java x: 35 commits (all time) y: 101 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/CreateExecutableStageNodeFunction.java x: 74 commits (all time) y: 480 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/InsertFetchAndFilterStreamingSideInputNodes.java x: 41 commits (all time) y: 129 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/DirectStreamObserver.java x: 25 commits (all time) y: 41 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/GrpcWindmillServer.java x: 76 commits (all time) y: 1378 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/GrpcContextHeaderAccessorProvider.java x: 34 commits (all time) y: 47 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/GrpcFnServer.java x: 48 commits (all time) y: 105 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/ServerFactory.java x: 48 commits (all time) y: 191 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/ArtifactRetrievalService.java x: 33 commits (all time) y: 105 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/ArtifactStagingService.java x: 20 commits (all time) y: 517 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleCheckpointHandlers.java x: 9 commits (all time) y: 106 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClient.java x: 66 commits (all time) y: 136 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClientPoolService.java x: 60 commits (all time) y: 89 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ProcessBundleDescriptors.java x: 110 commits (all time) y: 445 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/GrpcDataService.java x: 64 commits (all time) y: 146 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/ExternalEnvironmentFactory.java x: 19 commits (all time) y: 164 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/provisioning/JobInfo.java x: 36 commits (all time) y: 22 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java x: 60 commits (all time) y: 440 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/translation/PipelineTranslatorUtils.java x: 39 commits (all time) y: 156 lines of code runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/InMemoryJobService.java x: 18 commits (all time) y: 422 lines of code runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobInvocation.java x: 19 commits (all time) y: 217 lines of code runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/PortablePipelineJarCreator.java x: 19 commits (all time) y: 184 lines of code runners/portability/java/src/main/java/org/apache/beam/runners/portability/JobServicePipelineResult.java x: 32 commits (all time) y: 167 lines of code runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableRunner.java x: 40 commits (all time) y: 163 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/WindowAssignTranslator.java x: 27 commits (all time) y: 48 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/GroupByWindowFunction.java x: 16 commits (all time) y: 186 lines of code sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java x: 31 commits (all time) y: 420 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/SocketAddressFactory.java x: 33 commits (all time) y: 35 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataSizeBasedBufferingOutboundObserver.java x: 29 commits (all time) y: 106 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java x: 40 commits (all time) y: 223 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/AddHarnessIdInterceptor.java x: 26 commits (all time) y: 16 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnDataClient.java x: 43 commits (all time) y: 28 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/logging/BeamFnLoggingClient.java x: 84 commits (all time) y: 260 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BeamFnStateGrpcClientCache.java x: 56 commits (all time) y: 111 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java x: 62 commits (all time) y: 432 lines of code sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIOSource.java x: 14 commits (all time) y: 237 lines of code sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/SourceRecordJson.java x: 7 commits (all time) y: 148 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerTransformRegistrar.java x: 9 commits (all time) y: 306 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTransformTranslators.java x: 117 commits (all time) y: 719 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkRunner.java x: 91 commits (all time) y: 133 lines of code sdks/python/apache_beam/internal/gcp/json_value.py x: 55 commits (all time) y: 75 lines of code sdks/python/apache_beam/internal/http_client.py x: 17 commits (all time) y: 23 lines of code sdks/python/apache_beam/internal/metrics/metric.py x: 13 commits (all time) y: 118 lines of code sdks/python/apache_beam/internal/pickler.py x: 100 commits (all time) y: 160 lines of code sdks/python/apache_beam/metrics/cells.py x: 107 commits (all time) y: 284 lines of code sdks/python/apache_beam/metrics/execution.py x: 110 commits (all time) y: 188 lines of code sdks/python/apache_beam/metrics/metric.py x: 60 commits (all time) y: 139 lines of code sdks/python/apache_beam/metrics/metricbase.py x: 58 commits (all time) y: 55 lines of code sdks/python/apache_beam/metrics/monitoring_infos.py x: 53 commits (all time) y: 239 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java x: 172 commits (all time) y: 1125 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java x: 125 commits (all time) y: 715 lines of code sdks/python/apache_beam/io/gcp/bigquery_avro_tools.py x: 10 commits (all time) y: 73 lines of code sdks/python/apache_beam/io/gcp/datastore/v1new/datastoreio.py x: 22 commits (all time) y: 275 lines of code sdks/python/apache_beam/io/gcp/dicomio.py x: 3 commits (all time) y: 260 lines of code sdks/python/apache_beam/io/gcp/experimental/spannerio.py x: 16 commits (all time) y: 616 lines of code sdks/python/apache_beam/io/gcp/gcsfilesystem.py x: 51 commits (all time) y: 151 lines of code sdks/python/apache_beam/io/gcp/gcsio.py x: 128 commits (all time) y: 401 lines of code sdks/python/apache_beam/io/gcp/internal/clients/bigquery/__init__.py x: 12 commits (all time) y: 8 lines of code sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py x: 24 commits (all time) y: 704 lines of code sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_messages.py x: 28 commits (all time) y: 1524 lines of code sdks/python/apache_beam/io/gcp/internal/clients/storage/storage_v1_client.py x: 16 commits (all time) y: 904 lines of code sdks/python/apache_beam/io/gcp/internal/clients/storage/storage_v1_messages.py x: 13 commits (all time) y: 801 lines of code sdks/python/apache_beam/io/gcp/pubsub.py x: 117 commits (all time) y: 286 lines of code sdks/python/apache_beam/io/gcp/spanner.py x: 10 commits (all time) y: 369 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectHelpers.java x: 31 commits (all time) y: 346 lines of code sdks/go/pkg/beam/core/runtime/pipelinex/replace.go x: 15 commits (all time) y: 206 lines of code sdks/go/pkg/beam/options/jobopts/options.go x: 35 commits (all time) y: 98 lines of code sdks/go/pkg/beam/runners/dataflow/dataflow.go x: 123 commits (all time) y: 184 lines of code sdks/go/pkg/beam/runners/dataflow/dataflowlib/job.go x: 41 commits (all time) y: 263 lines of code sdks/python/apache_beam/typehints/native_type_compatibility.py x: 75 commits (all time) y: 210 lines of code sdks/python/apache_beam/typehints/opcodes.py x: 75 commits (all time) y: 253 lines of code sdks/python/apache_beam/typehints/trivial_inference.py x: 75 commits (all time) y: 388 lines of code sdks/python/apache_beam/typehints/typehints.py x: 113 commits (all time) y: 671 lines of code sdks/go/pkg/beam/encoding.go x: 21 commits (all time) y: 245 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineOptions.java x: 100 commits (all time) y: 187 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/PortablePipelineOptions.java x: 65 commits (all time) y: 76 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Reshuffle.java x: 41 commits (all time) y: 94 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkConfiguration.java x: 40 commits (all time) y: 549 lines of code sdks/go/pkg/beam/coder.go x: 73 commits (all time) y: 295 lines of code sdks/go/pkg/beam/core/graph/coder/row.go x: 17 commits (all time) y: 151 lines of code sdks/go/pkg/beam/core/graph/coder/row_decoder.go x: 9 commits (all time) y: 276 lines of code sdks/go/pkg/beam/core/graph/coder/row_encoder.go x: 9 commits (all time) y: 237 lines of code sdks/go/pkg/beam/util/shimx/generate.go x: 15 commits (all time) y: 356 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineOptions.java x: 130 commits (all time) y: 56 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/util/SparkCompat.java x: 22 commits (all time) y: 127 lines of code sdks/python/apache_beam/io/__init__.py x: 38 commits (all time) y: 17 lines of code sdks/python/apache_beam/io/aws/s3io.py x: 23 commits (all time) y: 323 lines of code sdks/python/apache_beam/io/azure/blobstorageio.py x: 4 commits (all time) y: 335 lines of code sdks/python/apache_beam/io/concat_source.py x: 37 commits (all time) y: 170 lines of code sdks/python/apache_beam/io/filebasedsink.py x: 60 commits (all time) y: 287 lines of code sdks/python/apache_beam/io/filebasedsource.py x: 120 commits (all time) y: 250 lines of code sdks/python/apache_beam/io/fileio.py x: 168 commits (all time) y: 439 lines of code sdks/python/apache_beam/io/filesystemio.py x: 45 commits (all time) y: 133 lines of code sdks/python/apache_beam/io/filesystems.py x: 76 commits (all time) y: 132 lines of code sdks/python/apache_beam/io/hadoopfilesystem.py x: 50 commits (all time) y: 260 lines of code sdks/python/apache_beam/io/mongodbio.py x: 50 commits (all time) y: 345 lines of code sdks/python/apache_beam/io/range_trackers.py x: 75 commits (all time) y: 273 lines of code sdks/python/apache_beam/io/restriction_trackers.py x: 62 commits (all time) y: 113 lines of code sdks/python/apache_beam/io/source_test_utils.py x: 66 commits (all time) y: 425 lines of code sdks/python/apache_beam/io/textio.py x: 121 commits (all time) y: 337 lines of code sdks/python/apache_beam/io/tfrecordio.py x: 76 commits (all time) y: 172 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ExpressionConverter.java x: 90 commits (all time) y: 806 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtils.java x: 76 commits (all time) y: 341 lines of code sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/options/AwsModule.java x: 47 commits (all time) y: 311 lines of code sdks/java/build-tools/src/main/resources/beam/suppressions.xml x: 87 commits (all time) y: 82 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/trigger_manager.py x: 1 commits (all time) y: 352 lines of code sdks/python/apache_beam/dataframe/doctests.py x: 51 commits (all time) y: 487 lines of code sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/CassandraIO.java x: 108 commits (all time) y: 888 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSqlCalciteTranslationUtils.java x: 27 commits (all time) y: 297 lines of code sdks/python/apache_beam/io/gcp/bigquery_read_internal.py x: 14 commits (all time) y: 286 lines of code sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/dynamodb/DynamoDBIO.java x: 32 commits (all time) y: 371 lines of code sdks/python/apache_beam/pvalue.py x: 149 commits (all time) y: 350 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java x: 414 commits (all time) y: 1640 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/RetryManager.java x: 2 commits (all time) y: 225 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFinalizeWritesDoFn.java x: 2 commits (all time) y: 139 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java x: 2 commits (all time) y: 163 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowToStorageApiProto.java x: 7 commits (all time) y: 259 lines of code sdks/java/container/license_scripts/pull_licenses_java.py x: 24 commits (all time) y: 254 lines of code sdks/python/apache_beam/coders/typecoders.py x: 81 commits (all time) y: 93 lines of code release/src/main/scripts/mass_comment.py x: 25 commits (all time) y: 109 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamRuleSets.java x: 75 commits (all time) y: 125 lines of code sdks/python/apache_beam/options/value_provider.py x: 51 commits (all time) y: 102 lines of code sdks/python/apache_beam/runners/common.py x: 252 commits (all time) y: 1004 lines of code sdks/python/apache_beam/typehints/decorators.py x: 102 commits (all time) y: 536 lines of code sdks/go/pkg/beam/core/runtime/graphx/schema/logicaltypes.go x: 11 commits (all time) y: 95 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessageToRow.java x: 17 commits (all time) y: 193 lines of code website/www/site/data/io_matrix.yaml x: 20 commits (all time) y: 368 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/SqlTransform.java x: 76 commits (all time) y: 189 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSqlEnv.java x: 119 commits (all time) y: 209 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CalciteQueryPlanner.java x: 43 commits (all time) y: 200 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowMetrics.java x: 92 commits (all time) y: 252 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineJob.java x: 148 commits (all time) y: 380 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineResult.java x: 3 commits (all time) y: 108 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java x: 3 commits (all time) y: 212 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/streaming/DatasetSourceStreaming.java x: 3 commits (all time) y: 187 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/BeamKafkaCSVTable.java x: 37 commits (all time) y: 89 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/AwsModule.java x: 30 commits (all time) y: 267 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HttpHealthcareApiClient.java x: 40 commits (all time) y: 797 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessages.java x: 12 commits (all time) y: 47 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaRecord.java x: 54 commits (all time) y: 90 lines of code sdks/python/apache_beam/coders/observable.py x: 28 commits (all time) y: 10 lines of code sdks/python/apache_beam/coders/slow_stream.py x: 44 commits (all time) y: 113 lines of code sdks/python/apache_beam/coders/stream.pyx x: 29 commits (all time) y: 154 lines of code sdks/python/apache_beam/portability/python_urns.py x: 31 commits (all time) y: 18 lines of code sdks/python/apache_beam/runners/worker/operations.py x: 184 commits (all time) y: 851 lines of code sdks/python/apache_beam/runners/worker/statesampler_fast.pyx x: 43 commits (all time) y: 146 lines of code learning/katas/go/course-remote-info.yaml x: 39 commits (all time) y: 2 lines of code model/fn-execution/src/main/proto/beam_fn_api.proto x: 161 commits (all time) y: 797 lines of code model/job-management/src/main/proto/beam_artifact_api.proto x: 40 commits (all time) y: 198 lines of code model/pipeline/src/main/proto/metrics.proto x: 34 commits (all time) y: 543 lines of code model/pipeline/src/main/proto/standard_window_fns.proto x: 22 commits (all time) y: 98 lines of code ownership/PYTHON_DEPENDENCY_OWNERS.yaml x: 18 commits (all time) y: 55 lines of code release/src/main/groovy/mobilegaming-java-dataflow.groovy x: 12 commits (all time) y: 81 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ModelCoderRegistrar.java x: 67 commits (all time) y: 102 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformMatchers.java x: 84 commits (all time) y: 382 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RehydratedComponents.java x: 55 commits (all time) y: 121 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RunnerPCollectionView.java x: 38 commits (all time) y: 82 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/Timer.java x: 37 commits (all time) y: 157 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/TriggerTranslation.java x: 31 commits (all time) y: 272 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/UnboundedReadFromBoundedSource.java x: 67 commits (all time) y: 402 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyStageFuser.java x: 46 commits (all time) y: 144 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/Networks.java x: 28 commits (all time) y: 190 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/OutputDeduplicator.java x: 47 commits (all time) y: 265 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java x: 119 commits (all time) y: 139 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/GlobalCombineFnRunners.java x: 22 commits (all time) y: 160 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/GroupByKeyViaGroupByKeyOnly.java x: 54 commits (all time) y: 145 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryStateInternals.java x: 79 commits (all time) y: 591 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java x: 85 commits (all time) y: 106 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataUtils.java x: 38 commits (all time) y: 71 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/MergingActiveWindowSet.java x: 57 commits (all time) y: 290 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/OutputAndTimeBoundedSplittableProcessElementInvoker.java x: 112 commits (all time) y: 295 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java x: 54 commits (all time) y: 99 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnContextFactory.java x: 88 commits (all time) y: 464 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnRunner.java x: 116 commits (all time) y: 629 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java x: 78 commits (all time) y: 157 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java x: 242 commits (all time) y: 1033 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/StateTags.java x: 65 commits (all time) y: 253 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/StatefulDoFnRunner.java x: 72 commits (all time) y: 314 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/DefaultMetricResults.java x: 24 commits (all time) y: 34 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterPaneStateMachine.java x: 57 commits (all time) y: 87 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java x: 65 commits (all time) y: 213 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.java x: 66 commits (all time) y: 466 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/BoundedReadEvaluatorFactory.java x: 103 commits (all time) y: 188 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/CloningBundleFactory.java x: 36 commits (all time) y: 69 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/CommittedResult.java x: 67 commits (all time) y: 27 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/CompletionCallback.java x: 43 commits (all time) y: 11 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/CopyOnAccessInMemoryStateInternals.java x: 73 commits (all time) y: 336 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectTransformExecutor.java x: 26 commits (all time) y: 142 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/EvaluationContext.java x: 152 commits (all time) y: 262 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java x: 190 commits (all time) y: 327 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java x: 163 commits (all time) y: 213 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupByKeyOnlyEvaluatorFactory.java x: 82 commits (all time) y: 105 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ImmutabilityCheckingBundleFactory.java x: 64 commits (all time) y: 94 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ImmutableListBundleFactory.java x: 64 commits (all time) y: 134 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/KeyedPValueTrackingVisitor.java x: 62 commits (all time) y: 85 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/MultiStepCombine.java x: 54 commits (all time) y: 419 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java x: 158 commits (all time) y: 256 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoMultiOverrideFactory.java x: 132 commits (all time) y: 246 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/RootProviderRegistry.java x: 52 commits (all time) y: 52 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/SideInputContainer.java x: 59 commits (all time) y: 233 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java x: 127 commits (all time) y: 196 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluatorRegistry.java x: 128 commits (all time) y: 151 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutorServices.java x: 37 commits (all time) y: 116 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformResult.java x: 62 commits (all time) y: 30 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java x: 149 commits (all time) y: 274 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ViewEvaluatorFactory.java x: 98 commits (all time) y: 55 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkCallbackExecutor.java x: 53 commits (all time) y: 134 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java x: 186 commits (all time) y: 1197 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WindowEvaluatorFactory.java x: 84 commits (all time) y: 95 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WriteWithShardingFactory.java x: 107 commits (all time) y: 110 lines of code runners/extensions-java/metrics/src/main/java/org/apache/beam/runners/extensions/metrics/MetricsHttpSink.java x: 38 commits (all time) y: 134 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkExecutionEnvironments.java x: 95 commits (all time) y: 301 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkRunnerResult.java x: 46 commits (all time) y: 50 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPipelineTranslator.java x: 72 commits (all time) y: 289 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java x: 186 commits (all time) y: 1291 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/TestFlinkRunner.java x: 42 commits (all time) y: 53 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunction.java x: 93 commits (all time) y: 322 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkStreamingSideInputHandlerFactory.java x: 21 commits (all time) y: 118 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/ImpulseSourceFunction.java x: 28 commits (all time) y: 63 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SourceInputFormat.java x: 46 commits (all time) y: 117 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SplittableDoFnOperator.java x: 112 commits (all time) y: 153 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java x: 70 commits (all time) y: 95 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapper.java x: 114 commits (all time) y: 368 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java x: 63 commits (all time) y: 676 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java x: 116 commits (all time) y: 1324 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchViewOverrides.java x: 91 commits (all time) y: 913 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/SplittableParDoOverrides.java x: 13 commits (all time) y: 50 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java x: 91 commits (all time) y: 506 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslators.java x: 42 commits (all time) y: 477 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DataflowTemplateJob.java x: 45 commits (all time) y: 45 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java x: 84 commits (all time) y: 171 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PackageUtil.java x: 95 commits (all time) y: 379 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java x: 62 commits (all time) y: 230 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/Structs.java x: 21 commits (all time) y: 285 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/AvroByteReader.java x: 20 commits (all time) y: 142 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchDataflowWorker.java x: 54 commits (all time) y: 310 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContext.java x: 36 commits (all time) y: 419 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java x: 42 commits (all time) y: 669 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/CombineValuesFnFactory.java x: 26 commits (all time) y: 278 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ConcatReader.java x: 22 commits (all time) y: 204 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowElementExecutionTracker.java x: 20 commits (all time) y: 244 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java x: 27 commits (all time) y: 200 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowPortabilityPCollectionView.java x: 19 commits (all time) y: 125 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkProgressUpdater.java x: 25 commits (all time) y: 119 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupingShuffleReader.java x: 33 commits (all time) y: 357 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java x: 21 commits (all time) y: 327 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java x: 25 commits (all time) y: 842 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/MetricTrackingWindmillServerStub.java x: 43 commits (all time) y: 234 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartialGroupByKeyParDoFns.java x: 23 commits (all time) y: 305 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReaderRegistry.java x: 22 commits (all time) y: 78 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SdkHarnessRegistries.java x: 28 commits (all time) y: 202 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SimpleParDoFn.java x: 44 commits (all time) y: 384 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/UngroupedShuffleReader.java x: 20 commits (all time) y: 95 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkItemStatusClient.java x: 42 commits (all time) y: 254 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/counters/CounterFactory.java x: 24 commits (all time) y: 632 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/BeamFnMapTaskExecutor.java x: 62 commits (all time) y: 484 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/ExecutionTimeMonitoringInfoToCounterUpdateTransformer.java x: 17 commits (all time) y: 96 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/DeduceFlattenLocationsFunction.java x: 17 commits (all time) y: 218 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/Nodes.java x: 37 commits (all time) y: 276 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/DataflowWorkerLoggingHandler.java x: 27 commits (all time) y: 231 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/DataflowWorkerLoggingInitializer.java x: 31 commits (all time) y: 180 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/JulHandlerPrintStreamAdapterFactory.java x: 33 commits (all time) y: 350 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java x: 28 commits (all time) y: 417 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingTables.java x: 21 commits (all time) y: 354 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/MapTaskExecutor.java x: 30 commits (all time) y: 132 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/ReadOperation.java x: 28 commits (all time) y: 302 lines of code runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto x: 23 commits (all time) y: 530 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactory.java x: 91 commits (all time) y: 597 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/RemoteBundle.java x: 34 commits (all time) y: 17 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java x: 115 commits (all time) y: 528 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/DAGBuilder.java x: 14 commits (all time) y: 173 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/JetTransformTranslators.java x: 17 commits (all time) y: 370 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java x: 23 commits (all time) y: 231 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/StatefulParDoP.java x: 22 commits (all time) y: 303 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/WindowGroupP.java x: 18 commits (all time) y: 287 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/BoundedSourceSystem.java x: 40 commits (all time) y: 355 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/UnboundedSourceSystem.java x: 45 commits (all time) y: 424 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/GroupByKeyOp.java x: 43 commits (all time) y: 190 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/KeyedInternals.java x: 40 commits (all time) y: 128 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaDoFnRunners.java x: 44 commits (all time) y: 256 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java x: 52 commits (all time) y: 912 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java x: 48 commits (all time) y: 543 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ConfigBuilder.java x: 55 commits (all time) y: 243 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/GroupByKeyTranslator.java x: 37 commits (all time) y: 217 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPipelineTranslator.java x: 44 commits (all time) y: 159 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunnerRegistrar.java x: 56 commits (all time) y: 25 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/TestSparkRunner.java x: 119 commits (all time) y: 99 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/NamedAggregators.java x: 67 commits (all time) y: 49 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/MicrobatchSource.java x: 63 commits (all time) y: 259 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/SourceDStream.java x: 65 commits (all time) y: 150 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/SourceRDD.java x: 90 commits (all time) y: 265 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/SparkUnboundedSource.java x: 84 commits (all time) y: 231 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/MetricsAccumulator.java x: 58 commits (all time) y: 101 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/WithMetricsSupport.java x: 28 commits (all time) y: 130 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkGroupAlsoByWindowViaWindowSet.java x: 104 commits (all time) y: 408 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java x: 63 commits (all time) y: 316 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/StateSpecFunctions.java x: 81 commits (all time) y: 139 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/BoundedDataset.java x: 74 commits (all time) y: 95 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/EvaluationContext.java x: 159 commits (all time) y: 181 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkBatchPortablePipelineTranslator.java x: 57 commits (all time) y: 340 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkContextFactory.java x: 80 commits (all time) y: 66 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkExecutableStageExtractionFunction.java x: 12 commits (all time) y: 24 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkExecutableStageFunction.java x: 43 commits (all time) y: 258 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkStreamingPortablePipelineTranslator.java x: 10 commits (all time) y: 297 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java x: 270 commits (all time) y: 669 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TranslationUtils.java x: 118 commits (all time) y: 260 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/StreamingTransformTranslator.java x: 234 commits (all time) y: 525 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/util/SparkSideInputReader.java x: 75 commits (all time) y: 82 lines of code sdks/go/pkg/beam/beam.shims.go x: 17 commits (all time) y: 272 lines of code sdks/go/pkg/beam/core/graph/coder/coder.go x: 45 commits (all time) y: 303 lines of code sdks/go/pkg/beam/core/graph/fn.go x: 43 commits (all time) y: 796 lines of code sdks/go/pkg/beam/core/metrics/metrics.go x: 29 commits (all time) y: 409 lines of code sdks/go/pkg/beam/core/runtime/exec/coder.go x: 67 commits (all time) y: 840 lines of code sdks/go/pkg/beam/core/runtime/exec/datasource.go x: 88 commits (all time) y: 415 lines of code sdks/go/pkg/beam/core/runtime/exec/plan.go x: 59 commits (all time) y: 157 lines of code sdks/go/pkg/beam/core/runtime/exec/sdf.go x: 20 commits (all time) y: 393 lines of code sdks/go/pkg/beam/core/runtime/graphx/coder.go x: 53 commits (all time) y: 459 lines of code sdks/go/pkg/beam/core/runtime/graphx/serialize.go x: 52 commits (all time) y: 700 lines of code sdks/go/pkg/beam/core/runtime/graphx/translate.go x: 123 commits (all time) y: 856 lines of code sdks/go/pkg/beam/core/runtime/graphx/xlang.go x: 20 commits (all time) y: 202 lines of code sdks/go/pkg/beam/core/runtime/harness/harness.go x: 93 commits (all time) y: 368 lines of code sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go x: 17 commits (all time) y: 135 lines of code sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api.pb.go x: 104 commits (all time) y: 5022 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_artifact_api.pb.go x: 60 commits (all time) y: 1911 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_expansion_api.pb.go x: 20 commits (all time) y: 321 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_job_api.pb.go x: 55 commits (all time) y: 2323 lines of code sdks/go/pkg/beam/model/pipeline_v1/endpoints.pb.go x: 45 commits (all time) y: 201 lines of code sdks/go/pkg/beam/model/pipeline_v1/standard_window_fns.pb.go x: 46 commits (all time) y: 483 lines of code sdks/go/pkg/beam/runners/direct/direct.go x: 55 commits (all time) y: 226 lines of code sdks/go/pkg/beam/runners/session/session.go x: 31 commits (all time) y: 238 lines of code sdks/go/pkg/beam/runners/universal/runnerlib/execute.go x: 33 commits (all time) y: 85 lines of code sdks/go/pkg/beam/runners/universal/universal.go x: 54 commits (all time) y: 70 lines of code sdks/go/pkg/beam/runners/vet/vet.go x: 13 commits (all time) y: 444 lines of code sdks/go/pkg/beam/transforms/stats/quantiles.go x: 3 commits (all time) y: 549 lines of code sdks/go/pkg/beam/util/starcgenx/starcgenx.go x: 29 commits (all time) y: 585 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/annotations/Experimental.java x: 65 commits (all time) y: 38 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AtomicCoder.java x: 35 commits (all time) y: 26 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java x: 103 commits (all time) y: 456 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java x: 227 commits (all time) y: 1030 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java x: 115 commits (all time) y: 583 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java x: 117 commits (all time) y: 191 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/CompressedSource.java x: 131 commits (all time) y: 286 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/Compression.java x: 36 commits (all time) y: 226 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingSource.java x: 77 commits (all time) y: 311 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java x: 215 commits (all time) y: 742 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java x: 88 commits (all time) y: 392 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java x: 107 commits (all time) y: 870 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java x: 133 commits (all time) y: 742 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/TFRecordIO.java x: 100 commits (all time) y: 476 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextIO.java x: 254 commits (all time) y: 689 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java x: 37 commits (all time) y: 14 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptionsFactory.java x: 156 commits (all time) y: 1322 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/ProxyInvocationHandler.java x: 113 commits (all time) y: 528 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/ValueProvider.java x: 86 commits (all time) y: 252 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformOverrideFactory.java x: 41 commits (all time) y: 45 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldAccessDescriptor.java x: 68 commits (all time) y: 444 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoderHelpers.java x: 9 commits (all time) y: 138 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaRegistry.java x: 51 commits (all time) y: 207 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Cast.java x: 32 commits (all time) y: 295 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/CoGroup.java x: 53 commits (all time) y: 522 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Group.java x: 43 commits (all time) y: 741 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Join.java x: 22 commits (all time) y: 180 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/SchemaAggregateFn.java x: 44 commits (all time) y: 285 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AutoValueUtils.java x: 38 commits (all time) y: 255 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java x: 82 commits (all time) y: 1164 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ConvertHelpers.java x: 43 commits (all time) y: 172 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java x: 57 commits (all time) y: 360 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/POJOUtils.java x: 76 commits (all time) y: 440 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ReflectUtils.java x: 46 commits (all time) y: 189 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectByteBuddyHelpers.java x: 12 commits (all time) y: 686 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/state/StateSpecs.java x: 51 commits (all time) y: 540 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/Annotations.java x: 28 commits (all time) y: 23 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/CombineFnTester.java x: 28 commits (all time) y: 113 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SerializableMatchers.java x: 73 commits (all time) y: 452 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SourceTestUtils.java x: 71 commits (all time) y: 644 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java x: 138 commits (all time) y: 370 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateQuantiles.java x: 86 commits (all time) y: 426 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java x: 70 commits (all time) y: 218 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java x: 111 commits (all time) y: 524 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java x: 131 commits (all time) y: 488 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Distinct.java x: 59 commits (all time) y: 120 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java x: 254 commits (all time) y: 273 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupIntoBatches.java x: 74 commits (all time) y: 241 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Latest.java x: 63 commits (all time) y: 110 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java x: 251 commits (all time) y: 531 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Partition.java x: 62 commits (all time) y: 120 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PeriodicSequence.java x: 20 commits (all time) y: 161 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Regex.java x: 49 commits (all time) y: 426 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Reify.java x: 31 commits (all time) y: 209 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Top.java x: 80 commits (all time) y: 263 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java x: 81 commits (all time) y: 881 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithKeys.java x: 64 commits (all time) y: 63 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/display/DisplayData.java x: 116 commits (all time) y: 506 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java x: 82 commits (all time) y: 285 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterPane.java x: 54 commits (all time) y: 56 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java x: 39 commits (all time) y: 37 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java x: 86 commits (all time) y: 110 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Never.java x: 48 commits (all time) y: 26 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java x: 144 commits (all time) y: 241 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/ApiSurface.java x: 77 commits (all time) y: 522 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/ReleaseInfo.java x: 50 commits (all time) y: 74 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJson.java x: 38 commits (all time) y: 426 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableUtils.java x: 44 commits (all time) y: 146 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollection.java x: 97 commits (all time) y: 271 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionTuple.java x: 70 commits (all time) y: 168 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/PValue.java x: 50 commits (all time) y: 16 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/TypeDescriptors.java x: 71 commits (all time) y: 134 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowingStrategy.java x: 41 commits (all time) y: 342 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/Join.java x: 27 commits (all time) y: 248 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java x: 30 commits (all time) y: 505 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java x: 34 commits (all time) y: 465 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/GcpOptions.java x: 63 commits (all time) y: 326 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsFileSystem.java x: 60 commits (all time) y: 231 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java x: 28 commits (all time) y: 619 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java x: 18 commits (all time) y: 406 lines of code sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/DLPInspectText.java x: 15 commits (all time) y: 147 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoByteBuddyUtils.java x: 31 commits (all time) y: 942 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java x: 51 commits (all time) y: 196 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDynamicMessageSchema.java x: 17 commits (all time) y: 650 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/BeamSqlCli.java x: 65 commits (all time) y: 50 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteTable.java x: 57 commits (all time) y: 110 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ScalarFunctionImpl.java x: 33 commits (all time) y: 162 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TableResolutionUtils.java x: 15 commits (all time) y: 117 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPLiteral.java x: 16 commits (all time) y: 315 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/nfa/NFA.java x: 10 commits (all time) y: 640 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamAggregationRel.java x: 124 commits (all time) y: 296 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java x: 95 commits (all time) y: 370 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMatchRel.java x: 30 commits (all time) y: 375 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSortRel.java x: 95 commits (all time) y: 282 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamIOPushDownRule.java x: 35 commits (all time) y: 224 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamBuiltinAggregations.java x: 80 commits (all time) y: 406 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamJoinTransforms.java x: 74 commits (all time) y: 148 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BeamBigQuerySqlDialect.java x: 36 commits (all time) y: 346 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BigQueryTable.java x: 68 commits (all time) y: 210 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigtable/BigtableTable.java x: 11 commits (all time) y: 189 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTable.java x: 39 commits (all time) y: 361 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/DateTimeUtils.java x: 26 commits (all time) y: 164 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlOperators.java x: 36 commits (all time) y: 242 lines of code sdks/java/extensions/zetasketch/src/main/java/org/apache/beam/sdk/extensions/zetasketch/ApproximateCountDistinct.java x: 8 commits (all time) y: 165 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/BeamFnDataReadRunner.java x: 99 commits (all time) y: 272 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/BeamFnDataWriteRunner.java x: 91 commits (all time) y: 140 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/MapFnRunners.java x: 49 commits (all time) y: 148 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PTransformRunnerFactory.java x: 50 commits (all time) y: 52 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java x: 21 commits (all time) y: 395 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/WindowMappingFnRunner.java x: 41 commits (all time) y: 38 lines of code sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3FileSystem.java x: 65 commits (all time) y: 521 lines of code sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sns/SnsIO.java x: 31 commits (all time) y: 231 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/SimplifiedKinesisClient.java x: 11 commits (all time) y: 202 lines of code sdks/java/io/amqp/src/main/java/org/apache/beam/sdk/io/amqp/AmqpIO.java x: 44 commits (all time) y: 231 lines of code sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/ClickHouseIO.java x: 42 commits (all time) y: 300 lines of code sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/TableSchema.java x: 30 commits (all time) y: 241 lines of code sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIO.java x: 13 commits (all time) y: 408 lines of code sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java x: 4 commits (all time) y: 199 lines of code sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/KafkaSourceConsumerFn.java x: 4 commits (all time) y: 255 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProto.java x: 3 commits (all time) y: 278 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java x: 38 commits (all time) y: 110 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageStreamSource.java x: 48 commits (all time) y: 292 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/DynamicDestinations.java x: 52 commits (all time) y: 84 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/DynamicDestinationsHelpers.java x: 56 commits (all time) y: 328 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StreamingWriteTables.java x: 57 commits (all time) y: 308 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TestBigQuery.java x: 42 commits (all time) y: 284 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteTables.java x: 122 commits (all time) y: 391 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableConfig.java x: 41 commits (all time) y: 170 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java x: 219 commits (all time) y: 815 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceImpl.java x: 87 commits (all time) y: 217 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java x: 144 commits (all time) y: 903 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java x: 17 commits (all time) y: 423 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java x: 50 commits (all time) y: 294 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java x: 125 commits (all time) y: 671 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubJsonClient.java x: 64 commits (all time) y: 279 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubTestClient.java x: 44 commits (all time) y: 334 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsub.java x: 62 commits (all time) y: 315 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java x: 131 commits (all time) y: 1044 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/StructUtils.java x: 6 commits (all time) y: 349 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/Transaction.java x: 25 commits (all time) y: 15 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeJobService.java x: 23 commits (all time) y: 478 lines of code sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java x: 38 commits (all time) y: 1244 lines of code sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java x: 84 commits (all time) y: 525 lines of code sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/HCatalogIO.java x: 49 commits (all time) y: 402 lines of code sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/InfluxDbIO.java x: 14 commits (all time) y: 509 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java x: 25 commits (all time) y: 215 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/LogicalTypes.java x: 24 commits (all time) y: 207 lines of code sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java x: 125 commits (all time) y: 418 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCommitOffset.java x: 12 commits (all time) y: 104 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaExactlyOnceSink.java x: 38 commits (all time) y: 513 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java x: 74 commits (all time) y: 544 lines of code sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisIO.java x: 107 commits (all time) y: 421 lines of code sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisReader.java x: 69 commits (all time) y: 156 lines of code sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardCheckpoint.java x: 37 commits (all time) y: 119 lines of code sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java x: 52 commits (all time) y: 237 lines of code sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbGridFSIO.java x: 96 commits (all time) y: 477 lines of code sdks/java/io/rabbitmq/src/main/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqIO.java x: 42 commits (all time) y: 449 lines of code sdks/java/io/rabbitmq/src/main/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqMessage.java x: 27 commits (all time) y: 265 lines of code sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeIO.java x: 24 commits (all time) y: 1150 lines of code sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/SnowflakeBatchServiceImpl.java x: 13 commits (all time) y: 242 lines of code sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr/SolrIO.java x: 50 commits (all time) y: 432 lines of code sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/HttpEventPublisher.java x: 13 commits (all time) y: 185 lines of code sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/ThriftSchema.java x: 7 commits (all time) y: 298 lines of code sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/JAXBCoder.java x: 41 commits (all time) y: 151 lines of code sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/XmlIO.java x: 73 commits (all time) y: 363 lines of code sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/XmlSource.java x: 36 commits (all time) y: 278 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/Main.java x: 38 commits (all time) y: 396 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkOptions.java x: 40 commits (all time) y: 334 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkUtils.java x: 40 commits (all time) y: 571 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query10.java x: 33 commits (all time) y: 312 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query3.java x: 20 commits (all time) y: 181 lines of code sdks/java/testing/watermarks/src/main/java/org/apache/beam/sdk/testing/watermarks/WatermarkLatency.java x: 6 commits (all time) y: 180 lines of code sdks/python/apache_beam/runners/common.pxd x: 111 commits (all time) y: 98 lines of code sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/inspector/InspectableView.tsx x: 12 commits (all time) y: 172 lines of code sdks/python/apache_beam/runners/worker/bundle_processor.py x: 290 commits (all time) y: 1487 lines of code sdks/python/apache_beam/runners/worker/data_plane.py x: 124 commits (all time) y: 467 lines of code sdks/python/apache_beam/runners/worker/opcounters.py x: 61 commits (all time) y: 172 lines of code website/www/site/assets/scss/_calendar.scss x: 7 commits (all time) y: 230 lines of code website/www/site/assets/scss/_capability-matrix.scss x: 5 commits (all time) y: 317 lines of code website/www/site/assets/scss/_lists.scss x: 9 commits (all time) y: 281 lines of code website/www/site/assets/scss/_syntax-highlighting.scss x: 9 commits (all time) y: 335 lines of code website/www/site/assets/scss/_typography.scss x: 9 commits (all time) y: 170 lines of code website/www/site/assets/scss/bootstrap/_navbar.scss x: 7 commits (all time) y: 480 lines of code website/www/site/assets/scss/capability-matrix.scss x: 7 commits (all time) y: 279 lines of code website/www/site/data/capability_matrix.yaml x: 24 commits (all time) y: 1669 lines of code website/www/site/data/capability_matrix_snapshot.yaml x: 11 commits (all time) y: 733 lines of code sdks/go/pkg/beam/transforms/stats/stats.shims.go x: 22 commits (all time) y: 437 lines of code ownership/JAVA_DEPENDENCY_OWNERS.yaml x: 23 commits (all time) y: 803 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/PipelineValidator.java x: 35 commits (all time) y: 260 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/PushbackSideInputDoFnRunner.java x: 53 commits (all time) y: 20 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/TimerInternals.java x: 51 commits (all time) y: 169 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluatorFactory.java x: 53 commits (all time) y: 12 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java x: 55 commits (all time) y: 211 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/ParDoP.java x: 6 commits (all time) y: 162 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/GroupCombineFunctions.java x: 109 commits (all time) y: 124 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java x: 128 commits (all time) y: 125 lines of code sdks/go/pkg/beam/artifact/stage.go x: 37 commits (all time) y: 196 lines of code sdks/go/pkg/beam/core/funcx/fn.go x: 23 commits (all time) y: 403 lines of code sdks/go/pkg/beam/core/runtime/exec/combine.go x: 56 commits (all time) y: 378 lines of code sdks/go/pkg/beam/core/runtime/exec/translate.go x: 86 commits (all time) y: 494 lines of code sdks/go/pkg/beam/core/runtime/harness/datamgr.go x: 58 commits (all time) y: 399 lines of code sdks/go/pkg/beam/core/runtime/harness/session.go x: 29 commits (all time) y: 163 lines of code sdks/go/pkg/beam/core/runtime/harness/statemgr.go x: 26 commits (all time) y: 331 lines of code sdks/go/pkg/beam/testing/passert/passert.shims.go x: 16 commits (all time) y: 455 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java x: 94 commits (all time) y: 147 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Count.java x: 73 commits (all time) y: 115 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterEach.java x: 57 commits (all time) y: 41 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/DefaultTrigger.java x: 38 commits (all time) y: 30 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowedValue.java x: 94 commits (all time) y: 614 lines of code sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/CloudVision.java x: 6 commits (all time) y: 139 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamCostModel.java x: 12 commits (all time) y: 183 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamPCollectionTable.java x: 46 commits (all time) y: 36 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryQuerySource.java x: 68 commits (all time) y: 56 lines of code sdks/python/gen_protos.py x: 100 commits (all time) y: 279 lines of code website/www/site/assets/scss/bootstrap/_forms.scss x: 2 commits (all time) y: 391 lines of code website/www/site/static/js/bootstrap/modal.js x: 2 commits (all time) y: 245 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamIOSourceRel.java x: 70 commits (all time) y: 109 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CalciteConnectionWrapper.java x: 5 commits (all time) y: 301 lines of code sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystem.java x: 53 commits (all time) y: 298 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRegistrar.java x: 44 commits (all time) y: 24 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/OrderedCode.java x: 13 commits (all time) y: 388 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/SparkRunnerStreamingContextFactory.java x: 69 commits (all time) y: 76 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteArrayCoder.java x: 46 commits (all time) y: 86 lines of code sdks/java/extensions/join-library/src/main/java/org/apache/beam/sdk/extensions/joinlibrary/Join.java x: 34 commits (all time) y: 280 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/OrderedCode.java x: 25 commits (all time) y: 450 lines of code sdks/go/pkg/beam/core/graph/bind.go x: 19 commits (all time) y: 235 lines of code sdks/go/pkg/beam/x/debug/debug.shims.go x: 12 commits (all time) y: 303 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Filter.java x: 57 commits (all time) y: 66 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectGBKIntoKeyedWorkItemsOverrideFactory.java x: 57 commits (all time) y: 27 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/PubsubHelper.java x: 4 commits (all time) y: 158 lines of code sdks/go/pkg/beam/core/runtime/exec/fn_arity.go x: 4 commits (all time) y: 190 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutor.java x: 68 commits (all time) y: 2 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/callers.go x: 6 commits (all time) y: 470 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/decoders.go x: 6 commits (all time) y: 1856 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/encoders.go x: 6 commits (all time) y: 1772 lines of code sdks/go/pkg/beam/core/util/reflectx/calls.go x: 8 commits (all time) y: 1058 lines of code sdks/java/build-tools/src/main/resources/beam/beam-codestyle.xml x: 4 commits (all time) y: 313 lines of code
5022.0
lines of code
  min: 1.0
  average: 103.38
  25th percentile: 11.0
  median: 39.0
  75th percentile: 108.0
  max: 5022.0
0 892.0
commits (all time)
min: 1.0 | average: 23.01 | 25th percentile: 5.0 | median: 11.0 | 75th percentile: 27.0 | max: 892.0

File Size vs. Contributors (all time): 4821 points

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSideInputReader.java x: 24 contributors (all time) y: 772 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java x: 53 contributors (all time) y: 1332 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java x: 45 contributors (all time) y: 361 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java x: 29 contributors (all time) y: 996 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/UnboundedEventSource.java x: 11 contributors (all time) y: 239 lines of code sdks/python/apache_beam/ml/gcp/recommendations_ai.py x: 1 contributors (all time) y: 359 lines of code sdks/python/apache_beam/ml/gcp/recommendations_ai_test_it.py x: 1 contributors (all time) y: 63 lines of code sdks/python/setup.py x: 122 contributors (all time) y: 246 lines of code sdks/python/apache_beam/pipeline.py x: 85 contributors (all time) y: 803 lines of code sdks/python/apache_beam/transforms/external.py x: 32 contributors (all time) y: 349 lines of code sdks/python/apache_beam/dataframe/frames.py x: 15 contributors (all time) y: 2272 lines of code sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet/ParquetIO.java x: 37 contributors (all time) y: 898 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java x: 66 contributors (all time) y: 1016 lines of code sdks/go/pkg/beam/core/runtime/xlangx/payload.go x: 1 contributors (all time) y: 38 lines of code sdks/go/pkg/beam/xlang.go x: 10 contributors (all time) y: 88 lines of code sdks/go/pkg/beam/core/runtime/graphx/v1/gen.go x: 7 contributors (all time) y: 1 lines of code sdks/go/pkg/beam/core/runtime/graphx/v1/v1.pb.go x: 10 contributors (all time) y: 1503 lines of code sdks/go/pkg/beam/core/runtime/graphx/v1/v1.proto x: 10 contributors (all time) y: 213 lines of code sdks/go/pkg/beam/model/fnexecution_v1/beam_provision_api.pb.go x: 42 contributors (all time) y: 430 lines of code sdks/go/pkg/beam/model/pipeline_v1/metrics.pb.go x: 21 contributors (all time) y: 1119 lines of code sdks/go/pkg/beam/model/pipeline_v1/schema.pb.go x: 6 contributors (all time) y: 1614 lines of code website/www/site/config.toml x: 22 contributors (all time) y: 89 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy x: 153 contributors (all time) y: 1680 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/QueueingBeamFnDataClient.java x: 25 contributors (all time) y: 203 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java x: 36 contributors (all time) y: 493 lines of code sdks/go/pkg/beam/core/runtime/graphx/schema/schema.go x: 8 contributors (all time) y: 610 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateBackedIterable.java x: 9 contributors (all time) y: 164 lines of code sdks/python/apache_beam/version.py x: 65 contributors (all time) y: 1 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryTimerInternals.java x: 24 contributors (all time) y: 242 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/Row.java x: 49 contributors (all time) y: 529 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/RowUtils.java x: 14 contributors (all time) y: 506 lines of code sdks/python/apache_beam/ml/gcp/naturallanguageml_test_it.py x: 4 contributors (all time) y: 40 lines of code sdks/python/apache_beam/ml/gcp/videointelligenceml_test_it.py x: 5 contributors (all time) y: 42 lines of code sdks/python/conftest.py x: 13 contributors (all time) y: 17 lines of code model/pipeline/src/main/proto/schema.proto x: 13 contributors (all time) y: 148 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RowCoderCloudObjectTranslator.java x: 1 contributors (all time) y: 52 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/SchemaCoderCloudObjectTranslator.java x: 17 contributors (all time) y: 95 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java x: 36 contributors (all time) y: 43 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoderGenerator.java x: 34 contributors (all time) y: 316 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java x: 50 contributors (all time) y: 984 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java x: 27 contributors (all time) y: 187 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaTranslation.java x: 18 contributors (all time) y: 457 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamSqlOutputToConsoleFn.java x: 10 contributors (all time) y: 14 lines of code sdks/python/apache_beam/runners/dataflow/__init__.py x: 11 contributors (all time) y: 2 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline.py x: 13 contributors (all time) y: 132 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline.py x: 13 contributors (all time) y: 62 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py x: 39 contributors (all time) y: 211 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_runner.py x: 93 contributors (all time) y: 1152 lines of code sdks/python/apache_beam/runners/dataflow/internal/__init__.py x: 8 contributors (all time) y: 1 lines of code sdks/python/apache_beam/runners/dataflow/internal/apiclient.py x: 91 contributors (all time) y: 918 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/cloudbuild/__init__.py x: 5 contributors (all time) y: 8 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/__init__.py x: 12 contributors (all time) y: 8 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py x: 29 contributors (all time) y: 1016 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py x: 36 contributors (all time) y: 2067 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/message_matchers.py x: 17 contributors (all time) y: 65 lines of code sdks/python/apache_beam/runners/dataflow/internal/names.py x: 63 contributors (all time) y: 68 lines of code sdks/python/apache_beam/runners/dataflow/native_io/iobase.py x: 26 contributors (all time) y: 144 lines of code sdks/python/apache_beam/runners/dataflow/ptransform_overrides.py x: 37 contributors (all time) y: 211 lines of code sdks/python/apache_beam/runners/interactive/augmented_pipeline.py x: 3 contributors (all time) y: 73 lines of code sdks/python/apache_beam/runners/interactive/background_caching_job.py x: 27 contributors (all time) y: 164 lines of code sdks/python/apache_beam/runners/interactive/cache_manager.py x: 35 contributors (all time) y: 158 lines of code sdks/python/apache_beam/runners/interactive/caching/__init__.py x: 4 contributors (all time) y: 1 lines of code sdks/python/apache_beam/runners/interactive/caching/cacheable.py x: 3 contributors (all time) y: 40 lines of code sdks/python/apache_beam/runners/interactive/caching/read_cache.py x: 3 contributors (all time) y: 84 lines of code sdks/python/apache_beam/runners/interactive/caching/streaming_cache.py x: 20 contributors (all time) y: 286 lines of code sdks/python/apache_beam/runners/interactive/caching/write_cache.py x: 3 contributors (all time) y: 116 lines of code sdks/python/apache_beam/runners/interactive/display/display_manager.py x: 19 contributors (all time) y: 107 lines of code sdks/python/apache_beam/runners/interactive/display/interactive_pipeline_graph.py x: 13 contributors (all time) y: 87 lines of code sdks/python/apache_beam/runners/interactive/display/pcoll_visualization.py x: 25 contributors (all time) y: 244 lines of code sdks/python/apache_beam/runners/interactive/display/pipeline_graph.py x: 25 contributors (all time) y: 149 lines of code sdks/python/apache_beam/runners/interactive/display/pipeline_graph_renderer.py x: 18 contributors (all time) y: 55 lines of code sdks/python/apache_beam/runners/interactive/interactive_beam.py x: 26 contributors (all time) y: 243 lines of code sdks/python/apache_beam/runners/interactive/interactive_environment.py x: 32 contributors (all time) y: 305 lines of code sdks/python/apache_beam/runners/interactive/interactive_runner.py x: 38 contributors (all time) y: 133 lines of code sdks/python/apache_beam/runners/interactive/messaging/interactive_environment_inspector.py x: 8 contributors (all time) y: 88 lines of code sdks/python/apache_beam/runners/interactive/options/capture_control.py x: 11 contributors (all time) y: 31 lines of code sdks/python/apache_beam/runners/interactive/options/capture_limiters.py x: 14 contributors (all time) y: 67 lines of code sdks/python/apache_beam/runners/interactive/pipeline_fragment.py x: 17 contributors (all time) y: 143 lines of code sdks/python/apache_beam/runners/interactive/pipeline_instrument.py x: 30 contributors (all time) y: 493 lines of code sdks/python/apache_beam/runners/interactive/recording_manager.py x: 15 contributors (all time) y: 259 lines of code sdks/python/apache_beam/runners/interactive/testing/integration/notebook_executor.py x: 9 contributors (all time) y: 103 lines of code sdks/python/apache_beam/runners/interactive/testing/integration/screen_diff.py x: 11 contributors (all time) y: 141 lines of code sdks/python/apache_beam/runners/interactive/utils.py x: 16 contributors (all time) y: 146 lines of code model/pipeline/src/main/proto/beam_runner_api.proto x: 71 contributors (all time) y: 1567 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/resources/PipelineResources.java x: 9 contributors (all time) y: 88 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/ZipFiles.java x: 31 contributors (all time) y: 155 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java x: 60 contributors (all time) y: 2053 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java x: 41 contributors (all time) y: 650 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateCache.java x: 37 contributors (all time) y: 288 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query19.sql x: 4 contributors (all time) y: 22 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query62.sql x: 5 contributors (all time) y: 32 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query8.sql x: 4 contributors (all time) y: 105 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query85.sql x: 4 contributors (all time) y: 81 lines of code runners/portability/java/src/main/java/org/apache/beam/runners/portability/ExternalWorkerService.java x: 21 contributors (all time) y: 68 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/WindowFn.java x: 15 contributors (all time) y: 45 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java x: 75 contributors (all time) y: 1005 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/External.java x: 26 contributors (all time) y: 326 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PTransformTranslation.java x: 59 contributors (all time) y: 386 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ParDoTranslation.java x: 58 contributors (all time) y: 684 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SdkComponents.java x: 48 contributors (all time) y: 267 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowingStrategyTranslation.java x: 43 contributors (all time) y: 322 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PropertyNames.java x: 28 contributors (all time) y: 54 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/Pipeline.java x: 45 contributors (all time) y: 433 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/runners/AppliedPTransform.java x: 19 contributors (all time) y: 47 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java x: 32 contributors (all time) y: 392 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PTransform.java x: 25 contributors (all time) y: 106 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/ResourceHint.java x: 3 contributors (all time) y: 12 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/ResourceHints.java x: 3 contributors (all time) y: 219 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/ResourceHintsOptions.java x: 3 contributors (all time) y: 21 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/package-info.java x: 2 contributors (all time) y: 1 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowClient.java x: 16 contributors (all time) y: 122 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java x: 101 contributors (all time) y: 1751 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TestDataflowRunner.java x: 26 contributors (all time) y: 289 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClient.java x: 25 contributors (all time) y: 190 lines of code model/fn-execution/src/main/proto/beam_provision_api.proto x: 24 contributors (all time) y: 71 lines of code sdks/java/container/boot.go x: 30 contributors (all time) y: 129 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateSampler.java x: 15 contributors (all time) y: 115 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/ExperimentalOptions.java x: 23 contributors (all time) y: 54 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java x: 54 contributors (all time) y: 255 lines of code sdks/go/pkg/beam/runners/universal/runnerlib/stage.go x: 17 contributors (all time) y: 123 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlAnalyzer.java x: 21 contributors (all time) y: 133 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlOperatorMappingTable.java x: 12 contributors (all time) y: 72 lines of code sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java x: 46 contributors (all time) y: 399 lines of code sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java x: 39 contributors (all time) y: 476 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ParDoTranslatorBatch.java x: 3 contributors (all time) y: 200 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/MultiOutputCoder.java x: 2 contributors (all time) y: 55 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/aggregators/AggregatorsAccumulator.java x: 28 contributors (all time) y: 97 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkCombineFn.java x: 13 contributors (all time) y: 656 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchStatefulParDoOverrides.java x: 28 contributors (all time) y: 222 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TransformTranslator.java x: 32 contributors (all time) y: 57 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DefaultCoderCloudObjectTranslatorRegistrar.java x: 27 contributors (all time) y: 109 lines of code sdks/python/apache_beam/runners/direct/bundle_factory.py x: 29 contributors (all time) y: 98 lines of code sdks/python/apache_beam/runners/direct/clock.py x: 22 contributors (all time) y: 17 lines of code sdks/python/apache_beam/runners/direct/consumer_tracking_pipeline_visitor.py x: 21 contributors (all time) y: 33 lines of code sdks/python/apache_beam/runners/direct/direct_metrics.py x: 24 contributors (all time) y: 84 lines of code sdks/python/apache_beam/runners/direct/direct_runner.py x: 59 contributors (all time) y: 401 lines of code sdks/python/apache_beam/runners/direct/direct_userstate.py x: 27 contributors (all time) y: 239 lines of code sdks/python/apache_beam/runners/direct/evaluation_context.py x: 42 contributors (all time) y: 258 lines of code sdks/python/apache_beam/runners/direct/executor.py x: 44 contributors (all time) y: 514 lines of code sdks/python/apache_beam/runners/direct/helper_transforms.py x: 31 contributors (all time) y: 72 lines of code sdks/python/apache_beam/runners/direct/sdf_direct_runner.py x: 35 contributors (all time) y: 338 lines of code sdks/python/apache_beam/runners/direct/transform_evaluator.py x: 63 contributors (all time) y: 898 lines of code sdks/python/apache_beam/runners/direct/util.py x: 27 contributors (all time) y: 48 lines of code sdks/python/apache_beam/runners/direct/watermark_manager.py x: 33 contributors (all time) y: 219 lines of code sdks/python/apache_beam/runners/job/__init__.py x: 6 contributors (all time) y: 1 lines of code sdks/python/apache_beam/runners/job/manager.py x: 16 contributors (all time) y: 19 lines of code sdks/python/apache_beam/runners/job/utils.py x: 18 contributors (all time) y: 12 lines of code sdks/python/apache_beam/runners/portability/abstract_job_service.py x: 21 contributors (all time) y: 258 lines of code sdks/python/apache_beam/runners/portability/artifact_service.py x: 28 contributors (all time) y: 271 lines of code sdks/python/apache_beam/runners/portability/expansion_service.py x: 20 contributors (all time) y: 66 lines of code sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py x: 19 contributors (all time) y: 182 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py x: 24 contributors (all time) y: 715 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py x: 31 contributors (all time) y: 831 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/translations.py x: 24 contributors (all time) y: 1512 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py x: 25 contributors (all time) y: 818 lines of code sdks/python/apache_beam/runners/portability/job_server.py x: 28 contributors (all time) y: 104 lines of code sdks/python/apache_beam/runners/portability/local_job_service.py x: 46 contributors (all time) y: 304 lines of code sdks/python/apache_beam/runners/portability/local_job_service_main.py x: 31 contributors (all time) y: 126 lines of code sdks/python/apache_beam/runners/portability/portable_metrics.py x: 13 contributors (all time) y: 33 lines of code sdks/python/apache_beam/runners/portability/portable_runner.py x: 68 contributors (all time) y: 457 lines of code sdks/python/apache_beam/runners/portability/sdk_container_builder.py x: 14 contributors (all time) y: 266 lines of code sdks/python/apache_beam/runners/portability/spark_runner.py x: 19 contributors (all time) y: 67 lines of code sdks/python/apache_beam/runners/portability/spark_uber_jar_job_server.py x: 16 contributors (all time) y: 199 lines of code sdks/python/apache_beam/runners/portability/stager.py x: 49 contributors (all time) y: 510 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java x: 76 contributors (all time) y: 1333 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java x: 4 contributors (all time) y: 133 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIO.java x: 22 contributors (all time) y: 1023 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BagUserState.java x: 27 contributors (all time) y: 98 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/IterableSideInput.java x: 9 contributors (all time) y: 43 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/MultimapSideInput.java x: 26 contributors (all time) y: 69 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateFetchingIterators.java x: 26 contributors (all time) y: 167 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/PCollectionConsumerRegistry.java x: 29 contributors (all time) y: 284 lines of code sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbIO.java x: 47 contributors (all time) y: 587 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunnerInfo.java x: 20 contributors (all time) y: 100 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineWorkerPoolOptions.java x: 37 contributors (all time) y: 105 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCatalog.java x: 3 contributors (all time) y: 470 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroUtils.java x: 40 contributors (all time) y: 993 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/BeamFnControlClient.java x: 36 contributors (all time) y: 129 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineRunner.java x: 41 contributors (all time) y: 227 lines of code sdks/python/apache_beam/options/pipeline_options.py x: 86 contributors (all time) y: 1237 lines of code sdks/python/apache_beam/transforms/resources.py x: 1 contributors (all time) y: 137 lines of code sdks/python/apache_beam/transforms/__init__.py x: 17 contributors (all time) y: 11 lines of code sdks/python/apache_beam/transforms/combiners.py x: 57 contributors (all time) y: 661 lines of code sdks/python/apache_beam/transforms/core.py x: 90 contributors (all time) y: 1571 lines of code sdks/python/apache_beam/transforms/cy_combiners.py x: 35 contributors (all time) y: 253 lines of code sdks/python/apache_beam/transforms/deduplicate.py x: 5 contributors (all time) y: 77 lines of code sdks/python/apache_beam/transforms/display.py x: 43 contributors (all time) y: 199 lines of code sdks/python/apache_beam/transforms/environments.py x: 48 contributors (all time) y: 597 lines of code sdks/python/apache_beam/transforms/external_java.py x: 12 contributors (all time) y: 120 lines of code sdks/python/apache_beam/transforms/periodicsequence.py x: 7 contributors (all time) y: 128 lines of code sdks/python/apache_beam/transforms/ptransform.py x: 67 contributors (all time) y: 623 lines of code sdks/python/apache_beam/transforms/sideinputs.py x: 25 contributors (all time) y: 57 lines of code sdks/python/apache_beam/transforms/stats.py x: 27 contributors (all time) y: 548 lines of code sdks/python/apache_beam/transforms/trigger.py x: 63 contributors (all time) y: 1053 lines of code sdks/python/apache_beam/transforms/util.py x: 70 contributors (all time) y: 754 lines of code sdks/python/apache_beam/transforms/window.py x: 51 contributors (all time) y: 330 lines of code sdks/python/apache_beam/io/gcp/bigquery_tools.py x: 51 contributors (all time) y: 1162 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PublisherCache.java x: 12 contributors (all time) y: 49 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PublisherOptions.java x: 14 contributors (all time) y: 25 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/Publishers.java x: 8 contributors (all time) y: 40 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteSink.java x: 14 contributors (all time) y: 119 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscribeTransform.java x: 7 contributors (all time) y: 114 lines of code sdks/python/apache_beam/options/pipeline_options_validator.py x: 34 contributors (all time) y: 262 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java x: 60 contributors (all time) y: 593 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchedStreamingWrite.java x: 8 contributors (all time) y: 317 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/AggregateScanConverter.java x: 20 contributors (all time) y: 201 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java x: 53 contributors (all time) y: 243 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/CalcRelSplitter.java x: 1 contributors (all time) y: 571 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCalcSplittingRule.java x: 1 contributors (all time) y: 16 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/BeamSqlEnvRunner.java x: 6 contributors (all time) y: 153 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java x: 6 contributors (all time) y: 131 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query14a.sql x: 2 contributors (all time) y: 78 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query14b.sql x: 2 contributors (all time) y: 94 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query39a.sql x: 2 contributors (all time) y: 24 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query58.sql x: 4 contributors (all time) y: 62 lines of code sdks/java/testing/tpcds/src/main/resources/queries/query66.sql x: 4 contributors (all time) y: 219 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobServerDriver.java x: 30 contributors (all time) y: 62 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineRunner.java x: 17 contributors (all time) y: 39 lines of code sdks/python/apache_beam/portability/common_urns.py x: 39 contributors (all time) y: 41 lines of code sdks/python/apache_beam/runners/pipeline_context.py x: 48 contributors (all time) y: 210 lines of code sdks/java/container/license_scripts/dep_urls_java.yaml x: 19 contributors (all time) y: 27 lines of code sdks/python/apache_beam/runners/worker/sdk_worker_main.py x: 50 contributors (all time) y: 168 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java x: 63 contributors (all time) y: 697 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProvider.java x: 34 contributors (all time) y: 87 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java x: 68 contributors (all time) y: 1218 lines of code build.gradle.kts x: 14 contributors (all time) y: 293 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java x: 52 contributors (all time) y: 426 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/SimpleExecutionState.java x: 23 contributors (all time) y: 113 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/SimpleStateRegistry.java x: 21 contributors (all time) y: 48 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironment.java x: 43 contributors (all time) y: 81 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/data/BeamFnDataGrpcService.java x: 30 contributors (all time) y: 187 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/EmbeddedEnvironmentFactory.java x: 25 contributors (all time) y: 138 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingRunner.java x: 5 contributors (all time) y: 130 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunner.java x: 55 contributors (all time) y: 337 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/HistogramData.java x: 5 contributors (all time) y: 179 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/ReflectHelpers.java x: 38 contributors (all time) y: 230 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamCalcRel.java x: 43 contributors (all time) y: 660 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver.java x: 25 contributors (all time) y: 65 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/CompletableFutureInboundDataClient.java x: 16 contributors (all time) y: 40 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/InboundDataClient.java x: 15 contributors (all time) y: 10 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnDataGrpcClient.java x: 39 contributors (all time) y: 69 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnTimerGrpcClient.java x: 6 contributors (all time) y: 68 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServices.java x: 56 contributors (all time) y: 107 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java x: 4 contributors (all time) y: 262 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java x: 2 contributors (all time) y: 420 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java x: 23 contributors (all time) y: 464 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TableSchemaJSONLoader.java x: 7 contributors (all time) y: 68 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsSchemas.java x: 7 contributors (all time) y: 632 lines of code sdks/python/apache_beam/dataframe/frame_base.py x: 13 contributors (all time) y: 413 lines of code sdks/python/apache_beam/dataframe/io.py x: 13 contributors (all time) y: 447 lines of code sdks/python/apache_beam/dataframe/pandas_top_level_functions.py x: 8 contributors (all time) y: 135 lines of code sdks/python/apache_beam/dataframe/transforms.py x: 13 contributors (all time) y: 346 lines of code sdks/python/apache_beam/io/gcp/bigquery.py x: 75 contributors (all time) y: 1138 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/preprocess.py x: 17 contributors (all time) y: 162 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/trainer/task.py x: 14 contributors (all time) y: 105 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/trainer/taxi.py x: 15 contributors (all time) y: 97 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py x: 24 contributors (all time) y: 314 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_util.py x: 19 contributors (all time) y: 139 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query11.py x: 9 contributors (all time) y: 22 lines of code sdks/python/apache_beam/testing/pipeline_verifiers.py x: 23 contributors (all time) y: 85 lines of code sdks/python/apache_beam/testing/synthetic_pipeline.py x: 30 contributors (all time) y: 653 lines of code sdks/python/apache_beam/testing/util.py x: 48 contributors (all time) y: 165 lines of code sdks/python/apache_beam/tools/coders_microbenchmark.py x: 20 contributors (all time) y: 146 lines of code sdks/python/apache_beam/tools/fn_api_runner_microbenchmark.py x: 16 contributors (all time) y: 71 lines of code sdks/python/apache_beam/tools/sideinput_microbenchmark.py x: 20 contributors (all time) y: 43 lines of code sdks/python/apache_beam/typehints/typecheck_test_py3.py x: 10 contributors (all time) y: 229 lines of code sdks/python/apache_beam/utils/annotations.py x: 30 contributors (all time) y: 43 lines of code sdks/python/apache_beam/utils/counters.py x: 39 contributors (all time) y: 116 lines of code sdks/python/apache_beam/utils/histogram.py x: 8 contributors (all time) y: 163 lines of code sdks/python/apache_beam/utils/profiler.py x: 43 contributors (all time) y: 117 lines of code sdks/python/apache_beam/utils/proto_utils.py x: 27 contributors (all time) y: 64 lines of code sdks/python/apache_beam/utils/retry.py x: 51 contributors (all time) y: 137 lines of code sdks/python/apache_beam/utils/sharded_key.py x: 10 contributors (all time) y: 22 lines of code sdks/python/apache_beam/utils/shared.py x: 10 contributors (all time) y: 57 lines of code sdks/python/apache_beam/utils/subprocess_server.py x: 21 contributors (all time) y: 236 lines of code sdks/python/apache_beam/utils/thread_pool_executor.py x: 19 contributors (all time) y: 80 lines of code sdks/python/apache_beam/utils/timestamp.py x: 50 contributors (all time) y: 211 lines of code sdks/python/apache_beam/utils/urns.py x: 35 contributors (all time) y: 90 lines of code sdks/python/container/boot.go x: 37 contributors (all time) y: 250 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDo.java x: 41 contributors (all time) y: 599 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SplittableParDoNaiveBounded.java x: 31 contributors (all time) y: 511 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java x: 38 contributors (all time) y: 187 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java x: 36 contributors (all time) y: 199 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkStatefulDoFnFunction.java x: 34 contributors (all time) y: 195 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java x: 71 contributors (all time) y: 1149 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/UserParDoFnFactory.java x: 21 contributors (all time) y: 114 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/AbstractParDoP.java x: 13 contributors (all time) y: 462 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java x: 9 contributors (all time) y: 215 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DoFnFunction.java x: 3 contributors (all time) y: 124 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/MultiDoFnFunction.java x: 54 contributors (all time) y: 199 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/DoFnFunction.java x: 13 contributors (all time) y: 293 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java x: 52 contributors (all time) y: 575 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/ByteBuddyDoFnInvokerFactory.java x: 45 contributors (all time) y: 979 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvoker.java x: 43 contributors (all time) y: 342 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java x: 50 contributors (all time) y: 882 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java x: 61 contributors (all time) y: 2064 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java x: 59 contributors (all time) y: 2203 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/WatermarkHold.java x: 30 contributors (all time) y: 298 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkNonMergingReduceFunction.java x: 8 contributors (all time) y: 76 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/HashingFlinkCombineRunner.java x: 9 contributors (all time) y: 140 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/SortingFlinkCombineRunner.java x: 20 contributors (all time) y: 124 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowViaIteratorsFn.java x: 15 contributors (all time) y: 194 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/AggregatorCombiner.java x: 4 contributors (all time) y: 212 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/SlidingWindows.java x: 15 contributors (all time) y: 132 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/IdentityWindowFn.java x: 18 contributors (all time) y: 63 lines of code sdks/python/apache_beam/coders/coder_impl.py x: 62 contributors (all time) y: 900 lines of code sdks/python/apache_beam/coders/coders_test_common.py x: 57 contributors (all time) y: 563 lines of code sdks/python/apache_beam/coders/coder_impl.pxd x: 28 contributors (all time) y: 132 lines of code settings.gradle.kts x: 13 contributors (all time) y: 190 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java x: 42 contributors (all time) y: 166 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/BeamFnStatusClient.java x: 1 contributors (all time) y: 186 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java x: 1 contributors (all time) y: 401 lines of code sdks/python/apache_beam/coders/coders.py x: 77 contributors (all time) y: 874 lines of code sdks/python/apache_beam/io/gcp/bigquery_file_loads.py x: 38 contributors (all time) y: 818 lines of code sdks/python/apache_beam/runners/worker/sdk_worker.py x: 78 contributors (all time) y: 891 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineOptions.java x: 54 contributors (all time) y: 138 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AvroCoder.java x: 50 contributors (all time) y: 468 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java x: 42 contributors (all time) y: 780 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java x: 43 contributors (all time) y: 904 lines of code sdks/python/apache_beam/coders/row_coder.py x: 25 contributors (all time) y: 162 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/ExecutionStateTracker.java x: 22 contributors (all time) y: 176 lines of code website/www/site/layouts/partials/section-menu/en/documentation.html x: 22 contributors (all time) y: 313 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java x: 14 contributors (all time) y: 316 lines of code sdks/go/pkg/beam/artifact/materialize.go x: 24 contributors (all time) y: 402 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubSubPayloadTranslation.java x: 2 contributors (all time) y: 126 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSink.java x: 37 contributors (all time) y: 321 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java x: 40 contributors (all time) y: 1130 lines of code sdks/python/apache_beam/io/filesystem.py x: 56 contributors (all time) y: 428 lines of code sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java x: 63 contributors (all time) y: 973 lines of code sdks/python/apache_beam/io/iobase.py x: 66 contributors (all time) y: 559 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java x: 44 contributors (all time) y: 291 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/GrpcVendoring_1_26_0.groovy x: 24 contributors (all time) y: 150 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslators.java x: 34 contributors (all time) y: 159 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CombineTranslation.java x: 40 contributors (all time) y: 189 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/DefaultExpansionServiceClientFactory.java x: 17 contributors (all time) y: 46 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/Environments.java x: 60 contributors (all time) y: 425 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslation.java x: 26 contributors (all time) y: 89 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReadTranslation.java x: 35 contributors (all time) y: 166 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/TestStreamTranslation.java x: 28 contributors (all time) y: 161 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowIntoTranslation.java x: 38 contributors (all time) y: 104 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WriteFilesTranslation.java x: 41 contributors (all time) y: 259 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyPCollectionFusers.java x: 42 contributors (all time) y: 233 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/QueryablePipeline.java x: 48 contributors (all time) y: 328 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MonitoringInfoEncodings.java x: 5 contributors (all time) y: 100 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPortablePipelineTranslator.java x: 41 contributors (all time) y: 486 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java x: 40 contributors (all time) y: 77 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineRunner.java x: 33 contributors (all time) y: 181 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPortablePipelineTranslator.java x: 47 contributors (all time) y: 828 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/utils/FlinkPortableRunnerUtils.java x: 6 contributors (all time) y: 27 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperator.java x: 57 contributors (all time) y: 1012 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ByteStringCoder.java x: 16 contributors (all time) y: 26 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowParDoFnFactory.java x: 25 contributors (all time) y: 317 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StateFetcher.java x: 24 contributors (all time) y: 217 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateInternals.java x: 30 contributors (all time) y: 1696 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateReader.java x: 25 contributors (all time) y: 717 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimerInternals.java x: 33 contributors (all time) y: 324 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSources.java x: 33 contributors (all time) y: 677 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/RegisterAndProcessBundleOperation.java x: 38 contributors (all time) y: 600 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/logging/BeamFnLoggingService.java x: 24 contributors (all time) y: 101 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/CreateExecutableStageNodeFunction.java x: 32 contributors (all time) y: 480 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/InsertFetchAndFilterStreamingSideInputNodes.java x: 26 contributors (all time) y: 129 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/RegisterNodeFunction.java x: 35 contributors (all time) y: 493 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/ForwardingClientResponseObserver.java x: 20 contributors (all time) y: 34 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/GrpcWindmillServer.java x: 43 contributors (all time) y: 1378 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/FnService.java x: 20 contributors (all time) y: 6 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/GrpcContextHeaderAccessorProvider.java x: 26 contributors (all time) y: 47 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/GrpcFnServer.java x: 29 contributors (all time) y: 105 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/InProcessServerFactory.java x: 24 contributors (all time) y: 42 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/ServerFactory.java x: 35 contributors (all time) y: 191 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/ArtifactStagingService.java x: 12 contributors (all time) y: 517 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleCheckpointHandlers.java x: 8 contributors (all time) y: 106 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClient.java x: 35 contributors (all time) y: 136 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClientPoolService.java x: 32 contributors (all time) y: 89 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ProcessBundleDescriptors.java x: 45 contributors (all time) y: 445 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/GrpcDataService.java x: 36 contributors (all time) y: 146 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/ExternalEnvironmentFactory.java x: 12 contributors (all time) y: 164 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/provisioning/JobInfo.java x: 27 contributors (all time) y: 22 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java x: 33 contributors (all time) y: 440 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/status/BeamWorkerStatusGrpcService.java x: 10 contributors (all time) y: 153 lines of code runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/InMemoryJobService.java x: 12 contributors (all time) y: 422 lines of code runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobInvocation.java x: 13 contributors (all time) y: 217 lines of code runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/PortablePipelineJarCreator.java x: 11 contributors (all time) y: 184 lines of code runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/PortablePipelineJarUtils.java x: 11 contributors (all time) y: 81 lines of code runners/portability/java/src/main/java/org/apache/beam/runners/portability/JobServicePipelineResult.java x: 21 contributors (all time) y: 167 lines of code runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableRunner.java x: 24 contributors (all time) y: 163 lines of code runners/portability/java/src/main/java/org/apache/beam/runners/portability/testing/TestJobService.java x: 13 contributors (all time) y: 59 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/AssignWindowsFunction.java x: 12 contributors (all time) y: 87 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/GroupByWindowFunction.java x: 12 contributors (all time) y: 186 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextSource.java x: 24 contributors (all time) y: 184 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKey.java x: 14 contributors (all time) y: 83 lines of code sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java x: 16 contributors (all time) y: 420 lines of code sdks/java/extensions/schemaio-expansion-service/src/main/java/org/apache/beam/sdk/extensions/schemaio/expansion/ExternalSchemaIOTransformRegistrar.java x: 9 contributors (all time) y: 119 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/SocketAddressFactory.java x: 24 contributors (all time) y: 35 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataGrpcMultiplexer.java x: 32 contributors (all time) y: 158 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/DecodingFnDataReceiver.java x: 7 contributors (all time) y: 22 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/RemoteGrpcPortRead.java x: 25 contributors (all time) y: 39 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/BufferingStreamObserver.java x: 30 contributors (all time) y: 114 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java x: 26 contributors (all time) y: 223 lines of code sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/SynchronizedStreamObserver.java x: 23 contributors (all time) y: 29 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/AddHarnessIdInterceptor.java x: 21 contributors (all time) y: 16 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/logging/BeamFnLoggingClient.java x: 36 contributors (all time) y: 260 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java x: 35 contributors (all time) y: 432 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/stream/HarnessStreamObserverFactories.java x: 26 contributors (all time) y: 31 lines of code sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIOSource.java x: 9 contributors (all time) y: 237 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerTransformRegistrar.java x: 8 contributors (all time) y: 306 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTransformTranslators.java x: 48 contributors (all time) y: 719 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkRunner.java x: 33 contributors (all time) y: 133 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/EncodedValueSerializer.java x: 6 contributors (all time) y: 84 lines of code sdks/python/apache_beam/internal/gcp/auth.py x: 35 contributors (all time) y: 72 lines of code sdks/python/apache_beam/internal/metrics/cells.py x: 7 contributors (all time) y: 81 lines of code sdks/python/apache_beam/internal/pickler.py x: 49 contributors (all time) y: 160 lines of code sdks/python/apache_beam/internal/util.py x: 31 contributors (all time) y: 51 lines of code sdks/python/apache_beam/metrics/cells.py x: 55 contributors (all time) y: 284 lines of code sdks/python/apache_beam/metrics/execution.py x: 56 contributors (all time) y: 188 lines of code sdks/python/apache_beam/metrics/metric.py x: 43 contributors (all time) y: 139 lines of code sdks/python/apache_beam/metrics/metricbase.py x: 42 contributors (all time) y: 55 lines of code sdks/python/apache_beam/metrics/monitoring_infos.py x: 32 contributors (all time) y: 239 lines of code sdks/python/apache_beam/io/parquetio.py x: 25 contributors (all time) y: 288 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java x: 52 contributors (all time) y: 1125 lines of code sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/ThriftCoder.java x: 14 contributors (all time) y: 48 lines of code sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/ThriftIO.java x: 14 contributors (all time) y: 166 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java x: 62 contributors (all time) y: 715 lines of code sdks/python/apache_beam/io/gcp/datastore/v1new/datastore_write_it_pipeline.py x: 17 contributors (all time) y: 99 lines of code sdks/python/apache_beam/io/gcp/datastore/v1new/helper.py x: 18 contributors (all time) y: 37 lines of code sdks/python/apache_beam/io/gcp/dicomio.py x: 3 contributors (all time) y: 260 lines of code sdks/python/apache_beam/io/gcp/experimental/spannerio.py x: 14 contributors (all time) y: 616 lines of code sdks/python/apache_beam/io/gcp/gcsio.py x: 47 contributors (all time) y: 401 lines of code sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py x: 19 contributors (all time) y: 704 lines of code sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_messages.py x: 22 contributors (all time) y: 1524 lines of code sdks/python/apache_beam/io/gcp/internal/clients/storage/storage_v1_client.py x: 13 contributors (all time) y: 904 lines of code sdks/python/apache_beam/io/gcp/internal/clients/storage/storage_v1_messages.py x: 12 contributors (all time) y: 801 lines of code sdks/python/apache_beam/io/gcp/pubsub.py x: 50 contributors (all time) y: 286 lines of code sdks/python/apache_beam/io/gcp/spanner.py x: 9 contributors (all time) y: 369 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectHelpers.java x: 19 contributors (all time) y: 346 lines of code sdks/go/pkg/beam/core/runtime/xlangx/namespace.go x: 10 contributors (all time) y: 77 lines of code sdks/go/pkg/beam/runners/dataflow/dataflow.go x: 50 contributors (all time) y: 184 lines of code sdks/go/pkg/beam/runners/dataflow/dataflowlib/job.go x: 25 contributors (all time) y: 263 lines of code sdks/python/apache_beam/typehints/opcodes.py x: 39 contributors (all time) y: 253 lines of code sdks/python/apache_beam/typehints/trivial_inference.py x: 43 contributors (all time) y: 388 lines of code sdks/python/apache_beam/typehints/typehints.py x: 52 contributors (all time) y: 671 lines of code sdks/go/pkg/beam/encoding.go x: 14 contributors (all time) y: 245 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineOptions.java x: 43 contributors (all time) y: 187 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2PipelineOptions.java x: 6 contributors (all time) y: 41 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/PortablePipelineOptions.java x: 32 contributors (all time) y: 76 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Reshuffle.java x: 25 contributors (all time) y: 94 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkConfiguration.java x: 25 contributors (all time) y: 549 lines of code sdks/go/pkg/beam/core/graph/coder/row.go x: 8 contributors (all time) y: 151 lines of code sdks/go/pkg/beam/core/graph/coder/row_decoder.go x: 5 contributors (all time) y: 276 lines of code sdks/go/pkg/beam/core/graph/coder/row_encoder.go x: 5 contributors (all time) y: 237 lines of code sdks/go/pkg/beam/util/shimx/generate.go x: 6 contributors (all time) y: 356 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/PipelineTranslator.java x: 2 contributors (all time) y: 111 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineOptions.java x: 47 contributors (all time) y: 56 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/util/SparkCompat.java x: 11 contributors (all time) y: 127 lines of code sdks/python/apache_beam/io/aws/clients/s3/fake_client.py x: 10 contributors (all time) y: 136 lines of code sdks/python/apache_beam/io/aws/s3io.py x: 20 contributors (all time) y: 323 lines of code sdks/python/apache_beam/io/azure/blobstorageio.py x: 4 contributors (all time) y: 335 lines of code sdks/python/apache_beam/io/filebasedsink.py x: 42 contributors (all time) y: 287 lines of code sdks/python/apache_beam/io/filebasedsource.py x: 41 contributors (all time) y: 250 lines of code sdks/python/apache_beam/io/fileio.py x: 47 contributors (all time) y: 439 lines of code sdks/python/apache_beam/io/filesystemio.py x: 34 contributors (all time) y: 133 lines of code sdks/python/apache_beam/io/filesystems.py x: 42 contributors (all time) y: 132 lines of code sdks/python/apache_beam/io/hadoopfilesystem.py x: 31 contributors (all time) y: 260 lines of code sdks/python/apache_beam/io/jdbc.py x: 11 contributors (all time) y: 106 lines of code sdks/python/apache_beam/io/localfilesystem.py x: 33 contributors (all time) y: 150 lines of code sdks/python/apache_beam/io/mongodbio.py x: 29 contributors (all time) y: 345 lines of code sdks/python/apache_beam/io/range_trackers.py x: 40 contributors (all time) y: 273 lines of code sdks/python/apache_beam/io/snowflake.py x: 5 contributors (all time) y: 212 lines of code sdks/python/apache_beam/io/source_test_utils.py x: 34 contributors (all time) y: 425 lines of code sdks/python/apache_beam/io/textio.py x: 56 contributors (all time) y: 337 lines of code sdks/python/apache_beam/io/tfrecordio.py x: 43 contributors (all time) y: 172 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ExpressionConverter.java x: 26 contributors (all time) y: 806 lines of code sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/options/AwsModule.java x: 31 contributors (all time) y: 311 lines of code sdks/java/build-tools/src/main/resources/beam/suppressions.xml x: 55 contributors (all time) y: 82 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/trigger_manager.py x: 1 contributors (all time) y: 352 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableDestination.java x: 28 contributors (all time) y: 148 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java x: 12 contributors (all time) y: 252 lines of code sdks/python/apache_beam/dataframe/doctests.py x: 15 contributors (all time) y: 487 lines of code sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/CassandraIO.java x: 43 contributors (all time) y: 888 lines of code sdks/python/apache_beam/io/gcp/bigquery_read_internal.py x: 9 contributors (all time) y: 286 lines of code sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/dynamodb/DynamoDBIO.java x: 19 contributors (all time) y: 371 lines of code sdks/python/apache_beam/pvalue.py x: 58 contributors (all time) y: 350 lines of code sdks/java/build-tools/src/main/resources/beam/spotbugs-filter.xml x: 12 contributors (all time) y: 27 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java x: 102 contributors (all time) y: 1640 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/RetryManager.java x: 1 contributors (all time) y: 225 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFinalizeWritesDoFn.java x: 1 contributors (all time) y: 139 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java x: 1 contributors (all time) y: 163 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSqlBeamTranslationUtils.java x: 15 contributors (all time) y: 249 lines of code release/src/main/scripts/mass_comment.py x: 16 contributors (all time) y: 109 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamRuleSets.java x: 40 contributors (all time) y: 125 lines of code sdks/python/apache_beam/dataframe/expressions.py x: 10 contributors (all time) y: 196 lines of code sdks/python/apache_beam/dataframe/partitionings.py x: 10 contributors (all time) y: 104 lines of code sdks/python/apache_beam/runners/common.py x: 72 contributors (all time) y: 1004 lines of code sdks/python/apache_beam/typehints/decorators.py x: 44 contributors (all time) y: 536 lines of code website/www/site/data/io_matrix.yaml x: 14 contributors (all time) y: 368 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/SqlTransform.java x: 41 contributors (all time) y: 189 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkPartialReduceFunction.java x: 23 contributors (all time) y: 71 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TranslationContext.java x: 2 contributors (all time) y: 174 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/functions/SparkSideInputReader.java x: 2 contributors (all time) y: 150 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java x: 2 contributors (all time) y: 212 lines of code runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/streaming/DatasetSourceStreaming.java x: 2 contributors (all time) y: 187 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/BeamKafkaTable.java x: 37 contributors (all time) y: 196 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/NestedPayloadKafkaTable.java x: 3 contributors (all time) y: 153 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/PubsubLiteTableProvider.java x: 3 contributors (all time) y: 161 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/AwsModule.java x: 19 contributors (all time) y: 267 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HttpHealthcareApiClient.java x: 24 contributors (all time) y: 797 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaRecord.java x: 31 contributors (all time) y: 90 lines of code sdks/python/apache_beam/coders/slow_stream.py x: 31 contributors (all time) y: 113 lines of code sdks/python/apache_beam/coders/stream.pyx x: 15 contributors (all time) y: 154 lines of code sdks/python/apache_beam/runners/worker/operations.py x: 61 contributors (all time) y: 851 lines of code sdks/python/apache_beam/runners/worker/statesampler_fast.pyx x: 23 contributors (all time) y: 146 lines of code learning/katas/go/core_transforms/section-info.yaml x: 9 contributors (all time) y: 11 lines of code model/fn-execution/src/main/proto/beam_fn_api.proto x: 54 contributors (all time) y: 797 lines of code model/fn-execution/src/main/resources/org/apache/beam/model/fnexecution/v1/standard_coders.yaml x: 35 contributors (all time) y: 285 lines of code model/job-management/src/main/proto/beam_artifact_api.proto x: 23 contributors (all time) y: 198 lines of code model/pipeline/src/main/proto/endpoints.proto x: 11 contributors (all time) y: 56 lines of code model/pipeline/src/main/proto/metrics.proto x: 19 contributors (all time) y: 543 lines of code model/pipeline/src/main/proto/standard_window_fns.proto x: 16 contributors (all time) y: 98 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineTranslation.java x: 29 contributors (all time) y: 138 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/ReshuffleTranslation.java x: 8 contributors (all time) y: 34 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/RunnerPCollectionView.java x: 21 contributors (all time) y: 82 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/Timer.java x: 22 contributors (all time) y: 157 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/TransformPayloadTranslatorRegistrar.java x: 14 contributors (all time) y: 11 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/UnboundedReadFromBoundedSource.java x: 29 contributors (all time) y: 402 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyPipelineFuser.java x: 39 contributors (all time) y: 292 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/Networks.java x: 16 contributors (all time) y: 190 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/SplittableParDoExpander.java x: 18 contributors (all time) y: 263 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/TrivialNativeTransformExpander.java x: 7 contributors (all time) y: 41 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java x: 45 contributors (all time) y: 139 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryStateInternals.java x: 30 contributors (all time) y: 591 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/MergingActiveWindowSet.java x: 23 contributors (all time) y: 290 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/PaneInfoTracker.java x: 18 contributors (all time) y: 105 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java x: 34 contributors (all time) y: 99 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnContextFactory.java x: 30 contributors (all time) y: 464 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnRunner.java x: 37 contributors (all time) y: 629 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java x: 30 contributors (all time) y: 157 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java x: 56 contributors (all time) y: 1033 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/StateTable.java x: 11 contributors (all time) y: 60 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/StateTags.java x: 22 contributors (all time) y: 253 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/StatefulDoFnRunner.java x: 35 contributors (all time) y: 314 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SystemReduceFn.java x: 20 contributors (all time) y: 94 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java x: 28 contributors (all time) y: 35 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsMap.java x: 22 contributors (all time) y: 51 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java x: 29 contributors (all time) y: 192 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterWatermarkStateMachine.java x: 29 contributors (all time) y: 213 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.java x: 27 contributors (all time) y: 466 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/BoundedReadEvaluatorFactory.java x: 28 contributors (all time) y: 188 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java x: 34 contributors (all time) y: 213 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ImmutabilityEnforcementFactory.java x: 24 contributors (all time) y: 121 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/MultiStepCombine.java x: 28 contributors (all time) y: 419 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java x: 46 contributors (all time) y: 256 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoMultiOverrideFactory.java x: 29 contributors (all time) y: 246 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/SideInputContainer.java x: 29 contributors (all time) y: 233 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/StepTransformResult.java x: 19 contributors (all time) y: 119 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java x: 31 contributors (all time) y: 196 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluatorRegistry.java x: 29 contributors (all time) y: 151 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java x: 38 contributors (all time) y: 274 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java x: 45 contributors (all time) y: 1197 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WindowEvaluatorFactory.java x: 30 contributors (all time) y: 95 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkExecutionEnvironments.java x: 38 contributors (all time) y: 301 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPipelineTranslator.java x: 30 contributors (all time) y: 289 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java x: 65 contributors (all time) y: 1291 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunction.java x: 39 contributors (all time) y: 322 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/ImpulseSourceFunction.java x: 15 contributors (all time) y: 63 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SplittableDoFnOperator.java x: 40 contributors (all time) y: 153 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java x: 33 contributors (all time) y: 95 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapper.java x: 46 contributors (all time) y: 368 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/KeyedBufferingElementsHandler.java x: 9 contributors (all time) y: 67 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java x: 31 contributors (all time) y: 676 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java x: 51 contributors (all time) y: 1324 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchViewOverrides.java x: 28 contributors (all time) y: 913 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/PrimitiveParDoSingleFactory.java x: 46 contributors (all time) y: 294 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/ReshuffleOverrideFactory.java x: 22 contributors (all time) y: 61 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslators.java x: 22 contributors (all time) y: 477 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RandomAccessData.java x: 25 contributors (all time) y: 230 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContext.java x: 25 contributors (all time) y: 419 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java x: 26 contributors (all time) y: 669 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java x: 18 contributors (all time) y: 200 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java x: 28 contributors (all time) y: 293 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowProcessFnRunner.java x: 18 contributors (all time) y: 93 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowsParDoFn.java x: 16 contributors (all time) y: 169 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java x: 14 contributors (all time) y: 327 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java x: 17 contributors (all time) y: 842 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSink.java x: 14 contributors (all time) y: 202 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartialGroupByKeyParDoFns.java x: 17 contributors (all time) y: 305 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ShuffleSink.java x: 16 contributors (all time) y: 264 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SimpleParDoFn.java x: 27 contributors (all time) y: 384 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SplittableProcessFnFactory.java x: 18 contributors (all time) y: 176 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/counters/CounterFactory.java x: 17 contributors (all time) y: 632 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/BeamFnMapTaskExecutor.java x: 34 contributors (all time) y: 484 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/DeduceFlattenLocationsFunction.java x: 12 contributors (all time) y: 218 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/DataflowWorkerLoggingHandler.java x: 19 contributors (all time) y: 231 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/DataflowWorkerLoggingInitializer.java x: 23 contributors (all time) y: 180 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/JulHandlerPrintStreamAdapterFactory.java x: 20 contributors (all time) y: 350 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/options/StreamingDataflowWorkerOptions.java x: 21 contributors (all time) y: 144 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/status/DebugCapture.java x: 20 contributors (all time) y: 172 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java x: 20 contributors (all time) y: 417 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingTables.java x: 16 contributors (all time) y: 354 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/MapTaskExecutor.java x: 18 contributors (all time) y: 132 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/ReadOperation.java x: 18 contributors (all time) y: 302 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/WindmillServerBase.java x: 12 contributors (all time) y: 103 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/WindmillServerStub.java x: 27 contributors (all time) y: 135 lines of code runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto x: 19 contributors (all time) y: 530 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactory.java x: 37 contributors (all time) y: 597 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java x: 9 contributors (all time) y: 179 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/RemoteBundle.java x: 28 contributors (all time) y: 17 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java x: 45 contributors (all time) y: 528 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SingleEnvironmentInstanceJobBundleFactory.java x: 30 contributors (all time) y: 175 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/DAGBuilder.java x: 11 contributors (all time) y: 173 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/JetPipelineResult.java x: 13 contributors (all time) y: 101 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/JetTransformTranslators.java x: 12 contributors (all time) y: 370 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java x: 15 contributors (all time) y: 231 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/metrics/JetMetricResults.java x: 13 contributors (all time) y: 162 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/StatefulParDoP.java x: 16 contributors (all time) y: 303 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/UnboundedSourceP.java x: 11 contributors (all time) y: 229 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineResult.java x: 23 contributors (all time) y: 121 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/BoundedSourceSystem.java x: 27 contributors (all time) y: 355 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/UnboundedSourceSystem.java x: 29 contributors (all time) y: 424 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java x: 30 contributors (all time) y: 912 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java x: 31 contributors (all time) y: 543 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ConfigBuilder.java x: 30 contributors (all time) y: 243 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/GroupByKeyTranslator.java x: 26 contributors (all time) y: 217 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkNativePipelineVisitor.java x: 37 contributors (all time) y: 163 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunnerRegistrar.java x: 31 contributors (all time) y: 25 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/TestSparkRunner.java x: 40 contributors (all time) y: 99 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/MicrobatchSource.java x: 27 contributors (all time) y: 259 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/SparkUnboundedSource.java x: 35 contributors (all time) y: 231 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkGroupAlsoByWindowViaWindowSet.java x: 41 contributors (all time) y: 408 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java x: 23 contributors (all time) y: 316 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/BoundedDataset.java x: 37 contributors (all time) y: 95 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/EvaluationContext.java x: 54 contributors (all time) y: 181 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkExecutableStageFunction.java x: 20 contributors (all time) y: 258 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java x: 67 contributors (all time) y: 669 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/StreamingTransformTranslator.java x: 59 contributors (all time) y: 525 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/translation/wrappers/Twister2BoundedSource.java x: 11 contributors (all time) y: 210 lines of code sdks/go/pkg/beam/beam.shims.go x: 10 contributors (all time) y: 272 lines of code sdks/go/pkg/beam/core/graph/coder/coder.go x: 19 contributors (all time) y: 303 lines of code sdks/go/pkg/beam/core/graph/coder/testutil/testutil.go x: 5 contributors (all time) y: 96 lines of code sdks/go/pkg/beam/core/graph/edge.go x: 25 contributors (all time) y: 350 lines of code sdks/go/pkg/beam/core/graph/fn.go x: 21 contributors (all time) y: 796 lines of code sdks/go/pkg/beam/core/metrics/metrics.go x: 19 contributors (all time) y: 409 lines of code sdks/go/pkg/beam/core/runtime/exec/coder.go x: 27 contributors (all time) y: 840 lines of code sdks/go/pkg/beam/core/runtime/exec/datasource.go x: 36 contributors (all time) y: 415 lines of code sdks/go/pkg/beam/core/runtime/exec/plan.go x: 34 contributors (all time) y: 157 lines of code sdks/go/pkg/beam/core/runtime/exec/sdf.go x: 8 contributors (all time) y: 393 lines of code sdks/go/pkg/beam/core/runtime/graphx/serialize.go x: 25 contributors (all time) y: 700 lines of code sdks/go/pkg/beam/core/runtime/graphx/translate.go x: 41 contributors (all time) y: 856 lines of code sdks/go/pkg/beam/core/runtime/graphx/xlang.go x: 12 contributors (all time) y: 202 lines of code sdks/go/pkg/beam/core/runtime/harness/harness.go x: 37 contributors (all time) y: 368 lines of code sdks/go/pkg/beam/core/runtime/harness/monitoring.go x: 14 contributors (all time) y: 154 lines of code sdks/go/pkg/beam/core/runtime/metricsx/metricsx.go x: 6 contributors (all time) y: 104 lines of code sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api.pb.go x: 49 contributors (all time) y: 5022 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_artifact_api.pb.go x: 38 contributors (all time) y: 1911 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_expansion_api.pb.go x: 16 contributors (all time) y: 321 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_job_api.pb.go x: 36 contributors (all time) y: 2323 lines of code sdks/go/pkg/beam/model/pipeline_v1/endpoints.pb.go x: 31 contributors (all time) y: 201 lines of code sdks/go/pkg/beam/model/pipeline_v1/standard_window_fns.pb.go x: 31 contributors (all time) y: 483 lines of code sdks/go/pkg/beam/runners/dot/dot.go x: 15 contributors (all time) y: 28 lines of code sdks/go/pkg/beam/runners/session/session.go x: 21 contributors (all time) y: 238 lines of code sdks/go/pkg/beam/runners/universal/universal.go x: 28 contributors (all time) y: 70 lines of code sdks/go/pkg/beam/runners/vet/vet.go x: 11 contributors (all time) y: 444 lines of code sdks/go/pkg/beam/transforms/stats/quantiles.go x: 3 contributors (all time) y: 549 lines of code sdks/go/pkg/beam/transforms/top/top.go x: 22 contributors (all time) y: 190 lines of code sdks/go/pkg/beam/util/starcgenx/starcgenx.go x: 16 contributors (all time) y: 585 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/annotations/Experimental.java x: 34 contributors (all time) y: 38 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java x: 38 contributors (all time) y: 456 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java x: 64 contributors (all time) y: 1030 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSink.java x: 26 contributors (all time) y: 109 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java x: 39 contributors (all time) y: 583 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/Compression.java x: 18 contributors (all time) y: 226 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/DefaultFilenamePolicy.java x: 22 contributors (all time) y: 267 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java x: 55 contributors (all time) y: 742 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java x: 30 contributors (all time) y: 392 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java x: 49 contributors (all time) y: 870 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java x: 31 contributors (all time) y: 358 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java x: 36 contributors (all time) y: 742 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextIO.java x: 55 contributors (all time) y: 689 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/ProxyInvocationHandler.java x: 41 contributors (all time) y: 528 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldAccessDescriptor.java x: 25 contributors (all time) y: 444 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java x: 17 contributors (all time) y: 210 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Cast.java x: 18 contributors (all time) y: 295 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/CoGroup.java x: 22 contributors (all time) y: 522 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Group.java x: 26 contributors (all time) y: 741 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AutoValueUtils.java x: 18 contributors (all time) y: 255 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java x: 28 contributors (all time) y: 1164 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java x: 24 contributors (all time) y: 360 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/POJOUtils.java x: 29 contributors (all time) y: 440 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ReflectUtils.java x: 21 contributors (all time) y: 189 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectByteBuddyHelpers.java x: 8 contributors (all time) y: 686 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/state/StateSpecs.java x: 24 contributors (all time) y: 540 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/CombineFnTester.java x: 22 contributors (all time) y: 113 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SourceTestUtils.java x: 30 contributors (all time) y: 644 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestStream.java x: 43 contributors (all time) y: 274 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateQuantiles.java x: 36 contributors (all time) y: 426 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java x: 34 contributors (all time) y: 218 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java x: 39 contributors (all time) y: 524 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java x: 48 contributors (all time) y: 488 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java x: 59 contributors (all time) y: 273 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/FlatMapElements.java x: 30 contributors (all time) y: 232 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupIntoBatches.java x: 33 contributors (all time) y: 241 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/MapElements.java x: 32 contributors (all time) y: 220 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Regex.java x: 21 contributors (all time) y: 426 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Reify.java x: 22 contributors (all time) y: 209 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sample.java x: 27 contributors (all time) y: 210 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Top.java x: 32 contributors (all time) y: 263 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java x: 31 contributors (all time) y: 881 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/display/DisplayData.java x: 36 contributors (all time) y: 506 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java x: 31 contributors (all time) y: 285 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/RestrictionTracker.java x: 37 contributors (all time) y: 42 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java x: 36 contributors (all time) y: 110 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java x: 31 contributors (all time) y: 241 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/ApiSurface.java x: 32 contributors (all time) y: 522 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/Preconditions.java x: 8 contributors (all time) y: 251 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionView.java x: 22 contributors (all time) y: 35 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/TypeDescriptors.java x: 32 contributors (all time) y: 134 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowingStrategy.java x: 24 contributors (all time) y: 342 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/Distinct.java x: 19 contributors (all time) y: 290 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java x: 19 contributors (all time) y: 505 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java x: 21 contributors (all time) y: 465 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/ReduceByKeyTranslator.java x: 21 contributors (all time) y: 198 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/GcpOptions.java x: 30 contributors (all time) y: 326 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsFileSystem.java x: 31 contributors (all time) y: 231 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java x: 19 contributors (all time) y: 619 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java x: 12 contributors (all time) y: 406 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoByteBuddyUtils.java x: 16 contributors (all time) y: 942 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java x: 13 contributors (all time) y: 257 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDynamicMessageSchema.java x: 10 contributors (all time) y: 650 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPLiteral.java x: 10 contributors (all time) y: 315 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/nfa/NFA.java x: 8 contributors (all time) y: 640 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java x: 39 contributors (all time) y: 370 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMatchRel.java x: 10 contributors (all time) y: 375 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSortRel.java x: 43 contributors (all time) y: 282 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamIOPushDownRule.java x: 17 contributors (all time) y: 224 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamTableUtils.java x: 43 contributors (all time) y: 133 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamBuiltinAggregations.java x: 43 contributors (all time) y: 406 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/AggregationCombineFnAdapter.java x: 27 contributors (all time) y: 149 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BeamBigQuerySqlDialect.java x: 23 contributors (all time) y: 346 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BeamSqlUnparseContext.java x: 19 contributors (all time) y: 169 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigtable/BigtableTable.java x: 6 contributors (all time) y: 189 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTable.java x: 21 contributors (all time) y: 361 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/text/TextTableProvider.java x: 40 contributors (all time) y: 215 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/DateTimeUtils.java x: 15 contributors (all time) y: 164 lines of code sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlOperators.java x: 17 contributors (all time) y: 242 lines of code sdks/java/extensions/zetasketch/src/main/java/org/apache/beam/sdk/extensions/zetasketch/ApproximateCountDistinct.java x: 7 contributors (all time) y: 165 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/CombineRunners.java x: 33 contributors (all time) y: 202 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java x: 17 contributors (all time) y: 395 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/WindowMappingFnRunner.java x: 30 contributors (all time) y: 38 lines of code sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3FileSystem.java x: 36 contributors (all time) y: 521 lines of code sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/ClickHouseIO.java x: 21 contributors (all time) y: 300 lines of code sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIO.java x: 9 contributors (all time) y: 408 lines of code sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/KafkaSourceConsumerFn.java x: 4 contributors (all time) y: 255 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProto.java x: 3 contributors (all time) y: 278 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryTableSource.java x: 34 contributors (all time) y: 72 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/DynamicDestinationsHelpers.java x: 35 contributors (all time) y: 328 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StreamingWriteTables.java x: 28 contributors (all time) y: 308 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteTables.java x: 54 contributors (all time) y: 391 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java x: 65 contributors (all time) y: 815 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java x: 51 contributors (all time) y: 903 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java x: 10 contributors (all time) y: 423 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java x: 47 contributors (all time) y: 671 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubTestClient.java x: 28 contributors (all time) y: 334 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationUtils.java x: 13 contributors (all time) y: 316 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java x: 48 contributors (all time) y: 1044 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/StructUtils.java x: 6 contributors (all time) y: 349 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClient.java x: 26 contributors (all time) y: 421 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeJobService.java x: 17 contributors (all time) y: 478 lines of code sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java x: 23 contributors (all time) y: 1244 lines of code sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java x: 28 contributors (all time) y: 525 lines of code sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/HCatalogIO.java x: 28 contributors (all time) y: 402 lines of code sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/InfluxDbIO.java x: 11 contributors (all time) y: 509 lines of code sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java x: 44 contributors (all time) y: 418 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ConsumerSpEL.java x: 39 contributors (all time) y: 141 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaExactlyOnceSink.java x: 24 contributors (all time) y: 513 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java x: 47 contributors (all time) y: 544 lines of code sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisIO.java x: 47 contributors (all time) y: 421 lines of code sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisReader.java x: 38 contributors (all time) y: 156 lines of code sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisTransformRegistrar.java x: 8 contributors (all time) y: 216 lines of code sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardCheckpoint.java x: 22 contributors (all time) y: 119 lines of code sdks/java/io/kudu/src/main/java/org/apache/beam/sdk/io/kudu/KuduIO.java x: 16 contributors (all time) y: 279 lines of code sdks/java/io/rabbitmq/src/main/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqIO.java x: 20 contributors (all time) y: 449 lines of code sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeIO.java x: 17 contributors (all time) y: 1150 lines of code sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkEventWriter.java x: 9 contributors (all time) y: 249 lines of code sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticOptions.java x: 22 contributors (all time) y: 229 lines of code sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticUnboundedSource.java x: 12 contributors (all time) y: 148 lines of code sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/ThriftSchema.java x: 5 contributors (all time) y: 298 lines of code sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/XmlIO.java x: 32 contributors (all time) y: 363 lines of code sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/XmlSource.java x: 22 contributors (all time) y: 278 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/Main.java x: 21 contributors (all time) y: 396 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkOptions.java x: 29 contributors (all time) y: 334 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkUtils.java x: 24 contributors (all time) y: 571 lines of code sdks/python/apache_beam/__init__.py x: 38 contributors (all time) y: 26 lines of code sdks/python/apache_beam/metrics/execution.pxd x: 23 contributors (all time) y: 19 lines of code sdks/python/apache_beam/runners/common.pxd x: 45 contributors (all time) y: 98 lines of code sdks/python/apache_beam/runners/runner.py x: 58 contributors (all time) y: 212 lines of code sdks/python/apache_beam/runners/worker/bundle_processor.py x: 74 contributors (all time) y: 1487 lines of code sdks/python/apache_beam/runners/worker/data_plane.py x: 56 contributors (all time) y: 467 lines of code sdks/python/apache_beam/runners/worker/log_handler.py x: 37 contributors (all time) y: 134 lines of code sdks/python/apache_beam/typehints/typecheck.py x: 44 contributors (all time) y: 234 lines of code website/www/site/assets/scss/_calendar.scss x: 6 contributors (all time) y: 230 lines of code website/www/site/assets/scss/_capability-matrix.scss x: 5 contributors (all time) y: 317 lines of code website/www/site/assets/scss/_layout.scss x: 7 contributors (all time) y: 180 lines of code website/www/site/assets/scss/_lists.scss x: 5 contributors (all time) y: 281 lines of code website/www/site/assets/scss/_navbar-desktop.scss x: 6 contributors (all time) y: 169 lines of code website/www/site/assets/scss/bootstrap/_navbar.scss x: 7 contributors (all time) y: 480 lines of code website/www/site/assets/scss/capability-matrix.scss x: 7 contributors (all time) y: 279 lines of code website/www/site/data/capability_matrix.yaml x: 16 contributors (all time) y: 1669 lines of code website/www/site/data/capability_matrix_snapshot.yaml x: 10 contributors (all time) y: 733 lines of code website/www/site/layouts/index.html x: 7 contributors (all time) y: 227 lines of code website/www/site/layouts/partials/header.html x: 7 contributors (all time) y: 208 lines of code sdks/go/pkg/beam/transforms/stats/stats.shims.go x: 15 contributors (all time) y: 437 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/VendorJavaPlugin.groovy x: 19 contributors (all time) y: 253 lines of code ownership/JAVA_DEPENDENCY_OWNERS.yaml x: 19 contributors (all time) y: 803 lines of code runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/PipelineValidator.java x: 24 contributors (all time) y: 260 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/ParDoP.java x: 5 contributors (all time) y: 162 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/DoFnRunnerWithMetrics.java x: 29 contributors (all time) y: 76 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/GroupCombineFunctions.java x: 44 contributors (all time) y: 124 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java x: 45 contributors (all time) y: 125 lines of code sdks/go/pkg/beam/core/runtime/exec/combine.go x: 23 contributors (all time) y: 378 lines of code sdks/go/pkg/beam/core/runtime/harness/datamgr.go x: 27 contributors (all time) y: 399 lines of code sdks/go/pkg/beam/core/runtime/harness/statemgr.go x: 15 contributors (all time) y: 331 lines of code sdks/go/pkg/beam/testing/passert/passert.shims.go x: 9 contributors (all time) y: 455 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowedValue.java x: 30 contributors (all time) y: 614 lines of code sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/HadoopExternalSorter.java x: 7 contributors (all time) y: 143 lines of code sdks/python/apache_beam/testing/data/trigger_transcripts.yaml x: 20 contributors (all time) y: 243 lines of code website/www/site/assets/scss/bootstrap/_forms.scss x: 2 contributors (all time) y: 391 lines of code website/www/site/assets/scss/bootstrap/_glyphicons.scss x: 2 contributors (all time) y: 285 lines of code website/www/site/static/js/bootstrap/modal.js x: 2 contributors (all time) y: 245 lines of code sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystem.java x: 27 contributors (all time) y: 298 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/OrderedCode.java x: 11 contributors (all time) y: 388 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/OrderedCode.java x: 16 contributors (all time) y: 450 lines of code sdks/go/pkg/beam/core/runtime/coderx/coderx.shims.go x: 6 contributors (all time) y: 257 lines of code sdks/go/pkg/beam/io/datastoreio/datastore.go x: 10 contributors (all time) y: 173 lines of code sdks/java/extensions/sql/src/main/codegen/includes/parserImpls.ftl x: 18 contributors (all time) y: 329 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/CalendarWindows.java x: 12 contributors (all time) y: 263 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/callers.go x: 6 contributors (all time) y: 470 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/decoders.go x: 6 contributors (all time) y: 1856 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/encoders.go x: 6 contributors (all time) y: 1772 lines of code sdks/go/pkg/beam/core/util/reflectx/calls.go x: 7 contributors (all time) y: 1058 lines of code sdks/java/build-tools/src/main/resources/beam/beam-codestyle.xml x: 4 contributors (all time) y: 313 lines of code
5022.0
lines of code
  min: 1.0
  average: 103.38
  25th percentile: 11.0
  median: 39.0
  75th percentile: 108.0
  max: 5022.0
0 153.0
contributors (all time)
min: 1.0 | average: 12.37 | 25th percentile: 4.0 | median: 8.0 | 75th percentile: 16.0 | max: 153.0

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".

File Size vs. Commits (90 days): 0 points

No data for "commits (90d)" vs. "lines of code".

File Size vs. Contributors (90 days): 0 points

No data for "contributors (90d)" vs. "lines of code".