Path	Lines of Code
build.gradle.kts	560
buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy	2244
buildSrc/src/main/groovy/org/apache/beam/gradle/VendorJavaPlugin.groovy	261
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/LoadTestBase.java	367
it/jdbc/src/main/java/org/apache/beam/it/jdbc/OracleResourceManager.java	53
it/splunk/src/main/java/org/apache/beam/it/splunk/SplunkContainer.java	44
it/splunk/src/main/java/org/apache/beam/it/splunk/SplunkResourceManager.java	244
learning/tour-of-beam/backend/auth.go	56
learning/tour-of-beam/backend/playground_api/api/v1/api.pb.go	3333
model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto	1125
model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.proto	1716
model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/endpoints.proto	56
playground/api/v1/api.proto	318
playground/backend/cmd/server/wrapper.go	20
playground/backend/internal/api/v1/api.pb.go	3333
playground/backend/internal/db/entity/example.go	20
playground/backend/internal/utils/cache_utils.go	14
playground/backend/internal/validators/scio_validators.go	27
playground/frontend/lib/modules/messages/parsers/messages_parser.dart	28
playground/frontend/lib/pages/standalone_playground/screen.dart	93
playground/frontend/playground_components/lib/src/constants/sizes.dart	51
playground/frontend/playground_components/lib/src/controllers/code_runner.dart	416
playground/frontend/playground_components/lib/src/widgets/drag_handle.dart	20
playground/infrastructure/checker.py	69
playground/terraform/infrastructure/artifact_registry/main.tf	9
playground/terraform/infrastructure/memorystore/main.tf	14
playground/terraform/provider.tf	23
runners/core-java/src/main/java/org/apache/beam/runners/core/ReduceFnRunner.java	629
runners/core-java/src/main/java/org/apache/beam/runners/core/WatermarkHold.java	298
runners/core-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java	69
runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/AfterDelayFromFirstElementStateMachine.java	194
runners/core-java/src/main/java/org/apache/beam/runners/core/triggers/TriggerStateMachineRunner.java	132
runners/direct-java/src/main/java/org/apache/beam/runners/direct/BoundedReadEvaluatorFactory.java	187
runners/direct-java/src/main/java/org/apache/beam/runners/direct/DirectGraph.java	85
runners/direct-java/src/main/java/org/apache/beam/runners/direct/ExecutorServiceParallelExecutor.java	338
runners/direct-java/src/main/java/org/apache/beam/runners/direct/KeyedPValueTrackingVisitor.java	85
runners/direct-java/src/main/java/org/apache/beam/runners/direct/QuiescenceDriver.java	263
runners/direct-java/src/main/java/org/apache/beam/runners/direct/TransformExecutorServices.java	116
runners/direct-java/src/main/java/org/apache/beam/runners/direct/WatermarkManager.java	1165
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPortablePipelineTranslator.java	460
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java	77
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobServerDriver.java	100
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPipelineRunner.java	163
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkPortablePipelineTranslator.java	45
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPortablePipelineTranslator.java	909
runners/flink/src/main/java/org/apache/beam/runners/flink/metrics/FileReporter.java	57
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkExecutableStageFunction.java	322
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkPartialReduceFunction.java	71
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/functions/FlinkReduceFunction.java	71
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/SourceInputFormat.java	134
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java	1251
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperator.java	1029
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/KeyedPushedBackElementsHandler.java	70
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/NonKeyedPushedBackElementsHandler.java	32
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/unbounded/FlinkUnboundedSourceReader.java	295
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchViewOverrides.java	914
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowMetrics.java	297
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java	1017
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java	2216
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/PrimitiveParDoSingleFactory.java	317
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/CustomSources.java	76
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DefaultCoderCloudObjectTranslatorRegistrar.java	112
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java	172
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/Structs.java	285
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchDataflowWorker.java	219
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContext.java	447
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/CombinePhase.java	7
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowElementExecutionTracker.java	244
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowExecutionContext.java	345
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java	272
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOutputCounter.java	58
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowPortabilityPCollectionView.java	125
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowProcessFnRunner.java	93
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClient.java	248
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkerHarnessHelper.java	109
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DeltaDistributionCell.java	50
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowParDoFnFactory.java	301
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowsParDoFn.java	169
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/InMemoryReader.java	138
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSideInputReader.java	793
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/PartialGroupByKeyParDoFns.java	305
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/ShuffleSink.java	262
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SimpleParDoFn.java	394
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java	771
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkItemStatusClient.java	285
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSources.java	700
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerPipelineOptionsFactory.java	55
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/counters/CounterFactory.java	638
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/counters/CounterName.java	188
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/LengthPrefixUnknownCoders.java	200
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/Networks.java	144
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/DataflowWorkerLoggingHandler.java	236
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/BatchingShuffleEntryReader.java	88
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/MapTaskExecutor.java	124
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/OutputObjectAndByteCounter.java	115
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/ProgressTrackerGroup.java	28
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/ShuffleEntry.java	81
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/WriteOperation.java	101
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/appliance/JniWindmillApplianceServer.java	30
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/auth/VendoredCredentialsAdapter.java	45
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/auth/VendoredRequestMetadataCallbackAdapter.java	20
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/WindmillMap.java	357
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/work/processing/StreamingCommitFinalizer.java	49
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactory.java	603
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClientPoolService.java	85
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/MapControlClientPool.java	45
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/ProcessBundleDescriptors.java	445
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/SdkHarnessClient.java	543
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/GrpcDataService.java	142
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerCommand.java	180
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerEnvironmentFactory.java	211
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/EmbeddedEnvironmentFactory.java	152
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/logging/Slf4jLogWriter.java	54
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/GrpcStateService.java	116
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/state/StateRequestHandlers.java	441
runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/InMemoryJobService.java	441
runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobInvocation.java	217
runners/portability/java/src/main/java/org/apache/beam/runners/portability/JobServicePipelineResult.java	177
runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobServerDriver.java	68
runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineRunner.java	53
runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaRunnerOverrideConfigs.java	49
runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/BoundedSourceSystem.java	350
runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/UnboundedSourceSystem.java	420
runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java	470
runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/PortableDoFnOp.java	381
runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaDoFnRunners.java	425
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ConfigBuilder.java	273
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ParDoBoundMultiTranslator.java	452
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPublishViewTranslator.java	44
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTransformOverrides.java	34
runners/samza/src/main/java/org/apache/beam/runners/samza/util/DoFnUtils.java	39
runners/samza/src/main/java/org/apache/beam/runners/samza/util/PipelineJsonRenderer.java	240
runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/metrics/BeamMetricSet.java	25
runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/SparkSessionFactory.java	222
runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/SparkTransformOverrides.java	34
runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DoFnPartitionIteratorFactory.java	131
runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/GroupByKeyTranslatorBatch.java	196
runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ParDoTranslatorBatch.java	194
runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/PipelineTranslatorBatch.java	47
runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineRunner.java	209
runners/spark/src/main/java/org/apache/beam/runners/spark/SparkTransformOverrides.java	47
runners/spark/src/main/java/org/apache/beam/runners/spark/io/CreateStream.java	124
runners/spark/src/main/java/org/apache/beam/runners/spark/metrics/BeamMetricSet.java	24
runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkStreamingPortablePipelineTranslator.java	296
runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2Runner.java	274
runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/batch/ParDoMultiOutputTranslatorBatch.java	98
runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/ByteToWindowFunction.java	74
runners/twister2/src/main/java/org/apache/beam/runners/twister2/translators/functions/Twister2SinkFunction.java	23
scripts/tools/bomupgrader.py	197
sdks/go/pkg/beam/core/graph/coder/row.go	148
sdks/go/pkg/beam/core/graph/edge.go	361
sdks/go/pkg/beam/core/graph/fn.go	1247
sdks/go/pkg/beam/core/graph/window/trigger/trigger.go	214
sdks/go/pkg/beam/core/runtime/exec/plan.go	223
sdks/go/pkg/beam/core/runtime/graphx/schema/logicaltypes.go	95
sdks/go/pkg/beam/core/runtime/harness/monitoring.go	201
sdks/go/pkg/beam/core/runtime/metricsx/urns.go	135
sdks/go/pkg/beam/core/runtime/xlangx/registry.go	214
sdks/go/pkg/beam/io/databaseio/database.go	168
sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api.pb.go	5486
sdks/go/pkg/beam/runners/prism/internal/engine/data.go	214
sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go	1524
sdks/go/pkg/beam/runners/prism/internal/engine/strategy.go	405
sdks/go/pkg/beam/runners/prism/internal/environments.go	236
sdks/go/pkg/beam/runners/prism/internal/execute.go	363
sdks/go/pkg/beam/runners/prism/internal/handlecombine.go	152
sdks/go/pkg/beam/runners/prism/internal/handlepardo.go	135
sdks/go/pkg/beam/runners/prism/internal/handlerunner.go	345
sdks/go/pkg/beam/runners/prism/internal/jobservices/management.go	464
sdks/go/pkg/beam/runners/prism/internal/jobservices/server.go	101
sdks/go/pkg/beam/runners/prism/internal/preprocess.go	416
sdks/go/pkg/beam/runners/prism/internal/stage.go	614
sdks/go/pkg/beam/runners/prism/internal/web/web.go	350
sdks/go/pkg/beam/runners/prism/internal/worker/bundle.go	198
sdks/go/pkg/beam/runners/prism/internal/worker/worker.go	641
sdks/java/container/boot.go	282
sdks/java/core/src/main/java/org/apache/beam/sdk/Pipeline.java	454
sdks/java/core/src/main/java/org/apache/beam/sdk/PipelineResult.java	33
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/IterableLikeCoder.java	155
sdks/java/core/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataGrpcMultiplexer.java	241
sdks/java/core/src/main/java/org/apache/beam/sdk/fn/windowing/EncodedBoundedWindow.java	53
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java	761
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java	432
sdks/java/core/src/main/java/org/apache/beam/sdk/io/LocalFileSystem.java	239
sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java	842
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceIdTester.java	119
sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRangeTracker.java	172
sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptionsFactory.java	1522
sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java	392
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldTypeDescriptors.java	112
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldValueTypeInformation.java	269
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/JavaBeanSchema.java	185
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/JavaFieldSchema.java	122
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoderHelpers.java	138
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaRegistry.java	217
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/parser/FieldAccessDescriptorParser.java	116
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Cast.java	292
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Convert.java	89
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Select.java	187
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java	1201
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ConvertHelpers.java	178
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectHelpers.java	343
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/StaticSchemaInference.java	165
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java	1179
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java	633
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java	595
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java	541
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sets.java	148
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java	921
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithKeys.java	79
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGroupByKey.java	93
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/KeyedPCollectionTuple.java	124
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java	40
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/UnionCoder.java	91
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/ResourceHints.java	311
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ApiSurface.java	530
sdks/java/core/src/main/java/org/apache/beam/sdk/util/InstanceBuilder.java	138
sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJson.java	423
sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableUtils.java	146
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ZipFiles.java	155
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/CoderTranslation.java	160
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineOptionsTranslation.java	93
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/PipelineTranslation.java	157
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/SdkComponents.java	267
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/WindowingStrategyTranslation.java	322
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/WriteFilesTranslation.java	277
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/GreedyPCollectionFusers.java	239
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/GreedyPipelineFuser.java	297
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/GreedyStageFuser.java	143
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/Networks.java	191
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/PipelineValidator.java	281
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/ProtoOverrides.java	50
sdks/java/core/src/main/java/org/apache/beam/sdk/util/construction/graph/QueryablePipeline.java	316
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java	1530
sdks/java/extensions/arrow/src/main/java/org/apache/beam/sdk/extensions/arrow/ArrowConversion.java	412
sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/coders/AvroCoder.java	484
sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroByteBuddyUtils.java	98
sdks/java/extensions/avro/src/main/java/org/apache/beam/sdk/extensions/avro/schemas/utils/AvroUtils.java	1310
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsCreateOptions.java	17
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsFileSystem.java	265
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java	1132
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/RetryHttpRequestInitializer.java	214
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java	407
sdks/java/extensions/ordered/src/main/java/org/apache/beam/sdk/extensions/ordered/GlobalSequencesProcessorDoFn.java	223
sdks/java/extensions/ordered/src/main/java/org/apache/beam/sdk/extensions/ordered/ProcessorDoFn.java	313
sdks/java/extensions/ordered/src/main/java/org/apache/beam/sdk/extensions/ordered/SequencePerKeyProcessorDoFn.java	208
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/Sorter.java	7
sdks/java/extensions/sql/expansion-service/src/main/java/org/apache/beam/sdk/extensions/sql/expansion/SqlTransformSchemaTransformProvider.java	186
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/SqlTransform.java	193
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ScalarFunctionImpl.java	165
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPLiteral.java	315
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/nfa/NFA.java	640
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamCalcRel.java	739
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java	373
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMatchRel.java	392
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSetOperatorRelBase.java	65
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamAggregationRule.java	120
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamUnnestRule.java	79
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamTableUtils.java	131
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/BuiltinTrigonometricFunctions.java	39
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/FullNameTableProvider.java	79
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BeamSqlUnparseContext.java	184
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BigQueryFilter.java	102
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BigQueryTable.java	208
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTable.java	359
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCatalog.java	477
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/DateTimeUtils.java	162
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/QueryTrait.java	44
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSqlCalciteTranslationUtils.java	297
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/AggregateScanConverter.java	215
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ExpressionConverter.java	814
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/TVFScanConverter.java	75
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/TableScanConverter.java	82
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/BeamZetaSqlUnnestRule.java	74
sdks/java/extensions/zetasketch/src/main/java/org/apache/beam/sdk/extensions/zetasketch/HyperLogLogPlusPlusCoder.java	32
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/AssignWindowsRunner.java	77
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java	3120
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java	321
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/MapFnRunners.java	86
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java	1043
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnDataGrpcClient.java	83
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/PCollectionConsumerRegistry.java	422
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BagUserState.java	121
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BeamFnStateGrpcClientCache.java	139
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java	830
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/MultimapUserState.java	311
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/OrderedListUserState.java	236
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsUnboundedReader.java	601
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/BlobstoreOptions.java	51
sdks/java/io/cdap/src/main/java/org/apache/beam/sdk/io/cdap/CdapIO.java	240
sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/ClickHouseIO.java	307
sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIO.java	408
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/AvroRowWriter.java	46
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtils.java	508
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java	2391
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java	1606
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java	136
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageStreamSource.java	353
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java	943
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/CreateTableHelpers.java	187
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/CreateTables.java	106
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java	208
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java	1076
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java	856
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowToStorageApiProto.java	1031
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java	1473
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceImpl.java	715
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/reconciler/PartitionReconciler.java	133
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DataStoreV1SchemaIOProvider.java	122
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/EntityToRow.java	106
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/DicomIO.java	98
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java	508
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java	1081
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSink.java	539
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java	916
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/SubscriptionPartitionLoader.java	141
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationUtils.java	371
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java	1593
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerTransformRegistrar.java	314
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/StructUtils.java	411
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/changestreams/action/QueryChangeStreamAction.java	185
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java	712
sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystem.java	300
sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/SchemaUtils.java	64
sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergWriteSchemaTransformProvider.java	163
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCommitOffset.java	157
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java	2032
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaRecordCoder.java	108
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java	650
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaWriteSchemaTransformProvider.java	280
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java	585
sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/ReadFromPulsarDoFn.java	194
sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr/SolrIO.java	429
sdks/java/io/sparkreceiver/3/src/main/java/org/apache/beam/sdk/io/sparkreceiver/SparkReceiverIO.java	102
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticBoundedSource.java	180
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/delay/ReaderDelay.java	24
sdks/java/io/tika/src/main/java/org/apache/beam/sdk/io/tika/ParseResult.java	97
sdks/java/io/tika/src/main/java/org/apache/beam/sdk/io/tika/TikaIO.java	167
sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java	122
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java	1081
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java	310
sdks/java/transform-service/src/main/java/org/apache/beam/sdk/transformservice/ArtifactService.java	121
sdks/python/apache_beam/coders/coder_impl.py	1324
sdks/python/apache_beam/coders/coders.py	1028
sdks/python/apache_beam/dataframe/convert.py	177
sdks/python/apache_beam/dataframe/frame_base.py	516
sdks/python/apache_beam/dataframe/frames.py	4224
sdks/python/apache_beam/internal/cloudpickle/cloudpickle.py	784
sdks/python/apache_beam/internal/cloudpickle_pickler.py	113
sdks/python/apache_beam/internal/dill_pickler.py	290
sdks/python/apache_beam/internal/util.py	52
sdks/python/apache_beam/io/avroio.py	452
sdks/python/apache_beam/io/aws/clients/s3/fake_client.py	137
sdks/python/apache_beam/io/aws/s3io.py	351
sdks/python/apache_beam/io/filebasedsink.py	326
sdks/python/apache_beam/io/fileio.py	567
sdks/python/apache_beam/io/gcp/gcsio.py	433
sdks/python/apache_beam/io/gcp/gcsio_retry.py	56
sdks/python/apache_beam/ml/anomaly/detectors/offline.py	44
sdks/python/apache_beam/ml/anomaly/specifiable.py	237
sdks/python/apache_beam/ml/inference/base.py	1159
sdks/python/apache_beam/ml/inference/vertex_ai_inference.py	92
sdks/python/apache_beam/ml/transforms/base.py	454
sdks/python/apache_beam/ml/transforms/embeddings/__init__.py	1
sdks/python/apache_beam/ml/transforms/embeddings/huggingface.py	169
sdks/python/apache_beam/ml/transforms/embeddings/tensorflow_hub.py	89
sdks/python/apache_beam/ml/transforms/embeddings/vertex_ai.py	224
sdks/python/apache_beam/ml/transforms/handlers.py	314
sdks/python/apache_beam/ml/transforms/tft.py	404
sdks/python/apache_beam/ml/transforms/utils.py	45
sdks/python/apache_beam/pipeline.py	920
sdks/python/apache_beam/runners/common.py	1303
sdks/python/apache_beam/runners/dataflow/dataflow_runner.py	551
sdks/python/apache_beam/runners/dataflow/internal/apiclient.py	977
sdks/python/apache_beam/runners/direct/direct_runner.py	452
sdks/python/apache_beam/runners/direct/sdf_direct_runner.py	342
sdks/python/apache_beam/runners/direct/transform_evaluator.py	850
sdks/python/apache_beam/runners/interactive/interactive_runner.py	197
sdks/python/apache_beam/runners/pipeline_context.py	227
sdks/python/apache_beam/runners/portability/portable_runner.py	457
sdks/python/apache_beam/runners/render.py	404
sdks/python/apache_beam/runners/runner.py	163
sdks/python/apache_beam/runners/worker/bundle_processor.py	1769
sdks/python/apache_beam/runners/worker/opcounters.py	182
sdks/python/apache_beam/runners/worker/operations.py	1019
sdks/python/apache_beam/runners/worker/sdk_worker.py	973
sdks/python/apache_beam/runners/worker/worker_id_interceptor.py	36
sdks/python/apache_beam/testing/analyzers/github_issues_utils.py	134
sdks/python/apache_beam/testing/benchmarks/cloudml/pipelines/workflow.py	137
sdks/python/apache_beam/testing/benchmarks/inference/pytorch_image_classification_benchmarks.py	40
sdks/python/apache_beam/testing/benchmarks/inference/pytorch_language_modeling_benchmarks.py	16
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query10.py	83
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/winning_bids.py	133
sdks/python/apache_beam/transforms/core.py	2275
sdks/python/apache_beam/transforms/display.py	222
sdks/python/apache_beam/transforms/external.py	839
sdks/python/apache_beam/typehints/batch.py	198
sdks/python/apache_beam/typehints/pytorch_type_compatibility.py	98
sdks/python/apache_beam/typehints/schemas.py	738
sdks/python/apache_beam/typehints/testing/strategies.py	46
sdks/python/apache_beam/typehints/trivial_inference.py	508
sdks/python/apache_beam/typehints/typehints.py	912
sdks/python/apache_beam/utils/multi_process_shared.py	184
sdks/python/apache_beam/utils/subprocess_server.py	385
sdks/python/apache_beam/utils/transform_service_launcher.py	195
sdks/python/apache_beam/yaml/yaml_errors.py	49
sdks/python/apache_beam/yaml/yaml_io.py	345
sdks/python/apache_beam/yaml/yaml_provider.py	1047
sdks/python/apache_beam/yaml/yaml_testing.py	420
sdks/python/apache_beam/yaml/yaml_transform.py	914
sdks/python/expansion-service-container/boot.go	130
sdks/typescript/src/apache_beam/coders/coders.ts	78
sdks/typescript/src/apache_beam/coders/js_coders.ts	121
sdks/typescript/src/apache_beam/coders/required_coders.ts	434
sdks/typescript/src/apache_beam/coders/row_coder.ts	362
sdks/typescript/src/apache_beam/internal/environments.ts	69
sdks/typescript/src/apache_beam/internal/pipeline.ts	294
sdks/typescript/src/apache_beam/io/avroio.ts	33
sdks/typescript/src/apache_beam/io/bigqueryio.ts	36
sdks/typescript/src/apache_beam/io/kafka.ts	97
sdks/typescript/src/apache_beam/io/pubsub.ts	105
sdks/typescript/src/apache_beam/io/pubsublite.ts	33
sdks/typescript/src/apache_beam/proto/beam_fn_api.client.ts	121
sdks/typescript/src/apache_beam/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.grpc-client.ts	132
sdks/typescript/src/apache_beam/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.grpc-server.ts	128
sdks/typescript/src/apache_beam/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.ts	3456
sdks/typescript/src/apache_beam/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.ts	5095
sdks/typescript/src/apache_beam/runners/artifacts.ts	166
sdks/typescript/src/apache_beam/runners/direct_runner.ts	405
sdks/typescript/src/apache_beam/runners/runner.ts	95
sdks/typescript/src/apache_beam/serialization.ts	46
sdks/typescript/src/apache_beam/testing/assert.ts	63
sdks/typescript/src/apache_beam/testing/multi_pipeline_runner.ts	129
sdks/typescript/src/apache_beam/transforms/external.ts	298
sdks/typescript/src/apache_beam/transforms/flatten.ts	24
sdks/typescript/src/apache_beam/transforms/group_and_combine.ts	308
sdks/typescript/src/apache_beam/transforms/internal.ts	175
sdks/typescript/src/apache_beam/transforms/pardo.ts	297
sdks/typescript/src/apache_beam/transforms/window.ts	105
sdks/typescript/src/apache_beam/transforms/windowings.ts	130
sdks/typescript/src/apache_beam/utils/service.ts	413
sdks/typescript/src/apache_beam/values.ts	45
sdks/typescript/src/apache_beam/worker/data.ts	196
sdks/typescript/src/apache_beam/worker/operators.ts	816
sdks/typescript/src/apache_beam/worker/pardo_context.ts	215
sdks/typescript/src/apache_beam/worker/state.ts	184
sdks/typescript/src/apache_beam/worker/worker.ts	452
website/www/site/assets/scss/_hero.scss	102
website/www/site/assets/scss/_navbar-desktop.scss	169
website/www/site/assets/scss/bootstrap/_dropdowns.scss	147
website/www/site/assets/scss/bootstrap/_variables.scss	388
website/www/site/layouts/partials/head.html	66
website/www/site/layouts/partials/head_homepage.html	60