From cf72293a1e6a60549c99cec9ad11877f525f3468 Mon Sep 17 00:00:00 2001 From: marsishandsome Date: Fri, 15 Oct 2021 11:54:04 +0800 Subject: [PATCH] add Serializable for BackupDecoder Signed-off-by: marsishandsome --- src/main/java/org/tikv/br/BackupDecoder.java | 3 ++- src/main/java/org/tikv/br/KVDecoder.java | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) 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);