Uber / uForwarder
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
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredTags.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java		 3 5 (60%) 10 (30%) 2024-03-06
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java
idl/src/main/proto/data/kafka/data-transfer/job_status.proto		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java		 3 5 (60%) 7 (42%) 2024-03-06
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java
idl/src/main/proto/data/kafka/data-transfer/job_group.proto		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java		 3 7 (42%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java
uforwarder-core/src/main/resources/workerJobStatus.html		 3 7 (42%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java		 3 7 (42%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java		 3 7 (42%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java		 3 7 (42%) 7 (42%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java
idl/src/main/proto/data/kafka/data-transfer/job.proto		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java		 3 3 (100%) 5 (60%) 2024-03-06
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java
idl/src/main/proto/data/kafka/data-transfer/job_group.proto		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java
idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto		 3 5 (60%) 7 (42%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java		 3 5 (60%) 10 (30%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java		 3 10 (30%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java
idl/src/main/proto/data/kafka/data-transfer/job.proto		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java		 3 7 (42%) 5 (60%) 2024-03-06
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java		 3 7 (42%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java
idl/src/main/proto/data/kafka/data-transfer/job_group.proto		 3 10 (30%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java
uforwarder-core/src/main/resources/workerJobStatus.html		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java		 3 5 (60%) 10 (30%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java
idl/src/main/proto/data/kafka/data-transfer/job_group.proto		 3 7 (42%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java
uforwarder-core/src/main/resources/workerJobStatus.html		 3 10 (30%) 5 (60%) 2024-03-06
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java
idl/src/main/proto/data/kafka/data-transfer/job_group.proto		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder-core/src/main/resources/workerJobStatus.html
idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto		 3 5 (60%) 7 (42%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java		 3 5 (60%) 3 (100%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java
uforwarder-core/src/main/resources/workerJobStatus.html		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java		 3 5 (60%) 7 (42%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java
instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java		 3 10 (30%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java		 3 5 (60%) 5 (60%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java		 3 5 (60%) 7 (42%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java		 3 5 (60%) 7 (42%) 2024-03-06
uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredTags.java
uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java		 3 5 (60%) 7 (42%) 2024-03-06
Dependencies between files in same commits
The number on the lines shows the number of shared commits.
G [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java]--[uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java]--[uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java] 3 [idl/src/main/proto/data/kafka/data-transfer/job_status.proto] [idl/src/main/proto/data/kafka/data-transfer/job_status.proto] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java]--[idl/src/main/proto/data/kafka/data-transfer/job_status.proto] 3 [idl/src/main/proto/data/kafka/data-transfer/job_group.proto] [idl/src/main/proto/data/kafka/data-transfer/job_group.proto] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java]--[idl/src/main/proto/data/kafka/data-transfer/job_group.proto] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredTags.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredTags.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java]--[uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredTags.java] 3 [idl/src/main/proto/data/kafka/data-transfer/job.proto] [idl/src/main/proto/data/kafka/data-transfer/job.proto] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java]--[idl/src/main/proto/data/kafka/data-transfer/job.proto] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredTags.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java]--[uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java] 3 [uforwarder-core/src/main/resources/workerJobStatus.html] [uforwarder-core/src/main/resources/workerJobStatus.html] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java]--[uforwarder-core/src/main/resources/workerJobStatus.html] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java]--[idl/src/main/proto/data/kafka/data-transfer/job_group.proto] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java] 3 [instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java] [instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java]--[instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java]--[uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java]--[uforwarder-core/src/main/resources/workerJobStatus.html] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java]--[idl/src/main/proto/data/kafka/data-transfer/job_group.proto] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java]--[idl/src/main/proto/data/kafka/data-transfer/job_group.proto] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java]--[uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java]--[uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java]--[uforwarder-core/src/main/resources/workerJobStatus.html] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java] 3 [idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto] [idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java]--[idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java]--[idl/src/main/proto/data/kafka/data-transfer/job_group.proto] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java] 3 [uforwarder-core/src/main/resources/workerJobStatus.html]--[idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java] 3 [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java] [uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java]--[uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java]--[idl/src/main/proto/data/kafka/data-transfer/job.proto] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java]--[uforwarder-core/src/main/resources/workerJobStatus.html] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java]--[uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java] 3 [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java] [uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java]--[uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java] 3
Download: SVG DOT (open online Graphviz editor)

Open 3D force graph (file dependencies)...
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 uforwarder uforwarder uforwarder--uforwarder 3 uforwarder-core uforwarder-core uforwarder--uforwarder-core 3 idl idl uforwarder--idl 3 instrumentation instrumentation uforwarder--instrumentation 3 uforwarder-core--uforwarder-core 3 uforwarder-core--idl 3 uforwarder-core--instrumentation 3 idl--idl 3 instrumentation--idl 3
Download: SVG DOT (open online Graphviz editor)

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