apache / incubator-celeborn
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 370 files with 47,226 lines of code in files.
    • 1 files that are 366+ days old (407 lines of code)
    • 242 files that are 181-365 days old (33,969 lines of code)
    • 78 files that are 91-180 days old (7,279 lines of code)
    • 44 files that are 31-90 days old (4,823 lines of code)
    • 5 files that are 1-30 days old (748 lines of code)
<1% | 71% | 15% | 10% | 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 370 files with 47,226 lines of code in files.
    • 0 files have been last changed 366+ days ago (0 lines of code)
    • 89 files have been last changed 181-365 days ago (4,008 lines of code)
    • 66 files have been last changed 91-180 days ago (4,336 lines of code)
    • 135 files have been last changed 31-90 days ago (15,304 lines of code)
    • 80 files have been last changed 1-30 days ago (23,578 lines of code)
0% | 8% | 9% | 32% | 49%
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, sh, svg, yml, txt, yaml, py, patch, properties, sbt, proto, json, gitignore, gitattributes, tpl, bash
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
proto73% | 26% | 0% | 0% | 0%
scala0% | 82% | 2% | 12% | 2%
java0% | 64% | 28% | 7% | 0%
yaml0% | 100% | 0% | 0% | 0%
py0% | 32% | 0% | 67% | 0%
yml0% | 100% | 0% | 0% | 0%
tpl0% | 100% | 0% | 0% | 0%
bash0% | 0% | 0% | 0% | 100%
sbt0% | 0% | 0% | 0% | 100%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java0% | 10% | 16% | 26% | 47%
scala0% | 6% | 1% | 37% | 54%
tpl0% | 100% | 0% | 0% | 0%
py0% | 10% | 0% | 89% | 0%
yml0% | 12% | 0% | 0% | 87%
yaml0% | 0% | 18% | 81% | 0%
proto0% | 0% | 0% | 0% | 100%
bash0% | 0% | 0% | 0% | 100%
sbt0% | 0% | 0% | 0% | 100%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
common2% | 92% | 3% | 1% | <1%
worker0% | 76% | 23% | 0% | 0%
client0% | 80% | 5% | 13% | 0%
master0% | 97% | 0% | 2% | 0%
client-spark0% | 41% | 0% | 58% | 0%
client-flink0% | 17% | 79% | 2% | 0%
charts0% | 100% | 0% | 0% | 0%
service0% | 100% | 0% | 0% | 0%
toolkit0% | 100% | 0% | 0% | 0%
ROOT0% | 98% | 0% | 0% | 1%
build0% | 15% | 0% | 0% | 84%
dev0% | 0% | 0% | 100% | 0%
project0% | 0% | 0% | 0% | 100%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
common0% | 20% | 3% | 30% | 46%
worker0% | 2% | 13% | 27% | 56%
client-flink0% | 2% | 42% | 38% | 16%
toolkit0% | 36% | 0% | 63% | 0%
charts0% | 10% | 16% | 72% | 0%
client-spark0% | <1% | 0% | 51% | 47%
client0% | <1% | <1% | 31% | 67%
build0% | 15% | 0% | 0% | 84%
service0% | 5% | 0% | 0% | 94%
ROOT0% | 12% | 0% | 0% | 87%
master0% | 0% | 4% | 9% | 86%
dev0% | 0% | 0% | 100% | 0%
project0% | 0% | 0% | 0% | 100%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
proto
TransportMessages.proto
in common/src/main/proto
 407 - 2022-01-29 2023-08-07 60 11 fengmingxiao.fmx@alibaba-in... zky.zhoukeyong@alibaba-inc.com
mkdocs.yml
in root
 75 - 2022-09-09 2023-08-04 14 5 chengpan@apache.org xiyu.zk@alibaba-inc.com
ShuffleClientImpl.java
in client/src/main/java/org/apache/celeborn/client
 1513 45 2022-10-02 2023-07-25 73 20 zky.zhoukeyong@alibaba-inc.com 1178404354@qq.com
Utils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 882 78 2022-10-02 2023-08-04 40 16 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
ControlMessages.scala
in common/src/main/scala/org/apache/celeborn/common/protocol/message
 842 14 2022-10-02 2023-08-07 40 12 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
NettyRpcEnv.scala
in common/src/main/scala/org/apache/celeborn/common/rpc/netty
 475 37 2022-10-02 2023-06-21 8 5 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org
