spotify / flink
File Size

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

Intro
Learn more...
File Size Overall
6% | 11% | 26% | 23% | 31%
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
java5% | 10% | 26% | 23% | 33%
scala6% | 17% | 27% | 22% | 26%
xml80% | 0% | 9% | 3% | 7%
ftl97% | 0% | 0% | 0% | 2%
py16% | 12% | 27% | 23% | 20%
pyx0% | 72% | 0% | 16% | 11%
ts0% | 0% | 10% | 24% | 65%
clj0% | 0% | 22% | 55% | 21%
html0% | 0% | 13% | 12% | 73%
proto0% | 0% | 0% | 100% | 0%
pxd0% | 0% | 0% | 72% | 27%
less0% | 0% | 0% | 11% | 88%
in0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
edn0% | 0% | 0% | 0% | 100%
cfg0% | 0% | 0% | 0% | 100%
h0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-table6% | 16% | 25% | 22% | 28%
flink-filesystems76% | 0% | 3% | 8% | 12%
flink-runtime5% | 10% | 24% | 23% | 36%
flink-connectors8% | 6% | 31% | 23% | 29%
flink-core4% | 7% | 29% | 22% | 36%
flink-python7% | 12% | 22% | 25% | 31%
flink-optimizer9% | 8% | 30% | 24% | 26%
flink-libraries4% | 6% | 31% | 24% | 33%
flink-yarn25% | 25% | 14% | 13% | 21%
flink-formats6% | 0% | 42% | 27% | 24%
flink-streaming-java0% | 19% | 28% | 19% | 32%
flink-java0% | 19% | 18% | 28% | 34%
flink-state-backends0% | 15% | 43% | 20% | 21%
flink-clients0% | 22% | 20% | 17% | 38%
flink-scala0% | 12% | 29% | 26% | 30%
flink-mesos0% | 16% | 27% | 20% | 35%
flink-streaming-scala0% | 0% | 61% | 21% | 17%
flink-ml-parent0% | 0% | 44% | 19% | 35%
flink-runtime-web0% | 0% | 12% | 24% | 63%
flink-queryable-state0% | 0% | 22% | 33% | 43%
flink-metrics0% | 0% | 19% | 27% | 53%
flink-kubernetes0% | 0% | 16% | 35% | 47%
tools0% | 0% | 51% | 16% | 32%
flink-jepsen0% | 0% | 22% | 54% | 23%
flink-scala-shell0% | 0% | 37% | 45% | 17%
flink-dist0% | 0% | 45% | 23% | 31%
flink-contrib0% | 0% | 0% | 87% | 12%
flink-external-resources0% | 0% | 0% | 65% | 34%
flink-walkthroughs0% | 0% | 0% | 0% | 100%
flink-container0% | 0% | 0% | 0% | 100%
flink-quickstart0% | 0% | 0% | 0% | 100%
flink-annotations0% | 0% | 0% | 0% | 100%
flink-examples0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
XmlResponsesSaxParser.java
in flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3/model/transform
 2555 149
core-default-shaded.xml
in flink-filesystems/flink-fs-hadoop-shaded/src/main/resources
 2404 -
Configuration.java
in flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf
 2056 159
core-default-shaded.xml
in flink-filesystems/flink-swift-fs-hadoop/src/main/resources/META-INF
 1978 -
ScalarOperatorGens.scala
in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls
 1934 48
Configuration.java
in flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf
 1674 127
TaskExecutor.java
in flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor
 1554 92
types.py
in flink-python/pyflink/table
 1495 176
hbase-default.xml
in flink-connectors/flink-sql-connector-hbase/src/main/resources
 1477 -
TypeExtractor.java
in flink-core/src/main/java/org/apache/flink/api/java/typeutils
 1448 66
AggregateUtil.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate
 1428 30
parserImpls.ftl
in flink-table/flink-sql-parser-hive/src/main/codegen/includes
 1414 -
CodeGenerator.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen
 1400 52
parserImpls.ftl
in flink-table/flink-sql-parser/src/main/codegen/includes
 1278 -
TableEnvironmentImpl.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal
 1269 76
JobGraphGenerator.java
in flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate
 1255 34
Graph.java
in flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph
 1249 123
Record.java
in flink-core/src/main/java/org/apache/flink/types
 1218 80
ScalarOperators.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/calls
 1186 37
YarnClusterDescriptor.java
in flink-yarn/src/main/java/org/apache/flink/yarn
 1184 53
HiveCatalog.java
in flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive
 1183 70
BuiltInFunctionDefinitions.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions
 1168 1
CheckpointCoordinator.java
in flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint
 1139 71
ExecutionGraph.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 1133 85
OrcBatchReader.java
in flink-formats/flink-orc/src/main/java/org/apache/flink/orc
 1117 44
MutableHashTable.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash
 1117 56
FlinkKafkaProducer.java
in flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 1095 85
DataFormatConverters.java
in flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/util
 1087 116
Execution.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 1066 81
UnilateralSortMerger.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort
 1060 44
SqlDateTimeUtils.java
in flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions
 1039 120
TableEnvImpl.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal
 1032 72
SubQueryDecorrelator.java
in flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical
 983 57
Task.java
in flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager
 972 50
DescriptorProperties.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors
 945 110
FlinkKafkaProducer011.java
in flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka
 941 90
CopyOnWriteSkipListStateMap.java
in flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/flink/runtime/state/heap
 939 83
AggsHandlerCodeGenerator.scala
in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg
 929 31
SlotPoolImpl.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool
 928 92
JobMaster.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster
 914 70
BatchTask.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators
 897 49
SlotManagerImpl.java
in flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager
 893 66
CompactingHashTable.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash
 893 38
SqlFunctionUtils.java
in flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions
 885 112
JoinOperator.java
in flink-java/src/main/java/org/apache/flink/api/java/operators
 878 60
ResourceManager.java
in flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager
 868 60
TaskConfig.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators/util
 858 122
AggregationCodeGenerator.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen
 835 17
FlinkSqlOperatorTable.java
in flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/sql
 829 12
BinaryStringDataUtil.java
in flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/binary
 812 36
Files With Most Units (Top 50)
File# lines# units
types.py
in flink-python/pyflink/table
 1495 176
Configuration.java
in flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf
 2056 159
XmlResponsesSaxParser.java
in flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3/model/transform
 2555 149
BaseExpressions.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal
 533 140
Configuration.java
in flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf
 1674 127
Graph.java
in flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph
 1249 123
TaskConfig.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators/util
 858 122
SqlDateTimeUtils.java
in flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions
 1039 120
DataFormatConverters.java
in flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/util
 1087 116
SqlFunctionUtils.java
in flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions
 885 112
DescriptorProperties.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors
 945 110
TableImpl.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal
 782 110
descriptors.py
in flink-python/pyflink/table
 607 108
StreamExecutionEnvironment.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment
 788 99
catalog.py
in flink-python/pyflink/table
 406 98
beam_coder_impl_slow.py
in flink-python/pyflink/fn_execution/beam
 403 92
SlotPoolImpl.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool
 928 92
TaskExecutor.java
in flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor
 1554 92
FlinkKafkaProducer011.java
in flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka
 941 90
FlinkKafkaProducer.java
in flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 1095 85
ExecutionGraph.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 1133 85
CopyOnWriteSkipListStateMap.java
in flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/flink/runtime/state/heap
 939 83
Execution.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 1066 81
Record.java
in flink-core/src/main/java/org/apache/flink/types
 1218 80
DataSet.scala
in flink-scala/src/main/scala/org/apache/flink/api/scala
 781 77
TableEnvironmentImpl.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal
 1269 76
ExecutionConfig.java
in flink-core/src/main/java/org/apache/flink/api/common
 624 76
coders.py
in flink-python/pyflink/fn_execution
 281 74
table_environment.py
in flink-python/pyflink/table
 542 74
NetworkBuffer.java
in flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer
 444 73
TableEnvImpl.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal
 1032 72
StreamTask.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks
 769 72
StreamGraph.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph
 626 72
DataSet.java
in flink-java/src/main/java/org/apache/flink/api/java
 472 71
CheckpointCoordinator.java
in flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint
 1139 71
DataTypes.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/api
 444 70
HiveCatalog.java
in flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive
 1183 70
ExecutionEnvironment.java
in flink-java/src/main/java/org/apache/flink/api/java
 507 70
JobMaster.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster
 914 70
data_stream.py
in flink-python/pyflink/datastream
 410 69
StreamConfig.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph
 483 68
LimitedConnectionsFileSystem.java
in flink-core/src/main/java/org/apache/flink/core/fs
 678 67
BinarySegmentUtils.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary
 788 66
DataStream.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream
 447 66
TypeExtractor.java
in flink-core/src/main/java/org/apache/flink/api/java/typeutils
 1448 66
SlotManagerImpl.java
in flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager
 893 66
LogicalTypeChecks.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils
 361 64
Graph.scala
in flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala
 485 64
WindowOperator.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing
 649 60
JoinOperator.java
in flink-java/src/main/java/org/apache/flink/api/java/operators
 878 60
Files With Long Lines (Top 50)

There are 1843 files with lines longer than 120 characters. In total, there are 6576 long lines.

File# lines# units# long lines
JoinOperator.java
in flink-java/src/main/java/org/apache/flink/api/java/operators
 878 60 99
CsvReader.java
in flink-java/src/main/java/org/apache/flink/api/java/io
 322 18 94
CrossOperator.java
in flink-java/src/main/java/org/apache/flink/api/java/operators
 534 24 79
TypeExtractor.java
in flink-core/src/main/java/org/apache/flink/api/java/typeutils
 1448 66 73
StreamProjection.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream
 222 2 61
ProjectOperator.java
in flink-java/src/main/java/org/apache/flink/api/java/operators
 263 4 59
TaskExecutor.java
in flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor
 1554 92 55
AllWindowedStream.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream
 786 50 44
CliStrings.java
in flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli
 192 7 41
WindowedStream.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream
 776 53 40
SlotManagerImpl.java
in flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager
 893 66 38
Execution.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 1066 81 38
MiniCluster.java
in flink-runtime/src/main/java/org/apache/flink/runtime/minicluster
 717 47 37
JobGraphGenerator.java
in flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate
 1255 34 36
YarnClusterDescriptor.java
in flink-yarn/src/main/java/org/apache/flink/yarn
 1184 53 34
HiveCatalog.java
in flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive
 1183 70 32
KinesisConfigUtil.java
in flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util
 232 9 32
PojoSerializer.java
in flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime
 806 34 32
CompactingHashTable.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash
 893 38 32
WebMonitorEndpoint.java
in flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor
 721 10 31
JobMaster.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster
 914 70 30
Dispatcher.java
in flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher
 662 50 30
AbstractJdbcCatalog.java
in flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog
 230 39 27
NettyShuffleEnvironmentOptions.java
in flink-core/src/main/java/org/apache/flink/configuration
 176 1 27
TaskConfig.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators/util
 858 122 27
shell.py
in flink-python/pyflink
 114 - 26
FlinkILoop.scala
in flink-scala-shell/src/main/scala/org/apache/flink/api/scala
 196 6 26
SemanticPropUtil.java
in flink-java/src/main/java/org/apache/flink/api/java/functions
 543 17 25
SchedulerBase.java
in flink-runtime/src/main/java/org/apache/flink/runtime/scheduler
 790 60 25
FlinkKafkaProducer.java
in flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka
 1095 85 24
141 - 23
TaskManagerOptions.java
in flink-core/src/main/java/org/apache/flink/configuration
 331 1 23
RestClusterClient.java
in flink-clients/src/main/java/org/apache/flink/client/program/rest
 575 27 23
MutableHashTable.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash
 1117 56 23
BucketStateSerializer.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem
 159 8 22
OutputStreamBasedPartFileWriter.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem
 214 24 22
FlinkKafkaConsumerBase.java
in flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka
 590 29 22
OrcBatchReader.java
in flink-formats/flink-orc/src/main/java/org/apache/flink/orc
 1117 44 22
job-checkpoints.component.html
in flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints
 240 - 22
TaskExecutorFlinkMemoryUtils.java
in flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/taskmanager
 234 22 22
RestClient.java
in flink-runtime/src/main/java/org/apache/flink/runtime/rest
 454 19 22
KinesisDataFetcher.java
in flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals
 716 39 21
FlinkKafkaProducer011.java
in flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka
 941 90 21
RangePartitionRewriter.java
in flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals
 187 4 21
CollectionExecutor.java
in flink-core/src/main/java/org/apache/flink/api/common/operators
 435 23 21
FlinkYarnSessionCli.java
in flink-yarn/src/main/java/org/apache/flink/yarn/cli
 668 28 21
ResourceManager.java
in flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager
 868 60 21
ReporterSetup.java
in flink-runtime/src/main/java/org/apache/flink/runtime/metrics
 248 19 21
CheckpointCoordinator.java
in flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint
 1139 71 21
BatchTask.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators
 897 49 21
Correlations

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

