apache / flink - Unit 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 67,527 units with 610,883 lines of code in units (66.1% of code).

185 very long units (26,744 lines of code)
925 long units (62,017 lines of code)
5,286 medium size units (159,428 lines of code)
9,662 small units (140,079 lines of code)
51,469 very small units (222,615 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
static in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/typeutils/SymbolUtil.java	387	1	0
private ApplicationReport startAppMaster() in flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java	377	53	7
def register() in flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/runtime/types/TupleSerializers.scala	372	1	1
private SqlNode registerFrom() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/validate/SqlValidatorImpl.java	359	73	9
def gen() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/LongHashJoinGenerator.scala	340	25	16
private static Function converter() in flink-python/src/main/java/org/apache/flink/streaming/api/utils/PythonTypeUtils.java	294	83	2
override def visitOver() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/ExprCodeGenerator.scala	287	86	1
def genWithKeys() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashAggCodeGenerator.scala	277	16	13
private static Function converter() in flink-python/src/main/java/org/apache/flink/table/utils/python/PythonTableUtils.java	257	76	1
def buildProgram() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkStreamProgram.scala	246	2	1
def visit() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala	242	59	2
public void onMatch() in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkAggregateJoinTransposeRule.java	230	35	1
def visit() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala	228	53	3
private[flink] def genPreAccumulate() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/WindowCodeGenerator.scala	226	16	12
override def onMatch() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/SplitAggregateRule.scala	222	14	1
def buildProgram() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkBatchProgram.scala	220	2	1
protected Transformation translateToPlanInternal() in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecRank.java	220	16	2
boolean resizeHashTable() in flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/CompactingHashTable.java	214	34	0
def getColumnInterval() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdColumnInterval.scala	213	56	3
private void registerQuery() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql/validate/SqlValidatorImpl.java	212	30	7
private void translateAgg() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java	210	32	6
public static DefaultExecutionGraph buildGraph() in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraphBuilder.java	210	16	26
private void doRun() in flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java	208	35	0
void initNonDynamicFunctions() in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions/converter/DirectConvertRule.java	207	1	0
private void substituteSubQuery() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java	205	38	2
public CompletableFuture submitTask() in flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java	202	12	3
private static void sortInternal() in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/QuickSort.java	200	35	11
private List createOverWindowFrames() in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/batch/BatchExecOverAggregate.java	196	22	7
private static void validateInfo() in flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java	189	63	3
public static WritableColumnVector createWritableColumnVector() in flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/vector/ParquetSplitReaderUtil.java	189	36	5
def gen() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashWindowCodeGenerator.scala	185	12	6
def visit() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala	185	45	2
private def genOutputByMerging() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashWindowCodeGenerator.scala	182	7	7
def extract_process_function() in flink-python/pyflink/fn_execution/datastream/embedded/operations.py	181	19	8
public static DataFormatConverter getConverterForDataType() in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/data/util/DataFormatConverters.java	179	56	1
public StreamOperatorStateContext streamOperatorStateContext() in flink-runtime/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java	175	17	10
private def doProcessConsumeWithKeys() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/fusion/spec/HashAggFusionCodegenSpec.scala	169	8	1
private StandardConvertletTable() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/StandardConvertletTable.java	166	9	0
public void prepare() in flink-runtime/src/main/java/org/apache/flink/runtime/operators/JoinDriver.java	165	12	0
private def transformTimeSlidingWindow() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/batch/BatchPhysicalWindowAggregateRule.scala	164	12	7
private ExternalSorter doBuild() in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/ExternalSorterBuilder.java	164	27	1
override def explain_() in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils/RelTreeWriterImpl.scala	163	60	3
private void rewriteUsingGroupingSets() in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkAggregateExpandDistinctAggregatesRule.java	162	18	2
public DispatcherResourceManagerComponent create() in flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/component/DefaultDispatcherResourceManagerComponentFactory.java	162	11	13
public static RowDataToAvroConverter createConverter() in flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RowDataToAvroConverters.java	162	33	2
public void onMatch() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/RelDecorrelator.java	161	26	1
public RocksDBKeyedStateBackend build() in flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/state/rocksdb/RocksDBKeyedStateBackendBuilder.java	161	9	0
public void invoke() in flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSinkTask.java	160	30	0
public RexNode convertExpression() in flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/SqlToRelConverter.java	157	47	1
public static StreamMultipleInputProcessor create() in flink-runtime/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessorFactory.java	157	12	19