spotify / flinkFile 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

Number of files: 7,649
Daily file updates (only one update per file and date counted): 42630
First update: 2010-12-16
Latest update: 2020-08-17
Days between first and latest update: 3,532 (504 weeks, estimated 2,520 working days)
Active days (at least one file change): 2,916
Data:

Organized per file

File Change History Overall

File Age Distribution Overall

Days since first update

There are 7,649 files with 661,539 lines of code in files.

7,649 files that are 366+ days old (661,539 lines of code)
0 files that are 181-365 days old (0 lines of code)
0 files that are 91-180 days old (0 lines of code)
0 files that are 31-90 days old (0 lines of code)
0 files that are 1-30 days old (0 lines of code)

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 7,649 files with 661,539 lines of code in files.

7,649 files have been last changed 366+ days ago (661,539 lines of code)
0 files have been last changed 181-365 days ago (0 lines of code)
0 files have been last changed 91-180 days ago (0 lines of code)
0 files have been last changed 31-90 days ago (0 lines of code)
0 files have been last changed 1-30 days ago (0 lines of code)

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, sh, html, ts, sql, properties, svg, yaml, less, clj, txt, json, rst, rb, gitignore, avsc, orc, css, pxd, pyx, edn, js, ftl, cfg, bat, editorconfig, in, h, proto, ini, prettierignore

File Age Distribution per Extension

Days since first update

366+

181-365

91-180

31-90

1-30

File Freshness Distribution per Extension

Days since last update

366+

181-365

91-180

31-90

1-30

File Change History per Logical Decomposition

primary

primary (file age distribution)

Days since first update

366+

181-365

91-180

31-90

1-30

primary (file freshness distribution)

Days since last update

366+

181-365

91-180

31-90

1-30