flink-python/pyflink/datastream/data_stream.py x: 13 commits (all time) y: 410 lines of code flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamTwoInputPythonStatelessFunctionOperator.java x: 2 commits (all time) y: 163 lines of code flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java x: 12 commits (all time) y: 30 lines of code flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchOptions.java x: 5 commits (all time) y: 113 lines of code flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java x: 5 commits (all time) y: 101 lines of code flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java x: 2 commits (all time) y: 110 lines of code flink-connectors/flink-sql-connector-hbase/src/main/resources/hbase-default.xml x: 2 commits (all time) y: 1477 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java x: 8 commits (all time) y: 134 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerConfigSnapshot.java x: 13 commits (all time) y: 91 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java x: 10 commits (all time) y: 30 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/MissingTypeInfo.java x: 2 commits (all time) y: 74 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoComparator.java x: 7 commits (all time) y: 254 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/TimestampFormat.java x: 3 commits (all time) y: 7 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/DataSink.java x: 26 commits (all time) y: 176 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/directed/EdgeMetrics.java x: 11 commits (all time) y: 215 lines of code flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/linalg/DenseMatrix.java x: 2 commits (all time) y: 308 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/FencedRpcEndpoint.java x: 7 commits (all time) y: 74 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsCsv.java x: 9 commits (all time) y: 23 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsText.java x: 8 commits (all time) y: 22 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java x: 9 commits (all time) y: 189 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java x: 5 commits (all time) y: 94 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils/AggSqlFunction.scala x: 11 commits (all time) y: 161 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecGroupAggregateBase.scala x: 3 commits (all time) y: 38 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecWindowAggregateBase.scala x: 2 commits (all time) y: 53 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/internal/MergingWindowSet.java x: 2 commits (all time) y: 111 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java x: 80 commits (all time) y: 1184 lines of code flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/SavepointEnvironment.java x: 14 commits (all time) y: 237 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java x: 172 commits (all time) y: 1066 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionAttemptID.java x: 6 commits (all time) y: 56 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java x: 38 commits (all time) y: 483 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertexID.java x: 14 commits (all time) y: 29 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskManagerJobMetricGroup.java x: 8 commits (all time) y: 72 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGroup.java x: 14 commits (all time) y: 111 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/UnregisteredMetricGroups.java x: 7 commits (all time) y: 127 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java x: 3 commits (all time) y: 52 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java x: 167 commits (all time) y: 1554 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/topology/VertexID.java x: 2 commits (all time) y: 3 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java x: 1 commits (all time) y: 218 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocatorFactory.java x: 1 commits (all time) y: 36 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java x: 27 commits (all time) y: 928 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/util/DualKeyLinkedMap.java x: 1 commits (all time) y: 122 lines of code flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java x: 30 commits (all time) y: 128 lines of code flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java x: 51 commits (all time) y: 207 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java x: 34 commits (all time) y: 272 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/FlinkUserCodeClassLoaders.java x: 12 commits (all time) y: 129 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerSharedServices.java x: 10 commits (all time) y: 121 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java x: 83 commits (all time) y: 300 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java x: 22 commits (all time) y: 284 lines of code flink-formats/flink-orc/src/main/java/org/apache/flink/orc/writer/ThreadLocalClassLoaderConfiguration.java x: 1 commits (all time) y: 28 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java x: 57 commits (all time) y: 710 lines of code flink-core/src/main/java/org/apache/flink/util/FlinkUserCodeClassLoader.java x: 4 commits (all time) y: 32 lines of code flink-python/pyflink/datastream/functions.py x: 8 commits (all time) y: 86 lines of code flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonStatelessFunctionOperator.java x: 3 commits (all time) y: 118 lines of code flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractOneInputPythonFunctionOperator.java x: 1 commits (all time) y: 18 lines of code flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/AbstractStatelessFunctionOperator.java x: 8 commits (all time) y: 152 lines of code flink-python/pyflink/proto/flink-fn-execution.proto x: 12 commits (all time) y: 183 lines of code flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractPythonFunctionOperatorBase.java x: 1 commits (all time) y: 208 lines of code flink-python/pyflink/common/serialization_schemas.py x: 1 commits (all time) y: 180 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java x: 226 commits (all time) y: 769 lines of code flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentFactory.java x: 19 commits (all time) y: 65 lines of code flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java x: 40 commits (all time) y: 310 lines of code flink-core/src/main/java/org/apache/flink/util/TaskManagerExceptionUtils.java x: 2 commits (all time) y: 30 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java x: 119 commits (all time) y: 662 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntryPointExceptionUtils.java x: 2 commits (all time) y: 40 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java x: 68 commits (all time) y: 390 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java x: 265 commits (all time) y: 1133 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/InputOutputFormatVertex.java x: 3 commits (all time) y: 102 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java x: 95 commits (all time) y: 346 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java x: 201 commits (all time) y: 972 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/CompletedOperationCache.java x: 2 commits (all time) y: 139 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunction.java x: 7 commits (all time) y: 49 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/UserDefinedFunctionHelper.java x: 5 commits (all time) y: 277 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/ImperativeAggCodeGen.scala x: 12 commits (all time) y: 374 lines of code flink-python/pyflink/datastream/stream_execution_environment.py x: 9 commits (all time) y: 209 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionCatalog.java x: 34 commits (all time) y: 472 lines of code flink-python/src/main/java/org/apache/flink/python/PythonConfig.java x: 6 commits (all time) y: 86 lines of code flink-python/src/main/java/org/apache/flink/python/util/PythonConfigUtil.java x: 2 commits (all time) y: 90 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ActiveResourceManager.java x: 5 commits (all time) y: 205 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/ResourceEventHandler.java x: 1 commits (all time) y: 9 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java x: 25 commits (all time) y: 288 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/entrypoint/KubernetesResourceManagerFactory.java x: 8 commits (all time) y: 67 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerFactory.java x: 13 commits (all time) y: 72 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/LegacyActiveResourceManagerFactory.java x: 1 commits (all time) y: 47 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java x: 105 commits (all time) y: 509 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnResourceManagerFactory.java x: 12 commits (all time) y: 58 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/jobmanager/JobManagerFlinkMemory.java x: 2 commits (all time) y: 45 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java x: 130 commits (all time) y: 868 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/StandaloneResourceManager.java x: 32 commits (all time) y: 82 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java x: 48 commits (all time) y: 634 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write/HiveBulkWriterFactory.java x: 3 commits (all time) y: 46 lines of code flink-formats/flink-orc/src/main/java/org/apache/flink/orc/writer/PhysicalWriterImpl.java x: 3 commits (all time) y: 288 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java x: 7 commits (all time) y: 140 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java x: 160 commits (all time) y: 1139 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleServiceFactory.java x: 17 commits (all time) y: 113 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java x: 40 commits (all time) y: 364 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java x: 68 commits (all time) y: 334 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java x: 19 commits (all time) y: 203 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnknownInputChannel.java x: 25 commits (all time) y: 90 lines of code flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetCloseableRegistry.java x: 8 commits (all time) y: 147 lines of code flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java x: 11 commits (all time) y: 92 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java x: 11 commits (all time) y: 203 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java x: 72 commits (all time) y: 1183 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java x: 27 commits (all time) y: 629 lines of code flink-table/flink-sql-parser-hive/src/main/codegen/includes/parserImpls.ftl x: 10 commits (all time) y: 1414 lines of code flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowPartitions.java x: 1 commits (all time) y: 56 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java x: 89 commits (all time) y: 1269 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java x: 45 commits (all time) y: 648 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPlannerImpl.scala x: 20 commits (all time) y: 149 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/typeutils/DataViewUtils.java x: 3 commits (all time) y: 195 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/DistinctAggCodeGen.scala x: 10 commits (all time) y: 764 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/AggregateUtil.scala x: 20 commits (all time) y: 731 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/aggregation.scala x: 4 commits (all time) y: 66 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/FirstValueAggFunction.java x: 5 commits (all time) y: 77 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/FirstValueWithRetractAggFunction.java x: 7 commits (all time) y: 189 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala x: 14 commits (all time) y: 467 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java x: 5 commits (all time) y: 122 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWsWithRetractAggFunction.java x: 4 commits (all time) y: 136 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/CollectAggFunction.java x: 3 commits (all time) y: 98 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala x: 25 commits (all time) y: 1934 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/MinWithRetractAggFunction.java x: 4 commits (all time) y: 174 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryRowData.java x: 2 commits (all time) y: 332 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/NestedRowData.java x: 2 commits (all time) y: 260 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryRawValueData.java x: 3 commits (all time) y: 88 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeChecks.java x: 14 commits (all time) y: 361 lines of code flink-core/src/main/java/org/apache/flink/util/ChildFirstClassLoader.java x: 6 commits (all time) y: 70 lines of code flink-core/src/main/java/org/apache/flink/core/plugin/PluginLoader.java x: 8 commits (all time) y: 124 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java x: 54 commits (all time) y: 475 lines of code flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonStatelessFunctionRunner.java x: 2 commits (all time) y: 130 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java x: 1 commits (all time) y: 115 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonFormatFactory.java x: 1 commits (all time) y: 102 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java x: 1 commits (all time) y: 71 lines of code flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ArrowUtils.java x: 20 commits (all time) y: 783 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java x: 25 commits (all time) y: 893 lines of code flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonReduceFunctionOperator.java x: 1 commits (all time) y: 82 lines of code flink-python/pyflink/table/table.py x: 24 commits (all time) y: 159 lines of code flink-python/pyflink/table/table_environment.py x: 81 commits (all time) y: 542 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils/UserDefinedFunctionUtils.scala x: 13 commits (all time) y: 620 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkStreamProgram.scala x: 5 commits (all time) y: 149 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/ProjectionCodeGenerator.scala x: 4 commits (all time) y: 92 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecCalc.scala x: 8 commits (all time) y: 51 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecCalc.scala x: 7 commits (all time) y: 59 lines of code flink-python/pyflink/fn_execution/beam/beam_coder_impl_slow.py x: 2 commits (all time) y: 403 lines of code flink-python/pyflink/fn_execution/beam/beam_coders.py x: 3 commits (all time) y: 173 lines of code flink-python/pyflink/fn_execution/beam/beam_operations_fast.pxd x: 2 commits (all time) y: 19 lines of code flink-python/pyflink/fn_execution/beam/beam_operations_fast.pyx x: 2 commits (all time) y: 145 lines of code flink-python/pyflink/fn_execution/coder_impl_fast.pyx x: 2 commits (all time) y: 649 lines of code flink-python/pyflink/fn_execution/coders.py x: 45 commits (all time) y: 281 lines of code flink-python/src/main/java/org/apache/flink/datastream/runtime/typeutils/python/PythonTypeUtils.java x: 1 commits (all time) y: 237 lines of code flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java x: 1 commits (all time) y: 187 lines of code flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/AbstractPythonStatelessFunctionFlatMap.java x: 4 commits (all time) y: 216 lines of code flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java x: 10 commits (all time) y: 63 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosTaskExecutorRunner.java x: 15 commits (all time) y: 43 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/util/FatalExitExceptionHandler.java x: 3 commits (all time) y: 17 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunner.java x: 29 commits (all time) y: 73 lines of code flink-python/pyflink/table/catalog.py x: 19 commits (all time) y: 406 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java x: 33 commits (all time) y: 252 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptions.java x: 18 commits (all time) y: 191 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/Constants.java x: 11 commits (all time) y: 38 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java x: 24 commits (all time) y: 150 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java x: 50 commits (all time) y: 604 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java x: 15 commits (all time) y: 103 lines of code flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java x: 14 commits (all time) y: 246 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImpl.java x: 1 commits (all time) y: 63 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/dataview/NullSerializer.java x: 3 commits (all time) y: 62 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeExtractor.java x: 13 commits (all time) y: 495 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGeneratorContext.scala x: 15 commits (all time) y: 502 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/AggsHandlerCodeGenerator.scala x: 15 commits (all time) y: 929 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/CollectionDataType.java x: 6 commits (all time) y: 101 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/FieldsDataType.java x: 4 commits (all time) y: 83 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LegacyTypeInformationType.java x: 4 commits (all time) y: 76 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/dataview/NullAwareMapSerializer.java x: 3 commits (all time) y: 124 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/dataview/StateMapView.java x: 4 commits (all time) y: 289 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java x: 1 commits (all time) y: 150 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils/LegacyDataViewUtils.scala x: 1 commits (all time) y: 168 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/dataview/PerWindowStateDataViewStore.java x: 2 commits (all time) y: 67 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala x: 19 commits (all time) y: 779 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/ExpressionReducer.scala x: 15 commits (all time) y: 201 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/types/PlannerTypeUtils.java x: 7 commits (all time) y: 202 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/DataTypeUtils.java x: 12 commits (all time) y: 291 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/leaderretrieval/ZooKeeperLeaderRetrievalService.java x: 13 commits (all time) y: 160 lines of code flink-python/pyflink/pyflink_gateway_server.py x: 5 commits (all time) y: 160 lines of code flink-python/src/main/java/org/apache/flink/api/common/python/PythonBridgeUtils.java x: 4 commits (all time) y: 147 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/utils/python/PythonTableUtils.scala x: 6 commits (all time) y: 373 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/LocalInputPreferredSlotSharingStrategy.java x: 1 commits (all time) y: 200 lines of code flink-python/pyflink/common/typeinfo.py x: 1 commits (all time) y: 298 lines of code flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java x: 7 commits (all time) y: 236 lines of code flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableWriter.java x: 8 commits (all time) y: 100 lines of code flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java x: 5 commits (all time) y: 43 lines of code flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl x: 39 commits (all time) y: 1278 lines of code flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTable.java x: 19 commits (all time) y: 253 lines of code flink-metrics/flink-metrics-jmx/src/main/java/org/apache/flink/metrics/jmx/JMXReporter.java x: 10 commits (all time) y: 272 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java x: 36 commits (all time) y: 257 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java x: 64 commits (all time) y: 116 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java x: 57 commits (all time) y: 721 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java x: 2 commits (all time) y: 152 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala x: 23 commits (all time) y: 252 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/CatalogSourceTable.scala x: 16 commits (all time) y: 186 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java x: 39 commits (all time) y: 1448 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java x: 12 commits (all time) y: 220 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroDeserializationSchema.java x: 4 commits (all time) y: 112 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFileSystemFormatFactory.java x: 4 commits (all time) y: 202 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowDataSerializationSchema.java x: 5 commits (all time) y: 59 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/RowDataToAvroConverters.java x: 1 commits (all time) y: 159 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java x: 5 commits (all time) y: 330 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java x: 7 commits (all time) y: 342 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnLocalResourceDescriptor.java x: 4 commits (all time) y: 121 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java x: 29 commits (all time) y: 192 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java x: 50 commits (all time) y: 331 lines of code flink-core/src/main/java/org/apache/flink/configuration/ResourceManagerOptions.java x: 18 commits (all time) y: 78 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/dialect/JdbcDialect.java x: 3 commits (all time) y: 72 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcBatchingOutputFormat.java x: 5 commits (all time) y: 242 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/AbstractJdbcRowConverter.java x: 4 commits (all time) y: 194 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicOutputFormatBuilder.java x: 2 commits (all time) y: 187 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcLookupFunction.java x: 3 commits (all time) y: 243 lines of code flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java x: 11 commits (all time) y: 188 lines of code flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java x: 4 commits (all time) y: 239 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkContextUtil.java x: 3 commits (all time) y: 21 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java x: 6 commits (all time) y: 18 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSink.java x: 9 commits (all time) y: 59 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/utils/AggregateOperationFactory.java x: 2 commits (all time) y: 445 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/typeutils/FieldInfoUtils.java x: 13 commits (all time) y: 557 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/ScalarFunction.java x: 5 commits (all time) y: 40 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/catalog/FunctionCatalogOperatorTable.java x: 13 commits (all time) y: 216 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/converter/OverConvertRule.java x: 3 commits (all time) y: 155 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java x: 26 commits (all time) y: 633 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/utils/ShortcutUtils.java x: 4 commits (all time) y: 46 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/ExprCodeGenerator.scala x: 18 commits (all time) y: 619 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/TableFunctionCallGen.scala x: 7 commits (all time) y: 104 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/CallExpression.java x: 9 commits (all time) y: 100 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java x: 44 commits (all time) y: 94 lines of code flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/ImplicitExpressionConversions.scala x: 3 commits (all time) y: 294 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/aggregations.scala x: 6 commits (all time) y: 164 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala x: 83 commits (all time) y: 1032 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala x: 5 commits (all time) y: 835 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/MatchCodeGenerator.scala x: 6 commits (all time) y: 619 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/aggregations.scala x: 6 commits (all time) y: 311 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/AggSqlFunction.scala x: 7 commits (all time) y: 157 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala x: 11 commits (all time) y: 444 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala x: 13 commits (all time) y: 1428 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java x: 39 commits (all time) y: 145 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/BytesHashMap.java x: 5 commits (all time) y: 447 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/LazyMemorySegmentPool.java x: 2 commits (all time) y: 92 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java x: 9 commits (all time) y: 15 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlot.java x: 17 commits (all time) y: 168 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java x: 3 commits (all time) y: 548 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AlternatingCheckpointBarrierHandler.java x: 10 commits (all time) y: 92 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnaligner.java x: 21 commits (all time) y: 277 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/LookupJoinCodeGenerator.scala x: 6 commits (all time) y: 358 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/SinkCodeGenerator.scala x: 11 commits (all time) y: 122 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/AggCodeGenHelper.scala x: 14 commits (all time) y: 623 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashAggCodeGenHelper.scala x: 12 commits (all time) y: 730 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashWindowCodeGenerator.scala x: 4 commits (all time) y: 693 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/SortWindowCodeGenerator.scala x: 3 commits (all time) y: 202 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/WindowCodeGenerator.scala x: 6 commits (all time) y: 626 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/types/LogicalTypeDataTypeConverter.java x: 8 commits (all time) y: 16 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java x: 20 commits (all time) y: 200 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/IterativeStream.java x: 14 commits (all time) y: 89 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/ConnectedStreams.scala x: 15 commits (all time) y: 119 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStreamUtils.scala x: 4 commits (all time) y: 24 lines of code flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java x: 35 commits (all time) y: 518 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/calcite/FlinkPlannerImpl.scala x: 19 commits (all time) y: 142 lines of code flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/DataGenTableSourceFactory.java x: 6 commits (all time) y: 328 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java x: 5 commits (all time) y: 457 lines of code flink-connectors/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSource.java x: 7 commits (all time) y: 243 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java x: 53 commits (all time) y: 296 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java x: 138 commits (all time) y: 565 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java x: 174 commits (all time) y: 914 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java x: 54 commits (all time) y: 790 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/BridgingSqlFunctionCallGen.scala x: 10 commits (all time) y: 247 lines of code flink-core/src/main/java/org/apache/flink/util/CollectionUtil.java x: 9 commits (all time) y: 64 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/Executor.java x: 11 commits (all time) y: 25 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java x: 57 commits (all time) y: 489 lines of code flink-python/pyflink/table/table_result.py x: 7 commits (all time) y: 19 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamUtils.java x: 5 commits (all time) y: 61 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectResultFetcher.java x: 3 commits (all time) y: 165 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableResult.java x: 5 commits (all time) y: 14 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/SelectTableSinkBase.java x: 5 commits (all time) y: 90 lines of code flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sinks/StreamSelectTableSink.java x: 6 commits (all time) y: 93 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableFactory.java x: 10 commits (all time) y: 76 lines of code flink-core/src/main/java/org/apache/flink/configuration/DelegatingConfiguration.java x: 13 commits (all time) y: 295 lines of code flink-metrics/flink-metrics-influxdb/src/main/java/org/apache/flink/metrics/influxdb/InfluxdbReporter.java x: 7 commits (all time) y: 117 lines of code flink-core/src/main/java/org/apache/flink/configuration/Configuration.java x: 31 commits (all time) y: 518 lines of code flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java x: 22 commits (all time) y: 301 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java x: 5 commits (all time) y: 362 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java x: 4 commits (all time) y: 266 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala x: 27 commits (all time) y: 243 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/TableSourceTable.scala x: 14 commits (all time) y: 68 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/LegacyTypeInfoDataTypeConverter.java x: 11 commits (all time) y: 297 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/StreamSelectTableSink.java x: 5 commits (all time) y: 28 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CorrelateCodeGenerator.scala x: 10 commits (all time) y: 312 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonLookupJoin.scala x: 12 commits (all time) y: 620 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPythonCalc.scala x: 12 commits (all time) y: 105 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecExchange.scala x: 6 commits (all time) y: 148 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecExpand.scala x: 6 commits (all time) y: 73 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecHashJoin.scala x: 8 commits (all time) y: 205 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecOverAggregate.scala x: 8 commits (all time) y: 516 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecRank.scala x: 7 commits (all time) y: 228 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecTableSourceScan.scala x: 15 commits (all time) y: 57 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecDeduplicate.scala x: 9 commits (all time) y: 129 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecGroupAggregate.scala x: 7 commits (all time) y: 142 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecGroupWindowAggregateBase.scala x: 5 commits (all time) y: 259 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecIntervalJoin.scala x: 2 commits (all time) y: 285 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecJoin.scala x: 6 commits (all time) y: 173 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecMatch.scala x: 10 commits (all time) y: 372 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecSort.scala x: 7 commits (all time) y: 88 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecSortLimit.scala x: 7 commits (all time) y: 165 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala x: 19 commits (all time) y: 55 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTemporalSort.scala x: 6 commits (all time) y: 131 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecWatermarkAssigner.scala x: 9 commits (all time) y: 80 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/util/DataFormatConverters.java x: 5 commits (all time) y: 1087 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemLookupFunction.java x: 4 commits (all time) y: 151 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/GroupAggFunction.java x: 6 commits (all time) y: 120 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/MiniBatchGroupAggFunction.java x: 6 commits (all time) y: 127 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/deduplicate/DeduplicateKeepLastRowFunction.java x: 6 commits (all time) y: 44 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/stream/AbstractStreamingJoinOperator.java x: 4 commits (all time) y: 163 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/stream/StreamingJoinOperator.java x: 5 commits (all time) y: 185 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/stream/state/JoinRecordStateViews.java x: 4 commits (all time) y: 182 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/stream/state/OuterJoinRecordStateViews.java x: 4 commits (all time) y: 255 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/temporal/TemporalRowTimeJoinOperator.java x: 5 commits (all time) y: 269 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/AbstractTopNFunction.java x: 5 commits (all time) y: 234 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/RetractableTopNFunction.java x: 7 commits (all time) y: 366 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/types/TypeInfoDataTypeConverter.java x: 11 commits (all time) y: 151 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalTypeInfo.java x: 1 commits (all time) y: 96 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RowDataSerializer.java x: 3 commits (all time) y: 281 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java x: 8 commits (all time) y: 440 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java x: 2 commits (all time) y: 233 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/TypeInferenceUtil.java x: 15 commits (all time) y: 349 lines of code flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java x: 28 commits (all time) y: 212 lines of code flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/SqlCreateHiveTable.java x: 3 commits (all time) y: 412 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java x: 14 commits (all time) y: 1168 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/InputTypeStrategies.java x: 11 commits (all time) y: 120 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/TypeStrategies.java x: 13 commits (all time) y: 260 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/PlannerExpressionConverter.scala x: 20 commits (all time) y: 329 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/PlannerContext.java x: 16 commits (all time) y: 217 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/FlinkCalciteCatalogReader.java x: 8 commits (all time) y: 196 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Table.java x: 21 commits (all time) y: 107 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/utils/OperationTreeBuilder.java x: 10 commits (all time) y: 687 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java x: 61 commits (all time) y: 206 lines of code flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java x: 8 commits (all time) y: 229 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/ExtractionUtils.java x: 5 commits (all time) y: 611 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdSize.scala x: 4 commits (all time) y: 340 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveTableUtil.java x: 18 commits (all time) y: 358 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java x: 10 commits (all time) y: 405 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/RowType.java x: 8 commits (all time) y: 219 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/SqlUnnestUtils.java x: 1 commits (all time) y: 135 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java x: 115 commits (all time) y: 788 lines of code flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSinkFactory.java x: 5 commits (all time) y: 139 lines of code flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java x: 5 commits (all time) y: 230 lines of code flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/internal/StreamTableEnvironmentImpl.java x: 2 commits (all time) y: 320 lines of code flink-table/flink-table-api-scala-bridge/src/main/scala/org/apache/flink/table/api/bridge/scala/internal/StreamTableEnvironmentImpl.scala x: 2 commits (all time) y: 272 lines of code flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/table/Kafka011DynamicSink.java x: 4 commits (all time) y: 60 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java x: 15 commits (all time) y: 287 lines of code flink-python/src/main/java/org/apache/flink/python/env/beam/ProcessPythonEnvironmentManager.java x: 1 commits (all time) y: 259 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionMappingExtractor.java x: 3 commits (all time) y: 373 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java x: 25 commits (all time) y: 328 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java x: 31 commits (all time) y: 97 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterGateway.java x: 52 commits (all time) y: 90 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java x: 44 commits (all time) y: 383 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultSchedulerFactory.java x: 19 commits (all time) y: 114 lines of code flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java x: 56 commits (all time) y: 470 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/sql/FlinkSqlOperatorTable.java x: 25 commits (all time) y: 829 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala x: 8 commits (all time) y: 494 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java x: 14 commits (all time) y: 383 lines of code flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java x: 19 commits (all time) y: 176 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyConfig.java x: 27 commits (all time) y: 123 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyConnectionManager.java x: 25 commits (all time) y: 57 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableConfig.java x: 17 commits (all time) y: 96 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java x: 24 commits (all time) y: 184 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/ReporterSetup.java x: 11 commits (all time) y: 248 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java x: 86 commits (all time) y: 494 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackendBuilder.java x: 18 commits (all time) y: 441 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBCachingPriorityQueueSet.java x: 6 commits (all time) y: 351 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java x: 33 commits (all time) y: 485 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala x: 43 commits (all time) y: 291 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java x: 7 commits (all time) y: 7 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/checkpoint/CheckpointedFunction.java x: 10 commits (all time) y: 12 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java x: 4 commits (all time) y: 226 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryArrayData.java x: 3 commits (all time) y: 446 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java x: 33 commits (all time) y: 374 lines of code flink-mesos/src/main/scala/org/apache/flink/mesos/scheduler/LaunchCoordinator.scala x: 9 commits (all time) y: 221 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosUtils.java x: 9 commits (all time) y: 105 lines of code flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java x: 75 commits (all time) y: 331 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/module/ModuleManager.java x: 7 commits (all time) y: 65 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/delegation/PlannerBase.scala x: 27 commits (all time) y: 291 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputChannel.java x: 30 commits (all time) y: 140 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGate.java x: 34 commits (all time) y: 47 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java x: 94 commits (all time) y: 561 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java x: 45 commits (all time) y: 210 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierAligner.java x: 12 commits (all time) y: 225 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierHandler.java x: 29 commits (all time) y: 82 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliTableauResultView.java x: 5 commits (all time) y: 170 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableResultImpl.java x: 8 commits (all time) y: 171 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java x: 7 commits (all time) y: 271 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessWindowFunction.java x: 7 commits (all time) y: 21 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/function/ProcessWindowFunction.scala x: 6 commits (all time) y: 23 lines of code flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java x: 23 commits (all time) y: 280 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/DynamicTableSink.java x: 6 commits (all time) y: 32 lines of code flink-core/src/main/java/org/apache/flink/configuration/JobManagerOptions.java x: 49 commits (all time) y: 211 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java x: 110 commits (all time) y: 772 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputProcessorUtil.java x: 35 commits (all time) y: 94 lines of code flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java x: 92 commits (all time) y: 743 lines of code flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java x: 107 commits (all time) y: 507 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java x: 41 commits (all time) y: 112 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ProgramDeployer.java x: 11 commits (all time) y: 50 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java x: 23 commits (all time) y: 457 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/catalog/DatabaseCalciteSchema.java x: 16 commits (all time) y: 122 lines of code flink-clients/src/main/java/org/apache/flink/client/cli/AbstractCustomCommandLine.java x: 14 commits (all time) y: 80 lines of code flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java x: 52 commits (all time) y: 370 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java x: 24 commits (all time) y: 225 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java x: 27 commits (all time) y: 225 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java x: 13 commits (all time) y: 82 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistryImpl.java x: 16 commits (all time) y: 340 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/GenerateUtils.scala x: 15 commits (all time) y: 729 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java x: 13 commits (all time) y: 194 lines of code flink-java/src/main/java/org/apache/flink/api/java/CollectionEnvironment.java x: 16 commits (all time) y: 19 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliStrings.java x: 12 commits (all time) y: 192 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBOptions.java x: 20 commits (all time) y: 86 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java x: 39 commits (all time) y: 506 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/reader/AbstractRecordReader.java x: 23 commits (all time) y: 81 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierTracker.java x: 9 commits (all time) y: 146 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointedInputGate.java x: 24 commits (all time) y: 116 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java x: 21 commits (all time) y: 194 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java x: 44 commits (all time) y: 49 lines of code flink-connectors/flink-connector-hbase/src/main/java/org/apache/flink/connector/hbase/util/HBaseSerde.java x: 4 commits (all time) y: 345 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/KeyGroupPartitionedPriorityQueue.java x: 5 commits (all time) y: 199 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java x: 21 commits (all time) y: 508 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOptions.java x: 11 commits (all time) y: 144 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java x: 16 commits (all time) y: 401 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/Environment.java x: 7 commits (all time) y: 192 lines of code flink-core/src/main/java/org/apache/flink/configuration/MetricOptions.java x: 17 commits (all time) y: 110 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocator.java x: 12 commits (all time) y: 72 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultExecutionSlotAllocatorFactory.java x: 4 commits (all time) y: 13 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java x: 120 commits (all time) y: 668 lines of code flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaInternalProducer.java x: 11 commits (all time) y: 272 lines of code flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java x: 40 commits (all time) y: 941 lines of code flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java x: 28 commits (all time) y: 1095 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java x: 9 commits (all time) y: 267 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/read/HiveContinuousMonitoringFunction.java x: 6 commits (all time) y: 262 lines of code flink-dist/src/main/assemblies/bin.xml x: 72 commits (all time) y: 237 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PartitionPathUtils.java x: 3 commits (all time) y: 227 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java x: 51 commits (all time) y: 37 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferBuilder.java x: 13 commits (all time) y: 121 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/BroadcastRecordWriter.java x: 11 commits (all time) y: 101 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferConsumer.java x: 12 commits (all time) y: 97 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingProcessingTimeWindows.java x: 13 commits (all time) y: 64 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerConfiguration.java x: 30 commits (all time) y: 172 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java x: 11 commits (all time) y: 316 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java x: 6 commits (all time) y: 294 lines of code flink-clients/src/main/java/org/apache/flink/client/program/OptimizerPlanEnvironment.java x: 13 commits (all time) y: 30 lines of code flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgramUtils.java x: 17 commits (all time) y: 179 lines of code flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java x: 84 commits (all time) y: 624 lines of code flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala x: 42 commits (all time) y: 279 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulerImpl.java x: 14 commits (all time) y: 421 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotProvider.java x: 9 commits (all time) y: 49 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java x: 45 commits (all time) y: 53 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java x: 23 commits (all time) y: 550 lines of code flink-external-resources/flink-external-resource-gpu/src/main/java/org/apache/flink/externalresource/gpu/GPUDriver.java x: 4 commits (all time) y: 106 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalog.java x: 9 commits (all time) y: 289 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java x: 1 commits (all time) y: 262 lines of code flink-table/flink-sql-parser-hive/src/main/java/org/apache/flink/sql/parser/hive/ddl/HiveDDLUtils.java x: 4 commits (all time) y: 315 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java x: 24 commits (all time) y: 480 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/BaseExpressions.java x: 2 commits (all time) y: 533 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LogicalTypeRoot.java x: 8 commits (all time) y: 110 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeMerging.java x: 1 commits (all time) y: 560 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/expressions/PlannerExpressionParserImpl.scala x: 5 commits (all time) y: 538 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/PlannerExpressionConverter.scala x: 30 commits (all time) y: 674 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/PlannerExpressionParserImpl.scala x: 18 commits (all time) y: 538 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/KubernetesSessionCli.java x: 9 commits (all time) y: 140 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriterImpl.java x: 16 commits (all time) y: 142 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateWriter.java x: 11 commits (all time) y: 83 lines of code flink-core/src/main/java/org/apache/flink/util/FileUtils.java x: 20 commits (all time) y: 395 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/util/config/memory/taskmanager/TaskExecutorFlinkMemoryUtils.java x: 3 commits (all time) y: 234 lines of code flink-dist/src/main/assemblies/opt.xml x: 44 commits (all time) y: 120 lines of code flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java x: 10 commits (all time) y: 131 lines of code flink-formats/flink-hadoop-bulk/src/main/java/org/apache/flink/formats/hadoop/bulk/HadoopPathBasedPartFileWriter.java x: 3 commits (all time) y: 212 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/TopNBuffer.java x: 3 commits (all time) y: 146 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java x: 8 commits (all time) y: 304 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/channel/ChannelStateCheckpointWriter.java x: 6 commits (all time) y: 189 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java x: 4 commits (all time) y: 243 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdColumnUniqueness.scala x: 4 commits (all time) y: 573 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdModifiedMonotonicity.scala x: 9 commits (all time) y: 477 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/IntervalJoinUtil.scala x: 1 commits (all time) y: 334 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java x: 33 commits (all time) y: 129 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdColumnInterval.scala x: 7 commits (all time) y: 484 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/ColumnIntervalUtil.scala x: 2 commits (all time) y: 228 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelOptUtil.scala x: 11 commits (all time) y: 261 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java x: 14 commits (all time) y: 52 lines of code flink-python/pyflink/java_gateway.py x: 20 commits (all time) y: 113 lines of code flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java x: 51 commits (all time) y: 590 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java x: 59 commits (all time) y: 447 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala x: 53 commits (all time) y: 432 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver/rules/ResolveCallByArgumentsRule.java x: 14 commits (all time) y: 293 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeCasts.java x: 5 commits (all time) y: 347 lines of code tools/maven/suppressions.xml x: 35 commits (all time) y: 34 lines of code flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java x: 48 commits (all time) y: 70 lines of code flink-core/src/main/java/org/apache/flink/api/common/functions/util/AbstractRuntimeUDFContext.java x: 32 commits (all time) y: 178 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java x: 48 commits (all time) y: 204 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java x: 12 commits (all time) y: 179 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java x: 33 commits (all time) y: 156 lines of code flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java x: 27 commits (all time) y: 690 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java x: 42 commits (all time) y: 396 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java x: 24 commits (all time) y: 219 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/StreamPlanner.scala x: 31 commits (all time) y: 263 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectSinkFunction.java x: 5 commits (all time) y: 338 lines of code flink-python/pyflink/table/__init__.py x: 23 commits (all time) y: 47 lines of code flink-python/pyflink/table/descriptors.py x: 12 commits (all time) y: 607 lines of code flink-python/pyflink/table/types.py x: 22 commits (all time) y: 1495 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/CreditBasedPartitionRequestClientHandler.java x: 9 commits (all time) y: 257 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailboxImpl.java x: 16 commits (all time) y: 251 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/MailboxProcessor.java x: 20 commits (all time) y: 211 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/TaskMailbox.java x: 12 commits (all time) y: 37 lines of code flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvFormatFactory.java x: 3 commits (all time) y: 189 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/Executors.java x: 9 commits (all time) y: 31 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java x: 62 commits (all time) y: 368 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java x: 35 commits (all time) y: 193 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.java x: 25 commits (all time) y: 74 lines of code flink-clients/src/main/java/org/apache/flink/client/deployment/application/executors/EmbeddedExecutor.java x: 7 commits (all time) y: 93 lines of code flink-core/src/main/java/org/apache/flink/configuration/AkkaOptions.java x: 14 commits (all time) y: 198 lines of code flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java x: 203 commits (all time) y: 604 lines of code flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala x: 99 commits (all time) y: 579 lines of code flink-clients/src/main/java/org/apache/flink/client/program/ContextEnvironment.java x: 49 commits (all time) y: 113 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/StructuredType.java x: 9 commits (all time) y: 295 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ExecutionEntry.java x: 9 commits (all time) y: 278 lines of code flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java x: 16 commits (all time) y: 78 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java x: 43 commits (all time) y: 215 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer/Lockable.java x: 12 commits (all time) y: 153 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/CoGroupedStreams.java x: 26 commits (all time) y: 497 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleEnvironment.java x: 17 commits (all time) y: 257 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesConfiguration.java x: 45 commits (all time) y: 192 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java x: 22 commits (all time) y: 243 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapMapState.java x: 12 commits (all time) y: 139 lines of code flink-core/src/main/java/org/apache/flink/util/MathUtils.java x: 12 commits (all time) y: 90 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/WorkerSpecContainerResourceAdapter.java x: 8 commits (all time) y: 181 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/RetrievableStreamStateHandle.java x: 8 commits (all time) y: 47 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/StreamStateHandle.java x: 5 commits (all time) y: 8 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FileStateHandle.java x: 12 commits (all time) y: 61 lines of code flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryBase.java x: 17 commits (all time) y: 304 lines of code flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sinks/CsvTableSinkFactoryBase.java x: 10 commits (all time) y: 113 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java x: 11 commits (all time) y: 945 lines of code flink-core/src/main/java/org/apache/flink/api/connector/source/SourceReaderContext.java x: 4 commits (all time) y: 8 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSource.java x: 13 commits (all time) y: 50 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeService.java x: 11 commits (all time) y: 11 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SystemProcessingTimeService.java x: 21 commits (all time) y: 208 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TestProcessingTimeService.java x: 18 commits (all time) y: 173 lines of code flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java x: 30 commits (all time) y: 292 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/SingleOutputStreamOperator.java x: 32 commits (all time) y: 154 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/ProcessingTimeCallback.java x: 6 commits (all time) y: 7 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java x: 13 commits (all time) y: 229 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/ApiExpressionUtils.java x: 25 commits (all time) y: 260 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamInputProcessor.java x: 45 commits (all time) y: 13 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessor.java x: 6 commits (all time) y: 228 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTwoInputProcessor.java x: 48 commits (all time) y: 296 lines of code flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/AbstractServerHandler.java x: 8 commits (all time) y: 188 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningWrapper.java x: 6 commits (all time) y: 247 lines of code flink-jepsen/src/jepsen/flink/db.clj x: 28 commits (all time) y: 279 lines of code flink-metrics/flink-metrics-datadog/src/main/java/org/apache/flink/metrics/datadog/DatadogHttpReporter.java x: 14 commits (all time) y: 153 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureReason.java x: 10 commits (all time) y: 41 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/RpcTaskManagerGateway.java x: 18 commits (all time) y: 86 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGateway.java x: 40 commits (all time) y: 84 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/AbstractInvokable.java x: 35 commits (all time) y: 80 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/TaskLocalStateStoreImpl.java x: 8 commits (all time) y: 263 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java x: 85 commits (all time) y: 279 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksFullSnapshotStrategy.java x: 8 commits (all time) y: 319 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java x: 10 commits (all time) y: 380 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java x: 21 commits (all time) y: 553 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java x: 107 commits (all time) y: 347 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/conversion/StructuredObjectConverter.java x: 2 commits (all time) y: 204 lines of code flink-core/src/main/java/org/apache/flink/core/memory/HybridMemorySegment.java x: 15 commits (all time) y: 252 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java x: 40 commits (all time) y: 420 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java x: 64 commits (all time) y: 582 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/RowTypeInfo.java x: 7 commits (all time) y: 300 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java x: 3 commits (all time) y: 364 lines of code flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/input/KeyedStateInputFormat.java x: 7 commits (all time) y: 172 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java x: 91 commits (all time) y: 396 lines of code flink-jepsen/src/jepsen/flink/utils.clj x: 12 commits (all time) y: 114 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BucketStateSerializer.java x: 6 commits (all time) y: 159 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/BulkPartWriter.java x: 7 commits (all time) y: 33 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/OutputStreamBasedPartFileWriter.java x: 2 commits (all time) y: 214 lines of code flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaShuffleFetcher.java x: 2 commits (all time) y: 201 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/schema/LegacyCatalogSourceTable.scala x: 2 commits (all time) y: 175 lines of code flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java x: 22 commits (all time) y: 172 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPeriodicWatermarks.java x: 9 commits (all time) y: 9 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/AssignerWithPunctuatedWatermarks.java x: 8 commits (all time) y: 8 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShim.java x: 20 commits (all time) y: 67 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV100.java x: 14 commits (all time) y: 307 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java x: 65 commits (all time) y: 626 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java x: 57 commits (all time) y: 543 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java x: 28 commits (all time) y: 267 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java x: 32 commits (all time) y: 322 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/execution/Environment.java x: 44 commits (all time) y: 60 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java x: 113 commits (all time) y: 717 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java x: 23 commits (all time) y: 897 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSinkTask.java x: 38 commits (all time) y: 271 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedDriver.java x: 19 commits (all time) y: 75 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/RuntimeEnvironment.java x: 35 commits (all time) y: 235 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala x: 65 commits (all time) y: 296 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java x: 32 commits (all time) y: 426 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/Checkpoints.java x: 14 commits (all time) y: 213 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java x: 7 commits (all time) y: 438 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniClusterConfiguration.java x: 26 commits (all time) y: 121 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/RowData.java x: 5 commits (all time) y: 176 lines of code flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataDeserializationSchema.java x: 3 commits (all time) y: 340 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java x: 10 commits (all time) y: 206 lines of code flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcTableSource.java x: 4 commits (all time) y: 364 lines of code flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java x: 7 commits (all time) y: 419 lines of code flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java x: 92 commits (all time) y: 38 lines of code flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java x: 36 commits (all time) y: 133 lines of code flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java x: 68 commits (all time) y: 575 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java x: 27 commits (all time) y: 73 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryStringData.java x: 2 commits (all time) y: 584 lines of code flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java x: 12 commits (all time) y: 149 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java x: 44 commits (all time) y: 319 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java x: 40 commits (all time) y: 214 lines of code flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/FlinkKafkaProducer.java x: 10 commits (all time) y: 267 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/WebSubmissionExtension.java x: 16 commits (all time) y: 103 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.scala x: 10 commits (all time) y: 526 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecSink.scala x: 10 commits (all time) y: 54 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecSink.scala x: 11 commits (all time) y: 70 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala x: 8 commits (all time) y: 238 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/ExecNodePlanDumper.scala x: 6 commits (all time) y: 282 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkRelBuilder.scala x: 14 commits (all time) y: 134 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java x: 13 commits (all time) y: 173 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java x: 16 commits (all time) y: 42 lines of code flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlTableLike.java x: 3 commits (all time) y: 134 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/EventSerializer.java x: 21 commits (all time) y: 229 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java x: 34 commits (all time) y: 372 lines of code flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BoundedStreamTask.java x: 9 commits (all time) y: 87 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableImpl.java x: 13 commits (all time) y: 782 lines of code flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java x: 31 commits (all time) y: 454 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveMetastoreClientWrapper.java x: 12 commits (all time) y: 211 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/BatchTableEnvImpl.scala x: 22 commits (all time) y: 407 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/FlinkRuleSets.scala x: 19 commits (all time) y: 169 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/calcite/RelTimeIndicatorConverter.scala x: 7 commits (all time) y: 447 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobVertex.java x: 24 commits (all time) y: 278 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartition.java x: 61 commits (all time) y: 233 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/JobLeaderService.java x: 23 commits (all time) y: 16 lines of code flink-python/pyflink/find_flink_home.py x: 8 commits (all time) y: 40 lines of code flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerBase.java x: 15 commits (all time) y: 243 lines of code flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java x: 29 commits (all time) y: 716 lines of code flink-formats/flink-csv/src/main/java/org/apache/flink/formats/csv/CsvRowDataSerializationSchema.java x: 1 commits (all time) y: 352 lines of code flink-core/src/main/java/org/apache/flink/util/StringUtils.java x: 18 commits (all time) y: 160 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/ValueLiteralExpression.java x: 18 commits (all time) y: 227 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/EncodingUtils.java x: 6 commits (all time) y: 232 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerGateway.java x: 44 commits (all time) y: 68 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnJobClusterEntrypoint.java x: 22 commits (all time) y: 50 lines of code flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterDescriptor.java x: 15 commits (all time) y: 20 lines of code flink-clients/src/main/java/org/apache/flink/client/deployment/StandaloneClusterDescriptor.java x: 17 commits (all time) y: 55 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherGateway.java x: 17 commits (all time) y: 26 lines of code flink-clients/src/main/java/org/apache/flink/client/cli/ProgramOptions.java x: 20 commits (all time) y: 127 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java x: 7 commits (all time) y: 395 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointingStatistics.java x: 5 commits (all time) y: 291 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/ResultPartitionWriter.java x: 33 commits (all time) y: 27 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java x: 24 commits (all time) y: 78 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/converter/ExpressionConverter.java x: 11 commits (all time) y: 268 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/LongHashJoinGenerator.scala x: 7 commits (all time) y: 316 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/MatchCodeGenerator.scala x: 4 commits (all time) y: 580 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/BuiltInMethods.scala x: 14 commits (all time) y: 331 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/StringCallGen.scala x: 10 commits (all time) y: 600 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/sort/SortCodeGenerator.scala x: 4 commits (all time) y: 305 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelMdUtil.scala x: 2 commits (all time) y: 476 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/RexNodeExtractor.scala x: 12 commits (all time) y: 310 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/StreamTableSourceScan.scala x: 10 commits (all time) y: 158 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/SqlDateTimeUtils.java x: 18 commits (all time) y: 1039 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/SqlFunctionUtils.java x: 12 commits (all time) y: 885 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/BinaryHashBucketArea.java x: 5 commits (all time) y: 411 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/BinaryHashPartition.java x: 6 commits (all time) y: 388 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/BinaryHashTable.java x: 8 commits (all time) y: 382 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/LongHashPartition.java x: 6 commits (all time) y: 692 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/BinaryExternalSorter.java x: 5 commits (all time) y: 689 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/ResettableExternalBuffer.java x: 5 commits (all time) y: 501 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/binary/BinaryStringDataUtil.java x: 1 commits (all time) y: 812 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/BinaryRowDataSerializer.java x: 1 commits (all time) y: 285 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java x: 1 commits (all time) y: 788 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/LocalZonedTimestampType.java x: 8 commits (all time) y: 115 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferProvider.java x: 13 commits (all time) y: 13 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactory.java x: 24 commits (all time) y: 175 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/NettyShuffleEnvironmentConfiguration.java x: 21 commits (all time) y: 283 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/functions/hive/conversion/HiveInspectors.java x: 21 commits (all time) y: 363 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java x: 38 commits (all time) y: 361 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerRuntimeServices.java x: 10 commits (all time) y: 36 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/StandaloneSessionClusterEntrypoint.java x: 16 commits (all time) y: 34 lines of code flink-dist/src/main/resources/flink-conf.yaml x: 52 commits (all time) y: 7 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java x: 57 commits (all time) y: 400 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointStatsTracker.java x: 9 commits (all time) y: 235 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBuffer.java x: 10 commits (all time) y: 444 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java x: 27 commits (all time) y: 201 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java x: 17 commits (all time) y: 16 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java x: 32 commits (all time) y: 483 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/EnvironmentSettings.java x: 9 commits (all time) y: 117 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/IntermediateResultPartition.java x: 10 commits (all time) y: 81 lines of code flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java x: 45 commits (all time) y: 390 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperatorBuilder.java x: 4 commits (all time) y: 275 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherFactory.java x: 13 commits (all time) y: 9 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/JobDispatcherFactory.java x: 16 commits (all time) y: 24 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/SessionDispatcherFactory.java x: 14 commits (all time) y: 17 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/StandaloneDispatcher.java x: 29 commits (all time) y: 17 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/HighAvailabilityServicesUtils.java x: 23 commits (all time) y: 198 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceUtils.java x: 19 commits (all time) y: 217 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java x: 46 commits (all time) y: 404 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeParser.java x: 6 commits (all time) y: 755 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/SupervisorActor.java x: 3 commits (all time) y: 264 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/resolver/ExpressionResolver.java x: 9 commits (all time) y: 308 lines of code flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/QueryOperationConverter.java x: 21 commits (all time) y: 452 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/LazyFromSourcesSchedulingStrategy.java x: 14 commits (all time) y: 106 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java x: 37 commits (all time) y: 182 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BoundedBlockingSubpartition.java x: 10 commits (all time) y: 178 lines of code flink-metrics/flink-metrics-statsd/src/main/java/org/apache/flink/metrics/statsd/StatsDReporter.java x: 11 commits (all time) y: 175 lines of code flink-java/src/main/java/org/apache/flink/api/java/Utils.java x: 28 commits (all time) y: 223 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala x: 5 commits (all time) y: 400 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala x: 6 commits (all time) y: 278 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamTaskStateInitializerImpl.java x: 19 commits (all time) y: 461 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java x: 17 commits (all time) y: 41 lines of code flink-python/pyflink/table/table_config.py x: 21 commits (all time) y: 80 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/RoundRobinOperatorStateRepartitioner.java x: 9 commits (all time) y: 248 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java x: 40 commits (all time) y: 450 lines of code flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/ParquetSchemaConverter.java x: 4 commits (all time) y: 435 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/memory/MemoryStateBackend.java x: 32 commits (all time) y: 137 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBNativeMetricOptions.java x: 5 commits (all time) y: 300 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcActor.java x: 36 commits (all time) y: 440 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/catalog/BasicOperatorTable.scala x: 3 commits (all time) y: 315 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosJobClusterEntrypoint.java x: 24 commits (all time) y: 83 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java x: 45 commits (all time) y: 236 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimeServiceManager.java x: 14 commits (all time) y: 170 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java x: 31 commits (all time) y: 28 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java x: 18 commits (all time) y: 69 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationTail.java x: 15 commits (all time) y: 91 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java x: 32 commits (all time) y: 602 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java x: 46 commits (all time) y: 170 lines of code flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java x: 42 commits (all time) y: 1255 lines of code flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java x: 2 commits (all time) y: 2555 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/util/python/PythonTableUtils.scala x: 8 commits (all time) y: 333 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/FunctionGenerator.scala x: 9 commits (all time) y: 669 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java x: 30 commits (all time) y: 211 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java x: 13 commits (all time) y: 139 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler/ScheduledUnit.java x: 11 commits (all time) y: 73 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/ExpressionBridge.scala x: 10 commits (all time) y: 6 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCheckpointIDCounter.java x: 18 commits (all time) y: 91 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/zookeeper/ZooKeeperHaServices.java x: 15 commits (all time) y: 175 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/leaderelection/ZooKeeperLeaderElectionService.java x: 19 commits (all time) y: 314 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java x: 35 commits (all time) y: 231 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/ZooKeeperStateHandleStore.java x: 21 commits (all time) y: 243 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/SubtaskState.java x: 18 commits (all time) y: 130 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/hooks/MasterHooks.java x: 9 commits (all time) y: 223 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/logical/LogicalWindowAggregateRuleBase.scala x: 6 commits (all time) y: 261 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaInvocationHandler.java x: 21 commits (all time) y: 259 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java x: 33 commits (all time) y: 150 lines of code flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java x: 16 commits (all time) y: 166 lines of code flink-core/src/main/java/org/apache/flink/configuration/HighAvailabilityOptions.java x: 19 commits (all time) y: 133 lines of code flink-core/src/main/java/org/apache/flink/configuration/RestOptions.java x: 21 commits (all time) y: 90 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/logical/PushFilterIntoTableSourceScanRule.scala x: 10 commits (all time) y: 105 lines of code flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java x: 28 commits (all time) y: 238 lines of code flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka010TableSource.java x: 12 commits (all time) y: 50 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CepOperator.java x: 9 commits (all time) y: 365 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java x: 15 commits (all time) y: 338 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarPlanHandler.java x: 15 commits (all time) y: 70 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkAggregateExpandDistinctAggregatesRule.java x: 3 commits (all time) y: 599 lines of code flink-java/src/main/java/org/apache/flink/api/java/DataSet.java x: 80 commits (all time) y: 472 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java x: 29 commits (all time) y: 116 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnSessionClusterEntrypoint.java x: 18 commits (all time) y: 46 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/metadata/FlinkRelMdCollation.java x: 1 commits (all time) y: 384 lines of code flink-core/src/main/java/org/apache/flink/types/StringValue.java x: 18 commits (all time) y: 529 lines of code flink-filesystems/flink-s3-fs-hadoop/src/main/java/org/apache/flink/fs/s3hadoop/S3FileSystemFactory.java x: 11 commits (all time) y: 59 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala x: 5 commits (all time) y: 1400 lines of code flink-java/src/main/java/org/apache/flink/api/java/io/CsvInputFormat.java x: 14 commits (all time) y: 98 lines of code flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java x: 5 commits (all time) y: 424 lines of code flink-java/src/main/java/org/apache/flink/api/java/LocalEnvironment.java x: 25 commits (all time) y: 31 lines of code flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java x: 30 commits (all time) y: 64 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java x: 30 commits (all time) y: 35 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java x: 22 commits (all time) y: 272 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorToResourceManagerConnection.java x: 17 commits (all time) y: 80 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java x: 32 commits (all time) y: 454 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java x: 24 commits (all time) y: 17 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala x: 4 commits (all time) y: 1186 lines of code flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java x: 20 commits (all time) y: 95 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java x: 21 commits (all time) y: 558 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java x: 13 commits (all time) y: 56 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBReducingState.java x: 13 commits (all time) y: 106 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java x: 61 commits (all time) y: 268 lines of code flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java x: 18 commits (all time) y: 232 lines of code flink-core/src/main/java/org/apache/flink/api/common/accumulators/AccumulatorHelper.java x: 17 commits (all time) y: 139 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/SynchronousChainedCombineDriver.java x: 15 commits (all time) y: 155 lines of code flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcBatchReader.java x: 1 commits (all time) y: 1117 lines of code flink-core/src/main/java/org/apache/flink/util/NetUtils.java x: 18 commits (all time) y: 246 lines of code flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java x: 21 commits (all time) y: 22 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdDistinctRowCount.scala x: 3 commits (all time) y: 537 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/calls/FunctionGenerator.scala x: 2 commits (all time) y: 676 lines of code flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java x: 17 commits (all time) y: 346 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarListHandler.java x: 19 commits (all time) y: 124 lines of code flink-java/src/main/java/org/apache/flink/api/java/utils/ParameterTool.java x: 25 commits (all time) y: 170 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureRequestCoordinator.java x: 1 commits (all time) y: 223 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassSerializer.scala x: 19 commits (all time) y: 99 lines of code flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteSkipListStateMap.java x: 2 commits (all time) y: 939 lines of code flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java x: 21 commits (all time) y: 441 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateMap.java x: 2 commits (all time) y: 600 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.java x: 15 commits (all time) y: 228 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlMapState.java x: 9 commits (all time) y: 155 lines of code flink-clients/src/main/java/org/apache/flink/client/cli/CustomCommandLine.java x: 12 commits (all time) y: 18 lines of code flink-core/src/main/java/org/apache/flink/api/common/Plan.java x: 26 commits (all time) y: 137 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala x: 25 commits (all time) y: 276 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedLeaderService.java x: 9 commits (all time) y: 382 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/util/LeaderRetrievalUtils.java x: 22 commits (all time) y: 75 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunner.java x: 54 commits (all time) y: 11 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/SessionClusterEntrypoint.java x: 27 commits (all time) y: 32 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpanningRecordSerializer.java x: 31 commits (all time) y: 58 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java x: 39 commits (all time) y: 193 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/blob/FileSystemBlobStore.java x: 23 commits (all time) y: 115 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/HighAvailabilityServices.java x: 23 commits (all time) y: 53 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java x: 13 commits (all time) y: 143 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/ClosureCleaner.scala x: 14 commits (all time) y: 382 lines of code flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/linalg/SparseVector.java x: 1 commits (all time) y: 438 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TypeStringUtils.java x: 3 commits (all time) y: 397 lines of code flink-metrics/flink-metrics-prometheus/src/main/java/org/apache/flink/metrics/prometheus/AbstractPrometheusReporter.java x: 3 commits (all time) y: 254 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializerSnapshot.java x: 5 commits (all time) y: 315 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializer.java x: 19 commits (all time) y: 806 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/SelectivityEstimator.scala x: 2 commits (all time) y: 788 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/SubQueryDecorrelator.java x: 1 commits (all time) y: 983 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/AggCallSelectivityEstimator.scala x: 1 commits (all time) y: 311 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdPopulationSize.scala x: 1 commits (all time) y: 315 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueGroups.scala x: 1 commits (all time) y: 357 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java x: 1 commits (all time) y: 673 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/JobLeaderIdService.java x: 9 commits (all time) y: 199 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/DeweyNumber.java x: 10 commits (all time) y: 167 lines of code flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java x: 12 commits (all time) y: 321 lines of code flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java x: 38 commits (all time) y: 447 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/RegisteredKeyValueStateBackendMetaInfo.java x: 13 commits (all time) y: 190 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java x: 82 commits (all time) y: 649 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/util/MesosArtifactServer.java x: 14 commits (all time) y: 253 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java x: 28 commits (all time) y: 246 lines of code flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala x: 17 commits (all time) y: 485 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala x: 76 commits (all time) y: 781 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/ConnectionManager.java x: 12 commits (all time) y: 9 lines of code flink-runtime-web/web-dashboard/src/app/share/common/dagre/dagre.component.ts x: 1 commits (all time) y: 278 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/KeyedStateBackend.java x: 15 commits (all time) y: 33 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/SqlLikeUtils.java x: 1 commits (all time) y: 244 lines of code flink-java/src/main/java/org/apache/flink/api/java/functions/FunctionAnnotation.java x: 14 commits (all time) y: 124 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/CoGroupOperator.java x: 33 commits (all time) y: 393 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/CrossOperator.java x: 28 commits (all time) y: 534 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/FilterOperator.java x: 13 commits (all time) y: 33 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/FlatMapOperator.java x: 17 commits (all time) y: 35 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/JoinOperator.java x: 46 commits (all time) y: 878 lines of code flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java x: 38 commits (all time) y: 600 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedInputView.java x: 4 commits (all time) y: 388 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractStateBackend.java x: 30 commits (all time) y: 43 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/JoinedStreams.java x: 16 commits (all time) y: 232 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java x: 46 commits (all time) y: 776 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializer.java x: 24 commits (all time) y: 23 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java x: 54 commits (all time) y: 698 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/SharedBuffer.java x: 34 commits (all time) y: 282 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimersSnapshotReaderWriters.java x: 10 commits (all time) y: 310 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlStateFactory.java x: 13 commits (all time) y: 290 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/streamrecord/StreamElementSerializer.java x: 19 commits (all time) y: 243 lines of code flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter.java x: 1 commits (all time) y: 330 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/TrySerializer.scala x: 16 commits (all time) y: 94 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java x: 18 commits (all time) y: 425 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/EnumValueSerializer.scala x: 17 commits (all time) y: 121 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/GenericArraySerializer.java x: 20 commits (all time) y: 139 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/OptionSerializer.scala x: 17 commits (all time) y: 81 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InPlaceMutableHashTable.java x: 4 commits (all time) y: 594 lines of code flink-core/src/main/java/org/apache/flink/api/common/io/FileOutputFormat.java x: 21 commits (all time) y: 169 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeInformationGen.scala x: 30 commits (all time) y: 325 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSerializationUtil.java x: 15 commits (all time) y: 171 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/package.scala x: 19 commits (all time) y: 104 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java x: 40 commits (all time) y: 786 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcService.java x: 19 commits (all time) y: 30 lines of code flink-filesystems/flink-s3-fs-base/src/main/java/org/apache/flink/fs/s3/common/writer/RecoverableMultiPartUploadImpl.java x: 6 commits (all time) y: 205 lines of code flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/OptimizerNode.java x: 7 commits (all time) y: 647 lines of code flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/PatternStream.scala x: 13 commits (all time) y: 168 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/PatternStream.java x: 17 commits (all time) y: 232 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarUploadHandler.java x: 15 commits (all time) y: 71 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala x: 20 commits (all time) y: 358 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/WindowedStream.scala x: 21 commits (all time) y: 342 lines of code flink-core/src/main/java/org/apache/flink/api/common/operators/CollectionExecutor.java x: 26 commits (all time) y: 435 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/unfinishedKeyPairOperation.scala x: 16 commits (all time) y: 88 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java x: 14 commits (all time) y: 141 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager/AsynchronousFileIOChannel.java x: 12 commits (all time) y: 279 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/JobClusterEntrypoint.java x: 26 commits (all time) y: 16 lines of code flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java x: 2 commits (all time) y: 2056 lines of code flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/core-default-shaded.xml x: 1 commits (all time) y: 2404 lines of code tools/maven/suppressions-core.xml x: 16 commits (all time) y: 63 lines of code flink-core/src/main/java/org/apache/flink/core/memory/DataInputDeserializer.java x: 3 commits (all time) y: 304 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeinfo/BasicTypeInfo.java x: 18 commits (all time) y: 194 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/linkanalysis/PageRank.java x: 6 commits (all time) y: 334 lines of code flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/TwoInputNode.java x: 7 commits (all time) y: 533 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/UnilateralSortMerger.java x: 21 commits (all time) y: 1060 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/triggers/Trigger.java x: 25 commits (all time) y: 42 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/EvictingWindowOperator.java x: 39 commits (all time) y: 314 lines of code flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala x: 20 commits (all time) y: 158 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/NormalizedKeySorter.java x: 13 commits (all time) y: 362 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapListState.java x: 15 commits (all time) y: 129 lines of code flink-core/src/main/java/org/apache/flink/core/fs/LimitedConnectionsFileSystem.java x: 4 commits (all time) y: 678 lines of code flink-java/src/main/java/org/apache/flink/api/java/io/CsvReader.java x: 23 commits (all time) y: 322 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobKey.java x: 9 commits (all time) y: 172 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeinfo/PrimitiveArrayTypeInfo.java x: 15 commits (all time) y: 147 lines of code flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/Client.java x: 5 commits (all time) y: 378 lines of code flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java x: 17 commits (all time) y: 281 lines of code flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java x: 24 commits (all time) y: 379 lines of code flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple17.java x: 4 commits (all time) y: 294 lines of code flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple19.java x: 4 commits (all time) y: 322 lines of code flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple23.java x: 4 commits (all time) y: 378 lines of code flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple25.java x: 4 commits (all time) y: 406 lines of code tools/maven/spotbugs-exclude.xml x: 3 commits (all time) y: 437 lines of code flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java x: 1 commits (all time) y: 1674 lines of code flink-filesystems/flink-swift-fs-hadoop/src/main/resources/META-INF/core-default-shaded.xml x: 1 commits (all time) y: 1978 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/broadcast/BroadcastVariableMaterialization.java x: 12 commits (all time) y: 166 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationSynchronizationSinkTask.java x: 19 commits (all time) y: 159 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeAnalyzer.scala x: 22 commits (all time) y: 391 lines of code flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java x: 18 commits (all time) y: 134 lines of code flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/GlobalProperties.java x: 5 commits (all time) y: 389 lines of code flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/Runner.java x: 10 commits (all time) y: 338 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java x: 18 commits (all time) y: 260 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/LocalClusteringCoefficient.java x: 20 commits (all time) y: 161 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/undirected/EdgeMetrics.java x: 10 commits (all time) y: 191 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java x: 28 commits (all time) y: 1249 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/gsa/GatherSumApplyIteration.java x: 10 commits (all time) y: 298 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/clustering/undirected/TriangleListing.java x: 15 commits (all time) y: 220 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/similarity/JaccardIndex.java x: 16 commits (all time) y: 310 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/pregel/VertexCentricIteration.java x: 8 commits (all time) y: 291 lines of code flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/transform/GraphKeyTypeTransform.java x: 1 commits (all time) y: 564 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/AggregateOperator.java x: 20 commits (all time) y: 190 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/DistinctOperator.java x: 26 commits (all time) y: 94 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/GroupCombineOperator.java x: 10 commits (all time) y: 142 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/PartitionOperator.java x: 17 commits (all time) y: 153 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/ProjectOperator.java x: 18 commits (all time) y: 263 lines of code flink-java/src/main/java/org/apache/flink/api/java/functions/SemanticPropUtil.java x: 15 commits (all time) y: 543 lines of code flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java x: 16 commits (all time) y: 192 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/iterative/io/SerializedUpdateBuffer.java x: 8 commits (all time) y: 252 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/ScatterGatherIteration.java x: 9 commits (all time) y: 421 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/CompactingHashTable.java x: 19 commits (all time) y: 893 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/TaskConfig.java x: 17 commits (all time) y: 858 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/CombiningUnilateralSortMerger.java x: 18 commits (all time) y: 367 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/FixedLengthRecordSorter.java x: 11 commits (all time) y: 323 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InMemoryPartition.java x: 10 commits (all time) y: 217 lines of code flink-core/src/main/java/org/apache/flink/types/Record.java x: 10 commits (all time) y: 1218 lines of code flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/PlanNode.java x: 5 commits (all time) y: 311 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/CrossDriver.java x: 15 commits (all time) y: 302 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeutils/CompositeType.java x: 18 commits (all time) y: 169 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassTypeInfo.scala x: 23 commits (all time) y: 205 lines of code flink-core/src/main/java/org/apache/flink/api/common/operators/Ordering.java x: 10 commits (all time) y: 198 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/DriverStrategy.java x: 21 commits (all time) y: 118 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java x: 24 commits (all time) y: 1117 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala x: 26 commits (all time) y: 266 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/HashPartition.java x: 16 commits (all time) y: 375 lines of code flink-core/src/main/java/org/apache/flink/api/common/operators/base/CoGroupOperatorBase.java x: 15 commits (all time) y: 264 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/coGroupDataSet.scala x: 16 commits (all time) y: 158 lines of code
2555.0
lines of code
  min: 1.0
  average: 86.48
  25th percentile: 18.0
  median: 44.0
  75th percentile: 96.0
  max: 2555.0
