apache / flink
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 9,588 files with 924,342 lines of code in files.
    • 8,067 files that are 366+ days old (780,604 lines of code)
    • 1,106 files that are 181-365 days old (109,716 lines of code)
    • 307 files that are 91-180 days old (26,180 lines of code)
    • 64 files that are 31-90 days old (4,732 lines of code)
    • 44 files that are 1-30 days old (3,110 lines of code)
84% | 11% | 2% | <1% | <1%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 9,588 files with 924,342 lines of code in files.
    • 5,966 files have been last changed 366+ days ago (385,562 lines of code)
    • 1,879 files have been last changed 181-365 days ago (193,841 lines of code)
    • 1,002 files have been last changed 91-180 days ago (174,835 lines of code)
    • 531 files have been last changed 31-90 days ago (115,908 lines of code)
    • 210 files have been last changed 1-30 days ago (54,196 lines of code)
41% | 20% | 18% | 12% | 5%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, scala, md, xml, py, json, html, sql, ts, sh, properties, svg, less, rst, yaml, q, txt, proto, js, pxd, avsc, pyx, orc, gitignore, css, cfg, in, ftl, toml, scss, g4, bat, editorconfig, cmd, eslintignore, stylelintignore, h, pyi, gitmodules, ini, prettierignore
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java82% | 13% | 3% | <1% | <1%
scala92% | 4% | 2% | <1% | 0%
py99% | <1% | 0% | <1% | 0%
ts100% | 0% | 0% | 0% | 0%
html100% | 0% | 0% | 0% | 0%
ftl100% | 0% | 0% | 0% | 0%
pyx100% | 0% | 0% | 0% | 0%
less100% | 0% | 0% | 0% | 0%
xml100% | 0% | 0% | 0% | 0%
g4100% | 0% | 0% | 0% | 0%
pyi100% | 0% | 0% | 0% | 0%
proto100% | 0% | 0% | 0% | 0%
pxd100% | 0% | 0% | 0% | 0%
in100% | 0% | 0% | 0% | 0%
toml100% | 0% | 0% | 0% | 0%
cfg100% | 0% | 0% | 0% | 0%
h100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java40% | 20% | 20% | 13% | 5%
scala45% | 27% | 8% | 10% | 7%
py55% | 11% | 2% | 12% | 17%
ts75% | 20% | 3% | 0% | 0%
html82% | 13% | 4% | 0% | 0%
pyx100% | 0% | 0% | 0% | 0%
less92% | 7% | 0% | 0% | 0%
g4100% | 0% | 0% | 0% | 0%
xml59% | 21% | 0% | 18% | 0%
pyi100% | 0% | 0% | 0% | 0%
proto100% | 0% | 0% | 0% | 0%
pxd100% | 0% | 0% | 0% | 0%
in100% | 0% | 0% | 0% | 0%
ftl<1% | 0% | 0% | 0% | 99%
cfg100% | 0% | 0% | 0% | 0%
h100% | 0% | 0% | 0% | 0%
toml0% | 0% | 0% | 100% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
flink-table90% | 4% | 3% | <1% | <1%
flink-runtime75% | 21% | 2% | <1% | <1%
flink-core96% | 2% | <1% | <1% | <1%
flink-python95% | 3% | <1% | <1% | 0%
flink-formats95% | 4% | 0% | 0% | 0%
flink-connectors98% | <1% | 0% | 0% | <1%
flink-runtime-web100% | 0% | 0% | 0% | 0%
flink-state-backends36% | 56% | 6% | <1% | 0%
flink-libraries89% | <1% | 8% | 1% | 0%
flink-filesystems100% | 0% | 0% | 0% | 0%
flink-clients100% | 0% | 0% | 0% | 0%
flink-kubernetes99% | <1% | 0% | 0% | 0%
flink-yarn100% | 0% | 0% | 0% | 0%
flink-streaming-java78% | 21% | <1% | <1% | 0%
flink-rpc100% | 0% | 0% | 0% | 0%
flink-datastream54% | <1% | 44% | 0% | 0%
flink-metrics78% | 14% | 0% | 7% | 0%
flink-queryable-state100% | 0% | 0% | 0% | 0%
flink-dstl100% | 0% | 0% | 0% | 0%
tools100% | 0% | 0% | 0% | 0%
flink-core-api7% | 88% | 3% | 0% | 0%
flink-dist100% | 0% | 0% | 0% | 0%
flink-datastream-api34% | <1% | 64% | 0% | 0%
flink-walkthroughs100% | 0% | 0% | 0% | 0%
flink-container100% | 0% | 0% | 0% | 0%
flink-external-resources80% | 19% | 0% | 0% | 0%
flink-annotations100% | 0% | 0% | 0% | 0%
flink-quickstart100% | 0% | 0% | 0% | 0%
flink-examples100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
flink-table41% | 17% | 19% | 13% | 8%
flink-runtime36% | 26% | 20% | 13% | 2%
flink-core50% | 22% | 17% | 7% | 1%
flink-python55% | 11% | 10% | 14% | 8%
flink-formats60% | 23% | 12% | 3% | 1%
flink-runtime-web74% | 20% | 2% | 1% | 0%
flink-connectors64% | 26% | 3% | 2% | 2%
flink-kubernetes66% | 8% | 19% | 5% | 0%
flink-libraries41% | 16% | 11% | 30% | 0%
flink-state-backends14% | 24% | 17% | 17% | 25%
flink-filesystems53% | 15% | 28% | 2% | 0%
flink-rpc65% | 16% | 4% | 12% | 0%
flink-metrics58% | 28% | 1% | 11% | 0%
flink-streaming-java38% | 46% | 2% | 12% | 0%
flink-queryable-state79% | 1% | 5% | 13% | 0%
flink-yarn36% | 1% | 30% | 0% | 32%
flink-dstl80% | 5% | 11% | 2% | 0%
tools80% | 3% | 16% | 0% | 0%
flink-clients19% | 39% | 16% | 11% | 13%
flink-core-api6% | 12% | 81% | 0% | 0%
flink-datastream5% | 3% | 66% | 25% | 0%
flink-walkthroughs80% | 19% | 0% | 0% | 0%
flink-datastream-api7% | 8% | 66% | 17% | 0%
flink-dist17% | 36% | 0% | 45% | 0%
flink-external-resources22% | 77% | 0% | 0% | 0%
flink-annotations39% | 0% | 60% | 0% | 0%
flink-quickstart100% | 0% | 0% | 0% | 0%
flink-examples100% | 0% | 0% | 0% | 0%
flink-container0% | 100% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ConfigConstants.java
in flink-core/src/main/java/org/apache/flink/configuration
 30 1 2014-06-16 2025-03-18 191 67 metzgerr@web.de piotr.nowojski@gmail.com
