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" ] "[flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/ProcessTableOperator.java]" -- "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/SinkReuser.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/OptimizerConfigOptions.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/sync/ForStSyncKeyedStateBackendBuilder.java]" -- "[flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateBackend.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/sync/ForStSyncKeyedStateBackend.java]" -- "[flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateBackend.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecProcessTableFunction.java]" -- "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/sync/ForStSyncKeyedStateBackendBuilder.java]" -- "[flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/sync/ForStSyncKeyedStateBackend.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/ProcessTableOperator.java]" -- "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecProcessTableFunction.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/ProcessTableOperator.java]" -- "[flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ProcessTableRunnerGenerator.scala]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/reuse/SubplanReuser.scala]" -- "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/SinkReuser.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/reuse/SubplanReuser.scala]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/OptimizerConfigOptions.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ProcessTableRunnerGenerator.scala]" -- "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ProcessTableRunnerGenerator.scala]" -- "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecProcessTableFunction.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLegacyTableSourceScan.java]" -- "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingStateConfig.java]" -- "[flink-core/src/main/java/org/apache/flink/configuration/StateSizeTrackOptions.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingMapState.java]" -- "[flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/AbstractMetricsTrackState.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/EnvironmentSettings.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingStateConfig.java]" -- "[flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingStateConfig.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/AbstractValueState.java]" -- "[flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/AbstractAggregatingState.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlCreateModelConverter.java]" -- "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterModelRenameConverter.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/legacy/factories/TableSourceFactory.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/legacy/factories/TableSourceFactory.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SourceQueryOperation.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterModelSetConverter.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeModelOperation.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ResolvedExpressionJsonSerializer.java]" -- "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/PassThroughCollectorBase.java]" -- "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecProcessTableFunction.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/SqlFactory.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModelReset.java]" -- "[flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModel.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlCreateModelConverter.java]" -- "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlNodeToOperationConversion.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/ShortcutUtils.java]" -- "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference/OperatorBindingCallContext.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/PlannerQueryOperation.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ProjectQueryOperation.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/legacy/factories/TableSinkFactory.java]" -- "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ResolvedCatalogModel.java]" -- "[flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/legacy/factories/TableSourceFactory.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterModelSetConverter.java]" -- "[flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModelRename.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingListState.java]" -- "[flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/AbstractMetricsTrackState.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecProcessTableFunction.java]" -- "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/StaticArgumentTrait.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/RuntimeChangelogMode.java]" -- "[flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/ReadableInternalTimeContext.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlDescribeModelConverter.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowModelsOperation.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowCreateTableOperation.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ResolvedCatalogTable.java]" -- "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPropertiesUtil.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueKeys.scala]" -- "[flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ProcessTableRunnerGenerator.scala]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/catalog/CatalogSchemaTable.java]" -- "[flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/DefaultSqlFactory.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueKeys.scala]" -- "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecProcessTableFunction.java]" -- "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference/OperatorBindingCallContext.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStMapState.java]" -- "[flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/AbstractValueState.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/FilterQueryOperation.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/TableReferenceExpression.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStOptions.java]" -- "[flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/sync/ForStSyncKeyedStateBackend.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterModelChangeOperation.java]" -- "[flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModel.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; "[flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/catalog/CatalogSchemaTable.java]" -- "[flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/functions/TemporalTableFunctionImpl.java]" [label=" 1 ", penwidth="1", color="#00688b5E"]; }