0 265.0
commits (all time)
min: 1.0 | average: 5.39 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 5.0 | max: 265.0

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

flink-python/pyflink/datastream/data_stream.py x: 2 contributors (all time) y: 410 lines of code flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamTwoInputPythonStatelessFunctionOperator.java x: 1 contributors (all time) y: 163 lines of code flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchApiCallBridge.java x: 8 contributors (all time) y: 30 lines of code flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/ElasticsearchOptions.java x: 4 contributors (all time) y: 113 lines of code flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6/ElasticsearchSink.java x: 5 contributors (all time) y: 101 lines of code flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java x: 2 contributors (all time) y: 110 lines of code flink-connectors/flink-sql-connector-hbase/src/main/resources/hbase-default.xml x: 2 contributors (all time) y: 1477 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeinfo/Types.java x: 5 contributors (all time) y: 134 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerConfigSnapshot.java x: 4 contributors (all time) y: 91 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeutils/TypeSerializerSnapshot.java x: 4 contributors (all time) y: 30 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/MissingTypeInfo.java x: 2 contributors (all time) y: 74 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoComparator.java x: 7 contributors (all time) y: 254 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/TimestampFormat.java x: 3 contributors (all time) y: 7 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/DataSink.java x: 13 contributors (all time) y: 176 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/directed/EdgeMetrics.java x: 2 contributors (all time) y: 215 lines of code flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/linalg/DenseMatrix.java x: 2 contributors (all time) y: 308 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/FencedRpcEndpoint.java x: 3 contributors (all time) y: 74 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/WriteFormatAsCsv.java x: 7 contributors (all time) y: 23 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerSerializer.java x: 5 contributors (all time) y: 189 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/DistinctType.java x: 2 contributors (all time) y: 94 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils/AggSqlFunction.scala x: 7 contributors (all time) y: 161 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecGroupAggregateBase.scala x: 3 contributors (all time) y: 38 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecWindowAggregateBase.scala x: 2 contributors (all time) y: 53 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/internal/MergingWindowSet.java x: 2 contributors (all time) y: 111 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java x: 21 contributors (all time) y: 1184 lines of code flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/SavepointEnvironment.java x: 9 contributors (all time) y: 237 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Execution.java x: 36 contributors (all time) y: 1066 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionAttemptID.java x: 6 contributors (all time) y: 56 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java x: 11 contributors (all time) y: 483 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskMetricGroup.java x: 3 contributors (all time) y: 111 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/UnregisteredMetricGroups.java x: 5 contributors (all time) y: 127 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/scope/TaskScopeFormat.java x: 2 contributors (all time) y: 37 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/strategy/ExecutionVertexID.java x: 3 contributors (all time) y: 52 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java x: 39 contributors (all time) y: 1554 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/topology/VertexID.java x: 2 contributors (all time) y: 3 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProvider.java x: 1 contributors (all time) y: 7 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocator.java x: 1 contributors (all time) y: 218 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SlotSharingExecutionSlotAllocatorFactory.java x: 1 contributors (all time) y: 36 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolImpl.java x: 9 contributors (all time) y: 928 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/util/DualKeyLinkedMap.java x: 1 contributors (all time) y: 122 lines of code flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java x: 8 contributors (all time) y: 128 lines of code flink-core/src/main/java/org/apache/flink/configuration/CoreOptions.java x: 19 contributors (all time) y: 207 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/BlobLibraryCacheManager.java x: 13 contributors (all time) y: 272 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache/FlinkUserCodeClassLoaders.java x: 7 contributors (all time) y: 129 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServices.java x: 20 contributors (all time) y: 300 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSink.java x: 10 contributors (all time) y: 284 lines of code flink-formats/flink-orc/src/main/java/org/apache/flink/orc/writer/ThreadLocalClassLoaderConfiguration.java x: 1 contributors (all time) y: 28 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ExecutionContext.java x: 23 contributors (all time) y: 710 lines of code flink-python/pyflink/datastream/functions.py x: 2 contributors (all time) y: 86 lines of code flink-python/pyflink/fn_execution/operation_utils.py x: 3 contributors (all time) y: 100 lines of code flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractOneInputPythonFunctionOperator.java x: 1 contributors (all time) y: 18 lines of code flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/AbstractStatelessFunctionOperator.java x: 5 contributors (all time) y: 152 lines of code flink-python/pyflink/proto/flink-fn-execution.proto x: 6 contributors (all time) y: 183 lines of code flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractPythonFunctionOperatorBase.java x: 1 contributors (all time) y: 208 lines of code flink-python/pyflink/common/serialization_schemas.py x: 1 contributors (all time) y: 180 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java x: 39 contributors (all time) y: 769 lines of code flink-core/src/main/java/org/apache/flink/core/memory/MemorySegmentFactory.java x: 8 contributors (all time) y: 65 lines of code flink-core/src/main/java/org/apache/flink/util/ExceptionUtils.java x: 12 contributors (all time) y: 310 lines of code flink-core/src/main/java/org/apache/flink/util/TaskManagerExceptionUtils.java x: 2 contributors (all time) y: 30 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java x: 18 contributors (all time) y: 662 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java x: 22 contributors (all time) y: 390 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java x: 40 contributors (all time) y: 1133 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/InputOutputFormatVertex.java x: 3 contributors (all time) y: 102 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerRunner.java x: 32 contributors (all time) y: 346 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java x: 43 contributors (all time) y: 972 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/async/CompletedOperationCache.java x: 2 contributors (all time) y: 139 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/TableFunction.java x: 2 contributors (all time) y: 49 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/UserDefinedFunctionHelper.java x: 1 contributors (all time) y: 277 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/ImperativeAggCodeGen.scala x: 5 contributors (all time) y: 374 lines of code flink-python/pyflink/datastream/stream_execution_environment.py x: 3 contributors (all time) y: 209 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/FunctionCatalog.java x: 7 contributors (all time) y: 472 lines of code flink-python/src/main/java/org/apache/flink/python/PythonConfig.java x: 4 contributors (all time) y: 86 lines of code flink-python/src/main/java/org/apache/flink/python/util/PythonConfigUtil.java x: 1 contributors (all time) y: 90 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java x: 7 contributors (all time) y: 288 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/entrypoint/KubernetesResourceManagerFactory.java x: 4 contributors (all time) y: 67 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManagerFactory.java x: 4 contributors (all time) y: 72 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/active/LegacyActiveResourceManagerFactory.java x: 1 contributors (all time) y: 47 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java x: 24 contributors (all time) y: 509 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnResourceManagerFactory.java x: 4 contributors (all time) y: 58 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java x: 22 contributors (all time) y: 868 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/StandaloneResourceManager.java x: 12 contributors (all time) y: 82 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java x: 17 contributors (all time) y: 634 lines of code flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/OrcNoHiveBulkWriterFactory.java x: 2 contributors (all time) y: 167 lines of code flink-formats/flink-orc/src/main/java/org/apache/flink/orc/writer/PhysicalWriterImpl.java x: 3 contributors (all time) y: 288 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointRequestDecider.java x: 3 contributors (all time) y: 140 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java x: 30 contributors (all time) y: 1139 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleServiceFactory.java x: 9 contributors (all time) y: 113 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java x: 15 contributors (all time) y: 364 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/BufferManager.java x: 3 contributors (all time) y: 256 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java x: 14 contributors (all time) y: 334 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGateFactory.java x: 5 contributors (all time) y: 203 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnknownInputChannel.java x: 11 contributors (all time) y: 90 lines of code flink-core/src/main/java/org/apache/flink/core/fs/SafetyNetCloseableRegistry.java x: 5 contributors (all time) y: 147 lines of code flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java x: 5 contributors (all time) y: 92 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java x: 7 contributors (all time) y: 203 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveCatalog.java x: 12 contributors (all time) y: 1183 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/CliClient.java x: 13 contributors (all time) y: 629 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/SqlCommandParser.java x: 11 contributors (all time) y: 282 lines of code flink-table/flink-sql-parser-hive/src/main/codegen/includes/parserImpls.ftl x: 4 contributors (all time) y: 1414 lines of code flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql/SqlShowPartitions.java x: 1 contributors (all time) y: 56 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java x: 17 contributors (all time) y: 1269 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations/SqlToOperationConverter.java x: 17 contributors (all time) y: 648 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkPlannerImpl.scala x: 12 contributors (all time) y: 149 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/typeutils/DataViewUtils.java x: 1 contributors (all time) y: 195 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/DistinctAggCodeGen.scala x: 8 contributors (all time) y: 764 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/AggregateUtil.scala x: 9 contributors (all time) y: 731 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/aggregation.scala x: 2 contributors (all time) y: 66 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/FirstValueWithRetractAggFunction.java x: 4 contributors (all time) y: 189 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/AggFunctionFactory.scala x: 6 contributors (all time) y: 467 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/ListAggWithRetractAggFunction.java x: 3 contributors (all time) y: 122 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/ScalarOperatorGens.scala x: 12 contributors (all time) y: 1934 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions/MinWithRetractAggFunction.java x: 4 contributors (all time) y: 174 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryRowData.java x: 2 contributors (all time) y: 332 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/NestedRowData.java x: 2 contributors (all time) y: 260 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeChecks.java x: 3 contributors (all time) y: 361 lines of code flink-core/src/main/java/org/apache/flink/util/ChildFirstClassLoader.java x: 3 contributors (all time) y: 70 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServer.java x: 16 contributors (all time) y: 475 lines of code flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcSplitReaderUtil.java x: 4 contributors (all time) y: 158 lines of code flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector/AbstractOrcColumnVector.java x: 4 contributors (all time) y: 139 lines of code flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonStatelessFunctionRunner.java x: 2 contributors (all time) y: 130 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonDeserializationSchema.java x: 1 contributors (all time) y: 115 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonFormatFactory.java x: 1 contributors (all time) y: 102 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java x: 1 contributors (all time) y: 71 lines of code flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ArrowUtils.java x: 2 contributors (all time) y: 783 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java x: 5 contributors (all time) y: 893 lines of code flink-python/pyflink/table/table.py x: 9 contributors (all time) y: 159 lines of code flink-python/pyflink/table/table_environment.py x: 19 contributors (all time) y: 542 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils/UserDefinedFunctionUtils.scala x: 6 contributors (all time) y: 620 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkStreamProgram.scala x: 4 contributors (all time) y: 149 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CalcCodeGenerator.scala x: 6 contributors (all time) y: 158 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecCalc.scala x: 8 contributors (all time) y: 51 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecCalc.scala x: 7 contributors (all time) y: 59 lines of code flink-python/pyflink/fn_execution/beam/beam_coders.py x: 2 contributors (all time) y: 173 lines of code flink-python/pyflink/fn_execution/beam/beam_operations_fast.pxd x: 2 contributors (all time) y: 19 lines of code flink-python/pyflink/fn_execution/beam/beam_operations_fast.pyx x: 2 contributors (all time) y: 145 lines of code flink-python/pyflink/fn_execution/coder_impl_fast.pyx x: 2 contributors (all time) y: 649 lines of code flink-python/pyflink/fn_execution/coders.py x: 5 contributors (all time) y: 281 lines of code flink-python/src/main/java/org/apache/flink/datastream/runtime/typeutils/python/PythonTypeUtils.java x: 1 contributors (all time) y: 237 lines of code flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java x: 1 contributors (all time) y: 187 lines of code flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/AbstractPythonStatelessFunctionFlatMap.java x: 3 contributors (all time) y: 216 lines of code flink-core/src/main/java/org/apache/flink/configuration/ClusterOptions.java x: 5 contributors (all time) y: 63 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosTaskExecutorRunner.java x: 11 contributors (all time) y: 43 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/util/FatalExitExceptionHandler.java x: 3 contributors (all time) y: 17 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnTaskExecutorRunner.java x: 20 contributors (all time) y: 73 lines of code flink-python/pyflink/table/catalog.py x: 8 contributors (all time) y: 406 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/StreamingFileSink.java x: 16 contributors (all time) y: 252 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/Constants.java x: 4 contributors (all time) y: 38 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/utils/KubernetesUtils.java x: 8 contributors (all time) y: 150 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java x: 16 contributors (all time) y: 604 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientFactory.java x: 7 contributors (all time) y: 103 lines of code flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java x: 10 contributors (all time) y: 246 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/PhysicalSlotProviderImpl.java x: 1 contributors (all time) y: 63 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/LocationPreferenceSlotSelectionStrategy.java x: 5 contributors (all time) y: 72 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/DataTypeExtractor.java x: 1 contributors (all time) y: 495 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGeneratorContext.scala x: 9 contributors (all time) y: 502 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/AggsHandlerCodeGenerator.scala x: 8 contributors (all time) y: 929 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/KeyValueDataType.java x: 1 contributors (all time) y: 95 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/dataview/ListViewTypeInfo.java x: 3 contributors (all time) y: 85 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/ExternalSerializer.java x: 1 contributors (all time) y: 150 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CodeGenUtils.scala x: 9 contributors (all time) y: 779 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/ExpressionReducer.scala x: 7 contributors (all time) y: 201 lines of code flink-python/pyflink/pyflink_gateway_server.py x: 3 contributors (all time) y: 160 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/utils/python/PythonTableUtils.scala x: 3 contributors (all time) y: 373 lines of code flink-python/pyflink/common/typeinfo.py x: 1 contributors (all time) y: 298 lines of code flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableFsDataOutputStream.java x: 6 contributors (all time) y: 236 lines of code flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/fs/hdfs/HadoopRecoverableWriter.java x: 7 contributors (all time) y: 100 lines of code flink-core/src/main/java/org/apache/flink/api/common/eventtime/WatermarkStrategy.java x: 3 contributors (all time) y: 43 lines of code flink-table/flink-sql-parser/src/main/codegen/includes/parserImpls.ftl x: 19 contributors (all time) y: 1278 lines of code flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlCreateTable.java x: 11 contributors (all time) y: 253 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/LaunchableMesosWorker.java x: 23 contributors (all time) y: 257 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java x: 7 contributors (all time) y: 116 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java x: 14 contributors (all time) y: 721 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRule.java x: 1 contributors (all time) y: 152 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkBatchRuleSets.scala x: 10 contributors (all time) y: 252 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java x: 17 contributors (all time) y: 1448 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroTypeInfo.java x: 5 contributors (all time) y: 60 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractionUtils.java x: 5 contributors (all time) y: 220 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroFileSystemFormatFactory.java x: 4 contributors (all time) y: 202 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSchemaConverter.java x: 4 contributors (all time) y: 330 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnApplicationFileUploader.java x: 3 contributors (all time) y: 342 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptions.java x: 19 contributors (all time) y: 192 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java x: 32 contributors (all time) y: 331 lines of code flink-core/src/main/java/org/apache/flink/configuration/ResourceManagerOptions.java x: 12 contributors (all time) y: 78 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/JdbcBatchingOutputFormat.java x: 5 contributors (all time) y: 242 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/converter/AbstractJdbcRowConverter.java x: 3 contributors (all time) y: 194 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcLookupFunction.java x: 3 contributors (all time) y: 243 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcTableSource.java x: 4 contributors (all time) y: 196 lines of code flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java x: 7 contributors (all time) y: 188 lines of code flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/common/RMQConnectionConfig.java x: 4 contributors (all time) y: 239 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SinkFunction.java x: 5 contributors (all time) y: 18 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/utils/AggregateOperationFactory.java x: 2 contributors (all time) y: 445 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/typeutils/FieldInfoUtils.java x: 4 contributors (all time) y: 557 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/expressions/SqlAggFunctionVisitor.java x: 6 contributors (all time) y: 128 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/QueryOperationConverter.java x: 11 contributors (all time) y: 633 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/ExprCodeGenerator.scala x: 8 contributors (all time) y: 619 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/TableFunctionCallGen.scala x: 4 contributors (all time) y: 104 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java x: 13 contributors (all time) y: 94 lines of code flink-table/flink-table-api-scala/src/main/scala/org/apache/flink/table/api/ImplicitExpressionConversions.scala x: 2 contributors (all time) y: 294 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/aggregations.scala x: 4 contributors (all time) y: 164 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/TableEnvImpl.scala x: 15 contributors (all time) y: 1032 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala x: 2 contributors (all time) y: 835 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/MatchCodeGenerator.scala x: 5 contributors (all time) y: 619 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/aggregations.scala x: 3 contributors (all time) y: 311 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/functions/utils/UserDefinedFunctionUtils.scala x: 6 contributors (all time) y: 444 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala x: 5 contributors (all time) y: 1428 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java x: 23 contributors (all time) y: 145 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/aggregate/BytesHashMap.java x: 4 contributors (all time) y: 447 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingEventTimeWindows.java x: 6 contributors (all time) y: 67 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingTimeWindows.java x: 7 contributors (all time) y: 15 lines of code flink-core/src/main/java/org/apache/flink/util/JavaGcCleanerWrapper.java x: 1 contributors (all time) y: 310 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlot.java x: 6 contributors (all time) y: 168 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTableImpl.java x: 2 contributors (all time) y: 548 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/LookupJoinCodeGenerator.scala x: 4 contributors (all time) y: 358 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashAggCodeGenHelper.scala x: 7 contributors (all time) y: 730 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/HashWindowCodeGenerator.scala x: 4 contributors (all time) y: 693 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/agg/batch/WindowCodeGenerator.scala x: 5 contributors (all time) y: 626 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/ConnectedStreams.java x: 11 contributors (all time) y: 200 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/IterativeStream.java x: 8 contributors (all time) y: 89 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/ConnectedStreams.scala x: 10 contributors (all time) y: 119 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStreamUtils.scala x: 3 contributors (all time) y: 24 lines of code flink-table/flink-table-planner/src/main/java/org/apache/flink/table/sqlexec/SqlToOperationConverter.java x: 16 contributors (all time) y: 518 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/calcite/FlinkPlannerImpl.scala x: 10 contributors (all time) y: 142 lines of code flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/factories/DataGenTableSourceFactory.java x: 3 contributors (all time) y: 328 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/FactoryUtil.java x: 4 contributors (all time) y: 457 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraphBuilder.java x: 16 contributors (all time) y: 296 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionVertex.java x: 33 contributors (all time) y: 565 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java x: 28 contributors (all time) y: 914 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/SchedulerBase.java x: 10 contributors (all time) y: 790 lines of code flink-core/src/main/java/org/apache/flink/util/CollectionUtil.java x: 7 contributors (all time) y: 64 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/Executor.java x: 5 contributors (all time) y: 25 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java x: 25 contributors (all time) y: 489 lines of code flink-python/pyflink/table/table_result.py x: 4 contributors (all time) y: 19 lines of code flink-core/src/main/java/org/apache/flink/configuration/DelegatingConfiguration.java x: 11 contributors (all time) y: 295 lines of code flink-metrics/flink-metrics-influxdb/src/main/java/org/apache/flink/metrics/influxdb/InfluxdbReporter.java x: 6 contributors (all time) y: 117 lines of code flink-metrics/flink-metrics-influxdb/src/main/java/org/apache/flink/metrics/influxdb/InfluxdbReporterOptions.java x: 5 contributors (all time) y: 90 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataDeserializationSchema.java x: 5 contributors (all time) y: 362 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDataSerializationSchema.java x: 4 contributors (all time) y: 266 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/rules/FlinkStreamRuleSets.scala x: 11 contributors (all time) y: 243 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/utils/LegacyTypeInfoDataTypeConverter.java x: 5 contributors (all time) y: 297 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/CorrelateCodeGenerator.scala x: 6 contributors (all time) y: 312 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonLookupJoin.scala x: 9 contributors (all time) y: 620 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/common/CommonPythonCalc.scala x: 6 contributors (all time) y: 105 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecExchange.scala x: 6 contributors (all time) y: 148 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecExpand.scala x: 6 contributors (all time) y: 73 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecHashJoin.scala x: 6 contributors (all time) y: 205 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecOverAggregate.scala x: 6 contributors (all time) y: 516 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecRank.scala x: 6 contributors (all time) y: 228 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecSort.scala x: 6 contributors (all time) y: 89 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/BatchExecSortAggregateBase.scala x: 6 contributors (all time) y: 91 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecIntervalJoin.scala x: 2 contributors (all time) y: 285 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecJoin.scala x: 5 contributors (all time) y: 173 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecMatch.scala x: 9 contributors (all time) y: 372 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecOverAggregate.scala x: 6 contributors (all time) y: 332 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecSortLimit.scala x: 5 contributors (all time) y: 165 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTableSourceScan.scala x: 11 contributors (all time) y: 55 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/StreamExecTemporalJoin.scala x: 5 contributors (all time) y: 329 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/PartitionPruner.scala x: 4 contributors (all time) y: 130 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/sinks/TableSinkUtils.scala x: 7 contributors (all time) y: 248 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/util/DataFormatConverters.java x: 3 contributors (all time) y: 1087 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemLookupFunction.java x: 2 contributors (all time) y: 151 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/deduplicate/DeduplicateKeepLastRowFunction.java x: 4 contributors (all time) y: 44 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/stream/state/OuterJoinRecordStateViews.java x: 4 contributors (all time) y: 255 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/over/ProcTimeRowsBoundedPrecedingFunction.java x: 3 contributors (all time) y: 162 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/AbstractTopNFunction.java x: 3 contributors (all time) y: 234 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/RetractableTopNFunction.java x: 5 contributors (all time) y: 366 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java x: 4 contributors (all time) y: 380 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/RowDataSerializer.java x: 2 contributors (all time) y: 281 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperator.java x: 7 contributors (all time) y: 440 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/MapDataSerializer.java x: 2 contributors (all time) y: 233 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/TypeInferenceUtil.java x: 2 contributors (all time) y: 349 lines of code flink-core/src/main/java/org/apache/flink/core/fs/local/LocalFileSystem.java x: 13 contributors (all time) y: 212 lines of code flink-python/setup.py x: 10 contributors (all time) y: 272 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java x: 3 contributors (all time) y: 1168 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/FlinkTypeFactory.scala x: 7 contributors (all time) y: 411 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/expressions/PlannerExpressionConverter.scala x: 7 contributors (all time) y: 329 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/delegation/PlannerContext.java x: 9 contributors (all time) y: 217 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/FlinkCalciteCatalogReader.java x: 5 contributors (all time) y: 196 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Table.java x: 8 contributors (all time) y: 107 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java x: 17 contributors (all time) y: 206 lines of code flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch6DynamicSink.java x: 5 contributors (all time) y: 229 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/DataTypes.java x: 1 contributors (all time) y: 444 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/ExtractionUtils.java x: 1 contributors (all time) y: 611 lines of code flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/IndexGeneratorFactory.java x: 2 contributors (all time) y: 187 lines of code flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonRowDeserializationSchema.java x: 6 contributors (all time) y: 405 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/SqlUnnestUtils.java x: 1 contributors (all time) y: 135 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java x: 43 contributors (all time) y: 788 lines of code flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java x: 3 contributors (all time) y: 230 lines of code flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/api/bridge/java/internal/StreamTableEnvironmentImpl.java x: 1 contributors (all time) y: 320 lines of code flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaOptions.java x: 3 contributors (all time) y: 298 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowSerializer.java x: 9 contributors (all time) y: 287 lines of code flink-python/src/main/java/org/apache/flink/python/env/beam/ProcessPythonEnvironmentManager.java x: 1 contributors (all time) y: 259 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/extraction/FunctionMappingExtractor.java x: 1 contributors (all time) y: 373 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServerArchiveFetcher.java x: 11 contributors (all time) y: 328 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java x: 12 contributors (all time) y: 97 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMasterGateway.java x: 14 contributors (all time) y: 90 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultScheduler.java x: 5 contributors (all time) y: 383 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/DefaultSchedulerFactory.java x: 5 contributors (all time) y: 114 lines of code flink-core/src/main/java/org/apache/flink/core/fs/FileSystem.java x: 20 contributors (all time) y: 470 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/sql/FlinkSqlOperatorTable.java x: 11 contributors (all time) y: 829 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala x: 2 contributors (all time) y: 494 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/api/TableSchema.java x: 7 contributors (all time) y: 383 lines of code flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java x: 11 contributors (all time) y: 176 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyConfig.java x: 12 contributors (all time) y: 123 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyConnectionManager.java x: 9 contributors (all time) y: 57 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableConfig.java x: 9 contributors (all time) y: 96 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/CheckpointConfig.java x: 15 contributors (all time) y: 184 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java x: 14 contributors (all time) y: 494 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBCachingPriorityQueueSet.java x: 3 contributors (all time) y: 351 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBMapState.java x: 12 contributors (all time) y: 485 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/restore/RocksDBIncrementalRestoreOperation.java x: 7 contributors (all time) y: 367 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/StreamExecutionEnvironment.scala x: 26 contributors (all time) y: 291 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/CheckpointListener.java x: 5 contributors (all time) y: 7 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/GenericArrayData.java x: 2 contributors (all time) y: 226 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosTaskManagerParameters.java x: 17 contributors (all time) y: 374 lines of code flink-core/src/main/java/org/apache/flink/configuration/TaskManagerOptions.java x: 19 contributors (all time) y: 331 lines of code flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosConfigKeys.java x: 4 contributors (all time) y: 9 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputChannel.java x: 13 contributors (all time) y: 140 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/InputGate.java x: 12 contributors (all time) y: 47 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/SingleInputGate.java x: 19 contributors (all time) y: 561 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java x: 12 contributors (all time) y: 210 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierHandler.java x: 13 contributors (all time) y: 82 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/PrintUtils.java x: 3 contributors (all time) y: 271 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessAllWindowFunction.java x: 6 contributors (all time) y: 19 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/function/ProcessWindowFunction.scala x: 6 contributors (all time) y: 23 lines of code flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java x: 14 contributors (all time) y: 280 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java x: 40 contributors (all time) y: 772 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/InputProcessorUtil.java x: 8 contributors (all time) y: 94 lines of code flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java x: 29 contributors (all time) y: 743 lines of code flink-java/src/main/java/org/apache/flink/api/java/ExecutionEnvironment.java x: 34 contributors (all time) y: 507 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/RemoteStreamEnvironment.java x: 16 contributors (all time) y: 112 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/ProgramDeployer.java x: 6 contributors (all time) y: 50 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java x: 10 contributors (all time) y: 457 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogTableImpl.java x: 7 contributors (all time) y: 78 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/catalog/CatalogSchemaTable.java x: 6 contributors (all time) y: 138 lines of code flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontendParser.java x: 24 contributors (all time) y: 370 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobClient.java x: 11 contributors (all time) y: 225 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/security/modules/HadoopModule.java x: 10 contributors (all time) y: 82 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java x: 11 contributors (all time) y: 94 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/GenerateUtils.scala x: 8 contributors (all time) y: 729 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/config/ExecutionConfigOptions.java x: 8 contributors (all time) y: 194 lines of code flink-java/src/main/java/org/apache/flink/api/java/CollectionEnvironment.java x: 10 contributors (all time) y: 19 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBStateBackend.java x: 13 contributors (all time) y: 506 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskNetworkInput.java x: 9 contributors (all time) y: 194 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java x: 18 contributors (all time) y: 49 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/KeyGroupPartitionedPriorityQueue.java x: 2 contributors (all time) y: 199 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SubtaskCheckpointCoordinatorImpl.java x: 5 contributors (all time) y: 508 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemTableSink.java x: 7 contributors (all time) y: 401 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java x: 35 contributors (all time) y: 668 lines of code flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java x: 19 contributors (all time) y: 941 lines of code flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java x: 18 contributors (all time) y: 1095 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/typeutils/AvroSerializer.java x: 7 contributors (all time) y: 267 lines of code flink-dist/src/main/assemblies/bin.xml x: 28 contributors (all time) y: 237 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOutputFormat.java x: 3 contributors (all time) y: 174 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java x: 13 contributors (all time) y: 37 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerConfiguration.java x: 14 contributors (all time) y: 172 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java x: 8 contributors (all time) y: 316 lines of code flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java x: 32 contributors (all time) y: 624 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulerImpl.java x: 5 contributors (all time) y: 421 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotProvider.java x: 5 contributors (all time) y: 49 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java x: 10 contributors (all time) y: 53 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java x: 7 contributors (all time) y: 550 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/catalog/PostgresCatalog.java x: 5 contributors (all time) y: 289 lines of code flink-connectors/flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableFactory.java x: 1 contributors (all time) y: 262 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveTypeUtil.java x: 4 contributors (all time) y: 250 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveTableSource.java x: 8 contributors (all time) y: 480 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/BaseExpressions.java x: 2 contributors (all time) y: 533 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeMerging.java x: 1 contributors (all time) y: 560 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/expressions/PlannerExpressionParserImpl.scala x: 4 contributors (all time) y: 538 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/PlannerExpressionConverter.scala x: 7 contributors (all time) y: 674 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/AsyncCheckpointRunnable.java x: 3 contributors (all time) y: 190 lines of code flink-core/src/main/java/org/apache/flink/util/FileUtils.java x: 10 contributors (all time) y: 395 lines of code flink-dist/src/main/assemblies/opt.xml x: 24 contributors (all time) y: 120 lines of code flink-filesystems/flink-hadoop-fs/src/main/java/org/apache/flink/runtime/util/HadoopUtils.java x: 7 contributors (all time) y: 131 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OneInputStreamTask.java x: 18 contributors (all time) y: 112 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/rank/TopNBuffer.java x: 3 contributors (all time) y: 146 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java x: 5 contributors (all time) y: 304 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/filesystem/Buckets.java x: 9 contributors (all time) y: 252 lines of code flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro/AvroRowSerializationSchema.java x: 2 contributors (all time) y: 243 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdColumnUniqueness.scala x: 3 contributors (all time) y: 573 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdModifiedMonotonicity.scala x: 5 contributors (all time) y: 477 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueKeys.scala x: 3 contributors (all time) y: 460 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/IntervalJoinUtil.scala x: 1 contributors (all time) y: 334 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSource.java x: 16 contributors (all time) y: 129 lines of code flink-python/src/main/java/org/apache/flink/python/metric/FlinkMetricContainer.java x: 2 contributors (all time) y: 205 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdColumnInterval.scala x: 3 contributors (all time) y: 484 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/ColumnIntervalUtil.scala x: 1 contributors (all time) y: 228 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelOptUtil.scala x: 6 contributors (all time) y: 261 lines of code flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java x: 27 contributors (all time) y: 590 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java x: 23 contributors (all time) y: 447 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/DataStream.scala x: 22 contributors (all time) y: 432 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeCasts.java x: 1 contributors (all time) y: 347 lines of code tools/maven/suppressions.xml x: 20 contributors (all time) y: 34 lines of code flink-core/src/main/java/org/apache/flink/api/common/functions/RuntimeContext.java x: 21 contributors (all time) y: 70 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/DefaultOperatorStateBackend.java x: 15 contributors (all time) y: 204 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/async/RichAsyncFunction.java x: 10 contributors (all time) y: 179 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java x: 18 contributors (all time) y: 156 lines of code flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/bucketing/BucketingSink.java x: 20 contributors (all time) y: 690 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileReaderOperator.java x: 16 contributors (all time) y: 396 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/MessageAcknowledgingSourceBase.java x: 13 contributors (all time) y: 110 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.java x: 10 contributors (all time) y: 219 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/StreamPlanner.scala x: 10 contributors (all time) y: 263 lines of code flink-python/pyflink/table/__init__.py x: 9 contributors (all time) y: 47 lines of code flink-python/pyflink/table/descriptors.py x: 9 contributors (all time) y: 607 lines of code flink-python/pyflink/table/types.py x: 5 contributors (all time) y: 1495 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/Executors.java x: 5 contributors (all time) y: 31 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/OperatorCoordinatorHolder.java x: 1 contributors (all time) y: 244 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/PendingCheckpoint.java x: 16 contributors (all time) y: 368 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorUtils.java x: 10 contributors (all time) y: 193 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/SpillingAdaptiveSpanningRecordDeserializer.java x: 9 contributors (all time) y: 74 lines of code flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java x: 54 contributors (all time) y: 604 lines of code flink-runtime/src/main/scala/org/apache/flink/runtime/akka/AkkaUtils.scala x: 26 contributors (all time) y: 579 lines of code flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/config/entries/ExecutionEntry.java x: 4 contributors (all time) y: 278 lines of code flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java x: 8 contributors (all time) y: 78 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java x: 15 contributors (all time) y: 215 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/co/IntervalJoinOperator.java x: 6 contributors (all time) y: 360 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NettyShuffleEnvironment.java x: 8 contributors (all time) y: 257 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskManagerServicesConfiguration.java x: 15 contributors (all time) y: 192 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsCheckpointStreamFactory.java x: 9 contributors (all time) y: 243 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/OperatorSubtaskState.java x: 4 contributors (all time) y: 219 lines of code flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchUpsertTableSinkFactoryBase.java x: 8 contributors (all time) y: 249 lines of code flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryBase.java x: 11 contributors (all time) y: 304 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/descriptors/DescriptorProperties.java x: 8 contributors (all time) y: 945 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperatorFactoryUtil.java x: 6 contributors (all time) y: 40 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SystemProcessingTimeService.java x: 10 contributors (all time) y: 208 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TestProcessingTimeService.java x: 8 contributors (all time) y: 173 lines of code flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/AbstractFetcher.java x: 15 contributors (all time) y: 292 lines of code flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfig.java x: 6 contributors (all time) y: 247 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/Fabric8FlinkKubeClient.java x: 4 contributors (all time) y: 229 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamInputProcessor.java x: 14 contributors (all time) y: 13 lines of code flink-jepsen/src/jepsen/flink/db.clj x: 8 contributors (all time) y: 279 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointFailureReason.java x: 7 contributors (all time) y: 41 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/slots/TaskManagerGateway.java x: 9 contributors (all time) y: 62 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorGateway.java x: 17 contributors (all time) y: 84 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java x: 18 contributors (all time) y: 279 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksFullSnapshotStrategy.java x: 7 contributors (all time) y: 319 lines of code flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/snapshot/RocksIncrementalSnapshotStrategy.java x: 7 contributors (all time) y: 380 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java x: 10 contributors (all time) y: 553 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperatorV2.java x: 3 contributors (all time) y: 321 lines of code flink-core/src/main/java/org/apache/flink/core/memory/DataOutputSerializer.java x: 5 contributors (all time) y: 271 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpoint.java x: 13 contributors (all time) y: 420 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/RowComparator.java x: 3 contributors (all time) y: 364 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionJobVertex.java x: 25 contributors (all time) y: 396 lines of code flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer010.java x: 12 contributors (all time) y: 172 lines of code flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaConsumerThread.java x: 2 contributors (all time) y: 315 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV100.java x: 4 contributors (all time) y: 307 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java x: 22 contributors (all time) y: 626 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java x: 23 contributors (all time) y: 543 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamNode.java x: 15 contributors (all time) y: 267 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/transformations/SourceTransformation.java x: 8 contributors (all time) y: 33 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/memory/MemoryManager.java x: 12 contributors (all time) y: 322 lines of code flink-core/src/main/java/org/apache/flink/core/memory/MemoryUtils.java x: 7 contributors (all time) y: 89 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/execution/Environment.java x: 14 contributors (all time) y: 60 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/AbstractIterativeTask.java x: 6 contributors (all time) y: 267 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/minicluster/MiniCluster.java x: 22 contributors (all time) y: 717 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/BatchTask.java x: 12 contributors (all time) y: 897 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSinkTask.java x: 16 contributors (all time) y: 271 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/DataSourceTask.java x: 17 contributors (all time) y: 252 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/ChainedDriver.java x: 10 contributors (all time) y: 75 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/RuntimeEnvironment.java x: 12 contributors (all time) y: 235 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/ExecutionEnvironment.scala x: 31 contributors (all time) y: 296 lines of code flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSink.java x: 8 contributors (all time) y: 136 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StateAssignmentOperation.java x: 17 contributors (all time) y: 426 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/metadata/MetadataV2V3SerializerBase.java x: 3 contributors (all time) y: 438 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks/CheckpointCoordinatorConfiguration.java x: 8 contributors (all time) y: 206 lines of code flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/ParquetTableSource.java x: 7 contributors (all time) y: 419 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/ContinuousFileMonitoringFunction.java x: 14 contributors (all time) y: 253 lines of code flink-clients/src/main/java/org/apache/flink/client/program/ClusterClient.java x: 25 contributors (all time) y: 38 lines of code flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java x: 10 contributors (all time) y: 133 lines of code flink-clients/src/main/java/org/apache/flink/client/program/rest/RestClusterClient.java x: 17 contributors (all time) y: 575 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinaryStringData.java x: 2 contributors (all time) y: 584 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java x: 13 contributors (all time) y: 319 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/LocalInputChannel.java x: 12 contributors (all time) y: 214 lines of code flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterDescriptor.java x: 6 contributors (all time) y: 199 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/calcite/RelTimeIndicatorConverter.scala x: 6 contributors (all time) y: 526 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala x: 5 contributors (all time) y: 238 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/ExecNodePlanDumper.scala x: 4 contributors (all time) y: 282 lines of code flink-yarn/src/main/java/org/apache/flink/yarn/YarnConfigKeys.java x: 9 contributors (all time) y: 18 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointProperties.java x: 7 contributors (all time) y: 173 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CompletedCheckpointStore.java x: 10 contributors (all time) y: 42 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/serialization/EventSerializer.java x: 7 contributors (all time) y: 229 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java x: 12 contributors (all time) y: 372 lines of code flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/output/BoundedStreamTask.java x: 9 contributors (all time) y: 87 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableImpl.java x: 5 contributors (all time) y: 782 lines of code flink-core/src/main/java/org/apache/flink/api/common/io/DelimitedInputFormat.java x: 17 contributors (all time) y: 454 lines of code flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/client/HiveShimV310.java x: 2 contributors (all time) y: 269 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/internal/BatchTableEnvImpl.scala x: 9 contributors (all time) y: 407 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/rules/FlinkRuleSets.scala x: 9 contributors (all time) y: 169 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartition.java x: 19 contributors (all time) y: 233 lines of code flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java x: 13 contributors (all time) y: 716 lines of code flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java x: 12 contributors (all time) y: 261 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManagerGateway.java x: 11 contributors (all time) y: 68 lines of code flink-clients/src/main/java/org/apache/flink/client/cli/ProgramOptions.java x: 14 contributors (all time) y: 127 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/checkpoints/CheckpointStatistics.java x: 5 contributors (all time) y: 395 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/ResultPartitionWriter.java x: 12 contributors (all time) y: 27 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/LongHashJoinGenerator.scala x: 4 contributors (all time) y: 316 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/MatchCodeGenerator.scala x: 4 contributors (all time) y: 580 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/StringCallGen.scala x: 6 contributors (all time) y: 600 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/FlinkRelMdUtil.scala x: 2 contributors (all time) y: 476 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/utils/RexNodeExtractor.scala x: 6 contributors (all time) y: 310 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/SqlDateTimeUtils.java x: 8 contributors (all time) y: 1039 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/functions/SqlFunctionUtils.java x: 8 contributors (all time) y: 885 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/BinaryHashBucketArea.java x: 4 contributors (all time) y: 411 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/join/SortMergeJoinOperator.java x: 3 contributors (all time) y: 386 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/sort/BinaryExternalSorter.java x: 5 contributors (all time) y: 689 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/ResettableExternalBuffer.java x: 3 contributors (all time) y: 501 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/data/binary/BinaryStringDataUtil.java x: 1 contributors (all time) y: 812 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils/BinaryRowDataSerializer.java x: 1 contributors (all time) y: 285 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/data/binary/BinarySegmentUtils.java x: 1 contributors (all time) y: 788 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/types/ResourceProfile.java x: 13 contributors (all time) y: 361 lines of code flink-dist/src/main/resources/flink-conf.yaml x: 24 contributors (all time) y: 7 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/clusterframework/BootstrapTools.java x: 24 contributors (all time) y: 400 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartitionView.java x: 8 contributors (all time) y: 16 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java x: 17 contributors (all time) y: 483 lines of code flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java x: 24 contributors (all time) y: 390 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/WindowOperatorBuilder.java x: 3 contributors (all time) y: 275 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/akka/AkkaRpcService.java x: 5 contributors (all time) y: 404 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical/utils/LogicalTypeParser.java x: 2 contributors (all time) y: 755 lines of code flink-table/flink-table-planner/src/main/java/org/apache/flink/table/plan/QueryOperationConverter.java x: 3 contributors (all time) y: 452 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/StandaloneCompletedCheckpointStore.java x: 10 contributors (all time) y: 61 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/ZooKeeperCompletedCheckpointStore.java x: 13 contributors (all time) y: 182 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordWriterOutput.java x: 12 contributors (all time) y: 113 lines of code flink-metrics/flink-metrics-statsd/src/main/java/org/apache/flink/metrics/statsd/StatsDReporter.java x: 6 contributors (all time) y: 175 lines of code flink-java/src/main/java/org/apache/flink/api/java/Utils.java x: 17 contributors (all time) y: 223 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamWindowJoin.scala x: 6 contributors (all time) y: 278 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricNames.java x: 8 contributors (all time) y: 41 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java x: 22 contributors (all time) y: 450 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/utils/JarHandlerUtils.java x: 7 contributors (all time) y: 157 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/StateBackendFactory.java x: 6 contributors (all time) y: 9 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/AbstractKeyedStateBackend.java x: 16 contributors (all time) y: 236 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java x: 14 contributors (all time) y: 28 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamIterationHead.java x: 13 contributors (all time) y: 69 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/compiler/NFACompiler.java x: 12 contributors (all time) y: 602 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/deployment/TaskDeploymentDescriptor.java x: 19 contributors (all time) y: 170 lines of code flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java x: 24 contributors (all time) y: 1255 lines of code flink-filesystems/flink-s3-fs-base/src/main/java/com/amazonaws/services/s3/model/transform/XmlResponsesSaxParser.java x: 2 contributors (all time) y: 2555 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/util/python/PythonTableUtils.scala x: 4 contributors (all time) y: 333 lines of code flink-core/src/main/java/org/apache/flink/configuration/MemorySize.java x: 5 contributors (all time) y: 253 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/codegen/calls/FunctionGenerator.scala x: 5 contributors (all time) y: 669 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java x: 16 contributors (all time) y: 211 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/hashtable/BaseHybridHashTable.java x: 6 contributors (all time) y: 290 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/util/ZooKeeperUtils.java x: 14 contributors (all time) y: 231 lines of code flink-core/src/main/java/org/apache/flink/configuration/SecurityOptions.java x: 11 contributors (all time) y: 276 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rpc/RpcEndpoint.java x: 7 contributors (all time) y: 150 lines of code flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer010.java x: 11 contributors (all time) y: 166 lines of code flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java x: 7 contributors (all time) y: 238 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/CepOperator.java x: 4 contributors (all time) y: 365 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java x: 9 contributors (all time) y: 338 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/FlinkAggregateExpandDistinctAggregatesRule.java x: 3 contributors (all time) y: 599 lines of code flink-java/src/main/java/org/apache/flink/api/java/DataSet.java x: 33 contributors (all time) y: 472 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/UnsortedGrouping.java x: 19 contributors (all time) y: 116 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyServer.java x: 9 contributors (all time) y: 141 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/metadata/FlinkRelMdCollation.java x: 1 contributors (all time) y: 384 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java x: 12 contributors (all time) y: 225 lines of code flink-core/src/main/java/org/apache/flink/types/StringValue.java x: 13 contributors (all time) y: 529 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala x: 4 contributors (all time) y: 1400 lines of code flink-table/flink-table-api-java-bridge/src/main/java/org/apache/flink/table/sources/CsvTableSource.java x: 5 contributors (all time) y: 424 lines of code flink-java/src/main/java/org/apache/flink/api/java/LocalEnvironment.java x: 12 contributors (all time) y: 31 lines of code flink-java/src/main/java/org/apache/flink/api/java/RemoteEnvironment.java x: 15 contributors (all time) y: 64 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/LocalStreamEnvironment.java x: 16 contributors (all time) y: 35 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/AbstractMetricGroup.java x: 7 contributors (all time) y: 272 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/AccessExecutionGraph.java x: 9 contributors (all time) y: 38 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java x: 12 contributors (all time) y: 454 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/calls/ScalarOperators.scala x: 4 contributors (all time) y: 1186 lines of code flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/GenericInMemoryCatalog.java x: 7 contributors (all time) y: 558 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java x: 20 contributors (all time) y: 268 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/chaining/SynchronousChainedCombineDriver.java x: 12 contributors (all time) y: 155 lines of code flink-formats/flink-orc/src/main/java/org/apache/flink/orc/OrcBatchReader.java x: 1 contributors (all time) y: 1117 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/SocketClientSink.java x: 9 contributors (all time) y: 139 lines of code flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java x: 9 contributors (all time) y: 22 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdDistinctRowCount.scala x: 3 contributors (all time) y: 537 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/codegen/calls/FunctionGenerator.scala x: 2 contributors (all time) y: 676 lines of code flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java x: 12 contributors (all time) y: 346 lines of code flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarListHandler.java x: 11 contributors (all time) y: 124 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/typeutils/CaseClassSerializer.scala x: 10 contributors (all time) y: 99 lines of code flink-state-backends/flink-statebackend-heap-spillable/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteSkipListStateMap.java x: 2 contributors (all time) y: 939 lines of code flink-core/src/main/java/org/apache/flink/core/memory/MemorySegment.java x: 14 contributors (all time) y: 441 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/CopyOnWriteStateMap.java x: 1 contributors (all time) y: 600 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/StateTable.java x: 8 contributors (all time) y: 228 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/KeyedStream.scala x: 15 contributors (all time) y: 276 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationHeadTask.java x: 8 contributors (all time) y: 307 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/SessionClusterEntrypoint.java x: 7 contributors (all time) y: 32 lines of code flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaCsvOutputFormat.java x: 8 contributors (all time) y: 115 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobUtils.java x: 17 contributors (all time) y: 193 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobService.java x: 7 contributors (all time) y: 7 lines of code flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/linalg/SparseVector.java x: 1 contributors (all time) y: 438 lines of code flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/TypeStringUtils.java x: 2 contributors (all time) y: 397 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/PojoSerializer.java x: 7 contributors (all time) y: 806 lines of code flink-connectors/flink-connector-filesystem/src/main/java/org/apache/flink/streaming/connectors/fs/AvroKeyValueSinkWriter.java x: 7 contributors (all time) y: 212 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/SelectivityEstimator.scala x: 2 contributors (all time) y: 788 lines of code flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/SubQueryDecorrelator.java x: 1 contributors (all time) y: 983 lines of code flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/metadata/FlinkRelMdUniqueGroups.scala x: 1 contributors (all time) y: 357 lines of code flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/util/SegmentsUtil.java x: 1 contributors (all time) y: 673 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedOutputView.java x: 4 contributors (all time) y: 296 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/DeweyNumber.java x: 8 contributors (all time) y: 167 lines of code flink-connectors/flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraSink.java x: 9 contributors (all time) y: 321 lines of code flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java x: 18 contributors (all time) y: 447 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java x: 21 contributors (all time) y: 649 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Pattern.java x: 12 contributors (all time) y: 246 lines of code flink-libraries/flink-gelly-scala/src/main/scala/org/apache/flink/graph/scala/Graph.scala x: 9 contributors (all time) y: 485 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/DataSet.scala x: 23 contributors (all time) y: 781 lines of code flink-core/src/main/java/org/apache/flink/api/common/typeinfo/TypeInformation.java x: 12 contributors (all time) y: 60 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java x: 10 contributors (all time) y: 25 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/CoGroupOperator.java x: 14 contributors (all time) y: 393 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/CrossOperator.java x: 16 contributors (all time) y: 534 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/FilterOperator.java x: 10 contributors (all time) y: 33 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java x: 16 contributors (all time) y: 226 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/JoinOperator.java x: 20 contributors (all time) y: 878 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/ReduceOperator.java x: 13 contributors (all time) y: 114 lines of code flink-core/src/main/java/org/apache/flink/api/common/io/FileInputFormat.java x: 22 contributors (all time) y: 600 lines of code flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/expressions/mathExpressions.scala x: 2 contributors (all time) y: 364 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/memory/AbstractPagedInputView.java x: 4 contributors (all time) y: 388 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java x: 21 contributors (all time) y: 776 lines of code flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java x: 13 contributors (all time) y: 698 lines of code flink-formats/flink-parquet/src/main/java/org/apache/flink/formats/parquet/utils/RowConverter.java x: 1 contributors (all time) y: 330 lines of code flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/kryo/KryoSerializer.java x: 9 contributors (all time) y: 425 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InPlaceMutableHashTable.java x: 4 contributors (all time) y: 594 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeInformationGen.scala x: 9 contributors (all time) y: 325 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/package.scala x: 11 contributors (all time) y: 104 lines of code flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/AllWindowedStream.java x: 19 contributors (all time) y: 786 lines of code flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/OptimizerNode.java x: 5 contributors (all time) y: 647 lines of code flink-streaming-scala/src/main/scala/org/apache/flink/streaming/api/scala/AllWindowedStream.scala x: 14 contributors (all time) y: 358 lines of code flink-core/src/main/java/org/apache/flink/api/common/operators/CollectionExecutor.java x: 12 contributors (all time) y: 435 lines of code flink-filesystems/flink-fs-hadoop-shaded/src/main/java/org/apache/hadoop/conf/Configuration.java x: 1 contributors (all time) y: 2056 lines of code flink-filesystems/flink-fs-hadoop-shaded/src/main/resources/core-default-shaded.xml x: 1 contributors (all time) y: 2404 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/UnilateralSortMerger.java x: 7 contributors (all time) y: 1060 lines of code flink-libraries/flink-cep-scala/src/main/scala/org/apache/flink/cep/scala/pattern/Pattern.scala x: 8 contributors (all time) y: 158 lines of code flink-java/src/main/java/org/apache/flink/api/java/io/CsvReader.java x: 15 contributors (all time) y: 322 lines of code flink-core/src/main/java/org/apache/flink/api/common/functions/RichGroupReduceFunction.java x: 8 contributors (all time) y: 9 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/TwoInputUdfOperator.java x: 10 contributors (all time) y: 182 lines of code flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/GraphCreatingVisitor.java x: 7 contributors (all time) y: 297 lines of code flink-core/src/main/java/org/apache/flink/api/common/io/BinaryInputFormat.java x: 9 contributors (all time) y: 281 lines of code flink-core/src/main/java/org/apache/flink/api/common/io/GenericCsvInputFormat.java x: 14 contributors (all time) y: 379 lines of code flink-core/src/main/java/org/apache/flink/api/java/tuple/Tuple21.java x: 4 contributors (all time) y: 350 lines of code flink-filesystems/flink-swift-fs-hadoop/src/main/java/org/apache/hadoop/conf/Configuration.java x: 1 contributors (all time) y: 1674 lines of code flink-filesystems/flink-swift-fs-hadoop/src/main/resources/META-INF/core-default-shaded.xml x: 1 contributors (all time) y: 1978 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationSynchronizationSinkTask.java x: 11 contributors (all time) y: 159 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/CoGroupDriver.java x: 9 contributors (all time) y: 108 lines of code flink-core/src/main/java/org/apache/flink/types/parser/FieldParser.java x: 12 contributors (all time) y: 134 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/Graph.java x: 6 contributors (all time) y: 1249 lines of code flink-libraries/flink-gelly-examples/src/main/java/org/apache/flink/graph/drivers/transform/GraphKeyTypeTransform.java x: 1 contributors (all time) y: 564 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/ProjectOperator.java x: 13 contributors (all time) y: 263 lines of code flink-java/src/main/java/org/apache/flink/api/java/operators/SortedGrouping.java x: 17 contributors (all time) y: 139 lines of code flink-java/src/main/java/org/apache/flink/api/java/functions/SemanticPropUtil.java x: 9 contributors (all time) y: 543 lines of code flink-java/src/main/java/org/apache/flink/api/java/utils/DataSetUtils.java x: 13 contributors (all time) y: 192 lines of code flink-scala/src/main/java/org/apache/flink/api/scala/operators/ScalaAggregateOperator.java x: 11 contributors (all time) y: 190 lines of code flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/spargel/ScatterGatherIteration.java x: 3 contributors (all time) y: 421 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/CompactingHashTable.java x: 10 contributors (all time) y: 893 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/TaskConfig.java x: 10 contributors (all time) y: 858 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/CombiningUnilateralSortMerger.java x: 10 contributors (all time) y: 367 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/FixedLengthRecordSorter.java x: 6 contributors (all time) y: 323 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/InMemoryPartition.java x: 6 contributors (all time) y: 217 lines of code flink-core/src/main/java/org/apache/flink/types/Record.java x: 7 contributors (all time) y: 1218 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/CrossDriver.java x: 10 contributors (all time) y: 302 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/ReduceCombineDriver.java x: 10 contributors (all time) y: 232 lines of code flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/PlanJSONDumpGenerator.java x: 6 contributors (all time) y: 493 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/GroupReduceCombineDriver.java x: 12 contributors (all time) y: 167 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java x: 10 contributors (all time) y: 1117 lines of code flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala x: 11 contributors (all time) y: 266 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort/LargeRecordHandler.java x: 6 contributors (all time) y: 296 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/HashPartition.java x: 8 contributors (all time) y: 375 lines of code flink-core/src/main/java/org/apache/flink/api/common/operators/base/CoGroupOperatorBase.java x: 8 contributors (all time) y: 264 lines of code flink-runtime/src/main/java/org/apache/flink/runtime/operators/AllGroupReduceDriver.java x: 10 contributors (all time) y: 102 lines of code
2555.0
lines of code
  min: 1.0
  average: 86.48
  25th percentile: 18.0
  median: 44.0
  75th percentile: 96.0
  max: 2555.0
0 54.0
contributors (all time)
min: 1.0 | average: 3.0 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 54.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): 0 points

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

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

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