Oldest Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
suppressions.xml in tools/maven	34	-	2014-05-02	2020-06-03	32	20	alexff91@gmail.com	dianfu@apache.org
ConfigConstants.java in flink-core/src/main/java/org/apache/flink/configuration	604	1	2014-06-16	2020-05-15	172	54	metzgerr@web.de	wtgeeker@163.com
JobGraph.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph	268	39	2014-06-22	2019-11-11	60	20	sewen@apache.org	kkloudas@gmail.com
AbstractInvokable.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/tasks	80	18	2014-06-22	2020-05-11	33	20	sewen@apache.org	myasuka@live.com
JobEdge.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph	77	15	2014-06-22	2015-08-18	7	4	sewen@apache.org	sewen@apache.org
CompactingHashTable.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash	893	38	2014-06-23	2017-05-10	19	10	robert.waury@googlemail.com	rbonifacio123@gmail.com
InMemoryPartition.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash	217	28	2014-06-23	2017-03-20	10	6	robert.waury@googlemail.com	uce@apache.org
IntArrayList.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	53	9	2014-06-23	2016-10-04	5	4	robert.waury@googlemail.com	s.richter@data-artisans.com
LongArrayList.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	46	7	2014-06-23	2016-10-04	3	3	robert.waury@googlemail.com	s.richter@data-artisans.com
JobVertexID.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph	29	6	2014-06-23	2020-04-22	13	8	sewen@apache.org	karmagyz@gmail.com
InstanceID.java in flink-runtime/src/main/java/org/apache/flink/runtime/instance	10	2	2014-06-23	2015-02-08	7	5	sewen@apache.org	chiwanpark@icloud.com
ExecutionEnvironment.java in flink-java/src/main/java/org/apache/flink/api/java	507	70	2014-06-25	2020-06-19	97	34	qmlmoon@gmail.com	kkloudas@gmail.com
DataSet.java in flink-java/src/main/java/org/apache/flink/api/java	472	71	2014-06-25	2019-04-24	76	33	fleischmann.kay@googlemail.com	1059789585@qq.com
ExecutionEnvironment.scala in flink-scala/src/main/scala/org/apache/flink/api/scala	296	36	2014-06-25	2020-05-11	61	31	qmlmoon@gmail.com	1920405993@qq.com
DriverStrategy.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators	118	8	2014-06-25	2016-02-08	18	13	fleischmann.kay@googlemail.com	ggab90@gmail.com
PrimitiveInputFormat.java in flink-java/src/main/java/org/apache/flink/api/java/io	47	4	2014-06-25	2017-07-14	8	6	qmlmoon@gmail.com	dwysakowicz@apache.org
ExecutionGraph.java in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph	1133	85	2014-06-30	2020-08-10	221	40	sewen@apache.org	matthias@ververica.com
UnilateralSortMerger.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort	1060	44	2014-06-30	2018-08-03	18	7	sewen@apache.org	trohrmann@apache.org
Task.java in flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager	972	50	2014-06-30	2020-08-10	178	43	sewen@apache.org	matthias@ververica.com
FileInputFormat.java in flink-core/src/main/java/org/apache/flink/api/common/io	600	49	2014-06-30	2019-03-03	36	22	sewen@apache.org	a10y@users.noreply.github.com
ExecutionVertex.java in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph	565	58	2014-06-30	2020-07-20	121	33	sewen@apache.org	chesnay@apache.org
ExecutionJobVertex.java in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph	396	28	2014-06-30	2020-05-18	85	25	sewen@apache.org	sewen@apache.org
ExceptionUtils.java in flink-core/src/main/java/org/apache/flink/util	310	33	2014-06-30	2020-08-10	36	12	sewen@apache.org	matthias@ververica.com
CrossDriver.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators	302	11	2014-06-30	2016-10-05	15	10	sewen@apache.org	chesnay@apache.org
LocatableInputSplitAssigner.java in flink-core/src/main/java/org/apache/flink/api/common/io	232	15	2014-06-30	2019-04-10	9	6	sewen@apache.org	43952554+ryantaocer@users.n...
TaskDeploymentDescriptor.java in flink-runtime/src/main/java/org/apache/flink/runtime/deployment	170	19	2014-06-30	2020-03-13	46	19	sewen@apache.org	wangzhijiang999@aliyun.com
FileOutputFormat.java in flink-core/src/main/java/org/apache/flink/api/common/io	169	16	2014-06-30	2019-02-13	21	8	sewen@apache.org	trohrmann@apache.org
ChannelReaderInputView.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	125	9	2014-06-30	2019-03-09	9	6	sewen@apache.org	ykt836@gmail.com
NumberSequenceIterator.java in flink-core/src/main/java/org/apache/flink/util	111	8	2014-06-30	2018-01-18	8	3	sewen@apache.org	sewen@apache.org
IntermediateResult.java in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph	105	15	2014-06-30	2019-04-12	12	5	sewen@apache.org	zhuzhu.zz@alibaba-inc.com
ChannelWriterOutputView.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	93	8	2014-06-30	2016-04-12	9	6	sewen@apache.org	code@greghogan.com
TaskExecutionState.java in flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager	87	12	2014-06-30	2017-08-06	18	6	sewen@apache.org	trohrmann@apache.org
IntermediateResultPartition.java in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph	81	12	2014-06-30	2020-04-22	9	5	sewen@apache.org	karmagyz@gmail.com
IOManager.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	76	7	2014-06-30	2019-07-01	22	5	sewen@apache.org	wangzhijiang999@aliyun.com
ExecutorThreadFactory.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	65	8	2014-06-30	2018-10-08	8	4	sewen@apache.org	chesnay@apache.org
HeaderlessChannelReaderInputView.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	60	5	2014-06-30	2019-03-11	7	6	sewen@apache.org	lzljs3620320@aliyun.com
Environment.java in flink-runtime/src/main/java/org/apache/flink/runtime/execution	60	-	2014-06-30	2020-04-24	43	14	sewen@apache.org	karmagyz@gmail.com
ExecutionAttemptID.java in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph	56	9	2014-06-30	2020-04-22	6	6	sewen@apache.org	karmagyz@gmail.com
FileInputSplit.java in flink-core/src/main/java/org/apache/flink/core/fs	48	7	2014-06-30	2017-11-19	10	4	sewen@apache.org	yew1eb@gmail.com
DefaultInputSplitAssigner.java in flink-core/src/main/java/org/apache/flink/api/common/io	46	4	2014-06-30	2019-04-10	6	5	sewen@apache.org	43952554+ryantaocer@users.n...
AllVerticesIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph	42	4	2014-06-30	2014-09-23	3	2	sewen@apache.org	trohrmann@apache.org
GenericInputFormat.java in flink-core/src/main/java/org/apache/flink/api/common/io	40	5	2014-06-30	2015-12-01	6	4	sewen@apache.org	rmetzger@apache.org
GenericInputSplit.java in flink-core/src/main/java/org/apache/flink/core/io	36	6	2014-06-30	2017-11-19	8	4	sewen@apache.org	yew1eb@gmail.com
IntermediateDataSet.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph	36	7	2014-06-30	2017-02-10	8	6	sewen@apache.org	nico@data-artisans.com
SlotSharingGroup.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler	35	6	2014-06-30	2019-12-04	12	4	sewen@apache.org	reedpor@gmail.com
IntermediateDataSetID.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph	29	6	2014-06-30	2020-04-22	5	5	sewen@apache.org	karmagyz@gmail.com
NoResourceAvailableException.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler	25	5	2014-06-30	2019-09-28	15	5	sewen@apache.org	reedpor@gmail.com
InputFormat.java in flink-core/src/main/java/org/apache/flink/api/common/io	22	-	2014-06-30	2020-03-03	10	7	sewen@apache.org	paullin3280@gmail.com
SolutionSetUpdateBarrier.java in flink-runtime/src/main/java/org/apache/flink/runtime/iterative/concurrent	16	3	2014-06-30	2015-10-06	6	4	sewen@apache.org	hsaputra@apache.org
LibraryCacheManager.java in flink-runtime/src/main/java/org/apache/flink/runtime/execution/librarycache	16	-	2014-06-30	2020-04-30	16	6	sewen@apache.org	trohrmann@apache.org