JobGraph.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph
 362 50 2014-06-22 2025-01-26 79 33 sewen@apache.org flinker@126.com
AbstractInvokable.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks
 119 20 2014-06-22 2021-09-14 49 23 sewen@apache.org piotr.nowojski@gmail.com
JobEdge.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph
 101 21 2014-06-22 2024-11-16 16 12 sewen@apache.org jrlee.ljr@gmail.com
CompactingHashTable.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash
 1013 38 2014-06-23 2024-12-06 23 13 robert.waury@googlemail.com snuyanzin@gmail.com
InMemoryPartition.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash
 232 28 2014-06-23 2024-12-06 12 8 robert.waury@googlemail.com snuyanzin@gmail.com
IntArrayList.java
in flink-runtime/src/main/java/org/apache/flink/runtime/util
 56 9 2014-06-23 2024-12-06 7 6 robert.waury@googlemail.com snuyanzin@gmail.com
LongArrayList.java
in flink-runtime/src/main/java/org/apache/flink/runtime/util
 48 7 2014-06-23 2020-12-28 4 4 robert.waury@googlemail.com dev@flink.apache.org
JobVertexID.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph
 29 6 2014-06-23 2020-12-28 14 9 sewen@apache.org dev@flink.apache.org
InstanceID.java
in flink-runtime/src/main/java/org/apache/flink/runtime/instance
 9 2 2014-06-23 2020-12-28 8 6 sewen@apache.org dev@flink.apache.org
DriverStrategy.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators
 127 8 2014-06-25 2020-12-28 19 14 fleischmann.kay@googlemail.com dev@flink.apache.org
Task.java
in flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager
 1224 60 2014-06-30 2025-01-10 227 60 sewen@apache.org m1a2@outlook.com
FileInputFormat.java
in flink-core/src/main/java/org/apache/flink/api/common/io
 649 48 2014-06-30 2024-09-23 46 28 sewen@apache.org reswqa@163.com
ExecutionJobVertex.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 504 38 2014-06-30 2024-12-12 115 38 sewen@apache.org jrlee.ljr@gmail.com
ExecutionVertex.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 374 58 2014-06-30 2024-09-16 154 43 sewen@apache.org mapohl@apache.org
CrossDriver.java
in flink-runtime/src/main/java/org/apache/flink/runtime/operators
 371 11 2014-06-30 2020-12-28 16 11 sewen@apache.org dev@flink.apache.org
ExceptionUtils.java
in flink-core/src/main/java/org/apache/flink/util
 340 38 2014-06-30 2022-04-15 41 15 sewen@apache.org karmagyz@gmail.com
