hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mi...@apache.org
Subject [29/51] [partial] hbase-site git commit: Published site at eea8b38dfa0180d3e6f93d3e8055d5d4fbf673c3.
Date Fri, 11 Mar 2016 17:00:03 GMT
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0b785cb2/devapidocs/src-html/org/apache/hadoop/hbase/codec/KeyValueCodecWithTags.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/codec/KeyValueCodecWithTags.html b/devapidocs/src-html/org/apache/hadoop/hbase/codec/KeyValueCodecWithTags.html
index fa822a9..a559869 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/codec/KeyValueCodecWithTags.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/codec/KeyValueCodecWithTags.html
@@ -28,74 +28,93 @@
 <span class="sourceLineNo">020</span>import java.io.IOException;<a name="line.20"></a>
 <span class="sourceLineNo">021</span>import java.io.InputStream;<a name="line.21"></a>
 <span class="sourceLineNo">022</span>import java.io.OutputStream;<a name="line.22"></a>
-<span class="sourceLineNo">023</span><a name="line.23"></a>
-<span class="sourceLineNo">024</span>import org.apache.hadoop.hbase.Cell;<a name="line.24"></a>
-<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.HBaseInterfaceAudience;<a name="line.25"></a>
-<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.KeyValueUtil;<a name="line.26"></a>
-<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.classification.InterfaceAudience;<a name="line.27"></a>
-<span class="sourceLineNo">028</span><a name="line.28"></a>
-<span class="sourceLineNo">029</span>/**<a name="line.29"></a>
-<span class="sourceLineNo">030</span> * Codec that does KeyValue version 1 serialization with serializing tags also.<a name="line.30"></a>
-<span class="sourceLineNo">031</span> *<a name="line.31"></a>
-<span class="sourceLineNo">032</span> * &lt;p&gt;<a name="line.32"></a>
-<span class="sourceLineNo">033</span> * Encodes Cell as serialized in KeyValue with total length prefix. This<a name="line.33"></a>
-<span class="sourceLineNo">034</span> * is how KVs were serialized in Puts, Deletes and Results pre-0.96. Its what would happen if you<a name="line.34"></a>
-<span class="sourceLineNo">035</span> * called the Writable#write KeyValue implementation. This encoder will fail if the passed Cell is<a name="line.35"></a>
-<span class="sourceLineNo">036</span> * not an old-school pre-0.96 KeyValue. Does not copy bytes writing. It just writes them direct to<a name="line.36"></a>
-<span class="sourceLineNo">037</span> * the passed stream.<a name="line.37"></a>
-<span class="sourceLineNo">038</span> *<a name="line.38"></a>
-<span class="sourceLineNo">039</span> * &lt;p&gt;<a name="line.39"></a>
-<span class="sourceLineNo">040</span> * If you wrote two KeyValues to this encoder, it would look like this in the stream:<a name="line.40"></a>
-<span class="sourceLineNo">041</span> *<a name="line.41"></a>
-<span class="sourceLineNo">042</span> * &lt;pre&gt;<a name="line.42"></a>
-<span class="sourceLineNo">043</span> * length-of-KeyValue1 // A java int with the length of KeyValue1 backing array<a name="line.43"></a>
-<span class="sourceLineNo">044</span> * KeyValue1 backing array filled with a KeyValue serialized in its particular format<a name="line.44"></a>
-<span class="sourceLineNo">045</span> * length-of-KeyValue2<a name="line.45"></a>
-<span class="sourceLineNo">046</span> * KeyValue2 backing array<a name="line.46"></a>
-<span class="sourceLineNo">047</span> * &lt;/pre&gt;<a name="line.47"></a>
-<span class="sourceLineNo">048</span> *<a name="line.48"></a>
-<span class="sourceLineNo">049</span> * Note: The only difference of this with KeyValueCodec is the latter ignores tags in Cells.<a name="line.49"></a>
-<span class="sourceLineNo">050</span> * &lt;b&gt;Use this Codec only at server side.&lt;/b&gt;<a name="line.50"></a>
-<span class="sourceLineNo">051</span> */<a name="line.51"></a>
-<span class="sourceLineNo">052</span>@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)<a name="line.52"></a>
-<span class="sourceLineNo">053</span>public class KeyValueCodecWithTags implements Codec {<a name="line.53"></a>
-<span class="sourceLineNo">054</span>  public static class KeyValueEncoder extends BaseEncoder {<a name="line.54"></a>
-<span class="sourceLineNo">055</span>    public KeyValueEncoder(final OutputStream out) {<a name="line.55"></a>
-<span class="sourceLineNo">056</span>      super(out);<a name="line.56"></a>
-<span class="sourceLineNo">057</span>    }<a name="line.57"></a>
-<span class="sourceLineNo">058</span><a name="line.58"></a>
-<span class="sourceLineNo">059</span>    @Override<a name="line.59"></a>
-<span class="sourceLineNo">060</span>    public void write(Cell cell) throws IOException {<a name="line.60"></a>
-<span class="sourceLineNo">061</span>      checkFlushed();<a name="line.61"></a>
-<span class="sourceLineNo">062</span>      // Write tags<a name="line.62"></a>
-<span class="sourceLineNo">063</span>      KeyValueUtil.oswrite(cell, out, true);<a name="line.63"></a>
-<span class="sourceLineNo">064</span>    }<a name="line.64"></a>
-<span class="sourceLineNo">065</span>  }<a name="line.65"></a>
-<span class="sourceLineNo">066</span><a name="line.66"></a>
-<span class="sourceLineNo">067</span>  public static class KeyValueDecoder extends BaseDecoder {<a name="line.67"></a>
-<span class="sourceLineNo">068</span>    public KeyValueDecoder(final InputStream in) {<a name="line.68"></a>
-<span class="sourceLineNo">069</span>      super(in);<a name="line.69"></a>
-<span class="sourceLineNo">070</span>    }<a name="line.70"></a>
-<span class="sourceLineNo">071</span><a name="line.71"></a>
-<span class="sourceLineNo">072</span>    protected Cell parseCell() throws IOException {<a name="line.72"></a>
-<span class="sourceLineNo">073</span>      // create KeyValue with tags<a name="line.73"></a>
-<span class="sourceLineNo">074</span>      return KeyValueUtil.iscreate(in, true);<a name="line.74"></a>
-<span class="sourceLineNo">075</span>    }<a name="line.75"></a>
-<span class="sourceLineNo">076</span>  }<a name="line.76"></a>
-<span class="sourceLineNo">077</span><a name="line.77"></a>
-<span class="sourceLineNo">078</span>  /**<a name="line.78"></a>
-<span class="sourceLineNo">079</span>   * Implementation depends on {@link InputStream#available()}<a name="line.79"></a>
-<span class="sourceLineNo">080</span>   */<a name="line.80"></a>
-<span class="sourceLineNo">081</span>  @Override<a name="line.81"></a>
-<span class="sourceLineNo">082</span>  public Decoder getDecoder(final InputStream is) {<a name="line.82"></a>
-<span class="sourceLineNo">083</span>    return new KeyValueDecoder(is);<a name="line.83"></a>
-<span class="sourceLineNo">084</span>  }<a name="line.84"></a>
-<span class="sourceLineNo">085</span><a name="line.85"></a>
-<span class="sourceLineNo">086</span>  @Override<a name="line.86"></a>
-<span class="sourceLineNo">087</span>  public Encoder getEncoder(OutputStream os) {<a name="line.87"></a>
-<span class="sourceLineNo">088</span>    return new KeyValueEncoder(os);<a name="line.88"></a>
-<span class="sourceLineNo">089</span>  }<a name="line.89"></a>
-<span class="sourceLineNo">090</span>}<a name="line.90"></a>
+<span class="sourceLineNo">023</span>import java.nio.ByteBuffer;<a name="line.23"></a>
+<span class="sourceLineNo">024</span><a name="line.24"></a>
+<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.Cell;<a name="line.25"></a>
+<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.HBaseInterfaceAudience;<a name="line.26"></a>
+<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.KeyValue;<a name="line.27"></a>
+<span class="sourceLineNo">028</span>import org.apache.hadoop.hbase.KeyValueUtil;<a name="line.28"></a>
+<span class="sourceLineNo">029</span>import org.apache.hadoop.hbase.classification.InterfaceAudience;<a name="line.29"></a>
+<span class="sourceLineNo">030</span><a name="line.30"></a>
+<span class="sourceLineNo">031</span>/**<a name="line.31"></a>
+<span class="sourceLineNo">032</span> * Codec that does KeyValue version 1 serialization with serializing tags also.<a name="line.32"></a>
+<span class="sourceLineNo">033</span> *<a name="line.33"></a>
+<span class="sourceLineNo">034</span> * &lt;p&gt;<a name="line.34"></a>
+<span class="sourceLineNo">035</span> * Encodes Cell as serialized in KeyValue with total length prefix. This<a name="line.35"></a>
+<span class="sourceLineNo">036</span> * is how KVs were serialized in Puts, Deletes and Results pre-0.96. Its what would happen if you<a name="line.36"></a>
+<span class="sourceLineNo">037</span> * called the Writable#write KeyValue implementation. This encoder will fail if the passed Cell is<a name="line.37"></a>
+<span class="sourceLineNo">038</span> * not an old-school pre-0.96 KeyValue. Does not copy bytes writing. It just writes them direct to<a name="line.38"></a>
+<span class="sourceLineNo">039</span> * the passed stream.<a name="line.39"></a>
+<span class="sourceLineNo">040</span> *<a name="line.40"></a>
+<span class="sourceLineNo">041</span> * &lt;p&gt;<a name="line.41"></a>
+<span class="sourceLineNo">042</span> * If you wrote two KeyValues to this encoder, it would look like this in the stream:<a name="line.42"></a>
+<span class="sourceLineNo">043</span> *<a name="line.43"></a>
+<span class="sourceLineNo">044</span> * &lt;pre&gt;<a name="line.44"></a>
+<span class="sourceLineNo">045</span> * length-of-KeyValue1 // A java int with the length of KeyValue1 backing array<a name="line.45"></a>
+<span class="sourceLineNo">046</span> * KeyValue1 backing array filled with a KeyValue serialized in its particular format<a name="line.46"></a>
+<span class="sourceLineNo">047</span> * length-of-KeyValue2<a name="line.47"></a>
+<span class="sourceLineNo">048</span> * KeyValue2 backing array<a name="line.48"></a>
+<span class="sourceLineNo">049</span> * &lt;/pre&gt;<a name="line.49"></a>
+<span class="sourceLineNo">050</span> *<a name="line.50"></a>
+<span class="sourceLineNo">051</span> * Note: The only difference of this with KeyValueCodec is the latter ignores tags in Cells.<a name="line.51"></a>
+<span class="sourceLineNo">052</span> * &lt;b&gt;Use this Codec only at server side.&lt;/b&gt;<a name="line.52"></a>
+<span class="sourceLineNo">053</span> */<a name="line.53"></a>
+<span class="sourceLineNo">054</span>@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)<a name="line.54"></a>
+<span class="sourceLineNo">055</span>public class KeyValueCodecWithTags implements Codec {<a name="line.55"></a>
+<span class="sourceLineNo">056</span>  public static class KeyValueEncoder extends BaseEncoder {<a name="line.56"></a>
+<span class="sourceLineNo">057</span>    public KeyValueEncoder(final OutputStream out) {<a name="line.57"></a>
+<span class="sourceLineNo">058</span>      super(out);<a name="line.58"></a>
+<span class="sourceLineNo">059</span>    }<a name="line.59"></a>
+<span class="sourceLineNo">060</span><a name="line.60"></a>
+<span class="sourceLineNo">061</span>    @Override<a name="line.61"></a>
+<span class="sourceLineNo">062</span>    public void write(Cell cell) throws IOException {<a name="line.62"></a>
+<span class="sourceLineNo">063</span>      checkFlushed();<a name="line.63"></a>
+<span class="sourceLineNo">064</span>      // Write tags<a name="line.64"></a>
+<span class="sourceLineNo">065</span>      KeyValueUtil.oswrite(cell, out, true);<a name="line.65"></a>
+<span class="sourceLineNo">066</span>    }<a name="line.66"></a>
+<span class="sourceLineNo">067</span>  }<a name="line.67"></a>
+<span class="sourceLineNo">068</span><a name="line.68"></a>
+<span class="sourceLineNo">069</span>  public static class KeyValueDecoder extends BaseDecoder {<a name="line.69"></a>
+<span class="sourceLineNo">070</span>    public KeyValueDecoder(final InputStream in) {<a name="line.70"></a>
+<span class="sourceLineNo">071</span>      super(in);<a name="line.71"></a>
+<span class="sourceLineNo">072</span>    }<a name="line.72"></a>
+<span class="sourceLineNo">073</span><a name="line.73"></a>
+<span class="sourceLineNo">074</span>    protected Cell parseCell() throws IOException {<a name="line.74"></a>
+<span class="sourceLineNo">075</span>      // create KeyValue with tags<a name="line.75"></a>
+<span class="sourceLineNo">076</span>      return KeyValueUtil.iscreate(in, true);<a name="line.76"></a>
+<span class="sourceLineNo">077</span>    }<a name="line.77"></a>
+<span class="sourceLineNo">078</span>  }<a name="line.78"></a>
+<span class="sourceLineNo">079</span><a name="line.79"></a>
+<span class="sourceLineNo">080</span>  public static class ByteBufferedKeyValueDecoder<a name="line.80"></a>
+<span class="sourceLineNo">081</span>      extends KeyValueCodec.ByteBufferedKeyValueDecoder {<a name="line.81"></a>
+<span class="sourceLineNo">082</span><a name="line.82"></a>
+<span class="sourceLineNo">083</span>    public ByteBufferedKeyValueDecoder(ByteBuffer buf) {<a name="line.83"></a>
+<span class="sourceLineNo">084</span>      super(buf);<a name="line.84"></a>
+<span class="sourceLineNo">085</span>    }<a name="line.85"></a>
+<span class="sourceLineNo">086</span><a name="line.86"></a>
+<span class="sourceLineNo">087</span>    protected Cell createCell(byte[] buf, int offset, int len) {<a name="line.87"></a>
+<span class="sourceLineNo">088</span>      return new KeyValue(buf, offset, len);<a name="line.88"></a>
+<span class="sourceLineNo">089</span>    }<a name="line.89"></a>
+<span class="sourceLineNo">090</span>  }<a name="line.90"></a>
+<span class="sourceLineNo">091</span><a name="line.91"></a>
+<span class="sourceLineNo">092</span>  /**<a name="line.92"></a>
+<span class="sourceLineNo">093</span>   * Implementation depends on {@link InputStream#available()}<a name="line.93"></a>
+<span class="sourceLineNo">094</span>   */<a name="line.94"></a>
+<span class="sourceLineNo">095</span>  @Override<a name="line.95"></a>
+<span class="sourceLineNo">096</span>  public Decoder getDecoder(final InputStream is) {<a name="line.96"></a>
+<span class="sourceLineNo">097</span>    return new KeyValueDecoder(is);<a name="line.97"></a>
+<span class="sourceLineNo">098</span>  }<a name="line.98"></a>
+<span class="sourceLineNo">099</span><a name="line.99"></a>
+<span class="sourceLineNo">100</span>  @Override<a name="line.100"></a>
+<span class="sourceLineNo">101</span>  public Encoder getEncoder(OutputStream os) {<a name="line.101"></a>
+<span class="sourceLineNo">102</span>    return new KeyValueEncoder(os);<a name="line.102"></a>
+<span class="sourceLineNo">103</span>  }<a name="line.103"></a>
+<span class="sourceLineNo">104</span><a name="line.104"></a>
+<span class="sourceLineNo">105</span>  @Override<a name="line.105"></a>
+<span class="sourceLineNo">106</span>  public Decoder getDecoder(ByteBuffer buf) {<a name="line.106"></a>
+<span class="sourceLineNo">107</span>    return new ByteBufferedKeyValueDecoder(buf);<a name="line.107"></a>
+<span class="sourceLineNo">108</span>  }<a name="line.108"></a>
+<span class="sourceLineNo">109</span>}<a name="line.109"></a>
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0b785cb2/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.MessageDecoder.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.MessageDecoder.html b/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.MessageDecoder.html
index 6359ce9..39ba4a2 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.MessageDecoder.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.MessageDecoder.html
@@ -28,70 +28,77 @@
 <span class="sourceLineNo">020</span>import java.io.IOException;<a name="line.20"></a>
 <span class="sourceLineNo">021</span>import java.io.InputStream;<a name="line.21"></a>
 <span class="sourceLineNo">022</span>import java.io.OutputStream;<a name="line.22"></a>