Files Not Recently Changed (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
ExceptionHandler.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort	4	-	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
IndexedSorter.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort	5	-	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
ResettableMutableObjectIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	6	-	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
MemoryBlockIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	6	-	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
ResettableIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	7	-	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
Sorter.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort	7	-	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
CloseableInputProvider.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/util	8	-	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
DamBehavior.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators	9	1	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
CorruptConfigurationException.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/util	11	2	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
LocalStrategy.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/util	19	3	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
EmptyIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	27	5	2014-07-10	2014-09-23	4	3	rmetzger@apache.org	trohrmann@apache.org
HeapSort.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort	39	4	2014-07-10	2014-09-23	3	2	rmetzger@apache.org	trohrmann@apache.org
AllVerticesIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph	42	4	2014-06-30	2014-09-23	3	2	sewen@apache.org	trohrmann@apache.org
SingleElementIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	32	5	2014-07-10	2014-10-01	5	4	rmetzger@apache.org	warneke@apache.org
EventListener.java in flink-runtime/src/main/java/org/apache/flink/runtime/util/event	4	-	2014-10-08	2014-10-08	1	1	uce@apache.org	uce@apache.org
NotificationListener.java in flink-runtime/src/main/java/org/apache/flink/runtime/util/event	4	-	2014-10-08	2014-10-08	1	1	uce@apache.org	uce@apache.org
DistributionPattern.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph	6	-	2014-06-30	2014-10-08	5	4	sewen@apache.org	uce@apache.org
SimpleCloseableInputProvider.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/util	17	3	2014-07-10	2014-10-08	4	3	rmetzger@apache.org	uce@apache.org
BulkBlockChannelReader.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	6	-	2014-07-10	2014-11-07	4	3	rmetzger@apache.org	sewen@apache.org
RequestDoneCallback.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	6	-	2014-10-08	2014-11-07	2	2	uce@apache.org	sewen@apache.org
IORequest.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	11	-	2014-07-10	2014-11-07	5	4	rmetzger@apache.org	sewen@apache.org
RequestQueue.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	14	2	2014-07-10	2014-11-07	4	3	rmetzger@apache.org	sewen@apache.org
AsynchronousBulkBlockReader.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	54	7	2014-10-08	2014-11-07	2	2	uce@apache.org	sewen@apache.org
InputViewIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk	31	3	2014-07-10	2014-12-02	4	3	rmetzger@apache.org	aljoscha.krettek@gmail.com
ReusingMutableToRegularIteratorWrapper.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	62	5	2014-12-15	2014-12-15	1	1	aljoscha.krettek@gmail.com	aljoscha.krettek@gmail.com
ReusingSortMergeCoGroupIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/sort	102	6	2014-12-15	2014-12-15	1	1	aljoscha.krettek@gmail.com	aljoscha.krettek@gmail.com
BufferFileSegmentReader.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	7	-	2015-01-06	2015-01-06	1	1	uce@apache.org	uce@apache.org
BufferFileReader.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	8	-	2015-01-06	2015-01-06	1	1	uce@apache.org	uce@apache.org
BufferFileWriter.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	8	-	2015-01-06	2015-01-06	1	1	uce@apache.org	uce@apache.org
AsynchronousBlockWriterWithCallback.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	14	2	2014-10-08	2015-01-06	3	2	uce@apache.org	uce@apache.org
QueuingCallback.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	17	3	2014-10-08	2015-01-06	3	2	uce@apache.org	uce@apache.org
SynchronousFileIOChannel.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	17	3	2014-11-07	2015-01-06	2	2	sewen@apache.org	uce@apache.org
AsynchronousBufferFileSegmentReader.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	21	4	2015-01-06	2015-01-06	1	1	uce@apache.org	uce@apache.org
AsynchronousBufferFileReader.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	22	4	2015-01-06	2015-01-06	1	1	uce@apache.org	uce@apache.org
ExecutionEdge.java in flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph	24	5	2014-07-10	2015-01-06	7	4	rmetzger@apache.org	uce@apache.org
FileSegment.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	26	5	2015-01-06	2015-01-06	1	1	uce@apache.org	uce@apache.org
AsynchronousBlockWriter.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	37	3	2014-11-07	2015-01-06	2	2	sewen@apache.org	uce@apache.org
AsynchronousBlockReader.java in flink-runtime/src/main/java/org/apache/flink/runtime/io/disk/iomanager	45	5	2014-10-08	2015-01-06	4	2	uce@apache.org	uce@apache.org
EmptyMutableObjectIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	18	3	2014-07-10	2015-01-07	5	4	rmetzger@apache.org	sewen@apache.org
RegularToMutableObjectIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	28	3	2014-07-10	2015-01-07	5	4	rmetzger@apache.org	sewen@apache.org
NonReusingMutableToRegularIteratorWrapper.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	57	5	2014-12-15	2015-01-07	2	2	aljoscha.krettek@gmail.com	sewen@apache.org
InstanceID.java in flink-runtime/src/main/java/org/apache/flink/runtime/instance	10	2	2014-06-23	2015-02-08	7	5	sewen@apache.org	chiwanpark@icloud.com
ReaderIterator.java in flink-runtime/src/main/java/org/apache/flink/runtime/operators/util	45	3	2014-07-10	2015-02-11	7	6	rmetzger@apache.org	gyfora@apache.org
AtomicDisposableReferenceCounter.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	52	7	2014-10-08	2015-02-23	4	2	uce@apache.org	trohrmann@apache.org
OptimizerPostPass.java in flink-optimizer/src/main/java/org/apache/flink/optimizer/postpass	5	-	2015-03-17	2015-03-17	1	1	sewen@apache.org	sewen@apache.org
IterationNode.java in flink-optimizer/src/main/java/org/apache/flink/optimizer/dag	5	-	2015-03-17	2015-03-17	1	1	sewen@apache.org	sewen@apache.org
AbstractOperatorDescriptor.java in flink-optimizer/src/main/java/org/apache/flink/optimizer/operators	5	-	2015-03-17	2015-03-17	1	1	sewen@apache.org	sewen@apache.org
DumpableConnection.java in flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump	6	-	2015-03-17	2015-03-17	1	1	sewen@apache.org	sewen@apache.org
EstimateProvider.java in flink-optimizer/src/main/java/org/apache/flink/optimizer/dag	6	-	2015-03-17	2015-03-17	1	1	sewen@apache.org	sewen@apache.org
IterationPlanNode.java in flink-optimizer/src/main/java/org/apache/flink/optimizer/plan	7	-	2015-03-17	2015-03-17	1	1	sewen@apache.org	sewen@apache.org

Most Recently Created Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
AbstractPythonFunctionOperatorBase.java in flink-python/src/main/java/org/apache/flink/streaming/api/operators/python	208	16	2020-08-15	2020-08-15	1	1	hequn.chq@alibaba-inc.com	hequn.chq@alibaba-inc.com
serialization_schemas.py in flink-python/pyflink/common	180	38	2020-08-15	2020-08-15	1	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
DataStreamTwoInputPythonStatelessFunctionOperator.java in flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python	163	10	2020-08-15	2020-08-17	2	1	hequn.chq@alibaba-inc.com	hequn.chq@alibaba-inc.com
AbstractTwoInputPythonFunctionOperator.java in flink-python/src/main/java/org/apache/flink/streaming/api/operators/python	18	2	2020-08-15	2020-08-15	1	1	hequn.chq@alibaba-inc.com	hequn.chq@alibaba-inc.com
AbstractOneInputPythonFunctionOperator.java in flink-python/src/main/java/org/apache/flink/streaming/api/operators/python	18	2	2020-08-15	2020-08-15	1	1	hequn.chq@alibaba-inc.com	hequn.chq@alibaba-inc.com
NoHivePhysicalWriterImpl.java in flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/writer	32	4	2020-08-14	2020-08-14	1	1	lirui@apache.org	lirui@apache.org
SqlShowPartitions.java in flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/dql	56	6	2020-08-13	2020-08-13	1	1	programgeek@163.com	programgeek@163.com
ShowPartitionsOperation.java in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations	25	4	2020-08-13	2020-08-13	1	1	programgeek@163.com	programgeek@163.com
MaxwellJsonDeserializationSchema.java in flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell	115	8	2020-08-12	2020-08-12	1	1	nj18652727118@gmail.com	nj18652727118@gmail.com
MaxwellJsonFormatFactory.java in flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell	102	5	2020-08-12	2020-08-12	1	1	nj18652727118@gmail.com	nj18652727118@gmail.com
MaxwellJsonSerializationSchema.java in flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell	71	6	2020-08-12	2020-08-12	1	1	nj18652727118@gmail.com	nj18652727118@gmail.com
OrcLegacyTimestampColumnVector.java in flink-formats/flink-orc/src/main/java/org/apache/flink/orc/vector	51	4	2020-08-12	2020-08-12	1	1	lirui@apache.org	lirui@apache.org
TimestampUtil.java in flink-formats/flink-orc/src/main/java/org/apache/flink/orc	29	4	2020-08-12	2020-08-12	1	1	lirui@apache.org	lirui@apache.org
DataStreamPythonReduceFunctionOperator.java in flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python	82	5	2020-08-11	2020-08-11	1	1	hequn.chq@alibaba-inc.com	hequn.chq@alibaba-inc.com
PickledKeySelector.java in flink-python/src/main/java/org/apache/flink/datastream/runtime/functions/python	23	2	2020-08-11	2020-08-11	1	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
PythonTypeUtils.java in flink-python/src/main/java/org/apache/flink/datastream/runtime/typeutils/python	237	2	2020-08-09	2020-08-09	1	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
BeamPythonFunctionRunner.java in flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam	187	13	2020-08-09	2020-08-09	1	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
BeamPythonStatelessFunctionRunner.java in flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam	130	2	2020-08-09	2020-08-12	2	2	acqua.csq@alibaba-inc.com	dianfu@apache.org
DataStreamPythonStatelessFunctionOperator.java in flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python	118	6	2020-08-09	2020-08-15	3	2	acqua.csq@alibaba-inc.com	hequn.chq@alibaba-inc.com
PythonConfigUtil.java in flink-python/src/main/java/org/apache/flink/python/util	90	6	2020-08-09	2020-08-14	2	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
functions.py in flink-python/pyflink/datastream	86	25	2020-08-09	2020-08-16	5	2	acqua.csq@alibaba-inc.com	hequn.chq@alibaba-inc.com
BeamTablePythonStatelessFunctionRunner.java in flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/beam	60	1	2020-08-09	2020-08-12	2	2	acqua.csq@alibaba-inc.com	dianfu@apache.org
BeamDataStreamPythonStatelessFunctionRunner.java in flink-python/src/main/java/org/apache/flink/datastream/runtime/runners/python/beam	57	1	2020-08-09	2020-08-09	1	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
DataStreamPythonFunction.java in flink-python/src/main/java/org/apache/flink/datastream/runtime/functions/python	23	2	2020-08-09	2020-08-09	1	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
DataStreamPythonFunctionInfo.java in flink-python/src/main/java/org/apache/flink/datastream/runtime/functions/python	18	3	2020-08-09	2020-08-09	1	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
SlotSharingExecutionSlotAllocator.java in flink-runtime/src/main/java/org/apache/flink/runtime/scheduler	218	17	2020-08-06	2020-08-06	1	1	azagrebin@apache.org	azagrebin@apache.org
DualKeyLinkedMap.java in flink-runtime/src/main/java/org/apache/flink/runtime/util	122	19	2020-08-06	2020-08-06	1	1	azagrebin@apache.org	azagrebin@apache.org
SlotSharingExecutionSlotAllocatorFactory.java in flink-runtime/src/main/java/org/apache/flink/runtime/scheduler	36	1	2020-08-06	2020-08-06	1	1	azagrebin@apache.org	azagrebin@apache.org
InternalAggregateFunction.java in flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/functions/aggfunctions	22	1	2020-08-06	2020-08-06	1	1	twalthr@apache.org	twalthr@apache.org
data_stream.py in flink-python/pyflink/datastream	410	69	2020-08-05	2020-08-17	9	2	acqua.csq@alibaba-inc.com	hequn.chq@alibaba-inc.com
typeinfo.py in flink-python/pyflink/common	298	46	2020-08-05	2020-08-05	1	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
PickledByteArrayTypeInfo.java in flink-python/src/main/java/org/apache/flink/datastream/typeinfo/python	54	12	2020-08-05	2020-08-05	1	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
LocalInputPreferredSlotSharingStrategy.java in flink-runtime/src/main/java/org/apache/flink/runtime/scheduler	200	14	2020-08-04	2020-08-04	1	1	reedpor@gmail.com	reedpor@gmail.com
CoLocationGroupDesc.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler	36	6	2020-08-04	2020-08-04	1	1	reedpor@gmail.com	reedpor@gmail.com
ThreadLocalClassLoaderConfiguration.java in flink-formats/flink-orc/src/main/java/org/apache/flink/orc/writer	28	5	2020-08-04	2020-08-04	1	1	arvid@ververica.com	arvid@ververica.com
CoLocationConstraintDesc.java in flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/scheduler	28	2	2020-08-04	2020-08-04	1	1	reedpor@gmail.com	reedpor@gmail.com
SlotSharingStrategy.java in flink-runtime/src/main/java/org/apache/flink/runtime/scheduler	18	1	2020-08-04	2020-08-04	1	1	reedpor@gmail.com	reedpor@gmail.com
ExecutionSlotSharingGroup.java in flink-runtime/src/main/java/org/apache/flink/runtime/scheduler	17	2	2020-08-04	2020-08-04	1	1	reedpor@gmail.com	reedpor@gmail.com
JMXServer.java in flink-runtime/src/main/java/org/apache/flink/runtime/management	104	8	2020-08-03	2020-08-03	1	1	rongr@apache.org	rongr@apache.org
JMXService.java in flink-runtime/src/main/java/org/apache/flink/runtime/management	58	5	2020-08-03	2020-08-03	1	1	rongr@apache.org	rongr@apache.org
JMXServerOptions.java in flink-core/src/main/java/org/apache/flink/configuration	21	1	2020-08-03	2020-08-03	1	1	rongr@apache.org	rongr@apache.org
PushLimitIntoTableSourceScanRule.java in flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical	70	4	2020-07-31	2020-07-31	1	1	liuyongvs@gmail.com	liuyongvs@gmail.com
ExitTrappingSecurityManager.java in flink-runtime/src/main/java/org/apache/flink/runtime/security	50	4	2020-07-31	2020-07-31	1	1	mxm@apache.org	mxm@apache.org
DataViewUtils.java in flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/typeutils	195	22	2020-07-30	2020-08-07	3	1	twalthr@apache.org	twalthr@apache.org
AvroToRowDataConverters.java in flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro	192	10	2020-07-30	2020-07-30	1	1	yuzhao.cyz@gmail.com	yuzhao.cyz@gmail.com
LegacyDataViewUtils.scala in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/typeutils	168	3	2020-07-30	2020-07-30	1	1	twalthr@apache.org	twalthr@apache.org
RowDataToAvroConverters.java in flink-formats/flink-avro/src/main/java/org/apache/flink/formats/avro	159	4	2020-07-30	2020-07-30	1	1	yuzhao.cyz@gmail.com	yuzhao.cyz@gmail.com
ExternalSerializer.java in flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/typeutils	150	22	2020-07-30	2020-07-30	1	1	twalthr@apache.org	twalthr@apache.org
RegistryAvroFormatFactory.java in flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent	108	5	2020-07-30	2020-07-30	1	1	yuzhao.cyz@gmail.com	yuzhao.cyz@gmail.com
CachedSchemaCoderProvider.java in flink-formats/flink-avro-confluent-registry/src/main/java/org/apache/flink/formats/avro/registry/confluent	45	3	2020-07-30	2020-07-30	1	1	yuzhao.cyz@gmail.com	yuzhao.cyz@gmail.com

Most Recently Changed Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
hbase-default.xml in flink-connectors/flink-sql-connector-hbase/src/main/resources	1477	-	2020-06-23	2020-08-17	2	2	xbjtdcq@163.com	brandonjy@users.noreply.git...
YarnClusterDescriptor.java in flink-yarn/src/main/java/org/apache/flink/yarn	1184	53	2016-04-22	2020-08-17	63	21	mxm@apache.org	brandonjy@users.noreply.git...
data_stream.py in flink-python/pyflink/datastream	410	69	2020-08-05	2020-08-17	9	2	acqua.csq@alibaba-inc.com	hequn.chq@alibaba-inc.com
DenseMatrix.java in flink-ml-parent/flink-ml-lib/src/main/java/org/apache/flink/ml/common/linalg	308	36	2019-06-10	2020-08-17	2	2	xuyang1706@gmail.com	brandonjy@users.noreply.git...
PojoComparator.java in flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime	254	22	2016-01-31	2020-08-17	7	7	sewen@apache.org	brandonjy@users.noreply.git...
EdgeMetrics.java in flink-libraries/flink-gelly/src/main/java/org/apache/flink/graph/library/metric/directed	215	18	2016-07-20	2020-08-17	11	2	code@greghogan.com	brandonjy@users.noreply.git...
TimerSerializer.java in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators	189	21	2018-06-13	2020-08-17	8	5	tzulitai@apache.org	brandonjy@users.noreply.git...
DataSink.java in flink-java/src/main/java/org/apache/flink/api/java/operators	176	17	2014-07-10	2020-08-17	25	13	rmetzger@apache.org	brandonjy@users.noreply.git...
DataStreamTwoInputPythonStatelessFunctionOperator.java in flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python	163	10	2020-08-15	2020-08-17	2	1	hequn.chq@alibaba-inc.com	hequn.chq@alibaba-inc.com
AggSqlFunction.scala in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/functions/utils	161	5	2019-07-22	2020-08-17	10	7	godfreyhe@163.com	brandonjy@users.noreply.git...
Types.java in flink-core/src/main/java/org/apache/flink/api/common/typeinfo	134	10	2017-04-03	2020-08-17	8	5	twalthr@apache.org	brandonjy@users.noreply.git...
ElasticsearchOptions.java in flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table	113	1	2020-05-15	2020-08-17	5	4	dwysakowicz@apache.org	brandonjy@users.noreply.git...
MergingWindowSet.java in flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/window/internal	111	7	2019-07-19	2020-08-17	2	2	godfreyhe@163.com	brandonjy@users.noreply.git...
ElasticsearchSink.java in flink-connectors/flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7	110	14	2019-09-18	2020-08-17	2	2	yanghua1127@gmail.com	brandonjy@users.noreply.git...
ElasticsearchSink.java in flink-connectors/flink-connector-elasticsearch6/src/main/java/org/apache/flink/streaming/connectors/elasticsearch6	101	14	2018-01-25	2020-08-17	5	5	cjolif@gmail.com	brandonjy@users.noreply.git...
DistinctType.java in flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/logical	94	13	2019-05-02	2020-08-17	5	2	twalthr@apache.org	brandonjy@users.noreply.git...
TypeSerializerConfigSnapshot.java in flink-core/src/main/java/org/apache/flink/api/common/typeutils	91	8	2017-05-07	2020-08-17	11	4	tzulitai@apache.org	brandonjy@users.noreply.git...
MissingTypeInfo.java in flink-core/src/main/java/org/apache/flink/api/java/typeutils	74	15	2016-01-31	2020-08-17	2	2	sewen@apache.org	brandonjy@users.noreply.git...
FencedRpcEndpoint.java in flink-runtime/src/main/java/org/apache/flink/runtime/rpc	74	9	2017-08-23	2020-08-17	7	3	trohrmann@apache.org	brandonjy@users.noreply.git...
BatchExecWindowAggregateBase.scala in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch	53	1	2019-07-22	2020-08-17	2	2	godfreyhe@163.com	brandonjy@users.noreply.git...
BatchExecGroupAggregateBase.scala in flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch	38	1	2019-07-22	2020-08-17	3	3	godfreyhe@163.com	brandonjy@users.noreply.git...
ElasticsearchApiCallBridge.java in flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch	30	2	2017-01-12	2020-08-17	12	8	tzulitai@apache.org	brandonjy@users.noreply.git...
TypeSerializerSnapshot.java in flink-core/src/main/java/org/apache/flink/api/common/typeutils	30	2	2018-10-05	2020-08-17	7	4	tzulitai@apache.org	brandonjy@users.noreply.git...
WriteFormatAsCsv.java in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink	23	1	2015-10-20	2020-08-17	8	7	rufus@refactor.com	brandonjy@users.noreply.git...
WriteFormatAsText.java in flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink	22	1	2015-10-20	2020-08-17	8	7	rufus@refactor.com	brandonjy@users.noreply.git...
TimestampFormat.java in flink-formats/flink-json/src/main/java/org/apache/flink/formats/json	7	-	2020-06-17	2020-08-17	3	3	33114724+fsk119@users.norep...	brandonjy@users.noreply.git...
operation_utils.py in flink-python/pyflink/fn_execution	100	4	2020-07-15	2020-08-16	5	3	hxbks2ks@gmail.com	hequn.chq@alibaba-inc.com
functions.py in flink-python/pyflink/datastream	86	25	2020-08-09	2020-08-16	5	2	acqua.csq@alibaba-inc.com	hequn.chq@alibaba-inc.com
AbstractPythonFunctionOperatorBase.java in flink-python/src/main/java/org/apache/flink/streaming/api/operators/python	208	16	2020-08-15	2020-08-15	1	1	hequn.chq@alibaba-inc.com	hequn.chq@alibaba-inc.com
proto flink-fn-execution.proto in flink-python/pyflink/proto	183	-	2019-09-18	2020-08-15	11	6	fudian.fd@alibaba-inc.com	hequn.chq@alibaba-inc.com
serialization_schemas.py in flink-python/pyflink/common	180	38	2020-08-15	2020-08-15	1	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
AbstractStatelessFunctionOperator.java in flink-python/src/main/java/org/apache/flink/table/runtime/operators/python	152	12	2020-02-10	2020-08-15	7	5	hxbks2ks@gmail.com	hequn.chq@alibaba-inc.com
DataStreamPythonStatelessFunctionOperator.java in flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python	118	6	2020-08-09	2020-08-15	3	2	acqua.csq@alibaba-inc.com	hequn.chq@alibaba-inc.com
AbstractTwoInputPythonFunctionOperator.java in flink-python/src/main/java/org/apache/flink/streaming/api/operators/python	18	2	2020-08-15	2020-08-15	1	1	hequn.chq@alibaba-inc.com	hequn.chq@alibaba-inc.com
AbstractOneInputPythonFunctionOperator.java in flink-python/src/main/java/org/apache/flink/streaming/api/operators/python	18	2	2020-08-15	2020-08-15	1	1	hequn.chq@alibaba-inc.com	hequn.chq@alibaba-inc.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
StreamTask.java in flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks	769	72	2015-10-20	2020-08-14	186	39	rufus@refactor.com	dianfu@apache.org
PhysicalWriterImpl.java in flink-formats/flink-orc/src/main/java/org/apache/flink/orc/writer	288	26	2020-03-20	2020-08-14	3	3	sivaprasanna246@gmail.com	lirui@apache.org
HiveTableSink.java in flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive	284	10	2019-07-26	2020-08-14	19	10	lirui@apache.org	lirui@apache.org
stream_execution_environment.py in flink-python/pyflink/datastream	209	38	2019-06-10	2020-08-14	7	3	weizhong0618@gmail.com	acqua.csq@alibaba-inc.com
OrcNoHiveBulkWriterFactory.java in flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive	167	5	2020-05-18	2020-08-14	2	2	jingsonglee0@gmail.com	lirui@apache.org
PythonConfigUtil.java in flink-python/src/main/java/org/apache/flink/python/util	90	6	2020-08-09	2020-08-14	2	1	acqua.csq@alibaba-inc.com	acqua.csq@alibaba-inc.com
PythonConfig.java in flink-python/src/main/java/org/apache/flink/python	86	14	2019-12-07	2020-08-14	6	4	weizhong0618@gmail.com	acqua.csq@alibaba-inc.com
HiveBulkWriterFactory.java in flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/write	46	2	2020-05-15	2020-08-14	3	2	lzljs3620320@aliyun.com	lirui@apache.org
NoHivePhysicalWriterImpl.java in flink-formats/flink-orc-nohive/src/main/java/org/apache/flink/orc/nohive/writer	32	4	2020-08-14	2020-08-14	1	1	lirui@apache.org	lirui@apache.org
parserImpls.ftl in flink-table/flink-sql-parser-hive/src/main/codegen/includes	1414	-	2020-04-28	2020-08-13	9	4	lirui@apache.org	programgeek@163.com
TableEnvironmentImpl.java in flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal	1269	76	2019-06-01	2020-08-13	68	17	dwysakowicz@apache.org	programgeek@163.com
HiveCatalog.java in flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive	1183	70	2019-05-03	2020-08-13	57	12	bowenli86@gmail.com	lirui@apache.org
SqlToOperationConverter.java in flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/operations	648	34	2019-07-22	2020-08-13	36	17	godfreyhe@163.com	programgeek@163.com
CliClient.java in flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli	629	45	2019-01-15	2020-08-13	25	13	yanghua1127@gmail.com	programgeek@163.com