AbstractSource.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/source
 339 36 2022-10-02 2023-07-04 15 9 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com
TransportResponseHandler.java
in common/src/main/java/org/apache/celeborn/common/network/client
 307 17 2022-10-02 2023-08-05 13 6 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
PartitionLocation.java
in common/src/main/java/org/apache/celeborn/common/protocol
 271 38 2022-10-02 2023-06-29 9 7 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
SerializationDebugger.scala
in common/src/main/scala/org/apache/celeborn/common/serializer
 266 28 2022-10-02 2023-06-29 2 2 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org
TransportClient.java
in common/src/main/java/org/apache/celeborn/common/network/client
 253 24 2022-10-02 2023-08-05 13 8 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
ConfigBuilder.scala
in common/src/main/scala/org/apache/celeborn/common/internal/config
 240 23 2022-10-02 2023-07-04 9 5 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com
Platform.java
in common/src/main/java/org/apache/celeborn/common/unsafe
 235 28 2022-10-02 2022-11-16 2 2 zky.zhoukeyong@alibaba-inc.com gabrielleebuaa@gmail.com
DfsPartitionReader.java
in client/src/main/java/org/apache/celeborn/client/read
 228 8 2022-10-02 2023-08-05 10 6 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
DeviceInfo.scala
in common/src/main/scala/org/apache/celeborn/common/meta
 225 17 2022-10-02 2023-07-06 10 7 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org
WorkerInfo.scala
in common/src/main/scala/org/apache/celeborn/common/meta
 219 19 2022-10-02 2023-07-14 16 10 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
ShutdownHookManager.java
in common/src/main/java/org/apache/celeborn/common/util
 194 19 2022-10-02 2023-07-19 6 4 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com
DataPusher.java
in client/src/main/java/org/apache/celeborn/client/write
 193 10 2022-10-02 2023-07-31 14 6 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
Outbox.scala
in common/src/main/scala/org/apache/celeborn/common/rpc/netty
 186 13 2022-10-02 2022-11-08 2 2 zky.zhoukeyong@alibaba-inc.com 490081539@qq.com
Message.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 185 15 2022-10-02 2023-08-05 10 5 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
ConfigEntry.scala
in common/src/main/scala/org/apache/celeborn/common/internal/config
 185 8 2022-10-02 2023-07-04 12 7 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com
TransportClientFactory.java
in common/src/main/java/org/apache/celeborn/common/network/client
 181 8 2022-10-02 2023-08-05 13 8 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
FileInfo.java
in common/src/main/java/org/apache/celeborn/common/meta
 177 31 2022-10-02 2023-07-05 12 7 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
ThreadUtils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 168 13 2022-10-02 2023-06-19 3 3 zky.zhoukeyong@alibaba-inc.com sychen@ctrip.com
WorkerPartitionReader.java
in client/src/main/java/org/apache/celeborn/client/read
 166 8 2022-10-02 2023-08-05 13 8 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
Dispatcher.scala
in common/src/main/scala/org/apache/celeborn/common/rpc/netty
 164 12 2022-10-02 2023-07-06 5 5 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org
Inbox.scala
in common/src/main/scala/org/apache/celeborn/common/rpc/netty
 156 5 2022-10-02 2022-11-08 2 2 zky.zhoukeyong@alibaba-inc.com 490081539@qq.com
TransportChannelHandler.java
in common/src/main/java/org/apache/celeborn/common/network/server
 141 9 2022-10-02 2023-07-19 3 3 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com
MetricsSystem.scala
in common/src/main/scala/org/apache/celeborn/common/metrics
 134 10 2022-10-02 2023-06-19 4 3 zky.zhoukeyong@alibaba-inc.com sychen@ctrip.com
TransportFrameDecoder.java
in common/src/main/java/org/apache/celeborn/common/network/util
 126 8 2022-10-02 2023-06-14 3 3 zky.zhoukeyong@alibaba-inc.com lvshuang.tb@gmail.com
NettyUtils.java
in common/src/main/java/org/apache/celeborn/common/network/util
 123 8 2022-10-02 2023-06-08 5 4 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com
