apache / flink
Temporal Dependencies

A temporal dependency occurs when developers change two or more files at the same time (i.e. they are a part of the same commit).


Files Most Frequently Changed Together (Top 50)

data...

Pairs # same commits # commits 1 # commits 2 latest commit
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
2 5 (40%) 8 (25%) 2025-05-07
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
2 2 (100%) 30 (6%) 2025-04-25
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
2 11 (18%) 25 (8%) 2025-04-21
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
2 12 (16%) 25 (8%) 2025-04-21
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
2 7 (28%) 8 (25%) 2025-05-07
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
2 11 (18%) 12 (16%) 2025-04-21
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
2 5 (40%) 7 (28%) 2025-05-07
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
2 5 (40%) 7 (28%) 2025-05-07
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
2 7 (28%) 2 (100%) 2025-04-25
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
2 7 (28%) 30 (6%) 2025-04-25
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
2 7 (28%) 8 (25%) 2025-05-07
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
2 7 (28%) 7 (28%) 2025-05-07
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
1 10 (10%) 23 (4%) 2025-04-10
flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingStateConfig.java
flink-core/src/main/java/org/apache/flink/configuration/StateSizeTrackOptions.java
1 4 (25%) 1 (100%) 2025-04-21
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
1 1 (100%) 1 (100%) 2025-04-21
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
1 15 (6%) 27 (3%) 2025-04-10
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
1 1 (100%) 4 (25%) 2025-04-21
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
1 3 (33%) 7 (14%) 2025-04-07
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
1 1 (100%) 1 (100%) 2025-04-28
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
1 5 (20%) 77 (1%) 2025-04-10
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
1 137 (<1%) 77 (1%) 2025-04-10
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
1 5 (20%) 6 (16%) 2025-04-10
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
1 1 (100%) 1 (100%) 2025-04-28
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
1 3 (33%) 12 (8%) 2025-04-10
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
1 3 (33%) 7 (14%) 2025-05-07
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
1 1 (100%) 77 (1%) 2025-04-10
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
1 1 (100%) 2 (50%) 2025-04-28
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
1 1 (100%) 26 (3%) 2025-04-28
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
1 10 (10%) 9 (11%) 2025-05-07
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
1 3 (33%) 8 (12%) 2025-04-10
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
1 5 (20%) 13 (7%) 2025-04-10
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
1 2 (50%) 58 (1%) 2025-04-10
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
1 5 (20%) 6 (16%) 2025-04-10
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
1 1 (100%) 1 (100%) 2025-04-28
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
1 1 (100%) 1 (100%) 2025-04-21
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
1 7 (14%) 6 (16%) 2025-05-07
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
1 1 (100%) 2 (50%) 2025-05-07
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
1 10 (10%) 77 (1%) 2025-04-10
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
1 1 (100%) 1 (100%) 2025-04-28
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
1 11 (9%) 5 (20%) 2025-04-10
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
1 9 (11%) 14 (7%) 2025-04-10
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
1 10 (10%) 7 (14%) 2025-05-07
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
1 10 (10%) 1 (100%) 2025-04-10
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
1 10 (10%) 2 (50%) 2025-05-07
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
1 7 (14%) 9 (11%) 2025-05-07
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
1 12 (8%) 3 (33%) 2025-04-07
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
1 8 (12%) 10 (10%) 2025-04-10
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
1 16 (6%) 12 (8%) 2025-04-09
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
1 1 (100%) 2 (50%) 2025-04-28
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
1 10 (10%) 8 (12%) 2025-04-10
Dependencies between files in same commits
The number on the lines shows the number of shared commits.
G [flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/ProcessTableOperator.java] [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] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ProcessTableFunction.java] [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] 2 [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/plan/nodes/exec/stream/StreamExecProcessTableFunction.java] [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] 2 [flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ProcessTableRunnerGenerator.scala] [flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ProcessTableRunnerGenerator.scala] [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] 2 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse/SinkReuser.java] [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] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/OptimizerConfigOptions.java] [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] 2 [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/ForStSyncKeyedStateBackendBuilder.java] [flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateBackend.java] [flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateBackend.java] [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] 2 [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/sync/ForStSyncKeyedStateBackend.java] [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] 2 [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] 2 [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] 2 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference/OperatorBindingCallContext.java] [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference/OperatorBindingCallContext.java] [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] 1 [flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/StaticArgumentTrait.java] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/StaticArgumentTrait.java] [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] 1 [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] 2 [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] 2 [flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/reuse/SubplanReuser.scala] [flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/reuse/SubplanReuser.scala] [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] 2 [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] 2 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/common/CommonExecLegacyTableSourceScan.java] [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] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java] [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] 1 [flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingStateConfig.java] [flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingStateConfig.java] [flink-core/src/main/java/org/apache/flink/configuration/StateSizeTrackOptions.java] [flink-core/src/main/java/org/apache/flink/configuration/StateSizeTrackOptions.java] [flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/LatencyTrackingStateConfig.java]--[flink-core/src/main/java/org/apache/flink/configuration/StateSizeTrackOptions.java] 1 [flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingMapState.java] [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] [flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/AbstractMetricsTrackState.java] [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] 1 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java] [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] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/EnvironmentSettings.java] [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] 1 [flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingStateConfig.java] [flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingStateConfig.java] [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] 1 [flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/AbstractValueState.java] [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] [flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/AbstractAggregatingState.java] [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] 1 [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/SqlCreateModelConverter.java] [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterModelRenameConverter.java] [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterModelRenameConverter.java] [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] 1 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlNodeToOperationConversion.java] [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/SqlNodeToOperationConversion.java] [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] 1 [flink-table/flink-table-common/src/main/java/org/apache/flink/table/legacy/factories/TableSourceFactory.java] [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] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java] [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] 1 [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SourceQueryOperation.java] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/SourceQueryOperation.java] [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] 1 [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ValuesQueryOperation.java] [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] 1 [flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java] [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] 1 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterModelSetConverter.java] [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] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeModelOperation.java] [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] 1 [flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModelRename.java] [flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModelRename.java] [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] 1 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde/ResolvedExpressionJsonSerializer.java] [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] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/FieldReferenceExpression.java] [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] 1 [flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/PassThroughCollectorBase.java] [flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/PassThroughCollectorBase.java] [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] 1 [flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/SqlFactory.java] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/SqlFactory.java] [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] 1 [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/SqlAlterModelReset.java] [flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModel.java] [flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModel.java] [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] 1 [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/utils/ShortcutUtils.java] [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] 1 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/PlannerQueryOperation.java] [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] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ProjectQueryOperation.java] [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] 1 [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/legacy/factories/TableSinkFactory.java] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/TypeLiteralExpression.java] [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] 1 [flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/ResolvedCatalogModel.java] [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] [flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala] [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] 1 [flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingListState.java] [flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics/MetricsTrackingListState.java] [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] 1 [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/RuntimeChangelogMode.java] [flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/ReadableInternalTimeContext.java] [flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process/ReadableInternalTimeContext.java] [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] 1 [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/expressions/TableReferenceExpression.java] [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] 1 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlDescribeModelConverter.java] [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] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowModelsOperation.java] [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] 1 [flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/SqlCallSyntax.java] [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] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ShowCreateTableOperation.java] [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] 1 [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/ResolvedCatalogTable.java] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPropertiesUtil.java] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/CatalogPropertiesUtil.java] [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] 1 [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/plan/metadata/FlinkRelMdUniqueKeys.scala] [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] 1 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java] [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/trait/ModifyKindSet.java] [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] 1 [flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/catalog/CatalogSchemaTable.java] [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] [flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/DefaultSqlFactory.java] [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] 1 [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/functions/TemporalTableFunctionImpl.java] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/functions/TemporalTableFunctionImpl.java] [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] 1 [flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStMapState.java] [flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStMapState.java] [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] 1 [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/operations/FilterQueryOperation.java] [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] 1 [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/ForStOptions.java] [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] 1 [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterModelChangeOperation.java] [flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl/AlterModelChangeOperation.java] [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] 1
Download: SVG DOT (open online Graphviz editor)

Open 2D force graph (file dependencies)... Open 3D force graph (file dependencies)...
Open 2D force graph (file dependencies with commits)... Open 3D force graph (file dependencies with commits)...
Dependencies between components in same commits (primary)
The number on the lines shows the number of shared commits.
G flink-table flink-table flink-table--flink-table 10 flink-python flink-python flink-table--flink-python 1 flink-state-backends flink-state-backends flink-state-backends--flink-state-backends 6 flink-runtime flink-runtime flink-state-backends--flink-runtime 3 flink-core flink-core flink-state-backends--flink-core 1 flink-runtime--flink-runtime 6 flink-runtime--flink-core 1 flink-python--flink-python 3 flink-connectors flink-connectors flink-connectors--flink-connectors 1 flink-libraries flink-libraries flink-libraries--flink-libraries 1 flink-formats flink-formats flink-formats--flink-formats 1 flink-yarn flink-yarn flink-yarn--flink-yarn 1
Download: SVG DOT (open online Graphviz editor)

Open 2D force graph (file dependencies)... Open 3D force graph (file dependencies)...