An overview of contributor trends.
Contributed in past 6 months (a rookie = the first contribution in past year)
Past 30 days (1):
Past 31 to 90 days (5):
Past 91 to 180 days (3):
Last contributed more than 6 months ago
Commits (3m) |
Commit Days |
-
|
2
|
4
|
5
|
4
|
1
|
3
|
1
|
1
|
2
|
2
|
3
|
4
|
2
|
4
|
3
|
4
|
6
|
2
|
7
|
10
|
1
|
4
|
10
|
21
|
|
karp@apache.org | 8 | 10 |
-
|
|
|
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
44845151+elenacliu@users.noreply.github.com | 1 | 1 |
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
elena.cliu@gmail | 1 | 2 |
-
|
-
|
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
szsuzyli@gmail.com | 4 | 3 |
-
|
-
|
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
nizeze.ni@alibaba-inc.com | 4 | 12 |
-
|
-
|
|
|
|
-
|
-
|
-
|
-
|
-
|
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
|
jingxin_1@163.com | 1 | 1 |
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
elena.cliu@gmail.com | - | 1 |
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
unclerangoo@gmail.com | - | 133 |
-
|
-
|
-
|
-
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
-
|
-
|
|
|
qiao_ao@foxmail.com | - | 3 |
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
jargon9@pku.edu.cn | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
yukon@apache.org | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
yibinhaha@163.com | - | 6 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
totalo@apache.org | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
libya_003@163.com | - | 7 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
|
-
|
|
-
|
-
|
-
|
-
|
|
linfan.china@gmail.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
hyl.xidian@gmail.com | - | 2 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
reg.tong@outlook.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
liuziming.lzm@alibaba-inc.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
yuan_xiao_dong@163.com | - | 21 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
|
-
|
-
|
|
-
|
|
|
|
junjie.cheng@alibaba-inc.com | - | 7 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
|
-
|
|
|
-
|
-
|
|
-
|
vongosling@apache.org | - | 4 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
lizhiboo@yeah.net | - | 5 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
|
-
|
-
|
-
|
|
rocklau83@gmail.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
jet.j.j.cheng@gmail.com | - | 10 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
|
|
-
|
-
|
|
|
643422162@qq.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
wesleyone666@163.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
-
|
877036922@qq.com | - | 3 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
|
-
|
-
|
-
|
-
|
write2me@vip.qq.com | - | 13 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
|
-
|
-
|
|
|
jacekjanur1@gmail.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
-
|
-
|
-
|
-
|
duhengforever@apache.org | - | 25 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
|
-
|
|
|
31175234+ni-ze@users.noreply.github.com | - | 5 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
|
|
-
|
cw68ster@gmail.com | - | 12 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
-
|
|
|
|
xstorm@live.cn | - | 5 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
|
|
tigerweili@tencent.net | - | 2 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
gaoyang.cgy@alibaba-inc.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
francislee.cn@outlook.com | - | 2 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
85347842+laura-monkey@users.noreply.github.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
1158402635@qq.com | - | 2 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
arthur.lyj@alibaba-inc.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
jinrongtong16@mails.ucas.ac.cn | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
ltamber12@gmail.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
jinrongtong5@163.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
zengyu.cw@alibaba-inc.com | - | 1 |
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
-
|
|
1 contributor (3 commit):
# | Contributor |
First Commit |
Latest Commit |
Commits Count |
File Updates (per extension) |
---|---|---|---|---|---|
1. | karp@apache.org | 2023-04-24 | 2023-07-20 | 3 (100%) | java (9) |
6 contributors (19 commits):
# | Contributor |
First Commit |
Latest Commit |
Commits Count |
File Updates (per extension) |
---|---|---|---|---|---|
1. | karp@apache.org | 2023-04-24 | 2023-07-20 | 8 (42%) | java (22) |
2. | nizeze.ni@alibaba-inc.com | 2021-08-21 | 2023-06-02 | 4 (21%) | java (12) |
3. | szsuzyli@gmail.com | 2023-05-14 | 2023-06-12 | 4 (21%) | java (6) |
4. | elena.cliu@gmail | 2023-04-24 | 2023-06-25 | 1 (5%) | java (2) |
5. | jingxin_1@163.com | 2023-05-22 | 2023-05-22 | 1 (5%) | java (4) |
6. | 44845151+elenacliu@users.noreply.github.com | 2023-07-07 | 2023-07-07 | 1 (5%) | java (1) |
A contributor dependency is detected if two contributors have changed the same files in the past 90 days.
The number on lines shows the number of same files that both persons changed in past 90 days.
Contributor 1 | Contributor 2 | # shared files | |
---|---|---|---|
1. | karp@apache.org | nizeze.ni@alibaba-inc.com |
9 shared files
core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java example/src/main/java/org/apache/rocketmq/streams/examples/WordCount.java |
2. | jingxin_1@163.com | karp@apache.org |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java |
3. | szsuzyli@gmail.com | karp@apache.org |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
4. | szsuzyli@gmail.com | nizeze.ni@alibaba-inc.com |
3 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
5. | nizeze.ni@alibaba-inc.com | jingxin_1@163.com |
3 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java |
6. | karp@apache.org | elena.cliu@gmail |
2 shared files
example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowOrderCount.java example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Order.java |
7. | szsuzyli@gmail.com | 44845151+elenacliu@users.noreply.github.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
8. | karp@apache.org | 44845151+elenacliu@users.noreply.github.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
Contributor | # connections | # commits | |
---|---|---|---|
1. | karp@apache.org | 5 | 8 |
2. | nizeze.ni@alibaba-inc.com | 3 | 4 |
3. | szsuzyli@gmail.com | 3 | 4 |
4. | jingxin_1@163.com | 2 | 1 |
5. | 44845151+elenacliu@users.noreply.github.com | 2 | 1 |
6. | elena.cliu@gmail | 1 | 1 |
C-median: 2.5
A half of the contributors has more than 2.5 connections, and a half has less than this number.
C-mean: 2.6
An average number of connections a contributor has with other contributors.
C-index: 2.0
There are 2.0 contributors with 2.0 or more connections.
9 contributors (45 commits):
# | Contributor |
First Commit |
Latest Commit |
Commits Count |
---|---|---|---|---|
1. | unclerangoo@gmail.com | 2021-08-24 | 2023-04-11 | 14 (31%) |
2. | karp@apache.org | 2023-04-24 | 2023-07-20 | 11 (24%) |
3. | nizeze.ni@alibaba-inc.com | 2021-08-21 | 2023-06-02 | 6 (13%) |
4. | qiao_ao@foxmail.com | 2023-02-19 | 2023-02-24 | 5 (11%) |
5. | szsuzyli@gmail.com | 2023-05-14 | 2023-06-12 | 4 (8%) |
6. | elena.cliu@gmail | 2023-04-24 | 2023-06-25 | 2 (4%) |
7. | jingxin_1@163.com | 2023-05-22 | 2023-05-22 | 1 (2%) |
8. | 44845151+elenacliu@users.noreply.github.com | 2023-07-07 | 2023-07-07 | 1 (2%) |
9. | elena.cliu@gmail.com | 2023-05-04 | 2023-05-04 | 1 (2%) |
A contributor dependency is detected if two contributors have changed the same files in the past 180 days.
The number on lines shows the number of same files that both persons changed in past 180 days.
Contributor 1 | Contributor 2 | # shared files | |
---|---|---|---|
1. | karp@apache.org | nizeze.ni@alibaba-inc.com |
13 shared files
core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Union.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java example/src/main/java/org/apache/rocketmq/streams/examples/WordCount.java |
2. | unclerangoo@gmail.com | karp@apache.org |
9 shared files
core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowMin.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowSum.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java example/src/main/java/org/apache/rocketmq/streams/examples/WordCount.java |
3. | unclerangoo@gmail.com | nizeze.ni@alibaba-inc.com |
6 shared files
core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java example/src/main/java/org/apache/rocketmq/streams/examples/WordCount.java |
4. | unclerangoo@gmail.com | qiao_ao@foxmail.com |
6 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowMin.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowSum.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Grade.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
5. | karp@apache.org | elena.cliu@gmail |
4 shared files
example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowOrderCount.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Order.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java |
6. | szsuzyli@gmail.com | karp@apache.org |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
7. | jingxin_1@163.com | karp@apache.org |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java |
8. | karp@apache.org | qiao_ao@foxmail.com |
3 shared files
example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowMin.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowSum.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
9. | nizeze.ni@alibaba-inc.com | jingxin_1@163.com |
3 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java |
10. | szsuzyli@gmail.com | nizeze.ni@alibaba-inc.com |
3 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
11. | elena.cliu@gmail | elena.cliu@gmail.com |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java |
12. | elena.cliu@gmail | nizeze.ni@alibaba-inc.com |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java |
13. | elena.cliu@gmail.com | karp@apache.org |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java |
14. | elena.cliu@gmail.com | nizeze.ni@alibaba-inc.com |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java |
15. | unclerangoo@gmail.com | szsuzyli@gmail.com |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
16. | szsuzyli@gmail.com | 44845151+elenacliu@users.noreply.github.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
17. | karp@apache.org | 44845151+elenacliu@users.noreply.github.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
18. | unclerangoo@gmail.com | jingxin_1@163.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java |
19. | qiao_ao@foxmail.com | szsuzyli@gmail.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
20. | qiao_ao@foxmail.com | nizeze.ni@alibaba-inc.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
Contributor | # connections | # commits | |
---|---|---|---|
1. | karp@apache.org | 8 | 11 |
2. | nizeze.ni@alibaba-inc.com | 7 | 6 |
3. | unclerangoo@gmail.com | 5 | 14 |
4. | szsuzyli@gmail.com | 5 | 4 |
5. | qiao_ao@foxmail.com | 4 | 5 |
6. | elena.cliu@gmail | 3 | 2 |
7. | jingxin_1@163.com | 3 | 1 |
8. | elena.cliu@gmail.com | 3 | 1 |
9. | 44845151+elenacliu@users.noreply.github.com | 2 | 1 |
C-median: 4.0
A half of the contributors has more than 4.0 connections, and a half has less than this number.
C-mean: 4.4
An average number of connections a contributor has with other contributors.
C-index: 4.0
There are 4.0 contributors with 4.0 or more connections.
13 contributors (251 commits):
# | Contributor |
First Commit |
Latest Commit |
Commits Count |
---|---|---|---|---|
1. | unclerangoo@gmail.com | 2021-08-24 | 2023-04-11 | 204 (81%) |
2. | karp@apache.org | 2023-04-24 | 2023-07-20 | 11 (4%) |
3. | nizeze.ni@alibaba-inc.com | 2021-08-21 | 2023-06-02 | 9 (3%) |
4. | yibinhaha@163.com | 2022-08-31 | 2022-09-23 | 8 (3%) |
5. | qiao_ao@foxmail.com | 2023-02-19 | 2023-02-24 | 5 (1%) |
6. | szsuzyli@gmail.com | 2023-05-14 | 2023-06-12 | 4 (1%) |
7. | jargon9@pku.edu.cn | 2023-02-05 | 2023-02-05 | 3 (1%) |
8. | elena.cliu@gmail | 2023-04-24 | 2023-06-25 | 2 (<1%) |
9. | jingxin_1@163.com | 2023-05-22 | 2023-05-22 | 1 (<1%) |
10. | 44845151+elenacliu@users.noreply.github.com | 2023-07-07 | 2023-07-07 | 1 (<1%) |
11. | elena.cliu@gmail.com | 2023-05-04 | 2023-05-04 | 1 (<1%) |
12. | yukon@apache.org | 2022-11-07 | 2022-11-07 | 1 (<1%) |
13. | totalo@apache.org | 2022-08-24 | 2022-08-24 | 1 (<1%) |
A contributor dependency is detected if two contributors have changed the same files in the past 365 days.
The number on lines shows the number of same files that both persons changed in past 365 days.
Contributor 1 | Contributor 2 | # shared files | |
---|---|---|---|
1. | unclerangoo@gmail.com | jargon9@pku.edu.cn |
44 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/function/accumulator/AvgAccumulator.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/WindowFire.java example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Demo.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/serialization/serImpl/KVJsonSerializer.java core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinAggregateSupplier.java example/src/main/java/org/apache/rocketmq/streams/examples/window/SessionWindowCount.java core/src/main/java/org/apache/rocketmq/streams/core/common/Constant.java core/src/main/java/org/apache/rocketmq/streams/core/serialization/deImpl/KVJsonDeserializer.java core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContextImpl.java core/src/main/java/org/apache/rocketmq/streams/core/window/WindowStore.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java example/src/main/java/org/apache/rocketmq/streams/examples/window/SlideWindowCount.java core/src/main/java/org/apache/rocketmq/streams/core/running/StreamContext.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowAvg.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractWindowProcessor.java core/src/main/java/org/apache/rocketmq/streams/core/util/Utils.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocksDBStore.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/SourceSupplier.java example/src/main/java/org/apache/rocketmq/streams/examples/joinWindow/JoinWindow.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowCount.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/running/AbstractProcessor.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowWordCount.java core/src/main/java/org/apache/rocketmq/streams/core/window/WindowKey.java core/src/main/java/org/apache/rocketmq/streams/core/window/Time.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/JoinWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/AccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/TimestampSelectorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/util/OperatorNameMaker.java example/src/main/java/org/apache/rocketmq/streams/examples/sink/WordCountSink.java |
2. | unclerangoo@gmail.com | yibinhaha@163.com |
37 shared files
rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/CustomeDeserializerExample.java rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/SchemaRocketmqSourceExample1.java rocketmq-streams-examples/src/main/resources/word.txt rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/function/service/impl/ScanFunctionService.java rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/SchemaRocketmqWindowExample.java rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/SchemaConfig.java rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/source/RocketMQSource.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/StringValueKV.java rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/SchemaType.java rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/WordCountExample.java rocketmq-streams-script/src/main/java/org/apache/rocketmq/streams/script/utils/FunctionUtils.java rocketmq-streams-commons/pom.xml rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/datatype/JavaBeanDataType.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/AbstractBatchSource.java rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/SchemaWrapperFactory.java rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/SchemaRocketmqExample.java rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/AvroSchemaWrapper.java rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/source/Data.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/checkpoint/CheckPointStorageFactory.java rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/StringSchemaWrapper.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/MessageUtil.java rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/JsonSchemaWrapper.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/MessageOffset.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/impl/memory/MemorySource.java rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/source/DataStreamSource.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/AbstractSource.java rocketmq-streams-examples/src/main/resources/data-2.txt rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/Message.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/UserDefinedMessage.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/context/IMessage.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/utils/ReflectUtil.java rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/SchemaWrapper.java rocketmq-streams-clients/src/main/java/org/apache/rocketmq/streams/client/transform/WindowStream.java rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/DataDeserializer.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/cache/compress/impl/IntValueKV.java rocketmq-streams-channel-rocketmq/pom.xml rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/CustomSchemaWrapper.java |
3. | unclerangoo@gmail.com | nizeze.ni@alibaba-inc.com |
22 shared files
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/fire/SplitEventTimeManager.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/source/RocketMQSource.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java docs/images/状态存储.png docs/images/扩缩容.png core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Union.java core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java example/src/main/java/org/apache/rocketmq/streams/examples/WordCount.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java docs/design/1.RocketMQ-streams整体架构.md rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/AbstractSource.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java docs/images/RocketMQ-streams扩缩容.png docs/images/消费模型.png |
4. | unclerangoo@gmail.com | karp@apache.org |
20 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowMin.java example/src/main/java/org/apache/rocketmq/streams/examples/window/SessionWindowCount.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Union.java core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java example/src/main/java/org/apache/rocketmq/streams/examples/WordCount.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowSum.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java |
5. | karp@apache.org | nizeze.ni@alibaba-inc.com |
14 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Union.java core/src/main/java/org/apache/rocketmq/streams/core/state/AbstractStore.java example/src/main/java/org/apache/rocketmq/streams/examples/WordCount.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
6. | jargon9@pku.edu.cn | karp@apache.org |
12 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java example/src/main/java/org/apache/rocketmq/streams/examples/window/SessionWindowCount.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AggregateSessionWindowFire.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/AccumulatorSessionWindowFire.java |
7. | jargon9@pku.edu.cn | nizeze.ni@alibaba-inc.com |
8 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/metadata/StreamConfig.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
8. | unclerangoo@gmail.com | qiao_ao@foxmail.com |
6 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowMin.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowSum.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Grade.java |
9. | elena.cliu@gmail | karp@apache.org |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowOrderCount.java example/src/main/java/org/apache/rocketmq/streams/examples/pojo/Order.java |
10. | unclerangoo@gmail.com | szsuzyli@gmail.com |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
11. | szsuzyli@gmail.com | karp@apache.org |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
12. | szsuzyli@gmail.com | nizeze.ni@alibaba-inc.com |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStream.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
13. | unclerangoo@gmail.com | jingxin_1@163.com |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
14. | jargon9@pku.edu.cn | jingxin_1@163.com |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
15. | jingxin_1@163.com | karp@apache.org |
4 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/window/fire/IdleWindowScaner.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
16. | jargon9@pku.edu.cn | qiao_ao@foxmail.com |
3 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/rstream/WindowStream.java |
17. | unclerangoo@gmail.com | totalo@apache.org |
3 shared files
rocketmq-streams-clients/pom.xml pom.xml rocketmq-streams-commons/pom.xml |
18. | jargon9@pku.edu.cn | szsuzyli@gmail.com |
3 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java core/src/main/java/org/apache/rocketmq/streams/core/state/RocketMQStore.java |
19. | qiao_ao@foxmail.com | karp@apache.org |
3 shared files
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowMin.java example/src/main/java/org/apache/rocketmq/streams/examples/window/WindowSum.java |
20. | nizeze.ni@alibaba-inc.com | jingxin_1@163.com |
3 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAccumulatorSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/WindowAggregateSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/JoinWindowAggregateSupplier.java |
21. | unclerangoo@gmail.com | elena.cliu@gmail |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java |
22. | unclerangoo@gmail.com | elena.cliu@gmail.com |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java |
23. | elena.cliu@gmail | elena.cliu@gmail.com |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java |
24. | elena.cliu@gmail | nizeze.ni@alibaba-inc.com |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java |
25. | elena.cliu@gmail.com | karp@apache.org |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java |
26. | elena.cliu@gmail.com | nizeze.ni@alibaba-inc.com |
2 shared files
core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/ValueChangeSupplier.java core/src/main/java/org/apache/rocketmq/streams/core/function/supplier/MultiValueChangeSupplier.java |
27. | nizeze.ni@alibaba-inc.com | yibinhaha@163.com |
2 shared files
rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/source/RocketMQSource.java rocketmq-streams-commons/src/main/java/org/apache/rocketmq/streams/common/channel/source/AbstractSource.java |
28. | qiao_ao@foxmail.com | szsuzyli@gmail.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
29. | qiao_ao@foxmail.com | nizeze.ni@alibaba-inc.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/rstream/GroupedStreamImpl.java |
30. | unclerangoo@gmail.com | yukon@apache.org |
1 shared file
.asf.yaml |
31. | yibinhaha@163.com | totalo@apache.org |
1 shared file
rocketmq-streams-commons/pom.xml |
32. | unclerangoo@gmail.com | 44845151+elenacliu@users.noreply.github.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
33. | nizeze.ni@alibaba-inc.com | 44845151+elenacliu@users.noreply.github.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
34. | jargon9@pku.edu.cn | 44845151+elenacliu@users.noreply.github.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
35. | szsuzyli@gmail.com | 44845151+elenacliu@users.noreply.github.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
36. | karp@apache.org | 44845151+elenacliu@users.noreply.github.com |
1 shared file
core/src/main/java/org/apache/rocketmq/streams/core/running/MessageQueueListenerWrapper.java |
Contributor | # connections | # commits | |
---|---|---|---|
1. | unclerangoo@gmail.com | 12 | 204 |
2. | nizeze.ni@alibaba-inc.com | 10 | 9 |
3. | karp@apache.org | 9 | 11 |
4. | jargon9@pku.edu.cn | 7 | 3 |
5. | szsuzyli@gmail.com | 6 | 4 |
6. | qiao_ao@foxmail.com | 5 | 5 |
7. | 44845151+elenacliu@users.noreply.github.com | 5 | 1 |
8. | elena.cliu@gmail | 4 | 2 |
9. | jingxin_1@163.com | 4 | 1 |
10. | elena.cliu@gmail.com | 4 | 1 |
11. | yibinhaha@163.com | 3 | 8 |
12. | totalo@apache.org | 2 | 1 |
13. | yukon@apache.org | 1 | 1 |
C-median: 5.0
A half of the contributors has more than 5.0 connections, and a half has less than this number.
C-mean: 5.5
An average number of connections a contributor has with other contributors.
C-index: 5.0
There are 5.0 contributors with 5.0 or more connections.