Apache/hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-16070 Mapreduce Serialization classes do not have Interface audience

Browse Source 
(Ram)
This commit is contained in:
Ramkrishna 2016-06-23 10:22:24 +05:30
parent d297ecdf3c
commit c1a559a666
3 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/KeyValueSerialization.java
View File

@ -25,10 +25,14 @@ import java.io.OutputStream;
import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.KeyValueUtil; import org.apache.hadoop.hbase.KeyValueUtil;
import org.apache.hadoop.hbase.classification.InterfaceAudience;
import org.apache.hadoop.hbase.classification.InterfaceStability;
import org.apache.hadoop.io.serializer.Deserializer; import org.apache.hadoop.io.serializer.Deserializer;
import org.apache.hadoop.io.serializer.Serialization; import org.apache.hadoop.io.serializer.Serialization;
import org.apache.hadoop.io.serializer.Serializer; import org.apache.hadoop.io.serializer.Serializer;
@InterfaceAudience.Public
@InterfaceStability.Evolving
public class KeyValueSerialization implements Serialization<KeyValue> { public class KeyValueSerialization implements Serialization<KeyValue> {
@Override @Override
public boolean accept(Class<?> c) { public boolean accept(Class<?> c) {

4
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MutationSerialization.java
View File

@ -21,6 +21,8 @@ import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.io.OutputStream; import java.io.OutputStream;
import org.apache.hadoop.hbase.classification.InterfaceAudience;
import org.apache.hadoop.hbase.classification.InterfaceStability;
import org.apache.hadoop.hbase.client.Delete; import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Mutation; import org.apache.hadoop.hbase.client.Mutation;
import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Put;
@ -31,6 +33,8 @@ import org.apache.hadoop.io.serializer.Deserializer;
import org.apache.hadoop.io.serializer.Serialization; import org.apache.hadoop.io.serializer.Serialization;
import org.apache.hadoop.io.serializer.Serializer; import org.apache.hadoop.io.serializer.Serializer;
@InterfaceAudience.Public
@InterfaceStability.Evolving
public class MutationSerialization implements Serialization<Mutation> { public class MutationSerialization implements Serialization<Mutation> {
@Override @Override
public boolean accept(Class<?> c) { public boolean accept(Class<?> c) {

4
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/ResultSerialization.java
View File

@ -31,6 +31,8 @@ import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.conf.Configured; import org.apache.hadoop.conf.Configured;
import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.classification.InterfaceAudience;
import org.apache.hadoop.hbase.classification.InterfaceStability;
import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.protobuf.ProtobufUtil; import org.apache.hadoop.hbase.protobuf.ProtobufUtil;
import org.apache.hadoop.hbase.protobuf.generated.ClientProtos; import org.apache.hadoop.hbase.protobuf.generated.ClientProtos;
@ -39,6 +41,8 @@ import org.apache.hadoop.io.serializer.Deserializer;
import org.apache.hadoop.io.serializer.Serialization; import org.apache.hadoop.io.serializer.Serialization;
import org.apache.hadoop.io.serializer.Serializer; import org.apache.hadoop.io.serializer.Serializer;
@InterfaceAudience.Public
@InterfaceStability.Evolving
public class ResultSerialization extends Configured implements Serialization<Result> { public class ResultSerialization extends Configured implements Serialization<Result> {
private static final Log LOG = LogFactory.getLog(ResultSerialization.class); private static final Log LOG = LogFactory.getLog(ResultSerialization.class);
// The following configuration property indicates import file format version. // The following configuration property indicates import file format version.