anthropics / beam
File Size

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

Intro
  • File size measurements show the distribution of size of files.
  • Files are classified in four categories based on their size (lines of code): 1-100 (very small files), 101-200 (small files), 201-500 (medium size files), 501-1000 (long files), 1001+(very long files).
  • It is a good practice to keep files small. Long files may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.
Learn more...
File Size Overall
  • There are 7,196 files with 802,375 lines of code.
    • 92 very long files (161,683 lines of code)
    • 177 long files (119,123 lines of code)
    • 710 medium size files (217,600 lines of code)
    • 1,008 small files (142,466 lines of code)
    • 5,209 very small files (161,503 lines of code)
20% | 14% | 27% | 17% | 20%
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
java13% | 15% | 29% | 20% | 21%
go35% | 14% | 20% | 14% | 14%
py25% | 20% | 30% | 12% | 10%
ts46% | 6% | 23% | 14% | 8%
yaml44% | 10% | 10% | 5% | 29%
proto46% | 24% | 16% | 5% | 7%
dart11% | 2% | 18% | 16% | 50%
groovy58% | 0% | 13% | 15% | 13%
kts0% | 31% | 44% | 16% | 7%
ftl0% | 100% | 0% | 0% | 0%
scss0% | 0% | 42% | 36% | 21%
html0% | 0% | 30% | 14% | 55%
tsx0% | 0% | 55% | 16% | 27%
js0% | 0% | 30% | 39% | 30%
pyi0% | 0% | 100% | 0% | 0%
xml0% | 0% | 51% | 0% | 48%
ipynb0% | 0% | 59% | 40% | 0%
sql0% | 0% | 4% | 15% | 79%
pyx0% | 0% | 0% | 61% | 38%
pxd0% | 0% | 0% | 42% | 57%
css0% | 0% | 0% | 68% | 31%
sass0% | 0% | 0% | 35% | 64%
kt0% | 0% | 0% | 0% | 100%
tpl0% | 0% | 0% | 0% | 100%
toml0% | 0% | 0% | 0% | 100%
ps10% | 0% | 0% | 0% | 100%
h0% | 0% | 0% | 0% | 100%
cfg0% | 0% | 0% | 0% | 100%
rdf0% | 0% | 0% | 0% | 100%
in0% | 0% | 0% | 0% | 100%
scala0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
sdks23% | 17% | 27% | 16% | 16%
runners9% | 13% | 32% | 22% | 22%
playground32% | 6% | 16% | 14% | 30%
learning11% | 5% | 6% | 14% | 61%
model55% | 13% | 16% | 6% | 8%
buildSrc71% | 0% | 16% | 4% | 7%
website8% | 3% | 32% | 25% | 30%
infra21% | 28% | 38% | 9% | 1%
ROOT0% | 61% | 27% | 9% | 1%
it0% | 0% | 41% | 28% | 29%
.test-infra0% | 0% | 46% | 17% | 36%
scripts0% | 0% | 39% | 43% | 16%
release0% | 0% | 21% | 49% | 28%
contributor-docs0% | 0% | 0% | 100% | 0%
.github0% | 0% | 0% | 0% | 100%
plugins0% | 0% | 0% | 0% | 100%
.gemini0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
register.go
in sdks/go/pkg/beam/register
 7254 504
go.g.yaml
in playground/frontend/playground_components/assets/symbols
 6641 -
beam_fn_api.pb.go
in sdks/go/pkg/beam/model/fnexecution_v1
 5486 545
beam_runner_api.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/pipeline/v1
 5095 102
frames.py
in sdks/python/apache_beam/dataframe
 4173 191
beam_fn_api.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/fn_execution/v1
 3456 67
api.pb.go
in learning/tour-of-beam/backend/playground_api/api/v1
 3333 339
api.pb.go
in playground/backend/internal/api/v1
 3333 339
BigQueryIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 2664 168
FnApiDoFnRunner.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness
 2428 156
core.py
in sdks/python/apache_beam/transforms
 2413 286
api.pb.dart
in playground/frontend/playground_components/lib/src/api/v1
 2383 113
BeamModulePlugin.groovy
in buildSrc/src/main/groovy/org/apache/beam/gradle
 2377 7
dataflow_v1b3_messages.py
in sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow
 2358 -
DataflowRunner.java
in runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow
 2215 86
KafkaIO.java
in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka
 2191 169
DoFnSignatures.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect
 2091 67
beam_job_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 2041 194
descriptor.ts
in sdks/typescript/src/apache_beam/proto/google/protobuf
 1991 27
bigquery.py
in sdks/python/apache_beam/io/gcp
 1953 95
JdbcIO.java
in sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc
 1931 153
decoders.go
in sdks/go/pkg/beam/core/runtime/exec/optimized
 1856 441
ElasticsearchIO.java
in sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch
 1831 174
bundle_processor.py
in sdks/python/apache_beam/runners/worker
 1786 128
encoders.go
in sdks/go/pkg/beam/core/runtime/exec/optimized
 1772 421
elementmanager.go
in sdks/go/pkg/beam/runners/prism/internal/engine
 1756 85
schema.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
 1749 181
metrics.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
 1734 111
proto
beam_runner_api.proto
in model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1
 1722 -
pipeline_options.py
in sdks/python/apache_beam/options
 1719 71
SpannerIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner
 1709 170
capability_matrix.yaml
in website/www/site/data
 1685 -
translations.py
in sdks/python/apache_beam/runners/portability/fn_api_runner
 1679 64
BigQueryServicesImpl.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 1656 67
DatastoreV1.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore
 1645 136
v1.pb.go
in sdks/go/pkg/beam/core/runtime/graphx/v1
 1608 148
TableRowToStorageApiProto.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 1607 38
FlinkStateInternals.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state
 1587 121
bigquery_v2_messages.py
in sdks/python/apache_beam/io/gcp/internal/clients/bigquery
 1582 -
PCollectionViews.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/values
 1534 105
PipelineOptionsFactory.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/options
 1521 67
calls.go
in sdks/go/pkg/beam/core/util/reflectx
 1490 270
beam_artifact_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 1484 144
BigtableIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable
 1473 132
util.py
in sdks/python/apache_beam/transforms
 1457 117
coder_impl.py
in sdks/python/apache_beam/coders
 1409 191
AvroUtils.java
in sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils
 1365 75
Combine.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
 1359 160
common.py
in sdks/python/apache_beam/runners
 1311 97
bigquery_tools.py
in sdks/python/apache_beam/io/gcp
 1267 78
Files With Most Units (Top 50)
File# lines# units
beam_fn_api.pb.go
in sdks/go/pkg/beam/model/fnexecution_v1
 5486 545
register.go
in sdks/go/pkg/beam/register
 7254 504
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
api.pb.go
in learning/tour-of-beam/backend/playground_api/api/v1
 3333 339
api.pb.go
in playground/backend/internal/api/v1
 3333 339
coders.py
in sdks/python/apache_beam/coders
 1101 323
core.py
in sdks/python/apache_beam/transforms
 2413 286
calls.go
in sdks/go/pkg/beam/core/util/reflectx
 1490 270
trigger.py
in sdks/python/apache_beam/transforms
 1162 239
beam_job_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 2041 194
frames.py
in sdks/python/apache_beam/dataframe
 4173 191
coder_impl.py
in sdks/python/apache_beam/coders
 1409 191
schema.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
 1749 181
ElasticsearchIO.java
in sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch
 1831 174
SpannerIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner
 1709 170
KafkaIO.java
in sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka
 2191 169
BigQueryIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery
 2664 168
Combine.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/transforms
 1359 160
FnApiDoFnRunner.java
in sdks/java/harness/src/main/java/org/apache/beam/fn/harness
 2428 156
JdbcIO.java
in sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc
 1931 153
v1.pb.go
in sdks/go/pkg/beam/core/runtime/graphx/v1
 1608 148
beam_artifact_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 1484 144
cells.py
in sdks/python/apache_beam/metrics
 648 143
Schema.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/schemas
 1089 143
base.py
in sdks/python/apache_beam/ml/inference
 1170 142
AvroIO.java
in sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/io
 1177 138
SimpleDoFnRunner.java
in runners/core-java/src/main/java/org/apache/beam/runners/core
 1254 137
DatastoreV1.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore
 1645 136
yaml_provider.py
in sdks/python/apache_beam/yaml
 1141 134
BigtableIO.java
in sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable
 1473 132
typehints.py
in sdks/python/apache_beam/typehints
 920 130
combiners.py
in sdks/python/apache_beam/transforms
 731 129
PAssert.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/testing
 1179 129
bundle_processor.py
in sdks/python/apache_beam/runners/worker
 1786 128
schemas.py
in sdks/python/apache_beam/typehints
 846 127
FlinkStateInternals.java
in runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state
 1587 121
util.py
in sdks/python/apache_beam/transforms
 1457 117
iobase.py
in sdks/python/apache_beam/io
 750 113
api.pb.dart
in playground/frontend/playground_components/lib/src/api/v1
 2383 113
metrics.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
 1734 111
callers.go
in sdks/go/pkg/beam/core/runtime/exec/optimized
 470 111
WindowedValues.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/values
 916 110
SnowflakeIO.java
in sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake
 1169 109
WatermarkManager.java
in runners/direct-java/src/main/java/org/apache/beam/runners/direct
 1165 106
PCollectionViews.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/values
 1534 105
TextIO.java
in sdks/java/core/src/main/java/org/apache/beam/sdk/io
 806 105
beam_runner_api.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/pipeline/v1
 5095 102
worker_handlers.py
in sdks/python/apache_beam/runners/portability/fn_api_runner
 934 99
operations.py
in sdks/python/apache_beam/runners/worker
 1028 99
Files With Long Lines (Top 50)

There are 523 files with lines longer than 120 characters. In total, there are 5228 long lines.

File# lines# units# long lines
register.go
in sdks/go/pkg/beam/register
 7254 504 874
beam_runner_api.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/pipeline/v1
 5095 102 384
beam_fn_api.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/fn_execution/v1
 3456 67 299
api.pb.dart
in playground/frontend/playground_components/lib/src/api/v1
 2383 113 253
beam_fn_api.pb.go
in sdks/go/pkg/beam/model/fnexecution_v1
 5486 545 152
descriptor.ts
in sdks/typescript/src/apache_beam/proto/google/protobuf
 1991 27 137
beam-codestyle.xml
in sdks/java/build-tools/src/main/resources/beam
 313 - 101
beam_artifact_api.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/job_management/v1
 994 19 81
beam_job_api.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/job_management/v1
 1193 24 80
schema.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/pipeline/v1
 1175 18 75
api_grpc.pb.go
in learning/tour-of-beam/backend/playground_api/api/v1
 736 62 73
api_grpc.pb.go
in playground/backend/internal/api/v1
 736 62 73
BeamModulePlugin.groovy
in buildSrc/src/main/groovy/org/apache/beam/gradle
 2377 7 70
controller.go
in playground/backend/cmd/server
 517 21 61
beam_job_api.grpc-client.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/job_management/v1
 107 1 56
mock.go
in learning/tour-of-beam/backend/playground_api/api/v1
 811 40 56
api.pbjson.dart
in playground/frontend/playground_components/lib/src/api/v1
 468 - 51
beam_job_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 2041 194 49
calls.go
in sdks/go/pkg/beam/core/util/reflectx
 1490 270 45
elementmanager.go
in sdks/go/pkg/beam/runners/prism/internal/engine
 1756 85 42
beam_artifact_api.grpc-client.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/job_management/v1
 107 4 38
beam_fn_api.grpc-client.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/fn_execution/v1
 132 6 36
capability_matrix.yaml
in website/www/site/data
 1685 - 36
api.pb.go
in learning/tour-of-beam/backend/playground_api/api/v1
 3333 339 34
api.pb.go
in playground/backend/internal/api/v1
 3333 339 34
beam_artifact_api.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 1484 144 33
beam_artifact_api_grpc.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 457 45 31
beam_job_api_grpc.pb.go
in sdks/go/pkg/beam/model/jobmanagement_v1
 453 40 31
capability_matrix_snapshot.yaml
in website/www/site/data
 733 - 30
standard_coders.yaml
in model/fn-execution/src/main/resources/org/apache/beam/model/fnexecution/v1
 395 - 29
schema.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
 1749 181 27
fn.go
in sdks/go/pkg/beam/core/graph
 1247 65 27
api.pbenum.dart
in playground/frontend/playground_components/lib/src/api/v1
 93 - 25
worker.go
in sdks/go/pkg/beam/runners/prism/internal/worker
 699 34 24
stage.go
in sdks/go/pkg/beam/runners/prism/internal
 631 9 24
code_processing.go
in playground/backend/internal/code_processing
 497 27 24
sdks.html
in website/www/site/layouts/partials/section-menu/en
 161 - 24
beam_provision_api.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/fn_execution/v1
 212 4 23
metrics.pb.go
in sdks/go/pkg/beam/model/pipeline_v1
 1734 111 22
statemgr.go
in sdks/go/pkg/beam/core/runtime/harness
 588 37 22
beam_fn_api_grpc.pb.go
in sdks/go/pkg/beam/model/fnexecution_v1
 570 62 21
account_keys.py
in infra/enforcement
 302 16 21
header.html
in website/www/site/layouts/partials
 238 - 21
flink_python_pipeline_options.html
in website/www/site/layouts/shortcodes
 202 - 21
flink_java_pipeline_options.html
in website/www/site/layouts/shortcodes
 202 - 21
metrics.ts
in sdks/typescript/src/apache_beam/proto/org/apache/beam/model/pipeline/v1
 379 7 20
generate_event.py
in learning/katas/python/Streaming/Triggers/Early Triggers
 37 2 20
generate_event.py
in learning/katas/python/Streaming/Triggers/Window Accumulation Modes
 37 2 20
generate_event.py
in learning/katas/python/Streaming/Triggers/Event Time Triggers
 37 2 20
fn.go
in sdks/go/pkg/beam/core/runtime/exec
 431 18 19
Correlations

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

