Skip to content

Commit b911deb

Browse files
committed
HBASE-22890 Verify the file integrity in persistent IOEngine
1 parent 8a5a6aa commit b911deb

File tree

2 files changed

+20
-2
lines changed

2 files changed

+20
-2
lines changed

hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/FileIOEngine.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@
4545
* IO engine that stores data to a file on the local file system.
4646
*/
4747
@InterfaceAudience.Private
48-
public class FileIOEngine implements IOEngine, PersistentIOEngine {
48+
public class FileIOEngine implements PersistentIOEngine {
4949
private static final Log LOG = LogFactory.getLog(FileIOEngine.class);
5050
public static final String FILE_DELIMITER = ",";
5151
private static final DuFileCommand du = new DuFileCommand(new String[] {"du", ""});

hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/PersistentIOEngine.java

Lines changed: 19 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,21 @@
1+
/**
2+
* Copyright The Apache Software Foundation
3+
*
4+
* Licensed to the Apache Software Foundation (ASF) under one or more
5+
* contributor license agreements. See the NOTICE file distributed with this
6+
* work for additional information regarding copyright ownership. The ASF
7+
* licenses this file to you under the Apache License, Version 2.0 (the
8+
* "License"); you may not use this file except in compliance with the License.
9+
* You may obtain a copy of the License at
10+
*
11+
* http://www.apache.org/licenses/LICENSE-2.0
12+
*
13+
* Unless required by applicable law or agreed to in writing, software
14+
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
15+
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
16+
* License for the specific language governing permissions and limitations
17+
* under the License.
18+
*/
119
package org.apache.hadoop.hbase.io.hfile.bucket;
220

321
import java.io.IOException;
@@ -10,7 +28,7 @@
1028
* for {@link BucketCache}
1129
*/
1230
@InterfaceAudience.Private
13-
public interface PersistentIOEngine {
31+
public interface PersistentIOEngine extends IOEngine {
1432

1533
/**
1634
* Read the persistence checksum from persistence path

0 commit comments

Comments
 (0)