apache / rocketmq-eventbridge
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 0% | 16% | 18% | 65%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 0% | 14% | 19% | 65%
xml0% | 0% | 37% | 0% | 62%
sql0% | 0% | 0% | 53% | 46%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
adapter0% | 0% | 19% | 16% | 63%
domain0% | 0% | 22% | 12% | 64%
common0% | 0% | 0% | 38% | 61%
supports0% | 0% | 0% | 35% | 64%
start0% | 0% | 0% | 0% | 100%
style0% | 0% | 0% | 0% | 100%
infrastructure0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
ConnectionService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection
 349 17
RocketMQEventSubscriber.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer
 291 20
EventApiDestinationMapper.xml
in adapter/persistence/src/main/resources/mybatis
 264 -
EventConnectionMapper.xml
in adapter/persistence/src/main/resources/mybatis
 261 -
HTTPEventSourceService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source
 251 16
LitePullConsumerImpl.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer
 249 15
ConnectionController.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller
 228 9
HttpEventConverter.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter
 218 8
CirculatorContext.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common
 208 16
PluginUtils.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin
 203 6
PatternCondition.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern
 191 24
ApiDestinationController.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller
 178 6
BatchedCloudEventDeserializer.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format
 162 6
CloudEventTransform.java
in supports/connect-cloudevent-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge
 161 15
Plugin.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin
 155 12
PatternEvaluatorBuilder.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern
 151 4
PatternConditionBuilder.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern
 150 6
TriggerTaskContext.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger
 147 7
V1__baseline.sql
in adapter/persistence/src/main/resources/db/migration
 135 -
EventRuleController.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller
 135 7
LocalMessageCache.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer
 134 8
EventTargetRunnerService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/run
 125 9
TargetKeyValue.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity
 117 23
PatternEvaluator.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern
 117 13
TransformEngine.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/transfer
 115 9
EventSourceController.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller
 114 5
EventBridgeErrorCode.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common/exception
 111 3
RocketMQEventDataAPIImpl.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api
 109 6
JsonPathUtil.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform
 108 6
StringSubstitutorTemplate.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform
 105 7
ApiDestinationService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination
 105 10
FileAndPropertyUtil.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common
 102 5
EventRuleTransfer.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot
 100 6
EventRuleService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/rule
 100 9
EventSourceClassService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/classes
 99 7
ServiceThread.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common
 98 12
BatchedCloudEventSerializer.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format
 96 3
EventSourceService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source
 93 8
AbstractTargetRunnerConfigObserver.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service
 91 8
90 -
FileBaseKeyValueStore.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store
 90 6
TargetRunnerConfig.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity
 89 7
ClientConfig.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer
 89 21
88 -
EventTargetClassService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/classes
 88 6
RocketMQConnectClient.java
in adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect
 87 6
TargetRunnerConfigOnFileObserver.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service
 85 5
EventDataController.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller
 84 3
EventSourceMapper.xml
in adapter/persistence/src/main/resources/mybatis
 83 -
EventTargetController.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller
 82 4
Files With Most Units (Top 50)
File# lines# units
PatternCondition.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern
 191 24
TargetKeyValue.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity
 117 23
ClientConfig.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer
 89 21
RocketMQEventSubscriber.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer
 291 20
ConnectionService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection
 349 17
CirculatorContext.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common
 208 16
HTTPEventSourceService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source
 251 16
CloudEventTransform.java
in supports/connect-cloudevent-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge
 161 15
LitePullConsumerImpl.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer
 249 15
PatternEvaluator.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern
 117 13
Plugin.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin
 155 12
ServiceThread.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common
 98 12
MemoryBasedKeyValueStore.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store
 48 11
MybatisConnectRepository.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/repository
 63 10
ApiDestinationService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination
 105 10
TransformEngine.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/transfer
 115 9
MybatisApiDestinationRepository.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/repository
 55 9
BatchedJsonFormat.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format
 67 9
ConnectionController.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller
 228 9
TransformParam.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform
 34 9
EventRuleService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/rule
 100 9
EventTargetRunnerService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/run
 125 9
AbstractTargetRunnerConfigObserver.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service
 91 8
LocalMessageCache.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer
 134 8
MybatisEventRuleRepository.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/rule/mybatis/repository
 48 8
HttpEventConverter.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter
 218 8
StringData.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform
 31 8
JsonPathExtract.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform
 70 8
TransformBuilder.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform
 53 8
EventBridgeException.java
in common/src/main/java/org/apache/rocketmq/eventbridge/exception
 38 8
EventSourceService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source
 93 8
EventBridgeFilterTransform.java
in supports/connect-filter-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge
 55 7
TriggerTaskContext.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger
 147 7
TargetRunnerConfig.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity
 89 7
RocketMQEventDataRepository.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl
 81 7
MybatisEventSourceRepository.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/source/mybatis/repository
 54 7
EventRuleController.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller
 135 7
RocketMQConverter.java
in adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect
 63 7
RocketMQConnectSourceRunnerAPIImpl.java
in adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect
 63 7
StringSubstitutorTemplate.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform
 105 7
EventSourceClassService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/classes
 99 7
EventRuleTransfer.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot
 100 6
PluginUtils.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin
 203 6
PluginClassLoader.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin
 50 6
FileBaseKeyValueStore.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store
 90 6
RocketMQEventDataAPIImpl.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api
 109 6
MybatisEventBusRepository.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/bus/mybatis/repository
 33 6
MybatisEventTypeRepository.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/type/mybatis/repository
 40 6
BatchedCloudEventDeserializer.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format
 162 6
EventTargetDTOConverter.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter
 62 6
Files With Long Lines (Top 50)