MessageWithHeader.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 121 9 2022-10-02 2023-07-19 2 2 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com
FileSegmentManagedBuffer.java
in common/src/main/java/org/apache/celeborn/common/network/buffer
 119 11 2022-10-02 2023-02-28 2 2 zky.zhoukeyong@alibaba-inc.com zhouky@apache.org
NettyMemoryMetrics.java
in common/src/main/java/org/apache/celeborn/common/network/util
 118 4 2022-10-02 2023-07-03 4 4 zky.zhoukeyong@alibaba-inc.com chengpan@apache.org
TransportServer.java
in common/src/main/java/org/apache/celeborn/common/network/server
 118 6 2022-10-02 2023-07-25 6 5 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com
TransportContext.java
in common/src/main/java/org/apache/celeborn/common/network
 115 13 2022-10-02 2023-07-19 7 5 zky.zhoukeyong@alibaba-inc.com lyh-36@163.com
StorageInfo.java
in common/src/main/java/org/apache/celeborn/common/protocol
 110 18 2022-10-02 2023-06-27 2 2 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
JavaSerializer.scala
in common/src/main/scala/org/apache/celeborn/common/serializer
 105 14 2022-10-02 2022-10-20 2 2 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com
ShuffleClient.java
in client/src/main/java/org/apache/celeborn/client
 103 4 2022-10-02 2023-07-31 26 13 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
PushMergedData.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 96 10 2022-10-02 2023-06-29 2 2 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
PushData.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 82 10 2022-10-02 2023-06-29 3 3 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
Quota.scala
in common/src/main/scala/org/apache/celeborn/common/quota
 81 6 2022-10-02 2022-12-15 5 3 zky.zhoukeyong@alibaba-inc.com 30563796+nafiyaix@users.nor...
TransportConf.java
in common/src/main/java/org/apache/celeborn/common/network/util
 76 23 2022-10-02 2023-06-15 8 5 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com
LimitedInputStream.java
in common/src/main/java/org/apache/celeborn/common/network/util
 76 9 2022-10-02 2023-03-02 2 2 zky.zhoukeyong@alibaba-inc.com zhouky@apache.org
OpenStream.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 75 9 2022-10-02 2023-08-05 2 2 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
TransportRequestHandler.java
in common/src/main/java/org/apache/celeborn/common/network/server
 73 7 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
MetricsConfig.scala
in common/src/main/scala/org/apache/celeborn/common/metrics
 71 5 2022-10-02 2023-07-04 5 3 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com
Serializer.scala
in common/src/main/scala/org/apache/celeborn/common/serializer
 70 7 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
TransportMessage.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 65 6 2022-10-02 2023-08-05 3 3 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
ShuffleBlockInfoUtils.java
in common/src/main/java/org/apache/celeborn/common/util
 64 1 2022-10-02 2022-11-30 2 2 zky.zhoukeyong@alibaba-inc.com ethanfeng@apache.org
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
RpcEnvStoppedException.scala
in common/src/main/scala/org/apache/celeborn/common/rpc
 3 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
MetricsCallback.java
in client/src/main/java/org/apache/celeborn/client/read
 5 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
FrameDecoder.java
in common/src/main/java/org/apache/celeborn/common/network/util
 5 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
IOMode.java
in common/src/main/java/org/apache/celeborn/common/network/util
 5 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
AlreadyClosedException.scala
in common/src/main/scala/org/apache/celeborn/common/exception
 6 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
RpcCallContext.scala
in common/src/main/scala/org/apache/celeborn/common/rpc
 6 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
Sink.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/sink
 6 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
RpcResponseCallback.java
in common/src/main/java/org/apache/celeborn/common/network/client
 6 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
Encodable.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 6 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
PrometheusSink.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/sink
 8 3 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
TransportModuleConstants.java
in common/src/main/java/org/apache/celeborn/common/protocol
 8 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
MessageHandler.java
in common/src/main/java/org/apache/celeborn/common/network/server
 8 - 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
IntParam.scala
in common/src/main/scala/org/apache/celeborn/common/util
 10 1 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
RequestMessage.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 10 2 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
RpcEndpointVerifier.scala
in common/src/main/scala/org/apache/celeborn/common/rpc/netty
 12 1 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
ResponseMessage.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 13 3 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
BaseMessageHandler.java
in common/src/main/java/org/apache/celeborn/common/network/server
 14 5 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
PartitionSplitMode.java
in common/src/main/java/org/apache/celeborn/common/protocol
 20 2 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
