Field Detail

• LOG

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

• cellBlockDecompressionMultiplier

  private final int cellBlockDecompressionMultiplier

  How much we think the decompressor will expand the original compressed content.

• cellBlockBuildingInitialBufferSize

  private final int cellBlockBuildingInitialBufferSize

• conf

  private final org.apache.hadoop.conf.Configuration conf

Constructor Detail

• IPCUtil

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

Method Detail

• buildCellBlock

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

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

  Parameters:

  codec -

  compressor -

  cellScanner -

  Returns:

  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.

  Throws:

  IOException

• buildCellBlock

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

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

  Parameters:

  codec -

  compressor -

  cellScanner -

  pool - Pool of ByteBuffers to make use of. Can be null and then we'll allocate our own ByteBuffer.

  Returns:

  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. If pool was not null, then this returned ByteBuffer came from there and should be returned to the pool when done.

  Throws:

  IOException

• createCellScanner

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

  Parameters:

  codec -

  cellBlock -

  Returns:

  CellScanner to work against the content of cellBlock

  Throws:

  IOException

• createCellScanner

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

  Parameters:

  codec -

  cellBlock -

  offset -

  length -

  Returns:

  CellScanner to work against the content of cellBlock

  Throws:

  IOException

• getDelimitedMessageAsByteBuffer

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

  Parameters:

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

  Returns:

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

  Throws:

  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.

  Parameters:

  dos -

  header -

  param -

  cellBlock -

  Returns:

  Total number of bytes written.

  Throws:

  IOException

• write

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

  Throws:

  IOException

• readChunked

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

  Read in chunks of 8K (HBASE-7239)

  Parameters:

  in -

  dest -

  offset -

  len -

  Throws:

  IOException

• getTotalSizeWhenWrittenDelimited

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

  Returns:

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

• toIOE

  static IOException toIOE(Throwable t)