apache / bahir-flink
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 173 files with 10,438 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 11 files changed 6-20 times (1,365 lines of code)
    • 162 files changed 1-5 times (9,073 lines of code)
0% | 0% | 0% | 13% | 86%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 173 files with 10,438 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 7 files changed by 6-10 contributors (938 lines of code)
    • 103 files changed by 2-5 contributors (6,516 lines of code)
    • 63 files changed by 1 contributor (2,984 lines of code)
0% | 0% | 8% | 62% | 28%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, scala, properties, md, sh, gitignore, gitattributes, txt, json, yml, yaml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 13% | 86%
scala0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
flink-connector-redis0% | 0% | 0% | 52% | 47%
flink-connector-kudu0% | 0% | 0% | 11% | 88%
flink-connector-influxdb20% | 0% | 0% | 0% | 100%
flink-library-siddhi0% | 0% | 0% | 0% | 100%
flink-connector-pinot0% | 0% | 0% | 0% | 100%
flink-connector-activemq0% | 0% | 0% | 0% | 100%
flink-connector-netty0% | 0% | 0% | 0% | 100%
flink-connector-influxdb0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
flink-connector-akka0% | 0% | 0% | 0% | 100%
flink-connector-flume0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RedisClusterContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 249 21 2016-08-19 2023-05-30 11 10 rmetzger@apache.org jwalag87@gmail.com
RedisSink.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis
 121 4 2016-08-19 2023-05-30 9 8 rmetzger@apache.org jwalag87@gmail.com
RedisContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 355 24 2016-08-19 2023-05-30 8 7 rmetzger@apache.org jwalag87@gmail.com
RedisCommandsContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 25 - 2016-08-19 2023-05-30 7 6 rmetzger@apache.org jwalag87@gmail.com
RedisCommand.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper
 28 1 2016-08-19 2023-05-30 7 6 rmetzger@apache.org jwalag87@gmail.com
KuduTableFactory.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 118 7 2020-05-19 2023-03-08 7 6 mbalassi@cloudera.com boto@boto.pro
RedisTableSinkFactory.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis
 42 2 2020-03-14 2021-12-26 6 7 hzyuemeng1@corp.netease.com flinker@126.com
RedisCommandsContainerBuilder.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 75 5 2016-08-19 2022-10-21 6 5 rmetzger@apache.org sramirez@brex.com
FlinkJedisClusterConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 109 16 2016-08-19 2022-10-21 6 5 rmetzger@apache.org sramirez@brex.com
KuduWriter.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 110 12 2019-09-03 2023-03-08 6 5 boto@boto.pro boto@boto.pro
KuduFilterInfo.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector
 133 16 2019-09-03 2023-03-08 6 5 boto@boto.pro boto@boto.pro
FlumeSink.java
in flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume
 107 8 2016-08-22 2019-07-04 5 4 rmetzger@apache.org boto@boto.pro
FlinkJedisPoolConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 110 18 2016-08-19 2022-10-21 5 4 rmetzger@apache.org sramirez@brex.com
FlinkJedisSentinelConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 126 19 2016-08-19 2022-10-21 5 4 rmetzger@apache.org sramirez@brex.com
KuduReader.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader
 127 12 2019-09-03 2023-03-08 5 3 boto@boto.pro boto@boto.pro
KuduTableSource.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 141 12 2020-05-19 2023-03-08 5 4 mbalassi@cloudera.com boto@boto.pro
KuduWriterConfig.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 147 22 2019-09-03 2023-03-08 5 3 boto@boto.pro boto@boto.pro
AMQSource.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 164 9 2016-08-23 2019-05-09 5 5 rmetzger@apache.org 5840423+krystex@users.norep...
KuduTableUtils.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils
 220 13 2020-05-19 2023-03-08 5 4 mbalassi@cloudera.com boto@boto.pro
KuduCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 241 31 2020-05-19 2023-03-08 5 4 mbalassi@cloudera.com boto@boto.pro
FlinkJedisClusterConfigHandler.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler
 42 3 2020-03-14 2021-03-11 4 5 hzyuemeng1@corp.netease.com ahern88@163.com
Redis.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor
 48 7 2020-03-14 2021-12-26 4 5 hzyuemeng1@corp.netease.com flinker@126.com
KuduReaderConfig.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader
 52 9 2019-09-03 2023-03-08 4 2 boto@boto.pro boto@boto.pro
KuduTableInfo.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector
 57 9 2019-09-03 2023-03-08 4 3 boto@boto.pro boto@boto.pro
FlinkJedisConfigBase.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 58 10 2016-08-19 2022-10-21 4 4 rmetzger@apache.org sramirez@brex.com
RowRedisMapper.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row
 69 13 2020-03-14 2020-05-27 4 5 hzyuemeng1@corp.netease.com 43072462+git-charles@users....
