diff --git a/src/main/java/org/tikv/br/BackupDecoder.java b/src/main/java/org/tikv/br/BackupDecoder.java index fb63d63ee46..c36e6194cf7 100644 --- a/src/main/java/org/tikv/br/BackupDecoder.java +++ b/src/main/java/org/tikv/br/BackupDecoder.java @@ -17,12 +17,13 @@ package org.tikv.br; +import java.io.Serializable; import org.rocksdb.Options; import org.rocksdb.ReadOptions; import org.tikv.common.exception.SSTDecodeException; import org.tikv.kvproto.Brpb; -public class BackupDecoder { +public class BackupDecoder implements Serializable { private final Brpb.BackupMeta backupMeta; private final boolean ttlEnabled; private final KVDecoder kvDecoder; diff --git a/src/main/java/org/tikv/br/KVDecoder.java b/src/main/java/org/tikv/br/KVDecoder.java index 1f0b580c1a4..f365c269f34 100644 --- a/src/main/java/org/tikv/br/KVDecoder.java +++ b/src/main/java/org/tikv/br/KVDecoder.java @@ -18,8 +18,9 @@ package org.tikv.br; import com.google.protobuf.ByteString; +import java.io.Serializable; -public interface KVDecoder { +public interface KVDecoder extends Serializable { ByteString decodeKey(byte[] key); ByteString decodeValue(byte[] value);