sdks/python/apache_beam/version.py x: 153 commits (all time) y: 1 lines of code sdks/python/apache_beam/utils/subprocess_server.py x: 98 commits (all time) y: 456 lines of code sdks/go/pkg/beam/core/core.go x: 55 commits (all time) y: 6 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java x: 236 commits (all time) y: 1709 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy x: 1519 commits (all time) y: 2377 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/AvroGenericRecordToStorageApiProto.java x: 21 commits (all time) y: 490 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProto.java x: 24 commits (all time) y: 393 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtils.java x: 104 commits (all time) y: 548 lines of code sdks/python/apache_beam/io/components/rate_limiter.py x: 2 commits (all time) y: 138 lines of code sdks/python/apache_beam/ml/inference/base.py x: 87 commits (all time) y: 1170 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java x: 191 commits (all time) y: 1055 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineRunner.java x: 97 commits (all time) y: 165 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java x: 344 commits (all time) y: 1253 lines of code sdks/python/apache_beam/yaml/yaml_io.py x: 54 commits (all time) y: 362 lines of code sdks/python/apache_beam/runners/dataflow/internal/names.py x: 331 commits (all time) y: 6 lines of code sdks/python/apache_beam/yaml/yaml_transform.py x: 117 commits (all time) y: 1049 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowToStorageApiProto.java x: 75 commits (all time) y: 1607 lines of code sdks/python/apache_beam/yaml/yaml_testing.py x: 16 commits (all time) y: 444 lines of code sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read/SolaceCheckpointMark.java x: 7 commits (all time) y: 57 lines of code sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read/UnboundedSolaceReader.java x: 11 commits (all time) y: 191 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryWriteSchemaTransformProvider.java x: 4 commits (all time) y: 60 lines of code website/www/site/data/en/quotes.yaml x: 41 commits (all time) y: 36 lines of code sdks/python/container/license_scripts/dep_urls_py.yaml x: 58 commits (all time) y: 144 lines of code sdks/typescript/reporterConfig.js x: 2 commits (all time) y: 13 lines of code runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableMetrics.java x: 35 commits (all time) y: 226 lines of code sdks/python/apache_beam/transforms/core.py x: 589 commits (all time) y: 2413 lines of code sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java x: 240 commits (all time) y: 1831 lines of code sdks/python/apache_beam/yaml/yaml_provider.py x: 159 commits (all time) y: 1141 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/AppendFilesToTables.java x: 16 commits (all time) y: 181 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/RecordWriter.java x: 21 commits (all time) y: 146 lines of code sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java x: 11 commits (all time) y: 38 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java x: 248 commits (all time) y: 296 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/dao/MetadataTableDao.java x: 21 commits (all time) y: 523 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySourceBase.java x: 124 commits (all time) y: 201 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageApiInsertError.java x: 9 commits (all time) y: 44 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiConvertMessages.java x: 27 commits (all time) y: 172 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java x: 137 commits (all time) y: 1114 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java x: 105 commits (all time) y: 870 lines of code sdks/python/apache_beam/coders/coder_impl.py x: 243 commits (all time) y: 1409 lines of code sdks/python/apache_beam/coders/coders_test_common.py x: 194 commits (all time) y: 816 lines of code sdks/python/apache_beam/transforms/periodicsequence.py x: 27 commits (all time) y: 269 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java x: 560 commits (all time) y: 2664 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTranslation.java x: 31 commits (all time) y: 867 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageQuerySource.java x: 58 commits (all time) y: 214 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java x: 74 commits (all time) y: 195 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageTableSource.java x: 68 commits (all time) y: 189 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java x: 136 commits (all time) y: 791 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillKeyedWorkItem.java x: 40 commits (all time) y: 189 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimerInternals.java x: 94 commits (all time) y: 168 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindowingWindmillReader.java x: 40 commits (all time) y: 140 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/CachingStateTable.java x: 8 commits (all time) y: 265 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillCombiningState.java x: 6 commits (all time) y: 129 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncoding.java x: 1 commits (all time) y: 75 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncodingV1.java x: 1 commits (all time) y: 164 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/KeyCommitTooLargeException.java x: 5 commits (all time) y: 30 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/processing/failures/WorkFailureProcessor.java x: 5 commits (all time) y: 154 lines of code sdks/java/container/license_scripts/dep_urls_java.yaml x: 122 commits (all time) y: 47 lines of code sdks/python/apache_beam/runners/interactive/interactive_environment.py x: 112 commits (all time) y: 390 lines of code sdks/python/apache_beam/runners/interactive/recording_manager.py x: 70 commits (all time) y: 667 lines of code settings.gradle.kts x: 306 commits (all time) y: 339 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/GrowableOffsetRangeTracker.java x: 32 commits (all time) y: 69 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/UnsplittableRestrictionTracker.java x: 1 commits (all time) y: 37 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java x: 92 commits (all time) y: 588 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisIO.java x: 60 commits (all time) y: 794 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/RecordWriterManager.java x: 23 commits (all time) y: 306 lines of code website/www/site/config.toml x: 118 commits (all time) y: 89 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/commits/StreamingEngineWorkCommitter.java x: 11 commits (all time) y: 214 lines of code sdks/python/apache_beam/options/pipeline_options.py x: 443 commits (all time) y: 1719 lines of code sdks/python/apache_beam/runners/dask/dask_runner.py x: 6 commits (all time) y: 175 lines of code sdks/python/apache_beam/ml/inference/pytorch_inference.py x: 52 commits (all time) y: 334 lines of code sdks/python/apache_beam/ml/inference/sklearn_inference.py x: 45 commits (all time) y: 169 lines of code sdks/python/apache_beam/ml/inference/tensorrt_inference.py x: 23 commits (all time) y: 212 lines of code sdks/python/apache_beam/ml/inference/vertex_ai_inference.py x: 16 commits (all time) y: 90 lines of code sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java x: 16 commits (all time) y: 246 lines of code .test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py x: 12 commits (all time) y: 401 lines of code sdks/go/pkg/beam/core/timers/timers.go x: 10 commits (all time) y: 106 lines of code sdks/java/extensions/sql/src/main/codegen/includes/parserImpls.ftl x: 52 commits (all time) y: 731 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteSchema.java x: 50 commits (all time) y: 120 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSystemSchema.java x: 1 commits (all time) y: 94 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CatalogManagerSchema.java x: 2 commits (all time) y: 231 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlCreateExternalTable.java x: 57 commits (all time) y: 183 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDdlNodes.java x: 39 commits (all time) y: 73 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/catalog/Catalog.java x: 5 commits (all time) y: 24 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/catalog/InMemoryCatalog.java x: 7 commits (all time) y: 100 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/SerializableDataFile.java x: 8 commits (all time) y: 218 lines of code sdks/python/apache_beam/runners/portability/stager.py x: 129 commits (all time) y: 567 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreStatefulComponentFactory.java x: 17 commits (all time) y: 88 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1.java x: 19 commits (all time) y: 1028 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1ReadFn.java x: 20 commits (all time) y: 592 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteSchemaFactory.java x: 55 commits (all time) y: 130 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteTable.java x: 77 commits (all time) y: 107 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSqlEnv.java x: 145 commits (all time) y: 235 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java x: 54 commits (all time) y: 83 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcDriver.java x: 77 commits (all time) y: 118 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ScalarFunctionImpl.java x: 56 commits (all time) y: 165 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TVFSlidingWindowFn.java x: 19 commits (all time) y: 50 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TableResolutionUtils.java x: 37 commits (all time) y: 126 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdfImpl.java x: 33 commits (all time) y: 36 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/FullNameTableProvider.java x: 28 commits (all time) y: 76 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/ReadOnlyTableProvider.java x: 44 commits (all time) y: 47 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/TableProvider.java x: 48 commits (all time) y: 28 lines of code build.gradle.kts x: 258 commits (all time) y: 769 lines of code model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto x: 37 commits (all time) y: 1176 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillSink.java x: 76 commits (all time) y: 296 lines of code sdks/python/apache_beam/coders/typecoders.py x: 116 commits (all time) y: 117 lines of code sdks/python/apache_beam/internal/cloudpickle_pickler.py x: 23 commits (all time) y: 180 lines of code sdks/python/apache_beam/internal/pickler.py x: 126 commits (all time) y: 66 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py x: 101 commits (all time) y: 934 lines of code sdks/python/apache_beam/runners/worker/sdk_worker_main.py x: 165 commits (all time) y: 271 lines of code sdks/python/apache_beam/typehints/schemas.py x: 120 commits (all time) y: 846 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateFetchingIterators.java x: 105 commits (all time) y: 530 lines of code sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go x: 71 commits (all time) y: 1756 lines of code sdks/go/pkg/beam/runners/prism/internal/engine/teststream.go x: 14 commits (all time) y: 212 lines of code sdks/go/pkg/beam/runners/prism/internal/execute.go x: 66 commits (all time) y: 406 lines of code sdks/go/pkg/beam/runners/prism/internal/handlerunner.go x: 31 commits (all time) y: 474 lines of code website/www/site/layouts/partials/head.html x: 35 commits (all time) y: 70 lines of code website/www/site/layouts/partials/head_homepage.html x: 14 commits (all time) y: 64 lines of code sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtils.java x: 36 commits (all time) y: 1365 lines of code sdks/java/extensions/arrow/src/main/java/org/apache/beam/sdk/extensions/arrow/ArrowConversion.java x: 18 commits (all time) y: 449 lines of code sdks/python/apache_beam/io/mongodbio.py x: 69 commits (all time) y: 445 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/Work.java x: 32 commits (all time) y: 328 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/PaneInfo.java x: 80 commits (all time) y: 250 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueWithRecordId.java x: 32 commits (all time) y: 108 lines of code sdks/python/apache_beam/transforms/util.py x: 288 commits (all time) y: 1457 lines of code sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/ReadFn.java x: 25 commits (all time) y: 123 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java x: 294 commits (all time) y: 1066 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/UngroupedWindmillReader.java x: 45 commits (all time) y: 125 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcDirectGetWorkStream.java x: 29 commits (all time) y: 304 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/WorkItemReceiver.java x: 6 commits (all time) y: 17 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/processing/StreamingWorkScheduler.java x: 20 commits (all time) y: 337 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowedValues.java x: 16 commits (all time) y: 916 lines of code sdks/python/apache_beam/io/kafka.py x: 42 commits (all time) y: 114 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java x: 87 commits (all time) y: 718 lines of code release/build.gradle.kts x: 29 commits (all time) y: 26 lines of code sdks/python/apache_beam/io/hadoopfilesystem.py x: 65 commits (all time) y: 271 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreOptions.java x: 12 commits (all time) y: 24 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1WriteFn.java x: 18 commits (all time) y: 513 lines of code runners/flink/1.20/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java x: 1 commits (all time) y: 1249 lines of code sdks/typescript/src/apache_beam/runners/flink.ts x: 36 commits (all time) y: 58 lines of code sdks/python/apache_beam/runners/worker/operations.pxd x: 69 commits (all time) y: 98 lines of code sdks/python/apache_beam/runners/worker/operations.py x: 225 commits (all time) y: 1028 lines of code sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/HCatalogIO.java x: 66 commits (all time) y: 399 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationUtils.java x: 32 commits (all time) y: 428 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/StructUtils.java x: 23 commits (all time) y: 436 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergUtils.java x: 13 commits (all time) y: 501 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergWriteSchemaTransformProvider.java x: 18 commits (all time) y: 195 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/WriteToDestinations.java x: 10 commits (all time) y: 197 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/SdkHarnessOptions.java x: 49 commits (all time) y: 246 lines of code sdks/python/apache_beam/runners/interactive/interactive_beam.py x: 114 commits (all time) y: 545 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java x: 11 commits (all time) y: 147 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java x: 740 commits (all time) y: 2215 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java x: 409 commits (all time) y: 2191 lines of code sdks/python/conftest.py x: 23 commits (all time) y: 90 lines of code sdks/python/apache_beam/ml/rag/ingestion/postgres_common.py x: 3 commits (all time) y: 227 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/SqlTypes.java x: 14 commits (all time) y: 16 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDropObject.java x: 45 commits (all time) y: 64 lines of code sdks/python/apache_beam/yaml/standard_io.yaml x: 71 commits (all time) y: 370 lines of code sdks/python/apache_beam/typehints/native_type_compatibility.py x: 125 commits (all time) y: 331 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/OutputAndTimeBoundedSplittableProcessElementInvoker.java x: 147 commits (all time) y: 341 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java x: 298 commits (all time) y: 1254 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java x: 288 commits (all time) y: 296 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnSchemaInformation.java x: 45 commits (all time) y: 174 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvoker.java x: 155 commits (all time) y: 346 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java x: 204 commits (all time) y: 1021 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/Preconditions.java x: 36 commits (all time) y: 331 lines of code sdks/java/container/boot.go x: 108 commits (all time) y: 355 lines of code sdks/python/apache_beam/typehints/typehints.py x: 194 commits (all time) y: 920 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java x: 124 commits (all time) y: 1217 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java x: 90 commits (all time) y: 463 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/POJOUtils.java x: 110 commits (all time) y: 402 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/Compression.java x: 42 commits (all time) y: 227 lines of code sdks/python/apache_beam/runners/worker/bundle_processor.py x: 348 commits (all time) y: 1786 lines of code sdks/python/apache_beam/runners/worker/channel_factory.py x: 17 commits (all time) y: 24 lines of code sdks/python/apache_beam/internal/cloudpickle/cloudpickle.py x: 10 commits (all time) y: 905 lines of code sdks/python/apache_beam/pipeline.py x: 400 commits (all time) y: 971 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/MultimapUserState.java x: 37 commits (all time) y: 432 lines of code sdks/python/apache_beam/transforms/async_dofn.py x: 4 commits (all time) y: 247 lines of code sdks/python/apache_beam/ml/rag/enrichment/milvus_search.py x: 7 commits (all time) y: 288 lines of code sdks/python/apache_beam/runners/portability/sdk_container_builder.py x: 60 commits (all time) y: 293 lines of code website/www/site/assets/scss/_case_study.scss x: 42 commits (all time) y: 372 lines of code website/www/site/layouts/case-studies/list.html x: 20 commits (all time) y: 102 lines of code sdks/python/apache_beam/io/tfrecordio.py x: 87 commits (all time) y: 208 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillOrderedList.java x: 11 commits (all time) y: 237 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironment.java x: 123 commits (all time) y: 162 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageStreamSource.java x: 82 commits (all time) y: 372 lines of code sdks/python/apache_beam/__init__.py x: 95 commits (all time) y: 29 lines of code sdks/python/apache_beam/coders/coders.py x: 316 commits (all time) y: 1101 lines of code sdks/python/apache_beam/dataframe/expressions.py x: 52 commits (all time) y: 201 lines of code sdks/python/apache_beam/dataframe/io.py x: 75 commits (all time) y: 625 lines of code sdks/python/apache_beam/internal/gcp/auth.py x: 92 commits (all time) y: 99 lines of code sdks/python/apache_beam/io/__init__.py x: 41 commits (all time) y: 18 lines of code sdks/python/apache_beam/io/azure/blobstorageio.py x: 15 commits (all time) y: 355 lines of code sdks/python/apache_beam/io/gcp/bigquery.py x: 411 commits (all time) y: 1953 lines of code sdks/python/apache_beam/io/gcp/bigtableio.py x: 45 commits (all time) y: 239 lines of code sdks/python/apache_beam/io/gcp/datastore/v1new/datastoreio.py x: 41 commits (all time) y: 345 lines of code sdks/python/apache_beam/io/gcp/experimental/spannerio.py x: 39 commits (all time) y: 781 lines of code sdks/python/apache_beam/io/parquetio.py x: 56 commits (all time) y: 455 lines of code sdks/python/apache_beam/metrics/metric.py x: 91 commits (all time) y: 284 lines of code sdks/python/apache_beam/ml/gcp/videointelligenceml_test_it.py x: 15 commits (all time) y: 40 lines of code sdks/python/apache_beam/ml/gcp/visionml_test_it.py x: 20 commits (all time) y: 49 lines of code sdks/python/apache_beam/ml/inference/huggingface_inference.py x: 26 commits (all time) y: 428 lines of code sdks/python/apache_beam/ml/inference/onnx_inference.py x: 13 commits (all time) y: 97 lines of code sdks/python/apache_beam/ml/transforms/embeddings/vertex_ai.py x: 19 commits (all time) y: 350 lines of code sdks/python/apache_beam/ml/transforms/handlers.py x: 26 commits (all time) y: 314 lines of code sdks/python/apache_beam/ml/transforms/tft.py x: 33 commits (all time) y: 404 lines of code sdks/python/apache_beam/pvalue.py x: 182 commits (all time) y: 384 lines of code sdks/python/apache_beam/runners/__init__.py x: 33 commits (all time) y: 7 lines of code sdks/python/apache_beam/runners/common.py x: 316 commits (all time) y: 1311 lines of code sdks/python/apache_beam/runners/dask/transform_evaluator.py x: 9 commits (all time) y: 167 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_runner.py x: 538 commits (all time) y: 554 lines of code sdks/python/apache_beam/runners/dataflow/internal/apiclient.py x: 417 commits (all time) y: 975 lines of code sdks/python/apache_beam/runners/dataflow/ptransform_overrides.py x: 70 commits (all time) y: 45 lines of code sdks/python/apache_beam/runners/direct/direct_runner.py x: 238 commits (all time) y: 427 lines of code sdks/python/apache_beam/runners/direct/evaluation_context.py x: 86 commits (all time) y: 258 lines of code sdks/python/apache_beam/runners/direct/transform_evaluator.py x: 226 commits (all time) y: 849 lines of code sdks/python/apache_beam/runners/interactive/augmented_pipeline.py x: 17 commits (all time) y: 71 lines of code sdks/python/apache_beam/runners/interactive/dataproc/dataproc_cluster_manager.py x: 36 commits (all time) y: 244 lines of code sdks/python/apache_beam/runners/interactive/display/display_manager.py x: 28 commits (all time) y: 107 lines of code sdks/python/apache_beam/runners/interactive/display/pcoll_visualization.py x: 56 commits (all time) y: 276 lines of code sdks/python/apache_beam/runners/interactive/interactive_runner.py x: 124 commits (all time) y: 199 lines of code sdks/python/apache_beam/runners/interactive/pipeline_instrument.py x: 80 commits (all time) y: 432 lines of code sdks/python/apache_beam/runners/interactive/sql/beam_sql_magics.py x: 18 commits (all time) y: 302 lines of code sdks/python/apache_beam/runners/interactive/utils.py x: 98 commits (all time) y: 284 lines of code sdks/python/apache_beam/runners/runner.py x: 180 commits (all time) y: 163 lines of code sdks/python/apache_beam/testing/benchmarks/cloudml/pipelines/workflow.py x: 5 commits (all time) y: 136 lines of code sdks/python/apache_beam/tools/coders_microbenchmark.py x: 46 commits (all time) y: 221 lines of code sdks/python/apache_beam/transforms/enrichment_handlers/feast_feature_store.py x: 5 commits (all time) y: 111 lines of code sdks/python/apache_beam/transforms/ptransform.py x: 271 commits (all time) y: 739 lines of code sdks/python/apache_beam/transforms/userstate.py x: 87 commits (all time) y: 252 lines of code sdks/python/apache_beam/typehints/decorators.py x: 123 commits (all time) y: 480 lines of code sdks/python/apache_beam/utils/interactive_utils.py x: 36 commits (all time) y: 43 lines of code sdks/python/apache_beam/yaml/yaml_ml.py x: 9 commits (all time) y: 242 lines of code sdks/python/gen_xlang_wrappers.py x: 8 commits (all time) y: 255 lines of code model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/metrics.proto x: 16 commits (all time) y: 678 lines of code sdks/go/pkg/beam/runners/prism/internal/jobservices/metrics.go x: 19 commits (all time) y: 563 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamCalcRel.java x: 151 commits (all time) y: 746 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java x: 333 commits (all time) y: 1656 lines of code sdks/python/apache_beam/io/gcp/bigquery_tools.py x: 218 commits (all time) y: 1267 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java x: 117 commits (all time) y: 655 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsBeamRow.java x: 36 commits (all time) y: 93 lines of code sdks/python/apache_beam/ml/rag/ingestion/spanner.py x: 1 commits (all time) y: 213 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ExecutionStateSampler.java x: 36 commits (all time) y: 527 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java x: 264 commits (all time) y: 1052 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/PCollectionConsumerRegistry.java x: 87 commits (all time) y: 435 lines of code model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.proto x: 53 commits (all time) y: 1722 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/Environments.java x: 13 commits (all time) y: 533 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java x: 116 commits (all time) y: 1183 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillMultimap.java x: 11 commits (all time) y: 596 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateCache.java x: 16 commits (all time) y: 293 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchViewOverrides.java x: 116 commits (all time) y: 929 lines of code sdks/python/apache_beam/internal/metrics/metric.py x: 29 commits (all time) y: 136 lines of code sdks/python/apache_beam/metrics/cells.py x: 143 commits (all time) y: 648 lines of code sdks/python/apache_beam/metrics/execution.py x: 128 commits (all time) y: 216 lines of code sdks/python/apache_beam/metrics/monitoring_infos.py x: 87 commits (all time) y: 349 lines of code sdks/python/apache_beam/io/gcp/gcsio.py x: 213 commits (all time) y: 432 lines of code sdks/python/apache_beam/runners/pipeline_context.py x: 135 commits (all time) y: 228 lines of code sdks/python/apache_beam/io/filebasedsink.py x: 82 commits (all time) y: 416 lines of code website/www/site/layouts/partials/section-menu/en/documentation.html x: 105 commits (all time) y: 396 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java x: 204 commits (all time) y: 756 lines of code sdks/python/apache_beam/transforms/combiners.py x: 164 commits (all time) y: 731 lines of code sdks/python/apache_beam/runners/worker/worker_status.py x: 36 commits (all time) y: 293 lines of code sdks/python/apache_beam/runners/worker/data_plane.py x: 150 commits (all time) y: 573 lines of code sdks/python/apache_beam/runners/worker/sdk_worker.py x: 318 commits (all time) y: 986 lines of code sdks/python/apache_beam/internal/dill_pickler.py x: 21 commits (all time) y: 297 lines of code sdks/python/apache_beam/io/filebasedsource.py x: 139 commits (all time) y: 277 lines of code sdks/python/apache_beam/runners/portability/local_job_service.py x: 148 commits (all time) y: 353 lines of code sdks/python/apache_beam/runners/portability/portable_runner.py x: 260 commits (all time) y: 461 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDoViaKeyedWorkItems.java x: 111 commits (all time) y: 544 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java x: 261 commits (all time) y: 618 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDoNaiveBounded.java x: 8 commits (all time) y: 607 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java x: 319 commits (all time) y: 2428 lines of code sdks/go/pkg/beam/runners/prism/internal/stage.go x: 58 commits (all time) y: 631 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupByEncryptedKey.java x: 4 commits (all time) y: 180 lines of code sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java x: 111 commits (all time) y: 736 lines of code sdks/python/apache_beam/runners/portability/prism_runner.py x: 17 commits (all time) y: 326 lines of code sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/JAXBCoder.java x: 52 commits (all time) y: 171 lines of code sdks/python/apache_beam/runners/portability/expansion_service.py x: 54 commits (all time) y: 95 lines of code sdks/go/pkg/beam/core/runtime/harness/harness.go x: 167 commits (all time) y: 569 lines of code sdks/go/pkg/beam/forward.go x: 59 commits (all time) y: 74 lines of code sdks/go/pkg/beam/log/log.go x: 14 commits (all time) y: 152 lines of code sdks/go/pkg/beam/runners/prism/internal/worker/worker.go x: 49 commits (all time) y: 699 lines of code sdks/go/pkg/beam/runners/universal/universal.go x: 70 commits (all time) y: 72 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Reshuffle.java x: 63 commits (all time) y: 167 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueInSingleWindow.java x: 51 commits (all time) y: 110 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/AutoValueSchema.java x: 60 commits (all time) y: 110 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/TypeDescriptor.java x: 69 commits (all time) y: 193 lines of code sdks/go/pkg/beam/core/runtime/xlangx/expansionx/download.go x: 26 commits (all time) y: 355 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JavaUdfLoader.java x: 27 commits (all time) y: 228 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaReadSchemaTransformConfiguration.java x: 30 commits (all time) y: 168 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStream.java x: 28 commits (all time) y: 454 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaSourceDescriptor.java x: 26 commits (all time) y: 106 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaWriteSchemaTransformProvider.java x: 31 commits (all time) y: 354 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dao/PartitionMetadataDao.java x: 26 commits (all time) y: 519 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/StreamingWorkerStatusReporter.java x: 6 commits (all time) y: 379 lines of code sdks/python/apache_beam/transforms/external.py x: 197 commits (all time) y: 871 lines of code sdks/python/apache_beam/transforms/managed.py x: 19 commits (all time) y: 127 lines of code infra/enforcement/iam.py x: 3 commits (all time) y: 259 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/External.java x: 5 commits (all time) y: 411 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java x: 245 commits (all time) y: 1359 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptions.java x: 139 commits (all time) y: 145 lines of code sdks/go/pkg/beam/core/runtime/graphx/coder.go x: 91 commits (all time) y: 491 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformTranslation.java x: 15 commits (all time) y: 496 lines of code sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumReadSchemaTransformProvider.java x: 18 commits (all time) y: 154 lines of code sdks/python/apache_beam/coders/coder_impl.pxd x: 103 commits (all time) y: 200 lines of code sdks/python/apache_beam/runners/direct/direct_metrics.py x: 38 commits (all time) y: 162 lines of code runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto x: 56 commits (all time) y: 858 lines of code sdks/go/pkg/beam/runners/prism/internal/engine/strategy.go x: 9 commits (all time) y: 551 lines of code sdks/go/pkg/beam/runners/prism/internal/jobservices/management.go x: 59 commits (all time) y: 469 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoBeamConverter.java x: 2 commits (all time) y: 512 lines of code playground/infrastructure/models.py x: 10 commits (all time) y: 137 lines of code sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py x: 63 commits (all time) y: 188 lines of code sdks/python/apache_beam/runners/portability/job_server.py x: 72 commits (all time) y: 116 lines of code sdks/python/apache_beam/transforms/trigger.py x: 210 commits (all time) y: 1162 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/SqlTransform.java x: 103 commits (all time) y: 194 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CatalogSchema.java x: 1 commits (all time) y: 174 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TableName.java x: 13 commits (all time) y: 60 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDropTable.java x: 28 commits (all time) y: 51 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/Table.java x: 31 commits (all time) y: 34 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/store/InMemoryMetaStore.java x: 56 commits (all time) y: 96 lines of code sdks/java/io/kafka/upgrade/src/main/java/org/apache/beam/sdk/io/kafka/upgrade/KafkaIOTranslation.java x: 25 commits (all time) y: 585 lines of code sdks/java/container/license_scripts/pull_licenses_java.py x: 42 commits (all time) y: 301 lines of code sdks/go/container/boot.go x: 57 commits (all time) y: 233 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java x: 47 commits (all time) y: 150 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java x: 165 commits (all time) y: 382 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java x: 67 commits (all time) y: 334 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java x: 185 commits (all time) y: 1089 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaUtils.java x: 20 commits (all time) y: 348 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java x: 34 commits (all time) y: 124 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/MicrosInstant.java x: 23 commits (all time) y: 49 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/Row.java x: 175 commits (all time) y: 584 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoByteBuddyUtils.java x: 63 commits (all time) y: 1018 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDynamicMessageSchema.java x: 25 commits (all time) y: 46 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoSchemaTranslator.java x: 49 commits (all time) y: 277 lines of code sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java x: 22 commits (all time) y: 131 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnRunner.java x: 134 commits (all time) y: 637 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupAlsoByWindowEvaluatorFactory.java x: 182 commits (all time) y: 195 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WindowEvaluatorFactory.java x: 103 commits (all time) y: 94 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java x: 234 commits (all time) y: 1156 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java x: 112 commits (all time) y: 200 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartialGroupByKeyParDoFns.java x: 39 commits (all time) y: 310 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowAndCombineFn.java x: 27 commits (all time) y: 233 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java x: 154 commits (all time) y: 640 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDo.java x: 6 commits (all time) y: 654 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/AssignWindowsRunner.java x: 42 commits (all time) y: 76 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/SplittableSplitAndSizeRestrictionsDoFnRunner.java x: 13 commits (all time) y: 349 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/SplittableTruncateSizedRestrictionsDoFnRunner.java x: 8 commits (all time) y: 823 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java x: 402 commits (all time) y: 1017 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineWorkerPoolOptions.java x: 89 commits (all time) y: 98 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java x: 157 commits (all time) y: 162 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslators.java x: 62 commits (all time) y: 532 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowParDoFnFactory.java x: 64 commits (all time) y: 302 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/utils/Twister2SideInputReader.java x: 32 commits (all time) y: 122 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoderHelpers.java x: 20 commits (all time) y: 138 lines of code sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java x: 61 commits (all time) y: 1251 lines of code sdks/python/apache_beam/testing/util.py x: 102 commits (all time) y: 255 lines of code sdks/go/pkg/beam/beam.shims.go x: 31 commits (all time) y: 262 lines of code sdks/go/pkg/beam/core/runtime/exec/emit.go x: 35 commits (all time) y: 92 lines of code sdks/go/pkg/beam/core/runtime/exec/pardo.go x: 103 commits (all time) y: 405 lines of code sdks/go/pkg/beam/testing/passert/passert.shims.go x: 31 commits (all time) y: 522 lines of code sdks/go/pkg/beam/x/debug/debug.shims.go x: 23 commits (all time) y: 322 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2PipelineExecutionEnvironment.java x: 22 commits (all time) y: 81 lines of code sdks/python/apache_beam/runners/render.py x: 42 commits (all time) y: 403 lines of code sdks/go/pkg/beam/runners/dataflow/dataflowlib/job.go x: 77 commits (all time) y: 346 lines of code sdks/python/container/boot.go x: 114 commits (all time) y: 389 lines of code sdks/python/apache_beam/io/gcp/pubsub.py x: 151 commits (all time) y: 463 lines of code sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarSourceDescriptor.java x: 10 commits (all time) y: 28 lines of code sdks/python/apache_beam/options/pipeline_options_validator.py x: 64 commits (all time) y: 341 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/DataflowWorkerLoggingHandler.java x: 44 commits (all time) y: 263 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java x: 198 commits (all time) y: 1081 lines of code sdks/python/apache_beam/transforms/enrichment_handlers/cloudsql.py x: 2 commits (all time) y: 374 lines of code sdks/python/apache_beam/ml/transforms/base.py x: 33 commits (all time) y: 476 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcReadSchemaTransformProvider.java x: 23 commits (all time) y: 365 lines of code sdks/python/apache_beam/yaml/pipeline.schema.yaml x: 28 commits (all time) y: 230 lines of code sdks/python/apache_beam/yaml/yaml_mapping.py x: 72 commits (all time) y: 670 lines of code sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java x: 112 commits (all time) y: 532 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java x: 146 commits (all time) y: 611 lines of code sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/index.ts x: 13 commits (all time) y: 135 lines of code sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml/EditablePanel.tsx x: 1 commits (all time) y: 330 lines of code sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml/YamlEditor.tsx x: 1 commits (all time) y: 293 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerConfig.java x: 88 commits (all time) y: 230 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerTransformRegistrar.java x: 44 commits (all time) y: 424 lines of code website/www/site/data/capability_matrix.yaml x: 38 commits (all time) y: 1685 lines of code sdks/go/pkg/beam/runners/prism/internal/environments.go x: 24 commits (all time) y: 250 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/PaneInfoTracker.java x: 65 commits (all time) y: 105 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/StateMerging.java x: 49 commits (all time) y: 134 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/StateTags.java x: 82 commits (all time) y: 270 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/WatermarkHold.java x: 104 commits (all time) y: 297 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java x: 128 commits (all time) y: 690 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSources.java x: 80 commits (all time) y: 702 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerCommand.java x: 48 commits (all time) y: 180 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java x: 39 commits (all time) y: 231 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TranslationContext.java x: 62 commits (all time) y: 303 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java x: 310 commits (all time) y: 755 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/StreamingTransformTranslator.java x: 267 commits (all time) y: 621 lines of code sdks/java/core/jmh/src/main/java/org/apache/beam/sdk/jmh/schemas/RowBundles.java x: 7 commits (all time) y: 162 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java x: 176 commits (all time) y: 843 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java x: 162 commits (all time) y: 1048 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptionsFactory.java x: 189 commits (all time) y: 1521 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Select.java x: 65 commits (all time) y: 188 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestStream.java x: 107 commits (all time) y: 270 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/MapElements.java x: 101 commits (all time) y: 271 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java x: 114 commits (all time) y: 671 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java x: 253 commits (all time) y: 2091 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/GroupIntoBatchesTranslation.java x: 6 commits (all time) y: 72 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ParDoTranslation.java x: 6 commits (all time) y: 755 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/TransformUpgrader.java x: 10 commits (all time) y: 403 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java x: 194 commits (all time) y: 1645 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIO.java x: 97 commits (all time) y: 1182 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubTestClient.java x: 74 commits (all time) y: 523 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java x: 296 commits (all time) y: 1931 lines of code sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java x: 159 commits (all time) y: 809 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCommitOffset.java x: 34 commits (all time) y: 159 lines of code sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkEventWriter.java x: 30 commits (all time) y: 394 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTable.java x: 66 commits (all time) y: 371 lines of code sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbGridFSIO.java x: 117 commits (all time) y: 515 lines of code sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbIO.java x: 174 commits (all time) y: 745 lines of code infra/iam/roles/beam_admin.role.yaml x: 1 commits (all time) y: 654 lines of code infra/iam/roles/beam_infra_manager.role.yaml x: 1 commits (all time) y: 828 lines of code infra/iam/roles/beam_viewer.role.yaml x: 1 commits (all time) y: 1093 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java x: 86 commits (all time) y: 154 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java x: 138 commits (all time) y: 964 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcCommitWorkStream.java x: 21 commits (all time) y: 413 lines of code sdks/go/pkg/beam/core/runtime/exec/userstate.go x: 12 commits (all time) y: 446 lines of code sdks/python/apache_beam/ml/anomaly/transforms.py x: 12 commits (all time) y: 336 lines of code infra/keys/secret_manager.py x: 1 commits (all time) y: 466 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/AbstractWindmillStream.java x: 20 commits (all time) y: 476 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaTranslation.java x: 83 commits (all time) y: 769 lines of code sdks/python/apache_beam/io/avroio.py x: 130 commits (all time) y: 460 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java x: 199 commits (all time) y: 330 lines of code sdks/python/apache_beam/io/textio.py x: 167 commits (all time) y: 596 lines of code sdks/go/pkg/beam/runners/prism/internal/worker/bundle.go x: 36 commits (all time) y: 198 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java x: 61 commits (all time) y: 235 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java x: 10 commits (all time) y: 222 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/Caches.java x: 35 commits (all time) y: 332 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BagUserState.java x: 76 commits (all time) y: 123 lines of code sdks/python/apache_beam/dataframe/doctests.py x: 66 commits (all time) y: 484 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamTableStatistics.java x: 26 commits (all time) y: 65 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CalciteQueryPlanner.java x: 69 commits (all time) y: 206 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/QueryPlanner.java x: 42 commits (all time) y: 47 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdafImpl.java x: 39 commits (all time) y: 95 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPLiteral.java x: 29 commits (all time) y: 315 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamRuleSets.java x: 100 commits (all time) y: 99 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamAggregationRel.java x: 158 commits (all time) y: 315 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java x: 118 commits (all time) y: 373 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamIOSinkRel.java x: 67 commits (all time) y: 139 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamJoinRel.java x: 131 commits (all time) y: 193 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMatchRel.java x: 55 commits (all time) y: 392 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMinusRel.java x: 48 commits (all time) y: 47 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSortRel.java x: 122 commits (all time) y: 284 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSqlRelUtils.java x: 53 commits (all time) y: 118 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUncollectRel.java x: 65 commits (all time) y: 77 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUnionRel.java x: 52 commits (all time) y: 48 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUnnestRel.java x: 93 commits (all time) y: 156 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamValuesRel.java x: 84 commits (all time) y: 70 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamWindowRel.java x: 38 commits (all time) y: 374 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamEnumerableConverterRule.java x: 20 commits (all time) y: 23 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamIOPushDownRule.java x: 55 commits (all time) y: 226 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamIOSinkRule.java x: 24 commits (all time) y: 22 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamUncollectRule.java x: 26 commits (all time) y: 24 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamTableUtils.java x: 83 commits (all time) y: 135 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/BuiltinStringFunctions.java x: 39 commits (all time) y: 212 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java x: 146 commits (all time) y: 296 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BigQueryTable.java x: 92 commits (all time) y: 208 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigtable/BigtableTable.java x: 34 commits (all time) y: 181 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/FilterUtils.java x: 8 commits (all time) y: 358 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java x: 44 commits (all time) y: 310 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/DefaultPipelineLauncher.java x: 19 commits (all time) y: 418 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/RestrictionTracker.java x: 97 commits (all time) y: 43 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java x: 75 commits (all time) y: 1145 lines of code sdks/python/apache_beam/io/gcp/bigquery_file_loads.py x: 139 commits (all time) y: 940 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableDestination.java x: 77 commits (all time) y: 156 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkTimerInternals.java x: 81 commits (all time) y: 175 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TranslationUtils.java x: 134 commits (all time) y: 289 lines of code sdks/python/apache_beam/typehints/row_type.py x: 25 commits (all time) y: 144 lines of code sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py x: 31 commits (all time) y: 681 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py x: 55 commits (all time) y: 815 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/VendorJavaPlugin.groovy x: 61 commits (all time) y: 261 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/BeamKafkaTable.java x: 100 commits (all time) y: 223 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProvider.java x: 63 commits (all time) y: 141 lines of code sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Call.java x: 14 commits (all time) y: 424 lines of code sdks/python/apache_beam/utils/windowed_value.py x: 85 commits (all time) y: 288 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/HistogramData.java x: 46 commits (all time) y: 465 lines of code sdks/python/apache_beam/transforms/environments.py x: 126 commits (all time) y: 715 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/BeamDockerPlugin.groovy x: 16 commits (all time) y: 273 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaExactlyOnceSink.java x: 64 commits (all time) y: 537 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/ResourceHints.java x: 35 commits (all time) y: 311 lines of code sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/KafkaSourceConsumerFn.java x: 18 commits (all time) y: 373 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkConfiguration.java x: 46 commits (all time) y: 551 lines of code sdks/python/apache_beam/io/iobase.py x: 271 commits (all time) y: 750 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadSchemaTransformProvider.java x: 9 commits (all time) y: 280 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3ReadableSeekableByteChannel.java x: 22 commits (all time) y: 157 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsIO.java x: 47 commits (all time) y: 623 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsUnboundedReader.java x: 40 commits (all time) y: 603 lines of code sdks/java/io/hadoop-common/src/main/java/org/apache/beam/sdk/io/hadoop/SerializableConfiguration.java x: 47 commits (all time) y: 88 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/TFRecordIO.java x: 113 commits (all time) y: 480 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextIO.java x: 293 commits (all time) y: 806 lines of code sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/io/AvroIO.java x: 20 commits (all time) y: 1177 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/BeamSqlCli.java x: 74 commits (all time) y: 55 lines of code sdks/python/apache_beam/ml/gcp/recommendations_ai.py x: 10 commits (all time) y: 367 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowMetrics.java x: 122 commits (all time) y: 359 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnContextFactory.java x: 100 commits (all time) y: 464 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/SideInputContainer.java x: 73 commits (all time) y: 233 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleCheckpointHandlers.java x: 45 commits (all time) y: 106 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/WindowGroupP.java x: 34 commits (all time) y: 271 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java x: 102 commits (all time) y: 471 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/PrepareWrite.java x: 48 commits (all time) y: 62 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/ByteBuddyDoFnInvokerFactory.java x: 183 commits (all time) y: 1046 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java x: 129 commits (all time) y: 137 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoEvaluator.java x: 172 commits (all time) y: 255 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkStatefulDoFnFunction.java x: 108 commits (all time) y: 215 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SplittableDoFnOperator.java x: 136 commits (all time) y: 149 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SimpleParDoFn.java x: 65 commits (all time) y: 394 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingGroupAlsoByWindowViaWindowSetFn.java x: 10 commits (all time) y: 77 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaDoFnRunners.java x: 77 commits (all time) y: 426 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkGroupAlsoByWindowViaWindowSet.java x: 129 commits (all time) y: 366 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/GroupByWindowFunction.java x: 41 commits (all time) y: 162 lines of code sdks/python/apache_beam/io/localfilesystem.py x: 74 commits (all time) y: 158 lines of code sdks/go/pkg/beam/runners/dataflow/dataflow.go x: 179 commits (all time) y: 377 lines of code .test-infra/metrics/sync/github/github_runs_prefetcher/code/config.yaml x: 6 commits (all time) y: 322 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunner.java x: 58 commits (all time) y: 23 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/GroupByKeyViaGroupByKeyOnly.java x: 66 commits (all time) y: 145 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/ProcessFnRunner.java x: 67 commits (all time) y: 103 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java x: 90 commits (all time) y: 157 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableProcessElementInvoker.java x: 60 commits (all time) y: 53 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/StatefulDoFnRunner.java x: 94 commits (all time) y: 302 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/DoFnLifecycleManagerRemovingTransformEvaluator.java x: 50 commits (all time) y: 61 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupByKeyOnlyEvaluatorFactory.java x: 94 commits (all time) y: 106 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ImmutabilityCheckingBundleFactory.java x: 76 commits (all time) y: 94 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ImmutableListBundleFactory.java x: 81 commits (all time) y: 134 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/MultiStepCombine.java x: 72 commits (all time) y: 418 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoMultiOverrideFactory.java x: 147 commits (all time) y: 247 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/QuiescenceDriver.java x: 69 commits (all time) y: 263 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/StatefulParDoEvaluatorFactory.java x: 157 commits (all time) y: 219 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/StepTransformResult.java x: 87 commits (all time) y: 119 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/TestStreamEvaluatorFactory.java x: 145 commits (all time) y: 194 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java x: 164 commits (all time) y: 275 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ViewEvaluatorFactory.java x: 115 commits (all time) y: 54 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPortablePipelineTranslator.java x: 135 commits (all time) y: 461 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTransformTranslators.java x: 142 commits (all time) y: 688 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingAggregationsTranslators.java x: 3 commits (all time) y: 431 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPortablePipelineTranslator.java x: 170 commits (all time) y: 910 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunction.java x: 111 commits (all time) y: 322 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkPartialReduceFunction.java x: 56 commits (all time) y: 71 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperator.java x: 241 commits (all time) y: 1032 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/UnboundedSourceWrapper.java x: 144 commits (all time) y: 367 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchStatefulParDoOverrides.java x: 89 commits (all time) y: 223 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupingShuffleReader.java x: 46 commits (all time) y: 357 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java x: 43 commits (all time) y: 920 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSideInputReader.java x: 52 commits (all time) y: 793 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSink.java x: 30 commits (all time) y: 202 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PubsubDynamicSink.java x: 14 commits (all time) y: 128 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ShuffleSink.java x: 38 commits (all time) y: 262 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingSideInputDoFnRunner.java x: 20 commits (all time) y: 69 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ProcessBundleDescriptors.java x: 135 commits (all time) y: 445 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/translation/PipelineTranslatorUtils.java x: 64 commits (all time) y: 157 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/DAGBuilder.java x: 21 commits (all time) y: 174 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/JetTransformTranslators.java x: 29 commits (all time) y: 371 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/BoundedSourceSystem.java x: 61 commits (all time) y: 351 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/OpAdapter.java x: 42 commits (all time) y: 187 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/PortableDoFnOp.java x: 12 commits (all time) y: 381 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ParDoBoundMultiTranslator.java x: 93 commits (all time) y: 453 lines of code runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ParDoTranslatorBatch.java x: 30 commits (all time) y: 194 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/SourceRDD.java x: 106 commits (all time) y: 266 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/SparkUnboundedSource.java x: 100 commits (all time) y: 232 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/StateSpecFunctions.java x: 97 commits (all time) y: 140 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/BoundedDataset.java x: 86 commits (all time) y: 96 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/EvaluationContext.java x: 179 commits (all time) y: 214 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/GroupCombineFunctions.java x: 117 commits (all time) y: 147 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/MultiDoFnFunction.java x: 161 commits (all time) y: 200 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkCombineFn.java x: 42 commits (all time) y: 650 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/BeamFnDataReadRunner.java x: 140 commits (all time) y: 277 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/CombineRunners.java x: 96 commits (all time) y: 211 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FlattenRunner.java x: 79 commits (all time) y: 31 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PTransformRunnerFactory.java x: 79 commits (all time) y: 63 lines of code sdks/python/gen_protos.py x: 126 commits (all time) y: 372 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java x: 89 commits (all time) y: 1534 lines of code sdks/python/apache_beam/yaml/generate_yaml_docs.py x: 35 commits (all time) y: 518 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/PortablePipelineOptions.java x: 72 commits (all time) y: 89 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/MemoryMonitor.java x: 50 commits (all time) y: 530 lines of code sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/RequestResponseIO.java x: 11 commits (all time) y: 281 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/PartitionMetadata.java x: 18 commits (all time) y: 269 lines of code sdks/python/apache_beam/typehints/opcodes.py x: 91 commits (all time) y: 425 lines of code sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/coders/AvroCoder.java x: 15 commits (all time) y: 578 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/WindmillServerStub.java x: 66 commits (all time) y: 16 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsPusher.java x: 67 commits (all time) y: 83 lines of code sdks/python/apache_beam/dataframe/frames.py x: 252 commits (all time) y: 4173 lines of code sdks/python/apache_beam/io/fileio.py x: 219 commits (all time) y: 568 lines of code sdks/python/apache_beam/io/range_trackers.py x: 88 commits (all time) y: 293 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py x: 83 commits (all time) y: 218 lines of code sdks/python/apache_beam/runners/portability/abstract_job_service.py x: 59 commits (all time) y: 273 lines of code sdks/python/apache_beam/runners/portability/artifact_service.py x: 67 commits (all time) y: 271 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py x: 84 commits (all time) y: 916 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py x: 154 commits (all time) y: 1223 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/translations.py x: 121 commits (all time) y: 1679 lines of code sdks/python/apache_beam/testing/load_tests/load_test_metrics_utils.py x: 94 commits (all time) y: 398 lines of code sdks/python/apache_beam/transforms/window.py x: 150 commits (all time) y: 351 lines of code sdks/python/apache_beam/utils/urns.py x: 106 commits (all time) y: 94 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateBackedIterable.java x: 51 commits (all time) y: 246 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineRunner.java x: 154 commits (all time) y: 209 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedSource.java x: 49 commits (all time) y: 211 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BoundedQueueExecutor.java x: 53 commits (all time) y: 218 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubJsonClient.java x: 96 commits (all time) y: 332 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSink.java x: 97 commits (all time) y: 539 lines of code sdks/python/apache_beam/io/filesystem.py x: 145 commits (all time) y: 469 lines of code sdks/go/pkg/beam/model/pipeline_v1/external_transforms.pb.go x: 43 commits (all time) y: 733 lines of code sdks/go/pkg/beam/model/pipeline_v1/metrics.pb.go x: 55 commits (all time) y: 1734 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java x: 120 commits (all time) y: 77 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java x: 97 commits (all time) y: 1081 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkOptions.java x: 43 commits (all time) y: 336 lines of code sdks/go/pkg/beam/core/runtime/graphx/translate.go x: 211 commits (all time) y: 1259 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java x: 79 commits (all time) y: 731 lines of code sdks/python/apache_beam/utils/retry.py x: 105 commits (all time) y: 176 lines of code sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeIO.java x: 65 commits (all time) y: 1169 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MonitoringInfoEncodings.java x: 31 commits (all time) y: 147 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContext.java x: 63 commits (all time) y: 447 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisTransformRegistrar.java x: 3 commits (all time) y: 292 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3FileSystem.java x: 39 commits (all time) y: 579 lines of code sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystem.java x: 40 commits (all time) y: 374 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java x: 53 commits (all time) y: 20 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/RpcQosImpl.java x: 18 commits (all time) y: 839 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java x: 101 commits (all time) y: 186 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/metrics/JetMetricResults.java x: 32 commits (all time) y: 250 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/TestSparkRunner.java x: 136 commits (all time) y: 100 lines of code sdks/python/apache_beam/transforms/stats.py x: 53 commits (all time) y: 547 lines of code sdks/java/io/sparkreceiver/3/src/main/java/org/apache/beam/sdk/io/sparkreceiver/ReadFromSparkReceiverWithOffsetDoFn.java x: 1 commits (all time) y: 277 lines of code sdks/go/pkg/beam/io/bigqueryio/bigquery.go x: 51 commits (all time) y: 264 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java x: 75 commits (all time) y: 211 lines of code sdks/go/pkg/beam/util/starcgenx/starcgenx.go x: 37 commits (all time) y: 601 lines of code sdks/go/pkg/beam/core/runtime/graphx/serialize.go x: 68 commits (all time) y: 716 lines of code sdks/go/pkg/beam/runners/vet/vet.go x: 32 commits (all time) y: 505 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java x: 117 commits (all time) y: 459 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/ActiveWorkState.java x: 29 commits (all time) y: 267 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineOptions.java x: 128 commits (all time) y: 262 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java x: 143 commits (all time) y: 1587 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java x: 111 commits (all time) y: 145 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryOptions.java x: 71 commits (all time) y: 163 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/MetricsToPerStepNamespaceMetricsConverter.java x: 18 commits (all time) y: 237 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ByteStringCoder.java x: 36 commits (all time) y: 26 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateReader.java x: 14 commits (all time) y: 813 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClientPoolService.java x: 88 commits (all time) y: 85 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/GrpcDataService.java x: 91 commits (all time) y: 142 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/ExternalEnvironmentFactory.java x: 42 commits (all time) y: 160 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/provisioning/StaticGrpcProvisionService.java x: 61 commits (all time) y: 52 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/GrpcStateService.java x: 65 commits (all time) y: 116 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java x: 84 commits (all time) y: 441 lines of code runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/InMemoryJobService.java x: 45 commits (all time) y: 441 lines of code runners/portability/java/src/main/java/org/apache/beam/runners/portability/JobServicePipelineResult.java x: 58 commits (all time) y: 177 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextSource.java x: 74 commits (all time) y: 390 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/WindowingStrategyTranslation.java x: 4 commits (all time) y: 322 lines of code sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/JavaClassLookupTransformProvider.java x: 40 commits (all time) y: 523 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/BeamFnControlClient.java x: 101 commits (all time) y: 137 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnDataGrpcClient.java x: 110 commits (all time) y: 83 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/logging/BeamFnLoggingClient.java x: 127 commits (all time) y: 371 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java x: 128 commits (all time) y: 537 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/counters/CounterFactory.java x: 35 commits (all time) y: 638 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/WorkProgressUpdater.java x: 32 commits (all time) y: 209 lines of code sdks/go/pkg/beam/core/runtime/exec/translate.go x: 145 commits (all time) y: 732 lines of code sdks/go/pkg/beam/core/runtime/graphx/schema/schema.go x: 33 commits (all time) y: 659 lines of code sdks/go/pkg/beam/core/runtime/harness/statemgr.go x: 59 commits (all time) y: 588 lines of code sdks/go/pkg/beam/core/runtime/xlangx/registry.go x: 21 commits (all time) y: 214 lines of code sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api.pb.go x: 134 commits (all time) y: 5486 lines of code sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api_grpc.pb.go x: 22 commits (all time) y: 570 lines of code sdks/go/pkg/beam/model/fnexecution_v1/beam_provision_api.pb.go x: 96 commits (all time) y: 383 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_artifact_api.pb.go x: 83 commits (all time) y: 1484 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_artifact_api_grpc.pb.go x: 22 commits (all time) y: 457 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_expansion_api.pb.go x: 47 commits (all time) y: 543 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_job_api.pb.go x: 83 commits (all time) y: 2041 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_job_api_grpc.pb.go x: 26 commits (all time) y: 453 lines of code sdks/go/pkg/beam/model/pipeline_v1/endpoints.pb.go x: 67 commits (all time) y: 204 lines of code sdks/go/pkg/beam/model/pipeline_v1/schema.pb.go x: 30 commits (all time) y: 1749 lines of code sdks/go/pkg/beam/model/pipeline_v1/standard_window_fns.pb.go x: 68 commits (all time) y: 487 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java x: 299 commits (all time) y: 1473 lines of code sdks/python/apache_beam/transforms/sideinputs.py x: 54 commits (all time) y: 56 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServices.java x: 164 commits (all time) y: 145 lines of code sdks/go/pkg/beam/transforms/stats/quantiles.go x: 13 commits (all time) y: 556 lines of code sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/SolaceIO.java x: 12 commits (all time) y: 457 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiLoads.java x: 52 commits (all time) y: 406 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkStateInternals.java x: 80 commits (all time) y: 519 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java x: 132 commits (all time) y: 39 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteWriteSchemaTransformProvider.java x: 25 commits (all time) y: 386 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/Pipeline.java x: 195 commits (all time) y: 454 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java x: 125 commits (all time) y: 422 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/JavaBeanSchema.java x: 85 commits (all time) y: 185 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/JavaFieldSchema.java x: 71 commits (all time) y: 122 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ReflectUtils.java x: 72 commits (all time) y: 203 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/ReflectHelpers.java x: 105 commits (all time) y: 231 lines of code sdks/python/apache_beam/dataframe/frame_base.py x: 99 commits (all time) y: 516 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/providers/JavaRowUdf.java x: 13 commits (all time) y: 293 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteTables.java x: 172 commits (all time) y: 487 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java x: 89 commits (all time) y: 378 lines of code sdks/python/apache_beam/portability/common_urns.py x: 102 commits (all time) y: 63 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java x: 242 commits (all time) y: 761 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java x: 105 commits (all time) y: 432 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PeriodicSequence.java x: 37 commits (all time) y: 225 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceImpl.java x: 129 commits (all time) y: 715 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java x: 81 commits (all time) y: 167 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/CoGroup.java x: 67 commits (all time) y: 525 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java x: 97 commits (all time) y: 921 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java x: 118 commits (all time) y: 916 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java x: 9 commits (all time) y: 310 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java x: 213 commits (all time) y: 338 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java x: 201 commits (all time) y: 1179 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/ByteBuddyOnTimerInvokerFactory.java x: 96 commits (all time) y: 253 lines of code sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/ClickHouseIO.java x: 67 commits (all time) y: 307 lines of code sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/ClickHouseWriter.java x: 42 commits (all time) y: 141 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteRename.java x: 99 commits (all time) y: 388 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HttpHealthcareApiClient.java x: 70 commits (all time) y: 834 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py x: 74 commits (all time) y: 2358 lines of code sdks/python/apache_beam/runners/direct/executor.py x: 113 commits (all time) y: 499 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py x: 49 commits (all time) y: 389 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/state/StateSpecs.java x: 66 commits (all time) y: 614 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithKeys.java x: 76 commits (all time) y: 79 lines of code sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet/ParquetIO.java x: 115 commits (all time) y: 806 lines of code sdks/python/apache_beam/runners/common.pxd x: 124 commits (all time) y: 136 lines of code sdks/go/pkg/beam/core/runtime/exec/datasource.go x: 135 commits (all time) y: 592 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java x: 143 commits (all time) y: 428 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/DynamicDestinationsHelpers.java x: 85 commits (all time) y: 389 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkTransformOverrides.java x: 64 commits (all time) y: 44 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableConfigTranslator.java x: 22 commits (all time) y: 402 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformEvaluatorRegistry.java x: 149 commits (all time) y: 138 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WriteWithShardingFactory.java x: 115 commits (all time) y: 110 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkRunner.java x: 123 commits (all time) y: 107 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/GroupIntoBatchesOverride.java x: 39 commits (all time) y: 284 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TransformTranslator.java x: 81 commits (all time) y: 57 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/PackageUtil.java x: 109 commits (all time) y: 379 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactory.java x: 116 commits (all time) y: 603 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/RemoteBundle.java x: 42 commits (all time) y: 17 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java x: 134 commits (all time) y: 543 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java x: 71 commits (all time) y: 936 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkNativePipelineVisitor.java x: 83 commits (all time) y: 163 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunnerDebugger.java x: 63 commits (all time) y: 87 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PTransform.java x: 102 commits (all time) y: 132 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java x: 160 commits (all time) y: 237 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformMatchers.java x: 3 commits (all time) y: 397 lines of code sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/TableSchema.java x: 43 commits (all time) y: 256 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/SubscribeTransform.java x: 32 commits (all time) y: 181 lines of code sdks/java/io/neo4j/src/main/java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java x: 23 commits (all time) y: 807 lines of code sdks/typescript/src/apache_beam/pvalue.ts x: 35 commits (all time) y: 246 lines of code sdks/typescript/src/apache_beam/runners/direct_runner.ts x: 39 commits (all time) y: 405 lines of code sdks/typescript/src/apache_beam/runners/portable_runner/runner.ts x: 42 commits (all time) y: 283 lines of code sdks/typescript/src/apache_beam/worker/operators.ts x: 49 commits (all time) y: 816 lines of code website/www/site/layouts/index.html x: 65 commits (all time) y: 224 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkBroadcastStateInternals.java x: 83 commits (all time) y: 564 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ConfigBuilder.java x: 79 commits (all time) y: 273 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryStateInternals.java x: 91 commits (all time) y: 719 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryTimerInternals.java x: 77 commits (all time) y: 253 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java x: 93 commits (all time) y: 194 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.java x: 76 commits (all time) y: 466 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachineRunner.java x: 59 commits (all time) y: 132 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/KeyedPValueTrackingVisitor.java x: 72 commits (all time) y: 85 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java x: 215 commits (all time) y: 1165 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkRunnerResult.java x: 57 commits (all time) y: 50 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/FlinkMetricContainer.java x: 75 commits (all time) y: 30 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java x: 104 commits (all time) y: 505 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineOptionsValidator.java x: 32 commits (all time) y: 26 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunnerRegistrar.java x: 61 commits (all time) y: 25 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/SparkBeamMetric.java x: 62 commits (all time) y: 78 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/util/GlobalWatermarkHolder.java x: 58 commits (all time) y: 256 lines of code sdks/go/pkg/beam/core/graph/fn.go x: 92 commits (all time) y: 1247 lines of code sdks/go/pkg/beam/core/runtime/exec/sdf.go x: 61 commits (all time) y: 627 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java x: 127 commits (all time) y: 191 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/CompressedSource.java x: 144 commits (all time) y: 283 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingSource.java x: 91 commits (all time) y: 332 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/ProxyInvocationHandler.java x: 131 commits (all time) y: 620 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java x: 138 commits (all time) y: 392 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldAccessDescriptor.java x: 88 commits (all time) y: 441 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Cast.java x: 49 commits (all time) y: 292 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Group.java x: 63 commits (all time) y: 844 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectByteBuddyHelpers.java x: 33 commits (all time) y: 691 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectHelpers.java x: 43 commits (all time) y: 343 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/CoderProperties.java x: 81 commits (all time) y: 293 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SourceTestUtils.java x: 81 commits (all time) y: 644 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateQuantiles.java x: 97 commits (all time) y: 426 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java x: 80 commits (all time) y: 218 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java x: 274 commits (all time) y: 541 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Regex.java x: 60 commits (all time) y: 428 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Top.java x: 90 commits (all time) y: 263 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/display/DisplayData.java x: 139 commits (all time) y: 509 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/OffsetRangeTracker.java x: 82 commits (all time) y: 112 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterEach.java x: 66 commits (all time) y: 38 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/ApiSurface.java x: 94 commits (all time) y: 530 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableUtils.java x: 54 commits (all time) y: 146 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollection.java x: 114 commits (all time) y: 266 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/RowUtils.java x: 35 commits (all time) y: 510 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowingStrategy.java x: 49 commits (all time) y: 338 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java x: 39 commits (all time) y: 506 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java x: 48 commits (all time) y: 466 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BigQueryTableProvider.java x: 52 commits (all time) y: 28 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/text/TextTableProvider.java x: 95 commits (all time) y: 213 lines of code sdks/java/io/cdap/src/main/java/org/apache/beam/sdk/io/cdap/CdapIO.java x: 20 commits (all time) y: 240 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryTableSource.java x: 81 commits (all time) y: 78 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/action/DetectNewPartitionsAction.java x: 18 commits (all time) y: 214 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/RpcQosOptions.java x: 10 commits (all time) y: 377 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsub.java x: 78 commits (all time) y: 306 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsubSignal.java x: 71 commits (all time) y: 312 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/OrderedCode.java x: 35 commits (all time) y: 450 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClient.java x: 71 commits (all time) y: 470 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeJobService.java x: 50 commits (all time) y: 493 lines of code sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java x: 102 commits (all time) y: 667 lines of code sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/InfluxDbIO.java x: 27 commits (all time) y: 503 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/SchemaUtil.java x: 56 commits (all time) y: 358 lines of code sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java x: 96 commits (all time) y: 544 lines of code sdks/java/io/singlestore/src/main/java/org/apache/beam/sdk/io/singlestore/SingleStoreIO.java x: 11 commits (all time) y: 678 lines of code sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/XmlIO.java x: 83 commits (all time) y: 363 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsSchemas.java x: 13 commits (all time) y: 632 lines of code website/www/site/data/capability_matrix_snapshot.yaml x: 17 commits (all time) y: 733 lines of code playground/backend/internal/code_processing/code_processing.go x: 64 commits (all time) y: 497 lines of code learning/tour-of-beam/backend/playground_api/api/v1/api.pb.go x: 6 commits (all time) y: 3333 lines of code learning/tour-of-beam/backend/playground_api/api/v1/api_grpc.pb.go x: 5 commits (all time) y: 736 lines of code learning/tour-of-beam/backend/playground_api/api/v1/mock.go x: 4 commits (all time) y: 811 lines of code model/fn-execution/src/main/resources/org/apache/beam/model/fnexecution/v1/standard_coders.yaml x: 76 commits (all time) y: 395 lines of code playground/backend/cmd/server/controller.go x: 102 commits (all time) y: 517 lines of code playground/backend/internal/api/v1/api.pb.go x: 67 commits (all time) y: 3333 lines of code playground/frontend/playground_components/assets/symbols/go.g.yaml x: 7 commits (all time) y: 6641 lines of code playground/frontend/playground_components/lib/src/api/v1/api.pb.dart x: 13 commits (all time) y: 2383 lines of code playground/frontend/playground_components/lib/src/api/v1/api.pbgrpc.dart x: 7 commits (all time) y: 546 lines of code playground/frontend/playground_components/lib/src/controllers/playground_controller.dart x: 20 commits (all time) y: 268 lines of code playground/frontend/playground_components/lib/src/repositories/example_client/grpc_example_client.dart x: 14 commits (all time) y: 325 lines of code playground/infrastructure/api/v1/api_pb2_grpc.py x: 30 commits (all time) y: 612 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/CommittedResult.java x: 72 commits (all time) y: 27 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java x: 83 commits (all time) y: 100 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java x: 64 commits (all time) y: 549 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineOptions.java x: 135 commits (all time) y: 50 lines of code scripts/ci/pr-bot/gatherMetrics.ts x: 7 commits (all time) y: 429 lines of code sdks/go/pkg/beam/core/funcx/fn.go x: 50 commits (all time) y: 626 lines of code sdks/go/pkg/beam/core/graph/edge.go x: 73 commits (all time) y: 361 lines of code sdks/go/pkg/beam/core/metrics/metrics.go x: 53 commits (all time) y: 712 lines of code sdks/go/pkg/beam/core/runtime/exec/coder.go x: 86 commits (all time) y: 1043 lines of code sdks/go/pkg/beam/core/runtime/exec/combine.go x: 84 commits (all time) y: 489 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/decoders.go x: 12 commits (all time) y: 1856 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/encoders.go x: 12 commits (all time) y: 1772 lines of code sdks/go/pkg/beam/core/runtime/graphx/v1/v1.pb.go x: 33 commits (all time) y: 1608 lines of code sdks/go/pkg/beam/core/util/reflectx/calls.go x: 24 commits (all time) y: 1490 lines of code sdks/go/pkg/beam/register/register.go x: 11 commits (all time) y: 7254 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvokers.java x: 86 commits (all time) y: 42 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/nfa/NFA.java x: 15 commits (all time) y: 640 lines of code sdks/python/apache_beam/io/aws/s3io.py x: 34 commits (all time) y: 351 lines of code sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_messages.py x: 31 commits (all time) y: 1582 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/cloudbuild/cloudbuild_v1_messages.py x: 12 commits (all time) y: 1135 lines of code sdks/typescript/src/apache_beam/proto/google/protobuf/descriptor.ts x: 6 commits (all time) y: 1991 lines of code sdks/typescript/src/apache_beam/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.ts x: 4 commits (all time) y: 3456 lines of code sdks/typescript/src/apache_beam/proto/org/apache/beam/model/job_management/v1/beam_artifact_api.ts x: 4 commits (all time) y: 994 lines of code sdks/typescript/src/apache_beam/proto/org/apache/beam/model/job_management/v1/beam_job_api.ts x: 4 commits (all time) y: 1193 lines of code sdks/typescript/src/apache_beam/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.ts x: 4 commits (all time) y: 5095 lines of code website/www/site/assets/scss/_syntax-highlighting.scss x: 15 commits (all time) y: 393 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/trigger_manager.py x: 4 commits (all time) y: 352 lines of code website/www/site/assets/scss/bootstrap/_navbar.scss x: 7 commits (all time) y: 480 lines of code
7254.0
lines of code
  min: 1.0
  average: 111.5
  25th percentile: 13.0
  median: 42.0
  75th percentile: 112.0
  max: 7254.0
