uber / RemoteShuffleService
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 271 files with 17,066 lines of code in files.
    • 271 files that are 366+ days old (17,066 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)
100% | 0% | 0% | 0% | 0%
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 271 files with 17,066 lines of code in files.
    • 271 files have been last changed 366+ days ago (17,066 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)
100% | 0% | 0% | 0% | 0%
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, properties, yaml, txt, gitignore, xml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
scala100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
scala100% | 0% | 0% | 0% | 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
src100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
src100% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
StreamServerStressTool.java
in src/main/java/com/uber/rss/tools
615 36 2020-08-20 2021-06-16 10 3 boy@uber.com mabansal@uber.com
ShuffleExecutor.java
in src/main/java/com/uber/rss/execution
547 31 2020-08-20 2020-10-26 12 3 boy@uber.com boy@uber.com
ReplicatedReadClient.java
in src/main/java/com/uber/rss/clients
365 21 2020-08-20 2020-10-09 5 2 boy@uber.com boy@uber.com
RssShuffleManager.scala
in src/main/scala/org/apache/spark/shuffle
364 8 2020-08-20 2023-01-30 13 7 boy@uber.com mabansal@uber.com
StreamServerMessageDecoder.java
in src/main/java/com/uber/rss/decoders
347 8 2020-08-20 2021-06-16 10 3 boy@uber.com mabansal@uber.com
MultiServerAsyncWriteClient.java
in src/main/java/com/uber/rss/clients
332 21 2020-08-20 2020-10-09 5 2 boy@uber.com boy@uber.com
StreamServer.java
in src/main/java/com/uber/rss
303 21 2020-08-20 2020-10-23 10 3 boy@uber.com boy-uber@users.noreply.gith...
DataBlockSocketReadClient.java
in src/main/java/com/uber/rss/clients
299 13 2020-08-20 2020-10-30 8 2 boy@uber.com boy@uber.com
StreamServerConfig.java
in src/main/java/com/uber/rss
283 50 2020-08-20 2020-10-23 9 3 boy@uber.com boy-uber@users.noreply.gith...
ClientBase.java
in src/main/java/com/uber/rss/clients
268 17 2020-08-20 2020-09-02 2 1 boy@uber.com boy@uber.com
PooledWriteClientFactory.java
in src/main/java/com/uber/rss/clients
253 30 2020-08-20 2020-10-09 3 2 boy@uber.com boy@uber.com
ExecutorShuffleStageState.java
in src/main/java/com/uber/rss/execution
229 27 2020-08-20 2020-10-16 5 2 boy@uber.com boy@uber.com
LocalFileStateStore.java
in src/main/java/com/uber/rss/execution
204 15 2020-08-20 2020-10-29 3 2 boy@uber.com boy@uber.com
ZooKeeperServiceRegistry.java
in src/main/java/com/uber/rss/metadata
191 15 2020-08-20 2021-07-20 3 3 boy@uber.com mabansal@uber.com
UploadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
184 6 2020-08-20 2021-06-16 16 3 boy@uber.com mabansal@uber.com
RssShuffleWriter.scala
in src/main/scala/org/apache/spark/shuffle
181 6 2020-08-20 2023-01-30 12 7 boy@uber.com mabansal@uber.com
RssOpts.scala
in src/main/scala/org/apache/spark/shuffle
175 - 2020-08-20 2023-01-30 14 6 boy@uber.com mabansal@uber.com
BlockDownloaderPartitionRangeRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
175 5 2020-08-20 2023-01-30 10 5 boy@uber.com mabansal@uber.com
BlockDownloaderPartitionRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
174 4 2020-08-20 2023-01-30 7 4 boy@uber.com mabansal@uber.com
LocalFileStateStoreIterator.java
in src/main/java/com/uber/rss/execution
173 8 2020-08-20 2020-10-29 2 2 boy@uber.com boy@uber.com
SerializerBenchmark.java
in src/main/java/com/uber/rss/tools
164 4 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
MultiServerSyncWriteClient.java
in src/main/java/com/uber/rss/clients
160 14 2020-08-20 2020-10-09 4 2 boy@uber.com boy@uber.com
DownloadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
159 7 2020-08-20 2020-10-30 12 3 boy@uber.com boy@uber.com
StreamReadClientVerify.java
in src/main/java/com/uber/rss/tools
156 9 2020-08-20 2020-10-09 5 2 boy@uber.com boy@uber.com
DownloadServerHandler.java
in src/main/java/com/uber/rss/handlers
155 7 2020-08-20 2021-06-16 10 3 boy@uber.com mabansal@uber.com
ReplicatedWriteClient.java
in src/main/java/com/uber/rss/clients
153 12 2020-08-20 2020-10-09 4 2 boy@uber.com boy@uber.com
ServiceRegistryUtils.java
in src/main/java/com/uber/rss/metadata
151 5 2020-08-20 2021-06-15 6 3 boy@uber.com mabansal@uber.com
MultiServerSocketReadClient.java
in src/main/java/com/uber/rss/clients
149 9 2020-08-20 2020-10-09 5 2 boy@uber.com boy@uber.com
ShufflePartitionWriter.java
in src/main/java/com/uber/rss/execution
147 13 2020-08-20 2020-10-16 5 2 boy@uber.com boy@uber.com
DataBlockSyncWriteClient.java
in src/main/java/com/uber/rss/clients
142 10 2020-08-20 2020-10-30 5 2 boy@uber.com boy@uber.com
FsyncPerfTest.java
in src/main/java/com/uber/rss/tools
131 4 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
ServerIdAwareSyncWriteClient.java
in src/main/java/com/uber/rss/clients
127 10 2020-08-20 2020-10-09 4 2 boy@uber.com boy@uber.com
FileUtils.java
in src/main/java/com/uber/rss/util
119 5 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
StreamServerStressToolLongRun.java
in src/main/java/com/uber/rss/tools
118 2 2020-08-20 2020-10-16 3 2 boy@uber.com boy@uber.com
StreamDecoderBase.java
in src/main/java/com/uber/rss/clients
117 9 2020-08-20 2021-06-15 3 2 boy@uber.com mabansal@uber.com
StreamServerVersionDecoder.java
in src/main/java/com/uber/rss/decoders
113 3 2020-08-20 2020-10-26 6 3 boy@uber.com boy@uber.com
RssSparkListener.scala
in src/main/scala/org/apache/spark/shuffle/rss
111 6 2020-08-20 2020-09-30 2 2 boy@uber.com boy@uber.com
M3Stats.java
in src/main/java/com/uber/rss/metrics
106 7 2020-08-20 2021-06-16 3 3 boy@uber.com mabansal@uber.com
ServerBusyRetriableWriteClient.java
in src/main/java/com/uber/rss/clients
106 9 2020-08-20 2021-06-15 5 3 boy@uber.com mabansal@uber.com
UploadServerHandler.java
in src/main/java/com/uber/rss/handlers
103 12 2020-08-20 2020-10-26 9 3 boy@uber.com boy@uber.com
PartitionFileChecker.java
in src/main/java/com/uber/rss/tools
98 2 2020-08-20 2023-01-30 3 3 boy@uber.com mabansal@uber.com
ScheduledMetricCollector.java
in src/main/java/com/uber/rss/metrics
97 3 2020-08-20 2020-09-30 3 2 boy@uber.com boy@uber.com
RetryUtils.java
in src/main/java/com/uber/rss/util
96 4 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
StringUtils.java
in src/main/java/com/uber/rss/util
95 2 2020-08-20 2020-09-30 2 2 boy@uber.com boy@uber.com
ServiceRegistryWrapper.java
in src/main/java/com/uber/rss/metadata
93 9 2020-08-20 2021-06-17 2 3 boy@uber.com harshvardhan5795@gmail.com
M3DummyScope.java
in src/main/java/com/uber/rss/metrics
92 8 2020-08-20 2020-10-05 2 2 boy@uber.com boy@uber.com
RetriableSocketReadClient.java
in src/main/java/com/uber/rss/clients
92 7 2020-08-20 2020-10-09 5 2 boy@uber.com boy@uber.com
RssShuffleReader.scala
in src/main/scala/org/apache/spark/shuffle
90 1 2020-08-20 2023-01-30 7 5 boy@uber.com mabansal@uber.com
ConnectDownloadRequest.java
in src/main/java/com/uber/rss/messages
85 12 2020-08-20 2020-10-09 2 2 boy@uber.com boy@uber.com
BlockingQueueReadClient.java
in src/main/java/com/uber/rss/clients
84 6 2020-08-20 2021-06-15 3 3 boy@uber.com mabansal@uber.com
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
RssServerSelectionResult.scala
in src/main/scala/org/apache/spark/shuffle
3 - 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
SocketAsyncWriteCallback.java
in src/main/java/com/uber/rss/util
3 - 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
ControlMessage.java
in src/main/java/com/uber/rss/messages
3 - 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
LowMemoryListener.java
in src/main/java/com/uber/rss/common
4 - 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
BaseMessage.java
in src/main/java/com/uber/rss/messages
4 - 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
ServerConnectionRefresher.java
in src/main/java/com/uber/rss/clients
5 - 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
ServerConnectionStringResolver.java
in src/main/java/com/uber/rss/clients
5 - 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
SerializableMessage.java
in src/main/java/com/uber/rss/messages
5 - 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
ServerRole.java
in src/main/java/com/uber/rss/common
6 - 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssShuffleServerHandle.scala
in src/main/scala/org/apache/spark/shuffle
7 1 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssServerBusyException.java
in src/main/java/com/uber/rss/exceptions
8 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssNoServerAvailableException.java
in src/main/java/com/uber/rss/exceptions
8 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssInvalidMapStatusException.java
in src/main/java/com/uber/rss/exceptions
8 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssTooMuchDataException.java
in src/main/java/com/uber/rss/exceptions
8 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssServerDownException.java
in src/main/java/com/uber/rss/exceptions
8 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssMissingShuffleWriteConfigException.java
in src/main/java/com/uber/rss/exceptions
9 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssShuffleStageNotStartedException.java
in src/main/java/com/uber/rss/exceptions
9 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssFileCorruptedException.java
in src/main/java/com/uber/rss/exceptions
9 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssShuffleDataNotAvailableException.java
in src/main/java/com/uber/rss/exceptions
9 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssShuffleCorruptedException.java
in src/main/java/com/uber/rss/exceptions
9 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssStaleTaskAttemptException.java
in src/main/java/com/uber/rss/exceptions
9 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
LogUtils.java
in src/main/java/com/uber/rss/util
9 1 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssShuffleBlockResolver.scala
in src/main/scala/org/apache/spark/shuffle
10 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
EmptyRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
11 1 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssRetryTimeoutException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssInvalidServerIdException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssInvalidServerVersionException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssWriteRecordException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssNoActiveReadClientException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssRetryableSparkTaskException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssUberEnvironmentException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssNonRecoverableException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssFinishUploadException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssQueueNotReadyException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssInconsistentReplicaException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssServerResolveException.java
in src/main/java/com/uber/rss/exceptions
11 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
ExceptionMetricGroupContainer.java
in src/main/java/com/uber/rss/metrics
12 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
MetadataClientMetricsContainer.java
in src/main/java/com/uber/rss/metrics
12 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
ServerResponseMessage.java
in src/main/java/com/uber/rss/messages
13 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
NettyServerSideMetricGroupContainer.java
in src/main/java/com/uber/rss/metrics
14 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
NettyUtils.java
in src/main/java/com/uber/rss/util
14 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
SystemUtils.java
in src/main/java/com/uber/rss/util
14 1 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
ShuffleStorage.java
in src/main/java/com/uber/rss/storage
14 - 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
MetricGroup.java
in src/main/java/com/uber/rss/metrics
15 2 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
ThreadUtils.java
in src/main/java/com/uber/rss/util
15 1 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
ExceptionWrapper.java
in src/main/java/com/uber/rss/exceptions
16 3 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssStreamReadException.java
in src/main/java/com/uber/rss/exceptions
17 5 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssDiskSpaceException.java
in src/main/java/com/uber/rss/exceptions
17 5 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssUnsupportedCompressionException.java
in src/main/java/com/uber/rss/exceptions
17 5 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
RssInvalidDataException.java
in src/main/java/com/uber/rss/exceptions
17 5 2020-08-20 2020-08-20 1 1 boy@uber.com boy@uber.com
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
LazyWriteClient.java
in src/main/java/com/uber/rss/clients
70 9 2021-07-19 2021-07-22 2 2 mayurb@uber.com mabansal@uber.com
RssServiceRegistry.scala
in src/main/scala/org/apache/spark/shuffle
63 2 2021-06-17 2021-06-17 1 2 mabansal@uber.com harshvardhan5795@gmail.com
WriterAggregationImpl.scala
in src/main/scala/org/apache/spark/shuffle/rss
99 6 2021-06-16 2021-06-16 1 2 mabansal@uber.com mayurdb31@gmail.com
WriterAggregationManager.scala
in src/main/scala/org/apache/spark/shuffle/rss
32 2 2021-06-16 2021-06-16 1 2 mabansal@uber.com mayurdb31@gmail.com
WriterNoAggregationManager.scala
in src/main/scala/org/apache/spark/shuffle/rss
14 1 2021-06-16 2021-06-16 1 2 mabansal@uber.com mayurdb31@gmail.com
BlockingShuffleDataReader.java
in src/main/java/com/uber/rss/clients
6 - 2021-06-15 2021-06-15 1 1 mabansal@uber.com mabansal@uber.com
BlockingSingleServerReadClient.java
in src/main/java/com/uber/rss/clients
5 - 2021-06-15 2021-06-15 1 1 mabansal@uber.com mabansal@uber.com
ConnectDownloadRequestMessage.java
in src/main/java/com/uber/rss/messages
89 12 2021-06-12 2021-06-15 2 1 mabansal@uber.com mabansal@uber.com
GetDataAvailabilityRequestMessage.java
in src/main/java/com/uber/rss/messages
21 5 2021-06-12 2021-06-15 2 1 mabansal@uber.com mabansal@uber.com
ChannelIdleCheck.java
in src/main/java/com/uber/rss/handlers
52 6 2020-10-26 2020-10-26 1 2 boy-uber@users.noreply.gith... boy@uber.com
ChannelFutureCloseListener.java
in src/main/java/com/uber/rss/handlers
17 2 2020-10-26 2020-10-26 1 2 boy-uber@users.noreply.gith... boy@uber.com
GetBusyStatusResponse.java
in src/main/java/com/uber/rss/messages
60 7 2020-10-13 2020-10-13 1 2 boy-uber@users.noreply.gith... boy@uber.com
MovingAverageCalculator.java
in src/main/java/com/uber/rss/util
33 3 2020-10-13 2020-10-13 1 2 boy-uber@users.noreply.gith... boy@uber.com
BusyStatusSocketClient.java
in src/main/java/com/uber/rss/clients
32 3 2020-10-13 2020-10-29 2 3 boy-uber@users.noreply.gith... mabansal@uber.com
GetBusyStatusRequest.java
in src/main/java/com/uber/rss/messages
30 6 2020-10-13 2020-10-13 1 2 boy-uber@users.noreply.gith... boy@uber.com
ServerCandidate.java
in src/main/java/com/uber/rss/common
28 5 2020-10-13 2020-10-29 3 3 boy-uber@users.noreply.gith... mabansal@uber.com
PooledShuffleDataSyncWriteClient.java
in src/main/java/com/uber/rss/clients
113 16 2020-10-09 2020-10-09 1 2 boy-uber@users.noreply.gith... boy@uber.com
ShuffleDataSyncWriteClientBase.java
in src/main/java/com/uber/rss/clients
86 14 2020-10-09 2020-10-09 1 2 boy-uber@users.noreply.gith... boy@uber.com
ShuffleDataSocketReadClient.java
in src/main/java/com/uber/rss/clients
83 7 2020-10-09 2020-10-26 2 2 boy-uber@users.noreply.gith... boy@uber.com
TaskDataBlock.java
in src/main/java/com/uber/rss/clients
48 6 2020-10-09 2020-10-09 1 2 boy-uber@users.noreply.gith... boy@uber.com
PlainShuffleDataSyncWriteClient.java
in src/main/java/com/uber/rss/clients
26 3 2020-10-09 2020-10-26 2 2 boy-uber@users.noreply.gith... boy@uber.com
PlainShuffleDataSocketReadClient.java
in src/main/java/com/uber/rss/clients
18 2 2020-10-09 2020-10-26 2 2 boy-uber@users.noreply.gith... boy@uber.com
ShuffleDataSyncWriteClient.java
in src/main/java/com/uber/rss/clients
16 - 2020-10-09 2020-10-09 1 2 boy-uber@users.noreply.gith... boy@uber.com
ShuffleDataWriter.java
in src/main/java/com/uber/rss/clients
10 - 2020-10-09 2020-10-09 1 2 boy-uber@users.noreply.gith... boy@uber.com
ShuffleDataReader.java
in src/main/java/com/uber/rss/clients
6 - 2020-10-09 2020-10-09 1 2 boy-uber@users.noreply.gith... boy@uber.com
TaskByteArrayDataBlock.java
in src/main/java/com/uber/rss/clients
48 6 2020-10-05 2021-06-15 2 3 boy-uber@users.noreply.gith... mabansal@uber.com
RssStressTool.scala
in src/main/scala/org/apache/spark/shuffle/rss
348 10 2020-09-30 2023-01-30 11 7 boy-uber@users.noreply.gith... mabansal@uber.com
MultiServerHeartbeatClient.java
in src/main/java/com/uber/rss/clients
115 12 2020-09-30 2020-09-30 1 2 boy-uber@users.noreply.gith... boy@uber.com
WriterBufferManager.scala
in src/main/scala/org/apache/spark/shuffle/rss
105 5 2020-09-30 2021-06-16 3 4 boy-uber@users.noreply.gith... mayurdb31@gmail.com
FixedLengthInputStream.java
in src/main/java/com/uber/rss/common
86 12 2020-09-30 2020-09-30 1 2 boy-uber@users.noreply.gith... boy@uber.com
ServerHostAndPort.java
in src/main/java/com/uber/rss/util
57 8 2020-09-30 2020-09-30 1 2 boy-uber@users.noreply.gith... boy@uber.com
HeartbeatMessage.java
in src/main/java/com/uber/rss/messages
54 9 2020-09-30 2020-09-30 1 2 boy-uber@users.noreply.gith... boy@uber.com
MockTaskContext.scala
in src/main/scala/org/apache/spark/shuffle
50 13 2020-09-30 2020-09-30 1 2 boy-uber@users.noreply.gith... boy@uber.com
HeartbeatSocketClient.java
in src/main/java/com/uber/rss/clients
34 3 2020-09-30 2020-10-30 2 2 boy-uber@users.noreply.gith... boy@uber.com
MapTaskRssInfo.java
in src/main/java/com/uber/rss/common
62 9 2020-09-08 2020-09-30 2 2 boy@uber.com boy@uber.com
StreamServerStressTool.java
in src/main/java/com/uber/rss/tools
615 36 2020-08-20 2021-06-16 10 3 boy@uber.com mabansal@uber.com
ShuffleExecutor.java
in src/main/java/com/uber/rss/execution
547 31 2020-08-20 2020-10-26 12 3 boy@uber.com boy@uber.com
ReplicatedReadClient.java
in src/main/java/com/uber/rss/clients
365 21 2020-08-20 2020-10-09 5 2 boy@uber.com boy@uber.com
RssShuffleManager.scala
in src/main/scala/org/apache/spark/shuffle
364 8 2020-08-20 2023-01-30 13 7 boy@uber.com mabansal@uber.com
StreamServerMessageDecoder.java
in src/main/java/com/uber/rss/decoders
347 8 2020-08-20 2021-06-16 10 3 boy@uber.com mabansal@uber.com
MultiServerAsyncWriteClient.java
in src/main/java/com/uber/rss/clients
332 21 2020-08-20 2020-10-09 5 2 boy@uber.com boy@uber.com
StreamServer.java
in src/main/java/com/uber/rss
303 21 2020-08-20 2020-10-23 10 3 boy@uber.com boy-uber@users.noreply.gith...
DataBlockSocketReadClient.java
in src/main/java/com/uber/rss/clients
299 13 2020-08-20 2020-10-30 8 2 boy@uber.com boy@uber.com
StreamServerConfig.java
in src/main/java/com/uber/rss
283 50 2020-08-20 2020-10-23 9 3 boy@uber.com boy-uber@users.noreply.gith...
ClientBase.java
in src/main/java/com/uber/rss/clients
268 17 2020-08-20 2020-09-02 2 1 boy@uber.com boy@uber.com
PooledWriteClientFactory.java
in src/main/java/com/uber/rss/clients
253 30 2020-08-20 2020-10-09 3 2 boy@uber.com boy@uber.com
ExecutorShuffleStageState.java
in src/main/java/com/uber/rss/execution
229 27 2020-08-20 2020-10-16 5 2 boy@uber.com boy@uber.com
LocalFileStateStore.java
in src/main/java/com/uber/rss/execution
204 15 2020-08-20 2020-10-29 3 2 boy@uber.com boy@uber.com
ZooKeeperServiceRegistry.java
in src/main/java/com/uber/rss/metadata
191 15 2020-08-20 2021-07-20 3 3 boy@uber.com mabansal@uber.com
UploadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
184 6 2020-08-20 2021-06-16 16 3 boy@uber.com mabansal@uber.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
RssShuffleManager.scala
in src/main/scala/org/apache/spark/shuffle
364 8 2020-08-20 2023-01-30 13 7 boy@uber.com mabansal@uber.com
RssStressTool.scala
in src/main/scala/org/apache/spark/shuffle/rss
348 10 2020-09-30 2023-01-30 11 7 boy-uber@users.noreply.gith... mabansal@uber.com
RssShuffleWriter.scala
in src/main/scala/org/apache/spark/shuffle
181 6 2020-08-20 2023-01-30 12 7 boy@uber.com mabansal@uber.com
RssOpts.scala
in src/main/scala/org/apache/spark/shuffle
175 - 2020-08-20 2023-01-30 14 6 boy@uber.com mabansal@uber.com
BlockDownloaderPartitionRangeRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
175 5 2020-08-20 2023-01-30 10 5 boy@uber.com mabansal@uber.com
BlockDownloaderPartitionRecordIterator.scala
in src/main/scala/org/apache/spark/shuffle/rss
174 4 2020-08-20 2023-01-30 7 4 boy@uber.com mabansal@uber.com
PartitionFileChecker.java
in src/main/java/com/uber/rss/tools
98 2 2020-08-20 2023-01-30 3 3 boy@uber.com mabansal@uber.com
RssShuffleReader.scala
in src/main/scala/org/apache/spark/shuffle
90 1 2020-08-20 2023-01-30 7 5 boy@uber.com mabansal@uber.com
Compression.java
in src/main/java/com/uber/rss/common
56 2 2020-08-20 2023-01-30 3 3 boy@uber.com mabansal@uber.com
LazyWriteClient.java
in src/main/java/com/uber/rss/clients
70 9 2021-07-19 2021-07-22 2 2 mayurb@uber.com mabansal@uber.com
ZooKeeperServiceRegistry.java
in src/main/java/com/uber/rss/metadata
191 15 2020-08-20 2021-07-20 3 3 boy@uber.com mabansal@uber.com
ServiceRegistryWrapper.java
in src/main/java/com/uber/rss/metadata
93 9 2020-08-20 2021-06-17 2 3 boy@uber.com harshvardhan5795@gmail.com
RssServiceRegistry.scala
in src/main/scala/org/apache/spark/shuffle
63 2 2021-06-17 2021-06-17 1 2 mabansal@uber.com harshvardhan5795@gmail.com
MetadataClientMetrics.java
in src/main/java/com/uber/rss/metrics
39 6 2020-08-20 2021-06-17 2 3 boy@uber.com harshvardhan5795@gmail.com
StreamServerStressTool.java
in src/main/java/com/uber/rss/tools
615 36 2020-08-20 2021-06-16 10 3 boy@uber.com mabansal@uber.com
StreamServerMessageDecoder.java
in src/main/java/com/uber/rss/decoders
347 8 2020-08-20 2021-06-16 10 3 boy@uber.com mabansal@uber.com
UploadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
184 6 2020-08-20 2021-06-16 16 3 boy@uber.com mabansal@uber.com
DownloadServerHandler.java
in src/main/java/com/uber/rss/handlers
155 7 2020-08-20 2021-06-16 10 3 boy@uber.com mabansal@uber.com
M3Stats.java
in src/main/java/com/uber/rss/metrics
106 7 2020-08-20 2021-06-16 3 3 boy@uber.com mabansal@uber.com
WriterBufferManager.scala
in src/main/scala/org/apache/spark/shuffle/rss
105 5 2020-09-30 2021-06-16 3 4 boy-uber@users.noreply.gith... mayurdb31@gmail.com
WriterAggregationImpl.scala
in src/main/scala/org/apache/spark/shuffle/rss
99 6 2021-06-16 2021-06-16 1 2 mabansal@uber.com mayurdb31@gmail.com
ShuffleFileOutputStream.java
in src/main/java/com/uber/rss/storage
71 6 2020-08-20 2021-06-16 5 3 boy@uber.com mabansal@uber.com
MemoryMonitor.java
in src/main/java/com/uber/rss/common
70 2 2020-08-20 2021-06-16 4 3 boy@uber.com mabansal@uber.com
ServerHandlerMetrics.java
in src/main/java/com/uber/rss/metrics
35 5 2020-08-20 2021-06-16 3 3 boy@uber.com mabansal@uber.com
WriterAggregationManager.scala
in src/main/scala/org/apache/spark/shuffle/rss
32 2 2021-06-16 2021-06-16 1 2 mabansal@uber.com mayurdb31@gmail.com
WriterNoAggregationManager.scala
in src/main/scala/org/apache/spark/shuffle/rss
14 1 2021-06-16 2021-06-16 1 2 mabansal@uber.com mayurdb31@gmail.com
ServiceRegistryUtils.java
in src/main/java/com/uber/rss/metadata
151 5 2020-08-20 2021-06-15 6 3 boy@uber.com mabansal@uber.com
StreamDecoderBase.java
in src/main/java/com/uber/rss/clients
117 9 2020-08-20 2021-06-15 3 2 boy@uber.com mabansal@uber.com
ServerBusyRetriableWriteClient.java
in src/main/java/com/uber/rss/clients
106 9 2020-08-20 2021-06-15 5 3 boy@uber.com mabansal@uber.com
ConnectDownloadRequestMessage.java
in src/main/java/com/uber/rss/messages
89 12 2021-06-12 2021-06-15 2 1 mabansal@uber.com mabansal@uber.com
BlockingQueueReadClient.java
in src/main/java/com/uber/rss/clients
84 6 2020-08-20 2021-06-15 3 3 boy@uber.com mabansal@uber.com
RecordSocketReadClient.java
in src/main/java/com/uber/rss/clients
83 7 2020-08-20 2021-06-15 7 3 boy@uber.com mabansal@uber.com
TaskByteArrayDataBlock.java
in src/main/java/com/uber/rss/clients
48 6 2020-10-05 2021-06-15 2 3 boy-uber@users.noreply.gith... mabansal@uber.com
MessageConstants.java
in src/main/java/com/uber/rss/messages
46 - 2020-08-20 2021-06-15 10 3 boy@uber.com mabansal@uber.com
GetDataAvailabilityRequestMessage.java
in src/main/java/com/uber/rss/messages
21 5 2021-06-12 2021-06-15 2 1 mabansal@uber.com mabansal@uber.com
FailedFetchRecordKeyValuePair.java
in src/main/java/com/uber/rss/clients
11 2 2020-08-20 2021-06-15 3 3 boy@uber.com mabansal@uber.com
EofRecordKeyValuePair.java
in src/main/java/com/uber/rss/clients
6 1 2020-08-20 2021-06-15 3 3 boy@uber.com mabansal@uber.com
BlockingShuffleDataReader.java
in src/main/java/com/uber/rss/clients
6 - 2021-06-15 2021-06-15 1 1 mabansal@uber.com mabansal@uber.com
BlockingSingleServerReadClient.java
in src/main/java/com/uber/rss/clients
5 - 2021-06-15 2021-06-15 1 1 mabansal@uber.com mabansal@uber.com
DataBlockSocketReadClient.java
in src/main/java/com/uber/rss/clients
299 13 2020-08-20 2020-10-30 8 2 boy@uber.com boy@uber.com
DownloadChannelInboundHandler.java
in src/main/java/com/uber/rss/handlers
159 7 2020-08-20 2020-10-30 12 3 boy@uber.com boy@uber.com
DataBlockSyncWriteClient.java
in src/main/java/com/uber/rss/clients
142 10 2020-08-20 2020-10-30 5 2 boy@uber.com boy@uber.com
HeartbeatSocketClient.java
in src/main/java/com/uber/rss/clients
34 3 2020-09-30 2020-10-30 2 2 boy-uber@users.noreply.gith... boy@uber.com
LocalFileStateStore.java
in src/main/java/com/uber/rss/execution
204 15 2020-08-20 2020-10-29 3 2 boy@uber.com boy@uber.com
LocalFileStateStoreIterator.java
in src/main/java/com/uber/rss/execution
173 8 2020-08-20 2020-10-29 2 2 boy@uber.com boy@uber.com
BusyStatusSocketClient.java
in src/main/java/com/uber/rss/clients
32 3 2020-10-13 2020-10-29 2 3 boy-uber@users.noreply.gith... mabansal@uber.com
ServerCandidate.java
in src/main/java/com/uber/rss/common
28 5 2020-10-13 2020-10-29 3 3 boy-uber@users.noreply.gith... mabansal@uber.com
ShuffleExecutor.java
in src/main/java/com/uber/rss/execution
547 31 2020-08-20 2020-10-26 12 3 boy@uber.com boy@uber.com
StreamServerVersionDecoder.java
in src/main/java/com/uber/rss/decoders
113 3 2020-08-20 2020-10-26 6 3 boy@uber.com boy@uber.com
UploadServerHandler.java
in src/main/java/com/uber/rss/handlers
103 12 2020-08-20 2020-10-26 9 3 boy@uber.com boy@uber.com