You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by mi...@apache.org on 2015/12/15 20:46:08 UTC
hbase git commit: HBASE-14830 Make encoding classes
@InterfaceAudience.Private
Repository: hbase
Updated Branches:
refs/heads/0.94 509131608 -> 0f35a32ab
HBASE-14830 Make encoding classes @InterfaceAudience.Private
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/0f35a32a
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/0f35a32a
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/0f35a32a
Branch: refs/heads/0.94
Commit: 0f35a32ab123ee299f4aaaea02b4ba2d2b43cff2
Parents: 5091316
Author: Misty Stanley-Jones <ms...@cloudera.com>
Authored: Tue Dec 15 10:30:04 2015 -0800
Committer: Misty Stanley-Jones <ms...@cloudera.com>
Committed: Tue Dec 15 10:30:04 2015 -0800
----------------------------------------------------------------------
.../apache/hadoop/hbase/io/encoding/CopyKeyDataBlockEncoder.java | 3 +++
.../org/apache/hadoop/hbase/io/encoding/DiffKeyDeltaEncoder.java | 3 +++
.../org/apache/hadoop/hbase/io/encoding/FastDiffDeltaEncoder.java | 3 +++
.../apache/hadoop/hbase/io/encoding/PrefixKeyDeltaEncoder.java | 3 +++
4 files changed, 12 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/0f35a32a/src/main/java/org/apache/hadoop/hbase/io/encoding/CopyKeyDataBlockEncoder.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/hbase/io/encoding/CopyKeyDataBlockEncoder.java b/src/main/java/org/apache/hadoop/hbase/io/encoding/CopyKeyDataBlockEncoder.java
index 548985b..e9bebba 100644
--- a/src/main/java/org/apache/hadoop/hbase/io/encoding/CopyKeyDataBlockEncoder.java
+++ b/src/main/java/org/apache/hadoop/hbase/io/encoding/CopyKeyDataBlockEncoder.java
@@ -25,10 +25,13 @@ import org.apache.hadoop.hbase.util.ByteBufferUtils;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.io.RawComparator;
+import org.apache.hadoop.classification.InterfaceAudience;
+
/**
* Just copy data, do not do any kind of compression. Use for comparison and
* benchmarking.
*/
+@InterfaceAudience.Private
public class CopyKeyDataBlockEncoder extends BufferedDataBlockEncoder {
@Override
public void compressKeyValues(DataOutputStream out,
http://git-wip-us.apache.org/repos/asf/hbase/blob/0f35a32a/src/main/java/org/apache/hadoop/hbase/io/encoding/DiffKeyDeltaEncoder.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/hbase/io/encoding/DiffKeyDeltaEncoder.java b/src/main/java/org/apache/hadoop/hbase/io/encoding/DiffKeyDeltaEncoder.java
index 7e51818..4124055 100644
--- a/src/main/java/org/apache/hadoop/hbase/io/encoding/DiffKeyDeltaEncoder.java
+++ b/src/main/java/org/apache/hadoop/hbase/io/encoding/DiffKeyDeltaEncoder.java
@@ -26,6 +26,8 @@ import org.apache.hadoop.hbase.util.ByteBufferUtils;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.io.RawComparator;
+import org.apache.hadoop.classification.InterfaceAudience;
+
/**
* Compress using:
* - store size of common prefix
@@ -47,6 +49,7 @@ import org.apache.hadoop.io.RawComparator;
* - 1 byte: type (only if FLAG_SAME_TYPE is not set in the flag)
* - ... bytes: value
*/
+@InterfaceAudience.Private
public class DiffKeyDeltaEncoder extends BufferedDataBlockEncoder {
static final int FLAG_SAME_KEY_LENGTH = 1;
static final int FLAG_SAME_VALUE_LENGTH = 1 << 1;
http://git-wip-us.apache.org/repos/asf/hbase/blob/0f35a32a/src/main/java/org/apache/hadoop/hbase/io/encoding/FastDiffDeltaEncoder.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/hbase/io/encoding/FastDiffDeltaEncoder.java b/src/main/java/org/apache/hadoop/hbase/io/encoding/FastDiffDeltaEncoder.java
index 7959e0e..534906e 100644
--- a/src/main/java/org/apache/hadoop/hbase/io/encoding/FastDiffDeltaEncoder.java
+++ b/src/main/java/org/apache/hadoop/hbase/io/encoding/FastDiffDeltaEncoder.java
@@ -27,6 +27,8 @@ import org.apache.hadoop.hbase.util.ByteBufferUtils;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.io.RawComparator;
+import org.apache.hadoop.classification.InterfaceAudience;
+
/**
* Encoder similar to {@link DiffKeyDeltaEncoder} but supposedly faster.
*
@@ -52,6 +54,7 @@ import org.apache.hadoop.io.RawComparator;
* - ... bytes: value (only if FLAG_SAME_VALUE is not set in the flag)
*
*/
+@InterfaceAudience.Private
public class FastDiffDeltaEncoder extends BufferedDataBlockEncoder {
final int MASK_TIMESTAMP_LENGTH = (1 << 0) | (1 << 1) | (1 << 2);
final int SHIFT_TIMESTAMP_LENGTH = 0;
http://git-wip-us.apache.org/repos/asf/hbase/blob/0f35a32a/src/main/java/org/apache/hadoop/hbase/io/encoding/PrefixKeyDeltaEncoder.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/hadoop/hbase/io/encoding/PrefixKeyDeltaEncoder.java b/src/main/java/org/apache/hadoop/hbase/io/encoding/PrefixKeyDeltaEncoder.java
index 3e4416f..9e3806d 100644
--- a/src/main/java/org/apache/hadoop/hbase/io/encoding/PrefixKeyDeltaEncoder.java
+++ b/src/main/java/org/apache/hadoop/hbase/io/encoding/PrefixKeyDeltaEncoder.java
@@ -26,6 +26,8 @@ import org.apache.hadoop.hbase.util.ByteBufferUtils;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.hadoop.io.RawComparator;
+import org.apache.hadoop.classification.InterfaceAudience;
+
/**
* Compress key by storing size of common prefix with previous KeyValue
* and storing raw size of rest.
@@ -40,6 +42,7 @@ import org.apache.hadoop.io.RawComparator;
* In a worst case compressed KeyValue will be three bytes longer than original.
*
*/
+@InterfaceAudience.Private
public class PrefixKeyDeltaEncoder extends BufferedDataBlockEncoder {
private int addKV(int prevKeyOffset, DataOutputStream out,