graph G { compound="true" rankdir="TB" bgcolor="white" fontname="Tahoma" node [ fixedsize="false" fontname="Tahoma" color="white" fillcolor="deepskyblue2" fontcolor="black" shape="box" style="filled" penwidth="1.0" ] edge [ fontname="Arial" color="#00688b" fontcolor="black" fontsize="12" arrowsize="0.5" penwidth="1.0" ] "[sdks/python/apache_beam/yaml/yaml_transform.py]" -- "[sdks/python/apache_beam/yaml/yaml_provider.py]" [label=" 12 ", penwidth="10", color="#00688bFF"]; "[sdks/python/apache_beam/yaml/main.py]" -- "[sdks/python/apache_beam/yaml/yaml_transform.py]" [label=" 8 ", penwidth="6", color="#00688bB7"]; "[sdks/python/apache_beam/transforms/managed.py]" -- "[sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java]" [label=" 8 ", penwidth="6", color="#00688bB7"]; "[sdks/python/apache_beam/typehints/typehints.py]" -- "[sdks/python/apache_beam/typehints/native_type_compatibility.py]" [label=" 8 ", penwidth="6", color="#00688bB7"]; "[sdks/go/pkg/beam/runners/prism/internal/execute.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/jobservices/management.go]" [label=" 8 ", penwidth="6", color="#00688bB7"]; "[settings.gradle.kts]" -- "[build.gradle.kts]" [label=" 8 ", penwidth="6", color="#00688bB7"]; "[sdks/python/apache_beam/yaml/yaml_io.py]" -- "[sdks/python/apache_beam/yaml/yaml_provider.py]" [label=" 7 ", penwidth="5", color="#00688bA5"]; "[runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/BoundedTrieData.java]" -- "[runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/BoundedTrieCell.java]" [label=" 7 ", penwidth="5", color="#00688bA5"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetWorkStream.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcDirectGetWorkStream.java]" [label=" 7 ", penwidth="5", color="#00688bA5"]; "[sdks/go/pkg/beam/runners/prism/internal/execute.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go]" [label=" 7 ", penwidth="5", color="#00688bA5"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetWorkStream.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcWindmillStreamFactory.java]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[sdks/python/apache_beam/yaml/yaml_mapping.py]" -- "[sdks/python/apache_beam/yaml/yaml_provider.py]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[sdks/python/apache_beam/metrics/cells.pxd]" -- "[sdks/python/apache_beam/metrics/cells.py]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[sdks/java/container/license_scripts/dep_urls_java.yaml]" -- "[buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[sdks/python/apache_beam/yaml/generate_yaml_docs.py]" -- "[sdks/python/apache_beam/yaml/yaml_mapping.py]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingStepMetricsContainer.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchModeExecutionContext.java]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/ManagedSchemaTransformProvider.java]" -- "[sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[sdks/python/apache_beam/transforms/managed.py]" -- "[sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/ManagedSchemaTransformProvider.java]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcDirectGetWorkStream.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcWindmillStreamFactory.java]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java]" -- "[sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[sdks/go/pkg/beam/runners/prism/internal/jobservices/management.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/preprocess.go]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[settings.gradle.kts]" -- "[buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/read/UnboundedSolaceReader.java]" -- "[sdks/java/io/solace/src/main/java/org/apache/beam/sdk/io/solace/broker/SessionService.java]" [label=" 6 ", penwidth="5", color="#00688bA5"]; "[sdks/python/apache_beam/coders/typecoders.py]" -- "[sdks/python/apache_beam/coders/coders.py]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/python/apache_beam/runners/direct/direct_metrics.py]" -- "[sdks/python/apache_beam/metrics/cells.py]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowMetricsContainer.java]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcReadSchemaTransformProvider.java]" -- "[sdks/python/apache_beam/yaml/standard_io.yaml]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[runners/java-job-service/src/main/java/org/apache/beam/runners/jobsubmission/JobInvoker.java]" -- "[runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkJobInvoker.java]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/python/apache_beam/yaml/yaml_testing.py]" -- "[sdks/python/apache_beam/yaml/main.py]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStream.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcDirectGetWorkStream.java]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetWorkStream.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStream.java]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcGetDataStream.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/GrpcWindmillStreamFactory.java]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/python/apache_beam/dataframe/transforms.py]" -- "[sdks/python/apache_beam/dataframe/doctests.py]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/python/apache_beam/yaml/yaml_io.py]" -- "[sdks/python/apache_beam/yaml/yaml_mapping.py]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/python/apache_beam/dataframe/expressions.py]" -- "[sdks/python/apache_beam/dataframe/doctests.py]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java]" -- "[sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/python/apache_beam/dataframe/transforms.py]" -- "[sdks/python/apache_beam/dataframe/expressions.py]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/go/pkg/beam/runners/prism/internal/execute.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/preprocess.go]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/go/pkg/beam/runners/prism/internal/jobservices/management.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/stage.go]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/jobservices/management.go]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/python/apache_beam/yaml/yaml_errors.py]" -- "[sdks/python/apache_beam/yaml/generate_yaml_docs.py]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/go/pkg/beam/runners/prism/internal/jobservices/management.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/handlerunner.go]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/go/pkg/beam/runners/prism/internal/preprocess.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/handlerunner.go]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/go/pkg/beam/runners/prism/internal/execute.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/stage.go]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/DataflowMetricsContainer.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingStepMetricsContainer.java]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/go/pkg/beam/runners/prism/internal/worker/worker.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/execute.go]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/python/apache_beam/io/jdbc.py]" -- "[sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcSchemaIOProvider.java]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingStepMetricsContainer.java]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/go/pkg/beam/runners/prism/internal/worker/worker.go]" -- "[sdks/go/pkg/beam/runners/prism/internal/jobservices/management.go]" [label=" 5 ", penwidth="4", color="#00688b93"]; "[sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryWriteConfiguration.java]" -- "[sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/providers/BigQueryFileLoadsSchemaTransformProvider.java]" [label=" 4 ", penwidth="3", color="#00688b82"]; }