0 1519.0
commits (all time)
min: 1.0 | average: 22.28 | 25th percentile: 4.0 | median: 9.0 | 75th percentile: 24.0 | max: 1519.0

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

sdks/python/apache_beam/version.py x: 86 contributors (all time) y: 1 lines of code sdks/python/apache_beam/utils/subprocess_server.py x: 40 contributors (all time) y: 456 lines of code sdks/go/pkg/beam/core/core.go x: 34 contributors (all time) y: 6 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java x: 88 contributors (all time) y: 1709 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy x: 261 contributors (all time) y: 2377 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/AvroGenericRecordToStorageApiProto.java x: 13 contributors (all time) y: 490 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProto.java x: 13 contributors (all time) y: 393 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtils.java x: 57 contributors (all time) y: 548 lines of code sdks/python/apache_beam/io/components/rate_limiter.py x: 1 contributors (all time) y: 138 lines of code sdks/python/apache_beam/ml/inference/base.py x: 22 contributors (all time) y: 1170 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java x: 85 contributors (all time) y: 1055 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineRunner.java x: 43 contributors (all time) y: 165 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java x: 89 contributors (all time) y: 1253 lines of code sdks/python/apache_beam/yaml/yaml_io.py x: 11 contributors (all time) y: 362 lines of code sdks/python/apache_beam/runners/dataflow/internal/names.py x: 99 contributors (all time) y: 6 lines of code sdks/python/apache_beam/yaml/yaml_transform.py x: 15 contributors (all time) y: 1049 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowToStorageApiProto.java x: 35 contributors (all time) y: 1607 lines of code sdks/python/apache_beam/yaml/yaml_testing.py x: 4 contributors (all time) y: 444 lines of code sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read/SolaceCheckpointMark.java x: 2 contributors (all time) y: 57 lines of code sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read/UnboundedSolaceReader.java x: 5 contributors (all time) y: 191 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryWriteSchemaTransformProvider.java x: 4 contributors (all time) y: 60 lines of code website/www/site/data/en/quotes.yaml x: 23 contributors (all time) y: 36 lines of code sdks/python/container/license_scripts/dep_urls_py.yaml x: 40 contributors (all time) y: 144 lines of code sdks/typescript/reporterConfig.js x: 2 contributors (all time) y: 13 lines of code runners/portability/java/src/main/java/org/apache/beam/runners/portability/PortableMetrics.java x: 23 contributors (all time) y: 226 lines of code sdks/python/apache_beam/transforms/core.py x: 128 contributors (all time) y: 2413 lines of code sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java x: 91 contributors (all time) y: 1831 lines of code sdks/python/apache_beam/yaml/yaml_provider.py x: 20 contributors (all time) y: 1141 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/AppendFilesToTables.java x: 7 contributors (all time) y: 181 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/RecordWriter.java x: 7 contributors (all time) y: 146 lines of code sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java x: 9 contributors (all time) y: 38 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectRunner.java x: 51 contributors (all time) y: 296 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/dao/MetadataTableDao.java x: 9 contributors (all time) y: 523 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySourceBase.java x: 59 contributors (all time) y: 201 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageApiInsertError.java x: 7 contributors (all time) y: 44 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiConvertMessages.java x: 15 contributors (all time) y: 172 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java x: 37 contributors (all time) y: 1114 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java x: 34 contributors (all time) y: 870 lines of code sdks/python/apache_beam/coders/coder_impl.py x: 91 contributors (all time) y: 1409 lines of code sdks/python/apache_beam/coders/coders_test_common.py x: 79 contributors (all time) y: 816 lines of code sdks/python/apache_beam/transforms/periodicsequence.py x: 19 contributors (all time) y: 269 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java x: 150 contributors (all time) y: 2664 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOTranslation.java x: 13 contributors (all time) y: 867 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageQuerySource.java x: 40 contributors (all time) y: 214 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java x: 41 contributors (all time) y: 195 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageTableSource.java x: 43 contributors (all time) y: 189 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java x: 62 contributors (all time) y: 791 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillKeyedWorkItem.java x: 25 contributors (all time) y: 189 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimerInternals.java x: 47 contributors (all time) y: 168 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindowingWindmillReader.java x: 27 contributors (all time) y: 140 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/CachingStateTable.java x: 4 contributors (all time) y: 265 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillCombiningState.java x: 3 contributors (all time) y: 129 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateInternals.java x: 4 contributors (all time) y: 116 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncoding.java x: 1 contributors (all time) y: 75 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillTagEncodingV1.java x: 1 contributors (all time) y: 164 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/KeyCommitTooLargeException.java x: 4 contributors (all time) y: 30 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/processing/failures/WorkFailureProcessor.java x: 3 contributors (all time) y: 154 lines of code sdks/java/container/license_scripts/dep_urls_java.yaml x: 55 contributors (all time) y: 47 lines of code sdks/python/apache_beam/runners/interactive/interactive_environment.py x: 50 contributors (all time) y: 390 lines of code sdks/python/apache_beam/runners/interactive/recording_manager.py x: 34 contributors (all time) y: 667 lines of code settings.gradle.kts x: 105 contributors (all time) y: 339 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/GrowableOffsetRangeTracker.java x: 19 contributors (all time) y: 69 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/UnsplittableRestrictionTracker.java x: 1 contributors (all time) y: 37 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java x: 37 contributors (all time) y: 588 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisIO.java x: 31 contributors (all time) y: 794 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/RecordWriterManager.java x: 8 contributors (all time) y: 306 lines of code website/www/site/config.toml x: 55 contributors (all time) y: 89 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/commits/StreamingEngineWorkCommitter.java x: 6 contributors (all time) y: 214 lines of code sdks/python/apache_beam/options/pipeline_options.py x: 142 contributors (all time) y: 1719 lines of code sdks/python/apache_beam/runners/dask/dask_runner.py x: 4 contributors (all time) y: 175 lines of code sdks/python/apache_beam/ml/inference/pytorch_inference.py x: 20 contributors (all time) y: 334 lines of code sdks/python/apache_beam/ml/inference/sklearn_inference.py x: 18 contributors (all time) y: 169 lines of code sdks/python/apache_beam/ml/inference/tensorflow_inference.py x: 6 contributors (all time) y: 186 lines of code sdks/python/apache_beam/ml/inference/tensorrt_inference.py x: 13 contributors (all time) y: 212 lines of code sdks/python/apache_beam/ml/inference/vertex_ai_inference.py x: 5 contributors (all time) y: 90 lines of code sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java x: 12 contributors (all time) y: 246 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TimestampPrecision.java x: 1 contributors (all time) y: 7 lines of code .test-infra/metrics/sync/github/github_runs_prefetcher/code/main.py x: 7 contributors (all time) y: 401 lines of code sdks/java/extensions/sql/src/main/codegen/includes/parserImpls.ftl x: 23 contributors (all time) y: 731 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteSchema.java x: 32 contributors (all time) y: 120 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSystemSchema.java x: 1 contributors (all time) y: 94 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CatalogManagerSchema.java x: 1 contributors (all time) y: 231 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlCreateExternalTable.java x: 38 contributors (all time) y: 183 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDdlNodes.java x: 26 contributors (all time) y: 73 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlUseDatabase.java x: 2 contributors (all time) y: 65 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/catalog/InMemoryCatalog.java x: 2 contributors (all time) y: 100 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/FileWriteResult.java x: 8 contributors (all time) y: 48 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/SerializableDataFile.java x: 4 contributors (all time) y: 218 lines of code sdks/python/apache_beam/runners/portability/stager.py x: 70 contributors (all time) y: 567 lines of code sdks/python/apache_beam/ml/inference/gemini_inference.py x: 4 contributors (all time) y: 89 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreStatefulComponentFactory.java x: 11 contributors (all time) y: 88 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1.java x: 14 contributors (all time) y: 1028 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1ReadFn.java x: 16 contributors (all time) y: 592 lines of code sdks/go/pkg/beam/runners/prism/internal/jobservices/server.go x: 7 contributors (all time) y: 106 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteTable.java x: 34 contributors (all time) y: 107 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSqlEnv.java x: 56 contributors (all time) y: 235 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java x: 33 contributors (all time) y: 83 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcDriver.java x: 38 contributors (all time) y: 118 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ScalarFunctionImpl.java x: 33 contributors (all time) y: 165 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TVFSlidingWindowFn.java x: 14 contributors (all time) y: 50 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TableResolutionUtils.java x: 25 contributors (all time) y: 126 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdfImpl.java x: 27 contributors (all time) y: 36 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/ReadOnlyTableProvider.java x: 31 contributors (all time) y: 47 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/TableProvider.java x: 32 contributors (all time) y: 28 lines of code build.gradle.kts x: 88 contributors (all time) y: 769 lines of code model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto x: 21 contributors (all time) y: 1176 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillSink.java x: 41 contributors (all time) y: 296 lines of code sdks/python/apache_beam/coders/typecoders.py x: 61 contributors (all time) y: 117 lines of code sdks/python/apache_beam/internal/cloudpickle_pickler.py x: 11 contributors (all time) y: 180 lines of code sdks/python/apache_beam/internal/pickler.py x: 59 contributors (all time) y: 66 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py x: 53 contributors (all time) y: 934 lines of code sdks/python/apache_beam/runners/worker/sdk_worker_main.py x: 79 contributors (all time) y: 271 lines of code sdks/python/apache_beam/typehints/schemas.py x: 50 contributors (all time) y: 846 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/fn/data/WeightedList.java x: 6 contributors (all time) y: 50 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateFetchingIterators.java x: 47 contributors (all time) y: 530 lines of code sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go x: 8 contributors (all time) y: 1756 lines of code sdks/go/pkg/beam/runners/prism/internal/execute.go x: 8 contributors (all time) y: 406 lines of code sdks/go/pkg/beam/runners/prism/internal/handlerunner.go x: 7 contributors (all time) y: 474 lines of code website/www/site/layouts/partials/head.html x: 24 contributors (all time) y: 70 lines of code website/www/site/layouts/partials/head_homepage.html x: 9 contributors (all time) y: 64 lines of code sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtils.java x: 20 contributors (all time) y: 1365 lines of code sdks/java/extensions/arrow/src/main/java/org/apache/beam/sdk/extensions/arrow/ArrowConversion.java x: 12 contributors (all time) y: 449 lines of code sdks/python/apache_beam/io/mongodbio.py x: 42 contributors (all time) y: 445 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java x: 31 contributors (all time) y: 347 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/Work.java x: 11 contributors (all time) y: 328 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/IntervalWindow.java x: 23 contributors (all time) y: 130 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/PaneInfo.java x: 30 contributors (all time) y: 250 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueWithRecordId.java x: 19 contributors (all time) y: 108 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ReifyTimestampAndWindowsParDoFnFactory.java x: 23 contributors (all time) y: 69 lines of code sdks/python/apache_beam/transforms/util.py x: 101 contributors (all time) y: 1457 lines of code sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/ReadFn.java x: 21 contributors (all time) y: 123 lines of code sdks/go/pkg/beam/io/avroio/avroio.go x: 14 contributors (all time) y: 184 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java x: 99 contributors (all time) y: 1066 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/SingleSourceWorkerHarness.java x: 8 contributors (all time) y: 240 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GetWorkResponseChunkAssembler.java x: 6 contributors (all time) y: 104 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcDirectGetWorkStream.java x: 11 contributors (all time) y: 304 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetWorkStream.java x: 10 contributors (all time) y: 185 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/WorkItemReceiver.java x: 4 contributors (all time) y: 17 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/processing/StreamingWorkScheduler.java x: 10 contributors (all time) y: 337 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowedValues.java x: 3 contributors (all time) y: 916 lines of code sdks/python/apache_beam/io/kafka.py x: 33 contributors (all time) y: 114 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsGenericRecord.java x: 10 contributors (all time) y: 96 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java x: 42 contributors (all time) y: 718 lines of code release/build.gradle.kts x: 20 contributors (all time) y: 26 lines of code sdks/python/apache_beam/io/hadoopfilesystem.py x: 42 contributors (all time) y: 271 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreOptions.java x: 10 contributors (all time) y: 24 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreV1WriteFn.java x: 15 contributors (all time) y: 513 lines of code sdks/python/apache_beam/yaml/extended_tests/data/enrichment.yaml x: 3 contributors (all time) y: 26 lines of code runners/flink/1.20/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java x: 1 contributors (all time) y: 1249 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/types/CoderTypeSerializer.java x: 24 contributors (all time) y: 119 lines of code sdks/typescript/src/apache_beam/runners/flink.ts x: 14 contributors (all time) y: 58 lines of code sdks/python/apache_beam/runners/worker/operations.pxd x: 36 contributors (all time) y: 98 lines of code sdks/python/apache_beam/runners/worker/operations.py x: 79 contributors (all time) y: 1028 lines of code sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/HCatalogIO.java x: 37 contributors (all time) y: 399 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationUtils.java x: 27 contributors (all time) y: 428 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/StructUtils.java x: 20 contributors (all time) y: 436 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergUtils.java x: 7 contributors (all time) y: 501 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/WriteUngroupedRowsToFiles.java x: 5 contributors (all time) y: 216 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/SdkHarnessOptions.java x: 27 contributors (all time) y: 246 lines of code sdks/python/apache_beam/runners/interactive/interactive_beam.py x: 48 contributors (all time) y: 545 lines of code sdks/python/apache_beam/io/requestresponse.py x: 6 contributors (all time) y: 494 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/GcsOptions.java x: 35 contributors (all time) y: 168 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java x: 5 contributors (all time) y: 147 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java x: 145 contributors (all time) y: 2215 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java x: 117 contributors (all time) y: 2191 lines of code sdks/python/conftest.py x: 18 contributors (all time) y: 90 lines of code sdks/python/apache_beam/ml/rag/ingestion/postgres_common.py x: 2 contributors (all time) y: 227 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/SqlTypes.java x: 12 contributors (all time) y: 16 lines of code sdks/python/apache_beam/yaml/standard_io.yaml x: 18 contributors (all time) y: 370 lines of code sdks/python/apache_beam/typehints/native_type_compatibility.py x: 64 contributors (all time) y: 331 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataUtils.java x: 27 contributors (all time) y: 74 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/OutputAndTimeBoundedSplittableProcessElementInvoker.java x: 51 contributors (all time) y: 341 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputReader.java x: 7 contributors (all time) y: 12 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SimpleDoFnRunner.java x: 75 contributors (all time) y: 1254 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/state/TimerSpec.java x: 5 contributors (all time) y: 7 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java x: 68 contributors (all time) y: 296 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnSchemaInformation.java x: 26 contributors (all time) y: 174 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvoker.java x: 48 contributors (all time) y: 346 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java x: 61 contributors (all time) y: 1021 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/Preconditions.java x: 18 contributors (all time) y: 331 lines of code sdks/java/container/boot.go x: 58 contributors (all time) y: 355 lines of code sdks/python/apache_beam/typehints/trivial_inference.py x: 56 contributors (all time) y: 552 lines of code sdks/python/apache_beam/typehints/typehints.py x: 79 contributors (all time) y: 920 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AutoValueUtils.java x: 35 contributors (all time) y: 313 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java x: 51 contributors (all time) y: 1217 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java x: 37 contributors (all time) y: 463 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/POJOUtils.java x: 41 contributors (all time) y: 402 lines of code sdks/python/apache_beam/runners/worker/bundle_processor.py x: 96 contributors (all time) y: 1786 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java x: 24 contributors (all time) y: 333 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/MapTaskExecutor.java x: 29 contributors (all time) y: 157 lines of code sdks/python/apache_beam/runners/worker/channel_factory.py x: 17 contributors (all time) y: 24 lines of code sdks/python/apache_beam/internal/cloudpickle/cloudpickle.py x: 7 contributors (all time) y: 905 lines of code sdks/python/apache_beam/pipeline.py x: 110 contributors (all time) y: 971 lines of code sdks/python/apache_beam/ml/rag/enrichment/milvus_search.py x: 3 contributors (all time) y: 288 lines of code sdks/python/apache_beam/runners/portability/sdk_container_builder.py x: 27 contributors (all time) y: 293 lines of code website/www/site/assets/scss/_case_study.scss x: 18 contributors (all time) y: 372 lines of code website/www/site/assets/scss/_global.sass x: 20 contributors (all time) y: 142 lines of code website/www/site/layouts/case-studies/list.html x: 13 contributors (all time) y: 102 lines of code sdks/python/apache_beam/io/tfrecordio.py x: 53 contributors (all time) y: 208 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillOrderedList.java x: 6 contributors (all time) y: 237 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineExecutionEnvironment.java x: 58 contributors (all time) y: 162 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageStreamSource.java x: 41 contributors (all time) y: 372 lines of code sdks/python/apache_beam/__init__.py x: 50 contributors (all time) y: 29 lines of code sdks/python/apache_beam/coders/coders.py x: 106 contributors (all time) y: 1101 lines of code sdks/python/apache_beam/dataframe/expressions.py x: 18 contributors (all time) y: 201 lines of code sdks/python/apache_beam/dataframe/io.py x: 27 contributors (all time) y: 625 lines of code sdks/python/apache_beam/internal/gcp/auth.py x: 53 contributors (all time) y: 99 lines of code sdks/python/apache_beam/io/__init__.py x: 25 contributors (all time) y: 18 lines of code sdks/python/apache_beam/io/azure/blobstorageio.py x: 12 contributors (all time) y: 355 lines of code sdks/python/apache_beam/io/gcp/bigquery.py x: 127 contributors (all time) y: 1953 lines of code sdks/python/apache_beam/io/gcp/bigtableio.py x: 32 contributors (all time) y: 239 lines of code sdks/python/apache_beam/io/gcp/datastore/v1new/datastoreio.py x: 35 contributors (all time) y: 345 lines of code sdks/python/apache_beam/io/gcp/experimental/spannerio.py x: 33 contributors (all time) y: 781 lines of code sdks/python/apache_beam/metrics/metric.py x: 52 contributors (all time) y: 284 lines of code sdks/python/apache_beam/ml/gcp/recommendations_ai_test_it.py x: 11 contributors (all time) y: 80 lines of code sdks/python/apache_beam/ml/gcp/videointelligenceml_test_it.py x: 10 contributors (all time) y: 40 lines of code sdks/python/apache_beam/ml/transforms/embeddings/vertex_ai.py x: 9 contributors (all time) y: 350 lines of code sdks/python/apache_beam/ml/transforms/handlers.py x: 9 contributors (all time) y: 314 lines of code sdks/python/apache_beam/pvalue.py x: 74 contributors (all time) y: 384 lines of code sdks/python/apache_beam/runners/common.py x: 94 contributors (all time) y: 1311 lines of code sdks/python/apache_beam/runners/dataflow/dataflow_runner.py x: 123 contributors (all time) y: 554 lines of code sdks/python/apache_beam/runners/dataflow/internal/apiclient.py x: 122 contributors (all time) y: 975 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/cloudbuild/__init__.py x: 11 contributors (all time) y: 8 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/__init__.py x: 15 contributors (all time) y: 8 lines of code sdks/python/apache_beam/runners/dataflow/ptransform_overrides.py x: 46 contributors (all time) y: 45 lines of code sdks/python/apache_beam/runners/direct/direct_runner.py x: 74 contributors (all time) y: 427 lines of code sdks/python/apache_beam/runners/direct/evaluation_context.py x: 46 contributors (all time) y: 258 lines of code sdks/python/apache_beam/runners/direct/transform_evaluator.py x: 77 contributors (all time) y: 849 lines of code sdks/python/apache_beam/runners/interactive/augmented_pipeline.py x: 12 contributors (all time) y: 71 lines of code sdks/python/apache_beam/runners/interactive/dataproc/dataproc_cluster_manager.py x: 17 contributors (all time) y: 244 lines of code sdks/python/apache_beam/runners/interactive/display/display_manager.py x: 24 contributors (all time) y: 107 lines of code sdks/python/apache_beam/runners/interactive/display/pcoll_visualization.py x: 36 contributors (all time) y: 276 lines of code sdks/python/apache_beam/runners/interactive/interactive_runner.py x: 55 contributors (all time) y: 199 lines of code sdks/python/apache_beam/runners/interactive/utils.py x: 40 contributors (all time) y: 284 lines of code sdks/python/apache_beam/runners/runner.py x: 70 contributors (all time) y: 163 lines of code sdks/python/apache_beam/testing/analyzers/perf_analysis_utils.py x: 9 contributors (all time) y: 223 lines of code sdks/python/apache_beam/testing/benchmarks/inference/pytorch_image_classification_benchmarks.py x: 5 contributors (all time) y: 40 lines of code sdks/python/apache_beam/tools/coders_microbenchmark.py x: 27 contributors (all time) y: 221 lines of code sdks/python/apache_beam/transforms/ptransform.py x: 91 contributors (all time) y: 739 lines of code sdks/python/apache_beam/transforms/userstate.py x: 49 contributors (all time) y: 252 lines of code sdks/python/apache_beam/typehints/decorators.py x: 55 contributors (all time) y: 480 lines of code sdks/python/gen_xlang_wrappers.py x: 3 contributors (all time) y: 255 lines of code model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/metrics.proto x: 10 contributors (all time) y: 678 lines of code sdks/go/pkg/beam/runners/prism/internal/jobservices/metrics.go x: 6 contributors (all time) y: 563 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamCalcRel.java x: 56 contributors (all time) y: 746 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java x: 108 contributors (all time) y: 1656 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJsonUtils.java x: 8 contributors (all time) y: 91 lines of code sdks/python/apache_beam/io/gcp/bigquery_tools.py x: 90 contributors (all time) y: 1267 lines of code sdks/python/apache_beam/yaml/json_utils.py x: 8 contributors (all time) y: 275 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java x: 66 contributors (all time) y: 655 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/AppendClientInfo.java x: 10 contributors (all time) y: 141 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/RowWriterFactory.java x: 22 contributors (all time) y: 111 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsBeamRow.java x: 15 contributors (all time) y: 93 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsTableRow.java x: 19 contributors (all time) y: 158 lines of code sdks/python/apache_beam/ml/rag/ingestion/spanner.py x: 1 contributors (all time) y: 213 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ExecutionStateSampler.java x: 17 contributors (all time) y: 527 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java x: 83 contributors (all time) y: 1052 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/PCollectionConsumerRegistry.java x: 45 contributors (all time) y: 435 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/PTransformFunctionRegistry.java x: 25 contributors (all time) y: 61 lines of code model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.proto x: 26 contributors (all time) y: 1722 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/fn/stream/PrefetchableIterables.java x: 5 contributors (all time) y: 119 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/Environments.java x: 11 contributors (all time) y: 533 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java x: 51 contributors (all time) y: 1183 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillMap.java x: 10 contributors (all time) y: 353 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillMultimap.java x: 7 contributors (all time) y: 596 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchViewOverrides.java x: 35 contributors (all time) y: 929 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/ValueInEmptyWindows.java x: 18 contributors (all time) y: 72 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/util/TimerUtils.java x: 7 contributors (all time) y: 211 lines of code sdks/python/apache_beam/internal/metrics/metric.py x: 19 contributors (all time) y: 136 lines of code sdks/python/apache_beam/metrics/cells.py x: 67 contributors (all time) y: 648 lines of code sdks/python/apache_beam/metrics/execution.py x: 64 contributors (all time) y: 216 lines of code sdks/python/apache_beam/metrics/monitoring_infos.py x: 47 contributors (all time) y: 349 lines of code website/www/site/data/performance.yaml x: 7 contributors (all time) y: 240 lines of code sdks/python/apache_beam/io/gcp/gcsio.py x: 78 contributors (all time) y: 432 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/models/auction_bid.py x: 6 contributors (all time) y: 27 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/models/nexmark_model.py x: 12 contributors (all time) y: 167 lines of code sdks/python/apache_beam/internal/code_object_pickler.py x: 2 contributors (all time) y: 229 lines of code sdks/python/apache_beam/io/filebasedsink.py x: 54 contributors (all time) y: 416 lines of code website/www/site/layouts/partials/section-menu/en/documentation.html x: 57 contributors (all time) y: 396 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java x: 85 contributors (all time) y: 756 lines of code sdks/python/apache_beam/transforms/combiners.py x: 76 contributors (all time) y: 731 lines of code sdks/python/apache_beam/runners/worker/worker_status.py x: 28 contributors (all time) y: 293 lines of code sdks/python/apache_beam/runners/worker/data_plane.py x: 72 contributors (all time) y: 573 lines of code sdks/python/apache_beam/runners/worker/sdk_worker.py x: 101 contributors (all time) y: 986 lines of code sdks/python/apache_beam/internal/dill_pickler.py x: 13 contributors (all time) y: 297 lines of code sdks/python/apache_beam/io/filebasedsource.py x: 50 contributors (all time) y: 277 lines of code sdks/python/apache_beam/runners/portability/local_job_service.py x: 68 contributors (all time) y: 353 lines of code sdks/python/apache_beam/runners/portability/portable_runner.py x: 84 contributors (all time) y: 461 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/SplittingIterable.java x: 15 contributors (all time) y: 118 lines of code sdks/python/apache_beam/io/gcp/bigquery_schema_tools.py x: 6 contributors (all time) y: 77 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SplittableParDoViaKeyedWorkItems.java x: 43 contributors (all time) y: 544 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java x: 59 contributors (all time) y: 618 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDoNaiveBounded.java x: 4 contributors (all time) y: 607 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java x: 84 contributors (all time) y: 2428 lines of code sdks/go/pkg/beam/runners/prism/internal/stage.go x: 9 contributors (all time) y: 631 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupByEncryptedKey.java x: 1 contributors (all time) y: 180 lines of code sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionServiceOptions.java x: 9 contributors (all time) y: 89 lines of code sdks/python/apache_beam/runners/portability/prism_runner.py x: 8 contributors (all time) y: 326 lines of code sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/JAXBCoder.java x: 26 contributors (all time) y: 171 lines of code sdks/python/apache_beam/io/gcp/spanner.py x: 17 contributors (all time) y: 443 lines of code sdks/python/apache_beam/runners/portability/expansion_service.py x: 30 contributors (all time) y: 95 lines of code sdks/go/cmd/prism/prism.go x: 7 contributors (all time) y: 60 lines of code sdks/go/pkg/beam/core/runtime/harness/harness.go x: 62 contributors (all time) y: 569 lines of code sdks/go/pkg/beam/forward.go x: 30 contributors (all time) y: 74 lines of code sdks/go/pkg/beam/log/log.go x: 13 contributors (all time) y: 152 lines of code sdks/go/pkg/beam/runners/prism/internal/worker/worker.go x: 7 contributors (all time) y: 699 lines of code sdks/go/pkg/beam/runners/universal/universal.go x: 34 contributors (all time) y: 72 lines of code sdks/go/pkg/beam/runners/prism/internal/coders.go x: 7 contributors (all time) y: 291 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Reify.java x: 33 contributors (all time) y: 210 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Reshuffle.java x: 32 contributors (all time) y: 167 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/AutoValueSchema.java x: 27 contributors (all time) y: 110 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/TypeDescriptor.java x: 42 contributors (all time) y: 193 lines of code sdks/go/pkg/beam/core/runtime/xlangx/expansionx/download.go x: 14 contributors (all time) y: 355 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaReadSchemaTransformConfiguration.java x: 17 contributors (all time) y: 168 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStream.java x: 10 contributors (all time) y: 454 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaSourceDescriptor.java x: 17 contributors (all time) y: 106 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dao/PartitionMetadataDao.java x: 15 contributors (all time) y: 519 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/StreamingWorkerStatusReporter.java x: 5 contributors (all time) y: 379 lines of code sdks/python/apache_beam/transforms/external.py x: 64 contributors (all time) y: 871 lines of code sdks/python/apache_beam/transforms/managed.py x: 9 contributors (all time) y: 127 lines of code infra/enforcement/iam.py x: 1 contributors (all time) y: 259 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/External.java x: 4 contributors (all time) y: 411 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/providers/ReadFromPostgresSchemaTransformProvider.java x: 3 contributors (all time) y: 66 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/providers/WriteToPostgresSchemaTransformProvider.java x: 3 contributors (all time) y: 57 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java x: 65 contributors (all time) y: 1359 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptions.java x: 48 contributors (all time) y: 145 lines of code sdks/go/pkg/beam/core/runtime/graphx/coder.go x: 46 contributors (all time) y: 491 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/DataflowGroupByKey.java x: 2 contributors (all time) y: 148 lines of code sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumReadSchemaTransformProvider.java x: 10 contributors (all time) y: 154 lines of code sdks/python/apache_beam/coders/coder_impl.pxd x: 43 contributors (all time) y: 200 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaReadSchemaTransformProvider.java x: 16 contributors (all time) y: 367 lines of code sdks/python/apache_beam/runners/direct/direct_metrics.py x: 27 contributors (all time) y: 162 lines of code sdks/python/apache_beam/utils/histogram.py x: 15 contributors (all time) y: 209 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowStreamingPipelineOptions.java x: 8 contributors (all time) y: 200 lines of code runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto x: 38 contributors (all time) y: 858 lines of code sdks/go/pkg/beam/runners/prism/internal/engine/strategy.go x: 3 contributors (all time) y: 551 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoBeamConverter.java x: 2 contributors (all time) y: 512 lines of code playground/infrastructure/models.py x: 8 contributors (all time) y: 137 lines of code sdks/python/apache_beam/runners/portability/job_server.py x: 35 contributors (all time) y: 116 lines of code sdks/python/apache_beam/runners/portability/spark_uber_jar_job_server.py x: 26 contributors (all time) y: 203 lines of code sdks/python/apache_beam/transforms/trigger.py x: 81 contributors (all time) y: 1162 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/SqlTransform.java x: 51 contributors (all time) y: 194 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDropTable.java x: 24 contributors (all time) y: 51 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlSetOptionBeam.java x: 30 contributors (all time) y: 51 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/store/InMemoryMetaStore.java x: 37 contributors (all time) y: 96 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/BeamSqlEnvRunner.java x: 15 contributors (all time) y: 158 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteSchemaTransformProvider.java x: 7 contributors (all time) y: 370 lines of code sdks/python/apache_beam/yaml/extended_tests/databases/bigquery.yaml x: 3 contributors (all time) y: 110 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIOReadImplementationCompatibility.java x: 16 contributors (all time) y: 194 lines of code sdks/java/io/kafka/upgrade/src/main/java/org/apache/beam/sdk/io/kafka/upgrade/KafkaIOTranslation.java x: 11 contributors (all time) y: 585 lines of code sdks/java/container/license_scripts/pull_licenses_java.py x: 31 contributors (all time) y: 301 lines of code sdks/go/container/boot.go x: 34 contributors (all time) y: 233 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryStorageWriteApiSchemaTransformProvider.java x: 20 contributors (all time) y: 285 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java x: 25 contributors (all time) y: 150 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java x: 63 contributors (all time) y: 382 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java x: 34 contributors (all time) y: 334 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java x: 70 contributors (all time) y: 1089 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaUtils.java x: 17 contributors (all time) y: 348 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/Date.java x: 16 contributors (all time) y: 30 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/PassThroughLogicalType.java x: 17 contributors (all time) y: 42 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/Time.java x: 19 contributors (all time) y: 30 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/Row.java x: 67 contributors (all time) y: 584 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoByteBuddyUtils.java x: 30 contributors (all time) y: 1018 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoSchemaTranslator.java x: 26 contributors (all time) y: 277 lines of code sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/ThriftSchema.java x: 20 contributors (all time) y: 302 lines of code sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java x: 7 contributors (all time) y: 131 lines of code sdks/go/pkg/beam/core/runtime/xlangx/expansionx/process.go x: 8 contributors (all time) y: 82 lines of code sdks/go/pkg/beam/runners/prism/internal/preprocess.go x: 7 contributors (all time) y: 430 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnRunner.java x: 43 contributors (all time) y: 637 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/WindowMatchers.java x: 2 contributors (all time) y: 192 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java x: 76 contributors (all time) y: 1156 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkDoFnFunction.java x: 45 contributors (all time) y: 200 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkNonMergingReduceFunction.java x: 15 contributors (all time) y: 77 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartialGroupByKeyParDoFns.java x: 24 contributors (all time) y: 310 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowAndCombineFn.java x: 14 contributors (all time) y: 233 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java x: 54 contributors (all time) y: 640 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SplittableParDo.java x: 4 contributors (all time) y: 654 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/SplittableSplitAndSizeRestrictionsDoFnRunner.java x: 3 contributors (all time) y: 349 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/SplittableTruncateSizedRestrictionsDoFnRunner.java x: 3 contributors (all time) y: 823 lines of code sdks/python/apache_beam/dataframe/transforms.py x: 25 contributors (all time) y: 383 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java x: 96 contributors (all time) y: 1017 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/options/DataflowPipelineWorkerPoolOptions.java x: 40 contributors (all time) y: 98 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/SplittableProcessElementsEvaluatorFactory.java x: 50 contributors (all time) y: 162 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/CloudObjectTranslators.java x: 33 contributors (all time) y: 532 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/ProcessManager.java x: 30 contributors (all time) y: 177 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/util/SparkSideInputReader.java x: 46 contributors (all time) y: 107 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoByteUtils.java x: 4 contributors (all time) y: 235 lines of code sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java x: 37 contributors (all time) y: 1251 lines of code sdks/python/apache_beam/testing/util.py x: 58 contributors (all time) y: 255 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/observers/DirectStreamObserver.java x: 6 contributors (all time) y: 146 lines of code sdks/go/pkg/beam/beam.shims.go x: 18 contributors (all time) y: 262 lines of code sdks/go/pkg/beam/core/runtime/exec/emit.go x: 20 contributors (all time) y: 92 lines of code sdks/go/pkg/beam/core/runtime/exec/pardo.go x: 47 contributors (all time) y: 405 lines of code sdks/go/pkg/beam/runners/vet/testpipeline/testpipeline.shims.go x: 11 contributors (all time) y: 147 lines of code sdks/go/pkg/beam/testing/passert/passert.shims.go x: 21 contributors (all time) y: 522 lines of code sdks/go/pkg/beam/util/shimx/generate.go x: 15 contributors (all time) y: 371 lines of code sdks/go/pkg/beam/x/debug/debug.shims.go x: 14 contributors (all time) y: 322 lines of code sdks/python/apache_beam/runners/render.py x: 10 contributors (all time) y: 403 lines of code sdks/go/pkg/beam/runners/dataflow/dataflowlib/job.go x: 39 contributors (all time) y: 346 lines of code sdks/python/container/boot.go x: 54 contributors (all time) y: 389 lines of code sdks/python/apache_beam/io/gcp/pubsub.py x: 67 contributors (all time) y: 463 lines of code sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarIO.java x: 9 contributors (all time) y: 154 lines of code sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarSourceDescriptor.java x: 8 contributors (all time) y: 28 lines of code sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/package-info.java x: 9 contributors (all time) y: 1 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowJsonCoder.java x: 17 contributors (all time) y: 65 lines of code sdks/python/apache_beam/io/gcp/bigquery_read_internal.py x: 27 contributors (all time) y: 361 lines of code sdks/python/apache_beam/options/pipeline_options_validator.py x: 46 contributors (all time) y: 341 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/DataflowWorkerLoggingHandler.java x: 32 contributors (all time) y: 263 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/DataflowWorkerLoggingInitializer.java x: 30 contributors (all time) y: 208 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java x: 81 contributors (all time) y: 1081 lines of code sdks/python/apache_beam/transforms/enrichment_handlers/cloudsql.py x: 1 contributors (all time) y: 374 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIOUtils.java x: 22 contributors (all time) y: 118 lines of code sdks/python/apache_beam/ml/transforms/base.py x: 12 contributors (all time) y: 476 lines of code sdks/python/apache_beam/yaml/pipeline.schema.yaml x: 5 contributors (all time) y: 230 lines of code sdks/python/apache_beam/yaml/yaml_mapping.py x: 9 contributors (all time) y: 670 lines of code sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java x: 55 contributors (all time) y: 532 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java x: 66 contributors (all time) y: 611 lines of code sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/index.ts x: 12 contributors (all time) y: 135 lines of code sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml/EditablePanel.tsx x: 1 contributors (all time) y: 330 lines of code sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/yaml/YamlEditor.tsx x: 1 contributors (all time) y: 293 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerAccessor.java x: 51 contributors (all time) y: 267 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerConfig.java x: 52 contributors (all time) y: 230 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerTransformRegistrar.java x: 29 contributors (all time) y: 424 lines of code website/www/site/data/capability_matrix.yaml x: 27 contributors (all time) y: 1685 lines of code it/common/src/main/java/org/apache/beam/it/common/utils/ResourceManagerUtils.java x: 6 contributors (all time) y: 127 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/PaneInfoTracker.java x: 25 contributors (all time) y: 105 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/StateTags.java x: 34 contributors (all time) y: 270 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/TimerInternals.java x: 33 contributors (all time) y: 187 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/WatermarkHold.java x: 37 contributors (all time) y: 297 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java x: 68 contributors (all time) y: 690 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/ExecutableTriggerStateMachine.java x: 21 contributors (all time) y: 96 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineJob.java x: 53 contributors (all time) y: 382 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSources.java x: 50 contributors (all time) y: 702 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerCommand.java x: 31 contributors (all time) y: 180 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/Utils.java x: 22 contributors (all time) y: 231 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineResult.java x: 31 contributors (all time) y: 117 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/TranslationContext.java x: 38 contributors (all time) y: 303 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TransformTranslator.java x: 84 contributors (all time) y: 755 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/StreamingTransformTranslator.java x: 71 contributors (all time) y: 621 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataGrpcMultiplexer.java x: 9 contributors (all time) y: 242 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java x: 52 contributors (all time) y: 843 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java x: 65 contributors (all time) y: 1048 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptionsFactory.java x: 67 contributors (all time) y: 1521 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Select.java x: 34 contributors (all time) y: 188 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java x: 42 contributors (all time) y: 671 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java x: 78 contributors (all time) y: 2091 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/CombineFnUtil.java x: 14 contributors (all time) y: 128 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/ParDoTranslation.java x: 6 contributors (all time) y: 755 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/CovarianceFn.java x: 40 contributors (all time) y: 84 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java x: 78 contributors (all time) y: 1645 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIO.java x: 44 contributors (all time) y: 1182 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/action/QueryChangeStreamAction.java x: 20 contributors (all time) y: 230 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java x: 104 contributors (all time) y: 1931 lines of code sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java x: 57 contributors (all time) y: 809 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCommitOffset.java x: 21 contributors (all time) y: 159 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaWriter.java x: 28 contributors (all time) y: 150 lines of code sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkEventWriter.java x: 19 contributors (all time) y: 394 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTable.java x: 34 contributors (all time) y: 371 lines of code sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbGridFSIO.java x: 43 contributors (all time) y: 515 lines of code sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbIO.java x: 63 contributors (all time) y: 745 lines of code infra/iam/roles/beam_admin.role.yaml x: 1 contributors (all time) y: 654 lines of code infra/iam/roles/beam_infra_manager.role.yaml x: 1 contributors (all time) y: 828 lines of code infra/iam/roles/beam_viewer.role.yaml x: 1 contributors (all time) y: 1093 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TwoLevelMessageConverterCache.java x: 12 contributors (all time) y: 39 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunner.java x: 46 contributors (all time) y: 154 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2Runner.java x: 25 contributors (all time) y: 275 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java x: 61 contributors (all time) y: 964 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcDispatcherClient.java x: 10 contributors (all time) y: 218 lines of code sdks/go/pkg/beam/core/runtime/exec/userstate.go x: 5 contributors (all time) y: 446 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PreparePubsubWriteDoFn.java x: 9 contributors (all time) y: 194 lines of code sdks/python/apache_beam/ml/anomaly/transforms.py x: 4 contributors (all time) y: 336 lines of code infra/keys/secret_manager.py x: 1 contributors (all time) y: 466 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/AbstractWindmillStream.java x: 8 contributors (all time) y: 476 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/RowCoderCloudObjectTranslator.java x: 13 contributors (all time) y: 43 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaTranslation.java x: 39 contributors (all time) y: 769 lines of code sdks/python/apache_beam/io/avroio.py x: 61 contributors (all time) y: 460 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java x: 79 contributors (all time) y: 330 lines of code sdks/python/apache_beam/io/textio.py x: 77 contributors (all time) y: 596 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java x: 28 contributors (all time) y: 235 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/Repositories.groovy x: 29 contributors (all time) y: 39 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BagUserState.java x: 42 contributors (all time) y: 123 lines of code sdks/python/apache_beam/dataframe/doctests.py x: 25 contributors (all time) y: 484 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/TableNameExtractionUtils.java x: 15 contributors (all time) y: 56 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CalciteFactoryWrapper.java x: 13 contributors (all time) y: 77 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdafImpl.java x: 29 contributors (all time) y: 95 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPCall.java x: 11 contributors (all time) y: 52 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPLiteral.java x: 22 contributors (all time) y: 315 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPUtils.java x: 22 contributors (all time) y: 170 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/BeamSqlParser.java x: 14 contributors (all time) y: 28 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlColumnDeclaration.java x: 22 contributors (all time) y: 47 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlCreateFunction.java x: 14 contributors (all time) y: 94 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamCostModel.java x: 20 contributors (all time) y: 183 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamRelDataTypeSystem.java x: 21 contributors (all time) y: 42 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/NodeStatsMetadata.java x: 13 contributors (all time) y: 17 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamAggregationRel.java x: 61 contributors (all time) y: 315 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java x: 51 contributors (all time) y: 373 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamIntersectRel.java x: 28 contributors (all time) y: 51 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamJoinRel.java x: 53 contributors (all time) y: 193 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamLogicalConvention.java x: 32 contributors (all time) y: 43 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamRelNode.java x: 37 contributors (all time) y: 49 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSortRel.java x: 56 contributors (all time) y: 284 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamTableFunctionScanRel.java x: 25 contributors (all time) y: 291 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUncollectRel.java x: 35 contributors (all time) y: 77 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUnnestRel.java x: 49 contributors (all time) y: 156 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamValuesRel.java x: 38 contributors (all time) y: 70 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamWindowRel.java x: 24 contributors (all time) y: 374 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/CalcRelSplitter.java x: 13 contributors (all time) y: 571 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/package-info.java x: 24 contributors (all time) y: 4 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamAggregationRule.java x: 41 contributors (all time) y: 120 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamCalcRule.java x: 18 contributors (all time) y: 46 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamIOSinkRule.java x: 19 contributors (all time) y: 22 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamIntersectRule.java x: 20 contributors (all time) y: 29 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamUncollectRule.java x: 22 contributors (all time) y: 24 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamTableUtils.java x: 56 contributors (all time) y: 135 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/AggregationCombineFnAdapter.java x: 39 contributors (all time) y: 146 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/BuiltinStringFunctions.java x: 25 contributors (all time) y: 212 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java x: 62 contributors (all time) y: 296 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BeamSqlUnparseContext.java x: 29 contributors (all time) y: 186 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigtable/BigtableTable.java x: 21 contributors (all time) y: 181 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql/SqlBoundedSideInputJoin.java x: 20 contributors (all time) y: 85 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java x: 18 contributors (all time) y: 310 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/DefaultPipelineLauncher.java x: 5 contributors (all time) y: 418 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/RestrictionTracker.java x: 45 contributors (all time) y: 43 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/KV.java x: 21 contributors (all time) y: 78 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java x: 48 contributors (all time) y: 1145 lines of code sdks/python/apache_beam/io/gcp/bigquery_file_loads.py x: 57 contributors (all time) y: 940 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/TranslationUtils.java x: 55 contributors (all time) y: 289 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/StatefulStreamingParDoEvaluator.java x: 3 contributors (all time) y: 197 lines of code sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py x: 25 contributors (all time) y: 681 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py x: 40 contributors (all time) y: 815 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/VendorJavaPlugin.groovy x: 33 contributors (all time) y: 261 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/BeamKafkaCSVTable.java x: 28 contributors (all time) y: 101 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/BeamKafkaTable.java x: 50 contributors (all time) y: 223 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProvider.java x: 39 contributors (all time) y: 141 lines of code sdks/java/io/rabbitmq/src/main/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqIO.java x: 30 contributors (all time) y: 454 lines of code sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/PortableIcebergDestinations.java x: 5 contributors (all time) y: 68 lines of code sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumTransformRegistrar.java x: 16 contributors (all time) y: 84 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/mapper/ChangeStreamRecordMapper.java x: 15 contributors (all time) y: 594 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/DataChangeRecord.java x: 8 contributors (all time) y: 194 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcWindmillServer.java x: 13 contributors (all time) y: 317 lines of code sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Call.java x: 6 contributors (all time) y: 424 lines of code sdks/python/apache_beam/utils/windowed_value.py x: 46 contributors (all time) y: 288 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/HistogramData.java x: 24 contributors (all time) y: 465 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/ChangeStreamMetrics.java x: 11 contributors (all time) y: 123 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/dofn/ReadChangeStreamPartitionDoFn.java x: 14 contributors (all time) y: 156 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/KeyTokenInvalidException.java x: 18 contributors (all time) y: 16 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/refresh/ActiveWorkRefresher.java x: 4 contributors (all time) y: 146 lines of code sdks/python/apache_beam/transforms/display.py x: 52 contributors (all time) y: 223 lines of code sdks/python/apache_beam/transforms/environments.py x: 64 contributors (all time) y: 715 lines of code buildSrc/src/main/groovy/org/apache/beam/gradle/BeamDockerPlugin.groovy x: 7 contributors (all time) y: 273 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaExactlyOnceSink.java x: 36 contributors (all time) y: 537 lines of code sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticStep.java x: 18 contributors (all time) y: 120 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/ResourceHints.java x: 16 contributors (all time) y: 311 lines of code sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/KeyPairUtils.java x: 16 contributors (all time) y: 114 lines of code sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticOptions.java x: 29 contributors (all time) y: 232 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkConfiguration.java x: 30 contributors (all time) y: 551 lines of code sdks/python/apache_beam/io/iobase.py x: 82 contributors (all time) y: 750 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerReadSchemaTransformProvider.java x: 6 contributors (all time) y: 280 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3ReadableSeekableByteChannel.java x: 16 contributors (all time) y: 157 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsIO.java x: 24 contributors (all time) y: 623 lines of code sdks/python/apache_beam/io/snowflake.py x: 17 contributors (all time) y: 204 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/TFRecordIO.java x: 44 contributors (all time) y: 480 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextIO.java x: 75 contributors (all time) y: 806 lines of code sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/io/AvroIO.java x: 13 contributors (all time) y: 1177 lines of code sdks/java/io/csv/src/main/java/org/apache/beam/sdk/io/csv/CsvIO.java x: 10 contributors (all time) y: 243 lines of code sdks/python/apache_beam/ml/gcp/videointelligenceml.py x: 12 contributors (all time) y: 107 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowMetrics.java x: 51 contributors (all time) y: 359 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/LateDataDroppingDoFnRunner.java x: 45 contributors (all time) y: 107 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/SideInputContainer.java x: 36 contributors (all time) y: 233 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/BundleCheckpointHandlers.java x: 26 contributors (all time) y: 106 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java x: 49 contributors (all time) y: 471 lines of code runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java x: 12 contributors (all time) y: 427 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchedStreamingWrite.java x: 26 contributors (all time) y: 357 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/ByteBuddyDoFnInvokerFactory.java x: 62 contributors (all time) y: 1046 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunners.java x: 49 contributors (all time) y: 137 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkStatefulDoFnFunction.java x: 42 contributors (all time) y: 215 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/SplittableDoFnOperator.java x: 53 contributors (all time) y: 149 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowsParDoFn.java x: 23 contributors (all time) y: 157 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SimpleParDoFn.java x: 40 contributors (all time) y: 394 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SplittableProcessFnFactory.java x: 30 contributors (all time) y: 166 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/BatchGroupAlsoByWindowViaIteratorsFn.java x: 19 contributors (all time) y: 195 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/AbstractParDoP.java x: 21 contributors (all time) y: 463 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/GroupByKeyOp.java x: 36 contributors (all time) y: 198 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaDoFnRunners.java x: 40 contributors (all time) y: 426 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SplittableParDoProcessKeyedElementsOp.java x: 24 contributors (all time) y: 206 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/stateful/SparkGroupAlsoByWindowViaWindowSet.java x: 54 contributors (all time) y: 366 lines of code sdks/python/apache_beam/io/localfilesystem.py x: 38 contributors (all time) y: 158 lines of code sdks/go/pkg/beam/runners/dataflow/dataflow.go x: 67 contributors (all time) y: 377 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/DoFnRunner.java x: 26 contributors (all time) y: 23 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/GroupByKeyViaGroupByKeyOnly.java x: 31 contributors (all time) y: 145 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/PushbackSideInputDoFnRunner.java x: 28 contributors (all time) y: 21 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/SideInputHandler.java x: 36 contributors (all time) y: 157 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/StatefulDoFnRunner.java x: 48 contributors (all time) y: 302 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/BoundedReadEvaluatorFactory.java x: 40 contributors (all time) y: 188 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/CloningBundleFactory.java x: 31 contributors (all time) y: 69 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/GroupByKeyOnlyEvaluatorFactory.java x: 35 contributors (all time) y: 106 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/MultiStepCombine.java x: 37 contributors (all time) y: 418 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ParDoMultiOverrideFactory.java x: 35 contributors (all time) y: 247 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/StatefulParDoEvaluatorFactory.java x: 48 contributors (all time) y: 219 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/StepTransformResult.java x: 26 contributors (all time) y: 119 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/UnboundedReadEvaluatorFactory.java x: 45 contributors (all time) y: 275 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPortablePipelineTranslator.java x: 53 contributors (all time) y: 461 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchTransformTranslators.java x: 58 contributors (all time) y: 688 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingAggregationsTranslators.java x: 3 contributors (all time) y: 431 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPortablePipelineTranslator.java x: 62 contributors (all time) y: 910 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/DoFnRunnerWithMetricsUpdate.java x: 29 contributors (all time) y: 74 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/HashingFlinkCombineRunner.java x: 13 contributors (all time) y: 141 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/ImpulseSourceFunction.java x: 22 contributors (all time) y: 64 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperator.java x: 75 contributors (all time) y: 1032 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/WindowDoFnOperator.java x: 39 contributors (all time) y: 109 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/unbounded/FlinkUnboundedSourceReader.java x: 12 contributors (all time) y: 296 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/stableinput/BufferingDoFnRunner.java x: 28 contributors (all time) y: 265 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchStatefulParDoOverrides.java x: 36 contributors (all time) y: 223 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmReaderImpl.java x: 27 contributors (all time) y: 920 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSideInputReader.java x: 30 contributors (all time) y: 793 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSink.java x: 21 contributors (all time) y: 202 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingKeyedWorkItemSideInputDoFnRunner.java x: 28 contributors (all time) y: 122 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ProcessBundleDescriptors.java x: 54 contributors (all time) y: 445 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/JetTransformTranslators.java x: 19 contributors (all time) y: 371 lines of code runners/jet/src/main/java/org/apache/beam/runners/jet/processors/StatefulParDoP.java x: 22 contributors (all time) y: 303 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/BoundedSourceSystem.java x: 40 contributors (all time) y: 351 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/UnboundedSourceSystem.java x: 42 contributors (all time) y: 421 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnRunnerWithKeyedInternals.java x: 32 contributors (all time) y: 83 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/PortableDoFnOp.java x: 7 contributors (all time) y: 381 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/GroupByKeyTranslator.java x: 38 contributors (all time) y: 220 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ParDoBoundMultiTranslator.java x: 50 contributors (all time) y: 453 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTestStreamSystemFactory.java x: 16 contributors (all time) y: 132 lines of code runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/PipelineTranslator.java x: 13 contributors (all time) y: 343 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/SourceRDD.java x: 49 contributors (all time) y: 266 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/SparkUnboundedSource.java x: 43 contributors (all time) y: 232 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/BoundedDataset.java x: 44 contributors (all time) y: 96 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/MultiDoFnFunction.java x: 65 contributors (all time) y: 200 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkBatchPortablePipelineTranslator.java x: 36 contributors (all time) y: 346 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkCombineFn.java x: 17 contributors (all time) y: 650 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkPCollectionView.java x: 23 contributors (all time) y: 87 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/translation/wrappers/Twister2BoundedSource.java x: 20 contributors (all time) y: 208 lines of code runners/twister2/src/main/java/org/apache/beam/runners/twister2/translation/wrappers/Twister2EmptySource.java x: 16 contributors (all time) y: 16 lines of code sdks/java/harness/jmh/src/main/java/org/apache/beam/fn/harness/jmh/ProcessBundleBenchmark.java x: 16 contributors (all time) y: 448 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/BeamFnDataReadRunner.java x: 53 contributors (all time) y: 277 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/BeamFnDataWriteRunner.java x: 54 contributors (all time) y: 64 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/CombineRunners.java x: 46 contributors (all time) y: 211 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FlattenRunner.java x: 42 contributors (all time) y: 31 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java x: 28 contributors (all time) y: 452 lines of code sdks/python/gen_protos.py x: 59 contributors (all time) y: 372 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java x: 39 contributors (all time) y: 1534 lines of code sdks/python/apache_beam/coders/row_coder.py x: 47 contributors (all time) y: 137 lines of code sdks/go/pkg/beam/runners/prism/internal/engine/timers.go x: 5 contributors (all time) y: 326 lines of code sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/RequestResponseIO.java x: 5 contributors (all time) y: 281 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/AwsModule.java x: 32 contributors (all time) y: 297 lines of code sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/SnowflakeBatchServiceImpl.java x: 23 contributors (all time) y: 248 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/PartitionMetadata.java x: 13 contributors (all time) y: 269 lines of code sdks/python/apache_beam/typehints/opcodes.py x: 46 contributors (all time) y: 425 lines of code sdks/python/apache_beam/transforms/resources.py x: 8 contributors (all time) y: 162 lines of code sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/coders/AvroCoder.java x: 9 contributors (all time) y: 578 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/harness/FanOutStreamingEngineWorkerHarness.java x: 6 contributors (all time) y: 362 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/WindmillServerStub.java x: 39 contributors (all time) y: 16 lines of code runners/extensions-java/metrics/src/main/java/org/apache/beam/runners/extensions/metrics/MetricsGraphiteSink.java x: 24 contributors (all time) y: 267 lines of code runners/extensions-java/metrics/src/main/java/org/apache/beam/runners/extensions/metrics/MetricsHttpSink.java x: 30 contributors (all time) y: 138 lines of code sdks/python/apache_beam/dataframe/convert.py x: 18 contributors (all time) y: 177 lines of code sdks/python/apache_beam/dataframe/frames.py x: 44 contributors (all time) y: 4173 lines of code sdks/python/apache_beam/dataframe/pandas_top_level_functions.py x: 17 contributors (all time) y: 131 lines of code sdks/python/apache_beam/io/fileio.py x: 68 contributors (all time) y: 568 lines of code sdks/python/apache_beam/io/source_test_utils.py x: 35 contributors (all time) y: 425 lines of code sdks/python/apache_beam/runners/portability/abstract_job_service.py x: 31 contributors (all time) y: 273 lines of code sdks/python/apache_beam/runners/portability/artifact_service.py x: 35 contributors (all time) y: 271 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py x: 37 contributors (all time) y: 916 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py x: 50 contributors (all time) y: 1223 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/translations.py x: 40 contributors (all time) y: 1679 lines of code sdks/python/apache_beam/runners/worker/opcounters.py x: 48 contributors (all time) y: 182 lines of code sdks/python/apache_beam/runners/worker/operation_specs.py x: 34 contributors (all time) y: 123 lines of code sdks/python/apache_beam/testing/load_tests/load_test_metrics_utils.py x: 48 contributors (all time) y: 398 lines of code sdks/python/apache_beam/testing/synthetic_pipeline.py x: 36 contributors (all time) y: 675 lines of code sdks/python/apache_beam/transforms/window.py x: 63 contributors (all time) y: 351 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateBackedIterable.java x: 26 contributors (all time) y: 246 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineRunner.java x: 57 contributors (all time) y: 209 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedSource.java x: 32 contributors (all time) y: 211 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/WatchForKafkaTopicPartitions.java x: 13 contributors (all time) y: 173 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkTransformOverrides.java x: 25 contributors (all time) y: 47 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/coders/CoderHelpers.java x: 46 contributors (all time) y: 130 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubJsonClient.java x: 63 contributors (all time) y: 332 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSink.java x: 50 contributors (all time) y: 539 lines of code sdks/python/apache_beam/ml/anomaly/aggregations.py x: 2 contributors (all time) y: 124 lines of code sdks/python/apache_beam/io/filesystem.py x: 70 contributors (all time) y: 469 lines of code sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java x: 35 contributors (all time) y: 202 lines of code sdks/go/pkg/beam/model/pipeline_v1/external_transforms.pb.go x: 29 contributors (all time) y: 733 lines of code sdks/go/pkg/beam/model/pipeline_v1/metrics.pb.go x: 33 contributors (all time) y: 1734 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java x: 50 contributors (all time) y: 77 lines of code sdks/java/extensions/python/src/main/java/org/apache/beam/sdk/extensions/python/PythonExternalTransform.java x: 20 contributors (all time) y: 406 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java x: 48 contributors (all time) y: 1081 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkOptions.java x: 31 contributors (all time) y: 336 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManager.java x: 6 contributors (all time) y: 320 lines of code sdks/go/pkg/beam/core/runtime/graphx/translate.go x: 66 contributors (all time) y: 1259 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoderGenerator.java x: 51 contributors (all time) y: 414 lines of code sdks/java/io/google-ads/src/main/java/org/apache/beam/sdk/io/googleads/GoogleAdsV19.java x: 2 contributors (all time) y: 292 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java x: 46 contributors (all time) y: 731 lines of code sdks/python/apache_beam/utils/retry.py x: 62 contributors (all time) y: 176 lines of code sdks/python/apache_beam/coders/stream.pyx x: 22 contributors (all time) y: 192 lines of code sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeIO.java x: 42 contributors (all time) y: 1169 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContext.java x: 36 contributors (all time) y: 447 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingStepMetricsContainer.java x: 26 contributors (all time) y: 322 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/ReadOperation.java x: 27 contributors (all time) y: 315 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3FileSystem.java x: 23 contributors (all time) y: 579 lines of code sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ConsumerSpEL.java x: 43 contributors (all time) y: 116 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MonitoringInfoConstants.java x: 32 contributors (all time) y: 182 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricName.java x: 34 contributors (all time) y: 40 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/RpcQosImpl.java x: 12 contributors (all time) y: 839 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricUpdates.java x: 37 contributors (all time) y: 58 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerStepMap.java x: 61 contributors (all time) y: 186 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunner.java x: 71 contributors (all time) y: 309 lines of code sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcSchemaIOProvider.java x: 29 contributors (all time) y: 204 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/TestSparkRunner.java x: 51 contributors (all time) y: 100 lines of code sdks/python/apache_beam/transforms/stats.py x: 34 contributors (all time) y: 547 lines of code sdks/go/pkg/beam/util/starcgenx/starcgenx.go x: 21 contributors (all time) y: 601 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ConvertHelpers.java x: 35 contributors (all time) y: 178 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkCallbackExecutor.java x: 33 contributors (all time) y: 140 lines of code sdks/go/pkg/beam/core/runtime/graphx/serialize.go x: 35 contributors (all time) y: 716 lines of code sdks/go/pkg/beam/runners/vet/vet.go x: 21 contributors (all time) y: 505 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java x: 46 contributors (all time) y: 459 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/ActiveWorkState.java x: 10 contributors (all time) y: 267 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineOptions.java x: 57 contributors (all time) y: 262 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPipelineTranslator.java x: 40 contributors (all time) y: 289 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/state/FlinkStateInternals.java x: 62 contributors (all time) y: 1587 lines of code website/www/site/layouts/shortcodes/flink_java_pipeline_options.html x: 28 contributors (all time) y: 202 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java x: 42 contributors (all time) y: 145 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryOptions.java x: 41 contributors (all time) y: 163 lines of code sdks/java/extensions/ordered/src/main/java/org/apache/beam/sdk/extensions/ordered/OrderedEventProcessor.java x: 2 contributors (all time) y: 264 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/SimpleStateRegistry.java x: 33 contributors (all time) y: 53 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ByteStringCoder.java x: 23 contributors (all time) y: 26 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillStateReader.java x: 8 contributors (all time) y: 813 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/artifact/ArtifactStagingService.java x: 26 contributors (all time) y: 516 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClient.java x: 44 contributors (all time) y: 136 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClientPoolService.java x: 46 contributors (all time) y: 85 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/GrpcDataService.java x: 48 contributors (all time) y: 142 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/GrpcStateService.java x: 37 contributors (all time) y: 116 lines of code runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/InMemoryJobService.java x: 23 contributors (all time) y: 441 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/util/PipelineJsonRenderer.java x: 16 contributors (all time) y: 240 lines of code sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/JavaClassLookupTransformProvider.java x: 19 contributors (all time) y: 523 lines of code sdks/java/harness/jmh/src/main/java/org/apache/beam/fn/harness/jmh/logging/BeamFnLoggingClientBenchmark.java x: 12 contributors (all time) y: 185 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnDataGrpcClient.java x: 53 contributors (all time) y: 83 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/logging/BeamFnLoggingClient.java x: 53 contributors (all time) y: 371 lines of code sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIOSource.java x: 21 contributors (all time) y: 234 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/counters/CounterFactory.java x: 25 contributors (all time) y: 638 lines of code sdks/go/pkg/beam/artifact/materialize.go x: 32 contributors (all time) y: 417 lines of code sdks/go/pkg/beam/core/runtime/exec/translate.go x: 50 contributors (all time) y: 732 lines of code sdks/go/pkg/beam/core/runtime/graphx/schema/schema.go x: 13 contributors (all time) y: 659 lines of code sdks/go/pkg/beam/core/runtime/harness/datamgr.go x: 41 contributors (all time) y: 542 lines of code sdks/go/pkg/beam/core/runtime/harness/statemgr.go x: 31 contributors (all time) y: 588 lines of code sdks/go/pkg/beam/core/runtime/xlangx/registry.go x: 14 contributors (all time) y: 214 lines of code sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api.pb.go x: 62 contributors (all time) y: 5486 lines of code sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api_grpc.pb.go x: 14 contributors (all time) y: 570 lines of code sdks/go/pkg/beam/model/fnexecution_v1/beam_provision_api.pb.go x: 56 contributors (all time) y: 383 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_artifact_api.pb.go x: 49 contributors (all time) y: 1484 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_artifact_api_grpc.pb.go x: 14 contributors (all time) y: 457 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_expansion_api.pb.go x: 29 contributors (all time) y: 543 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_job_api.pb.go x: 49 contributors (all time) y: 2041 lines of code sdks/go/pkg/beam/model/jobmanagement_v1/beam_job_api_grpc.pb.go x: 15 contributors (all time) y: 453 lines of code sdks/go/pkg/beam/model/pipeline_v1/schema.pb.go x: 19 contributors (all time) y: 1749 lines of code sdks/go/pkg/beam/model/pipeline_v1/standard_window_fns.pb.go x: 43 contributors (all time) y: 487 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java x: 95 contributors (all time) y: 1473 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java x: 47 contributors (all time) y: 397 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServices.java x: 73 contributors (all time) y: 145 lines of code sdks/go/pkg/beam/transforms/stats/quantiles.go x: 12 contributors (all time) y: 556 lines of code sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/SolaceIO.java x: 4 contributors (all time) y: 457 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiLoads.java x: 25 contributors (all time) y: 406 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteSchemaTransformProvider.java x: 11 contributors (all time) y: 210 lines of code sdks/python/apache_beam/yaml/standard_providers.yaml x: 10 contributors (all time) y: 81 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkProcessContext.java x: 49 contributors (all time) y: 39 lines of code sdks/python/apache_beam/metrics/metricbase.py x: 44 contributors (all time) y: 73 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteWriteSchemaTransformProvider.java x: 12 contributors (all time) y: 386 lines of code scripts/ci/pr-bot/processNewPrs.ts x: 13 contributors (all time) y: 246 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java x: 45 contributors (all time) y: 422 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldValueGetter.java x: 21 contributors (all time) y: 14 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldValueTypeInformation.java x: 30 contributors (all time) y: 269 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/ReflectHelpers.java x: 48 contributors (all time) y: 231 lines of code sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnDataClient.java x: 36 contributors (all time) y: 21 lines of code sdks/python/apache_beam/dataframe/frame_base.py x: 27 contributors (all time) y: 516 lines of code sdks/python/apache_beam/testing/benchmarks/chicago_taxi/tfdv_analyze_and_validate.py x: 20 contributors (all time) y: 150 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/providers/JavaRowUdf.java x: 5 contributors (all time) y: 293 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteBundlesToFiles.java x: 51 contributors (all time) y: 241 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteTables.java x: 79 contributors (all time) y: 487 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubReadSchemaTransformProvider.java x: 12 contributors (all time) y: 271 lines of code sdks/python/apache_beam/portability/common_urns.py x: 60 contributors (all time) y: 63 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java x: 67 contributors (all time) y: 761 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java x: 38 contributors (all time) y: 432 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceImpl.java x: 58 contributors (all time) y: 715 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java x: 38 contributors (all time) y: 45 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/CoGroup.java x: 30 contributors (all time) y: 525 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java x: 40 contributors (all time) y: 921 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java x: 56 contributors (all time) y: 916 lines of code it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java x: 6 contributors (all time) y: 310 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java x: 52 contributors (all time) y: 338 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/Nodes.java x: 37 contributors (all time) y: 193 lines of code sdks/go/pkg/beam/coder.go x: 39 contributors (all time) y: 292 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java x: 71 contributors (all time) y: 1179 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/ByteBuddyOnTimerInvokerFactory.java x: 45 contributors (all time) y: 253 lines of code sdks/java/io/common/src/main/java/org/apache/beam/sdk/io/common/SchemaAwareJavaBeans.java x: 3 contributors (all time) y: 325 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteRename.java x: 49 contributors (all time) y: 388 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HttpHealthcareApiClient.java x: 39 contributors (all time) y: 834 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py x: 45 contributors (all time) y: 2358 lines of code sdks/python/apache_beam/transforms/cy_combiners.py x: 39 contributors (all time) y: 279 lines of code sdks/python/apache_beam/io/restriction_trackers.py x: 41 contributors (all time) y: 113 lines of code sdks/python/apache_beam/options/value_provider.py x: 38 contributors (all time) y: 100 lines of code sdks/python/apache_beam/runners/direct/executor.py x: 48 contributors (all time) y: 499 lines of code sdks/python/apache_beam/runners/direct/sdf_direct_runner.py x: 42 contributors (all time) y: 342 lines of code sdks/python/apache_beam/runners/direct/watermark_manager.py x: 34 contributors (all time) y: 223 lines of code sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py x: 32 contributors (all time) y: 389 lines of code sdks/python/apache_beam/utils/timestamp.py x: 57 contributors (all time) y: 233 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/state/StateSpecs.java x: 34 contributors (all time) y: 614 lines of code sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet/ParquetIO.java x: 53 contributors (all time) y: 806 lines of code sdks/python/apache_beam/runners/common.pxd x: 53 contributors (all time) y: 136 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPipelineTranslator.java x: 37 contributors (all time) y: 162 lines of code sdks/go/pkg/beam/core/runtime/exec/datasource.go x: 52 contributors (all time) y: 592 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/GcpOptions.java x: 43 contributors (all time) y: 416 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPortableClientEntryPoint.java x: 22 contributors (all time) y: 202 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java x: 49 contributors (all time) y: 428 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java x: 37 contributors (all time) y: 272 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationSizeEstimator.java x: 27 contributors (all time) y: 173 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkTransformOverrides.java x: 36 contributors (all time) y: 44 lines of code playground/backend/internal/preparers/java_preparers.go x: 18 contributors (all time) y: 257 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkRunner.java x: 48 contributors (all time) y: 107 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/PrimitiveParDoSingleFactory.java x: 53 contributors (all time) y: 317 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactory.java x: 47 contributors (all time) y: 603 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ReferenceCountingExecutableStageContextFactory.java x: 17 contributors (all time) y: 184 lines of code runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java x: 52 contributors (all time) y: 543 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaStoreStateInternals.java x: 42 contributors (all time) y: 936 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPortablePipelineTranslator.java x: 28 contributors (all time) y: 75 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkNativePipelineVisitor.java x: 45 contributors (all time) y: 163 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunnerDebugger.java x: 32 contributors (all time) y: 87 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PTransform.java x: 36 contributors (all time) y: 132 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java x: 38 contributors (all time) y: 237 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PTransformMatchers.java x: 3 contributors (all time) y: 397 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/TriggerTranslation.java x: 3 contributors (all time) y: 273 lines of code sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/TableSchema.java x: 25 contributors (all time) y: 256 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/RetryManager.java x: 16 contributors (all time) y: 268 lines of code sdks/java/io/neo4j/src/main/java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java x: 18 contributors (all time) y: 807 lines of code sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Cache.java x: 3 contributors (all time) y: 226 lines of code sdks/typescript/src/apache_beam/utils/service.ts x: 11 contributors (all time) y: 413 lines of code sdks/typescript/src/apache_beam/worker/operators.ts x: 12 contributors (all time) y: 816 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/InMemoryStateInternals.java x: 39 contributors (all time) y: 719 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/MergingActiveWindowSet.java x: 30 contributors (all time) y: 290 lines of code runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachineContextFactory.java x: 33 contributors (all time) y: 466 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java x: 58 contributors (all time) y: 1165 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkRunnerResult.java x: 35 contributors (all time) y: 50 lines of code runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/FlinkMetricContainer.java x: 39 contributors (all time) y: 30 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/TestDataflowRunner.java x: 33 contributors (all time) y: 296 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/IsmFormat.java x: 39 contributors (all time) y: 505 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java x: 44 contributors (all time) y: 172 lines of code runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/TimeUtil.java x: 31 contributors (all time) y: 98 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/CombineValuesFnFactory.java x: 27 contributors (all time) y: 278 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/Networks.java x: 24 contributors (all time) y: 144 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/JulHandlerPrintStreamAdapterFactory.java x: 29 contributors (all time) y: 351 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/status/DebugCapture.java x: 28 contributors (all time) y: 172 lines of code runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/GroupingTables.java x: 23 contributors (all time) y: 354 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ConfigContext.java x: 26 contributors (all time) y: 51 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkRunnerRegistrar.java x: 35 contributors (all time) y: 25 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/io/MicrobatchSource.java x: 41 contributors (all time) y: 258 lines of code sdks/go/pkg/beam/core/graph/fn.go x: 38 contributors (all time) y: 1247 lines of code sdks/go/pkg/beam/core/runtime/exec/plan.go x: 49 contributors (all time) y: 223 lines of code sdks/go/pkg/beam/core/runtime/exec/sdf.go x: 25 contributors (all time) y: 627 lines of code sdks/go/pkg/beam/core/typex/fulltype.go x: 25 contributors (all time) y: 322 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/coders/SerializableCoder.java x: 40 contributors (all time) y: 133 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingSource.java x: 43 contributors (all time) y: 332 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/io/GenerateSequence.java x: 24 contributors (all time) y: 181 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/options/ProxyInvocationHandler.java x: 54 contributors (all time) y: 620 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java x: 38 contributors (all time) y: 392 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldAccessDescriptor.java x: 37 contributors (all time) y: 441 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/AddFields.java x: 23 contributors (all time) y: 304 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Cast.java x: 29 contributors (all time) y: 292 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Group.java x: 37 contributors (all time) y: 844 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectByteBuddyHelpers.java x: 22 contributors (all time) y: 691 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/Annotations.java x: 27 contributors (all time) y: 23 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SourceTestUtils.java x: 37 contributors (all time) y: 644 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupIntoBatches.java x: 44 contributors (all time) y: 449 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java x: 76 contributors (all time) y: 541 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Top.java x: 38 contributors (all time) y: 263 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/display/DisplayData.java x: 51 contributors (all time) y: 509 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/ByteKeyRangeTracker.java x: 34 contributors (all time) y: 158 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java x: 43 contributors (all time) y: 107 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/ApiSurface.java x: 44 contributors (all time) y: 530 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJson.java x: 28 contributors (all time) y: 423 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/util/UnboundedScheduledExecutorService.java x: 9 contributors (all time) y: 399 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/RowUtils.java x: 27 contributors (all time) y: 510 lines of code sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowingStrategy.java x: 28 contributors (all time) y: 338 lines of code sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/io/AvroSource.java x: 10 contributors (all time) y: 500 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/Distinct.java x: 26 contributors (all time) y: 291 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java x: 24 contributors (all time) y: 506 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java x: 29 contributors (all time) y: 466 lines of code sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/TopPerKey.java x: 23 contributors (all time) y: 285 lines of code sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java x: 22 contributors (all time) y: 407 lines of code sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java x: 22 contributors (all time) y: 275 lines of code sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/CassandraIO.java x: 54 contributors (all time) y: 698 lines of code sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIO.java x: 16 contributors (all time) y: 408 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryTableSource.java x: 48 contributors (all time) y: 78 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TestBigQuery.java x: 36 contributors (all time) y: 296 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/QueryUtils.java x: 9 contributors (all time) y: 328 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java x: 26 contributors (all time) y: 508 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java x: 19 contributors (all time) y: 252 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsub.java x: 44 contributors (all time) y: 306 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsubSignal.java x: 42 contributors (all time) y: 312 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/OrderedCode.java x: 25 contributors (all time) y: 450 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/model/ChangeStreamRecordMetadata.java x: 14 contributors (all time) y: 272 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClient.java x: 43 contributors (all time) y: 470 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeJobService.java x: 31 contributors (all time) y: 493 lines of code sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java x: 40 contributors (all time) y: 667 lines of code sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/InfluxDbIO.java x: 19 contributors (all time) y: 503 lines of code sdks/java/io/singlestore/src/main/java/org/apache/beam/sdk/io/singlestore/SingleStoreIO.java x: 7 contributors (all time) y: 678 lines of code sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr/SolrIO.java x: 33 contributors (all time) y: 429 lines of code sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkUtils.java x: 36 contributors (all time) y: 576 lines of code sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsSchemas.java x: 11 contributors (all time) y: 632 lines of code sdks/python/apache_beam/typehints/typecheck.py x: 53 contributors (all time) y: 250 lines of code website/www/site/data/capability_matrix_snapshot.yaml x: 14 contributors (all time) y: 733 lines of code learning/tour-of-beam/frontend/lib/pages/tour/state.dart x: 7 contributors (all time) y: 323 lines of code playground/backend/internal/code_processing/code_processing.go x: 17 contributors (all time) y: 497 lines of code .test-infra/metrics/sync/github/sync.py x: 11 contributors (all time) y: 380 lines of code learning/tour-of-beam/backend/playground_api/api/v1/api.pb.go x: 5 contributors (all time) y: 3333 lines of code learning/tour-of-beam/backend/playground_api/api/v1/api_grpc.pb.go x: 5 contributors (all time) y: 736 lines of code learning/tour-of-beam/backend/playground_api/api/v1/mock.go x: 4 contributors (all time) y: 811 lines of code playground/backend/cmd/server/server.go x: 23 contributors (all time) y: 181 lines of code playground/backend/internal/api/v1/api.pb.go x: 26 contributors (all time) y: 3333 lines of code playground/backend/internal/db/datastore/datastore_db.go x: 11 contributors (all time) y: 498 lines of code playground/frontend/playground_components/assets/symbols/go.g.yaml x: 7 contributors (all time) y: 6641 lines of code playground/frontend/playground_components/lib/src/api/v1/api.pb.dart x: 10 contributors (all time) y: 2383 lines of code playground/frontend/playground_components/lib/src/api/v1/api.pbgrpc.dart x: 7 contributors (all time) y: 546 lines of code playground/frontend/playground_components/lib/src/api/v1/api.pbjson.dart x: 10 contributors (all time) y: 468 lines of code playground/frontend/playground_components/lib/src/controllers/playground_controller.dart x: 9 contributors (all time) y: 268 lines of code playground/infrastructure/api/v1/api_pb2_grpc.py x: 15 contributors (all time) y: 612 lines of code runners/direct-java/src/main/java/org/apache/beam/runners/direct/CommittedResult.java x: 31 contributors (all time) y: 27 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobServerDriver.java x: 36 contributors (all time) y: 68 lines of code runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaTimerInternalsFactory.java x: 39 contributors (all time) y: 549 lines of code runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineOptions.java x: 51 contributors (all time) y: 50 lines of code scripts/ci/pr-bot/gatherMetrics.ts x: 6 contributors (all time) y: 429 lines of code sdks/go/pkg/beam/core/graph/coder/coder.go x: 32 contributors (all time) y: 317 lines of code sdks/go/pkg/beam/core/graph/edge.go x: 33 contributors (all time) y: 361 lines of code sdks/go/pkg/beam/core/metrics/metrics.go x: 32 contributors (all time) y: 712 lines of code sdks/go/pkg/beam/core/runtime/exec/coder.go x: 40 contributors (all time) y: 1043 lines of code sdks/go/pkg/beam/core/runtime/exec/combine.go x: 37 contributors (all time) y: 489 lines of code sdks/go/pkg/beam/core/runtime/exec/fn_arity.go x: 15 contributors (all time) y: 254 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/callers.go x: 11 contributors (all time) y: 470 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/decoders.go x: 11 contributors (all time) y: 1856 lines of code sdks/go/pkg/beam/core/runtime/exec/optimized/encoders.go x: 11 contributors (all time) y: 1772 lines of code sdks/go/pkg/beam/core/runtime/exec/sdf_invokers.go x: 13 contributors (all time) y: 400 lines of code sdks/go/pkg/beam/core/runtime/graphx/v1/v1.pb.go x: 21 contributors (all time) y: 1608 lines of code sdks/go/pkg/beam/core/state/state.go x: 5 contributors (all time) y: 493 lines of code sdks/go/pkg/beam/core/util/reflectx/calls.go x: 19 contributors (all time) y: 1490 lines of code sdks/go/pkg/beam/register/register.go x: 6 contributors (all time) y: 7254 lines of code sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/nfa/NFA.java x: 13 contributors (all time) y: 640 lines of code sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StreamingWriteTables.java x: 44 contributors (all time) y: 393 lines of code sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_messages.py x: 24 contributors (all time) y: 1582 lines of code sdks/python/apache_beam/runners/dataflow/internal/clients/cloudbuild/cloudbuild_v1_messages.py x: 10 contributors (all time) y: 1135 lines of code sdks/typescript/src/apache_beam/proto/google/protobuf/descriptor.ts x: 6 contributors (all time) y: 1991 lines of code sdks/typescript/src/apache_beam/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.ts x: 3 contributors (all time) y: 3456 lines of code sdks/typescript/src/apache_beam/proto/org/apache/beam/model/job_management/v1/beam_artifact_api.ts x: 3 contributors (all time) y: 994 lines of code sdks/typescript/src/apache_beam/proto/org/apache/beam/model/job_management/v1/beam_job_api.ts x: 3 contributors (all time) y: 1193 lines of code sdks/typescript/src/apache_beam/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.ts x: 3 contributors (all time) y: 5095 lines of code website/www/site/assets/scss/_calendar.scss x: 11 contributors (all time) y: 237 lines of code website/www/site/assets/scss/_syntax-highlighting.scss x: 14 contributors (all time) y: 393 lines of code sdks/python/apache_beam/runners/portability/fn_api_runner/trigger_manager.py x: 4 contributors (all time) y: 352 lines of code website/www/site/assets/scss/bootstrap/_forms.scss x: 2 contributors (all time) y: 391 lines of code sdks/java/build-tools/src/main/resources/beam/beam-codestyle.xml x: 4 contributors (all time) y: 313 lines of code
7254.0
lines of code
  min: 1.0
  average: 111.5
  25th percentile: 13.0
  median: 42.0
  75th percentile: 112.0
  max: 7254.0
0 261.0
contributors (all time)
min: 1.0 | average: 12.27 | 25th percentile: 3.0 | median: 7.0 | 75th percentile: 16.0 | max: 261.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".