org.apache.hadoop.hbase.ipc

类 IPCUtil

java.lang.Object

org.apache.hadoop.hbase.ipc.IPCUtil

@InterfaceAudience.Private
public class IPCUtil
extends Object

Utility to help ipc'ing.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	IPCUtil.CellScannerButNoCodecException Thrown if a cellscanner but no codec to encode it with.

字段概要

字段

限定符和类型	字段和说明
static org.apache.commons.logging.Log	LOG

构造器概要

构造器

构造器和说明
IPCUtil(org.apache.hadoop.conf.Configuration conf)

方法概要

方法

限定符和类型	方法和说明
ByteBuffer	buildCellBlock(org.apache.hadoop.hbase.codec.Codec codec, org.apache.hadoop.io.compress.CompressionCodec compressor, org.apache.hadoop.hbase.CellScanner cellScanner) Puts CellScanner Cells into a cell block using passed in codec and/or compressor.
org.apache.hadoop.hbase.CellScanner	createCellScanner(org.apache.hadoop.hbase.codec.Codec codec, org.apache.hadoop.io.compress.CompressionCodec compressor, byte[] cellBlock)
org.apache.hadoop.hbase.CellScanner	createCellScanner(org.apache.hadoop.hbase.codec.Codec codec, org.apache.hadoop.io.compress.CompressionCodec compressor, byte[] cellBlock, int offset, int length)
static ByteBuffer	getDelimitedMessageAsByteBuffer(com.google.protobuf.Message m)
static int	getTotalSizeWhenWrittenDelimited(com.google.protobuf.Message... messages)
static void	readChunked(DataInput in, byte[] dest, int offset, int len) Read in chunks of 8K (HBASE-7239)
static int	write(OutputStream dos, com.google.protobuf.Message header, com.google.protobuf.Message param, ByteBuffer cellBlock) Write out header, param, and cell block if there is one.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

LOG

public static final org.apache.commons.logging.Log LOG

构造器详细资料

IPCUtil

public IPCUtil(org.apache.hadoop.conf.Configuration conf)

方法详细资料

buildCellBlock

public ByteBuffer buildCellBlock(org.apache.hadoop.hbase.codec.Codec codec,
                        org.apache.hadoop.io.compress.CompressionCodec compressor,
                        org.apache.hadoop.hbase.CellScanner cellScanner)
                          throws IOException

Puts CellScanner Cells into a cell block using passed in codec and/or compressor.

参数:

codec -

compressor -

cellScanner -

返回:

Null or byte buffer filled with a cellblock filled with passed-in Cells encoded using passed in codec and/or compressor; the returned buffer has been flipped and is ready for reading. Use limit to find total size.

抛出:

IOException

createCellScanner

public org.apache.hadoop.hbase.CellScanner createCellScanner(org.apache.hadoop.hbase.codec.Codec codec,
                                                    org.apache.hadoop.io.compress.CompressionCodec compressor,
                                                    byte[] cellBlock)
                                                      throws IOException

参数:

codec -

cellBlock -

返回:

CellScanner to work against the content of cellBlock

抛出:

IOException

createCellScanner

public org.apache.hadoop.hbase.CellScanner createCellScanner(org.apache.hadoop.hbase.codec.Codec codec,
                                                    org.apache.hadoop.io.compress.CompressionCodec compressor,
                                                    byte[] cellBlock,
                                                    int offset,
                                                    int length)
                                                      throws IOException

参数:

codec -

cellBlock -

offset -

length -

返回:

CellScanner to work against the content of cellBlock

抛出:

IOException

getDelimitedMessageAsByteBuffer

public static ByteBuffer getDelimitedMessageAsByteBuffer(com.google.protobuf.Message m)
                                                  throws IOException

参数:

m - Message to serialize delimited; i.e. w/ a vint of its size preceeding its serialization.

返回:

The passed in Message serialized with delimiter. Return null if m is null

抛出:

IOException

write

public static int write(OutputStream dos,
        com.google.protobuf.Message header,
        com.google.protobuf.Message param,
        ByteBuffer cellBlock)
                 throws IOException

Write out header, param, and cell block if there is one.

参数:

dos -

header -

param -

cellBlock -

返回:

Total number of bytes written.

抛出:

IOException

readChunked

public static void readChunked(DataInput in,
               byte[] dest,
               int offset,
               int len)
                        throws IOException

Read in chunks of 8K (HBASE-7239)

参数:

in -

dest -

offset -

len -

抛出:

IOException

getTotalSizeWhenWrittenDelimited

public static int getTotalSizeWhenWrittenDelimited(com.google.protobuf.Message... messages)

返回:

Size on the wire when the two messages are written with writeDelimitedTo