AbstractSiddhiOperator.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 244 20 2017-11-18 2021-12-26 4 4 hchen9@ebay.com flinker@126.com
SiddhiStreamFactory.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils
 11 1 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
KuduFailureHandler.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/failure
 13 1 2019-09-03 2023-03-08 3 2 boto@boto.pro boto@boto.pro
RedisValidator.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor
 14 - 2020-05-07 2021-03-11 3 3 ahoowang@qq.com ahern88@163.com
RedisMapper.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper
 15 2 2016-08-19 2019-10-11 3 3 rmetzger@apache.org artur_santos@usp.br
RedisMapperHandler.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder
 24 1 2020-03-14 2020-05-27 3 4 hzyuemeng1@corp.netease.com 43072462+git-charles@users....
InfluxDBSplitEnumerator.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/enumerator
 34 7 2020-12-06 2023-03-08 3 3 leonpapke@gmx.de boto@boto.pro
KuduReaderIterator.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader
 39 5 2019-09-03 2022-07-17 3 2 boto@boto.pro boto@boto.pro
FlinkJedisSentinelConfigHandler.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler
 41 3 2020-03-14 2021-03-11 3 3 hzyuemeng1@corp.netease.com evan.chanyiksan@gmail.com
RedisCommandDescription.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper
 50 5 2016-08-19 2020-03-14 3 3 rmetzger@apache.org hzyuemeng1@corp.netease.com
SiddhiStreamOperator.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 52 4 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
KuduSink.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/streaming
 59 7 2019-09-03 2023-03-08 3 2 boto@boto.pro boto@boto.pro
InfluxDBSink.java
in flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb
 60 4 2017-08-27 2018-09-18 3 3 zhouhai02@meituan.com wojciech.luczkow@comarch.com
KuduTableSink.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 61 6 2020-05-19 2021-04-07 3 3 mbalassi@cloudera.com jinfeng1995@gmail.com
DataPoint.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common
 63 8 2020-12-06 2023-03-08 3 3 leonpapke@gmx.de boto@boto.pro
AMQSinkConfig.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 65 12 2016-08-23 2018-07-20 3 3 rmetzger@apache.org bl@wp.pl
AMQSourceConfig.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 66 11 2016-08-23 2018-07-20 3 3 rmetzger@apache.org bl@wp.pl
StreamInMemOutputHandler.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 70 5 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
StreamOutputHandler.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 70 5 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
RedisTableSink.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis
 72 9 2020-03-14 2020-09-24 3 4 hzyuemeng1@corp.netease.com gyfora@apache.org
SiddhiTupleFactory.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils
 74 2 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
InfluxDBWriter.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/writer
 76 7 2020-12-06 2023-03-08 3 3 leonpapke@gmx.de boto@boto.pro
AkkaSource.java
in flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka
 83 7 2016-10-25 2019-08-26 3 3 sbcd90@gmail.com boto@boto.pro
InfluxDBSinkBuilder.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink
 97 11 2020-12-06 2023-03-08 3 3 leonpapke@gmx.de boto@boto.pro
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RedisClusterContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 249 21 2016-08-19 2023-05-30 11 10 rmetzger@apache.org jwalag87@gmail.com
RedisSink.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis
 121 4 2016-08-19 2023-05-30 9 8 rmetzger@apache.org jwalag87@gmail.com
RedisContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 355 24 2016-08-19 2023-05-30 8 7 rmetzger@apache.org jwalag87@gmail.com
RedisTableSinkFactory.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis
 42 2 2020-03-14 2021-12-26 6 7 hzyuemeng1@corp.netease.com flinker@126.com
KuduTableFactory.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 118 7 2020-05-19 2023-03-08 7 6 mbalassi@cloudera.com boto@boto.pro
RedisCommand.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper
 28 1 2016-08-19 2023-05-30 7 6 rmetzger@apache.org jwalag87@gmail.com
RedisCommandsContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 25 - 2016-08-19 2023-05-30 7 6 rmetzger@apache.org jwalag87@gmail.com
KuduFilterInfo.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector
 133 16 2019-09-03 2023-03-08 6 5 boto@boto.pro boto@boto.pro
KuduWriter.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 110 12 2019-09-03 2023-03-08 6 5 boto@boto.pro boto@boto.pro
FlinkJedisClusterConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 109 16 2016-08-19 2022-10-21 6 5 rmetzger@apache.org sramirez@brex.com
RedisCommandsContainerBuilder.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 75 5 2016-08-19 2022-10-21 6 5 rmetzger@apache.org sramirez@brex.com
AMQSource.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 164 9 2016-08-23 2019-05-09 5 5 rmetzger@apache.org 5840423+krystex@users.norep...
FlinkJedisClusterConfigHandler.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler
 42 3 2020-03-14 2021-03-11 4 5 hzyuemeng1@corp.netease.com ahern88@163.com
