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/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtils.java]" -- "[sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/AvroGenericRecordToStorageApiProto.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimerInternals.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillKeyedWorkItem.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProto.java]" -- "[sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/AvroGenericRecordToStorageApiProto.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillKeyedWorkItem.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[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/read/SolaceCheckpointMark.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtils.java]" -- "[sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProto.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimerInternals.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/PredictionResult.java]" -- "[sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelResponse.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlUseDatabase.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSystemDbMetadataSchema.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/runners/worker/sdk_worker_main.py]" -- "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/RemoteInference.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/TableProvider.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdfImpl.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/coders/typecoders.py]" -- "[sdks/python/apache_beam/runners/dataflow/internal/names.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/coders/typecoders.py]" -- "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseModelHandler.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelHandler.java]" -- "[sdks/python/apache_beam/ml/inference/gemini_inference.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/internal/pickler.py]" -- "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseModelHandler.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindowingWindmillReader.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillTimerInternals.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseModelParameters.java]" -- "[sdks/python/apache_beam/runners/portability/stager.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/TableProvider.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillSink.java]" -- "[sdks/python/apache_beam/runners/portability/stager.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CatalogManagerSchema.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSystemDbMetadataSchema.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/typehints/schemas.py]" -- "[sdks/python/apache_beam/ml/inference/gemini_inference.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/catalog/Catalog.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDdlNodes.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcDriver.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteSchemaFactory.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/internal/pickler.py]" -- "[sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelParameters.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/TableProvider.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSqlEnv.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelHandler.java]" -- "[sdks/python/apache_beam/runners/dataflow/internal/names.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/ml/inference/gemini_inference.py]" -- "[buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/ml/inference/vertex_ai_inference.py]" -- "[sdks/python/apache_beam/ml/inference/pytorch_inference.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/PredictionResult.java]" -- "[sdks/python/apache_beam/options/pipeline_options.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcDriver.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseResponse.java]" -- "[sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelInput.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/internal/pickler.py]" -- "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseInput.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSystemDbMetadataSchema.java]" -- "[sdks/java/extensions/sql/src/main/codegen/includes/parserImpls.ftl]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/PredictionResult.java]" -- "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseModelParameters.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/catalog/InMemoryCatalog.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlCreateExternalTable.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillSink.java]" -- "[sdks/python/apache_beam/runners/dataflow/internal/names.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/ml/inference/tensorrt_inference.py]" -- "[sdks/python/apache_beam/ml/inference/base.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseInput.java]" -- "[sdks/python/apache_beam/runners/portability/stager.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto]" -- "[buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseModelParameters.java]" -- "[build.gradle.kts]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py]" -- "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/BaseInput.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdfImpl.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/state/CachingStateTable.java]" -- "[runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingModeExecutionContext.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/TableProvider.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TVFSlidingWindowFn.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/python/apache_beam/runners/worker/sdk_worker_main.py]" -- "[sdks/python/apache_beam/options/pipeline_options.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/SystemTables.java]" -- "[sdks/java/extensions/sql/iceberg/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/IcebergCatalog.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelHandler.java]" -- "[model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/remote/src/main/java/org/apache/beam/sdk/ml/inference/remote/RemoteInference.java]" -- "[sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelResponse.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/TableProvider.java]" -- "[sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteTable.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[sdks/java/ml/inference/openai/src/main/java/org/apache/beam/sdk/ml/inference/openai/OpenAIModelInput.java]" -- "[sdks/python/apache_beam/ml/inference/gemini_inference.py]" [label=" 1 ", penwidth="1", color="#00688b5E"]; }