-<span class="sourceLineNo">023</span><a name="line.23"></a>
-<span class="sourceLineNo">024</span>import org.apache.hadoop.hbase.util.ByteStringer;<a name="line.24"></a>
-<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.classification.InterfaceAudience;<a name="line.25"></a>
-<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.Cell;<a name="line.26"></a>
-<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.CellUtil;<a name="line.27"></a>
-<span class="sourceLineNo">028</span>import org.apache.hadoop.hbase.HBaseInterfaceAudience;<a name="line.28"></a>
-<span class="sourceLineNo">029</span>import org.apache.hadoop.hbase.protobuf.generated.CellProtos;<a name="line.29"></a>
-<span class="sourceLineNo">030</span><a name="line.30"></a>
-<span class="sourceLineNo">031</span>/**<a name="line.31"></a>
-<span class="sourceLineNo">032</span> * Codec that just writes out Cell as a protobuf Cell Message.  Does not write the mvcc stamp.<a name="line.32"></a>
-<span class="sourceLineNo">033</span> * Use a different codec if you want that in the stream.<a name="line.33"></a>
-<span class="sourceLineNo">034</span> */<a name="line.34"></a>
-<span class="sourceLineNo">035</span>@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)<a name="line.35"></a>
-<span class="sourceLineNo">036</span>public class MessageCodec implements Codec {<a name="line.36"></a>
-<span class="sourceLineNo">037</span>  static class MessageEncoder extends BaseEncoder {<a name="line.37"></a>
-<span class="sourceLineNo">038</span>    MessageEncoder(final OutputStream out) {<a name="line.38"></a>
-<span class="sourceLineNo">039</span>      super(out);<a name="line.39"></a>
-<span class="sourceLineNo">040</span>    }<a name="line.40"></a>
-<span class="sourceLineNo">041</span><a name="line.41"></a>
-<span class="sourceLineNo">042</span>    @Override<a name="line.42"></a>
-<span class="sourceLineNo">043</span>    public void write(Cell cell) throws IOException {<a name="line.43"></a>
-<span class="sourceLineNo">044</span>      checkFlushed();<a name="line.44"></a>
-<span class="sourceLineNo">045</span>      CellProtos.Cell.Builder builder = CellProtos.Cell.newBuilder();<a name="line.45"></a>
-<span class="sourceLineNo">046</span>      // This copies bytes from Cell to ByteString.  I don't see anyway around the copy.<a name="line.46"></a>
-<span class="sourceLineNo">047</span>      // ByteString is final.<a name="line.47"></a>
-<span class="sourceLineNo">048</span>      builder.setRow(ByteStringer.wrap(cell.getRowArray(), cell.getRowOffset(),<a name="line.48"></a>
-<span class="sourceLineNo">049</span>          cell.getRowLength()));<a name="line.49"></a>
-<span class="sourceLineNo">050</span>      builder.setFamily(ByteStringer.wrap(cell.getFamilyArray(), cell.getFamilyOffset(),<a name="line.50"></a>
-<span class="sourceLineNo">051</span>          cell.getFamilyLength()));<a name="line.51"></a>
-<span class="sourceLineNo">052</span>      builder.setQualifier(ByteStringer.wrap(cell.getQualifierArray(),<a name="line.52"></a>
-<span class="sourceLineNo">053</span>          cell.getQualifierOffset(), cell.getQualifierLength()));<a name="line.53"></a>
-<span class="sourceLineNo">054</span>      builder.setTimestamp(cell.getTimestamp());<a name="line.54"></a>
-<span class="sourceLineNo">055</span>      builder.setCellType(CellProtos.CellType.valueOf(cell.getTypeByte()));<a name="line.55"></a>
-<span class="sourceLineNo">056</span>      builder.setValue(ByteStringer.wrap(cell.getValueArray(), cell.getValueOffset(),<a name="line.56"></a>
-<span class="sourceLineNo">057</span>          cell.getValueLength()));<a name="line.57"></a>
-<span class="sourceLineNo">058</span>      CellProtos.Cell pbcell = builder.build();<a name="line.58"></a>
-<span class="sourceLineNo">059</span>      pbcell.writeDelimitedTo(this.out);<a name="line.59"></a>
-<span class="sourceLineNo">060</span>    }<a name="line.60"></a>
-<span class="sourceLineNo">061</span>  }<a name="line.61"></a>
-<span class="sourceLineNo">062</span><a name="line.62"></a>
-<span class="sourceLineNo">063</span>  static class MessageDecoder extends BaseDecoder {<a name="line.63"></a>
-<span class="sourceLineNo">064</span>    MessageDecoder(final InputStream in) {<a name="line.64"></a>
-<span class="sourceLineNo">065</span>      super(in);<a name="line.65"></a>
-<span class="sourceLineNo">066</span>    }<a name="line.66"></a>
-<span class="sourceLineNo">067</span><a name="line.67"></a>
-<span class="sourceLineNo">068</span>    protected Cell parseCell() throws IOException {<a name="line.68"></a>
-<span class="sourceLineNo">069</span>      CellProtos.Cell pbcell = CellProtos.Cell.parseDelimitedFrom(this.in);<a name="line.69"></a>
-<span class="sourceLineNo">070</span>      return CellUtil.createCell(pbcell.getRow().toByteArray(),<a name="line.70"></a>
-<span class="sourceLineNo">071</span>        pbcell.getFamily().toByteArray(), pbcell.getQualifier().toByteArray(),<a name="line.71"></a>
-<span class="sourceLineNo">072</span>        pbcell.getTimestamp(), (byte)pbcell.getCellType().getNumber(),<a name="line.72"></a>
-<span class="sourceLineNo">073</span>        pbcell.getValue().toByteArray());<a name="line.73"></a>
-<span class="sourceLineNo">074</span>    }<a name="line.74"></a>
-<span class="sourceLineNo">075</span>  }<a name="line.75"></a>
-<span class="sourceLineNo">076</span><a name="line.76"></a>
-<span class="sourceLineNo">077</span>  @Override<a name="line.77"></a>
-<span class="sourceLineNo">078</span>  public Decoder getDecoder(InputStream is) {<a name="line.78"></a>
-<span class="sourceLineNo">079</span>    return new MessageDecoder(is);<a name="line.79"></a>
-<span class="sourceLineNo">080</span>  }<a name="line.80"></a>
-<span class="sourceLineNo">081</span><a name="line.81"></a>
-<span class="sourceLineNo">082</span>  @Override<a name="line.82"></a>
-<span class="sourceLineNo">083</span>  public Encoder getEncoder(OutputStream os) {<a name="line.83"></a>
-<span class="sourceLineNo">084</span>    return new MessageEncoder(os);<a name="line.84"></a>
-<span class="sourceLineNo">085</span>  }<a name="line.85"></a>
-<span class="sourceLineNo">086</span>}<a name="line.86"></a>
+<span class="sourceLineNo">023</span>import java.nio.ByteBuffer;<a name="line.23"></a>
+<span class="sourceLineNo">024</span><a name="line.24"></a>
+<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.util.ByteStringer;<a name="line.25"></a>
+<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.classification.InterfaceAudience;<a name="line.26"></a>
+<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.io.ByteBufferInputStream;<a name="line.27"></a>
+<span class="sourceLineNo">028</span>import org.apache.hadoop.hbase.Cell;<a name="line.28"></a>
+<span class="sourceLineNo">029</span>import org.apache.hadoop.hbase.CellUtil;<a name="line.29"></a>
+<span class="sourceLineNo">030</span>import org.apache.hadoop.hbase.HBaseInterfaceAudience;<a name="line.30"></a>
+<span class="sourceLineNo">031</span>import org.apache.hadoop.hbase.protobuf.generated.CellProtos;<a name="line.31"></a>
+<span class="sourceLineNo">032</span><a name="line.32"></a>
+<span class="sourceLineNo">033</span>/**<a name="line.33"></a>
+<span class="sourceLineNo">034</span> * Codec that just writes out Cell as a protobuf Cell Message.  Does not write the mvcc stamp.<a name="line.34"></a>
+<span class="sourceLineNo">035</span> * Use a different codec if you want that in the stream.<a name="line.35"></a>
+<span class="sourceLineNo">036</span> */<a name="line.36"></a>
+<span class="sourceLineNo">037</span>@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)<a name="line.37"></a>
+<span class="sourceLineNo">038</span>public class MessageCodec implements Codec {<a name="line.38"></a>
+<span class="sourceLineNo">039</span>  static class MessageEncoder extends BaseEncoder {<a name="line.39"></a>
+<span class="sourceLineNo">040</span>    MessageEncoder(final OutputStream out) {<a name="line.40"></a>
+<span class="sourceLineNo">041</span>      super(out);<a name="line.41"></a>
+<span class="sourceLineNo">042</span>    }<a name="line.42"></a>
+<span class="sourceLineNo">043</span><a name="line.43"></a>
+<span class="sourceLineNo">044</span>    @Override<a name="line.44"></a>
+<span class="sourceLineNo">045</span>    public void write(Cell cell) throws IOException {<a name="line.45"></a>
+<span class="sourceLineNo">046</span>      checkFlushed();<a name="line.46"></a>
+<span class="sourceLineNo">047</span>      CellProtos.Cell.Builder builder = CellProtos.Cell.newBuilder();<a name="line.47"></a>
+<span class="sourceLineNo">048</span>      // This copies bytes from Cell to ByteString.  I don't see anyway around the copy.<a name="line.48"></a>
+<span class="sourceLineNo">049</span>      // ByteString is final.<a name="line.49"></a>
+<span class="sourceLineNo">050</span>      builder.setRow(ByteStringer.wrap(cell.getRowArray(), cell.getRowOffset(),<a name="line.50"></a>
+<span class="sourceLineNo">051</span>          cell.getRowLength()));<a name="line.51"></a>
+<span class="sourceLineNo">052</span>      builder.setFamily(ByteStringer.wrap(cell.getFamilyArray(), cell.getFamilyOffset(),<a name="line.52"></a>
+<span class="sourceLineNo">053</span>          cell.getFamilyLength()));<a name="line.53"></a>
+<span class="sourceLineNo">054</span>      builder.setQualifier(ByteStringer.wrap(cell.getQualifierArray(),<a name="line.54"></a>
+<span class="sourceLineNo">055</span>          cell.getQualifierOffset(), cell.getQualifierLength()));<a name="line.55"></a>
+<span class="sourceLineNo">056</span>      builder.setTimestamp(cell.getTimestamp());<a name="line.56"></a>
+<span class="sourceLineNo">057</span>      builder.setCellType(CellProtos.CellType.valueOf(cell.getTypeByte()));<a name="line.57"></a>
+<span class="sourceLineNo">058</span>      builder.setValue(ByteStringer.wrap(cell.getValueArray(), cell.getValueOffset(),<a name="line.58"></a>
+<span class="sourceLineNo">059</span>          cell.getValueLength()));<a name="line.59"></a>
+<span class="sourceLineNo">060</span>      CellProtos.Cell pbcell = builder.build();<a name="line.60"></a>
+<span class="sourceLineNo">061</span>      pbcell.writeDelimitedTo(this.out);<a name="line.61"></a>
+<span class="sourceLineNo">062</span>    }<a name="line.62"></a>
+<span class="sourceLineNo">063</span>  }<a name="line.63"></a>
+<span class="sourceLineNo">064</span><a name="line.64"></a>
+<span class="sourceLineNo">065</span>  static class MessageDecoder extends BaseDecoder {<a name="line.65"></a>
+<span class="sourceLineNo">066</span>    MessageDecoder(final InputStream in) {<a name="line.66"></a>
+<span class="sourceLineNo">067</span>      super(in);<a name="line.67"></a>
+<span class="sourceLineNo">068</span>    }<a name="line.68"></a>
+<span class="sourceLineNo">069</span><a name="line.69"></a>
+<span class="sourceLineNo">070</span>    protected Cell parseCell() throws IOException {<a name="line.70"></a>
+<span class="sourceLineNo">071</span>      CellProtos.Cell pbcell = CellProtos.Cell.parseDelimitedFrom(this.in);<a name="line.71"></a>
+<span class="sourceLineNo">072</span>      return CellUtil.createCell(pbcell.getRow().toByteArray(),<a name="line.72"></a>
+<span class="sourceLineNo">073</span>        pbcell.getFamily().toByteArray(), pbcell.getQualifier().toByteArray(),<a name="line.73"></a>
+<span class="sourceLineNo">074</span>        pbcell.getTimestamp(), (byte)pbcell.getCellType().getNumber(),<a name="line.74"></a>
+<span class="sourceLineNo">075</span>        pbcell.getValue().toByteArray());<a name="line.75"></a>
+<span class="sourceLineNo">076</span>    }<a name="line.76"></a>
+<span class="sourceLineNo">077</span>  }<a name="line.77"></a>
+<span class="sourceLineNo">078</span><a name="line.78"></a>
+<span class="sourceLineNo">079</span>  @Override<a name="line.79"></a>
+<span class="sourceLineNo">080</span>  public Decoder getDecoder(InputStream is) {<a name="line.80"></a>
+<span class="sourceLineNo">081</span>    return new MessageDecoder(is);<a name="line.81"></a>
+<span class="sourceLineNo">082</span>  }<a name="line.82"></a>
+<span class="sourceLineNo">083</span><a name="line.83"></a>
+<span class="sourceLineNo">084</span>  @Override<a name="line.84"></a>
+<span class="sourceLineNo">085</span>  public Decoder getDecoder(ByteBuffer buf) {<a name="line.85"></a>
+<span class="sourceLineNo">086</span>    return getDecoder(new ByteBufferInputStream(buf));<a name="line.86"></a>
+<span class="sourceLineNo">087</span>  }<a name="line.87"></a>
+<span class="sourceLineNo">088</span><a name="line.88"></a>
+<span class="sourceLineNo">089</span>  @Override<a name="line.89"></a>
+<span class="sourceLineNo">090</span>  public Encoder getEncoder(OutputStream os) {<a name="line.90"></a>
+<span class="sourceLineNo">091</span>    return new MessageEncoder(os);<a name="line.91"></a>
+<span class="sourceLineNo">092</span>  }<a name="line.92"></a>
+<span class="sourceLineNo">093</span>}<a name="line.93"></a>
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0b785cb2/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.MessageEncoder.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.MessageEncoder.html b/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.MessageEncoder.html
index 6359ce9..39ba4a2 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.MessageEncoder.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.MessageEncoder.html
@@ -28,70 +28,77 @@
 <span class="sourceLineNo">020</span>import java.io.IOException;<a name="line.20"></a>
 <span class="sourceLineNo">021</span>import java.io.InputStream;<a name="line.21"></a>
 <span class="sourceLineNo">022</span>import java.io.OutputStream;<a name="line.22"></a>
