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" ] "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorServer.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessor.java]" [label=" 7 ", penwidth="7", color="#00688bC9"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletServer.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorServer.java]" [label=" 6 ", penwidth="6", color="#00688bB7"]; "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/protocol/Errors.java]" -- "[fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOptions.java]" [label=" 6 ", penwidth="6", color="#00688bB7"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorContext.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessor.java]" [label=" 6 ", penwidth="6", color="#00688bB7"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorService.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherThread.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/ReplicaManager.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorServer.java]" -- "[fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOptions.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-kafka/src/main/java/com/alibaba/fluss/kafka/KafkaRequestHandler.java]" -- "[fluss-kafka/src/main/java/com/alibaba/fluss/kafka/KafkaRequest.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java]" -- "[fluss-rpc/src/main/proto/FlussApi.proto]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/ReplicaManager.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServerHandler.java]" -- "[fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOptions.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServerHandler.java]" -- "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServer.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorService.java]" -- "[fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOptions.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-client/src/main/java/com/alibaba/fluss/client/admin/FlussAdmin.java]" -- "[fluss-client/src/main/java/com/alibaba/fluss/client/admin/Admin.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServer.java]" -- "[fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOptions.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessor.java]" -- "[fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOptions.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletServer.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessor.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/MetadataManager.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorService.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletServer.java]" -- "[fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOptions.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessor.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletService.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/ReplicaManager.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-rpc/src/main/proto/FlussApi.proto]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorServer.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/statemachine/TableBucketStateMachine.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/statemachine/ReplicaStateMachine.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-kafka/src/main/java/com/alibaba/fluss/kafka/KafkaRequestHandler.java]" -- "[fluss-kafka/src/main/java/com/alibaba/fluss/kafka/KafkaCommandDecoder.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherThread.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/RemoteLeaderEndpoint.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java]" -- "[fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOptions.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-rpc/src/main/proto/FlussApi.proto]" -- "[fluss-client/src/main/java/com/alibaba/fluss/client/admin/Admin.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-rpc/src/main/proto/FlussApi.proto]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessor.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorServer.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherThread.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/LeaderEndpoint.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletService.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/log/WriterStateManager.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/log/LogTablet.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/RequestProcessorPool.java]" -- "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServer.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/RemoteLeaderEndpoint.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/LeaderEndpoint.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-rpc/src/main/proto/FlussApi.proto]" -- "[fluss-client/src/main/java/com/alibaba/fluss/client/admin/FlussAdmin.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletService.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorService.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletServer.java]" -- "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServerHandler.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java]" -- "[fluss-client/src/main/java/com/alibaba/fluss/client/admin/Admin.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/ServerChannelInitializer.java]" -- "[fluss-common/src/main/java/com/alibaba/fluss/config/ConfigOptions.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/tablet/TabletService.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessor.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/ServerChannelInitializer.java]" -- "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServer.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-common/src/main/java/com/alibaba/fluss/record/MemoryLogRecordsIndexedBuilder.java]" -- "[fluss-common/src/main/java/com/alibaba/fluss/record/DefaultLogRecordBatch.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java]" -- "[fluss-client/src/main/java/com/alibaba/fluss/client/admin/FlussAdmin.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-rpc/src/main/proto/FlussApi.proto]" -- "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServerHandler.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/fetcher/ReplicaFetcherThread.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/log/LogTablet.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorServer.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorService.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-server/src/main/java/com/alibaba/fluss/server/replica/ReplicaManager.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessor.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-client/src/main/java/com/alibaba/fluss/client/utils/ClientRpcMessageUtils.java]" -- "[fluss-server/src/main/java/com/alibaba/fluss/server/RpcServiceBase.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-rpc/src/main/proto/FlussApi.proto]" -- "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/protocol/ApiKeys.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/RequestProcessorPool.java]" -- "[fluss-rpc/src/main/java/com/alibaba/fluss/rpc/netty/server/NettyServerHandler.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; }