ManagedBuffer-spark技术分享

ManagedBuffer

ManagedBuffer is the base of…FIXME



package org.apache.spark.network.buffer;

abstract class ManagedBuffer {
  abstract long size();
  abstract ByteBuffer nioByteBuffer() throws IOException;
  abstract InputStream createInputStream() throws IOException;
  abstract ManagedBuffer retain();
  abstract ManagedBuffer release();
  abstract Object convertToNetty() throws IOException;
}

package org.apache.spark.network.buffer;

abstract class ManagedBuffer {

abstract long size();

abstract ByteBuffer nioByteBuffer() throws IOException;

abstract InputStream createInputStream() throws IOException;

abstract ManagedBuffer retain();

abstract ManagedBuffer release();

abstract Object convertToNetty() throws IOException;

}

Table 1. ManagedBuffer Contract
Method	Description
`size`	Used when…FIXME
`nioByteBuffer`	Used when…FIXME
`createInputStream`	Used when…FIXME
`retain`	Used when…FIXME
`release`	Used when…FIXME
`convertToNetty`	Used when…FIXME

Table 2. ManagedBuffers
ManagedBuffer	Description
`BlockManagerManagedBuffer`
`FileSegmentManagedBuffer`
`NettyManagedBuffer`
`NioManagedBuffer`

ManagedBuffer

ManagedBuffer

相关推荐

欢迎关注：spark技术分享

热门标签

近期文章

分类目录

关注公众号：spark技术分享

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏

QQ咨询

回顶部