MessageDecoder.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 22 2 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
ConfigProvider.java
in common/src/main/java/org/apache/celeborn/common/network/util
 26 5 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
PushTask.java
in client/src/main/java/org/apache/celeborn/client/write
 27 5 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
AbstractFileRegion.java
in common/src/main/java/org/apache/celeborn/common/network/util
 29 5 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
ByteBufferOutputStream.scala
in common/src/main/scala/org/apache/celeborn/common/util
 30 4 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
NextIterator.scala
in common/src/main/scala/org/apache/celeborn/common/util
 34 2 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
ResettableSlidingWindowReservoir.scala
in common/src/main/scala/org/apache/celeborn/common/metrics
 35 3 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
ChunkFetchRequest.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 40 8 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
CsvSink.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/sink
 41 3 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
NioManagedBuffer.java
in common/src/main/java/org/apache/celeborn/common/network/buffer
 41 8 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
ByteBufferInputStream.scala
in common/src/main/scala/org/apache/celeborn/common/util
 44 5 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
ChunkFetchFailure.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 48 8 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
RpcFailure.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 48 8 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
OneWayMessage.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 50 9 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
Logging.scala
in common/src/main/scala/org/apache/celeborn/common/internal
 51 10 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
MessageEncoder.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 51 2 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
ByteUnit.java
in common/src/main/java/org/apache/celeborn/common/network/util
 53 8 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
RpcRequest.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 54 9 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
ConfigReader.scala
in common/src/main/scala/org/apache/celeborn/common/internal/config
 55 4 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
GraphiteSink.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/sink
 55 4 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
RpcResponse.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 57 10 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
StreamChunkSlice.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 63 8 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
Encoders.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 63 7 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
Serializer.scala
in common/src/main/scala/org/apache/celeborn/common/serializer
 70 7 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
TransportRequestHandler.java
in common/src/main/java/org/apache/celeborn/common/network/server
 73 7 2022-10-02 2022-10-02 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
OpenByteArrayOutputStream.java
in client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn
 10 1 2022-10-08 2022-10-08 1 1 chengpan@apache.org chengpan@apache.org
WorkingPartition.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker
 13 2 2022-10-08 2022-10-08 1 1 chengpan@apache.org chengpan@apache.org
HttpServerInitializer.scala
in service/src/main/scala/org/apache/celeborn/server/common/http
 13 1 2022-10-08 2022-10-08 1 1 chengpan@apache.org chengpan@apache.org
FlushNotifier.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 20 3 2022-10-08 2022-10-08 1 1 chengpan@apache.org chengpan@apache.org
PackedRecordPointer.java
in client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn
 30 4 2022-10-08 2022-10-08 1 1 chengpan@apache.org chengpan@apache.org
LevelDBProvider.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker
 110 7 2022-10-08 2022-10-08 1 1 chengpan@apache.org chengpan@apache.org
ShuffleRecoverHelper.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker
 15 1 2022-10-08 2022-10-13 3 2 chengpan@apache.org 30563796+nafiyaix@users.nor...
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
588 4 2023-07-28 2023-08-01 2 1 cfmcgrady@gmail.com cfmcgrady@gmail.com
151 - 2023-07-28 2023-07-28 1 1 cfmcgrady@gmail.com cfmcgrady@gmail.com
plugins.sbt
in project
 2 - 2023-07-28 2023-07-28 1 1 cfmcgrady@gmail.com cfmcgrady@gmail.com
1 - 2023-07-28 2023-07-28 1 1 cfmcgrady@gmail.com cfmcgrady@gmail.com
CelebornExitKind.scala
in common/src/main/scala/org/apache/celeborn/common/util
 6 - 2023-07-25 2023-07-25 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornInputStream.java
in client/src/main/java/org/apache/celeborn/client/read
 497 20 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornColumnType.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 485 94 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornCompressionSchemes.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 355 24 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornColumnBuilder.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 299 17 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornColumnarBatchCodeGenBuild.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 271 3 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornColumnStats.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 233 21 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornBufferStream.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient
 154 10 2023-07-04 2023-08-08 2 2 angers.zhu@gmail.com lvshuang.tb@gmail.com