-<span class="sourceLineNo">023</span><a name="line.23"></a>
-<span class="sourceLineNo">024</span>import org.apache.hadoop.hbase.util.ByteStringer;<a name="line.24"></a>
-<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.classification.InterfaceAudience;<a name="line.25"></a>
-<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.Cell;<a name="line.26"></a>
-<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.CellUtil;<a name="line.27"></a>
-<span class="sourceLineNo">028</span>import org.apache.hadoop.hbase.HBaseInterfaceAudience;<a name="line.28"></a>
-<span class="sourceLineNo">029</span>import org.apache.hadoop.hbase.protobuf.generated.CellProtos;<a name="line.29"></a>
-<span class="sourceLineNo">030</span><a name="line.30"></a>
-<span class="sourceLineNo">031</span>/**<a name="line.31"></a>
-<span class="sourceLineNo">032</span> * Codec that just writes out Cell as a protobuf Cell Message.  Does not write the mvcc stamp.<a name="line.32"></a>
-<span class="sourceLineNo">033</span> * Use a different codec if you want that in the stream.<a name="line.33"></a>
-<span class="sourceLineNo">034</span> */<a name="line.34"></a>
-<span class="sourceLineNo">035</span>@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)<a name="line.35"></a>
-<span class="sourceLineNo">036</span>public class MessageCodec implements Codec {<a name="line.36"></a>
-<span class="sourceLineNo">037</span>  static class MessageEncoder extends BaseEncoder {<a name="line.37"></a>
-<span class="sourceLineNo">038</span>    MessageEncoder(final OutputStream out) {<a name="line.38"></a>
-<span class="sourceLineNo">039</span>      super(out);<a name="line.39"></a>
-<span class="sourceLineNo">040</span>    }<a name="line.40"></a>
-<span class="sourceLineNo">041</span><a name="line.41"></a>
-<span class="sourceLineNo">042</span>    @Override<a name="line.42"></a>
-<span class="sourceLineNo">043</span>    public void write(Cell cell) throws IOException {<a name="line.43"></a>
-<span class="sourceLineNo">044</span>      checkFlushed();<a name="line.44"></a>
-<span class="sourceLineNo">045</span>      CellProtos.Cell.Builder builder = CellProtos.Cell.newBuilder();<a name="line.45"></a>
-<span class="sourceLineNo">046</span>      // This copies bytes from Cell to ByteString.  I don't see anyway around the copy.<a name="line.46"></a>
-<span class="sourceLineNo">047</span>      // ByteString is final.<a name="line.47"></a>
-<span class="sourceLineNo">048</span>      builder.setRow(ByteStringer.wrap(cell.getRowArray(), cell.getRowOffset(),<a name="line.48"></a>
-<span class="sourceLineNo">049</span>          cell.getRowLength()));<a name="line.49"></a>
-<span class="sourceLineNo">050</span>      builder.setFamily(ByteStringer.wrap(cell.getFamilyArray(), cell.getFamilyOffset(),<a name="line.50"></a>
-<span class="sourceLineNo">051</span>          cell.getFamilyLength()));<a name="line.51"></a>
-<span class="sourceLineNo">052</span>      builder.setQualifier(ByteStringer.wrap(cell.getQualifierArray(),<a name="line.52"></a>
-<span class="sourceLineNo">053</span>          cell.getQualifierOffset(), cell.getQualifierLength()));<a name="line.53"></a>
-<span class="sourceLineNo">054</span>      builder.setTimestamp(cell.getTimestamp());<a name="line.54"></a>
-<span class="sourceLineNo">055</span>      builder.setCellType(CellProtos.CellType.valueOf(cell.getTypeByte()));<a name="line.55"></a>
-<span class="sourceLineNo">056</span>      builder.setValue(ByteStringer.wrap(cell.getValueArray(), cell.getValueOffset(),<a name="line.56"></a>
-<span class="sourceLineNo">057</span>          cell.getValueLength()));<a name="line.57"></a>
-<span class="sourceLineNo">058</span>      CellProtos.Cell pbcell = builder.build();<a name="line.58"></a>
-<span class="sourceLineNo">059</span>      pbcell.writeDelimitedTo(this.out);<a name="line.59"></a>
-<span class="sourceLineNo">060</span>    }<a name="line.60"></a>
-<span class="sourceLineNo">061</span>  }<a name="line.61"></a>
-<span class="sourceLineNo">062</span><a name="line.62"></a>
-<span class="sourceLineNo">063</span>  static class MessageDecoder extends BaseDecoder {<a name="line.63"></a>
-<span class="sourceLineNo">064</span>    MessageDecoder(final InputStream in) {<a name="line.64"></a>
-<span class="sourceLineNo">065</span>      super(in);<a name="line.65"></a>
-<span class="sourceLineNo">066</span>    }<a name="line.66"></a>
-<span class="sourceLineNo">067</span><a name="line.67"></a>
-<span class="sourceLineNo">068</span>    protected Cell parseCell() throws IOException {<a name="line.68"></a>
-<span class="sourceLineNo">069</span>      CellProtos.Cell pbcell = CellProtos.Cell.parseDelimitedFrom(this.in);<a name="line.69"></a>
-<span class="sourceLineNo">070</span>      return CellUtil.createCell(pbcell.getRow().toByteArray(),<a name="line.70"></a>
-<span class="sourceLineNo">071</span>        pbcell.getFamily().toByteArray(), pbcell.getQualifier().toByteArray(),<a name="line.71"></a>
-<span class="sourceLineNo">072</span>        pbcell.getTimestamp(), (byte)pbcell.getCellType().getNumber(),<a name="line.72"></a>
-<span class="sourceLineNo">073</span>        pbcell.getValue().toByteArray());<a name="line.73"></a>
-<span class="sourceLineNo">074</span>    }<a name="line.74"></a>
-<span class="sourceLineNo">075</span>  }<a name="line.75"></a>
-<span class="sourceLineNo">076</span><a name="line.76"></a>
-<span class="sourceLineNo">077</span>  @Override<a name="line.77"></a>
-<span class="sourceLineNo">078</span>  public Decoder getDecoder(InputStream is) {<a name="line.78"></a>
-<span class="sourceLineNo">079</span>    return new MessageDecoder(is);<a name="line.79"></a>
-<span class="sourceLineNo">080</span>  }<a name="line.80"></a>
-<span class="sourceLineNo">081</span><a name="line.81"></a>
-<span class="sourceLineNo">082</span>  @Override<a name="line.82"></a>
-<span class="sourceLineNo">083</span>  public Encoder getEncoder(OutputStream os) {<a name="line.83"></a>
-<span class="sourceLineNo">084</span>    return new MessageEncoder(os);<a name="line.84"></a>
-<span class="sourceLineNo">085</span>  }<a name="line.85"></a>
-<span class="sourceLineNo">086</span>}<a name="line.86"></a>
+<span class="sourceLineNo">023</span>import java.nio.ByteBuffer;<a name="line.23"></a>
+<span class="sourceLineNo">024</span><a name="line.24"></a>
+<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.util.ByteStringer;<a name="line.25"></a>
+<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.classification.InterfaceAudience;<a name="line.26"></a>
+<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.io.ByteBufferInputStream;<a name="line.27"></a>
+<span class="sourceLineNo">028</span>import org.apache.hadoop.hbase.Cell;<a name="line.28"></a>
+<span class="sourceLineNo">029</span>import org.apache.hadoop.hbase.CellUtil;<a name="line.29"></a>
+<span class="sourceLineNo">030</span>import org.apache.hadoop.hbase.HBaseInterfaceAudience;<a name="line.30"></a>
+<span class="sourceLineNo">031</span>import org.apache.hadoop.hbase.protobuf.generated.CellProtos;<a name="line.31"></a>
+<span class="sourceLineNo">032</span><a name="line.32"></a>
+<span class="sourceLineNo">033</span>/**<a name="line.33"></a>
+<span class="sourceLineNo">034</span> * Codec that just writes out Cell as a protobuf Cell Message.  Does not write the mvcc stamp.<a name="line.34"></a>
+<span class="sourceLineNo">035</span> * Use a different codec if you want that in the stream.<a name="line.35"></a>
+<span class="sourceLineNo">036</span> */<a name="line.36"></a>
+<span class="sourceLineNo">037</span>@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)<a name="line.37"></a>
+<span class="sourceLineNo">038</span>public class MessageCodec implements Codec {<a name="line.38"></a>
+<span class="sourceLineNo">039</span>  static class MessageEncoder extends BaseEncoder {<a name="line.39"></a>
+<span class="sourceLineNo">040</span>    MessageEncoder(final OutputStream out) {<a name="line.40"></a>
+<span class="sourceLineNo">041</span>      super(out);<a name="line.41"></a>
+<span class="sourceLineNo">042</span>    }<a name="line.42"></a>
+<span class="sourceLineNo">043</span><a name="line.43"></a>
+<span class="sourceLineNo">044</span>    @Override<a name="line.44"></a>
+<span class="sourceLineNo">045</span>    public void write(Cell cell) throws IOException {<a name="line.45"></a>
+<span class="sourceLineNo">046</span>      checkFlushed();<a name="line.46"></a>
+<span class="sourceLineNo">047</span>      CellProtos.Cell.Builder builder = CellProtos.Cell.newBuilder();<a name="line.47"></a>
+<span class="sourceLineNo">048</span>      // This copies bytes from Cell to ByteString.  I don't see anyway around the copy.<a name="line.48"></a>
+<span class="sourceLineNo">049</span>      // ByteString is final.<a name="line.49"></a>
+<span class="sourceLineNo">050</span>      builder.setRow(ByteStringer.wrap(cell.getRowArray(), cell.getRowOffset(),<a name="line.50"></a>
+<span class="sourceLineNo">051</span>          cell.getRowLength()));<a name="line.51"></a>
+<span class="sourceLineNo">052</span>      builder.setFamily(ByteStringer.wrap(cell.getFamilyArray(), cell.getFamilyOffset(),<a name="line.52"></a>
+<span class="sourceLineNo">053</span>          cell.getFamilyLength()));<a name="line.53"></a>
+<span class="sourceLineNo">054</span>      builder.setQualifier(ByteStringer.wrap(cell.getQualifierArray(),<a name="line.54"></a>
+<span class="sourceLineNo">055</span>          cell.getQualifierOffset(), cell.getQualifierLength()));<a name="line.55"></a>
+<span class="sourceLineNo">056</span>      builder.setTimestamp(cell.getTimestamp());<a name="line.56"></a>
+<span class="sourceLineNo">057</span>      builder.setCellType(CellProtos.CellType.valueOf(cell.getTypeByte()));<a name="line.57"></a>
+<span class="sourceLineNo">058</span>      builder.setValue(ByteStringer.wrap(cell.getValueArray(), cell.getValueOffset(),<a name="line.58"></a>
+<span class="sourceLineNo">059</span>          cell.getValueLength()));<a name="line.59"></a>
+<span class="sourceLineNo">060</span>      CellProtos.Cell pbcell = builder.build();<a name="line.60"></a>
+<span class="sourceLineNo">061</span>      pbcell.writeDelimitedTo(this.out);<a name="line.61"></a>
+<span class="sourceLineNo">062</span>    }<a name="line.62"></a>
+<span class="sourceLineNo">063</span>  }<a name="line.63"></a>
+<span class="sourceLineNo">064</span><a name="line.64"></a>
+<span class="sourceLineNo">065</span>  static class MessageDecoder extends BaseDecoder {<a name="line.65"></a>
+<span class="sourceLineNo">066</span>    MessageDecoder(final InputStream in) {<a name="line.66"></a>
+<span class="sourceLineNo">067</span>      super(in);<a name="line.67"></a>
+<span class="sourceLineNo">068</span>    }<a name="line.68"></a>
+<span class="sourceLineNo">069</span><a name="line.69"></a>
+<span class="sourceLineNo">070</span>    protected Cell parseCell() throws IOException {<a name="line.70"></a>
+<span class="sourceLineNo">071</span>      CellProtos.Cell pbcell = CellProtos.Cell.parseDelimitedFrom(this.in);<a name="line.71"></a>
+<span class="sourceLineNo">072</span>      return CellUtil.createCell(pbcell.getRow().toByteArray(),<a name="line.72"></a>
+<span class="sourceLineNo">073</span>        pbcell.getFamily().toByteArray(), pbcell.getQualifier().toByteArray(),<a name="line.73"></a>
+<span class="sourceLineNo">074</span>        pbcell.getTimestamp(), (byte)pbcell.getCellType().getNumber(),<a name="line.74"></a>
+<span class="sourceLineNo">075</span>        pbcell.getValue().toByteArray());<a name="line.75"></a>
+<span class="sourceLineNo">076</span>    }<a name="line.76"></a>
+<span class="sourceLineNo">077</span>  }<a name="line.77"></a>
+<span class="sourceLineNo">078</span><a name="line.78"></a>
+<span class="sourceLineNo">079</span>  @Override<a name="line.79"></a>
+<span class="sourceLineNo">080</span>  public Decoder getDecoder(InputStream is) {<a name="line.80"></a>
+<span class="sourceLineNo">081</span>    return new MessageDecoder(is);<a name="line.81"></a>
+<span class="sourceLineNo">082</span>  }<a name="line.82"></a>
+<span class="sourceLineNo">083</span><a name="line.83"></a>
+<span class="sourceLineNo">084</span>  @Override<a name="line.84"></a>
+<span class="sourceLineNo">085</span>  public Decoder getDecoder(ByteBuffer buf) {<a name="line.85"></a>
+<span class="sourceLineNo">086</span>    return getDecoder(new ByteBufferInputStream(buf));<a name="line.86"></a>
+<span class="sourceLineNo">087</span>  }<a name="line.87"></a>
+<span class="sourceLineNo">088</span><a name="line.88"></a>
+<span class="sourceLineNo">089</span>  @Override<a name="line.89"></a>
+<span class="sourceLineNo">090</span>  public Encoder getEncoder(OutputStream os) {<a name="line.90"></a>
+<span class="sourceLineNo">091</span>    return new MessageEncoder(os);<a name="line.91"></a>
+<span class="sourceLineNo">092</span>  }<a name="line.92"></a>
+<span class="sourceLineNo">093</span>}<a name="line.93"></a>
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0b785cb2/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.html
----------------------------------------------------------------------
diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.html b/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.html
index 6359ce9..39ba4a2 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/codec/MessageCodec.html
@@ -28,70 +28,77 @@
 <span class="sourceLineNo">020</span>import java.io.IOException;<a name="line.20"></a>
 <span class="sourceLineNo">021</span>import java.io.InputStream;<a name="line.21"></a>
 <span class="sourceLineNo">022</span>import java.io.OutputStream;<a name="line.22"></a>
