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
资源评论
张岱珅
- 粉丝: 51
- 资源: 4689
最新资源
- 1114208313579521Crack.zip
- vi编辑器的使用沃尔沃
- 具有快速处理算法的正弦频率扫描 OFDR 分布式声学传感
- java学习资源共享平台源码数据库 MySQL源码类型 WebForm
- shiro 只提供了对 ehcache 和 parallelHashMap 的支持，下面介绍一个 shiro 可以使用的 redis cache 实现，希望对大家有帮助！.zip
- Ruby on Rails 的 Redis 存储.zip
- Resque 是一个由 Redis 支持的 Ruby 库，用于创建后台作业、将它们放在多个队列中，然后在稍后处理它们 .zip
- 我的生涯探索成长单-1733146098312.pdf.pdf
- matlab代码展示csv文件
- JAVA的Springboot+vue在线考试系统源码 前后端分离数据库 MySQL源码类型 WebForm
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