CelebornColumnarBatchSerializer.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 138 8 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornShuffleReader.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn
 111 1 2023-07-04 2023-07-19 3 3 angers.zhu@gmail.com chengpan@apache.org
CelebornColumnAccessor.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 105 8 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornColumnarBatchBuilder.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 102 4 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornShuffleReader.scala
in client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn
 94 1 2023-07-04 2023-07-19 3 3 angers.zhu@gmail.com chengpan@apache.org
CelebornCompressibleColumnBuilder.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 67 6 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
ZstdCompressor.java
in client/src/main/java/org/apache/celeborn/client/compress
 62 4 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
Lz4Compressor.java
in client/src/main/java/org/apache/celeborn/client/compress
 55 4 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
ZstdDecompressor.java
in client/src/main/java/org/apache/celeborn/client/compress
 50 3 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornNullableColumnBuilder.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 49 4 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornCompressionScheme.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 48 6 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
Lz4Decompressor.java
in client/src/main/java/org/apache/celeborn/client/compress
 48 3 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornNullableColumnAccessor.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 46 3 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornShuffleFallbackPolicyRunner.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn
 38 4 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornColumnDictionary.java
in client-spark/spark-3/src/main/java/org/apache/spark/sql/execution/columnar
 36 7 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornShuffleFallbackPolicyRunner.scala
in client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn
 32 3 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornBatchBuilder.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 28 2 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornCompressibleColumnAccessor.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar
 18 2 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
Lz4Trait.java
in client/src/main/java/org/apache/celeborn/client/compress
 14 - 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornShuffleHandle.scala
in client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn
 13 - 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornShuffleHandle.scala
in client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn
 13 - 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
ZstdTrait.java
in client/src/main/java/org/apache/celeborn/client/compress
 13 - 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornTimer.scala
in common/src/main/scala/org/apache/celeborn/common/metrics
 3 - 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
CelebornHistogram.scala
in common/src/main/scala/org/apache/celeborn/common/metrics
 3 - 2023-07-04 2023-07-04 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
SparkShuffleManager.java
in client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn
 287 14 2023-06-30 2023-07-20 7 4 angers.zhu@gmail.com angers.zhu@gmail.com
SparkShuffleManager.java
in client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn
 202 12 2023-06-30 2023-07-20 8 5 angers.zhu@gmail.com angers.zhu@gmail.com
MasterClient.java
in common/src/main/java/org/apache/celeborn/common/client
 170 15 2023-06-29 2023-07-19 3 2 angers.zhu@gmail.com lyh-36@163.com
MasterNotLeaderException.java
in common/src/main/java/org/apache/celeborn/common/client
 21 2 2023-06-29 2023-06-29 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
ReviveManager.java
in client/src/main/java/org/apache/celeborn/client
 92 2 2023-06-27 2023-07-25 3 2 zky.zhoukeyong@alibaba-inc.com 1178404354@qq.com
ReviveRequest.java
in common/src/main/java/org/apache/celeborn/common/protocol
 29 1 2023-06-27 2023-06-27 1 1 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
FetchRequestInfo.java
in common/src/main/java/org/apache/celeborn/common/read
 15 2 2023-06-15 2023-06-15 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
406 14 2023-06-02 2023-06-02 1 1 chengpan@apache.org chengpan@apache.org
CelebornRackResolver.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master/network
 64 4 2023-05-18 2023-06-29 3 2 angers.zhu@gmail.com cfmcgrady@gmail.com
SimpleStateMachineStorageUtil.java
in master/src/main/java/org/apache/ratis/statemachine/impl
 13 2 2023-05-18 2023-05-18 1 1 ckj@apache.org ckj@apache.org
TaskInterruptedHelper.java
in client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn
 12 1 2023-05-17 2023-05-17 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
SystemMiscSource.scala
in common/src/main/scala/org/apache/celeborn/common/metrics/source
 27 - 2023-05-16 2023-05-16 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
DriverChangedException.scala
in common/src/main/scala/org/apache/celeborn/common/exception
 5 - 2023-05-16 2023-05-16 1 1 lvshuang.tb@gmail.com lvshuang.tb@gmail.com
Heartbeat.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 20 4 2023-05-10 2023-06-14 2 2 zhongqiang.czq@alibaba-inc.com lvshuang.tb@gmail.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
LifecycleManager.scala
in client/src/main/scala/org/apache/celeborn/client
 884 33 2022-10-08 2023-08-08 71 14 angers.zhu@gmail.com fengmingxiao.fmx@alibaba-in...