-<span class="sourceLineNo">023</span><a name="line.23"></a>
-<span class="sourceLineNo">024</span>import org.apache.hadoop.hbase.util.ByteStringer;<a name="line.24"></a>
-<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.classification.InterfaceAudience;<a name="line.25"></a>
-<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.Cell;<a name="line.26"></a>
-<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.CellUtil;<a name="line.27"></a>
-<span class="sourceLineNo">028</span>import org.apache.hadoop.hbase.HBaseInterfaceAudience;<a name="line.28"></a>
-<span class="sourceLineNo">029</span>import org.apache.hadoop.hbase.protobuf.generated.CellProtos;<a name="line.29"></a>
-<span class="sourceLineNo">030</span><a name="line.30"></a>
-<span class="sourceLineNo">031</span>/**<a name="line.31"></a>
-<span class="sourceLineNo">032</span> * Codec that just writes out Cell as a protobuf Cell Message.  Does not write the mvcc stamp.<a name="line.32"></a>
-<span class="sourceLineNo">033</span> * Use a different codec if you want that in the stream.<a name="line.33"></a>
-<span class="sourceLineNo">034</span> */<a name="line.34"></a>
-<span class="sourceLineNo">035</span>@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)<a name="line.35"></a>
-<span class="sourceLineNo">036</span>public class MessageCodec implements Codec {<a name="line.36"></a>
-<span class="sourceLineNo">037</span>  static class MessageEncoder extends BaseEncoder {<a name="line.37"></a>
-<span class="sourceLineNo">038</span>    MessageEncoder(final OutputStream out) {<a name="line.38"></a>
-<span class="sourceLineNo">039</span>      super(out);<a name="line.39"></a>
-<span class="sourceLineNo">040</span>    }<a name="line.40"></a>
-<span class="sourceLineNo">041</span><a name="line.41"></a>
-<span class="sourceLineNo">042</span>    @Override<a name="line.42"></a>
-<span class="sourceLineNo">043</span>    public void write(Cell cell) throws IOException {<a name="line.43"></a>
-<span class="sourceLineNo">044</span>      checkFlushed();<a name="line.44"></a>
-<span class="sourceLineNo">045</span>      CellProtos.Cell.Builder builder = CellProtos.Cell.newBuilder();<a name="line.45"></a>
-<span class="sourceLineNo">046</span>      // This copies bytes from Cell to ByteString.  I don't see anyway around the copy.<a name="line.46"></a>
-<span class="sourceLineNo">047</span>      // ByteString is final.<a name="line.47"></a>
-<span class="sourceLineNo">048</span>      builder.setRow(ByteStringer.wrap(cell.getRowArray(), cell.getRowOffset(),<a name="line.48"></a>
-<span class="sourceLineNo">049</span>          cell.getRowLength()));<a name="line.49"></a>
-<span class="sourceLineNo">050</span>      builder.setFamily(ByteStringer.wrap(cell.getFamilyArray(), cell.getFamilyOffset(),<a name="line.50"></a>
-<span class="sourceLineNo">051</span>          cell.getFamilyLength()));<a name="line.51"></a>
-<span class="sourceLineNo">052</span>      builder.setQualifier(ByteStringer.wrap(cell.getQualifierArray(),<a name="line.52"></a>
-<span class="sourceLineNo">053</span>          cell.getQualifierOffset(), cell.getQualifierLength()));<a name="line.53"></a>
-<span class="sourceLineNo">054</span>      builder.setTimestamp(cell.getTimestamp());<a name="line.54"></a>
-<span class="sourceLineNo">055</span>      builder.setCellType(CellProtos.CellType.valueOf(cell.getTypeByte()));<a name="line.55"></a>
-<span class="sourceLineNo">056</span>      builder.setValue(ByteStringer.wrap(cell.getValueArray(), cell.getValueOffset(),<a name="line.56"></a>
-<span class="sourceLineNo">057</span>          cell.getValueLength()));<a name="line.57"></a>
-<span class="sourceLineNo">058</span>      CellProtos.Cell pbcell = builder.build();<a name="line.58"></a>
-<span class="sourceLineNo">059</span>      pbcell.writeDelimitedTo(this.out);<a name="line.59"></a>
-<span class="sourceLineNo">060</span>    }<a name="line.60"></a>
-<span class="sourceLineNo">061</span>  }<a name="line.61"></a>
-<span class="sourceLineNo">062</span><a name="line.62"></a>
-<span class="sourceLineNo">063</span>  static class MessageDecoder extends BaseDecoder {<a name="line.63"></a>
-<span class="sourceLineNo">064</span>    MessageDecoder(final InputStream in) {<a name="line.64"></a>
-<span class="sourceLineNo">065</span>      super(in);<a name="line.65"></a>
-<span class="sourceLineNo">066</span>    }<a name="line.66"></a>
-<span class="sourceLineNo">067</span><a name="line.67"></a>
-<span class="sourceLineNo">068</span>    protected Cell parseCell() throws IOException {<a name="line.68"></a>
-<span class="sourceLineNo">069</span>      CellProtos.Cell pbcell = CellProtos.Cell.parseDelimitedFrom(this.in);<a name="line.69"></a>
-<span class="sourceLineNo">070</span>      return CellUtil.createCell(pbcell.getRow().toByteArray(),<a name="line.70"></a>
-<span class="sourceLineNo">071</span>        pbcell.getFamily().toByteArray(), pbcell.getQualifier().toByteArray(),<a name="line.71"></a>
-<span class="sourceLineNo">072</span>        pbcell.getTimestamp(), (byte)pbcell.getCellType().getNumber(),<a name="line.72"></a>
-<span class="sourceLineNo">073</span>        pbcell.getValue().toByteArray());<a name="line.73"></a>
-<span class="sourceLineNo">074</span>    }<a name="line.74"></a>
-<span class="sourceLineNo">075</span>  }<a name="line.75"></a>
-<span class="sourceLineNo">076</span><a name="line.76"></a>
-<span class="sourceLineNo">077</span>  @Override<a name="line.77"></a>
-<span class="sourceLineNo">078</span>  public Decoder getDecoder(InputStream is) {<a name="line.78"></a>
-<span class="sourceLineNo">079</span>    return new MessageDecoder(is);<a name="line.79"></a>
-<span class="sourceLineNo">080</span>  }<a name="line.80"></a>
-<span class="sourceLineNo">081</span><a name="line.81"></a>
-<span class="sourceLineNo">082</span>  @Override<a name="line.82"></a>
-<span class="sourceLineNo">083</span>  public Encoder getEncoder(OutputStream os) {<a name="line.83"></a>
-<span class="sourceLineNo">084</span>    return new MessageEncoder(os);<a name="line.84"></a>
-<span class="sourceLineNo">085</span>  }<a name="line.85"></a>
-<span class="sourceLineNo">086</span>}<a name="line.86"></a>
+<span class="sourceLineNo">023</span>import java.nio.ByteBuffer;<a name="line.23"></a>
+<span class="sourceLineNo">024</span><a name="line.24"></a>
+<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.util.ByteStringer;<a name="line.25"></a>
+<span class="sourceLineNo">026</span>import org.apache.hadoop.hbase.classification.InterfaceAudience;<a name="line.26"></a>
+<span class="sourceLineNo">027</span>import org.apache.hadoop.hbase.io.ByteBufferInputStream;<a name="line.27"></a>
+<span class="sourceLineNo">028</span>import org.apache.hadoop.hbase.Cell;<a name="line.28"></a>
+<span class="sourceLineNo">029</span>import org.apache.hadoop.hbase.CellUtil;<a name="line.29"></a>
+<span class="sourceLineNo">030</span>import org.apache.hadoop.hbase.HBaseInterfaceAudience;<a name="line.30"></a>
+<span class="sourceLineNo">031</span>import org.apache.hadoop.hbase.protobuf.generated.CellProtos;<a name="line.31"></a>
+<span class="sourceLineNo">032</span><a name="line.32"></a>
+<span class="sourceLineNo">033</span>/**<a name="line.33"></a>
+<span class="sourceLineNo">034</span> * Codec that just writes out Cell as a protobuf Cell Message.  Does not write the mvcc stamp.<a name="line.34"></a>
+<span class="sourceLineNo">035</span> * Use a different codec if you want that in the stream.<a name="line.35"></a>
+<span class="sourceLineNo">036</span> */<a name="line.36"></a>
+<span class="sourceLineNo">037</span>@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)<a name="line.37"></a>
+<span class="sourceLineNo">038</span>public class MessageCodec implements Codec {<a name="line.38"></a>
+<span class="sourceLineNo">039</span>  static class MessageEncoder extends BaseEncoder {<a name="line.39"></a>
+<span class="sourceLineNo">040</span>    MessageEncoder(final OutputStream out) {<a name="line.40"></a>
+<span class="sourceLineNo">041</span>      super(out);<a name="line.41"></a>
+<span class="sourceLineNo">042</span>    }<a name="line.42"></a>
+<span class="sourceLineNo">043</span><a name="line.43"></a>
+<span class="sourceLineNo">044</span>    @Override<a name="line.44"></a>
+<span class="sourceLineNo">045</span>    public void write(Cell cell) throws IOException {<a name="line.45"></a>
+<span class="sourceLineNo">046</span>      checkFlushed();<a name="line.46"></a>
+<span class="sourceLineNo">047</span>      CellProtos.Cell.Builder builder = CellProtos.Cell.newBuilder();<a name="line.47"></a>
+<span class="sourceLineNo">048</span>      // This copies bytes from Cell to ByteString.  I don't see anyway around the copy.<a name="line.48"></a>
+<span class="sourceLineNo">049</span>      // ByteString is final.<a name="line.49"></a>
+<span class="sourceLineNo">050</span>      builder.setRow(ByteStringer.wrap(cell.getRowArray(), cell.getRowOffset(),<a name="line.50"></a>
+<span class="sourceLineNo">051</span>          cell.getRowLength()));<a name="line.51"></a>
+<span class="sourceLineNo">052</span>      builder.setFamily(ByteStringer.wrap(cell.getFamilyArray(), cell.getFamilyOffset(),<a name="line.52"></a>
+<span class="sourceLineNo">053</span>          cell.getFamilyLength()));<a name="line.53"></a>
+<span class="sourceLineNo">054</span>      builder.setQualifier(ByteStringer.wrap(cell.getQualifierArray(),<a name="line.54"></a>
+<span class="sourceLineNo">055</span>          cell.getQualifierOffset(), cell.getQualifierLength()));<a name="line.55"></a>
+<span class="sourceLineNo">056</span>      builder.setTimestamp(cell.getTimestamp());<a name="line.56"></a>
+<span class="sourceLineNo">057</span>      builder.setCellType(CellProtos.CellType.valueOf(cell.getTypeByte()));<a name="line.57"></a>
+<span class="sourceLineNo">058</span>      builder.setValue(ByteStringer.wrap(cell.getValueArray(), cell.getValueOffset(),<a name="line.58"></a>
+<span class="sourceLineNo">059</span>          cell.getValueLength()));<a name="line.59"></a>
+<span class="sourceLineNo">060</span>      CellProtos.Cell pbcell = builder.build();<a name="line.60"></a>
+<span class="sourceLineNo">061</span>      pbcell.writeDelimitedTo(this.out);<a name="line.61"></a>
+<span class="sourceLineNo">062</span>    }<a name="line.62"></a>
+<span class="sourceLineNo">063</span>  }<a name="line.63"></a>
+<span class="sourceLineNo">064</span><a name="line.64"></a>
+<span class="sourceLineNo">065</span>  static class MessageDecoder extends BaseDecoder {<a name="line.65"></a>
+<span class="sourceLineNo">066</span>    MessageDecoder(final InputStream in) {<a name="line.66"></a>
+<span class="sourceLineNo">067</span>      super(in);<a name="line.67"></a>
+<span class="sourceLineNo">068</span>    }<a name="line.68"></a>
+<span class="sourceLineNo">069</span><a name="line.69"></a>
+<span class="sourceLineNo">070</span>    protected Cell parseCell() throws IOException {<a name="line.70"></a>
+<span class="sourceLineNo">071</span>      CellProtos.Cell pbcell = CellProtos.Cell.parseDelimitedFrom(this.in);<a name="line.71"></a>
+<span class="sourceLineNo">072</span>      return CellUtil.createCell(pbcell.getRow().toByteArray(),<a name="line.72"></a>
+<span class="sourceLineNo">073</span>        pbcell.getFamily().toByteArray(), pbcell.getQualifier().toByteArray(),<a name="line.73"></a>
+<span class="sourceLineNo">074</span>        pbcell.getTimestamp(), (byte)pbcell.getCellType().getNumber(),<a name="line.74"></a>
+<span class="sourceLineNo">075</span>        pbcell.getValue().toByteArray());<a name="line.75"></a>
+<span class="sourceLineNo">076</span>    }<a name="line.76"></a>
+<span class="sourceLineNo">077</span>  }<a name="line.77"></a>
+<span class="sourceLineNo">078</span><a name="line.78"></a>
+<span class="sourceLineNo">079</span>  @Override<a name="line.79"></a>
+<span class="sourceLineNo">080</span>  public Decoder getDecoder(InputStream is) {<a name="line.80"></a>
+<span class="sourceLineNo">081</span>    return new MessageDecoder(is);<a name="line.81"></a>
+<span class="sourceLineNo">082</span>  }<a name="line.82"></a>
+<span class="sourceLineNo">083</span><a name="line.83"></a>
+<span class="sourceLineNo">084</span>  @Override<a name="line.84"></a>
+<span class="sourceLineNo">085</span>  public Decoder getDecoder(ByteBuffer buf) {<a name="line.85"></a>
+<span class="sourceLineNo">086</span>    return getDecoder(new ByteBufferInputStream(buf));<a name="line.86"></a>
+<span class="sourceLineNo">087</span>  }<a name="line.87"></a>
+<span class="sourceLineNo">088</span><a name="line.88"></a>
+<span class="sourceLineNo">089</span>  @Override<a name="line.89"></a>
+<span class="sourceLineNo">090</span>  public Encoder getEncoder(OutputStream os) {<a name="line.90"></a>
+<span class="sourceLineNo">091</span>    return new MessageEncoder(os);<a name="line.91"></a>
+<span class="sourceLineNo">092</span>  }<a name="line.92"></a>
+<span class="sourceLineNo">093</span>}<a name="line.93"></a>
 
 
 


Mime
View raw message