LocatableInputSplitAssigner.java
in flink-core/src/main/java/org/apache/flink/api/common/io
 239 15 2014-06-30 2021-04-09 11 8 sewen@apache.org chesnay@apache.org
IntermediateResult.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 183 23 2014-06-30 2024-12-24 28 12 sewen@apache.org jrlee.ljr@gmail.com
TaskDeploymentDescriptor.java
in flink-runtime/src/main/java/org/apache/flink/runtime/deployment
 182 18 2014-06-30 2024-03-06 55 26 sewen@apache.org caodizhou.1@bytedance.com
FileOutputFormat.java
in flink-core/src/main/java/org/apache/flink/api/common/io
 179 16 2014-06-30 2024-09-23 26 12 sewen@apache.org reswqa@163.com
IntermediateResultPartition.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 155 19 2014-06-30 2024-12-24 31 13 sewen@apache.org jrlee.ljr@gmail.com
ChannelReaderInputView.java
in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager
 132 9 2014-06-30 2020-12-28 10 7 sewen@apache.org dev@flink.apache.org
NumberSequenceIterator.java
in flink-core/src/main/java/org/apache/flink/util
 111 8 2014-06-30 2020-12-28 9 4 sewen@apache.org dev@flink.apache.org
ExecutionGraph.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 110 1 2014-06-30 2025-03-13 258 56 sewen@apache.org efrat890089@gmail.com
IntermediateDataSet.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph
 94 14 2014-06-30 2024-12-24 15 11 sewen@apache.org jrlee.ljr@gmail.com
ChannelWriterOutputView.java
in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager
 93 8 2014-06-30 2020-12-28 10 7 sewen@apache.org dev@flink.apache.org
IOManager.java
in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager
 88 8 2014-06-30 2024-02-16 25 8 sewen@apache.org khachatryan.roman@gmail.com
Environment.java
in flink-runtime/src/main/java/org/apache/flink/runtime/execution
 88 6 2014-06-30 2024-12-06 60 26 sewen@apache.org snuyanzin@gmail.com
TaskExecutionState.java
in flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager
 81 11 2014-06-30 2021-02-24 20 7 sewen@apache.org chesnay@apache.org
ExecutionAttemptID.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 74 12 2014-06-30 2022-05-12 12 9 sewen@apache.org reedpor@gmail.com
HeaderlessChannelReaderInputView.java
in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager
 62 5 2014-06-30 2020-12-28 8 7 sewen@apache.org dev@flink.apache.org
FileInputSplit.java
in flink-core/src/main/java/org/apache/flink/core/fs
 48 7 2014-06-30 2020-12-28 11 5 sewen@apache.org dev@flink.apache.org
DefaultInputSplitAssigner.java
in flink-core/src/main/java/org/apache/flink/api/common/io
 44 4 2014-06-30 2023-04-20 9 8 sewen@apache.org peter_vary4@apple.com
AllVerticesIterator.java
in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph
 41 4 2014-06-30 2021-05-09 5 4 sewen@apache.org 64569824+rocmarshal@users.n...
GenericInputFormat.java
in flink-core/src/main/java/org/apache/flink/api/common/io
 40 5 2014-06-30 2020-12-28 7 5 sewen@apache.org dev@flink.apache.org
SlotSharingGroup.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler
 36 7 2014-06-30 2024-07-26 16 7 sewen@apache.org flinker@126.com
GenericInputSplit.java
in flink-core/src/main/java/org/apache/flink/core/io
 36 6 2014-06-30 2020-12-28 9 5 sewen@apache.org dev@flink.apache.org
IntermediateDataSetID.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph
 32 7 2014-06-30 2024-12-27 7 7 sewen@apache.org jrlee.ljr@gmail.com
NoResourceAvailableException.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler
 31 6 2014-06-30 2021-07-17 17 7 sewen@apache.org khachatryan.roman@gmail.com
InputFormat.java
in flink-core/src/main/java/org/apache/flink/api/common/io
 22 - 2014-06-30 2020-12-28 11 8 sewen@apache.org dev@flink.apache.org
LibraryCacheManager.java
in flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache
 19 1 2014-06-30 2020-12-28 18 7 sewen@apache.org dev@flink.apache.org
OutputFormat.java
in flink-core/src/main/java/org/apache/flink/api/common/io
 18 - 2014-06-30 2024-12-06 10 8 sewen@apache.org snuyanzin@gmail.com
SolutionSetUpdateBarrier.java
in flink-runtime/src/main/java/org/apache/flink/runtime/iterative/concurrent
 16 3 2014-06-30 2020-12-28 7 5 sewen@apache.org dev@flink.apache.org
JobException.java
in flink-runtime/src/main/java/org/apache/flink/runtime
 11 2 2014-06-30 2020-12-28 5 5 sewen@apache.org dev@flink.apache.org