There are 60 files with lines longer than 120 characters. In total, there are 208 long lines.

File# lines# units# long lines
ConnectionService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection
 349 17 48
EventBridgeErrorCode.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common/exception
 111 3 16
HTTPEventSourceService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source
 251 16 15
TriggerTaskContext.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger
 147 7 11
EventApiDestinationMapper.xml
in adapter/persistence/src/main/resources/mybatis
 264 - 9
ApiDestinationService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination
 105 10 8
LitePullConsumerImpl.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer
 249 15 7
HttpEventConverter.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter
 218 8 7
EventRuleTransfer.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot
 100 6 6
MybatisApiDestinationRepository.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/repository
 55 9 5
LocalMessageCache.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer
 134 8 4
RocketMQEventSubscriber.java
in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer
 291 20 4
ConnectionController.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller
 228 9 4
RuntimeTargetRunnerAPIImpl.java
in adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/runtime
 64 3 4
logback-spring.xml
in start/src/main/resources
 46 - 3
CirculatorContext.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common
 208 16 3
TransformValidator.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform
 30 1 3
SwaggerConfig.java
in start/src/main/java/org/apache/rocketmq/eventbridge/config
 32 3 2
LogFilter.java
in start/src/main/java/org/apache/rocketmq/eventbridge/filter
 56 1 2
EventApiDestinationMapper.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/mapper
 23 - 2
MybatisConnectRepository.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/repository
 63 10 2
ConnectConverter.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/converter
 44 3 2
CreateApiDestinationRequest.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination
 32 - 2
UpdateApiDestinationRequest.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination
 32 - 2
EventBusDomainService.java
in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/service
 32 2 2
H2ServerConfig.java
in start/src/main/java/org/apache/rocketmq/eventbridge/config
 20 2 1
ValidateFilter.java
in start/src/main/java/org/apache/rocketmq/eventbridge/filter
 46 2 1
88 - 1
90 - 1
Apache.xml
in style/copyright
 7 - 1
EventTargetTrigger.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot
 73 5 1
TransformEngine.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/transfer
 115 9 1
TargetRunnerConfig.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity
 89 7 1
SubscribeRunnerKeys.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity
 29 3 1
ServiceThread.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common
 98 12 1
MemoryBasedKeyValueStore.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store
 48 11 1
ErrorHandler.java
in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/error
 65 3 1
EventSourceMapper.xml
in adapter/persistence/src/main/resources/mybatis
 83 - 1
EventTargetMapper.xml
in adapter/persistence/src/main/resources/mybatis
 74 - 1
V5__register_target_acs_dingtalk.sql
in adapter/persistence/src/main/resources/db/migration
 23 - 1
V6__register_target_acs_eventbridge.sql
in adapter/persistence/src/main/resources/db/migration
 42 - 1
V8__update_unique_key.sql
in adapter/persistence/src/main/resources/db/migration
 4 - 1
V9__init_file_target_class.sql
in adapter/persistence/src/main/resources/db/migration
 15 - 1
MybatisEventSourceRepository.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/source/mybatis/repository
 54 7 1
DatasourceConfig.java
in adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence
 73 3 1
UpdateConnectionRequest.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection
 28 - 1
CreateConnectionRequest.java
in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection
 28 - 1
NetworkServiceAPIImpl.java
in adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/network
 14 2 1
SecretManagerAPIImpl.java
in adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl
 29 6 1
StringSubstitutorTemplate.java
in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform
 105 7 1
Correlations

File Size vs. Commits (all time): 405 points

adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java x: 6 commits (all time) y: 100 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java x: 4 commits (all time) y: 249 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java x: 4 commits (all time) y: 134 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java x: 7 commits (all time) y: 291 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/ClientConfig.java x: 2 commits (all time) y: 89 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/AppConfigAPIImpl.java x: 4 commits (all time) y: 25 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java x: 5 commits (all time) y: 81 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/config/GlobalConfig.java x: 4 commits (all time) y: 9 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java x: 4 commits (all time) y: 20 lines of code adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql x: 6 commits (all time) y: 23 lines of code adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql x: 6 commits (all time) y: 42 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventBusController.java x: 4 commits (all time) y: 80 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/bus/ListEventBusesRequest.java x: 3 commits (all time) y: 11 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/FlywayConfig.java x: 1 commits (all time) y: 24 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java x: 5 commits (all time) y: 73 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java x: 3 commits (all time) y: 63 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/Main.java x: 4 commits (all time) y: 14 lines of code adapter/persistence/src/main/resources/db/migration/V9__init_file_target_class.sql x: 1 commits (all time) y: 15 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfiguration.java x: 2 commits (all time) y: 24 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnFileObserver.java x: 2 commits (all time) y: 85 lines of code supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileConstant.java x: 1 commits (all time) y: 4 lines of code supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java x: 1 commits (all time) y: 53 lines of code supports/eventbridge-connect-standard/src/main/java/org/apache/rocketmq/connect/sink/StandardSinkTask.java x: 1 commits (all time) y: 27 lines of code adapter/persistence/src/main/resources/db/migration/V1__baseline.sql x: 5 commits (all time) y: 135 lines of code adapter/persistence/src/main/resources/db/migration/V2__baseline.sql x: 6 commits (all time) y: 30 lines of code adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql x: 5 commits (all time) y: 2 lines of code adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql x: 5 commits (all time) y: 1 lines of code adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql x: 4 commits (all time) y: 4 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/filter/ValidateFilter.java x: 2 commits (all time) y: 46 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/DatasourceConfig.java x: 1 commits (all time) y: 73 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/PersistenceConfig.java x: 2 commits (all time) y: 28 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/exception/ServiceProviderNotFoundException.java x: 1 commits (all time) y: 9 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ServiceLifecycle.java x: 1 commits (all time) y: 5 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ValidationServiceFactory.java x: 1 commits (all time) y: 16 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ValidationServiceLoader.java x: 1 commits (all time) y: 50 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/typed/TypedSPI.java x: 1 commits (all time) y: 11 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/typed/TypedSPIRegistry.java x: 1 commits (all time) y: 36 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/config/H2ServerConfig.java x: 1 commits (all time) y: 20 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/filter/LoginFilter.java x: 5 commits (all time) y: 32 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java x: 3 commits (all time) y: 66 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java x: 3 commits (all time) y: 208 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/utils/ShutdownUtils.java x: 2 commits (all time) y: 23 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventBusListener.java x: 2 commits (all time) y: 48 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/AbstractStartAndShutdown.java x: 1 commits (all time) y: 44 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/ServiceThread.java x: 2 commits (all time) y: 98 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/runtime/RuntimeTargetRunnerAPIImpl.java x: 3 commits (all time) y: 64 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/OffsetManager.java x: 1 commits (all time) y: 18 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/TargetRunnerListener.java x: 1 commits (all time) y: 7 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/transfer/TransformEngine.java x: 1 commits (all time) y: 115 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger/TriggerTaskContext.java x: 1 commits (all time) y: 147 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/FileAndPropertyUtil.java x: 1 commits (all time) y: 102 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/SubscribeRunnerKeys.java x: 1 commits (all time) y: 29 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/TargetKeyValue.java x: 1 commits (all time) y: 117 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/TargetRunnerConfig.java x: 1 commits (all time) y: 89 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/enums/RefreshTypeEnum.java x: 1 commits (all time) y: 6 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/Plugin.java x: 1 commits (all time) y: 155 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginUtils.java x: 1 commits (all time) y: 203 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginWrapper.java x: 1 commits (all time) y: 49 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/FileBaseKeyValueStore.java x: 1 commits (all time) y: 90 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/MemoryBasedKeyValueStore.java x: 1 commits (all time) y: 48 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfigProps.java x: 1 commits (all time) y: 23 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/converter/JsonConverter.java x: 1 commits (all time) y: 46 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/converter/RecordOffsetConverter.java x: 1 commits (all time) y: 32 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/error/ErrorHandler.java x: 1 commits (all time) y: 65 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/AbstractTargetRunnerConfigObserver.java x: 1 commits (all time) y: 91 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigObserver.java x: 1 commits (all time) y: 10 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnControllerObserver.java x: 1 commits (all time) y: 21 lines of code supports/connect-filter-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/EventBridgeFilterTransform.java x: 4 commits (all time) y: 55 lines of code adapter/persistence/src/main/resources/mybatis/EventTargetRunnerMapper.xml x: 3 commits (all time) y: 77 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/RocketMQConverter.java x: 4 commits (all time) y: 63 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/run/EventTargetRunnerService.java x: 3 commits (all time) y: 125 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/repository/EventTargetRunnerRepository.java x: 3 commits (all time) y: 16 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api/RocketMQEventDataAPIImpl.java x: 1 commits (all time) y: 109 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/DefaultSendCallback.java x: 1 commits (all time) y: 25 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQMetaService.java x: 1 commits (all time) y: 68 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/bus/EventBusService.java x: 4 commits (all time) y: 75 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/data/EventDataService.java x: 2 commits (all time) y: 20 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/EventTargetConverter.java x: 3 commits (all time) y: 76 lines of code supports/connect-cloudevent-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/CloudEventTransform.java x: 4 commits (all time) y: 161 lines of code supports/connect-eventbridge-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/EventBridgeTransform.java x: 4 commits (all time) y: 46 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/context/RocketMQConnectTargetRunnerContext.java x: 2 commits (all time) y: 11 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/CreateSourceConnectorRequest.java x: 4 commits (all time) y: 43 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection/CreateConnectionRequest.java x: 4 commits (all time) y: 28 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/mapper/EventApiDestinationMapper.java x: 7 commits (all time) y: 23 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/repository/MybatisApiDestinationRepository.java x: 7 commits (all time) y: 55 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/mapper/EventConnectionMapper.java x: 6 commits (all time) y: 21 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/repository/MybatisConnectRepository.java x: 6 commits (all time) y: 63 lines of code adapter/persistence/src/main/resources/mybatis/EventApiDestinationMapper.xml x: 7 commits (all time) y: 264 lines of code adapter/persistence/src/main/resources/mybatis/EventConnectionMapper.xml x: 7 commits (all time) y: 261 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/ApiDestinationService.java x: 9 commits (all time) y: 105 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java x: 14 commits (all time) y: 349 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/repository/ApiDestinationRepository.java x: 5 commits (all time) y: 14 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common/exception/EventBridgeErrorCode.java x: 10 commits (all time) y: 111 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationController.java x: 7 commits (all time) y: 178 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/ListApiDestinationsRequest.java x: 5 commits (all time) y: 30 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ConnectionController.java x: 8 commits (all time) y: 228 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection/ConnectionResponse.java x: 3 commits (all time) y: 25 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/converter/ConnectConverter.java x: 6 commits (all time) y: 44 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/dataobject/ConnectionDO.java x: 4 commits (all time) y: 24 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionDTO.java x: 4 commits (all time) y: 21 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/rule/EventRuleService.java x: 3 commits (all time) y: 100 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/EventSourceService.java x: 4 commits (all time) y: 93 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/EventTypeService.java x: 3 commits (all time) y: 46 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/GetApiDestinationResponse.java x: 4 commits (all time) y: 38 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/ListApiDestinationsResponse.java x: 3 commits (all time) y: 34 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection/CreateConnectionResponse.java x: 2 commits (all time) y: 25 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection/ListConnectionRequest.java x: 3 commits (all time) y: 28 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common/EventBridgeConstants.java x: 4 commits (all time) y: 27 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/parameter/HttpApiParameters.java x: 3 commits (all time) y: 17 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/parameter/NetworkParameters.java x: 5 commits (all time) y: 18 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/rpc/NetworkServiceAPI.java x: 3 commits (all time) y: 5 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/handler/WebLogAspect.java x: 3 commits (all time) y: 38 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/config/EventBridgeConstants.java x: 2 commits (all time) y: 6 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/filter/LogFilter.java x: 1 commits (all time) y: 56 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/handler/ExceptionHandler.java x: 5 commits (all time) y: 54 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/CloudEventBatchedConverter.java x: 3 commits (all time) y: 21 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/CloudEventBinaryConverter.java x: 3 commits (all time) y: 44 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/HttpEventConverter.java x: 4 commits (all time) y: 218 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format/BatchedCloudEventDeserializer.java x: 3 commits (all time) y: 162 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format/BatchedCloudEventSerializer.java x: 3 commits (all time) y: 96 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/bus/DeleteEventBusRequest.java x: 2 commits (all time) y: 9 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/bus/GetEventBusResponse.java x: 2 commits (all time) y: 17 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/bus/ListEventBusesResponse.java x: 3 commits (all time) y: 18 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/data/PutEventsRequest.java x: 2 commits (all time) y: 15 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/rule/EventRuleDTO.java x: 3 commits (all time) y: 23 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/rule/ListRulesRequest.java x: 2 commits (all time) y: 13 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/source/GetEventSourceResponse.java x: 3 commits (all time) y: 20 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/handler/EventDataHandler.java x: 3 commits (all time) y: 35 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/bus/mybatis/mapper/EventBusMapper.java x: 3 commits (all time) y: 13 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/classes/mybatis/converter/EventSourceClassConverter.java x: 3 commits (all time) y: 31 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/classes/mybatis/converter/EventTargetClassConverter.java x: 3 commits (all time) y: 40 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/classes/mybatis/mapper/EventSourceClassMapper.java x: 3 commits (all time) y: 6 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/classes/mybatis/repository/MybatisEventSourceClassRepository.java x: 2 commits (all time) y: 19 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/rule/mybatis/repository/MybatisEventRuleRepository.java x: 4 commits (all time) y: 48 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/source/mybatis/repository/MybatisEventSourceRepository.java x: 4 commits (all time) y: 54 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/source/mybatis/repository/MybatisEventSourceRunnerRepository.java x: 2 commits (all time) y: 39 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/Component.java x: 3 commits (all time) y: 10 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/PaginationResult.java x: 2 commits (all time) y: 8 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/bus/EventBus.java x: 3 commits (all time) y: 15 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/HTTPEventSourceService.java x: 4 commits (all time) y: 251 lines of code style/rmq_checkstyle.xml x: 3 commits (all time) y: 90 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventDataController.java x: 4 commits (all time) y: 84 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventRuleController.java x: 4 commits (all time) y: 135 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventSourceController.java x: 4 commits (all time) y: 114 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventTargetController.java x: 3 commits (all time) y: 82 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventTypeController.java x: 3 commits (all time) y: 49 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format/BatchedJsonFormat.java x: 2 commits (all time) y: 67 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/source/UpdateEventSourceResponse.java x: 2 commits (all time) y: 4 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/converter/ApiDestinationConverter.java x: 5 commits (all time) y: 31 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/dataobject/ApiDestinationDO.java x: 2 commits (all time) y: 21 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/RocketMQConnectClient.java x: 2 commits (all time) y: 87 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/event/EventBridgeEvent.java x: 2 commits (all time) y: 43 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/EventTool.java x: 2 commits (all time) y: 40 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/JsonUtil.java x: 2 commits (all time) y: 32 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/ComplexConditionBuilders.java x: 2 commits (all time) y: 38 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/NumericOperators.java x: 2 commits (all time) y: 58 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternCondition.java x: 2 commits (all time) y: 191 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternConditionBuilder.java x: 2 commits (all time) y: 150 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternEntry.java x: 2 commits (all time) y: 45 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternEvaluator.java x: 2 commits (all time) y: 117 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/InsertFieldTransform.java x: 3 commits (all time) y: 43 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathExtract.java x: 3 commits (all time) y: 70 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathTransform.java x: 3 commits (all time) y: 27 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathUtil.java x: 3 commits (all time) y: 108 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonUtil.java x: 2 commits (all time) y: 69 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/StringSubstitutorTemplate.java x: 3 commits (all time) y: 105 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/TransformBuilder.java x: 2 commits (all time) y: 53 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/TransformValidator.java x: 2 commits (all time) y: 30 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common/enums/CacheEnum.java x: 2 commits (all time) y: 16 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/AbstractResourceService.java x: 2 commits (all time) y: 34 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/classes/EventSourceClassService.java x: 2 commits (all time) y: 99 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/ConnectEventSourceService.java x: 3 commits (all time) y: 73 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/repository/EventBusRepository.java x: 2 commits (all time) y: 10 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/service/EventRuleDomainService.java x: 2 commits (all time) y: 56 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/config/SwaggerConfig.java x: 3 commits (all time) y: 32 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/parameter/OAuthParameters.java x: 2 commits (all time) y: 27 lines of code adapter/persistence/src/main/resources/mybatis/EventBusMapper.xml x: 2 commits (all time) y: 63 lines of code adapter/persistence/src/main/resources/mybatis/EventRuleMapper.xml x: 3 commits (all time) y: 80 lines of code adapter/persistence/src/main/resources/mybatis/EventSourceMapper.xml x: 3 commits (all time) y: 83 lines of code adapter/persistence/src/main/resources/mybatis/EventTargetMapper.xml x: 2 commits (all time) y: 74 lines of code adapter/persistence/src/main/resources/mybatis/EventTypeMapper.xml x: 2 commits (all time) y: 68 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/ActionStatusResponseEnum.java x: 1 commits (all time) y: 54 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/exception/code/EventErrorCode.java x: 1 commits (all time) y: 43 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/exception/code/FiltterPatternErrorCode.java x: 1 commits (all time) y: 28 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/StringData.java x: 1 commits (all time) y: 31 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/TransformParam.java x: 1 commits (all time) y: 34 lines of code
349.0
lines of code
  min: 1.0
  average: 38.76
  25th percentile: 11.0
  median: 21.0
  75th percentile: 46.0
  max: 349.0
