Path	Lines of Code
buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy	1680
buildSrc/src/main/groovy/org/apache/beam/gradle/VendorJavaPlugin.groovy	253
model/fn-execution/src/main/proto/beam_fn_api.proto	797
model/pipeline/src/main/proto/beam_runner_api.proto	1567
model/pipeline/src/main/proto/endpoints.proto	56
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/CoderTranslation.java	130
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineOptionsTranslation.java	89
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/PipelineTranslation.java	138
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SdkComponents.java	267
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/SerializablePipelineOptions.java	69
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WindowingStrategyTranslation.java	322
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/WriteFilesTranslation.java	259
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyPCollectionFusers.java	233
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyPipelineFuser.java	292
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/GreedyStageFuser.java	144
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/Networks.java	190
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/PipelineValidator.java	260
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/ProtoOverrides.java	50
runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/graph/QueryablePipeline.java	328
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/triggers/AfterDelayFromFirstElementStateMachine.java	192
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	188
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	327
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	253
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	1197
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkBatchPortablePipelineTranslator.java	486
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	181
runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingPortablePipelineTranslator.java	828
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	117
runners/flink/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/ExecutableStageDoFnOperator.java	1012
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/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/BatchViewOverrides.java	913
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowMetrics.java	252
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineTranslator.java	1005
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java	1751
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/PrimitiveParDoSingleFactory.java	294
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/internal/CustomSources.java	65
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/DefaultCoderCloudObjectTranslatorRegistrar.java	109
runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/util/MonitoringUtil.java	171
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	310
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContext.java	419
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java	669
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	200
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOperationContext.java	293
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowOutputCounter.java	64
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/DataflowSystemMetrics.java	40
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowWorkUnitClient.java	190
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/FnApiWindowMappingFn.java	254
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/GroupAlsoByWindowParDoFnFactory.java	317
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/IntrinsicMapTaskExecutorFactory.java	327
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IsmSideInputReader.java	772
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	264
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SimpleParDoFn.java	384
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/SourceOperationExecutorFactory.java	35
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java	2053
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java	650
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillStateInternals.java	1696
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkItemStatusClient.java	254
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerCustomSources.java	677
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WorkerPipelineOptionsFactory.java	52
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/counters/CounterFactory.java	632
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/fn/BeamFnControlService.java	94
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/BeamFnMapTaskExecutor.java	484
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/RegisterAndProcessBundleOperation.java	600
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/data/BeamFnDataGrpcService.java	187
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/CreateExecutableStageNodeFunction.java	480
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/CreateRegisterFnOperationFunction.java	182
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/InsertFetchAndFilterStreamingSideInputNodes.java	129
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/LengthPrefixUnknownCoders.java	248
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/Networks.java	143
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/RegisterNodeFunction.java	493
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/logging/DataflowWorkerLoggingHandler.java	231
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	132
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/common/worker/OutputObjectAndByteCounter.java	114
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	80
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/GrpcWindmillServer.java	1378
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/WindmillServer.java	29
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/GrpcContextHeaderAccessorProvider.java	47
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/DefaultJobBundleFactory.java	597
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/control/FnApiControlClientPoolService.java	89
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	528
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/data/GrpcDataService.java	146
runners/java-fn-execution/src/main/java/org/apache/beam/runners/fnexecution/environment/DockerCommand.java	168
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	138
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	440
runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/InMemoryJobService.java	422
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	167
runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaJobServerDriver.java	62
runners/samza/src/main/java/org/apache/beam/runners/samza/SamzaPipelineOptionsValidator.java	28
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	355
runners/samza/src/main/java/org/apache/beam/runners/samza/adapter/UnboundedSourceSystem.java	424
runners/samza/src/main/java/org/apache/beam/runners/samza/metrics/SamzaMetricsContainer.java	74
runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/DoFnOp.java	493
runners/samza/src/main/java/org/apache/beam/runners/samza/runtime/SamzaDoFnRunners.java	256
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ConfigBuilder.java	243
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/ParDoBoundMultiTranslator.java	315
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaPublishViewTranslator.java	41
runners/samza/src/main/java/org/apache/beam/runners/samza/translation/SamzaTransformOverrides.java	34
runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingPipelineResult.java	108
runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/SparkStructuredStreamingRunner.java	130
runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/SparkTransformOverrides.java	34
runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/TranslationContext.java	174
runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DatasetSourceBatch.java	117
runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ParDoTranslatorBatch.java	200
runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/PipelineTranslatorBatch.java	51
runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ReshuffleTranslatorBatch.java	8
runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/streaming/DatasetSourceStreaming.java	187
runners/spark/2/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/streaming/PipelineTranslatorStreaming.java	36
runners/spark/src/main/java/org/apache/beam/runners/spark/SparkPipelineRunner.java	227
runners/spark/src/main/java/org/apache/beam/runners/spark/SparkTransformOverrides.java	34
runners/spark/src/main/java/org/apache/beam/runners/spark/io/CreateStream.java	124
runners/spark/src/main/java/org/apache/beam/runners/spark/translation/SparkStreamingPortablePipelineTranslator.java	297
runners/spark/src/main/java/org/apache/beam/runners/spark/translation/streaming/StreamingTransformTranslator.java	525
runners/twister2/src/main/java/org/apache/beam/runners/twister2/Twister2Runner.java	269
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
sdks/go/pkg/beam/core/graph/coder/row.go	151
sdks/go/pkg/beam/core/graph/edge.go	350
sdks/go/pkg/beam/core/graph/fn.go	796
sdks/go/pkg/beam/core/graph/mtime/time.go	64
sdks/go/pkg/beam/core/runtime/exec/plan.go	157
sdks/go/pkg/beam/core/runtime/graphx/schema/logicaltypes.go	95
sdks/go/pkg/beam/core/runtime/graphx/translate.go	856
sdks/go/pkg/beam/core/runtime/harness/harness.go	368
sdks/go/pkg/beam/core/runtime/harness/logging.go	111
sdks/go/pkg/beam/core/runtime/harness/monitoring.go	154
sdks/go/pkg/beam/core/runtime/metricsx/urns.go	120
sdks/go/pkg/beam/io/databaseio/database.go	168
sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api.pb.go	5022
sdks/java/core/src/main/java/org/apache/beam/sdk/Pipeline.java	433
sdks/java/core/src/main/java/org/apache/beam/sdk/PipelineResult.java	36
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AvroCoder.java	468
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/IterableLikeCoder.java	160
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java	742
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java	392
sdks/java/core/src/main/java/org/apache/beam/sdk/io/LocalFileSystem.java	231
sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java	742
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceIdTester.java	122
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	1322
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	115
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldValueTypeInformation.java	231
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/JavaBeanSchema.java	144
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/JavaFieldSchema.java	94
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	207
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	295
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Convert.java	105
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Select.java	192
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AutoValueUtils.java	255
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroByteBuddyUtils.java	102
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroUtils.java	993
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java	1164
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ConvertHelpers.java	172
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectHelpers.java	346
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/StaticSchemaInference.java	132
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java	1125
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java	488
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java	575
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java	531
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	881
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithKeys.java	63
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	219
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ApiSurface.java	522
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	426
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/values/PCollectionViews.java	996
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	231
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/RetryHttpRequestInitializer.java	201
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java	406
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/Sorter.java	7
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/SqlTransform.java	189
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ScalarFunctionImpl.java	162
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/cep/CEPPattern.java	85
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	660
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java	370
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMatchRel.java	375
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	117
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	133
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	81
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BeamSqlUnparseContext.java	169
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	210
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTable.java	361
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCatalog.java	470
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/DateTimeUtils.java	164
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	201
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ExpressionConverter.java	806
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/TVFScanConverter.java	76
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/TableScanConverter.java	73
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/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataBufferingOutboundObserver.java	60
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataGrpcMultiplexer.java	158
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataSizeBasedBufferingOutboundObserver.java	106
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/windowing/EncodedBoundedWindow.java	53
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	2203
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/MapFnRunners.java	148
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java	697
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnDataGrpcClient.java	69
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnTimerGrpcClient.java	68
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BagUserState.java	98
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BeamFnStateGrpcClientCache.java	111
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java	432
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/IterableSideInput.java	43
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/MultimapSideInput.java	69
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3ReadableSeekableByteChannel.java	135
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsIO.java	120
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/AzureModule.java	136
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/BlobstoreOptions.java	74
sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/ClickHouseIO.java	300
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/BigQueryIO.java	1640
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageStreamSource.java	292
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java	715
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/CreateTableHelpers.java	120
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/CreateTables.java	98
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsTableRow.java	46
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java	163
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java	262
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java	420
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java	815
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	105
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	423
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java	671
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java	904
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationUtils.java	316
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java	1044
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerTransformRegistrar.java	306
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/StructUtils.java	349
sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystem.java	298
sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/SchemaUtils.java	67
sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcSchemaIOProvider.java	140
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCommitOffset.java	104
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java	1333
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	544
sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr/SolrIO.java	432
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticBoundedSource.java	183
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	170
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java	1130
sdks/python/apache_beam/coders/coder_impl.py	900
sdks/python/apache_beam/dataframe/convert.py	130
sdks/python/apache_beam/dataframe/frame_base.py	413
sdks/python/apache_beam/dataframe/frames.py	2272
sdks/python/apache_beam/dataframe/schemas.py	184
sdks/python/apache_beam/internal/pickler.py	160
sdks/python/apache_beam/internal/util.py	51
sdks/python/apache_beam/io/avroio.py	303
sdks/python/apache_beam/io/aws/clients/s3/fake_client.py	136
sdks/python/apache_beam/io/aws/s3io.py	323
sdks/python/apache_beam/io/filebasedsink.py	287
sdks/python/apache_beam/io/fileio.py	439
sdks/python/apache_beam/io/gcp/gcsio.py	401
sdks/python/apache_beam/pipeline.py	803
sdks/python/apache_beam/runners/dataflow/dataflow_runner.py	1152
sdks/python/apache_beam/runners/dataflow/internal/apiclient.py	918
sdks/python/apache_beam/runners/direct/direct_runner.py	401
sdks/python/apache_beam/runners/direct/sdf_direct_runner.py	338
sdks/python/apache_beam/runners/direct/transform_evaluator.py	898
sdks/python/apache_beam/runners/interactive/interactive_runner.py	133
sdks/python/apache_beam/runners/pipeline_context.py	210
sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py	818
sdks/python/apache_beam/runners/portability/portable_runner.py	457
sdks/python/apache_beam/runners/runner.py	212
sdks/python/apache_beam/runners/worker/data_plane.py	467
sdks/python/apache_beam/runners/worker/opcounters.py	172
sdks/python/apache_beam/runners/worker/sdk_worker.py	891
sdks/python/apache_beam/runners/worker/statecache.py	142
sdks/python/apache_beam/runners/worker/worker_id_interceptor.py	39
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/combiners.py	661
sdks/python/apache_beam/transforms/core.py	1571
sdks/python/apache_beam/transforms/display.py	199
sdks/python/apache_beam/transforms/external.py	349
sdks/python/apache_beam/typehints/typehints.py	671
sdks/python/apache_beam/utils/subprocess_server.py	236
sdks/python/gen_protos.py	279
website/www/site/assets/scss/bootstrap/_dropdowns.scss	147
website/www/site/assets/scss/bootstrap/_variables.scss	388