TraversableOnceException.java
in flink-core/src/main/java/org/apache/flink/util
 10 1 2014-06-30 2020-12-28 5 4 sewen@apache.org dev@flink.apache.org
IOReadableWritable.java
in flink-core/src/main/java/org/apache/flink/core/io
 10 - 2014-06-30 2020-12-28 9 4 sewen@apache.org dev@flink.apache.org
DistributionPattern.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph
 8 - 2014-06-30 2021-02-24 7 6 sewen@apache.org cyprestar@outlook.com
InputSplitProvider.java
in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks
 8 - 2014-06-30 2020-12-28 8 4 sewen@apache.org dev@flink.apache.org
InputSplitSource.java
in flink-core/src/main/java/org/apache/flink/core/io
 8 - 2014-06-30 2020-12-28 5 5 sewen@apache.org dev@flink.apache.org
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
archetype-metadata.xml
in flink-quickstart/flink-quickstart-java/src/main/resources/META-INF/maven
 17 - 2014-08-12 2015-05-18 3 2 rmetzger@apache.org rmetzger@apache.org
logback.xml
in flink-examples/flink-examples-streaming/src/main/resources
 10 - 2016-02-01 2016-02-01 1 1 sewen@apache.org sewen@apache.org
cfg
zoo.cfg
in flink-dist/src/main/flink-bin/conf
 5 - 2015-07-03 2017-10-10 2 2 uce@apache.org yew1eb@gmail.com
package-info.java
in flink-streaming-java/src/main/java/org/apache/flink/streaming/experimental
 1 - 2017-12-02 2017-12-02 1 1 bowenli86@gmail.com bowenli86@gmail.com
list_deps.py
in tools
 23 - 2015-11-02 2018-01-03 2 2 aljoscha.krettek@gmail.com code@greghogan.com
spotbugs-exclude.xml
in tools/maven
 437 - 2017-07-17 2018-01-24 3 3 chesnay@apache.org sewen@apache.org
index.ts
in flink-runtime-web/web-dashboard/src/app/utils
 1 - 2019-03-14 2019-03-14 1 1 yadong.xyd@alibaba-inc.com yadong.xyd@alibaba-inc.com
index.ts
in flink-runtime-web/web-dashboard/src/app/interfaces
 1 - 2019-03-14 2019-03-14 1 1 yadong.xyd@alibaba-inc.com yadong.xyd@alibaba-inc.com
index.ts
in flink-runtime-web/web-dashboard/src/app/services
 1 - 2019-03-14 2019-03-14 1 1 yadong.xyd@alibaba-inc.com yadong.xyd@alibaba-inc.com
job-manager.component.html
in flink-runtime-web/web-dashboard/src/app/pages/job-manager
 2 - 2019-03-14 2019-03-14 1 1 yadong.xyd@alibaba-inc.com yadong.xyd@alibaba-inc.com
theme.less
in flink-runtime-web/web-dashboard/src/styles
 2 - 2019-03-14 2019-03-14 1 1 yadong.xyd@alibaba-inc.com yadong.xyd@alibaba-inc.com
environment.prod.ts
in flink-runtime-web/web-dashboard/src/environments
 3 - 2019-03-14 2019-03-14 1 1 yadong.xyd@alibaba-inc.com yadong.xyd@alibaba-inc.com
global.less
in flink-runtime-web/web-dashboard/src/styles
 3 - 2019-03-14 2019-03-14 1 1 yadong.xyd@alibaba-inc.com yadong.xyd@alibaba-inc.com
overview.component.less
in flink-runtime-web/web-dashboard/src/app/pages/overview
 4 - 2019-03-14 2019-03-14 1 1 yadong.xyd@alibaba-inc.com yadong.xyd@alibaba-inc.com
job-timeline.component.html
in flink-runtime-web/web-dashboard/src/app/pages/job/timeline
 5 - 2019-03-14 2019-03-14 1 1 yadong.xyd@alibaba-inc.com yadong.xyd@alibaba-inc.com
browserconfig.xml
in flink-runtime-web/web-dashboard/src/assets/favicon
 12 - 2019-03-14 2019-03-14 1 1 yadong.xyd@alibaba-inc.com yadong.xyd@alibaba-inc.com
__init__.py
in flink-python/pyflink/util
 1 - 2019-04-25 2019-04-25 1 1 weizhong0618@gmail.com weizhong0618@gmail.com
__init__.py
in flink-python/pyflink/testing
 1 - 2019-05-06 2019-05-06 1 1 fudian.fd@alibaba-inc.com fudian.fd@alibaba-inc.com
compoundIdentifier.ftl
in flink-table/flink-sql-parser/src/main/codegen/includes
 32 - 2019-05-31 2019-05-31 1 1 yuzhao.cyz@gmail.com yuzhao.cyz@gmail.com
