-
- Downloads
[SPARK-2468] Netty based block server / client module
Previous pull request (#1907) was reverted. This brings it back. Still looking into the hang. Author: Reynold Xin <rxin@apache.org> Closes #1971 from rxin/netty1 and squashes the following commits: b0be96f [Reynold Xin] Added test to make sure outstandingRequests are cleaned after firing the events. 4c6d0ee [Reynold Xin] Pass callbacks cleanly. 603dce7 [Reynold Xin] Upgrade Netty to 4.0.23 to fix the DefaultFileRegion bug. 88be1d4 [Reynold Xin] Downgrade to 4.0.21 to work around a bug in writing DefaultFileRegion. 002626a [Reynold Xin] Remove netty-test-file.txt. db6e6e0 [Reynold Xin] Revert "Revert "[SPARK-2468] Netty based block server / client module""
Showing
- core/src/main/scala/org/apache/spark/network/netty/FileClient.scala 0 additions, 85 deletions...ain/scala/org/apache/spark/network/netty/FileClient.scala
- core/src/main/scala/org/apache/spark/network/netty/FileServer.scala 0 additions, 91 deletions...ain/scala/org/apache/spark/network/netty/FileServer.scala
- core/src/main/scala/org/apache/spark/network/netty/FileServerHandler.scala 0 additions, 68 deletions...la/org/apache/spark/network/netty/FileServerHandler.scala
- core/src/main/scala/org/apache/spark/network/netty/NettyConfig.scala 59 additions, 0 deletions...in/scala/org/apache/spark/network/netty/NettyConfig.scala
- core/src/main/scala/org/apache/spark/network/netty/ShuffleCopier.scala 0 additions, 118 deletions.../scala/org/apache/spark/network/netty/ShuffleCopier.scala
- core/src/main/scala/org/apache/spark/network/netty/ShuffleSender.scala 0 additions, 71 deletions.../scala/org/apache/spark/network/netty/ShuffleSender.scala
- core/src/main/scala/org/apache/spark/network/netty/client/BlockClientListener.scala 7 additions, 9 deletions...ache/spark/network/netty/client/BlockClientListener.scala
- core/src/main/scala/org/apache/spark/network/netty/client/BlockFetchingClient.scala 132 additions, 0 deletions...ache/spark/network/netty/client/BlockFetchingClient.scala
- core/src/main/scala/org/apache/spark/network/netty/client/BlockFetchingClientFactory.scala 99 additions, 0 deletions...ark/network/netty/client/BlockFetchingClientFactory.scala
- core/src/main/scala/org/apache/spark/network/netty/client/BlockFetchingClientHandler.scala 103 additions, 0 deletions...ark/network/netty/client/BlockFetchingClientHandler.scala
- core/src/main/scala/org/apache/spark/network/netty/client/LazyInitIterator.scala 44 additions, 0 deletions.../apache/spark/network/netty/client/LazyInitIterator.scala
- core/src/main/scala/org/apache/spark/network/netty/client/ReferenceCountedBuffer.scala 47 additions, 0 deletions...e/spark/network/netty/client/ReferenceCountedBuffer.scala
- core/src/main/scala/org/apache/spark/network/netty/server/BlockHeader.scala 32 additions, 0 deletions...a/org/apache/spark/network/netty/server/BlockHeader.scala
- core/src/main/scala/org/apache/spark/network/netty/server/BlockHeaderEncoder.scala 47 additions, 0 deletions...pache/spark/network/netty/server/BlockHeaderEncoder.scala
- core/src/main/scala/org/apache/spark/network/netty/server/BlockServer.scala 162 additions, 0 deletions...a/org/apache/spark/network/netty/server/BlockServer.scala
- core/src/main/scala/org/apache/spark/network/netty/server/BlockServerChannelInitializer.scala 14 additions, 8 deletions.../network/netty/server/BlockServerChannelInitializer.scala
- core/src/main/scala/org/apache/spark/network/netty/server/BlockServerHandler.scala 140 additions, 0 deletions...pache/spark/network/netty/server/BlockServerHandler.scala
- core/src/main/scala/org/apache/spark/storage/BlockDataProvider.scala 32 additions, 0 deletions...in/scala/org/apache/spark/storage/BlockDataProvider.scala
- core/src/main/scala/org/apache/spark/storage/BlockFetcherIterator.scala 63 additions, 74 deletions...scala/org/apache/spark/storage/BlockFetcherIterator.scala
- core/src/main/scala/org/apache/spark/storage/BlockManager.scala 43 additions, 6 deletions...rc/main/scala/org/apache/spark/storage/BlockManager.scala
Loading
Please register or sign in to comment