RowRedisMapper.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row
 69 13 2020-03-14 2020-05-27 4 5 hzyuemeng1@corp.netease.com 43072462+git-charles@users....
Redis.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor
 48 7 2020-03-14 2021-12-26 4 5 hzyuemeng1@corp.netease.com flinker@126.com
KuduTableSource.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 141 12 2020-05-19 2023-03-08 5 4 mbalassi@cloudera.com boto@boto.pro
KuduCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 241 31 2020-05-19 2023-03-08 5 4 mbalassi@cloudera.com boto@boto.pro
KuduTableUtils.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils
 220 13 2020-05-19 2023-03-08 5 4 mbalassi@cloudera.com boto@boto.pro
FlinkJedisPoolConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 110 18 2016-08-19 2022-10-21 5 4 rmetzger@apache.org sramirez@brex.com
FlinkJedisSentinelConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 126 19 2016-08-19 2022-10-21 5 4 rmetzger@apache.org sramirez@brex.com
FlumeSink.java
in flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume
 107 8 2016-08-22 2019-07-04 5 4 rmetzger@apache.org boto@boto.pro
FlinkJedisConfigBase.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 58 10 2016-08-19 2022-10-21 4 4 rmetzger@apache.org sramirez@brex.com
AbstractSiddhiOperator.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 244 20 2017-11-18 2021-12-26 4 4 hchen9@ebay.com flinker@126.com
RedisMapperHandler.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder
 24 1 2020-03-14 2020-05-27 3 4 hzyuemeng1@corp.netease.com 43072462+git-charles@users....
RedisTableSink.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis
 72 9 2020-03-14 2020-09-24 3 4 hzyuemeng1@corp.netease.com gyfora@apache.org
KuduReader.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader
 127 12 2019-09-03 2023-03-08 5 3 boto@boto.pro boto@boto.pro
KuduWriterConfig.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 147 22 2019-09-03 2023-03-08 5 3 boto@boto.pro boto@boto.pro
KuduTableInfo.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector
 57 9 2019-09-03 2023-03-08 4 3 boto@boto.pro boto@boto.pro
KuduRowDataLookupFunction.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup
 179 13 2022-07-17 2023-05-30 3 3 boto@boto.pro 40719512+collabh@users.nore...
KuduTableSink.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 61 6 2020-05-19 2021-04-07 3 3 mbalassi@cloudera.com jinfeng1995@gmail.com
FlinkJedisSentinelConfigHandler.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler
 41 3 2020-03-14 2021-03-11 3 3 hzyuemeng1@corp.netease.com evan.chanyiksan@gmail.com
RedisCommandDescription.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper
 50 5 2016-08-19 2020-03-14 3 3 rmetzger@apache.org hzyuemeng1@corp.netease.com
RedisMapper.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper
 15 2 2016-08-19 2019-10-11 3 3 rmetzger@apache.org artur_santos@usp.br
RedisValidator.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor
 14 - 2020-05-07 2021-03-11 3 3 ahoowang@qq.com ahern88@163.com
InfluxDBSink.java
in flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb
 60 4 2017-08-27 2018-09-18 3 3 zhouhai02@meituan.com wojciech.luczkow@comarch.com
InfluxDBSplitEnumerator.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/enumerator
 34 7 2020-12-06 2023-03-08 3 3 leonpapke@gmx.de boto@boto.pro
InfluxDBSinkBuilder.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink
 97 11 2020-12-06 2023-03-08 3 3 leonpapke@gmx.de boto@boto.pro
InfluxDBWriter.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/writer
 76 7 2020-12-06 2023-03-08 3 3 leonpapke@gmx.de boto@boto.pro
DataPoint.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common
 63 8 2020-12-06 2023-03-08 3 3 leonpapke@gmx.de boto@boto.pro
NettyUtil.scala
in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example
 107 4 2016-10-24 2018-07-20 3 3 shijinkui@huawei.com bl@wp.pl
AkkaSource.java
in flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka
 83 7 2016-10-25 2019-08-26 3 3 sbcd90@gmail.com boto@boto.pro
AMQSinkConfig.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 65 12 2016-08-23 2018-07-20 3 3 rmetzger@apache.org bl@wp.pl
AMQSourceConfig.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 66 11 2016-08-23 2018-07-20 3 3 rmetzger@apache.org bl@wp.pl
SiddhiStream.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi
 162 17 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
SiddhiTupleFactory.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils
 74 2 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
SiddhiStreamFactory.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils
 11 1 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
SiddhiTypeFactory.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils
 98 6 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
SiddhiStreamOperator.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 52 4 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
StreamOutputHandler.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 70 5 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
StreamInMemOutputHandler.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 70 5 2017-11-18 2021-09-14 3 3 hchen9@ebay.com jboto@idealista.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
PinotSinkCommitter.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer
 264 14 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
KuduDynamicCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog
 243 31 2022-07-17 2023-03-08 2 1 boto@boto.pro boto@boto.pro
KuduDynamicTableSourceSinkFactory.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic
 178 4 2022-07-17 2022-07-17 1 1 boto@boto.pro boto@boto.pro
KuduDynamicTableSource.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic
 145 13 2022-07-17 2023-03-23 3 1 boto@boto.pro boto@boto.pro
StreamSchema.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/schema
 129 11 2017-11-18 2017-11-18 1 1 hchen9@ebay.com hchen9@ebay.com
RowDataUpsertOperationMapper.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 116 4 2022-07-17 2022-07-17 1 1 boto@boto.pro boto@boto.pro
PinotWriter.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer
 109 9 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
InfluxDBSinkBuilder.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2
 97 11 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
InfluxDBWriter.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/writer
 92 9 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
PinotSink.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2
 84 6 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
InfluxDBSinkOptions.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2
 72 2 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
PinotSinkBuilder.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2
 70 10 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
PinotWriterSegment.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer
 68 6 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
PinotControllerClient.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot
 67 6 2021-04-07 2021-04-07 1 1 me@matspoerschke.de me@matspoerschke.de
PinotControllerHttpClient.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot
 62 6 2021-04-07 2021-04-07 1 1 me@matspoerschke.de me@matspoerschke.de
RowResultRowDataConvertor.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor
 61 1 2022-07-17 2023-03-08 2 1 boto@boto.pro boto@boto.pro
KuduOutputFormat.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format
 59 8 2022-07-17 2023-03-08 2 1 boto@boto.pro boto@boto.pro
HttpServer.scala
in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example
 59 2 2016-10-24 2016-10-24 1 1 shijinkui@huawei.com shijinkui@huawei.com
KuduDynamicTableSink.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic
 58 8 2022-07-17 2022-07-17 1 1 boto@boto.pro boto@boto.pro
ReceiverActor.java
in flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka/utils
 58 7 2016-10-25 2016-10-25 1 1 sbcd90@gmail.com sbcd90@gmail.com
PinotWriterStateSerializer.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer
 50 3 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
FlumeUtils.java
in flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume
 48 3 2019-02-01 2019-02-01 1 1 1269223860@qq.com 1269223860@qq.com
StreamSerializer.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/schema
 48 2 2017-11-18 2017-11-18 1 1 hchen9@ebay.com hchen9@ebay.com
KuduLookupOptions.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup
 46 10 2022-07-17 2022-07-17 1 1 boto@boto.pro boto@boto.pro
InfluxDBPoint.java
in flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb
 45 10 2017-08-27 2017-08-27 1 1 zhouhai02@meituan.com zhouhai02@meituan.com
KuduCatalogFactory.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog
 41 2 2022-07-17 2022-07-17 1 1 boto@boto.pro boto@boto.pro
PinotSinkCommittableSerializer.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer
 41 3 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
InfluxDBSourceOptions.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source
 30 1 2020-12-06 2020-12-06 1 1 leonpapke@gmx.de leonpapke@gmx.de
InfluxDBSink.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2
 30 3 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
KuduRowInputFormat.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format
 29 4 2022-07-17 2022-07-17 1 1 boto@boto.pro boto@boto.pro
SubscribeReceiver.java
in flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka/utils
 29 5 2016-10-25 2016-10-25 1 1 sbcd90@gmail.com sbcd90@gmail.com
UnsubscribeReceiver.java
in flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka/utils
 29 5 2016-10-25 2016-10-25 1 1 sbcd90@gmail.com sbcd90@gmail.com
AMQExceptionListener.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/internal
 29 3 2016-08-23 2016-08-23 1 1 rmetzger@apache.org rmetzger@apache.org
KuduRowDataInputFormat.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format
 25 4 2022-07-17 2022-07-17 1 1 boto@boto.pro boto@boto.pro
PinotSinkGlobalCommittable.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/committer
 25 4 2021-04-07 2021-04-07 1 1 me@matspoerschke.de me@matspoerschke.de
ServerTrait.scala
in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example
 25 2 2016-10-24 2016-10-24 1 1 shijinkui@huawei.com shijinkui@huawei.com
SimpleSegmentNameGenerator.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/segment/name
 24 3 2021-04-07 2021-04-07 1 1 me@matspoerschke.de me@matspoerschke.de
FileSystemUtils.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/filesystem
 24 2 2021-04-07 2021-04-07 1 1 me@matspoerschke.de me@matspoerschke.de
PinotSinkCommittable.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer
 24 4 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
RowResultRowConvertor.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor
 22 1 2022-07-17 2022-07-17 1 1 boto@boto.pro boto@boto.pro
PinotWriterState.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer
 22 4 2023-03-08 2023-03-08 1 1 boto@boto.pro boto@boto.pro