cfg
setup.cfg
in flink-python
 4 - 2019-06-25 2019-06-25 1 1 weizhong0618@gmail.com weizhong0618@gmail.com
archetype-metadata.xml
in flink-walkthroughs/flink-walkthrough-datastream-java/src/main/resources/META-INF/maven
 17 - 2019-07-22 2019-07-22 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
FraudDetector.java
in flink-walkthroughs/flink-walkthrough-datastream-java/src/main/resources/archetype-resources/src/main/java
 20 1 2019-07-22 2019-07-22 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
FraudDetectionJob.java
in flink-walkthroughs/flink-walkthrough-datastream-java/src/main/resources/archetype-resources/src/main/java
 23 1 2019-07-22 2019-07-22 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
sql_dialect.py
in flink-python/pyflink/table
 26 2 2019-11-21 2019-11-21 1 1 hxbks2ks@gmail.com hxbks2ks@gmail.com
logback.xml
in flink-examples/flink-examples-table/src/main/resources
 10 - 2020-03-27 2020-03-27 1 1 trohrmann@apache.org trohrmann@apache.org
__init__.py
in flink-python/pyflink/metrics
 2 - 2020-03-26 2020-03-30 2 1 chenghequn@gmail.com chenghequn@gmail.com
pyflink_callback_server.py
in flink-python/pyflink
 11 - 2020-05-07 2020-05-07 1 1 weizhong0618@gmail.com weizhong0618@gmail.com
job_id.py
in flink-python/pyflink/common
 6 2 2020-05-06 2020-06-03 2 2 programgeek@163.com dianfu@apache.org
result_kind.py
in flink-python/pyflink/table
 15 1 2020-05-06 2020-06-03 2 2 programgeek@163.com dianfu@apache.org
completable_future.py
in flink-python/pyflink/common
 28 7 2020-05-06 2020-06-09 4 2 programgeek@163.com dianfu@apache.org
__init__.py
in flink-python/pyflink/fn_execution/beam
 1 - 2020-07-08 2020-07-08 1 1 hxbks2ks@gmail.com hxbks2ks@gmail.com
glibc_version_fix.h
in flink-python/dev
 1 - 2020-07-10 2020-08-15 2 2 hxbks2ks@gmail.com hequn.chq@alibaba-inc.com
pickle.py
in flink-python/pyflink/fn_execution
 6 1 2020-09-26 2020-09-26 1 1 dianfu@apache.org dianfu@apache.org
data_view.py
in flink-python/pyflink/table
 84 26 2020-09-29 2020-10-13 2 1 weizhong0618@gmail.com weizhong0618@gmail.com
ConfigurableCheckpointStorage.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state
 9 - 2020-10-26 2020-10-26 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
CheckpointStorageFactory.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state
 9 - 2020-10-26 2020-10-26 1 1 sjwiesman@gmail.com sjwiesman@gmail.com
time_domain.py
in flink-python/pyflink/datastream
 4 - 2020-10-28 2020-10-28 1 1 acqua.csq@alibaba-inc.com acqua.csq@alibaba-inc.com
input_dependency_constraint.py
in flink-python/pyflink/common
 15 2 2019-06-10 2020-10-28 2 2 weizhong0618@gmail.com hxbks2ks@gmail.com
job_execution_result.py
in flink-python/pyflink/common
 20 6 2020-04-11 2020-10-28 7 4 programgeek@163.com hxbks2ks@gmail.com
ZStandardInputStreamFactory.java
in flink-core/src/main/java/org/apache/flink/api/common/io/compression
 23 3 2020-11-12 2020-11-12 1 1 jboto@idealista.com jboto@idealista.com
SharedBufferNodeSerializer.java
in flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/sharedbuffer
 89 12 2020-12-02 2020-12-02 1 1 dwysakowicz@apache.org dwysakowicz@apache.org
PbCodegenSerializer.java
in flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/serialize
 5 - 2020-12-12 2020-12-12 1 1 maosuhan@bytedance.com maosuhan@bytedance.com
PbCodegenDeserializer.java
in flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/deserialize
 5 - 2020-12-12 2020-12-12 1 1 maosuhan@bytedance.com maosuhan@bytedance.com
ProtobufInternalUtils.java
in flink-formats/flink-protobuf/src/main/java/com/google/protobuf
 6 1 2020-12-12 2020-12-12 1 1 maosuhan@bytedance.com maosuhan@bytedance.com
PbCodegenException.java
in flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf
 13 4 2020-12-12 2020-12-12 1 1 maosuhan@bytedance.com maosuhan@bytedance.com
PbCodegenVarId.java
in flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/util
 13 3 2020-12-12 2020-12-12 1 1 maosuhan@bytedance.com maosuhan@bytedance.com