0 14.0
commits (all time)
min: 1.0 | average: 2.46 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 3.0 | max: 14.0

File Size vs. Contributors (all time): 405 points

adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java x: 5 contributors (all time) y: 100 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java x: 1 contributors (all time) y: 249 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java x: 1 contributors (all time) y: 134 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java x: 4 contributors (all time) y: 291 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/ClientConfig.java x: 1 contributors (all time) y: 89 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/AppConfigAPIImpl.java x: 2 contributors (all time) y: 25 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java x: 4 contributors (all time) y: 81 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/config/GlobalConfig.java x: 2 contributors (all time) y: 9 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java x: 3 contributors (all time) y: 20 lines of code adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql x: 2 contributors (all time) y: 23 lines of code adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql x: 2 contributors (all time) y: 42 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventBusController.java x: 1 contributors (all time) y: 80 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/bus/ListEventBusesRequest.java x: 1 contributors (all time) y: 11 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/FlywayConfig.java x: 1 contributors (all time) y: 24 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java x: 4 contributors (all time) y: 73 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java x: 2 contributors (all time) y: 63 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/storage/EventDataRepository.java x: 3 contributors (all time) y: 11 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/Main.java x: 3 contributors (all time) y: 14 lines of code adapter/persistence/src/main/resources/db/migration/V9__init_file_target_class.sql x: 1 contributors (all time) y: 15 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfiguration.java x: 2 contributors (all time) y: 24 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnFileObserver.java x: 2 contributors (all time) y: 85 lines of code supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileConstant.java x: 1 contributors (all time) y: 4 lines of code supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java x: 1 contributors (all time) y: 53 lines of code supports/eventbridge-connect-standard/src/main/java/org/apache/rocketmq/connect/sink/StandardSinkTask.java x: 1 contributors (all time) y: 27 lines of code adapter/persistence/src/main/resources/db/migration/V1__baseline.sql x: 2 contributors (all time) y: 135 lines of code adapter/persistence/src/main/resources/db/migration/V2__baseline.sql x: 3 contributors (all time) y: 30 lines of code adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql x: 3 contributors (all time) y: 2 lines of code adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql x: 2 contributors (all time) y: 1 lines of code adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql x: 2 contributors (all time) y: 4 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/filter/ValidateFilter.java x: 1 contributors (all time) y: 46 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/DatasourceConfig.java x: 1 contributors (all time) y: 73 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/PersistenceConfig.java x: 2 contributors (all time) y: 28 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/exception/ServiceProviderNotFoundException.java x: 1 contributors (all time) y: 9 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ServiceLifecycle.java x: 1 contributors (all time) y: 5 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ValidationServiceFactory.java x: 1 contributors (all time) y: 16 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ValidationServiceLoader.java x: 1 contributors (all time) y: 50 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/typed/TypedSPIRegistry.java x: 1 contributors (all time) y: 36 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/config/H2ServerConfig.java x: 1 contributors (all time) y: 20 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/filter/LoginFilter.java x: 2 contributors (all time) y: 32 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java x: 3 contributors (all time) y: 66 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java x: 3 contributors (all time) y: 208 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventBusListener.java x: 2 contributors (all time) y: 48 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/AbstractStartAndShutdown.java x: 1 contributors (all time) y: 44 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/ServiceThread.java x: 2 contributors (all time) y: 98 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/runtime/RuntimeTargetRunnerAPIImpl.java x: 2 contributors (all time) y: 64 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/OffsetManager.java x: 1 contributors (all time) y: 18 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/TargetRunnerListener.java x: 1 contributors (all time) y: 7 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/transfer/TransformEngine.java x: 1 contributors (all time) y: 115 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger/TriggerTaskContext.java x: 1 contributors (all time) y: 147 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/FileAndPropertyUtil.java x: 1 contributors (all time) y: 102 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/SubscribeRunnerKeys.java x: 1 contributors (all time) y: 29 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/TargetKeyValue.java x: 1 contributors (all time) y: 117 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/enums/RefreshTypeEnum.java x: 1 contributors (all time) y: 6 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/Plugin.java x: 1 contributors (all time) y: 155 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginUtils.java x: 1 contributors (all time) y: 203 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginWrapper.java x: 1 contributors (all time) y: 49 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/FileBaseKeyValueStore.java x: 1 contributors (all time) y: 90 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/MemoryBasedKeyValueStore.java x: 1 contributors (all time) y: 48 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfigProps.java x: 1 contributors (all time) y: 23 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/converter/RecordOffsetConverter.java x: 1 contributors (all time) y: 32 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/error/ErrorHandler.java x: 1 contributors (all time) y: 65 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/AbstractTargetRunnerConfigObserver.java x: 1 contributors (all time) y: 91 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigObserver.java x: 1 contributors (all time) y: 10 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnControllerObserver.java x: 1 contributors (all time) y: 21 lines of code supports/connect-filter-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/EventBridgeFilterTransform.java x: 3 contributors (all time) y: 55 lines of code adapter/persistence/src/main/resources/mybatis/EventTargetRunnerMapper.xml x: 1 contributors (all time) y: 77 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/run/EventTargetRunnerService.java x: 1 contributors (all time) y: 125 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api/RocketMQEventDataAPIImpl.java x: 1 contributors (all time) y: 109 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/DefaultSendCallback.java x: 1 contributors (all time) y: 25 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQMetaService.java x: 1 contributors (all time) y: 68 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/bus/EventBusService.java x: 3 contributors (all time) y: 75 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/data/EventDataService.java x: 2 contributors (all time) y: 20 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/EventTargetConverter.java x: 1 contributors (all time) y: 76 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/EventTargetDTOConverter.java x: 1 contributors (all time) y: 62 lines of code supports/connect-cloudevent-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/CloudEventTransform.java x: 3 contributors (all time) y: 161 lines of code supports/connect-eventbridge-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/EventBridgeTransform.java x: 3 contributors (all time) y: 46 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/context/RocketMQConnectTargetRunnerContext.java x: 2 contributors (all time) y: 11 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/CreateSourceConnectorRequest.java x: 3 contributors (all time) y: 43 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/mapper/EventConnectionMapper.java x: 2 contributors (all time) y: 21 lines of code adapter/persistence/src/main/resources/mybatis/EventApiDestinationMapper.xml x: 2 contributors (all time) y: 264 lines of code adapter/persistence/src/main/resources/mybatis/EventConnectionMapper.xml x: 2 contributors (all time) y: 261 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/ApiDestinationService.java x: 3 contributors (all time) y: 105 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java x: 3 contributors (all time) y: 349 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/repository/ApiDestinationRepository.java x: 2 contributors (all time) y: 14 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common/exception/EventBridgeErrorCode.java x: 3 contributors (all time) y: 111 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ApiDestinationController.java x: 2 contributors (all time) y: 178 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/ListApiDestinationsRequest.java x: 2 contributors (all time) y: 30 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ConnectionController.java x: 3 contributors (all time) y: 228 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/converter/ConnectConverter.java x: 2 contributors (all time) y: 44 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/rule/EventRuleService.java x: 2 contributors (all time) y: 100 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/EventSourceService.java x: 3 contributors (all time) y: 93 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/EventTypeService.java x: 2 contributors (all time) y: 46 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/GetApiDestinationResponse.java x: 2 contributors (all time) y: 38 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/apidestination/ListApiDestinationsResponse.java x: 2 contributors (all time) y: 34 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common/EventBridgeConstants.java x: 2 contributors (all time) y: 27 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/parameter/HttpApiParameters.java x: 2 contributors (all time) y: 17 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/parameter/NetworkParameters.java x: 3 contributors (all time) y: 18 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/rpc/NetworkServiceAPI.java x: 2 contributors (all time) y: 5 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/config/EventBridgeConstants.java x: 2 contributors (all time) y: 6 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/filter/LogFilter.java x: 1 contributors (all time) y: 56 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/handler/ExceptionHandler.java x: 2 contributors (all time) y: 54 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/HttpEventConverter.java x: 3 contributors (all time) y: 218 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format/BatchedCloudEventDeserializer.java x: 1 contributors (all time) y: 162 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format/BatchedCloudEventSerializer.java x: 1 contributors (all time) y: 96 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/bus/GetEventBusResponse.java x: 1 contributors (all time) y: 17 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/rule/GetRuleResponse.java x: 1 contributors (all time) y: 28 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/rule/ListRulesRequest.java x: 1 contributors (all time) y: 13 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/handler/EventDataHandler.java x: 1 contributors (all time) y: 35 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/bus/mybatis/repository/MybatisEventBusRepository.java x: 1 contributors (all time) y: 33 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/classes/mybatis/converter/EventSourceClassConverter.java x: 1 contributors (all time) y: 31 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/classes/mybatis/converter/EventTargetClassConverter.java x: 1 contributors (all time) y: 40 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/source/mybatis/repository/MybatisEventSourceRunnerRepository.java x: 1 contributors (all time) y: 39 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/HTTPEventSourceService.java x: 2 contributors (all time) y: 251 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventSourceController.java x: 2 contributors (all time) y: 114 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventTargetController.java x: 1 contributors (all time) y: 82 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format/BatchedJsonFormat.java x: 1 contributors (all time) y: 67 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/connection/ListEnumsResponse.java x: 3 contributors (all time) y: 21 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/converter/ApiDestinationConverter.java x: 3 contributors (all time) y: 31 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/RocketMQConnectClient.java x: 1 contributors (all time) y: 87 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/config/LocalConfig.java x: 2 contributors (all time) y: 10 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/event/EventBridgeEvent.java x: 1 contributors (all time) y: 43 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/NetUtil.java x: 2 contributors (all time) y: 35 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/ComplexConditionBuilders.java x: 1 contributors (all time) y: 38 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/NumericOperators.java x: 1 contributors (all time) y: 58 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternCondition.java x: 1 contributors (all time) y: 191 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternConditionBuilder.java x: 1 contributors (all time) y: 150 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathExtract.java x: 1 contributors (all time) y: 70 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathUtil.java x: 1 contributors (all time) y: 108 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/StringSubstitutorTemplate.java x: 1 contributors (all time) y: 105 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/common/enums/CacheEnum.java x: 2 contributors (all time) y: 16 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/classes/EventSourceClassService.java x: 1 contributors (all time) y: 99 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/ConnectEventSourceService.java x: 2 contributors (all time) y: 73 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/EventSourceServiceFactory.java x: 2 contributors (all time) y: 41 lines of code adapter/persistence/src/main/resources/mybatis/EventRuleMapper.xml x: 2 contributors (all time) y: 80 lines of code adapter/persistence/src/main/resources/mybatis/EventSourceMapper.xml x: 2 contributors (all time) y: 83 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/ActionStatusResponseEnum.java x: 1 contributors (all time) y: 54 lines of code
349.0
lines of code
  min: 1.0
  average: 38.76
  25th percentile: 11.0
  median: 21.0
  75th percentile: 46.0
  max: 349.0
