RemoteShuffleService:Apache Spark的远程洗牌服务，用于在远程服务器上存储洗牌数据
需积分: 50 125 浏览量
2021-05-01
00:35:32
上传
评论
收藏 899KB ZIP 举报
RemoteShuffleService:Apache Spark的远程洗牌服务，用于在远程服务器上存储洗牌数据 （352个子文件） 
.gitignore 475B DataBlockSocketReadClientTest.java 45KB StreamServerStressTool.java 35KB ShuffleExecutor.java 31KB MultiServerSocketReadClientTest.java 29KB ReplicatedReadClientTest.java 26KB ReplicatedWriteClientTest.java 24KB RecordSocketReadClientTest.java 23KB MultiServerAsyncWriteClientTest.java 22KB ServerReplicationGroupUtilTest.java 22KB RetriableSocketReadClientTest.java 19KB MultiServerAsyncWriteClient.java 17KB ReplicatedReadClient.java 17KB StreamServer.java 16KB StreamServerMultiAttemptTest.java 16KB MultiServerSyncWriteClientTest.java 16KB StreamServerMessageDecoder.java 16KB DataBlockSocketReadClient.java 15KB ClientBase.java 13KB LocalFileStateStoreTest.java 13KB StreamServerConfig.java 12KB ExecutorShuffleStageState.java 12KB PooledWriteClientFactoryTest.java 11KB ZooKeeperServiceRegistryTest.java 11KB UploadChannelInboundHandler.java 11KB LocalFileLocalFileStateStoreIteratorTest.java 11KB ServerIdAwareSyncWriteClientTest.java 11KB DownloadChannelInboundHandler.java 10KB ZooKeeperServiceRegistry.java 10KB PooledWriteClientFactory.java 10KB WriteClientEdgeCaseTest.java 10KB ShuffleExecutorTest.java 10KB DownloadServerHandler.java 10KB ServiceRegistryUtils.java 9KB SerializerBenchmark.java 9KB StreamReadClientVerify.java 9KB LocalFileStateStore.java 8KB FixedLengthInputStreamTest.java 8KB MultiServerSyncWriteClient.java 8KB ServerIdAwareSocketReadClientTest.java 7KB ShufflePartitionWriter.java 7KB DataBlockSyncWriteClient.java 7KB TestStreamServer.java 7KB MultiServerSocketReadClient.java 7KB StreamServerVersionDecoder.java 7KB StreamServerTest.java 7KB FsyncPerfTest.java 7KB StreamServerStressToolLongRun.java 7KB ReplicatedWriteClient.java 7KB DataBlockSyncWriteClientTest.java 7KB ScheduledMetricCollector.java 7KB LocalFileStateStoreIterator.java 6KB UploadServerHandler.java 6KB ServerIdAwareSyncWriteClient.java 6KB FileUtils.java 6KB ZooKeeperFaultTolerantServiceRegistryTest.java 6KB InMemoryServiceRegistryTest.java 5KB RetryUtils.java 5KB StreamServerCleanupTest.java 5KB MultiServerHeartbeatClient.java 5KB M3Stats.java 5KB RssMiniCluster.java 5KB HttpChannelInboundHandler.java 5KB MemoryMonitor.java 5KB MultiServerHeartbeatClientTest.java 4KB StreamServerWritingTooMuchDataTest.java 4KB RssZookeeperCluster.java 4KB ByteBufUtils.java 4KB RetriableSocketReadClient.java 4KB StringUtils.java 4KB ConnectDownloadResponse.java 4KB TaskAttemptCommitStateItem.java 4KB LocalFileStateStoreStressTest.java 4KB ShuffleDataSocketReadClient.java 4KB StreamServerTestUtils.java 4KB ConnectDownloadRequest.java 4KB PooledShuffleDataSyncWriteClient.java 4KB PackageJarFileITCase.java 4KB ZooKeeperFaultTolerantServiceRegistry.java 4KB PartitionFileChecker.java 4KB ServiceRegistryUtilsTest.java 4KB ClientTestUtils.java 4KB ShuffleDataSyncWriteClientBase.java 4KB ServiceRegistryWrapper.java 4KB NotifyClient.java 4KB InMemoryServiceRegistry.java 4KB ServerReplicationGroupUtil.java 3KB ServerIdAwareSocketReadClient.java 3KB ShuffleFileStorage.java 3KB MessageConstants.java 3KB FileUtilsTest.java 3KB PooledWriteClientFactoryRandomTest.java 3KB SocketUtils.java 3KB StageInfoStateItem.java 3KB ShuffleFileOutputStream.java 3KB FinishApplicationJobRequestMessage.java 3KB AppTaskAttemptId.java 3KB NotifyServerHandler.java 3KB RegistryClient.java 3KB StartUploadMessage.java 3KB共 352 条
- 1
- 2
- 3
- 4
资源评论
张岱珅
- 粉丝: 44
- 资源: 4690
最新资源
- Asset Bundle Extractor 3.0 beta1 x86
- jjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjjj
- mysql-‘万卷’大学图书管理系统源代码+论文-.zip
- JK时间《透视HTTP协议》pdf
- Asset Bundle Extractor 3.0 beta1 x64
- 一键下载maven安装包
- unity FlexReader WebGL LocalExcel
- mysql-‘准速达’物流管理系统源代码+论文.zip
- Avalonia 项目使用ReactiveUI实现的MVVM
- Android开发工程师学习路线图
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
