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=" 8 ", penwidth="8", color="#00688bDB"];
    "[settings.gradle.kts]" -- "[build.gradle.kts]" [label=" 7 ", penwidth="7", color="#00688bC9"];
    "[sdks/python/apache_beam/yaml/main.py]" -- "[sdks/python/apache_beam/yaml/yaml_transform.py]" [label=" 6 ", penwidth="6", color="#00688bB7"];
    "[sdks/python/apache_beam/yaml/yaml_testing.py]" -- "[sdks/python/apache_beam/yaml/main.py]" [label=" 5 ", penwidth="5", color="#00688bA5"];
    "[sdks/python/apache_beam/transforms/managed.py]" -- "[sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java]" [label=" 5 ", 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=" 4 ", penwidth="4", color="#00688b93"];
    "[sdks/python/apache_beam/runners/runner.py]" -- "[sdks/python/apache_beam/runners/dataflow/dataflow_runner.py]" [label=" 4 ", penwidth="4", color="#00688b93"];
    "[sdks/python/apache_beam/ml/anomaly/specifiable.py]" -- "[sdks/python/apache_beam/ml/anomaly/base.py]" [label=" 4 ", penwidth="4", color="#00688b93"];
    "[sdks/python/apache_beam/ml/anomaly/transforms.py]" -- "[sdks/python/apache_beam/ml/anomaly/specifiable.py]" [label=" 4 ", penwidth="4", color="#00688b93"];
    "[sdks/python/apache_beam/runners/common.py]" -- "[sdks/python/apache_beam/runners/dataflow/dataflow_runner.py]" [label=" 4 ", penwidth="4", color="#00688b93"];
    "[sdks/python/apache_beam/runners/runner.py]" -- "[sdks/python/apache_beam/pipeline.py]" [label=" 4 ", penwidth="4", color="#00688b93"];
    "[sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py]" -- "[sdks/python/apache_beam/runners/dataflow/dataflow_runner.py]" [label=" 4 ", penwidth="4", color="#00688b93"];
    "[sdks/python/apache_beam/typehints/typehints.py]" -- "[sdks/python/apache_beam/typehints/native_type_compatibility.py]" [label=" 4 ", penwidth="4", color="#00688b93"];
    "[sdks/python/apache_beam/runners/dataflow/dataflow_runner.py]" -- "[sdks/python/apache_beam/pipeline.py]" [label=" 4 ", penwidth="4", color="#00688b93"];
    "[sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py]" -- "[sdks/python/apache_beam/runners/common.py]" [label=" 4 ", penwidth="4", color="#00688b93"];
    "[sdks/python/apache_beam/transforms/managed.py]" -- "[sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/ManagedSchemaTransformProvider.java]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/pipeline_utils.py]" -- "[sdks/python/apache_beam/runners/common.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py]" -- "[sdks/python/apache_beam/runners/runner.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py]" -- "[sdks/python/apache_beam/runners/pipeline_utils.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/yaml/pipeline.schema.yaml]" -- "[sdks/python/apache_beam/yaml/yaml_transform.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/dataflow/internal/apiclient.py]" -- "[sdks/python/apache_beam/pipeline.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/WatchForKafkaTopicPartitions.java]" -- "[sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedSource.java]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[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=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/common.py]" -- "[sdks/python/apache_beam/runners/runner.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/dataflow/internal/apiclient.py]" -- "[sdks/python/apache_beam/runners/dataflow/dataflow_runner.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java]" -- "[sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PreparePubsubWriteDoFn.java]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/common.py]" -- "[sdks/python/apache_beam/runners/dataflow/internal/apiclient.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/pipeline_utils.py]" -- "[sdks/python/apache_beam/runners/dataflow/internal/apiclient.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/yaml/yaml_testing.py]" -- "[sdks/python/apache_beam/yaml/yaml_transform.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/ml/anomaly/transforms.py]" -- "[sdks/python/apache_beam/ml/anomaly/detectors/offline.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py]" -- "[sdks/python/apache_beam/pipeline.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/pipeline_utils.py]" -- "[sdks/python/apache_beam/runners/runner.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/dataflow/internal/apiclient.py]" -- "[sdks/python/apache_beam/runners/runner.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/ml/anomaly/base.py]" -- "[sdks/python/apache_beam/ml/anomaly/aggregations.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/setup.py]" -- "[sdks/python/apache_beam/yaml/yaml_provider.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[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=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/pipeline_utils.py]" -- "[sdks/python/apache_beam/pipeline.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py]" -- "[sdks/python/apache_beam/runners/dataflow/internal/apiclient.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedSource.java]" -- "[sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/providers/SqsReadSchemaTransformProvider.java]" -- "[sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/providers/SqsReadConfiguration.java]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/WatchForKafkaTopicPartitions.java]" -- "[sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/pipeline_utils.py]" -- "[sdks/python/apache_beam/runners/dataflow/dataflow_runner.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[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=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/runners/common.py]" -- "[sdks/python/apache_beam/pipeline.py]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaReadSchemaTransformConfiguration.java]" -- "[sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaReadSchemaTransformProvider.java]" [label=" 3 ", penwidth="3", color="#00688b82"];
    "[sdks/python/apache_beam/internal/cloudpickle/cloudpickle_fast.py]" -- "[build.gradle.kts]" [label=" 2 ", penwidth="2", color="#00688b70"];
    "[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/AbstractWindmillStream.java]" [label=" 2 ", penwidth="2", color="#00688b70"];
    "[sdks/python/gen_managed_doc.py]" -- "[sdks/python/apache_beam/transforms/managed.py]" [label=" 2 ", penwidth="2", color="#00688b70"];
    "[model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/metrics.proto]" -- "[runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/MetricsContainerImpl.java]" [label=" 2 ", penwidth="2", color="#00688b70"];
    "[sdks/python/apache_beam/runners/portability/expansion_service_main.py]" -- "[sdks/python/apache_beam/utils/subprocess_server.py]" [label=" 2 ", penwidth="2", color="#00688b70"];

}