PbEncodingFormat.java
in flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf
 25 3 2020-12-12 2020-12-12 1 1 maosuhan@bytedance.com maosuhan@bytedance.com
PbDecodingFormat.java
in flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf
 28 3 2020-12-12 2020-12-12 1 1 maosuhan@bytedance.com maosuhan@bytedance.com
PbCodegenSerializeFactory.java
in flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/serialize
 31 2 2020-12-12 2020-12-12 1 1 maosuhan@bytedance.com maosuhan@bytedance.com
PbCodegenDeserializeFactory.java
in flink-formats/flink-protobuf/src/main/java/org/apache/flink/formats/protobuf/deserialize
 31 2 2020-12-12 2020-12-12 1 1 maosuhan@bytedance.com maosuhan@bytedance.com
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RuntimeChangelogMode.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process
 29 3 2025-05-07 2025-05-07 1 1 twalthr@apache.org twalthr@apache.org
ChangelogFunction.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions
 14 - 2025-05-07 2025-05-07 1 1 twalthr@apache.org twalthr@apache.org
GlobalWindow.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window
 84 17 2025-04-29 2025-04-29 1 1 suez1224@users.noreply.gith... suez1224@users.noreply.gith...
DescribeModelOperation.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations
 114 6 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlCreateModelConverter.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters
 86 3 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
ModelChange.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog
 75 13 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
AlterModelChangeOperation.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl
 75 8 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
CreateModelOperation.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl
 61 7 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
AlterModelRenameOperation.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl
 56 6 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
ShowModelsOperation.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations
 52 7 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
DropModelOperation.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/ddl
 49 6 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlAlterModelSetConverter.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters
 48 1 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlAlterModelResetConverter.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters
 48 1 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlAlterModelReset.java
in flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl
 45 4 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlAlterModelSet.java
in flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl
 40 4 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlAlterModelRename.java
in flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl
 34 4 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlAlterModelRenameConverter.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters
 33 1 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
AbstractSqlAlterModelConverter.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters
 32 1 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlShowModelsConverter.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters
 29 3 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlDropModelConverter.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters
 17 1 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlDescribeModelConverter.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters
 17 1 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
ModelModificationEvent.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/listener
 10 - 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SinkReuser.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/reuse
 144 6 2025-04-22 2025-04-25 2 1 xiangyu0xf@gmail.com xiangyu0xf@gmail.com
MetricsTrackingMapState.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics
 458 42 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
MetricsTrackingListState.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics
 221 19 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
AbstractMetricsTrackState.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics
 188 19 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
MetricsTrackingStateFactory.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics
 139 8 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
MetricsTrackingReducingState.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics
 130 11 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
MetricsTrackingAggregatingState.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics
 126 12 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
MetricsTrackingValueState.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics
 102 8 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
MetricsTrackingStateConfig.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics
 76 10 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
StateMetricBase.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics
 58 6 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
SizeTrackingStateConfig.java
in flink-runtime/src/main/java/org/apache/flink/runtime/state/metrics
 45 3 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
StateSizeTrackOptions.java
in flink-core/src/main/java/org/apache/flink/configuration
 37 - 2025-04-21 2025-04-21 1 1 hejufang0590@gmail.com hejufang0590@gmail.com
TargetColumnWritingSpec.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/abilities/sink
 47 4 2025-04-16 2025-04-16 1 1 xiangyu0xf@gmail.com xiangyu0xf@gmail.com
SupportsTargetColumnWriting.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector/sink/abilities
 7 - 2025-04-16 2025-04-16 1 1 xiangyu0xf@gmail.com xiangyu0xf@gmail.com
DequeRequestBuffer.java
in flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer
 54 7 2025-04-15 2025-04-15 1 1 puravbhatia9@gmail.com puravbhatia9@gmail.com
SimpleBatchCreator.java
in flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer
 33 2 2025-04-15 2025-04-15 1 1 puravbhatia9@gmail.com puravbhatia9@gmail.com
Batch.java
in flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer
 24 4 2025-04-15 2025-04-15 1 1 puravbhatia9@gmail.com puravbhatia9@gmail.com
RequestBuffer.java
in flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer
 14 - 2025-04-15 2025-04-15 1 1 puravbhatia9@gmail.com puravbhatia9@gmail.com
BatchCreator.java
in flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/sink/writer
 10 - 2025-04-15 2025-04-15 1 1 puravbhatia9@gmail.com puravbhatia9@gmail.com
DefaultSqlFactory.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions
 13 1 2025-04-10 2025-04-10 1 1 dwysakowicz@apache.org dwysakowicz@apache.org