InfluxDBSourceEnumStateSerializer.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/enumerator
 19 2 2020-12-06 2020-12-06 1 1 leonpapke@gmx.de leonpapke@gmx.de
AMQUtil.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/internal
 19 2 2016-08-23 2016-08-23 1 1 rmetzger@apache.org rmetzger@apache.org
InfluxDBSplit.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/split
 17 3 2020-12-06 2020-12-06 1 1 leonpapke@gmx.de leonpapke@gmx.de
StreamRecordComparator.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 17 1 2017-11-18 2017-11-18 1 1 hchen9@ebay.com hchen9@ebay.com
RowOperationMapper.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 16 3 2020-05-19 2020-05-19 1 1 mbalassi@cloudera.com mbalassi@cloudera.com
TupleOperationMapper.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 16 3 2020-05-19 2020-05-19 1 1 mbalassi@cloudera.com mbalassi@cloudera.com
RunningChecker.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/internal
 11 2 2016-08-23 2016-08-23 1 1 rmetzger@apache.org rmetzger@apache.org
FileSystemAdapter.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/filesystem
 9 - 2021-04-07 2021-04-07 1 1 me@matspoerschke.de me@matspoerschke.de
PinotControllerApiException.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/exceptions
 9 1 2021-04-07 2021-04-07 1 1 me@matspoerschke.de me@matspoerschke.de
Correlations

File Size vs. Number of Changes: 173 points

flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/AbstractKuduInputFormat.java x: 114 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java x: 179 lines of code y: 3 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java x: 355 lines of code y: 8 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java x: 121 lines of code y: 9 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java x: 249 lines of code y: 11 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisCommandsContainer.java x: 25 lines of code y: 7 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/RedisCommand.java x: 28 lines of code y: 7 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java x: 145 lines of code y: 3 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common/DataPoint.java x: 63 lines of code y: 3 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common/InfluxParser.java x: 92 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/InfluxDBSink.java x: 59 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/InfluxDBSinkBuilder.java x: 97 lines of code y: 3 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/commiter/InfluxDBCommittableSerializer.java x: 22 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/commiter/InfluxDBCommitter.java x: 51 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/writer/InfluxDBPointSerializer.java x: 40 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/writer/InfluxDBSchemaSerializer.java x: 8 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/writer/InfluxDBWriter.java x: 76 lines of code y: 3 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSink.java x: 30 lines of code y: 1 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSinkBuilder.java x: 97 lines of code y: 1 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSinkOptions.java x: 72 lines of code y: 1 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/writer/InfluxDBSchemaSerializer.java x: 8 lines of code y: 1 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/writer/InfluxDBWriter.java x: 92 lines of code y: 1 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/InfluxDBSource.java x: 67 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/InfluxDBSourceBuilder.java x: 43 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/enumerator/InfluxDBSplitEnumerator.java x: 34 lines of code y: 3 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/http/Handler.java x: 20 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/http/HealthCheckHandler.java x: 12 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/http/WriteAPIHandler.java x: 91 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/reader/InfluxDBRecordEmitter.java x: 21 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/reader/InfluxDBSplitReader.java x: 128 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/reader/deserializer/InfluxDBDataPointDeserializer.java x: 15 lines of code y: 2 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/split/InfluxDBSplitSerializer.java x: 23 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/ColumnSchemasFactory.java x: 9 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduFilterInfo.java x: 133 lines of code y: 6 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduTableInfo.java x: 57 lines of code y: 4 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowDataConvertor.java x: 61 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/failure/KuduFailureHandler.java x: 13 lines of code y: 3 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReader.java x: 127 lines of code y: 5 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReaderConfig.java x: 52 lines of code y: 4 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/AbstractSingleOperationMapper.java x: 57 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduOperationMapper.java x: 10 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduWriter.java x: 110 lines of code y: 6 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduWriterConfig.java x: 147 lines of code y: 5 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/PojoOperationMapper.java x: 46 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/streaming/KuduSink.java x: 59 lines of code y: 3 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/AbstractReadOnlyCatalog.java x: 85 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduCatalog.java x: 241 lines of code y: 5 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableFactory.java x: 118 lines of code y: 7 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableSource.java x: 141 lines of code y: 5 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog/KuduDynamicCatalog.java x: 243 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils/KuduTableUtils.java x: 220 lines of code y: 5 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils/KuduTypeUtils.java x: 100 lines of code y: 2 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/PinotSink.java x: 84 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/PinotSinkBuilder.java x: 70 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer/PinotSinkCommittable.java x: 24 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer/PinotSinkCommittableSerializer.java x: 41 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer/PinotSinkCommitter.java x: 264 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer/PinotWriter.java x: 109 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer/PinotWriterSegment.java x: 68 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer/PinotWriterState.java x: 22 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer/PinotWriterStateSerializer.java x: 50 lines of code y: 1 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java x: 109 lines of code y: 6 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisConfigBase.java x: 58 lines of code y: 4 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java x: 110 lines of code y: 5 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java x: 126 lines of code y: 5 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisCommandsContainerBuilder.java x: 75 lines of code y: 6 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/InfluxDBSinkOptions.java x: 72 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReaderIterator.java x: 39 lines of code y: 3 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/RowDataUpsertOperationMapper.java x: 116 lines of code y: 1 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduRowDataInputFormat.java x: 25 lines of code y: 1 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduRowInputFormat.java x: 29 lines of code y: 1 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSink.java x: 58 lines of code y: 1 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java x: 178 lines of code y: 1 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduLookupOptions.java x: 46 lines of code y: 1 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java x: 42 lines of code y: 6 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/Redis.java x: 48 lines of code y: 4 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/AbstractSiddhiOperator.java x: 244 lines of code y: 4 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/SiddhiCEP.java x: 95 lines of code y: 2 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/SiddhiStream.java x: 162 lines of code y: 3 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/SiddhiOperatorContext.java x: 124 lines of code y: 2 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/SiddhiStreamOperator.java x: 52 lines of code y: 3 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/StreamInMemOutputHandler.java x: 70 lines of code y: 3 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/schema/SiddhiStreamSchema.java x: 42 lines of code y: 2 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils/SiddhiStreamFactory.java x: 11 lines of code y: 3 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils/SiddhiTupleFactory.java x: 74 lines of code y: 3 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils/SiddhiTypeFactory.java x: 98 lines of code y: 3 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/enumerator/InfluxDBSourceEnumState.java x: 4 lines of code y: 1 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/enumerator/InfluxDBSourceEnumStateSerializer.java x: 19 lines of code y: 1 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/split/InfluxDBSplit.java x: 17 lines of code y: 1 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableSink.java x: 61 lines of code y: 3 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/PinotControllerClient.java x: 67 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/PinotControllerHttpClient.java x: 62 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/exceptions/PinotControllerApiException.java x: 9 lines of code y: 1 # changes flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/segment/name/PinotSinkSegmentNameGenerator.java x: 5 lines of code y: 1 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisClusterConfigHandler.java x: 42 lines of code y: 4 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisSentinelConfigHandler.java x: 41 lines of code y: 3 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java x: 14 lines of code y: 3 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSink.java x: 72 lines of code y: 3 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/ZIncrByMapper.java x: 7 lines of code y: 1 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/FlinkJedisConfigHandler.java x: 6 lines of code y: 2 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandler.java x: 11 lines of code y: 2 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandlerServices.java x: 97 lines of code y: 2 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisMapperHandler.java x: 24 lines of code y: 3 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/HSetMapper.java x: 7 lines of code y: 2 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RowRedisMapper.java x: 69 lines of code y: 4 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/failure/DefaultKuduFailureHandler.java x: 14 lines of code y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/RowOperationMapper.java x: 16 lines of code y: 1 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/RedisCommandDescription.java x: 50 lines of code y: 3 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/RedisMapper.java x: 15 lines of code y: 3 # changes flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka/AkkaSource.java x: 83 lines of code y: 3 # changes flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume/FlumeSink.java x: 107 lines of code y: 5 # changes flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java x: 164 lines of code y: 5 # changes flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume/FlumeUtils.java x: 48 lines of code y: 1 # changes flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb/InfluxDBConfig.java x: 136 lines of code y: 2 # changes flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb/InfluxDBSink.java x: 60 lines of code y: 3 # changes flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSinkConfig.java x: 65 lines of code y: 3 # changes flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSourceConfig.java x: 66 lines of code y: 3 # changes flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/NettyUtil.scala x: 107 lines of code y: 3 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/exception/DuplicatedStreamException.java x: 6 lines of code y: 1 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/package-info.java x: 1 lines of code y: 1 # changes flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/schema/StreamSchema.java x: 129 lines of code y: 1 # changes flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb/InfluxDBPoint.java x: 45 lines of code y: 1 # changes flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/TcpHandler.scala x: 18 lines of code y: 2 # changes flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/TcpServer.scala x: 80 lines of code y: 2 # changes flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/HttpServer.scala x: 59 lines of code y: 1 # changes scalastyle-config.xml x: 203 lines of code y: 2 # changes flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/internal/RunningChecker.java x: 11 lines of code y: 1 # changes
11.0
# changes
  min: 1.0
  average: 2.38
  25th percentile: 1.0
  median: 2.0
  75th percentile: 3.0
  max: 11.0
0 355.0
lines of code
min: 1.0 | average: 60.34 | 25th percentile: 14.5 | median: 45.0 | 75th percentile: 84.5 | max: 355.0

Number of Contributors vs. Number of Changes: 173 points

flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/AbstractKuduInputFormat.java x: 2 # contributors y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java x: 3 # contributors y: 3 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java x: 7 # contributors y: 8 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java x: 8 # contributors y: 9 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java x: 10 # contributors y: 11 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisCommandsContainer.java x: 6 # contributors y: 7 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java x: 1 # contributors y: 3 # changes flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSink.java x: 1 # contributors y: 1 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduFilterInfo.java x: 5 # contributors y: 6 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduTableInfo.java x: 3 # contributors y: 4 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowDataConvertor.java x: 1 # contributors y: 2 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/failure/KuduFailureHandler.java x: 2 # contributors y: 3 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReader.java x: 3 # contributors y: 5 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReaderConfig.java x: 2 # contributors y: 4 # changes flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduCatalog.java x: 4 # contributors y: 5 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisConfigBase.java x: 4 # contributors y: 4 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java x: 7 # contributors y: 6 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/Redis.java x: 5 # contributors y: 4 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSink.java x: 4 # contributors y: 3 # changes flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/HIncrByMapper.java x: 2 # contributors y: 1 # changes flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java x: 5 # contributors y: 5 # changes
11.0
# changes
  min: 1.0
  average: 2.38
  25th percentile: 1.0
  median: 2.0
  75th percentile: 3.0
  max: 11.0
0 10.0
# contributors
min: 1.0 | average: 2.24 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 3.0 | max: 10.0

Number of Contributors vs. File Size: 173 points

flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/AbstractKuduInputFormat.java x: 2 # contributors y: 114 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java x: 3 # contributors y: 179 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java x: 7 # contributors y: 355 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java x: 8 # contributors y: 121 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java x: 10 # contributors y: 249 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisCommandsContainer.java x: 6 # contributors y: 25 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/RedisCommand.java x: 6 # contributors y: 28 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSource.java x: 1 # contributors y: 145 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common/DataPoint.java x: 3 # contributors y: 63 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common/InfluxParser.java x: 2 # contributors y: 92 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/InfluxDBSink.java x: 2 # contributors y: 59 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/InfluxDBSinkBuilder.java x: 3 # contributors y: 97 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/commiter/InfluxDBCommittableSerializer.java x: 2 # contributors y: 22 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/commiter/InfluxDBCommitter.java x: 2 # contributors y: 51 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/writer/InfluxDBPointSerializer.java x: 2 # contributors y: 40 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/writer/InfluxDBSchemaSerializer.java x: 2 # contributors y: 8 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/writer/InfluxDBWriter.java x: 3 # contributors y: 76 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSink.java x: 1 # contributors y: 30 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSinkBuilder.java x: 1 # contributors y: 97 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSinkOptions.java x: 1 # contributors y: 72 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/writer/InfluxDBSchemaSerializer.java x: 1 # contributors y: 8 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/writer/InfluxDBWriter.java x: 1 # contributors y: 92 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/InfluxDBSource.java x: 2 # contributors y: 67 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/InfluxDBSourceBuilder.java x: 2 # contributors y: 43 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/enumerator/InfluxDBSplitEnumerator.java x: 3 # contributors y: 34 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/http/Handler.java x: 2 # contributors y: 20 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/http/HealthCheckHandler.java x: 2 # contributors y: 12 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/reader/InfluxDBSplitReader.java x: 2 # contributors y: 128 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/reader/deserializer/InfluxDBDataPointDeserializer.java x: 2 # contributors y: 15 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/split/InfluxDBSplitSerializer.java x: 2 # contributors y: 23 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/ColumnSchemasFactory.java x: 2 # contributors y: 9 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduFilterInfo.java x: 5 # contributors y: 133 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduTableInfo.java x: 3 # contributors y: 57 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowDataConvertor.java x: 1 # contributors y: 61 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/failure/KuduFailureHandler.java x: 2 # contributors y: 13 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReader.java x: 3 # contributors y: 127 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReaderConfig.java x: 2 # contributors y: 52 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/AbstractSingleOperationMapper.java x: 2 # contributors y: 57 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduOperationMapper.java x: 2 # contributors y: 10 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduWriter.java x: 5 # contributors y: 110 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduWriterConfig.java x: 3 # contributors y: 147 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/PojoOperationMapper.java x: 2 # contributors y: 46 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduOutputFormat.java x: 1 # contributors y: 59 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/AbstractReadOnlyCatalog.java x: 2 # contributors y: 85 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduCatalog.java x: 4 # contributors y: 241 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableFactory.java x: 6 # contributors y: 118 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableSource.java x: 4 # contributors y: 141 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog/KuduDynamicCatalog.java x: 1 # contributors y: 243 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils/KuduTableUtils.java x: 4 # contributors y: 220 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils/KuduTypeUtils.java x: 2 # contributors y: 100 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/PinotSink.java x: 1 # contributors y: 84 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/PinotSinkBuilder.java x: 1 # contributors y: 70 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer/PinotSinkCommittable.java x: 1 # contributors y: 24 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer/PinotSinkCommittableSerializer.java x: 1 # contributors y: 41 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer/PinotSinkCommitter.java x: 1 # contributors y: 264 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer/PinotWriter.java x: 1 # contributors y: 109 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer/PinotWriterSegment.java x: 1 # contributors y: 68 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer/PinotWriterState.java x: 1 # contributors y: 22 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer/PinotWriterStateSerializer.java x: 1 # contributors y: 50 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisClusterConfig.java x: 5 # contributors y: 109 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisConfigBase.java x: 4 # contributors y: 58 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisPoolConfig.java x: 4 # contributors y: 110 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/FlinkJedisSentinelConfig.java x: 4 # contributors y: 126 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisCommandsContainerBuilder.java x: 5 # contributors y: 75 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/InfluxDBSinkOptions.java x: 2 # contributors y: 72 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader/KuduReaderIterator.java x: 2 # contributors y: 39 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/RowDataUpsertOperationMapper.java x: 1 # contributors y: 116 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/KuduRowInputFormat.java x: 1 # contributors y: 29 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSink.java x: 1 # contributors y: 58 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java x: 1 # contributors y: 178 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduLookupOptions.java x: 1 # contributors y: 46 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSinkFactory.java x: 7 # contributors y: 42 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/Redis.java x: 5 # contributors y: 48 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/AbstractSiddhiOperator.java x: 4 # contributors y: 244 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/SiddhiCEP.java x: 2 # contributors y: 95 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/SiddhiStream.java x: 3 # contributors y: 162 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/SiddhiOperatorContext.java x: 2 # contributors y: 124 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/SiddhiStreamOperator.java x: 3 # contributors y: 52 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/StreamInMemOutputHandler.java x: 3 # contributors y: 70 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils/SiddhiStreamFactory.java x: 3 # contributors y: 11 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils/SiddhiTupleFactory.java x: 3 # contributors y: 74 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils/SiddhiTypeFactory.java x: 3 # contributors y: 98 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/enumerator/InfluxDBSourceEnumState.java x: 1 # contributors y: 4 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/enumerator/InfluxDBSourceEnumStateSerializer.java x: 1 # contributors y: 19 lines of code flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/split/InfluxDBSplit.java x: 1 # contributors y: 17 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableSink.java x: 3 # contributors y: 61 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/PinotControllerClient.java x: 1 # contributors y: 67 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/PinotControllerHttpClient.java x: 1 # contributors y: 62 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/exceptions/PinotControllerApiException.java x: 1 # contributors y: 9 lines of code flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/segment/name/PinotSinkSegmentNameGenerator.java x: 1 # contributors y: 5 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisClusterConfigHandler.java x: 5 # contributors y: 42 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config/handler/FlinkJedisSentinelConfigHandler.java x: 3 # contributors y: 41 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/descriptor/RedisValidator.java x: 3 # contributors y: 14 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisTableSink.java x: 4 # contributors y: 72 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/FlinkJedisConfigHandler.java x: 2 # contributors y: 6 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisHandlerServices.java x: 2 # contributors y: 97 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder/RedisMapperHandler.java x: 4 # contributors y: 24 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row/RowRedisMapper.java x: 5 # contributors y: 69 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/RowOperationMapper.java x: 1 # contributors y: 16 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/RedisCommandDescription.java x: 3 # contributors y: 50 lines of code flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka/AkkaSource.java x: 3 # contributors y: 83 lines of code flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume/FlumeSink.java x: 4 # contributors y: 107 lines of code flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java x: 5 # contributors y: 164 lines of code flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume/FlumeUtils.java x: 1 # contributors y: 48 lines of code flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb/InfluxDBConfig.java x: 2 # contributors y: 136 lines of code flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb/InfluxDBSink.java x: 3 # contributors y: 60 lines of code flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSinkConfig.java x: 3 # contributors y: 65 lines of code flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSourceConfig.java x: 3 # contributors y: 66 lines of code flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/NettyUtil.scala x: 3 # contributors y: 107 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/exception/DuplicatedStreamException.java x: 1 # contributors y: 6 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/package-info.java x: 1 # contributors y: 1 lines of code flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/schema/StreamSchema.java x: 1 # contributors y: 129 lines of code flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/TcpHandler.scala x: 2 # contributors y: 18 lines of code flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/TcpServer.scala x: 2 # contributors y: 80 lines of code scalastyle-config.xml x: 2 # contributors y: 203 lines of code flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/internal/RunningChecker.java x: 1 # contributors y: 11 lines of code
355.0
lines of code
  min: 1.0
  average: 60.34
  25th percentile: 14.5
  median: 45.0
  75th percentile: 84.5
  max: 355.0
0 10.0
# contributors
min: 1.0 | average: 2.24 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 3.0 | max: 10.0