apache / bahir-flink
File Size

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

Intro
Learn more...
File Size Overall
0% | 0% | 19% | 30% | 50%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 0% | 18% | 30% | 50%
xml0% | 0% | 100% | 0% | 0%
scala0% | 0% | 0% | 28% | 71%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-connector-kudu0% | 0% | 21% | 46% | 31%
flink-connector-redis0% | 0% | 31% | 24% | 44%
flink-connector-pinot0% | 0% | 27% | 11% | 61%
flink-library-siddhi0% | 0% | 19% | 33% | 47%
ROOT0% | 0% | 100% | 0% | 0%
flink-connector-activemq0% | 0% | 0% | 36% | 63%
flink-connector-influxdb0% | 0% | 0% | 56% | 43%
flink-connector-influxdb20% | 0% | 0% | 8% | 91%
flink-connector-netty0% | 0% | 0% | 28% | 71%
flink-connector-flume0% | 0% | 0% | 65% | 34%
flink-connector-akka0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
RedisContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 355 24
PinotSinkCommitter.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer
 264 14
RedisClusterContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 249 21
AbstractSiddhiOperator.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 244 20
KuduDynamicCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog
 243 31
KuduCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 241 31
KuduTableUtils.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils
 220 13
203 -
KuduRowDataLookupFunction.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup
 179 13
KuduDynamicTableSourceSinkFactory.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic
 178 4
AMQSource.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 164 9
SiddhiStream.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi
 162 17
KuduWriterConfig.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 147 22
KuduDynamicTableSource.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic
 145 13
KuduTableSource.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 141 12
InfluxDBConfig.java
in flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb
 136 21
KuduFilterInfo.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector
 133 16
StreamSchema.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/schema
 129 11
InfluxDBSplitReader.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/reader
 128 11
KuduReader.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader
 127 12
FlinkJedisSentinelConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 126 19
SiddhiOperatorContext.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 124 19
RedisSink.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis
 121 4
KuduTableFactory.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 118 7
RowDataUpsertOperationMapper.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 116 4
AbstractKuduInputFormat.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format
 114 12
KuduWriter.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 110 12
FlinkJedisPoolConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 110 18
FlinkJedisClusterConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 109 16
PinotWriter.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer
 109 9
FlumeSink.java
in flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume
 107 8
NettyUtil.scala
in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example
 107 4
KuduTypeUtils.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils
 100 14
SiddhiTypeFactory.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils
 98 6
RedisHandlerServices.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder
 97 7
InfluxDBSinkBuilder.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink
 97 11
InfluxDBSinkBuilder.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2
 97 11
AMQSink.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 95 6
SiddhiCEP.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi
 95 8
InfluxParser.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common
 92 9
InfluxDBWriter.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/writer
 92 9
WriteAPIHandler.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/http
 91 2
AbstractReadOnlyCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 85 19
PinotSink.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2
 84 6
AkkaSource.java
in flink-connector-akka/src/main/java/org/apache/flink/streaming/connectors/akka
 83 7
TcpServer.scala
in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example
 80 3
InfluxDBWriter.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/writer
 76 7
RedisCommandsContainerBuilder.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 75 5
SiddhiTupleFactory.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils
 74 2
RedisTableSink.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis
 72 9
Files With Most Units (Top 50)
File# lines# units
KuduDynamicCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog
 243 31
KuduCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 241 31
RedisContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 355 24
KuduWriterConfig.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 147 22
RedisClusterContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 249 21
InfluxDBConfig.java
in flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb
 136 21
AbstractSiddhiOperator.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 244 20
AbstractReadOnlyCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 85 19
FlinkJedisSentinelConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 126 19
SiddhiOperatorContext.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 124 19
FlinkJedisPoolConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 110 18
SiddhiStream.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi
 162 17
KuduFilterInfo.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector
 133 16
FlinkJedisClusterConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 109 16
KuduTypeUtils.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils
 100 14
PinotSinkCommitter.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer
 264 14
KuduDynamicTableSource.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic
 145 13
KuduTableUtils.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils
 220 13
KuduRowDataLookupFunction.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup
 179 13
RowRedisMapper.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/row
 69 13
KuduTableSource.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 141 12
KuduReader.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader
 127 12
KuduWriter.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 110 12
AbstractKuduInputFormat.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format
 114 12
AMQSinkConfig.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 65 12
InfluxDBSplitReader.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/reader
 128 11
InfluxDBSinkBuilder.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink
 97 11
InfluxDBSinkBuilder.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2
 97 11
AMQSourceConfig.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 66 11
StreamSchema.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/schema
 129 11
KuduLookupOptions.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup
 46 10