SqlFactory.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions
 7 - 2025-04-10 2025-04-10 1 1 dwysakowicz@apache.org dwysakowicz@apache.org
DataViewUtils.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/dataview
 129 11 2025-04-08 2025-04-08 1 1 twalthr@apache.org twalthr@apache.org
StateModule.java
in flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/module
 92 4 2025-04-07 2025-04-07 1 1 gabor_somogyi2@apple.com gabor_somogyi2@apple.com
SavepointMetadataTableFunction.java
in flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table
 50 2 2025-04-07 2025-04-07 1 1 gabor_somogyi2@apple.com gabor_somogyi2@apple.com
StateModuleFactory.java
in flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/module
 26 2 2025-04-07 2025-04-07 1 1 gabor_somogyi2@apple.com gabor_somogyi2@apple.com
AsyncIntervalJoinOperator.java
in flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/co
 291 16 2025-04-03 2025-04-03 1 1 fredialei@gmail.com fredialei@gmail.com
AsyncKeyedCoProcessOperator.java
in flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/operators/co
 175 17 2025-04-03 2025-04-03 1 1 fredialei@gmail.com fredialei@gmail.com
DeclaringAsyncKeyedCoProcessFunction.java
in flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/functions
 39 5 2025-04-03 2025-04-03 1 1 fredialei@gmail.com fredialei@gmail.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
FlinkChangelogModeInferenceProgram.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/program
 1167 32 2021-07-06 2025-05-07 20 11 twalthr@apache.org twalthr@apache.org
FlinkRelMdUniqueKeys.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata
 554 39 2021-07-06 2025-05-07 10 6 twalthr@apache.org twalthr@apache.org
ProcessTableRunnerGenerator.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen
 379 9 2025-02-06 2025-05-07 7 1 twalthr@apache.org twalthr@apache.org
StreamPhysicalProcessTableFunction.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/physical/stream
 363 20 2025-01-21 2025-05-07 6 1 twalthr@apache.org twalthr@apache.org
ProcessTableOperator.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process
 336 23 2025-02-06 2025-05-07 5 1 twalthr@apache.org twalthr@apache.org
FlinkRelMdUpsertKeys.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/metadata
 272 29 2021-07-06 2025-05-07 8 4 twalthr@apache.org twalthr@apache.org
StreamExecProcessTableFunction.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream
 266 6 2025-01-21 2025-05-07 7 1 twalthr@apache.org twalthr@apache.org
OperatorBindingCallContext.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/functions/inference
 263 20 2021-07-06 2025-05-07 9 2 twalthr@apache.org twalthr@apache.org
StaticArgument.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference
 224 20 2024-11-25 2025-05-07 6 1 twalthr@apache.org twalthr@apache.org
ModifyKindSet.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/trait
 135 19 2021-07-06 2025-05-07 2 1 twalthr@apache.org twalthr@apache.org
ShortcutUtils.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils
 113 17 2021-07-06 2025-05-07 10 4 twalthr@apache.org twalthr@apache.org
RuntimeTableSemantics.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process
 80 10 2025-02-06 2025-05-07 3 1 twalthr@apache.org twalthr@apache.org
ChangelogPlanUtils.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/utils
 70 5 2021-07-06 2025-05-07 4 3 twalthr@apache.org twalthr@apache.org
ProcessTableOperatorFactory.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process
 66 3 2025-02-06 2025-05-07 3 1 twalthr@apache.org twalthr@apache.org
ProcessTableFunction.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions
 59 4 2024-11-29 2025-05-07 8 1 twalthr@apache.org twalthr@apache.org
ReadableInternalTimeContext.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process
 50 9 2025-03-10 2025-05-07 2 1 twalthr@apache.org twalthr@apache.org
PassThroughCollectorBase.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process
 48 3 2025-02-06 2025-05-07 3 1 twalthr@apache.org twalthr@apache.org
CallContext.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference
 47 4 2019-06-24 2025-05-07 11 4 twalthr@apache.org twalthr@apache.org
ArgumentTrait.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/annotation
 30 2 2024-11-26 2025-05-07 8 1 twalthr@apache.org twalthr@apache.org
RuntimeChangelogMode.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process
 29 3 2025-05-07 2025-05-07 1 1 twalthr@apache.org twalthr@apache.org
StaticArgumentTrait.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference
 26 1 2024-11-25 2025-05-07 6 1 twalthr@apache.org twalthr@apache.org
PassPartitionKeysCollector.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process
 20 2 2025-02-06 2025-05-07 3 1 twalthr@apache.org twalthr@apache.org
PassAllCollector.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/process
 15 2 2025-02-06 2025-05-07 3 1 twalthr@apache.org twalthr@apache.org
ChangelogFunction.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions
 14 - 2025-05-07 2025-05-07 1 1 twalthr@apache.org twalthr@apache.org
