This is a fork of the Apache Flink Kinesis connector adding Enhanced Fanout support for Flink 1.8/1.11 on KDA.
Main Code: 6,374 LOC (64 files) = JAVA (100%) | |||
Duplication: 2% | |||
File Size: 0% long (>1000 LOC), 57% short (<= 200 LOC) | |||
Unit Size: 5% long (>100 LOC), 63% short (<= 10 LOC) | |||
Conditional Complexity: 3% complex (McCabe index > 50), 73% simple (McCabe index <= 5) | |||
|
Logical Component Decomposition: primary (10 components) | ||
|
1 year, 4 months old
|
|
|
|
0% of code updated more than 50 times Also see temporal dependencies for files frequently changed in same commits. |
|
|
|
Goals: Keep the system simple and easy to change (4) |
|
|
Features of interest:
TODOs
3 files |
|
Latest commit date: 2022-01-04
5
commits
(30 days)
1
contributors
(30 days) |
|
generated by sokrates.dev (configuration) on 2022-01-31