Skip to content

Commit 47c22e3

Browse files
authored
HDFS-16943. RBF: Implements MySQL based StateStoreDriver. (#5469)
1 parent 422bf3b commit 47c22e3

File tree

6 files changed

+541
-1
lines changed

6 files changed

+541
-1
lines changed

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/store/driver/StateStoreDriver.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,8 @@
2020
import java.net.InetAddress;
2121
import java.util.Collection;
2222

23+
import org.apache.hadoop.classification.InterfaceAudience;
24+
import org.apache.hadoop.classification.InterfaceStability;
2325
import org.apache.hadoop.conf.Configuration;
2426
import org.apache.hadoop.hdfs.server.federation.metrics.StateStoreMetrics;
2527
import org.apache.hadoop.hdfs.server.federation.store.StateStoreService;
@@ -35,6 +37,8 @@
3537
* provider. Driver implementations will extend this class and implement some of
3638
* the default methods.
3739
*/
40+
@InterfaceAudience.Public
41+
@InterfaceStability.Evolving
3842
public abstract class StateStoreDriver implements StateStoreRecordOperations {
3943

4044
private static final Logger LOG =

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/store/driver/impl/StateStoreBaseImpl.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,8 @@
2323
import java.util.ArrayList;
2424
import java.util.List;
2525

26+
import org.apache.hadoop.classification.InterfaceAudience;
27+
import org.apache.hadoop.classification.InterfaceStability;
2628
import org.apache.hadoop.hdfs.server.federation.store.StateStoreUtils;
2729
import org.apache.hadoop.hdfs.server.federation.store.driver.StateStoreDriver;
2830
import org.apache.hadoop.hdfs.server.federation.store.records.BaseRecord;
@@ -39,6 +41,8 @@
3941
* optimization, such as custom get/put/remove queries, depending on the
4042
* capabilities of the data store.
4143
*/
44+
@InterfaceAudience.Public
45+
@InterfaceStability.Evolving
4246
public abstract class StateStoreBaseImpl extends StateStoreDriver {
4347

4448
@Override

0 commit comments

Comments
 (0)