types.py
in flink-python/pyflink/table
 1536 178 2019-04-25 2025-05-05 41 10 weizhong0618@gmail.com mnaylor@confluent.io
table_environment.py
in flink-python/pyflink/table
 544 75 2019-04-25 2025-05-05 129 36 weizhong0618@gmail.com mnaylor@confluent.io
table.py
in flink-python/pyflink/table
 339 60 2019-04-25 2025-05-05 46 14 weizhong0618@gmail.com mnaylor@confluent.io
types.py
in flink-python/pyflink/common
 161 24 2020-09-10 2025-05-05 13 6 weizhong0618@gmail.com mnaylor@confluent.io
ExprCodeGenerator.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen
 638 17 2021-07-06 2025-04-30 31 15 twalthr@apache.org gdemorais@confluent.io
JsonGenerateUtils.scala
in flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen
 236 14 2021-09-07 2025-04-30 12 6 ingo.buerk@tngtech.com gdemorais@confluent.io
ChangelogMode.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/connector
 115 17 2020-04-06 2025-04-30 9 4 twalthr@apache.org dwysakowicz@apache.org
ChangelogModeJsonDeserializer.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde
 36 1 2021-07-06 2025-04-30 3 2 twalthr@apache.org dwysakowicz@apache.org
ChangelogModeJsonSerializer.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/serde
 31 1 2021-07-06 2025-04-30 3 2 twalthr@apache.org dwysakowicz@apache.org
data_stream.py
in flink-python/pyflink/datastream
 1432 150 2020-08-05 2025-04-29 69 17 acqua.csq@alibaba-inc.com suez1224@users.noreply.gith...
converters.py
in flink-python/pyflink/fn_execution/embedded
 184 35 2022-07-14 2025-04-29 5 2 hxb@apache.org suez1224@users.noreply.gith...
AbstractJsonDeserializationSchema.java
in flink-formats/flink-json/src/main/java/org/apache/flink/formats/json
 102 7 2023-07-19 2025-04-29 2 2 ldliulsy@163.com 40313389+lianghongjia6@user...
GlobalWindow.java
in flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/window
 84 17 2025-04-29 2025-04-29 1 1 suez1224@users.noreply.gith... suez1224@users.noreply.gith...
JsonParserRowDataDeserializationSchema.java
in flink-formats/flink-json/src/main/java/org/apache/flink/formats/json
 72 5 2023-07-19 2025-04-29 2 2 ldliulsy@163.com 40313389+lianghongjia6@user...
JsonRowDataDeserializationSchema.java
in flink-formats/flink-json/src/main/java/org/apache/flink/formats/json
 69 4 2020-04-30 2025-04-29 15 16 jark@apache.org 40313389+lianghongjia6@user...
parserImpls.ftl
in flink-table/flink-sql-parser/src/main/codegen/includes
 3295 - 2019-05-31 2025-04-28 103 45 yuzhao.cyz@gmail.com 1127478+lihaosky@users.nore...
YarnClusterDescriptor.java
in flink-yarn/src/main/java/org/apache/flink/yarn
 1569 60 2016-04-22 2025-04-28 120 57 mxm@apache.org fcsaky@apache.org
CatalogManager.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog
 1323 88 2019-05-10 2025-04-28 67 30 dwysakowicz@apache.org 1127478+lihaosky@users.nore...
SqlNodeToOperationConversion.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations
 1121 56 2023-03-17 2025-04-28 21 15 jark@apache.org 1127478+lihaosky@users.nore...
GenericInMemoryCatalog.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog
 718 54 2019-03-19 2025-04-28 30 14 xuefu.z@alibaba-inc.com 1127478+lihaosky@users.nore...
ForStFlinkFileSystem.java
in flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/fs
 413 40 2024-03-22 2025-04-28 24 6 masteryhx@gmail.com masteryhx@gmail.com
YarnConfigOptions.java
in flink-yarn/src/main/java/org/apache/flink/yarn/configuration
 377 2 2016-12-05 2025-04-28 52 38 sewen@apache.org fcsaky@apache.org
Catalog.java
in flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog
 238 17 2019-05-07 2025-04-28 32 19 bowenli86@gmail.com 1127478+lihaosky@users.nore...
SchemaBuilderUtil.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations
 204 14 2024-07-08 2025-04-28 3 2 sergio@confluent.io 1127478+lihaosky@users.nore...
DescribeModelOperation.java
in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations
 114 6 2025-04-28 2025-04-28 1 1 1127478+lihaosky@users.nore... 1127478+lihaosky@users.nore...
SqlNodeConverters.java
in flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters
 97 3 2023-03-17 2025-04-28 23 12 jark@apache.org 1127478+lihaosky@users.nore...