0 5.0
contributors (all time)
min: 1.0 | average: 1.39 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 5.0

File Size vs. Commits (30 days): 3 points

adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java x: 1 commits (30d) y: 100 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java x: 1 commits (30d) y: 249 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java x: 1 commits (30d) y: 134 lines of code
249.0
lines of code
  min: 100.0
  average: 161.0
  25th percentile: 100.0
  median: 134.0
  75th percentile: 249.0
  max: 249.0
0 1.0
commits (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

File Size vs. Contributors (30 days): 3 points

adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java x: 1 contributors (30d) y: 100 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java x: 1 contributors (30d) y: 249 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java x: 1 contributors (30d) y: 134 lines of code
249.0
lines of code
  min: 100.0
  average: 161.0
  25th percentile: 100.0
  median: 134.0
  75th percentile: 249.0
  max: 249.0
0 1.0
contributors (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

File Size vs. Commits (90 days): 97 points

adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java x: 6 commits (90d) y: 100 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java x: 3 commits (90d) y: 249 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java x: 3 commits (90d) y: 134 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java x: 6 commits (90d) y: 291 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/ClientConfig.java x: 1 commits (90d) y: 89 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/AppConfigAPIImpl.java x: 1 commits (90d) y: 25 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java x: 4 commits (90d) y: 81 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/config/GlobalConfig.java x: 1 commits (90d) y: 9 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java x: 4 commits (90d) y: 20 lines of code adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql x: 4 commits (90d) y: 23 lines of code adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql x: 4 commits (90d) y: 42 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventBusController.java x: 1 commits (90d) y: 80 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/bus/ListEventBusesRequest.java x: 1 commits (90d) y: 11 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/FlywayConfig.java x: 1 commits (90d) y: 24 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java x: 5 commits (90d) y: 73 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java x: 3 commits (90d) y: 63 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/storage/EventDataRepository.java x: 2 commits (90d) y: 11 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/Main.java x: 1 commits (90d) y: 14 lines of code adapter/persistence/src/main/resources/db/migration/V9__init_file_target_class.sql x: 1 commits (90d) y: 15 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfiguration.java x: 2 commits (90d) y: 24 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnFileObserver.java x: 2 commits (90d) y: 85 lines of code supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileConstant.java x: 1 commits (90d) y: 4 lines of code supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java x: 1 commits (90d) y: 53 lines of code supports/eventbridge-connect-standard/src/main/java/org/apache/rocketmq/connect/sink/StandardSinkTask.java x: 1 commits (90d) y: 27 lines of code adapter/persistence/src/main/resources/db/migration/V1__baseline.sql x: 3 commits (90d) y: 135 lines of code adapter/persistence/src/main/resources/db/migration/V2__baseline.sql x: 3 commits (90d) y: 30 lines of code adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql x: 3 commits (90d) y: 2 lines of code adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql x: 3 commits (90d) y: 1 lines of code adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql x: 3 commits (90d) y: 4 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/filter/ValidateFilter.java x: 2 commits (90d) y: 46 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/DatasourceConfig.java x: 1 commits (90d) y: 73 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/PersistenceConfig.java x: 1 commits (90d) y: 28 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ServiceLifecycle.java x: 1 commits (90d) y: 5 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ValidationServiceLoader.java x: 1 commits (90d) y: 50 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/typed/TypedSPIRegistry.java x: 1 commits (90d) y: 36 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/config/H2ServerConfig.java x: 1 commits (90d) y: 20 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/filter/LoginFilter.java x: 1 commits (90d) y: 32 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java x: 3 commits (90d) y: 66 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java x: 3 commits (90d) y: 208 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventBusListener.java x: 2 commits (90d) y: 48 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/AbstractStartAndShutdown.java x: 1 commits (90d) y: 44 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/StartAndShutdown.java x: 1 commits (90d) y: 3 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/listener/EventSubscriber.java x: 2 commits (90d) y: 28 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/ServiceThread.java x: 2 commits (90d) y: 98 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/runtime/RuntimeTargetRunnerAPIImpl.java x: 2 commits (90d) y: 64 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/OffsetManager.java x: 1 commits (90d) y: 18 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/TargetRunnerListener.java x: 1 commits (90d) y: 7 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/transfer/TransformEngine.java x: 1 commits (90d) y: 115 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger/TriggerTaskContext.java x: 1 commits (90d) y: 147 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/FileAndPropertyUtil.java x: 1 commits (90d) y: 102 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/SubscribeRunnerKeys.java x: 1 commits (90d) y: 29 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/TargetKeyValue.java x: 1 commits (90d) y: 117 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/enums/RefreshTypeEnum.java x: 1 commits (90d) y: 6 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/Plugin.java x: 1 commits (90d) y: 155 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginUtils.java x: 1 commits (90d) y: 203 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginWrapper.java x: 1 commits (90d) y: 49 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/FileBaseKeyValueStore.java x: 1 commits (90d) y: 90 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/MemoryBasedKeyValueStore.java x: 1 commits (90d) y: 48 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfigDefine.java x: 1 commits (90d) y: 12 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/converter/JsonConverter.java x: 1 commits (90d) y: 46 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/error/ErrorHandler.java x: 1 commits (90d) y: 65 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/AbstractTargetRunnerConfigObserver.java x: 1 commits (90d) y: 91 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigObserver.java x: 1 commits (90d) y: 10 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnControllerObserver.java x: 1 commits (90d) y: 21 lines of code supports/connect-filter-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/EventBridgeFilterTransform.java x: 1 commits (90d) y: 55 lines of code
291.0
lines of code
  min: 1.0
  average: 45.91
  25th percentile: 9.0
  median: 24.0
  75th percentile: 64.5
  max: 291.0
0 6.0
commits (90d)
min: 1.0 | average: 1.57 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 6.0

File Size vs. Contributors (90 days): 97 points

adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java x: 5 contributors (90d) y: 100 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java x: 1 contributors (90d) y: 249 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java x: 1 contributors (90d) y: 134 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java x: 4 contributors (90d) y: 291 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/ClientConfig.java x: 1 contributors (90d) y: 89 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/AppConfigAPIImpl.java x: 1 contributors (90d) y: 25 lines of code adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java x: 3 contributors (90d) y: 81 lines of code common/src/main/java/org/apache/rocketmq/eventbridge/config/GlobalConfig.java x: 1 contributors (90d) y: 9 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/DefaultAuthValidation.java x: 3 contributors (90d) y: 20 lines of code adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql x: 2 contributors (90d) y: 23 lines of code adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql x: 2 contributors (90d) y: 42 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/EventBusController.java x: 1 contributors (90d) y: 80 lines of code adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/dto/bus/ListEventBusesRequest.java x: 1 contributors (90d) y: 11 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/FlywayConfig.java x: 1 contributors (90d) y: 24 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java x: 4 contributors (90d) y: 73 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java x: 2 contributors (90d) y: 63 lines of code domain/src/main/java/org/apache/rocketmq/eventbridge/domain/storage/EventDataRepository.java x: 2 contributors (90d) y: 11 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/Main.java x: 1 contributors (90d) y: 14 lines of code adapter/persistence/src/main/resources/db/migration/V9__init_file_target_class.sql x: 1 contributors (90d) y: 15 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnFileObserver.java x: 2 contributors (90d) y: 85 lines of code supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileConstant.java x: 1 contributors (90d) y: 4 lines of code supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java x: 1 contributors (90d) y: 53 lines of code supports/eventbridge-connect-standard/src/main/java/org/apache/rocketmq/connect/sink/StandardSinkTask.java x: 1 contributors (90d) y: 27 lines of code adapter/persistence/src/main/resources/db/migration/V1__baseline.sql x: 1 contributors (90d) y: 135 lines of code adapter/persistence/src/main/resources/db/migration/V2__baseline.sql x: 1 contributors (90d) y: 30 lines of code adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql x: 1 contributors (90d) y: 2 lines of code adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql x: 1 contributors (90d) y: 1 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/filter/ValidateFilter.java x: 1 contributors (90d) y: 46 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/DatasourceConfig.java x: 1 contributors (90d) y: 73 lines of code adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/PersistenceConfig.java x: 1 contributors (90d) y: 28 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ServiceLifecycle.java x: 1 contributors (90d) y: 5 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/ValidationServiceLoader.java x: 1 contributors (90d) y: 50 lines of code infrastructure/src/main/java/org/apache/rocketmq/eventbridge/infrastructure/validate/spi/typed/TypedSPIRegistry.java x: 1 contributors (90d) y: 36 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/config/H2ServerConfig.java x: 1 contributors (90d) y: 20 lines of code start/src/main/java/org/apache/rocketmq/eventbridge/filter/LoginFilter.java x: 1 contributors (90d) y: 32 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java x: 3 contributors (90d) y: 66 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java x: 3 contributors (90d) y: 208 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventBusListener.java x: 2 contributors (90d) y: 48 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/AbstractStartAndShutdown.java x: 1 contributors (90d) y: 44 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/hook/StartAndShutdown.java x: 1 contributors (90d) y: 3 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/listener/EventSubscriber.java x: 2 contributors (90d) y: 28 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/ServiceThread.java x: 2 contributors (90d) y: 98 lines of code adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/runtime/RuntimeTargetRunnerAPIImpl.java x: 2 contributors (90d) y: 64 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/OffsetManager.java x: 1 contributors (90d) y: 18 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/TargetRunnerListener.java x: 1 contributors (90d) y: 7 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/transfer/TransformEngine.java x: 1 contributors (90d) y: 115 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger/TriggerTaskContext.java x: 1 contributors (90d) y: 147 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/FileAndPropertyUtil.java x: 1 contributors (90d) y: 102 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/SubscribeRunnerKeys.java x: 1 contributors (90d) y: 29 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/TargetKeyValue.java x: 1 contributors (90d) y: 117 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/enums/RefreshTypeEnum.java x: 1 contributors (90d) y: 6 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/Plugin.java x: 1 contributors (90d) y: 155 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginUtils.java x: 1 contributors (90d) y: 203 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginWrapper.java x: 1 contributors (90d) y: 49 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/FileBaseKeyValueStore.java x: 1 contributors (90d) y: 90 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/store/MemoryBasedKeyValueStore.java x: 1 contributors (90d) y: 48 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfigDefine.java x: 1 contributors (90d) y: 12 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/error/ErrorHandler.java x: 1 contributors (90d) y: 65 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/AbstractTargetRunnerConfigObserver.java x: 1 contributors (90d) y: 91 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigObserver.java x: 1 contributors (90d) y: 10 lines of code adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnControllerObserver.java x: 1 contributors (90d) y: 21 lines of code supports/connect-filter-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/EventBridgeFilterTransform.java x: 1 contributors (90d) y: 55 lines of code
291.0
lines of code
  min: 1.0
  average: 45.91
  25th percentile: 9.0
  median: 24.0
  75th percentile: 64.5
  max: 291.0
0 5.0
contributors (90d)
min: 1.0 | average: 1.3 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 5.0