FlinkJedisConfigBase.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 58 10
PinotSinkBuilder.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2
 70 10
InfluxDBPoint.java
in flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb
 45 10
KuduReaderConfig.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader
 52 9
KuduTableInfo.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector
 57 9
RedisTableSink.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis
 72 9
PinotWriter.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer
 109 9
InfluxParser.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common
 92 9
InfluxDBWriter.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/writer
 92 9
AMQSource.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 164 9
KuduDynamicTableSink.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic
 58 8
KuduOutputFormat.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format
 59 8
FlumeSink.java
in flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume
 107 8
InfluxDBSource.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source
 67 8
DataPoint.java
in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common
 63 8
SiddhiCEP.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi
 95 8
KuduSink.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/streaming
 59 7
KuduTableFactory.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 118 7
RedisHandlerServices.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/hanlder
 97 7
Files With Long Lines (Top 42)

There are 42 files with lines longer than 120 characters. In total, there are 121 long lines.

File# lines# units# long lines
AbstractReadOnlyCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 85 19 18
AbstractSiddhiOperator.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 244 20 9
KuduDynamicCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog
 243 31 7
KuduCatalog.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 241 31 7
SiddhiStreamOperator.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 52 4 6
PinotControllerClient.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot
 67 6 5
KuduReader.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/reader
 127 12 4
RedisSink.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis
 121 4 4
PinotWriter.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer
 109 9 4
SiddhiStream.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi
 162 17 4
KuduTableInfo.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector
 57 9 3
KuduRowDataInputFormat.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format
 25 4 3
FlinkJedisPoolConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 110 18 3
PinotSinkCommitter.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer
 264 14 3
203 - 3
SiddhiTypeFactory.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils
 98 6 3
KuduDynamicTableSink.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic
 58 8 2
KuduWriter.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 110 12 2
FlinkJedisClusterConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 109 16 2
RedisContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 355 24 2
RedisClusterContainer.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 249 21 2
FlumeSink.java
in flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume
 107 8 2
InfluxDBSink.java
in flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb
 60 4 2
SiddhiStreamFactory.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils
 11 1 2
SiddhiCEP.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi
 95 8 2
KuduSink.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/streaming
 59 7 1
KuduDynamicTableSource.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic
 145 13 1
KuduTableSink.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table
 61 6 1
RowResultRowDataConvertor.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor
 61 1 1
PojoOperationMapper.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 46 3 1
AbstractSingleOperationMapper.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer
 57 4 1
AbstractKuduInputFormat.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format
 114 12 1
KuduOutputFormat.java
in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format
 59 8 1
FlinkJedisConfigBase.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 58 10 1
FlinkJedisSentinelConfig.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/config
 126 19 1
RedisCommandsContainerBuilder.java
in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container
 75 5 1
PinotWriterSegment.java
in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer
 68 6 1
AMQSinkConfig.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 65 12 1
AMQSourceConfig.java
in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq
 66 11 1
SiddhiTupleFactory.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils
 74 2 1
SiddhiOperatorContext.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 124 19 1
StreamOutputHandler.java
in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator
 70 5 1
Correlations

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

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

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

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

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

No data for "commits (30d)" vs. "lines of code".

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

No data for "contributors (30d)" vs. "lines of code".

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

flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/AbstractKuduInputFormat.java x: 1 commits (90d) y: 114 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java x: 1 commits (90d) y: 179 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java x: 3 commits (90d) y: 355 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java x: 2 commits (90d) y: 121 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java x: 2 commits (90d) y: 249 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisCommandsContainer.java x: 2 commits (90d) y: 25 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/RedisCommand.java x: 2 commits (90d) y: 28 lines of code
355.0
lines of code
  min: 25.0
  average: 153.0
  25th percentile: 28.0
  median: 121.0
  75th percentile: 249.0
  max: 355.0
0 3.0
commits (90d)
min: 1.0 | average: 1.86 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 3.0

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

flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/format/AbstractKuduInputFormat.java x: 1 contributors (90d) y: 114 lines of code flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java x: 1 contributors (90d) y: 179 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisContainer.java x: 1 contributors (90d) y: 355 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java x: 1 contributors (90d) y: 121 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisClusterContainer.java x: 1 contributors (90d) y: 249 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/container/RedisCommandsContainer.java x: 1 contributors (90d) y: 25 lines of code flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/RedisCommand.java x: 1 contributors (90d) y: 28 lines of code
355.0
lines of code
  min: 25.0
  average: 153.0
  25th percentile: 28.0
  median: 121.0
  75th percentile: 249.0
  max: 355.0
0 1.0
contributors (90d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0