FlinkShuffleClientImpl.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient
 485 17 2023-02-17 2023-08-08 21 11 ethanfeng@apache.org fengmingxiao.fmx@alibaba-in...
MapDataPartitionReader.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 380 27 2023-04-20 2023-08-08 4 3 ethanfeng@apache.org lvshuang.tb@gmail.com
FetchHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 319 13 2022-10-08 2023-08-08 26 9 chengpan@apache.org lvshuang.tb@gmail.com
ChangePartitionManager.scala
in client/src/main/scala/org/apache/celeborn/client
 267 8 2022-12-05 2023-08-08 19 6 angers.zhu@gmail.com fengmingxiao.fmx@alibaba-in...
CelebornBufferStream.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient
 154 10 2023-07-04 2023-08-08 2 2 angers.zhu@gmail.com lvshuang.tb@gmail.com
RemoteBufferStreamReader.java
in client-flink/common/src/main/java/org/apache/celeborn/plugin/flink
 118 9 2023-05-04 2023-08-08 4 4 ethanfeng@apache.org lvshuang.tb@gmail.com
ExceptionUtils.java
in common/src/main/java/org/apache/celeborn/common/util
 38 3 2023-01-11 2023-08-08 5 2 lvshuang.tb@gmail.com lvshuang.tb@gmail.com
CelebornConf.scala
in common/src/main/scala/org/apache/celeborn/common
 3090 81 2022-10-20 2023-08-07 92 20 angers.zhu@gmail.com zky.zhoukeyong@alibaba-inc.com
ControlMessages.scala
in common/src/main/scala/org/apache/celeborn/common/protocol/message
 842 14 2022-10-02 2023-08-07 40 12 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
Master.scala
in master/src/main/scala/org/apache/celeborn/service/deploy/master
 783 23 2022-10-08 2023-08-07 55 11 angers.zhu@gmail.com zky.zhoukeyong@alibaba-inc.com
proto
TransportMessages.proto
in common/src/main/proto
 407 - 2022-01-29 2023-08-07 60 11 fengmingxiao.fmx@alibaba-in... zky.zhoukeyong@alibaba-inc.com
TransportResponseHandler.java
in common/src/main/java/org/apache/celeborn/common/network/client
 307 17 2022-10-02 2023-08-05 13 6 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
TransportClient.java
in common/src/main/java/org/apache/celeborn/common/network/client
 253 24 2022-10-02 2023-08-05 13 8 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
DfsPartitionReader.java
in client/src/main/java/org/apache/celeborn/client/read
 228 8 2022-10-02 2023-08-05 10 6 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
Message.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 185 15 2022-10-02 2023-08-05 10 5 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
TransportClientFactory.java
in common/src/main/java/org/apache/celeborn/common/network/client
 181 8 2022-10-02 2023-08-05 13 8 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
WorkerPartitionReader.java
in client/src/main/java/org/apache/celeborn/client/read
 166 8 2022-10-02 2023-08-05 13 8 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
OpenStream.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 75 9 2022-10-02 2023-08-05 2 2 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
TransportMessage.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 65 6 2022-10-02 2023-08-05 3 3 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
OpenStreamWithCredit.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 60 5 2023-02-16 2023-08-05 2 2 ethanfeng@apache.org fengmingxiao.fmx@alibaba-in...
StreamHandle.java
in common/src/main/java/org/apache/celeborn/common/network/protocol
 47 8 2022-10-02 2023-08-05 2 2 zky.zhoukeyong@alibaba-inc.com fengmingxiao.fmx@alibaba-in...
Utils.scala
in common/src/main/scala/org/apache/celeborn/common/util
 882 78 2022-10-02 2023-08-04 40 16 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
StorageManager.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage
 713 28 2022-10-08 2023-08-04 47 19 chengpan@apache.org fengmingxiao.fmx@alibaba-in...
FileWriter.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 364 29 2022-10-08 2023-08-04 24 10 chengpan@apache.org fengmingxiao.fmx@alibaba-in...
mkdocs.yml
in root
 75 - 2022-09-09 2023-08-04 14 5 chengpan@apache.org xiyu.zk@alibaba-inc.com
