apache / bahir-flinkUnit Size

Intro

Unit size measurements show the distribution of size of units of code (methods, functions...).
Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

Unit Size Overall

There are 966 units with 6,585 lines of code in units (63.1% of code).

0 very long units (0 lines of code)
5 long units (294 lines of code)
33 medium size units (929 lines of code)
140 small units (1,997 lines of code)
788 very small units (3,365 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
public Object getFieldValue() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/RowDataUpsertOperationMapper.java	67	25	2
public void invoke() in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/RedisSink.java	65	19	2
public static T newTuple() in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils/SiddhiTupleFactory.java	59	27	1
public void eval() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/function/lookup/KuduRowDataLookupFunction.java	52	14	1
public RowData convertor() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/convertor/RowResultRowDataConvertor.java	51	15	1
public void handle() in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/http/WriteAPIHandler.java	47	9	1
private KuduPredicate predicateComparator() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/KuduFilterInfo.java	41	12	1
public void commitSink() in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer/PinotSinkCommitter.java	38	9	1
private void flush() in flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume/FlumeSink.java	38	10	0
private static Optional convertIsInExpression() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils/KuduTableUtils.java	37	10	1
def startServiceOnPort[T]() in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/NettyUtil.scala	37	10	4
def startNettyServer() in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/TcpServer.scala	36	2	2
public void close() in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java	36	10	0
private static Optional convertBinaryComparison() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils/KuduTableUtils.java	34	11	2
public List supportedProperties() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableFactory.java	30	1	0
private void generateSegment() in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer/PinotSinkCommitter.java	30	3	3
def startNettyServer() in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/HttpServer.scala	30	2	2
public static DataType toFlinkType() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils/KuduTypeUtils.java	28	12	2
public RedisCommandDescription() in flink-connector-redis/src/main/java/org/apache/flink/streaming/connectors/redis/common/mapper/RedisCommandDescription.java	27	10	3
public void handleSplitsChanges() in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/reader/InfluxDBSplitReader.java	27	4	1
def sendGetRequest() in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/NettyUtil.scala	27	8	1
def findLocalInetAddress() in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/NettyUtil.scala	26	9	0
public Boolean call() in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer/PinotSinkCommitter.java	25	4	0
public static RpcClient getRpcClient() in flink-connector-flume/src/main/java/org/apache/flink/streaming/connectors/flume/FlumeUtils.java	25	5	4
public void close() in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java	25	7	0
public void receive() in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/StreamOutputHandler.java	25	7	1
public static KuduTableInfo createTableInfo() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils/KuduTableUtils.java	23	3	3
public static DataPoint parseToDataPoint() in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common/InfluxParser.java	23	4	1
public void createTable() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/catalog/KuduDynamicCatalog.java	22	4	3
public DynamicTableSink createDynamicTableSink() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java	22	1	1
override def channelReadComplete() in flink-connector-netty/src/main/scala/org/apache/flink/streaming/connectors/netty/example/HttpHandler.scala	22	6	1
public void run() in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java	22	5	1
public DynamicTableSource createDynamicTableSource() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/dynamic/KuduDynamicTableSourceSinkFactory.java	21	1	1
public void createTable() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduCatalog.java	21	4	3
public void open() in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java	21	3	1
public static AbstractDefinition getStreamDefinition() in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/utils/SiddhiTypeFactory.java	21	4	2
private void startSiddhiRuntime() in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/AbstractSiddhiOperator.java	21	3	0
public void receive() in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/StreamInMemOutputHandler.java	21	7	1
private KuduTableSink createTableSink() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableFactory.java	20	1	3
public void close() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/connector/writer/KuduWriter.java	20	5	0
public static InfluxDBClient getInfluxDBClient() in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink/InfluxDBSinkOptions.java	20	4	1
public static InfluxDBClient getInfluxDBClient() in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/sink2/InfluxDBSinkOptions.java	20	4	1
public static List toKuduConnectorColumns() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/utils/KuduTableUtils.java	19	3	2
public PinotWriter() in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/writer/PinotWriter.java	19	3	7
public PinotSinkCommitter() in flink-connector-pinot/src/main/java/org/apache/flink/streaming/connectors/pinot/v2/committer/PinotSinkCommitter.java	19	1	9
public void open() in flink-connector-influxdb/src/main/java/org/apache/flink/streaming/connectors/influxdb/InfluxDBSink.java	19	5	1
public RecordsWithSplitIds fetch() in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/source/reader/InfluxDBSplitReader.java	19	4	0
protected void acknowledgeIDs() in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java	19	5	2
private void restoreState() in flink-library-siddhi/src/main/java/org/apache/flink/streaming/siddhi/operator/AbstractSiddhiOperator.java	19	3	0
public DataType getProducedDataType() in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableSource.java	18	3	0