SlotsAllocator.java
in master/src/main/java/org/apache/celeborn/service/deploy/master
 411 6 2022-10-08 2023-08-03 7 5 chengpan@apache.org 2213335496@qq.com
PushDataHandler.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 953 23 2022-10-08 2023-08-01 47 15 chengpan@apache.org caojiaqing@bilibili.com
588 4 2023-07-28 2023-08-01 2 1 cfmcgrady@gmail.com cfmcgrady@gmail.com
WorkerSource.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 83 - 2022-10-08 2023-08-01 18 10 chengpan@apache.org caojiaqing@bilibili.com
DataPusher.java
in client/src/main/java/org/apache/celeborn/client/write
 193 10 2022-10-02 2023-07-31 14 6 zky.zhoukeyong@alibaba-inc.com cfmcgrady@gmail.com
ShuffleClient.java
in client/src/main/java/org/apache/celeborn/client
 103 4 2022-10-02 2023-07-31 26 13 zky.zhoukeyong@alibaba-inc.com zky.zhoukeyong@alibaba-inc.com
151 - 2023-07-28 2023-07-28 1 1 cfmcgrady@gmail.com cfmcgrady@gmail.com
plugins.sbt
in project
 2 - 2023-07-28 2023-07-28 1 1 cfmcgrady@gmail.com cfmcgrady@gmail.com
1 - 2023-07-28 2023-07-28 1 1 cfmcgrady@gmail.com cfmcgrady@gmail.com
PartitionFilesSorter.java
in worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage
 608 27 2022-10-08 2023-07-27 22 7 chengpan@apache.org fengmingxiao.fmx@alibaba-in...
Worker.scala
in worker/src/main/scala/org/apache/celeborn/service/deploy/worker
 595 12 2022-10-08 2023-07-27 62 18 chengpan@apache.org angers.zhu@gmail.com
AbstractMetaManager.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta
 267 12 2022-10-08 2023-07-27 26 9 chengpan@apache.org angers.zhu@gmail.com
HAMasterMetaManager.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha
 257 13 2022-10-08 2023-07-27 13 6 chengpan@apache.org angers.zhu@gmail.com
SingleMasterMetaManager.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta
 98 11 2022-10-08 2023-07-27 10 4 chengpan@apache.org angers.zhu@gmail.com
HttpRequestHandler.scala
in service/src/main/scala/org/apache/celeborn/server/common/http
 73 3 2022-10-08 2023-07-27 8 3 chengpan@apache.org angers.zhu@gmail.com
HttpService.scala
in service/src/main/scala/org/apache/celeborn/server/common
 73 5 2022-10-08 2023-07-27 16 6 chengpan@apache.org angers.zhu@gmail.com
IMetadataHandler.java
in master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta
 44 - 2022-10-08 2023-07-27 5 4 chengpan@apache.org angers.zhu@gmail.com
ShuffleClientImpl.java
in client/src/main/java/org/apache/celeborn/client
 1513 45 2022-10-02 2023-07-25 73 20 zky.zhoukeyong@alibaba-inc.com 1178404354@qq.com
TransportServer.java
in common/src/main/java/org/apache/celeborn/common/network/server
 118 6 2022-10-02 2023-07-25 6 5 zky.zhoukeyong@alibaba-inc.com angers.zhu@gmail.com
ReviveManager.java
in client/src/main/java/org/apache/celeborn/client
 92 2 2023-06-27 2023-07-25 3 2 zky.zhoukeyong@alibaba-inc.com 1178404354@qq.com
HttpServer.scala
in service/src/main/scala/org/apache/celeborn/server/common/http
 64 2 2022-10-08 2023-07-25 3 3 chengpan@apache.org angers.zhu@gmail.com
Service.scala
in service/src/main/scala/org/apache/celeborn/server/common
 20 2 2022-10-08 2023-07-25 5 3 chengpan@apache.org angers.zhu@gmail.com
CelebornExitKind.scala
in common/src/main/scala/org/apache/celeborn/common/util
 6 - 2023-07-25 2023-07-25 1 1 angers.zhu@gmail.com angers.zhu@gmail.com
SparkShuffleManager.java
in client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn
 287 14 2023-06-30 2023-07-20 7 4 angers.zhu@gmail.com angers.zhu@gmail.com